|
|
@@ -53,6 +53,10 @@ class OfpayDataSyncer:
|
|
|
cursor = self.db_conn.cursor();
|
|
|
cursor.execute(sql_query);
|
|
|
results = cursor.fetchall();
|
|
|
+ if not results:
|
|
|
+ print('同步用户数据失败');
|
|
|
+ return
|
|
|
+ print(f'同步用户数据成功，记录条数：{len(results)}');
|
|
|
|
|
|
suffix = os.path.splitext(filename)[-1];
|
|
|
if suffix == '.csv' or suffix == '':
|
|
|
@@ -87,6 +91,10 @@ class OfpayDataSyncer:
|
|
|
cursor = self.db_conn.cursor();
|
|
|
cursor.execute(sql_query);
|
|
|
results = cursor.fetchall();
|
|
|
+ if not results:
|
|
|
+ print('同步活动数据失败');
|
|
|
+ return
|
|
|
+ print('同步活动数据进度1/2');
|
|
|
activity_list = [];
|
|
|
activity_dict = {};
|
|
|
column_names = [desc[0] for desc in cursor.description];
|
|
|
@@ -107,6 +115,7 @@ class OfpayDataSyncer:
|
|
|
sql_query = sql_query % repr(tuple(activity_ids));
|
|
|
cursor.execute(sql_query);
|
|
|
aw_results = cursor.fetchall();
|
|
|
+ print('同步活动数据进度2/2');
|
|
|
column_names = [desc[0] for desc in cursor.description];
|
|
|
for row in aw_results:
|
|
|
data_dict = dict(zip(column_names, row));
|
|
|
@@ -126,6 +135,7 @@ class OfpayDataSyncer:
|
|
|
with open(filename, 'w', newline='', encoding='utf-8') as f:
|
|
|
json_str = json.dumps(activity_list, cls=CustomEncoder, ensure_ascii=False);
|
|
|
f.write(json_str);
|
|
|
+ print('同步活动数据成功');
|
|
|
|
|
|
def read_csv(self, filename='results.csv'):
|
|
|
data = []
|
shawenguan