七悦改

app/api_data/platform_order/QiYue.py

@@ -13,7 +13,7 @@ from model.DateUtils import DateUtils
 import logging
 from urllib import parse
 from model.DingTalkUtils import DingTalkUtils
-from .order_util import save_order
+from .order_util import save_order2
 
 logging.getLogger().setLevel(logging.WARNING)
 db = MysqlUtils()
@@ -23,7 +23,7 @@ du = DateUtils()
 # 获取七悦订单数据
 def get_qiyue_order_task(start, end, account):
     """一分钟请求60次的限制"""
-    order_list = []
+
     # 参数
     order_url = "https://api.zhangwenwenhua.com" + "/v1/orders"
     stage = account[0]
@@ -31,8 +31,8 @@ def get_qiyue_order_task(start, end, account):
     size = 50
     freq = 0
     for date in du.getDateLists(start, end):
+        order_list = []
         page = 1
-
         while True:
             timestamp = int(time.time())
             url = order_url + "?" + "token=" + str(token) + "&timestamp=" + str(timestamp) + "&page=" + str(
@@ -75,7 +75,11 @@ def get_qiyue_order_task(start, end, account):
                     x['book_name'],
                     x['transaction_no'] if x['transaction_no'] != 0 else x['trade_no'],  # 订单id
                     x['state'],
-                    x['user_id']
+                    x['id'],
+                    x['user_id'],
+                    x['wechat_app_id'],
+                    x['book_keywords'],
+                    x['type']
                 )
                 )
 
@@ -84,9 +88,13 @@ def get_qiyue_order_task(start, end, account):
                 break
             page += 1
         # print(len(order_list))
-    print(f'{stage} [{start}~{end}] 有订单{order_list.__len__()}')
-    if order_list.__len__() > 0:
-        save_order(order_list)
+        print(f'{stage} [{date}] 有订单{order_list.__len__()}')
+        # print(order_list)
+        if order_list.__len__() > 0:
+
+            db.quchen_text.execute(f'DELETE from ods_order where platform="七悦" and date="{date}"')
+            save_order2(order_list)
+
 
 
 # 获取七悦用户信息

app/api_data/platform_order/order_util.py

@@ -230,9 +230,12 @@ def save_order(order_list):
     print("入库成功")
 
 def save_order2(order_list):
+
+
+
     db.quchen_text.executeMany("""replace into ods_order(date,stage,platform,channel,channel_id,user_id,
-                               order_time,reg_time,amount,from_novel,order_id,status) 
-                               values (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)""", order_list)
+                               order_time,reg_time,amount,from_novel,order_id,status,platform_order_id,platform_user_id,wechat_app_id,book_tags,order_type) 
+                               values (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)""", order_list)
     print("入库成功")
 
 def get_wd_account_siteid_list(account):