上传文件至 'dgp/tests'

dgp/tests/get_order_dairly_qiyue.py

@@ -63,7 +63,7 @@ def get_qiyue_order_task(st,et,account):
     
     order_st_date = date_util.getSelfDateStr(int(st-86400),date_format='%Y-%m-%d')
     for i in range((et-st)//86400 + 1):
-        statis_unix_time = st + (i-1)*86400
+        statis_unix_time = et - (i+1)*86400
         date = date_util.getSelfDateStr(statis_unix_time,date_format='%Y-%m-%d')
 
         while True:
@@ -89,6 +89,9 @@ def get_qiyue_order_task(st,et,account):
             if total <= 0:
                 break
 
+
+            #total = result_data['total']
+            #last_page2 = int(total//size)+1
             last_page = result_data['last_page']
             order_item_list = result_data['data']
             for x in order_item_list: 
@@ -113,10 +116,15 @@ def get_qiyue_order_task(st,et,account):
                 y = dict(y)
                 y = tuple(y.values())
                 order_list = order_list+((y),)
-
+            '''
             if page == last_page:
                 break
             page += 1
+            '''
+            next_page_url = result_data['next_page_url']
+            if next_page_url is None:
+                break
+            page += 1
 
     print(f"数据日期-{order_st_date}到{date}-期数-{stage}-获取数据-{len(order_list)}条，例如: {order_list[0:1]}")
     return order_list
@@ -173,6 +181,7 @@ def start_order_job():
     ## 20201105添加文鼎平台
     st_unix = date_util.getYesterdayStartTime()
     et_unix = date_util.getTodayStartTime()
+    st_unix = et_unix - 60
     account_list = get_qiyue_account_list()
     '''
     ## 2个账户测试看看
@@ -186,18 +195,13 @@ def start_order_job():
 
 
 
-start_job_time = '2020-11-18 02:00:00'
+#start_job_time = '2020-11-20 02:00:00'
 if __name__ == '__main__':
     scheduler = BlockingScheduler()
-    scheduler.add_job(start_order_job, 'interval', days =1 ,start_date=start_job_time)
-    #scheduler.add_job(start_order_job, 'interval',days =1,hours = 2,minutes = 0,seconds = 0)
-    #线上是24h执行一次
+    #scheduler.add_job(start_order_job, 'interval', days =1 ,start_date=start_job_time)
+    scheduler.add_job(start_order_job,'cron',hour ="02",minute="25")
     scheduler.start()
-'''
 
-if __name__ == '__main__':
-    start_order_job()   
-'''