From 14a00faaa094c45eb7f525ba5364c703a5ecf3c3 Mon Sep 17 00:00:00 2001 From: H Vs Date: Mon, 24 Mar 2025 10:59:13 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/endpoints/pipeline_endpoint.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/app/endpoints/pipeline_endpoint.py b/app/endpoints/pipeline_endpoint.py index 803e44c..9c6cb94 100644 --- a/app/endpoints/pipeline_endpoint.py +++ b/app/endpoints/pipeline_endpoint.py @@ -21,10 +21,11 @@ messages_router = APIRouter() WX_BACKLIST=['fmessage', 'medianote','weixin','weixingongzhong','tmessage'] @messages_router.post("/messages",response_model=None) -async def get_chatroominfo(request: Request, body: Dict[str, Any]): - logger.info(f"收到微信回调消息: {json.dumps(msg, separators=(',', ':'),ensure_ascii=False)}") +async def get_messages(request: Request, body: Dict[str, Any]): + try: msg = body + logger.info(f"收到微信回调消息: {json.dumps(msg, separators=(',', ':'),ensure_ascii=False)}") type_name =msg.get("TypeName") app_id = msg.get("Appid") k, loginfo = await request.app.state.gewe_service.get_login_info_by_app_id_async(app_id)