renyupeng 11 bulan lalu
induk
melakukan
10ebe66ea1

+ 0 - 2
spider/ReturnPromoterInfoSpider.py

@@ -84,5 +84,3 @@ class ReturnPromoterInfoSpider:
         except Exception as e:
             SendFeiShuMsg.send_robot_msg(
                 'PromoterUpdate {promoterId}请求错误请检查cookie{e}'.format(promoterId=promoterId, e=e))
-
-

+ 1 - 1
spider/SpiderPromoterHeader.py

@@ -35,7 +35,7 @@ class SpiderPromoterHeader:
             random_member = r.zrange('kuaishou_shop_click_token', 0, -1, withscores=True)
             random_item = random.choice(random_member)
             # cookie = random_item[0].decode('utf-8')
-            cookie = cookie_update.get_cookie_handler()
+            cookie = cookie_update.get_cookie_handler()[0]
             phone_num = int(random_item[1])
 
             headers = {'User-Agent': 'Mozilla/5.0',

+ 1 - 1
spider/SpiderPromoterHeaderMgs.py

@@ -35,7 +35,7 @@ class SpiderPromoterHeader:
             random_member = r.zrange('kuaishou_shop_click_token', 0, -1, withscores=True)
             random_item = random.choice(random_member)
             # cookie = random_item[0].decode('utf-8')
-            cookie = cookie_update.get_cookie_handler()
+            cookie = cookie_update.get_cookie_handler()[0]
             phone_num = int(random_item[1])
 
             headers = {'User-Agent': 'Mozilla/5.0',

+ 1 - 1
spider/SpiderPromoterHeaderRocket.py

@@ -35,7 +35,7 @@ class SpiderPromoterHeader:
             random_member = r.zrange('kuaishou_shop_click_token', 0, -1, withscores=True)
             random_item = random.choice(random_member)
             # cookie = random_item[0].decode('utf-8')
-            cookie = cookie_update.get_cookie_handler()
+            cookie = cookie_update.get_cookie_handler()[0]
             phone_num = int(random_item[1])
 
             headers = {'User-Agent': 'Mozilla/5.0',

+ 2 - 2
spider/SpiderPromoterInfo.py

@@ -22,12 +22,12 @@ class SpiderPromoterInfo:
     @staticmethod
     def get_promoter(promoterId):
         print(promoterId, '22222')
-        cookie = cookie_update.get_cookie_handler()
+        cookie = cookie_update.get_cookie_handler()[0]
         roll = ReturnPromoterInfoSpider().PromoterInfoSpiderHandler(promoterId, cookie)
         print(roll, '------')
 
         if json.loads(roll).__contains__("result"):
-            retry_cookie = cookie_update.get_cookie_handler()
+            retry_cookie = cookie_update.get_cookie_handler()[0]
             roll = ReturnPromoterInfoSpider().PromoterInfoSpiderHandler(promoterId, retry_cookie)
             try:
                 roll = json.loads(roll)

+ 1 - 1
spider/SpiderWeekPromoterInfo.py

@@ -38,7 +38,7 @@ class SpiderWeekPromoterInfo:
             random_member = cookie_update.r.zrange('kuaishou_shop_token', 0, -1, withscores=True)
             random_item = random.choice(random_member)
             # cookie = random_item[0].decode('utf-8')
-            cookie=cookie_update.get_cookie_handler()
+            cookie=cookie_update.get_cookie_handler()[0]
             phone_num = int(random_item[1])
             roll = ReturnPromoterInfoSpider().PromoterInfoSpiderHandler(promoterId, cookie)
 

+ 22 - 22
utils/PromoterInfoWebHook.py

@@ -46,7 +46,7 @@ def webhook_get_promoter():
             cookie_update.get_click_coookie_to_redis()
             random_member = r.zrange('kuaishou_shop_click_token', 0, -1, withscores=True)
             random_item = random.choice(random_member)
-            cookie = cookie_update.get_cookie_handler()
+            cookie = cookie_update.get_cookie_handler()[0]
             # cookie = random_item[0].decode('utf-8')
             roll = ReturnPromoterInfoSpider().PromoterInfoSpiderHandler(promoterId, cookie)
             print(roll, '-----000-----{promoterId}'.format(promoterId=promoterId))
@@ -54,21 +54,21 @@ def webhook_get_promoter():
 
 
         else:
-            random_member = r.zrange('kuaishou_shop_click_token', 0, -1, withscores=True)
-            random_item = random.choice(random_member)
+            # random_member = r.zrange('kuaishou_shop_click_token', 0, -1, withscores=True)
+            # random_item = random.choice(random_member)
             # cookie = random_item[0].decode('utf-8')
-            cookie = cookie_update.get_cookie_handler()
+            cookie = cookie_update.get_cookie_handler()[0]
             print(cookie,'----------cookie--------------')
-            phone_num = int(random_item[1])
+            phone_num = cookie_update.get_cookie_handler()[1]
             print(phone_num,'------phone_num-------')
             results = ReturnPromoterInfoSpider.PromoterInfoSpiderHandler(promoterId, cookie)
             print(results, '-----results-----{promoterId}'.format(promoterId=promoterId))
             if json.loads(results).__contains__("result"):
                 if json.loads(results)["result"] == 109:
-                    r.zrem('kuaishou_shop_click_token', random_item[0])
-                    retry_item = cookie_update.r.zrange('kuaishou_shop_click_token', 0, -1, withscores=True)
-                    print(retry_item[0][0], '-----cookie-----')
-                    retry_cookie = cookie_update.get_cookie_handler()
+                    # r.zrem('kuaishou_shop_click_token', random_item[0])
+                    # retry_item = cookie_update.r.zrange('kuaishou_shop_click_token', 0, -1, withscores=True)
+                    # print(retry_item[0][0], '-----cookie-----')
+                    retry_cookie = cookie_update.get_cookie_handler()[0]
 
                     # retry_cookie = retry_item[0][0].decode('utf-8')
                     cookie_update.update_cookie_handler(phone_num)
@@ -92,9 +92,9 @@ def webhook_get_promoter():
 
                 else:
                     cookie_update.update_temporary_cookie_handler(phone_num)
-                    r.zrem('kuaishou_shop_click_token', random_item[0])
+                    # r.zrem('kuaishou_shop_click_token', random_item[0])
 
-                    retry_item = cookie_update.r.zrange('kuaishou_shop_click_token', 0, -1, withscores=True)
+                    # retry_item = cookie_update.r.zrange('kuaishou_shop_click_token', 0, -1, withscores=True)
                     # retry_cookie = retry_item[0][0].decode('utf-8')
                     retry_cookie = cookie_update.update_cookie_handler(phone_num)
 
@@ -128,7 +128,7 @@ def webhook_get_promoter():
                 p3.start()
                 p4.start()
                 p5.start()
-                r.zrem('kuaishou_shop_click_token', random_item[0])
+                # r.zrem('kuaishou_shop_click_token', random_item[0])
                 print(results, '--------444---roll1---------{promoterId}'.format(promoterId=promoterId))
                 return results
 
@@ -149,18 +149,18 @@ def webhook_get_promoter():
 
 @app.route('/promoterInfo/updatePromoter', methods=['POST'])
 def webhook_update_promoter():
-    r = redis.Redis(host='192.168.0.99', password='', port=6379, db=0)
+    # r = redis.Redis(host='192.168.0.99', password='', port=6379, db=0)
     rep = json.loads(request.data)
     promoterId = rep["promoterId"]
-    if r.zcard('kuaishou_shop_click_token') == 0:
-        cookie_update.get_click_coookie_to_redis()
-    else:
-        random_member = r.zrange('kuaishou_shop_click_token', 0, -1, withscores=True)
-        random_item = random.choice(random_member)
-        # cookie = random_item[0].decode('utf-8')
-        cookie= cookie_update.get_cookie_handler()
-        ReturnPromoterInfoSpider().PromoterUpdate(promoterId, cookie)
-        r.close()
+    # if r.zcard('kuaishou_shop_click_token') == 0:
+    #     cookie_update.get_click_coookie_to_redis()
+    # else:
+    #     random_member = r.zrange('kuaishou_shop_click_token', 0, -1, withscores=True)
+    #     random_item = random.choice(random_member)
+    #     # cookie = random_item[0].decode('utf-8')
+    cookie= cookie_update.get_cookie_handler()[0]
+    ReturnPromoterInfoSpider().PromoterUpdate(promoterId, cookie)
+        # r.close()
     return '0'
 
 

+ 1 - 1
utils/cookie_update.py

@@ -16,7 +16,7 @@ class cookie_update:
     @staticmethod
     def get_cookie_handler():
         sql = "select cookie ,phone_num from kwai_promoter.kuaishou_supply_chain_cookie where status =0"
-        result = MysqlUtils().QueryOne(sql)[0]
+        result = MysqlUtils().QueryOne(sql)
         print(result)
         return result