From 3318e175a25f5f647d21107d8209e608b043d66b Mon Sep 17 00:00:00 2001 From: liuwei Date: Tue, 22 Apr 2025 17:56:47 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E5=86=85=E5=AE=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- db/contacts_db.py | 3 +-- db/kid_photo_redis.py | 2 +- gewechat/api/callback.py | 4 ++-- gewechat/client/get_chatroom_members.py | 14 +++++++++----- 4 files changed, 13 insertions(+), 10 deletions(-) diff --git a/db/contacts_db.py b/db/contacts_db.py index 48ec11f..53c8fc6 100644 --- a/db/contacts_db.py +++ b/db/contacts_db.py @@ -11,7 +11,6 @@ from typing import List, Dict, Optional, Union, Any from db.base import BaseDBOperator from db.connection import DBConnectionManager -logger = logging.getLogger(__name__) class ContactsDBOperator(BaseDBOperator): @@ -19,7 +18,7 @@ class ContactsDBOperator(BaseDBOperator): def __init__(self, db_manager: DBConnectionManager): super().__init__(db_manager) - + self.logger = logging.getLogger(__name__) def _ensure_table_exists(self): """确保联系人表存在""" diff --git a/db/kid_photo_redis.py b/db/kid_photo_redis.py index 5631615..a3f3bc4 100644 --- a/db/kid_photo_redis.py +++ b/db/kid_photo_redis.py @@ -14,7 +14,7 @@ class KidPhotoRedisDB: def __init__(self, db_manager: DBConnectionManager): self.db_manager = db_manager self.prefix = "group:kid_photo:" - self.logger = logging.getLogger("DB.KidPhotoRedis") + logger = logging.getLogger("DB.KidPhotoRedis") def get_redis_connection(self): """获取Redis连接""" diff --git a/gewechat/api/callback.py b/gewechat/api/callback.py index 5033b04..5d62d7c 100644 --- a/gewechat/api/callback.py +++ b/gewechat/api/callback.py @@ -71,8 +71,8 @@ async def handle_mod_contacts(msg: WxMessage): logger.info(f"联系人信息变更: {msg.raw_data}") # 获取对应的Robot实例并刷新联系人 robot = robot_instances.get(msg.appid) - if robot: - robot.refresh_contacts() + # if robot: + # robot.refresh_contacts() async def handle_del_contacts(msg: WxMessage): diff --git a/gewechat/client/get_chatroom_members.py b/gewechat/client/get_chatroom_members.py index cff615c..dbf7b7a 100644 --- a/gewechat/client/get_chatroom_members.py +++ b/gewechat/client/get_chatroom_members.py @@ -7,11 +7,14 @@ headers = { 'X-GEWE-TOKEN': 'cb43f52db27e4a56bb6ec7da54373582', 'Content-Type': 'application/json' } +app_id = "wx_3BC6eSHGE5xEm_hH3__7c" + + def get_chatroom_members(): url = "/group/getChatroomMemberList" payload = json.dumps({ - "appId": "wx_3BC6eSHGE5xEm_hH3__7c", + "appId": app_id, "chatroomId": "52418238895@chatroom" }) @@ -20,21 +23,22 @@ def get_chatroom_members(): print(response.text) -def revoke_msg(): +def revoke_msg(): url = "/message/revokeMsg" payload = json.dumps({ - "appId": "{{appid}}", + "appId": app_id, "toWxid": "34757816141@chatroom", "msgId": "769533801", "newMsgId": "5271007655758710001", "createTime": "1704163145" }) - response = requests.request("POST", base_url+url, headers=headers, data=payload) + response = requests.request("POST", base_url + url, headers=headers, data=payload) print(response.text) + if __name__ == '__main__': - get_chatroom_members() \ No newline at end of file + get_chatroom_members()