七悦订单优化

app/api_data/get_order.py

@@ -233,4 +233,6 @@ if __name__ == '__main__':
     # zhangzhongyun('2021-04-01', '2021-04-21')
     # youshuge()
     # yueweng()
-    huasheng()
+    # huasheng()
+    qiyue()
+    qiyueyousheng()

app/api_data/order_util.py

@@ -232,6 +232,7 @@ def get_qiyue_order_task(start, end, account):
                 page) + "&size=" + str(size) + "&date=" + date
             rsp=requests.get(url=url)
             response_result_json = rsp.json()
+            # print(response_result_json)
 
             freq += 1
             if freq == 59:
@@ -252,35 +253,38 @@ def get_qiyue_order_task(start, end, account):
 
             order_item_list = result_data['data']
             for x in order_item_list:
-                if int(x['state']) != 2:
-                    continue
-                y = ((int(x['create_time']) + 8 * 3600) // 86400 * 86400 - 8 * 3600,
+
+                create_time = DateUtils.stamp_to_str(x['create_time'],'%Y-%m-%d %H:%M:%S')
+                reg_time = DateUtils.stamp_to_str(x['user_create_time'],'%Y-%m-%d %H:%M:%S')
+                order_list.append((
+                     create_time[:10],
                      stage,
                      '七悦',
                      x['wechat_app_name'],  # 公众号名称
                      x['channel_id'],
-                     x['user_id'],
-                     time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(x['create_time'])),
-                     time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(x['user_create_time'])),  # 用户注册时间
+                     x['user_open_id'],
+                     create_time,
+                     reg_time,  # 用户注册时间
                      x['money'],
                      x['book_name'],
-                     x['id']   # 订单id
+                     x['transaction_no'] if x['transaction_no'] != 0 else x['trade_no'],   # 订单id
+                     x['state'])
                      )
-                order_list.append(y)
+
             next_page_url = result_data['next_page_url']
             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:
         save_order(order_list)
-    return order_list
+        # print(order_list)
+
 
 
 def save_order(order_list):
-    db.quchen_text.executeMany('replace into `order` values (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)',order_list)
+    db.quchen_text.executeMany('replace into ods_order values (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)',order_list)
     print("入库成功")
 
 
@@ -589,8 +593,11 @@ def get_zzy_channel_order(start, end, account, channel):
 
 
 if __name__ == '__main__':
-    account = "347347942,e0c361b54a35a55c2b6296b5a80867ce,趣程小程序"
-    get_hs_order_task('2021-05-01','2021-05-07',account.split(","))
+    # account = "347347942,e0c361b54a35a55c2b6296b5a80867ce,趣程小程序"
+    # get_hs_order_task('2021-05-01','2021-05-07',account.split(","))
+
+    # print(DateUtils.stamp_to_str(1612155476,'%Y-%m-%d %H:%M:%S')[:10])
+    # exit(0)
 
 
-    # get_qiyue_order_task('2021-02-01','2021-02-19',['趣程15期','eyJpdiI6ImluVWxoRUl3VTR6QU5hamlYOFBvXC9BPT0iLCJ2YWx1ZSI6Ik5IZ0N4dm5GcmJ0Zklsd0tNZ1JVSVE9PSIsIm1hYyI6IjJjODUzMjdlZTc2ODI2ZjFmY2QyYmU5MGViYTkzOGU4MDEwZTIyODIxOTE4NzgzYTNhOGQ1YWM4OGJkMDAzMmIifQ=='])
+    get_qiyue_order_task('2021-02-01','2021-02-02',['趣程15期','eyJpdiI6ImluVWxoRUl3VTR6QU5hamlYOFBvXC9BPT0iLCJ2YWx1ZSI6Ik5IZ0N4dm5GcmJ0Zklsd0tNZ1JVSVE9PSIsIm1hYyI6IjJjODUzMjdlZTc2ODI2ZjFmY2QyYmU5MGViYTkzOGU4MDEwZTIyODIxOTE4NzgzYTNhOGQ1YWM4OGJkMDAzMmIifQ=='])

app/api_data/platform_order/audio_qiyue.py

@@ -59,21 +59,22 @@ class AudioQiyue:
 
                 order_item_list = result_data['data']
                 for x in order_item_list:
-                    if int(x['state']) != 2:
-                        continue
-                    y = ((int(x['create_time']) + 8 * 3600) // 86400 * 86400 - 8 * 3600,
-                         stage,
-                         '七悦有声',
-                         x['wechat_app_name'],  # 公众号名称
-                         x['channel_id'],
-                         x['user_open_id'],
-                         time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(x['create_time'])),
-                         time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(x['user_create_time'])),  # 用户注册时间
-                         x['money'],
-                         x['book_name'],
-                         x['transaction_no']  # 订单id
-                         )
-                    order_list.append(y)
+                    create_time = DateUtils.stamp_to_str(x['create_time'], '%Y-%m-%d %H:%M:%S')
+                    reg_time = DateUtils.stamp_to_str(x['user_create_time'], '%Y-%m-%d %H:%M:%S')
+                    order_list.append((
+                        create_time[:10],
+                        stage,
+                        '七悦',
+                        x['wechat_app_name'],  # 公众号名称
+                        x['channel_id'],
+                        x['user_open_id'],
+                        create_time,
+                        reg_time,  # 用户注册时间
+                        x['money'],
+                        x['book_name'],
+                        x['transaction_no'] if x['transaction_no'] != '0' else x['trade_no'],  # 订单id
+                        x['state'])
+                    )
                 next_page_url = result_data['next_page_url']
                 if next_page_url is None:
                     break
@@ -82,9 +83,11 @@ class AudioQiyue:
 
         print(f'{stage} [{start}~{end}] 有订单{order_list.__len__()}')
         if order_list.__len__() > 0:
+            # print(order_list)
+
             save_order(db_operation=self.db_quchen_text, order_list=order_list)
             # print(order_list)
-        return order_list
+
 
 
 

data_processing/sql_tools.py

@@ -1,5 +1,5 @@
 
 
 def save_order(db_operation,order_list):
-    db_operation.executeMany('replace into `order` values (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)',order_list)
+    db_operation.executeMany('replace into ods_order values (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)',order_list)
     print("入库成功")