调整

app/endpoints/pipeline_endpoint.py

@@ -22,10 +22,10 @@ messages_router = APIRouter()
 WX_BACKLIST=['fmessage', 'medianote','weixin','weixingongzhong','tmessage']
 @messages_router.post("/messages",response_model=None)
 async def get_messages(request: Request, body: Dict[str, Any]):
-    
+    logger.info(f"收到微信回调消息: {json.dumps(body, separators=(',', ':'),ensure_ascii=False)}")
     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)