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)