1

app/api_data/get_order.py

@@ -5,8 +5,9 @@ from model.DingTalkUtils import DingTalkUtils
 db=MysqlUtils()
 
 
-def get_account(plactform):
-    data = db.quchen_text.getData(f"select text from order_account_text where platform='{plactform}'")
+def get_account(plactform,id=None):
+    op = f" and id={id} " if id else ''
+    data = db.quchen_text.getData(f"select text from order_account_text where platform='{plactform}' {op}")
     new_data = []
     for i in data:
         new_data.append(i[0].replace('\n', '').split(","))
@@ -134,10 +135,11 @@ def hourly():
 
 def daily():
     st = du.get_n_days(-10)
+    st2=du.get_n_days(-3)
     et = du.get_n_days(-1)
     yangguang(st, et)
     huasheng(st, et)
-    qiyue(st, et)
+    qiyue(st2, et)    # 有毛病
     wending(st, et)
     zhangdu(st, et)
 
@@ -152,4 +154,4 @@ if __name__ == '__main__':
 
     # zhangdu('2020-12-20','2021-02-22')
 
-    """要是只跑一个账号 把 get_yg_acccount() 里面的sql where 条件加上 id=xxx"""
+    """要是只跑一个账号 把 get_yg_acccount() 里面的sql where 条件加上 id=xxx"""

app/api_data/order_util.py

@@ -212,12 +212,14 @@ def get_qiyue_order_task(start, end, account):
     size = 50
     freq=0
     for date in du.getDateLists(start, end):
+
         while True:
             timestamp = int(time.time())
             url = order_url + "?" + "token=" + str(token) + "&timestamp=" + str(timestamp) + "&page=" + str(
                 page) + "&size=" + str(size) + "&date=" + date
             response_result_json = requests.get(url=url).json()
 
+
             freq += 1
             if freq == 59:
                 print("一分钟请求60次的限制 等待中")
@@ -256,6 +258,7 @@ def get_qiyue_order_task(start, end, account):
             if next_page_url is None:
                 break
             page += 1
+        # print(len(order_list))
 
     print(f'{stage} [{start}~{end}] 有订单{order_list.__len__()}')
     if order_list.__len__()>0: