修改调试代码,打开加群消息显示
This commit is contained in:
@@ -33,10 +33,10 @@ class GroupMemberChange:
|
|||||||
|
|
||||||
def process_message(self, group_id, xml_data_current):
|
def process_message(self, group_id, xml_data_current):
|
||||||
""" 处理消息并更新 Redis """
|
""" 处理消息并更新 Redis """
|
||||||
print(f"Processing message for group_id: {group_id}")
|
# print(f"Processing message for group_id: {group_id}")
|
||||||
root_current = ET.fromstring(xml_data_current)
|
root_current = ET.fromstring(xml_data_current)
|
||||||
membercount_current = root_current.find('membercount').text
|
membercount_current = root_current.find('membercount').text
|
||||||
print(f"Current membercount: {membercount_current}")
|
# print(f"Current membercount: {membercount_current}")
|
||||||
|
|
||||||
result = [] # 初始化文案列表
|
result = [] # 初始化文案列表
|
||||||
|
|
||||||
@@ -61,14 +61,14 @@ class GroupMemberChange:
|
|||||||
|
|
||||||
else:
|
else:
|
||||||
# 使用本地缓存的数据进行比较
|
# 使用本地缓存的数据进行比较
|
||||||
print("Using local data for comparison")
|
# print("Using local data for comparison")
|
||||||
membercount_previous = self.local_membercount
|
membercount_previous = self.local_membercount
|
||||||
members_previous = self.local_members
|
members_previous = self.local_members
|
||||||
|
|
||||||
# 比较 membercount 是否发生变化
|
# 比较 membercount 是否发生变化
|
||||||
if membercount_current != membercount_previous:
|
if membercount_current != membercount_previous:
|
||||||
print(f"Membercount changed: {membercount_previous} -> {membercount_current}")
|
print(f"Membercount changed: {membercount_previous} -> {membercount_current}")
|
||||||
result.append(f"membercount has changed: {membercount_previous} -> {membercount_current}")
|
# result.append(f"membercount has changed: {membercount_previous} -> {membercount_current}")
|
||||||
members_current = self.get_current_members(group_id)
|
members_current = self.get_current_members(group_id)
|
||||||
|
|
||||||
# 比较成员,仅使用 wxid 进行比较
|
# 比较成员,仅使用 wxid 进行比较
|
||||||
@@ -81,11 +81,11 @@ class GroupMemberChange:
|
|||||||
# 添加变化成员的文案
|
# 添加变化成员的文案
|
||||||
for wxid in added_members:
|
for wxid in added_members:
|
||||||
nickname = members_current[wxid]
|
nickname = members_current[wxid]
|
||||||
print(f"Detected member added: {nickname} ({wxid})")
|
# print(f"Detected member added: {nickname} ({wxid})")
|
||||||
result.append(f"检测到 {nickname}({wxid})加入群聊")
|
result.append(f"检测到 {nickname}({wxid})加入群聊")
|
||||||
for wxid in removed_members:
|
for wxid in removed_members:
|
||||||
nickname = members_previous[wxid]
|
nickname = members_previous[wxid]
|
||||||
print(f"Detected member removed: {nickname} ({wxid})")
|
# print(f"Detected member removed: {nickname} ({wxid})")
|
||||||
result.append(f"检测到 {nickname}({wxid})退出群聊")
|
result.append(f"检测到 {nickname}({wxid})退出群聊")
|
||||||
|
|
||||||
# 更新本地缓存
|
# 更新本地缓存
|
||||||
@@ -99,7 +99,7 @@ class GroupMemberChange:
|
|||||||
self.r.hmset(f"group:group_members:{group_id}", members_current)
|
self.r.hmset(f"group:group_members:{group_id}", members_current)
|
||||||
|
|
||||||
else:
|
else:
|
||||||
print("No change detected in membercount")
|
# print("No change detected in membercount")
|
||||||
result.append("$NO_CHANGE$")
|
result.append("$NO_CHANGE$")
|
||||||
|
|
||||||
# 返回拼接后的结果
|
# 返回拼接后的结果
|
||||||
|
|||||||
4
robot.py
4
robot.py
@@ -164,7 +164,7 @@ class Robot(Job):
|
|||||||
try:
|
try:
|
||||||
group_id = get_first_group_id(match.group(1))
|
group_id = get_first_group_id(match.group(1))
|
||||||
self.LOG.info(f"邀请加入{match.group(1)}群,ID:{group_id}{msg.sender}")
|
self.LOG.info(f"邀请加入{match.group(1)}群,ID:{group_id}{msg.sender}")
|
||||||
self.wcf.invite_chatroom_members(group_id, msg.sender)
|
resp =self.wcf.invite_chatroom_members(group_id, msg.sender)
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
self.LOG.error(f"邀请加入群出错:{e}")
|
self.LOG.error(f"邀请加入群出错:{e}")
|
||||||
return True
|
return True
|
||||||
@@ -287,7 +287,7 @@ class Robot(Job):
|
|||||||
while wcf.is_receiving_msg():
|
while wcf.is_receiving_msg():
|
||||||
try:
|
try:
|
||||||
msg = wcf.get_msg()
|
msg = wcf.get_msg()
|
||||||
self.LOG.debug(msg)
|
self.LOG.info(msg)
|
||||||
self.processMsg(msg)
|
self.processMsg(msg)
|
||||||
except Empty:
|
except Empty:
|
||||||
continue # Empty message
|
continue # Empty message
|
||||||
|
|||||||
Reference in New Issue
Block a user