fix(review-feedback-1245): address latest review comments

Author: ZhuLinsen

src/analyzer.py

@@ -646,6 +646,8 @@ def stabilize_decision_with_structure(
             _first_list_value(trend_dict.get("resistance_levels")),
         )
         flow_bias = _capital_flow_bias(fundamental_context)
+        if flow_bias == "unavailable":
+            return
         decision_type = infer_decision_type_from_advice(
             getattr(result, "decision_type", ""),
             default=getattr(result, "decision_type", "hold") or "hold",
@@ -808,24 +810,32 @@ def _first_numeric_value(*values: Any) -> Optional[float]:
 
 def _capital_flow_bias(fundamental_context: Optional[Dict[str, Any]]) -> str:
     if not isinstance(fundamental_context, dict):
-        return "neutral"
+        return "unavailable"
     block = fundamental_context.get("capital_flow")
     if not isinstance(block, dict):
-        return "neutral"
+        return "unavailable"
+    if block.get("status") == "not_supported":
+        return "unavailable"
     data = block.get("data") if isinstance(block.get("data"), dict) else block
     stock_flow = data.get("stock_flow") if isinstance(data, dict) else None
-    if not isinstance(stock_flow, dict):
-        return "neutral"
+    if not isinstance(stock_flow, dict) or not stock_flow:
+        return "unavailable"
 
     def _flow_direction(value: Optional[float]) -> Optional[str]:
         if value is None or value == 0:
             return None
         return "inflow" if value > 0 else "outflow"
 
+    numeric_values = [
+        _coerce_numeric_value(stock_flow.get("main_net_inflow")),
+        _coerce_numeric_value(stock_flow.get("inflow_5d")),
+        _coerce_numeric_value(stock_flow.get("inflow_10d")),
+    ]
+    if all(value is None for value in numeric_values):
+        return "unavailable"
+
     ordered_signals = [
-        _flow_direction(_coerce_numeric_value(stock_flow.get("main_net_inflow"))),
-        _flow_direction(_coerce_numeric_value(stock_flow.get("inflow_5d"))),
-        _flow_direction(_coerce_numeric_value(stock_flow.get("inflow_10d"))),
+        _flow_direction(value) for value in numeric_values
     ]
     directions = {signal for signal in ordered_signals if signal is not None}
     if not directions or len(directions) > 1:

tests/test_decision_stability.py

@@ -52,6 +52,15 @@ def _fund_flow(main: float, five_day: float = 0.0, ten_day: float = 0.0) -> dict
     }
 
 
+def _unsupported_fund_flow() -> dict:
+    return {"capital_flow": {"status": "not_supported", "data": {}}}
+
+
+def test_capital_flow_bias_is_unavailable_when_stock_flow_data_is_missing() -> None:
+    assert _capital_flow_bias(_unsupported_fund_flow()) == "unavailable"
+    assert _capital_flow_bias({"capital_flow": {"status": "ok", "data": {}}}) == "unavailable"
+
+
 def test_capital_flow_bias_is_neutral_when_missing_main_windows_conflict() -> None:
     context = {
         "capital_flow": {
@@ -115,6 +124,40 @@ def test_downgrades_buy_mid_range_with_neutral_fund_flow() -> None:
     assert "资金流不明确" in result.risk_warning
 
 
+def test_skips_calibration_when_capital_flow_is_unavailable() -> None:
+    buy_result = _result(
+        decision_type="buy",
+        operation_advice="买入",
+        score=66,
+        current_price=32.0,
+    )
+    sell_result = _result(
+        decision_type="sell",
+        operation_advice="卖出",
+        score=30,
+        current_price=30.4,
+        change_pct=-2.1,
+    )
+
+    stabilize_decision_with_structure(
+        buy_result,
+        SimpleNamespace(support_levels=[30.0], resistance_levels=[34.0]),
+        _unsupported_fund_flow(),
+    )
+    stabilize_decision_with_structure(
+        sell_result,
+        SimpleNamespace(support_levels=[30.0], resistance_levels=[34.0]),
+        _unsupported_fund_flow(),
+    )
+
+    assert buy_result.decision_type == "buy"
+    assert buy_result.operation_advice == "买入"
+    assert "decision_stability" not in buy_result.dashboard
+    assert sell_result.decision_type == "sell"
+    assert sell_result.operation_advice == "卖出"
+    assert "decision_stability" not in sell_result.dashboard
+
+
 def test_downgrades_sell_near_support_without_sustained_outflow() -> None:
     result = _result(
         decision_type="sell",