fix: normalize report strategy price fields (#1264)

Author: ZhuLinsen

api/v1/endpoints/analysis.py

@@ -797,10 +797,10 @@ def get_analysis_status(task_id: str) -> TaskStatus:
                     analysis_summary=record.analysis_summary,
                 ),
                 strategy=ReportStrategy(
-                    ideal_buy=str(getattr(record, 'ideal_buy', None)) if getattr(record, 'ideal_buy', None) is not None else None,
-                    secondary_buy=str(getattr(record, 'secondary_buy', None)) if getattr(record, 'secondary_buy', None) is not None else None,
-                    stop_loss=str(getattr(record, 'stop_loss', None)) if getattr(record, 'stop_loss', None) is not None else None,
-                    take_profit=str(getattr(record, 'take_profit', None)) if getattr(record, 'take_profit', None) is not None else None,
+                    ideal_buy=_stringify_report_strategy_value(getattr(record, 'ideal_buy', None)),
+                    secondary_buy=_stringify_report_strategy_value(getattr(record, 'secondary_buy', None)),
+                    stop_loss=_stringify_report_strategy_value(getattr(record, 'stop_loss', None)),
+                    take_profit=_stringify_report_strategy_value(getattr(record, 'take_profit', None)),
                 ),
             ).model_dump()
             return TaskStatus(
@@ -872,6 +872,14 @@ def _load_sync_fundamental_sources(
         return None, None
 
 
+def _stringify_report_strategy_value(value: Any) -> Optional[str]:
+    if value is None:
+        return None
+    if isinstance(value, str):
+        return value
+    return str(value)
+
+
 def _build_analysis_report(
         report_data: Dict[str, Any],
         query_id: str,
@@ -932,10 +940,10 @@ def _build_analysis_report(
     strategy = None
     if strategy_data:
         strategy = ReportStrategy(
-            ideal_buy=strategy_data.get("ideal_buy"),
-            secondary_buy=strategy_data.get("secondary_buy"),
-            stop_loss=strategy_data.get("stop_loss"),
-            take_profit=strategy_data.get("take_profit")
+            ideal_buy=_stringify_report_strategy_value(strategy_data.get("ideal_buy")),
+            secondary_buy=_stringify_report_strategy_value(strategy_data.get("secondary_buy")),
+            stop_loss=_stringify_report_strategy_value(strategy_data.get("stop_loss")),
+            take_profit=_stringify_report_strategy_value(strategy_data.get("take_profit"))
         )
 
     extracted_fundamental = extract_fundamental_detail_fields(

docs/CHANGELOG.md

@@ -32,6 +32,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/).
 - [新功能] 通知网关新增默认关闭的进程内降噪配置，支持去重、冷却、静默时段和最低严重级别，并将每日摘要开关标记为预留能力。
 - [文档] 恢复多语言 README 新闻源配置表中推荐项的加粗样式，统一相关项目章节层级，并精简顶部导航、联系文案和尾部展示。
 - [修复] Docker 挂载的 `logs` 目录不可写时启动日志自动降级到控制台输出，并补充非 root 容器目录权限说明。
+- [修复] 修正分析报告 API 构建策略点位时数值字段未归一为字符串的问题，避免策略价格触发响应 DTO 类型校验失败。
 - [修复] Docker 启动入口自动修复 `data` / `logs` / `reports` 挂载目录权限并降权运行，文档化的 Compose `exec` 手动命令显式使用 `dsa` 用户，避免普通部署需要手动 `chown` / `chmod`。
 
 ## [3.16.0] - 2026-05-10

tests/test_analysis_api_contract.py

@@ -638,6 +638,34 @@ def test_build_analysis_report_extracts_fundamental_fields_from_snapshot(self) -
         self.assertEqual(report.details.financial_report["report_date"], "2025-12-31")
         self.assertEqual(report.details.dividend_metrics["ttm_dividend_yield_pct"], 2.5)
 
+    def test_build_analysis_report_stringifies_strategy_price_fields(self) -> None:
+        if _build_analysis_report is None:
+            self.skipTest("analysis endpoint helpers unavailable in this environment")
+
+        report = _build_analysis_report(
+            report_data={
+                "meta": {},
+                "summary": {},
+                "strategy": {
+                    "ideal_buy": 10.0,
+                    "secondary_buy": None,
+                    "stop_loss": 9.5,
+                    "take_profit": 11.6,
+                },
+                "details": {},
+            },
+            query_id="q1",
+            stock_code="600519",
+            stock_name="贵州茅台",
+            context_snapshot=None,
+            fallback_fundamental_payload=None,
+        )
+
+        self.assertEqual(report.strategy.ideal_buy, "10.0")
+        self.assertIsNone(report.strategy.secondary_buy)
+        self.assertEqual(report.strategy.stop_loss, "9.5")
+        self.assertEqual(report.strategy.take_profit, "11.6")
+
     def test_build_analysis_report_extracts_related_board_fields_from_snapshot(self) -> None:
         if _build_analysis_report is None:
             self.skipTest("analysis endpoint helpers unavailable in this environment")