⑥ 微信联动篇——Python 脚本写起来!实现消息监听与自动回复

文件创建与解释器配置

创建文件  

我们首先要找个位置新建一个文件夹专门用于存放代码，这里我们创建一个名叫“code“的文件夹，创建好后双击进入该文件夹，接着，我们创建一个名叫“wxauto”的文件夹。

    接下来，选中“wxauto”文件夹，右击鼠标，点击“显示更多选项”。

    然后，我们选择“Open Folder as PyCharm Project”，点击，之后我们的pycharm会打开该文件。

    如下图所示，如果弹出所示内容，我们勾选“Trust all Project in 'code' folder"，点击”Trust  'code' Folder，即可打开文件夹。

    最新版的PyCharm已经支持中文了哦，但是默认仍然为“English”。想要改为中文的话先点击右上角“Main Menu” =>  "File" => "Settings"，如下图。

    接着，我们在Settings窗口直接搜索“chinese”，点击“Language and Region"，在右侧将语言设置为简体中文，点击“apply”，最后点击“OK”。

    最后，我们在弹出的窗口中点击“restart”，重启PyCharm。

配置解释器  

我们打开设置，在左侧“Python”中找到“解释器”，双击打开，如图所示依次点击“添加解释器”，“添加本地解释器”。

    在打开的窗口中我们选择“选择现有的”，类型选择“conda”，conda的路径我们点击右侧文件夹图标，找到自己的conda目录，并参考所示的路径找到“conda.exe"文件，双击或者选中后点击打开，我们再点击“重新加载环境”。

    加载完后，我们选择刚才用 wxauto.yml文件创建的wxauto环境，点击确定。

    接着，我们等待加载，加载完成后点击应用，最后点击确定，关闭设置。

    回到代码界面后，我们可以看到，之前在顶部的黄底色警告消失了，右下角显示了我们刚才配置的conda环境的名称，以及pycharm正在加载我们环境的资源包。

Python文件

创建文件  

    如图，我们创建我们的Python文件。

输入文件名称，这里我们可以使用“wxBot”命名，大家也可以起一个别的名字哦，命名好后，我们选择“Python文件”，回车。

我们可以在新的文件中输入以下代码：

测试一下。右键“运行”，看到控制台输出“hello world”则代表功能正常。

  编写文件  

下面开始写入我们的接入程序，具体代码和注解如下：

