优化发送效果

Author: budaLi

qq加群/qihuo_spider.py

@@ -25,11 +25,11 @@ def spider():
     response = requests.get(url, headers=headers).json()
 
     res = []
-    for i in range(10):
+    for i in range(20):
         tem = response['data'][i]['data']['content']
-        if "现货报价" in tem or "了解请戳" in tem:
+        if "现货报价" in tem or "了解请戳" in tem or "金十产品" in tem:
             continue
-        tem = tem.replace("金十期货讯", "").replace("。", "。/n/n").replace("<b>", "")
+        tem = tem.replace("金十期货讯", "").replace("。", "。\n\n").replace("<b>", "").replace("<br/>", "")
         res.append(tem)
 
     return 0, res

qq加群/spider.py

@@ -14,9 +14,9 @@ def spider():
         url = base_url.format(int(time.time() * 1000))
         response = requests.get(url).text
         totle_res = eval(response.replace("var ajaxResult=", ""))
-        lis_res = totle_res['LivesList'][:10]
+        lis_res = totle_res['LivesList'][:20]
         for one in lis_res:
-            res.append(one['digest'])
+            res.append(one['digest'].replace("</b>", ""))
         return (len(lis_res), res)
     except Exception as e:
         return (0, None)

qq加群/企业微信发消息.py

@@ -24,8 +24,8 @@
 send_message_count = 10  # 每隔多长时间发送一次联系人微信
 # 休眠时间
 winname = ["阿尔萨斯"]  # 需要发送的
-
-add_txt = "\n \n 更多咨询请联系客服微信：876134889"
+wx_number = {"阿尔萨斯": [1, "李不搭", "15735656005"]}  # 不同群对应发送的微信号
+add_txt = "\n \n 各位朋友好，欢迎来到实时期货快讯{}群，我是{}，我的微信号是：{}，欢迎大家一起交流。"
 
 totol_dic = set()  # 去重
 
@@ -147,9 +147,9 @@ def main(winname):
         logger("检测新闻中")
         try:
             qihuo_l, qihuo_res = qihuo_spider()
-            new_l, res = spider()
+            new_l, res_ = spider()
 
-            new_res = qihuo_res + res
+            new_res = qihuo_res + res_
 
             if new_res:
                 for one in new_res:
@@ -160,13 +160,16 @@ def main(winname):
                         else:
                             tem = time.strftime("%H:%M", time.localtime(time.time())) + " " + one
                         for wn in winname:
+                            tem = tem.format(*wx_number[wn])
                             if sendMsgToWX(tem, wn):
                                 logger("发送成功:{}".format(tem))
                                 totol_dic.add(one)
                             else:
-                                logger("发送失败:{},下次将会重新发送".format(tem))
-                    else:
-                        break
+                                sendMsgToWX(tem, wn)
+                                logger("发送成功:{}".format(tem.format(wx_number[wn])))
+                                totol_dic.add(one)
+                    # else:
+                    #     break
             time.sleep(sleep_time)
         except Exception as e:
             logger("运行错误.{}".format(e))