From 7470b5fe2d3dde36d7b37c6bccee157660a8f7f5 Mon Sep 17 00:00:00 2001
From: zhongcheng <cheng.zhong@t-systems.com>
Date: Thu, 5 Mar 2026 15:22:21 +0800
Subject: [PATCH] print request

---
 main.py | 29 +++++++++++++++++++++++------
 1 file changed, 23 insertions(+), 6 deletions(-)

diff --git a/main.py b/main.py
index 041c589..c298cab 100644
--- a/main.py
+++ b/main.py
@@ -2,7 +2,7 @@
 
 import logging
 
-from fastapi import FastAPI
+from fastapi import FastAPI, Request
 from fastapi.middleware.cors import CORSMiddleware
 from pydantic import BaseModel
 
@@ -43,7 +43,7 @@ class FullWorkflowResponse(BaseModel):
     status: str = "success"
 
 @app.post("/workflow/full", response_model=FullWorkflowResponse)
-async def full_workflow(request: RequirementRequest):
+async def full_workflow(request: Request):
     """
     完整工作流：PM Agent -> QA Agent -> Dev Agent
 
@@ -65,12 +65,29 @@ async def full_workflow(request: RequirementRequest):
         }
     """
     try:
-        logger.info(f"开始处理需求: {request.message}")
+        # 2. 获取原始 body（字节串）
+        body_bytes = await request.body()
 
-        # 调用编排函数，执行三个Agent的工作流
-        await orchestrate_agents(request.message)
+        # 3. 尝试解码为字符串并打印
+        try:
+            body_str = body_bytes.decode('utf-8')
+            print(f"Raw body (string): {body_str}")
+        except UnicodeDecodeError:
+            print("Raw body is not valid UTF-8")
 
-        # 构建响应
+        # 4. 尝试解析 JSON（如果失败则记录错误但不影响返回）
+        try:
+            json_data = await request.json()
+            print(f"Parsed JSON: {json_data}")
+        except Exception as e:
+            print(f"JSON parse error: {e}")
+
+        # logger.info(f"开始处理需求: {request.message}")
+        #
+        # # 调用编排函数，执行三个Agent的工作流
+        # await orchestrate_agents(request.message)
+        #
+        # # 构建响应
         response = FullWorkflowResponse(
             status="success"
         )