吉祥幸福 代码优化

application/common/feishu/feishu.py

@@ -472,6 +472,11 @@ class Feishu:
                 sheet_url = "https://w42nne6hzg.feishu.cn/sheets/shtcngRPoDYAi24x52j2nDuHMih"
                 users = "\n<at id=" + str(cls.get_userid(log_type, crawler, "wangkun")) + "></at> <at id=" + str(
                     cls.get_userid(log_type, crawler, "gaonannan")) + "></at>\n"
+            elif crawler == "jixiangxingfu":
+                content = text
+                sheet_url = ""
+                users = "\n<at id=" + str(cls.get_userid(log_type, crawler, "wangxueke")) + "></at> <at id=" + str(
+                    cls.get_userid(log_type, crawler, "zhangyong")) + "></at>\n"
 
             # elif crawler == "weixinzhishu_out":
             #     content = "微信指数_站外指数"

spider/crawler_online/jixiangxingfu.py

@@ -3,6 +3,8 @@ import random
 import sys
 import time
 import uuid
+import json
+
 from datetime import datetime
 
 import requests
@@ -38,14 +40,27 @@ class JXXFRecommend(object):
         self.aliyun_log = AliyunLogger(mode=self.mode, platform=self.platform)
         self.mysql = MysqlHelper(mode=self.mode, platform=self)
 
+    def get_cookie(self):
+        sql = f""" select * from crawler_config where source="{self.platform}" """
+        configs = self.mysql.select(sql=sql)
+        for config in configs:
+            if "token" in config:
+                token_element = config[3]
+                data_json = json.loads(token_element)
+                token = data_json.get("token")
+                return token
+
     def get_recommend_list(self):
         """
         获取推荐页视频
         """
+        token = self.get_cookie()
+
         headers = {
             'Host': 'api.huanqiwl.top',
             'Content-Type': 'application/json',
             'Accept-Language': 'zh-cn',
+            'token': token,
             'Accept': '*/*',
             'User-Agent': 'Mozilla/5.0 (iPhone; CPU iPhone OS 11_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E217 MicroMessenger/6.8.0(0x16080000) NetType/WIFI Language/en Branch/Br_trunk MiniProgramEnv/Mac',
             'Referer': 'https://servicewechat.com/wx6692a24ad2a88bfb/3/page-frame.html'
@@ -55,6 +70,9 @@ class JXXFRecommend(object):
             url = f"https://api.huanqiwl.top/index.php?s=mobile/Video/getList&cid=1&page={i}&api_version=4&appid=wx6692a24ad2a88bfb&version=1.9.5&env_version=release&scene=1053"
             payload = {}
             response = requests.request("GET", url, headers=headers, data=payload, proxies=tunnel_proxies())
+            if "未登录" in response.text:
+                Feishu.bot(self.platform, 'jixiangxingfu', f'吉祥幸福token失效，请及时更换～')
+                break
             for index, video_obj in enumerate(response.json()['data']['list'], 1):
                 try:
                     self.aliyun_log.logging(