|
|
@@ -46,9 +46,9 @@ class OfpayDataSyncer:
|
|
|
break;
|
|
|
self.db_conn = db_conn;
|
|
|
|
|
|
- def sync_account(self, filename='results.csv'):
|
|
|
+ def sync_account(self, day=0, filename='results.csv'):
|
|
|
sql_query = f'''
|
|
|
- SELECT * FROM elife_account_data WHERE update_time >= CURDATE() AND update_time < CURDATE() + INTERVAL 1 DAY;
|
|
|
+ SELECT * FROM elife_account_data WHERE update_time >= CURDATE() - {day} AND update_time < CURDATE() + INTERVAL 1 DAY;
|
|
|
''';
|
|
|
cursor = self.db_conn.cursor();
|
|
|
cursor.execute(sql_query);
|
|
|
@@ -154,7 +154,7 @@ def main():
|
|
|
syncer.sync_activities('elife_activities_data.json');
|
|
|
# syncer.read_json('elife_activities_data.json');
|
|
|
|
|
|
- syncer.sync_account('elife_accout_data');
|
|
|
+ syncer.sync_account(1, 'elife_accout_data');
|
|
|
# syncer.read_csv('elife_accout_data.csv');
|
|
|
# syncer.read_json('elife_accout_data.json');
|
|
|
|