import json  # 导入json模块，用于处理JSON格式数据import sysimport time  # 导入time模块，用于时间相关操作（如睡眠）import requests  # 导入requests库，用于发送HTTP请求import os  # 导入os模块，用于文件操作from wxauto import WeChat  # 从wxauto库导入WeChat类，用于控制微信def create_default_user_file():    # 创建默认的用户文件    with open("user.txt", "w", encoding="utf-8") as f:        f.write("# 每行写一个要监听的好友名称 该行可以删除\n")        f.write("好友昵称（你给微信好友的备注）\n")    print("📝 已创建默认 user.txt 文件，请编辑后重新运行程序")    returnFalsedef create_default_config_file():    # 创建默认的配置文件    default_config = {        "api_url": "输入你的小助手的API服务器网址",        "api_key": "输入你的小助手的API密钥"    }    with open("config.json", "w", encoding="utf-8") as f:        json.dump(default_config, f, indent=4, ensure_ascii=False)    print("📝 已创建默认 config.json 文件，请填写正确的API配置后重新运行程序")    returnFalsedef check_and_create_files():    # 检查并创建必要的文件    files_exist = True    ifnot os.path.exists("user.txt"):        files_exist = create_default_user_file()    ifnot os.path.exists("config.json"):        files_exist = create_default_config_file()    return files_existdef load_users():    # 定义加载用户列表的函数    users = []  # 初始化空用户列表    with open("user.txt", "r", encoding="utf-8") as f:  # 以只读模式打开user.txt文件        for line in f:  # 遍历文件的每一行            name = line.strip()  # 去除每行首尾的空白字符            if name andnot name.startswith('#'):  # 如果行不为空且不是注释行                users.append(name)  # 将用户名添加到列表中    print(f"📋 监听用户列表：{users}")  # 打印加载的用户列表    return users  # 返回用户列表def load_dify_config():    # 定义加载Dify配置的函数    with open("config.json", "r", encoding="utf-8") as f:  # 打开config.json配置文件        cfg = json.load(f)  # 加载JSON内容到变量cfg    api_url = cfg.get("api_url") + '/chat-messages'  # 获取api_url配置项，并生成完整调用路径    api_key = cfg.get("api_key")  # 获取api_key配置项    ifnot api_url ornot api_key or api_key == "输入你的小助手的API密钥":  # 检查配置是否完整有效        print("❌ config.json 配置不完整，请正确填写。")  # 打印错误提示        returnNone  # 返回None表示配置无效    return {"api_url": api_url, "api_key": api_key}  # 返回包含配置的字典def call_dify_api(query, api_url, api_key, conversation_id=None, user_id="wechat-bot"):    # 定义调用Dify API的函数    headers = {  # 设置HTTP请求头        "Authorization": f"Bearer {api_key}",  # 认证头，使用Bearer token        "Content-Type": "application/json",  # 内容类型为JSON    }    payload = {  # 设置请求负载（数据）        "inputs": {},  # 空输入字典        "query": query,  # 用户查询文本        "response_mode": "blocking",  # 响应模式为阻塞（同步）        "conversation_id": conversation_id or"",  # 会话ID，如果没有则为空字符串        "user": user_id,  # 用户标识    }    try:        resp = requests.post(api_url, headers=headers, json=payload, timeout=600)  # 发送POST请求，超时设为600秒        resp.raise_for_status()  # 如果响应状态码不是200，抛出异常        return resp.json()  # 返回响应的JSON数据    except Exception as e:  # 捕获所有异常        print(f"❌ 调用 Dify API 失败：{e}")  # 打印错误信息        returnNone  # 返回None表示调用失败# 主程序print("🤖 正在启动微信Dify机器人...")  # 打印启动消息# 首先检查并创建必要的文件ifnot check_and_create_files():    print("🛑 请完善配置文件后重新运行程序")    sys.exit(0)  # 正常退出，让用户完善配置wx = WeChat()  # 创建WeChat实例，连接微信print("✅ 微信连接成功")  # 打印连接成功消息monitored_users = load_users()  # 加载要监听的用户列表ifnot monitored_users:  # 如果没有用户    print("❌ 没有可监听的用户，程序退出")    exit()  # 退出程序dify_cfg = load_dify_config()  # 加载Dify配置ifnot dify_cfg:  # 如果配置无效    print("❌ Dify配置无效，程序退出")    exit()  # 退出程序api_url = dify_cfg["api_url"]  # 从配置中提取API URLapi_key = dify_cfg["api_key"]  # 从配置中提取API密钥print("✅ Dify配置加载成功")  # 打印配置成功消息# 为每个用户添加监听for u in monitored_users:  # 遍历所有要监听的用户    try:        wx.AddListenChat(who=u)  # 为每个用户添加监听        print(f"👂 已添加监听用户: {u}")  # 打印添加监听成功消息    except Exception as e:  # 捕获异常        print(f"❌ 添加监听失败：{u}，原因：{e}")  # 打印添加监听失败消息        print("🛑 程序终止，请检查微信客户端状态和用户名称是否正确")        sys.exit(1)  # 终止程序，退出码为1表示异常退出conversation_ids = {}  # 初始化空字典，用于存储各用户的会话IDprint("🎯 开始监听消息...")  # 打印开始监听消息whileTrue:  # 主循环    try:        listen_dict = wx.GetListenMessage()  # 获取监听到的消息字典        for chat_win, message_list in listen_dict.items():  # 遍历消息字典中的每个聊天窗口和消息列表            if chat_win.who notin monitored_users:  # 如果发送消息的用户不在监听列表中                continue  # 跳过此用户            for msg in message_list:  # 遍历该用户的消息列表                if msg.type == "friend"and msg.content.strip():  # 如果是好友消息且内容不为空                    text = msg.content.strip()  # 获取消息内容并去除首尾空白                    print(f"📩 收到来自 [{chat_win.who}] 的消息: {text}")  # 打印收到的消息                    current_cid = conversation_ids.get(chat_win.who)  # 获取该用户的当前会话ID                    result = call_dify_api(  # 调用Dify API                        query=text,  # 传入用户消息                        api_url=api_url,  # 传入API URL                        api_key=api_key,  # 传入API密钥                        conversation_id=current_cid,  # 传入当前会话ID                        user_id=chat_win.who,  # 传入用户ID                    )                    if result and result.get("answer"):  # 如果API调用成功且有回复                        reply = result["answer"].strip()  # 获取回复内容并去除首尾空白                        print(f"📤 回复 [{chat_win.who}]: {reply}")  # 打印回复内容                        chat_win.SendMsg(reply)  # 发送回复消息                        if result.get("conversation_id"):  # 如果返回了新的会话ID                            conversation_ids[chat_win.who] = result["conversation_id"]  # 更新该用户的会话ID                            print(f"💾 会话ID已更新")  # 打印会话ID更新消息                    else:  # 如果API调用失败                        error_msg = "抱歉，暂时无法获取回复，请稍后再试。"  # 设置错误提示消息                        print(f"❌ 回复失败，发送错误提示")  # 打印错误提示                        chat_win.SendMsg(error_msg)  # 发送错误提示消息    except KeyboardInterrupt:  # 捕获Ctrl+C中断信号        print("\n🛑 用户中断，程序退出")  # 打印退出消息        break  # 跳出循环，退出程序    except Exception as e:  # 捕获其他所有异常        print(f"⚠️  出现错误：{e}")  # 打印错误信息        time.sleep(2)  # 等待2秒后继续