diff --git a/plugins/group_member_change/main.py b/plugins/group_member_change/main.py index 5a2ad06..bb736d3 100644 --- a/plugins/group_member_change/main.py +++ b/plugins/group_member_change/main.py @@ -5,6 +5,8 @@ import xml.etree.ElementTree as ET from base.plugin_common.message_plugin_interface import MessagePluginInterface from base.plugin_common.plugin_interface import PluginStatus +from db.connection import DBConnectionManager +from db.contacts_db import ContactsDBOperator from utils.robot_cmd.robot_command import Feature, PermissionStatus, GroupBotManager from utils.wechat.contact_manager import ContactManager from wechat_ipad import WechatAPIClient @@ -122,10 +124,16 @@ class GroupMemberChangePlugin(MessagePluginInterface): await bot.send_at_message(roomid, f"👏欢迎 {nickname} 加入群聊!🎉", member_wxids) members = await bot.get_chatroom_member_detail(wxid, roomid) head_url = members.get("SmallHeadImgUrl") or members.get("BigHeadImgUrl") or "" - # 更新联系人信息 - ContactManager.get_instance().update_head_image(wxid, head_url) - ContactManager.get_instance().update_group_members(roomid, wxid, nickname) - + try: + # 更新联系人信息 + ContactManager.get_instance().update_head_image(wxid, head_url) + ContactManager.get_instance().update_group_members(roomid, wxid, nickname) + # 入库 + contact_db: ContactsDBOperator = ContactsDBOperator(DBConnectionManager.get_instance()) + member_details: List[Dict] = [members] + contact_db.save_chatroom_member_simple(roomid, member_details) + except Exception as e: + self.LOG.warning(f"新增群员信息失败: {e}") xml_content = f""" 👏欢迎 {nickname} 加入群聊!🎉