|
|
@@ -182,7 +182,10 @@ def get_yangguang_order_task(st,et,account):
|
|
|
|
|
|
order_item_list = result_data['list']
|
|
|
for order_item in order_item_list:
|
|
|
- if order_item['state'] != '1':
|
|
|
+ try:
|
|
|
+ if int(order_item['state']) != 1:
|
|
|
+ continue
|
|
|
+ except Exception as e:
|
|
|
continue
|
|
|
|
|
|
order = {}
|
|
|
@@ -236,8 +239,8 @@ def start_order_job():
|
|
|
print('订单同步执行时间（秒）：', date_util.getCurrentSecondTime() - start_exec_seconds)
|
|
|
|
|
|
|
|
|
-start_order_job()
|
|
|
-'''
|
|
|
+##start_order_job()
|
|
|
+
|
|
|
start_job_time = '2020-11-03 10:04:00'
|
|
|
if __name__ == '__main__':
|
|
|
scheduler = BlockingScheduler()
|
|
|
@@ -245,4 +248,4 @@ if __name__ == '__main__':
|
|
|
#scheduler.add_job(start_order_job, 'interval',days =1,hours = 2,minutes = 0,seconds = 0)
|
|
|
#线上是24h执行一次
|
|
|
scheduler.start()
|
|
|
-'''
|
|
|
+
|
