From 94aaa1aae5afdf1c5799e6f322535f6597c6710d Mon Sep 17 00:00:00 2001 From: liuwei Date: Mon, 19 Jan 2026 15:54:46 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=9B=B4=E6=96=B0=E7=9A=84?= =?UTF-8?q?=E9=80=BB=E8=BE=91=EF=BC=8C=E5=87=8F=E5=B0=91=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E5=8F=98=E6=9B=B4=E9=A1=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- utils/wechat/member_monitor.py | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/utils/wechat/member_monitor.py b/utils/wechat/member_monitor.py index 2c083cb..c6764c0 100644 --- a/utils/wechat/member_monitor.py +++ b/utils/wechat/member_monitor.py @@ -52,16 +52,17 @@ class ChatroomMemberMonitor: removed_wxids = [m['wxid'] for m in changes['removed']] self._remove_members_from_db(group_id, removed_wxids) - # 5.2 保存新增的成员 + # 5.2 保存新增的成员（使用原始API数据以正确映射字段） if changes['added']: - self.db.save_chatroom_member_simple(group_id, changes['added']) + added_raw = [m.get('raw_data', m) for m in changes['added']] + self.db.save_chatroom_member_simple(group_id, added_raw) self.logger.info(f"群 {group_id} 新增 {len(changes['added'])} 名成员缓存") - # 5.3 更新修改的成员 + # 5.3 更新修改的成员（同样使用原始API数据） if changes['modified']: - modified_members = [m['member'] for m in changes['modified']] - self.db.save_chatroom_member_simple(group_id, modified_members) - self.logger.info(f"群 {group_id} 更新 {len(modified_members)} 名成员缓存") + modified_raw = [m['member'].get('raw_data', m['member']) for m in changes['modified']] + self.db.save_chatroom_member_simple(group_id, modified_raw) + self.logger.info(f"群 {group_id} 更新 {len(modified_raw)} 名成员缓存") else: self.logger.info(f"群 {group_id} 成员无变化")