'commit'

Controller/YltAnalyticsController.py

@@ -97,27 +97,30 @@ async def export_prices_zip():
 
 @router.get("/api/ai/pricing/strategy-summary")
 async def ai_pricing_strategy_summary():
-    resp = await get_operators_hourly_prices()
-    data = resp.get("operators", [])
-    text_data = []
-    for item in data:
-        text_data.append({"operator": item.get("operator"), "series": item.get("series")})
-    text = (
-        "下面是四家供应商（新电途、特来电、驿来特、艾特吉易充）基于最新爬取数据计算出的平均24小时分时电价：\n"
-        f"{text_data}\n"
-        "请根据这些数据，综合分析各司的定价策略差异，重点对比我司（驿来特）与其他供应商的分时电价水平，"
-        "指出我司在不同时段可能存在的潜在问题和风险（例如明显偏贵、价格结构不合理等），并给出2-3条可执行的优化建议。"
-        "回答控制在600字以内。"
-    )
-    chunks: List[str] = []
-    async for chunk in get_llm_response(
-        text,
-        stream=False,
-        system_prompt="你是熟悉中国充电桩行业的电价策略分析顾问。",
-    ):
-        chunks.append(chunk)
-    summary_text = "".join(chunks)
-    return JSONResponse({"summary": summary_text})
+    async def generate_stream():
+        resp = await get_operators_hourly_prices()
+        data = resp.get("operators", [])
+        text_data = []
+        for item in data:
+            text_data.append({"operator": item.get("operator"), "series": item.get("series")})
+        
+        prompt = (
+            "下面是四家供应商（新电途、特来电、驿来特、艾特吉易充）基于最新爬取数据计算出的平均24小时分时电价：\n"
+            f"{text_data}\n"
+            "请根据这些数据，综合分析各司的定价策略差异，重点对比我司（驿来特）与其他供应商的分时电价水平，"
+            "指出我司在不同时段可能存在的潜在问题和风险（例如明显偏贵、价格结构不合理等），并给出2-3条可执行的优化建议。"
+            "请使用Markdown格式输出，重点可以使用加粗，如有公式可使用LaTeX格式。"
+            "回答控制在800字以内。"
+        )
+        
+        async for chunk in get_llm_response(
+            prompt,
+            stream=True,
+            system_prompt="你是熟悉中国充电桩行业的电价策略分析顾问。",
+        ):
+            yield chunk
+
+    return StreamingResponse(generate_stream(), media_type="text/event-stream")
 
 
 @router.get("/api/ylt/stations", response_model=List[StationBase])