liuwei_x_x/abot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

新成员信息提醒，并且完成入库动作。

Browse Source
This commit is contained in:
liuwei
2025-05-28 16:30:58 +08:00
parent 60543bedc7
commit c8e93edfc4
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
plugins/group_member_change/main.py
View File

@@ -5,6 +5,8 @@ import xml.etree.ElementTree as ET
from base.plugin_common.message_plugin_interface import MessagePluginInterface from base.plugin_common.message_plugin_interface import MessagePluginInterface
from base.plugin_common.plugin_interface import PluginStatus 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.robot_cmd.robot_command import Feature, PermissionStatus, GroupBotManager
from utils.wechat.contact_manager import ContactManager from utils.wechat.contact_manager import ContactManager
from wechat_ipad import WechatAPIClient from wechat_ipad import WechatAPIClient
@@ -122,10 +124,16 @@ class GroupMemberChangePlugin(MessagePluginInterface):
await bot.send_at_message(roomid, f"👏欢迎 {nickname} 加入群聊！🎉", member_wxids) await bot.send_at_message(roomid, f"👏欢迎 {nickname} 加入群聊！🎉", member_wxids)
members = await bot.get_chatroom_member_detail(wxid, roomid) members = await bot.get_chatroom_member_detail(wxid, roomid)
head_url = members.get("SmallHeadImgUrl") or members.get("BigHeadImgUrl") or "" head_url = members.get("SmallHeadImgUrl") or members.get("BigHeadImgUrl") or ""
# 更新联系人信息 try:
ContactManager.get_instance().update_head_image(wxid, head_url) # 更新联系人信息
ContactManager.get_instance().update_group_members(roomid, wxid, nickname) 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""" xml_content = f"""
<appmsg appid="" sdkver="1"> <appmsg appid="" sdkver="1">
<title>👏欢迎 {nickname} 加入群聊！🎉</title> <title>👏欢迎 {nickname} 加入群聊！🎉</title>