diff --git a/app/endpoints/pipeline_endpoint.py b/app/endpoints/pipeline_endpoint.py index de34a8d..d88eab0 100644 --- a/app/endpoints/pipeline_endpoint.py +++ b/app/endpoints/pipeline_endpoint.py @@ -1033,8 +1033,8 @@ async def handle_10000_msg_async(request: Request,token_id,app_id, wxid,msg_data content=msg_data.get("Content","").get("string","") if '修改群名' or '新群主' or '被移除群聊通知' in content and check_chatroom(from_wxid): - logger.info(f'{content} chatroom_id {chatroom_id} ') chatroom_id=from_wxid + logger.info(f'{content} chatroom_id {chatroom_id} ') await request.app.state.gewe_service.update_group_info_to_cache_async(token_id,app_id,wxid,chatroom_id) await request.app.state.gewe_service.update_group_members_to_cache_async(token_id,app_id,wxid,chatroom_id)