文鼎

app/api_data/get_order.py

@@ -234,5 +234,6 @@ if __name__ == '__main__':
     # youshuge()
     # yueweng()
     # huasheng()
-    qiyue()
-    qiyueyousheng()
+    # qiyue()
+    # qiyueyousheng()
+    wending()

app/api_data/order_util.py

@@ -350,10 +350,9 @@ def get_wending_json_object(url,params):
     starttime = params['starttime']
     endtime = params['endtime']
     page = params['page']
-    paystatus = params['paystatus']
     ## +'&secretkey='+str(secretkey)
     parameter = 'consumerkey='+str(consumerkey)+'&timestamp='+str(timestamp)+'&siteid='+str(siteid)+'&pageSize='+str(pageSize)\
-              +'&starttime='+str(starttime)+'&endtime='+str(endtime)+'&page='+str(page)+'&paystatus='+str(paystatus)+'&sign='+str(sign)
+              +'&starttime='+str(starttime)+'&endtime='+str(endtime)+'&page='+str(page)+'&sign='+str(sign)
     global get_url
     get_url = url+"?"+parameter
 
@@ -398,37 +397,40 @@ def get_wd_order_task(start,end,account):
                 'pageSize': 1000,
                 'starttime': starttime,
                 'endtime': endtime,
-                'page': page,
-                'paystatus': 1}
+                'page': page}
 
             response_result_json = get_wending_json_object(url, params)
+            # print(response_result_json)
 
             order_item_list = response_result_json['data']['rechargeList']
 
             for x in order_item_list:
-                createTime = time.strftime("%Y-%m-%d %H:%M:%S",
-                                           time.localtime(x['createTime'] // 1000))  ## 时间戳 》struct_time 》标准时间
-                uid_reg_time = time.strftime("%Y-%m-%d %H:%M:%S",
-                                             time.localtime(x['userRegisterTime'] // 1000))  ## 13位时间戳 》标准时间
-                y = (int(time.mktime(time.strptime(createTime[:10], '%Y-%m-%d'))),
+
+                order_time = DateUtils.stamp_to_str(x['createTime'])
+                reg_time = DateUtils.stamp_to_str(x['userRegisterTime'])
+
+                order_list.append(
+                    (order_time[:10],
                      stage,
                      '文鼎',
                      x['wx_mpName'],
                      x['wx_originalId'],
-                     x['userId'],
-                     createTime,
-                     uid_reg_time,
+                     x['wx_user_openId'],
+                     order_time,
+                     reg_time,
                      x['money'] / 100,
-                     x['bookTitle'],
-                     x['ewTradeId'])
-                order_list.append(y)
-
+                     x['bookTitle'] if x['bookTitle'] else '',
+                     x['ewTradeId'] if x.get('ewTradeId') else x['rechargeUuid'],
+                     2 if x['payStatus'] == 1 else 1
+                    )
+                )
             if len(order_item_list) < 1000:
                 break
             else:
                 page += 1
     print(f"{stage} [{start}~{end}] 有订单 {order_list.__len__()}")
     if order_list.__len__()>0:
+        # print(order_list)
         save_order(order_list)
 
 
@@ -599,5 +601,7 @@ if __name__ == '__main__':
     # print(DateUtils.stamp_to_str(1612155476,'%Y-%m-%d %H:%M:%S')[:10])
     # exit(0)
 
+    st= et = '2021-05-07'
 
-    get_qiyue_order_task('2021-02-01','2021-02-02',['趣程15期','eyJpdiI6ImluVWxoRUl3VTR6QU5hamlYOFBvXC9BPT0iLCJ2YWx1ZSI6Ik5IZ0N4dm5GcmJ0Zklsd0tNZ1JVSVE9PSIsIm1hYyI6IjJjODUzMjdlZTc2ODI2ZjFmY2QyYmU5MGViYTkzOGU4MDEwZTIyODIxOTE4NzgzYTNhOGQ1YWM4OGJkMDAzMmIifQ=='])
+    account = "62140324,KUUxPIokqtIrtvHQ,1025010,趣程19期,qucheng19qi@163.com"
+    get_wd_order_task(st,et,account.split(','))

app/api_data/platform_order/audio_qiyue.py

@@ -64,7 +64,7 @@ class AudioQiyue:
                     order_list.append((
                         create_time[:10],
                         stage,
-                        '七悦',
+                        '七悦有声',
                         x['wechat_app_name'],  # 公众号名称
                         x['channel_id'],
                         x['user_open_id'],

model/DateUtils.py

@@ -329,6 +329,11 @@ class DateUtils:
         @:param stamp->int
         @:return ->str
         """
+        if isinstance(stamp,str):
+            stamp = int(stamp)
+        if len(str(stamp))==13:
+            stamp = round(stamp/1000)
+
         return time.strftime(f, time.localtime(stamp))
 
     @staticmethod