app/api/callback.py
@@ -48,8 +48,13 @@ f"收到回调消息: messageType={callback_data.messageType}, wcId={callback_data.wcId}" ) # 将Pydantic模型转换为字典 # 将Pydantic模型转换为字典(兼容v1和v2) if hasattr(callback_data, 'model_dump'): # Pydantic v2 callback_dict = callback_data.model_dump() else: # Pydantic v1 callback_dict = callback_data.dict() # 将消息加入队列 success = message_processor.enqueue_callback_message(callback_dict)