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-04-22 17:56:47 +08:00
parent 2e4a426dcf
commit 3318e175a2
4 changed files with 13 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
db/contacts_db.py
View File

@@ -11,7 +11,6 @@ from typing import List, Dict, Optional, Union, Any
from db.base import BaseDBOperator from db.base import BaseDBOperator
from db.connection import DBConnectionManager from db.connection import DBConnectionManager
logger = logging.getLogger(__name__)
class ContactsDBOperator(BaseDBOperator): class ContactsDBOperator(BaseDBOperator):
@@ -19,7 +18,7 @@ class ContactsDBOperator(BaseDBOperator):
def __init__(self, db_manager: DBConnectionManager): def __init__(self, db_manager: DBConnectionManager):
super().__init__(db_manager) super().__init__(db_manager)
self.logger = logging.getLogger(__name__)
def _ensure_table_exists(self): def _ensure_table_exists(self):
"""确保联系人表存在""" """确保联系人表存在"""

2
db/kid_photo_redis.py
View File

@@ -14,7 +14,7 @@ class KidPhotoRedisDB:
def __init__(self, db_manager: DBConnectionManager): def __init__(self, db_manager: DBConnectionManager):
self.db_manager = db_manager self.db_manager = db_manager
self.prefix = "group:kid_photo:" self.prefix = "group:kid_photo:"
self.logger = logging.getLogger("DB.KidPhotoRedis") logger = logging.getLogger("DB.KidPhotoRedis")
def get_redis_connection(self): def get_redis_connection(self):
"""获取Redis连接""" """获取Redis连接"""

4
gewechat/api/callback.py
View File

@@ -71,8 +71,8 @@ async def handle_mod_contacts(msg: WxMessage):
logger.info(f"联系人信息变更: {msg.raw_data}") logger.info(f"联系人信息变更: {msg.raw_data}")
# 获取对应的Robot实例并刷新联系人 # 获取对应的Robot实例并刷新联系人
robot = robot_instances.get(msg.appid) robot = robot_instances.get(msg.appid)
if robot: # if robot:
robot.refresh_contacts() # robot.refresh_contacts()
async def handle_del_contacts(msg: WxMessage): async def handle_del_contacts(msg: WxMessage):

12
gewechat/client/get_chatroom_members.py
View File

@@ -7,11 +7,14 @@ headers = {
'X-GEWE-TOKEN': 'cb43f52db27e4a56bb6ec7da54373582', 'X-GEWE-TOKEN': 'cb43f52db27e4a56bb6ec7da54373582',
'Content-Type': 'application/json' 'Content-Type': 'application/json'
} }
app_id = "wx_3BC6eSHGE5xEm_hH3__7c"
def get_chatroom_members(): def get_chatroom_members():
url = "/group/getChatroomMemberList" url = "/group/getChatroomMemberList"
payload = json.dumps({ payload = json.dumps({
"appId": "wx_3BC6eSHGE5xEm_hH3__7c", "appId": app_id,
"chatroomId": "52418238895@chatroom" "chatroomId": "52418238895@chatroom"
}) })
@@ -20,21 +23,22 @@ def get_chatroom_members():
print(response.text) print(response.text)
def revoke_msg():
def revoke_msg():
url = "/message/revokeMsg" url = "/message/revokeMsg"
payload = json.dumps({ payload = json.dumps({
"appId": "{{appid}}", "appId": app_id,
"toWxid": "34757816141@chatroom", "toWxid": "34757816141@chatroom",
"msgId": "769533801", "msgId": "769533801",
"newMsgId": "5271007655758710001", "newMsgId": "5271007655758710001",
"createTime": "1704163145" "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) print(response.text)
if __name__ == '__main__': if __name__ == '__main__':
get_chatroom_members() get_chatroom_members()