fix: handle AlphaSift hotspot leader stocks field

Author: ZhuLinsen

apps/dsa-web/src/api/__tests__/alphasift.test.ts

@@ -205,6 +205,7 @@ describe('alphasiftApi', () => {
         summary: '玻璃基板盘中发酵',
         route: [{ title: '盘中发酵', description: '出现大笔买入' }],
         stocks: [{ code: '920438', name: '戈碧迦', role: '异动核心' }],
+        leader_stocks: [{ code: '920438', name: '戈碧迦', role: '异动核心' }],
         stock_count: 1,
       },
     });
@@ -218,6 +219,7 @@ describe('alphasiftApi', () => {
     expect(result.topic).toBe('玻璃基板');
     expect(result.stockCount).toBe(1);
     expect(result.stocks[0].name).toBe('戈碧迦');
+    expect(result.leaderStocks?.[0].name).toBe('戈碧迦');
   });
 
   it('uses a long timeout for LLM-backed screening', async () => {

apps/dsa-web/src/api/alphasift.ts

@@ -153,6 +153,7 @@ export type AlphaSiftHotspotDetail = {
   route: AlphaSiftHotspotRouteItem[];
   timeline?: AlphaSiftHotspotRouteItem[];
   stocks: AlphaSiftHotspotStock[];
+  leaderStocks?: AlphaSiftHotspotStock[];
   stockCount: number;
   sourceErrors?: string[];
   qualityStatus?: 'available' | 'partial' | 'stale' | 'failed' | string;

docs/CHANGELOG.md

@@ -40,6 +40,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/).
 - [文档] 补充 AlphaSift 迁移与回退边界：明确 `ALPHASIFT_INSTALL_SPEC` 显式覆盖语义、`requirements.txt + DEFAULT_ALPHASIFT_INSTALL_SPEC` 与运行时兼容边界、以及回滚路径（关闭功能/完整 revert）说明，覆盖旧 pin 用户升级行为。
 
 - [新功能] 个股分析历史成功保存后会从最终报告 best-effort 提取 `DecisionSignal` 决策信号，复用现有信号去重、计划质量计算和脱敏契约。
+- [修复] AlphaSift 热点详情兼容 `leader_stocks` 与 `stocks` 双字段，避免旧合约或缓存只提供其中一个字段时概念股详情报缺失字段。
 - [改进] 问股页移动端策略选择改为默认收起的按钮入口，展开后仍可多选策略并在发送后自动收起，减少对对话内容的遮挡。
 
 

src/services/alphasift_service.py

@@ -163,7 +163,7 @@ def _load_alphasift_hotspot_detail_cache(
     if stale and not allow_stale:
         return None
 
-    cached = dict(payload)
+    cached = _ensure_hotspot_detail_compat_fields(dict(payload))
     cached.update({
         "enabled": True,
         "provider": provider or cached.get("provider") or "akshare",
@@ -181,7 +181,7 @@ def _write_alphasift_hotspot_detail_cache(*, provider: str, topic: str, payload:
     cache_path = _alphasift_hotspot_detail_cache_path(provider=provider, topic=topic)
     try:
         cache_path.parent.mkdir(parents=True, exist_ok=True)
-        cleaned = _remove_non_finite_json_values(dict(payload))
+        cleaned = _remove_non_finite_json_values(_ensure_hotspot_detail_compat_fields(dict(payload)))
         cached_at = _utc_now_iso()
         cache_path.write_text(
             json.dumps(
@@ -201,6 +201,25 @@ def _write_alphasift_hotspot_detail_cache(*, provider: str, topic: str, payload:
         logger.warning("Failed to write AlphaSift hotspot detail cache for %s: %s", topic, exc)
 
 
+def _ensure_hotspot_detail_compat_fields(payload: Dict[str, Any]) -> Dict[str, Any]:
+    """Keep old and new AlphaSift hotspot detail consumers on the same shape."""
+    stocks = payload.get("stocks")
+    leader_stocks = payload.get("leader_stocks")
+    if not isinstance(stocks, list):
+        stocks = []
+    if not isinstance(leader_stocks, list):
+        leader_stocks = []
+    if not stocks and leader_stocks:
+        stocks = leader_stocks
+    if not leader_stocks and stocks:
+        leader_stocks = stocks
+    payload["stocks"] = stocks
+    payload["leader_stocks"] = leader_stocks
+    if not isinstance(payload.get("stock_count"), int):
+        payload["stock_count"] = len(stocks)
+    return payload
+
+
 def _load_alphasift_hotspot_cache(*, provider: str, top: int) -> Optional[Dict[str, Any]]:
     cache_path = _alphasift_hotspot_cache_path()
     try:
@@ -1028,6 +1047,7 @@ def hotspot_detail(self, *, topic: str, provider: str = "", refresh: bool = Fals
             if search_routes:
                 route = normalized.get("route")
                 normalized["route"] = search_routes + (route if isinstance(route, list) else [])
+        normalized = _ensure_hotspot_detail_compat_fields(normalized)
         normalized["enabled"] = True
         normalized["provider"] = provider_name
         cleaned = _remove_non_finite_json_values(normalized)
@@ -1105,7 +1125,13 @@ def _normalize_alphasift_hotspot_detail(detail: Any, *, provider: str, requested
     summary_value = raw.get("summary")
     summary: Dict[str, Any] = summary_value if isinstance(summary_value, dict) else {}
     stocks_value = raw.get("stocks")
+    leader_stocks_value = raw.get("leader_stocks")
     stocks: List[Any] = stocks_value if isinstance(stocks_value, list) else []
+    leader_stocks: List[Any] = leader_stocks_value if isinstance(leader_stocks_value, list) else []
+    if not stocks and leader_stocks:
+        stocks = leader_stocks
+    if not leader_stocks and stocks:
+        leader_stocks = stocks
     timeline_value = raw.get("timeline")
     timeline: List[Any] = timeline_value if isinstance(timeline_value, list) else []
     route_value = raw.get("route")
@@ -1122,7 +1148,7 @@ def _normalize_alphasift_hotspot_detail(detail: Any, *, provider: str, requested
         if isinstance(summary_text_value, str)
         else _build_alphasift_hotspot_summary_text(summary, topic=topic, canonical_topic=canonical_topic)
     )
-    return {
+    return _ensure_hotspot_detail_compat_fields({
         "enabled": True,
         "provider": provider,
         "topic": topic,
@@ -1134,6 +1160,7 @@ def _normalize_alphasift_hotspot_detail(detail: Any, *, provider: str, requested
         "route": route,
         "timeline": timeline,
         "stocks": stocks,
+        "leader_stocks": leader_stocks,
         "stock_count": len(stocks),
         "source_errors": source_errors,
         "quality_status": quality_status,
@@ -1142,7 +1169,7 @@ def _normalize_alphasift_hotspot_detail(detail: Any, *, provider: str, requested
         "stale": bool(summary.get("stale") or raw.get("stale") or False),
         "stale_age_hours": summary.get("stale_age_hours") or raw.get("stale_age_hours"),
         "resolver_candidates": _list_dict_values(summary.get("resolver_candidates") or raw.get("resolver_candidates")),
-    }
+    })
 
 
 def _list_text_values(value: Any) -> List[str]:
@@ -2190,16 +2217,17 @@ def hotspot_detail(self, topic: str) -> Dict[str, Any]:
                     "change_pct": None,
                     "hot_stock_score": 60.0,
                 })
-        return {
+        return _ensure_hotspot_detail_compat_fields({
             "topic": topic,
             "name": self._display_hotspot_name(topic),
             "canonical_topic": topic,
             "summary": self._build_hotspot_summary(topic, summary),
             "route": route,
             "stocks": stocks[:30],
+            "leader_stocks": stocks[:30],
             "stock_count": len(stocks),
             "source_errors": [],
-        }
+        })
 
     def _fetch_board_changes(self) -> Any:
         import pandas as pd

tests/test_alphasift_api.py

@@ -860,8 +860,40 @@ def get_hotspot_detail(topic: str, **kwargs: Any) -> Dict[str, Any]:
         self.assertEqual(payload["missing_fields"], ["live_stocks"])
         self.assertEqual(payload["source_errors"], ["none: no live detail rows"])
         self.assertEqual(payload["stocks"][0]["source"], "last_good_cache.leader_stocks")
+        self.assertEqual(payload["leader_stocks"][0]["source"], "last_good_cache.leader_stocks")
         self.assertEqual(payload["route"][0]["title"], "AI算力催化")
 
+    def test_hotspot_detail_backfills_stocks_from_contract_leader_stocks(self) -> None:
+        config = self._config(enabled=True)
+
+        def get_hotspot_detail(topic: str, **_kwargs: Any) -> Dict[str, Any]:
+            return {
+                "summary": {"topic": topic, "name": "算力"},
+                "leader_stocks": [{
+                    "code": "300001",
+                    "name": "算力龙头",
+                    "role": "核心龙头",
+                    "source": "last_good_cache.leader_stocks",
+                }],
+                "route": [{"title": "盘中发酵", "description": "真实新闻催化", "source": "news"}],
+            }
+
+        provider = alphasift_service.DsaEastMoneyHotspotProvider()
+        provider.hotspot_detail = MagicMock(side_effect=AssertionError("provider route fallback should not be used"))
+        with (
+            patch("src.services.alphasift_service._get_alphasift_status_snapshot", return_value=({}, True, {})),
+            patch("src.services.alphasift_service._resolve_hotspot_provider", return_value=("akshare", provider)),
+            patch(
+                "src.services.alphasift_service._import_alphasift_hotspot",
+                return_value=SimpleNamespace(get_hotspot_detail=get_hotspot_detail),
+            ),
+        ):
+            payload = self._hotspot_detail(config=config, provider="akshare", topic="AI算力")
+
+        self.assertEqual(payload["stocks"][0]["name"], "算力龙头")
+        self.assertEqual(payload["leader_stocks"][0]["name"], "算力龙头")
+        provider.hotspot_detail.assert_not_called()
+
     def test_hotspot_detail_uses_dsa_detail_cache_after_first_fetch(self) -> None:
         config = self._config(enabled=True)
         provider = alphasift_service.DsaEastMoneyHotspotProvider()
@@ -889,6 +921,7 @@ def test_hotspot_detail_uses_dsa_detail_cache_after_first_fetch(self) -> None:
         self.assertFalse(first.get("cache_used", False))
         self.assertTrue(second["cache_used"])
         self.assertEqual(second["stocks"][0]["name"], "盛龙股份")
+        self.assertEqual(second["leader_stocks"][0]["name"], "盛龙股份")
 
     def test_hotspot_detail_refresh_bypasses_dsa_detail_cache(self) -> None:
         config = self._config(enabled=True)
@@ -1118,6 +1151,7 @@ def hotspot_detail(self, topic: str) -> Dict[str, Any]:
         self.assertEqual(payload["topic"], "玻璃基板")
         self.assertEqual(payload["route"][0]["title"], "盘中发酵")
         self.assertEqual(payload["stocks"][0]["name"], "戈碧迦")
+        self.assertEqual(payload["leader_stocks"][0]["name"], "戈碧迦")
 
     def test_hotspot_detail_route_accepts_slash_containing_topic(self) -> None:
         config = self._config(enabled=True)