renyupeng 1 рік тому
батько
коміт
4be90e1529
2 змінених файлів з 50 додано та 43 видалено
  1. 43 41
      DouyinSpider/SpiderDouyinHeader.py
  2. 7 2
      utils/PromoterInfoWebHook.py

+ 43 - 41
DouyinSpider/SpiderDouyinHeader.py

@@ -29,44 +29,46 @@ class SpiderDouyinHeader:
             'Connection': 'keep-alive'
         }
         rep = requests.request("GET", url, headers=headers, data=payload)
-        print(rep.text,'-------rep.text---------')
-        dy_info_list = json.loads(rep.text)["data"]['list']
-        dy_promoter_item = {}
-        if dy_info_list is not None:
-            for dy_info in dy_info_list:
-                if dy_info['unique_id'] == promoter_id:
-                    print(dy_info, '-----------------')
-                    nickname = dy_info['nickname']
-                    unique_id = dy_info['unique_id']
-                    avatar = dy_info['avatar']
-                    follower_incr = dy_info['follower_incr']
-                    follower_count = dy_info['follower_count']
-                    aweme_avg_digg_count_30 = dy_info['aweme_avg_digg_count_30']
-                    aweme_digg_follower_ration = dy_info['aweme_digg_follower_ration']
-                    live_count_30 = dy_info['live_count_30']
-                    live_average_user_30 = dy_info['live_average_user_30']
-                    live_total_amount_30_text = dy_info['live_total_amount_30_text']
-                    dy_promoter_item = {
-                        ##达人名称
-                        "promoterNickName": nickname,
-                        ##达人头像
-                        "promoterHeadImgUrl": avatar,
-                        ## 达人ID
-                        "promoter_id": unique_id,
-                        ##粉丝增量
-                        "follower_incr": follower_incr,
-                        ## 粉丝数
-                        "fanNum": follower_count,
-                        ## 总销售额
-                        "totalSale": live_total_amount_30_text,
-                        ## 直播场次
-                        "live_count_30": live_count_30,
-                        ## 平均点赞量
-                        "aweme_avg_digg_count_30": aweme_avg_digg_count_30,
-                        ## 平均赞粉比
-                        "aweme_digg_follower_ration": aweme_digg_follower_ration,
-                        ##直播平均场观
-                        "live_average_user_30": live_average_user_30
-                    }
-        dy_promoter_item = json.dumps(dy_promoter_item)
-        return dy_promoter_item
+        if json.loads(rep.text)["data"] is not None:
+            dy_info_list = json.loads(rep.text)["data"]['list']
+            dy_promoter_item = {}
+            if dy_info_list is not None:
+                for dy_info in dy_info_list:
+                    if dy_info['unique_id'] == promoter_id:
+                        print(dy_info, '-----------------')
+                        nickname = dy_info['nickname']
+                        unique_id = dy_info['unique_id']
+                        avatar = dy_info['avatar']
+                        follower_incr = dy_info['follower_incr']
+                        follower_count = dy_info['follower_count']
+                        aweme_avg_digg_count_30 = dy_info['aweme_avg_digg_count_30']
+                        aweme_digg_follower_ration = dy_info['aweme_digg_follower_ration']
+                        live_count_30 = dy_info['live_count_30']
+                        live_average_user_30 = dy_info['live_average_user_30']
+                        live_total_amount_30_text = dy_info['live_total_amount_30_text']
+                        dy_promoter_item = {
+                            ##达人名称
+                            "promoterNickName": nickname,
+                            ##达人头像
+                            "promoterHeadImgUrl": avatar,
+                            ## 达人ID
+                            "promoter_id": unique_id,
+                            ##粉丝增量
+                            "follower_incr": follower_incr,
+                            ## 粉丝数
+                            "fanNum": follower_count,
+                            ## 总销售额
+                            "totalSale": live_total_amount_30_text,
+                            ## 直播场次
+                            "live_count_30": live_count_30,
+                            ## 平均点赞量
+                            "aweme_avg_digg_count_30": aweme_avg_digg_count_30,
+                            ## 平均赞粉比
+                            "aweme_digg_follower_ration": aweme_digg_follower_ration,
+                            ##直播平均场观
+                            "live_average_user_30": live_average_user_30
+                        }
+            dy_promoter_item = json.dumps(dy_promoter_item)
+            return dy_promoter_item
+        else:
+            return 10086

+ 7 - 2
utils/PromoterInfoWebHook.py

@@ -103,9 +103,14 @@ def webhook_get_promoter():
         rep = json.loads(request.data)
         promoterId = rep["promoterId"]
         cookie = douyin_cookie_update.get_cookie_handler()[0]
+        phone_num = douyin_cookie_update.get_cookie_handler()[1]
+
         roll = SpiderDouyinHeader().DouyinHandler(promoterId, cookie)
-        print(roll, '--------roll-------')
-        return roll
+        if roll != 10086:
+            return roll
+        else:
+            douyin_cookie_update.update_cookie_handler(phone_num)
+            return {}
 
 
 @app.route('/promoterInfo/updatePromoter', methods=['POST'])