白嫖coze+飞书，搭建自己的微信公众号每日跟踪AI总结机器人，告别资讯焦虑

#爬取微信公众号文章，并存在本地文本中
def get_wechat_upper_article_url(cookies_str):
    #query为要爬取的公众号名称
    #公众号主页
    url = 'https://mp.weixin.qq.com'
    #设置headers
    header = {
        "HOST": "mp.weixin.qq.com",
        "User-Agent": "Mozilla/5.0 (Windows NT 6.1; WOW64; rv:53.0) Gecko/20100101 Firefox/53.0"
        }
    cookies = json.loads(cookies_str)
    #登录之后的微信公众号首页url变化为：https://mp.weixin.qq.com/cgi-bin/home?t=home/index&lang=zh_CN&token=1849751598，从这里获取token信息
    response = requests.get(url=url, allow_redirects=False, cookies=cookies)
    if not response.headers.get("Location"):
        logging.info("微信cookie已过期，重新登录刷新")
        cookies = weChat_login()
        if not cookies:
            feishu_send_message("微信cookie过期，请重新登录刷新")
            return
        cookies = json.loads(cookies)

    response = requests.get(url=url,allow_redirects=False,cookies=cookies)
    token = re.findall(r'token=(\d+)', str(response.headers.get("Location")))[0]
    logging.info("微信token:"+ token)

    article_urls = []
    for account_name, account_id in gzlist.items():
        #搜索微信公众号的接口地址
        search_url = 'https://mp.weixin.qq.com/cgi-bin/searchbiz?'
        #搜索微信公众号接口需要传入的参数，有三个变量：微信公众号token、随机数random、搜索的微信公众号名字
        query_id = {
            'action': 'search_biz',
            'token' : token,
            'lang': 'zh_CN',
            'f': 'json',
            'ajax': '1',
            'random': random.random(),
            'query': account_name,
            'begin': '0',
            'count': '5'
            }
        #打开搜索微信公众号接口地址，需要传入相关参数信息如：cookies、params、headers
        search_response = requests.get(search_url, cookies=cookies, headers=header, params=query_id)
        #取搜索结果中的第一个公众号
        lists = search_response.json().get('list')[0]
        #获取这个公众号的fakeid，后面爬取公众号文章需要此字段
        fakeid = lists.get('fakeid')
        logging.info("fakeid:" + fakeid)
        #微信公众号文章接口地址
        appmsg_url = 'https://mp.weixin.qq.com/cgi-bin/appmsg?'
        #搜索文章需要传入几个参数：登录的公众号token、要爬取文章的公众号fakeid、随机数random
        query_id_data = {
            'token': token,
            'lang': 'zh_CN',
            'f': 'json',
            'ajax': '1',
            'random': random.random(),
            'action': 'list_ex',
            'begin': '0',#不同页，此参数变化，变化规则为每页加5
            'count': '5',
            'query': '',
            'fakeid': fakeid,
            'type': '9'
            }
        #打开搜索的微信公众号文章列表页
        query_fakeid_response = requests.get(appmsg_url, cookies=cookies, headers=header, params=query_id_data)
        fakeid_list = query_fakeid_response.json().get('app_msg_list')
        item = fakeid_list[0]
        # 采集item示例
        new_article = {
            'title': item.get('title'),
            'article_url': item.get('link'),
            'account_id': account_id,
            'account_name': account_name,
            'publish_time': datetime.datetime.fromtimestamp(int(item.get("update_time"))).strftime('%Y-%m-%d %H:%M:%S'),
            'collection_time': datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
        }
        logging.info("new_article:", new_article)
        article_urls.append(item.get('link'))
        time.sleep(2)
    return article_urls

def coze_workflow_run(token, workflow_id, parameters):
    """
    通用Coze平台工作流API调用函数
    :param token: Bearer Token字符串（不含'Bearer '前缀）
    :param workflow_id: 工作流ID
    :param parameters: dict类型，API参数
    :return: 返回API响应内容
    """
    logging.info("调用coze工作流开始")
    url = 'https://api.coze.cn/v1/workflow/run'
    headers = {
        'Accept': '*/*',
        'Authorization': f'Bearer {token}',
        'Content-Type': 'application/json',
    }
    data = {
        'workflow_id': workflow_id,
        'parameters': parameters
    }
    response = requests.post(url, headers=headers, data=json.dumps(data))
    try:
        return response.json()
    except Exception:
        return response.text