renyupeng преди 1 година
родител
ревизия
5988eee256
променени са 2 файла, в които са добавени 6 реда и са изтрити 2 реда
  1. 3 1
      FastDistributionSpider/PlatformClipOrderList.py
  2. 3 1
      FastDistributionSpider/PromoterOrderList.py

+ 3 - 1
FastDistributionSpider/PlatformClipOrderList.py

@@ -15,6 +15,7 @@ import requests
 
 from utils.mysql_helper import batch_insertPro
 from utils.mysql_utils_pro import MysqlProUtils
+from utils.send_wechat_msg import SendWechatMsg
 
 
 class PlatformClipOrderList:
@@ -49,7 +50,8 @@ class PlatformClipOrderList:
                 print(url,'-------')
                 rep = requests.request("GET", url, headers=headers, data=payload)
                 if json.loads(rep.text)["result"] != 1:
-                    return
+                    SendWechatMsg().send_data(json.loads(rep.text))
+                    continue
                 else:
                     total_list = json.loads(rep.text)["data"]["list"]
                     dataInfoList = []

+ 3 - 1
FastDistributionSpider/PromoterOrderList.py

@@ -14,6 +14,7 @@ import requests
 
 from utils.mysql_helper import batch_insertPro
 from utils.mysql_utils_pro import MysqlProUtils
+from utils.send_wechat_msg import SendWechatMsg
 
 
 class PromoterOrderList:
@@ -45,7 +46,8 @@ class PromoterOrderList:
                 response = requests.request("GET", url, headers=headers, data=payload)
                 print(json.loads(response.text))
                 if json.loads(response.text)["result"] != 1:
-                    return
+                    SendWechatMsg().send_data(json.loads(response.text))
+                    continue
                 else:
                     total_list = json.loads(response.text)["data"]["list"]
                     dataInfoList = []