fix: support KR stock autocomplete suggestions (#1723)

* fix: support KR stock autocomplete suggestions

* fix(review-feedback-1723): 补充自动补全 JP/KR 建议渲染截图、前后对比或无法截图说明

* fix(review-feedback-1723): 补充 Web 自动补全 JP/KR 建议渲染的截图或无法截图说明

* fix(review-feedback-1723): docs/review-evidence-kr-autocomplete-ui.md 是针对本 PR

* fix(review-feedback-1723): 修正 PR 描述与当前 head 的实际改动、验证范围不一致问题

* fix(review-feedback-1723): 修正 PR 描述与当前 diff 的实质性不一致，避免合入记录误导后续维护者

* fix(review-feedback-1723): 收敛 PR 描述与实际 diff 的契约不一致，避免用户误以为裸 005930 已会解析为 005930.KS

* fix(review-feedback-1723): 把描述、验证证据和兼容性说明收敛到当前 6 个改动文件真实范围，或补齐描述中声称的后端/历史链路实现与测试

* fix(review-feedback-1723): 收敛 PR 描述与实际 diff，避免把未实现的 bare-code/历史展示能力作为本 PR 已交付内容合入

* fix(review-feedback-1723): 补上相应真实代码与测试后再审

* fix(review-feedback-1723): 补齐所声称的后端实现与测试后再评审

* fix(review-feedback-1723): PR description 与当前完整 diff 不一致：描述声称新增 bare JP/KR code

* fix(review-feedback-1723): PR 描述与当前完整 diff 不一致

* fix(review-feedback-1723): 补充 Refs 1718，方便后续追踪

* fix(review-feedback-1723): 收敛描述与验证证据

* fix: resolve JP KR bare stock codes

* fix: backfill JP KR daily analysis context

* fix(review-feedback-1723): preserve persisted phase timing

* fix: align JP KR history lookup keys

* fix(review-feedback-1723): preserve raw code for snapshot lookups

* fix(review-feedback-1723): 收敛

Author: ZhuLinsen

api/v1/endpoints/analysis.py

@@ -55,6 +55,7 @@
 )
 from api.v1.schemas.run_flow import RunFlowSnapshot
 from data_provider.base import canonical_stock_code, normalize_stock_code
+from src.data.stock_index_loader import resolve_index_stock_code
 from src.config import Config
 from src.core.market_review_lock import (
     MarketReviewExecutionLock as _MarketReviewExecutionLock,
@@ -69,11 +70,14 @@
     extract_analysis_context_pack_overview,
     sanitize_context_snapshot_for_api,
 )
-from src.market_phase_summary import extract_market_phase_summary, render_market_phase_summary
+from src.market_phase_summary import (
+    extract_market_phase_summary,
+    rebuild_market_phase_summary_for_stock_code,
+)
+from src.services.stock_code_utils import is_code_like, resolve_index_stock_code_for_analysis
 from src.report_language import get_localized_stock_name, normalize_report_language
 from src.schemas.decision_action import build_action_fields
 from src.services.name_to_code_resolver import resolve_name_to_code
-from src.services.stock_code_utils import is_code_like
 from src.services.task_queue import (
     get_task_queue,
     DuplicateTaskError,
@@ -199,7 +203,7 @@ def _resolve_and_normalize_input(raw_value: str) -> str:
         return ""
 
     if is_code_like(text):
-        return canonical_stock_code(text)
+        return resolve_index_stock_code_for_analysis(text)
 
     if _is_obviously_invalid_analysis_input(text):
         raise _invalid_analysis_input_error()
@@ -818,6 +822,20 @@ def _extract_report_created_at(payload: Dict[str, Any]) -> Optional[str]:
     return _datetime_to_iso(meta.get("created_at"))
 
 
+def _display_stock_code_from_index(stock_code: Any) -> str:
+    code = str(stock_code or "").strip()
+    if not code:
+        return code
+    return resolve_index_stock_code(code) or code
+
+
+def _display_market_phase_summary(stock_code: Any, context_snapshot: Any) -> Any:
+    return rebuild_market_phase_summary_for_stock_code(
+        _display_stock_code_from_index(stock_code),
+        context_snapshot,
+    )
+
+
 def _prepare_report_for_task_enrichment(
     report_data: Dict[str, Any],
     created_at: Optional[str],
@@ -866,6 +884,9 @@ def _build_task_analysis_result(task: Any) -> AnalysisResultResponse:
         payload["trace_id"] = _get_task_trace_id(task) or task.task_id
     if not payload.get("stock_code"):
         payload["stock_code"] = task.stock_code
+    display_stock_code = _display_stock_code_from_index(payload.get("stock_code"))
+    if display_stock_code:
+        payload["stock_code"] = display_stock_code
 
     if not payload.get("stock_name") and getattr(task, "stock_name", None):
         payload["stock_name"] = task.stock_name
@@ -911,6 +932,14 @@ def _build_task_analysis_result(task: Any) -> AnalysisResultResponse:
                 )
 
     if not report_enriched and isinstance(report_data, dict):
+        meta = report_data.get("meta")
+        if isinstance(meta, dict) and display_stock_code:
+            raw_meta_code = meta.get("stock_code") or getattr(task, "stock_code", None)
+            meta["stock_code"] = display_stock_code
+            meta["market_phase_summary"] = _display_market_phase_summary(
+                raw_meta_code,
+                {"market_phase_summary": meta.get("market_phase_summary")},
+            )
         payload["report"] = _ensure_report_action_fields(report_data)
 
     return AnalysisResultResponse.model_validate(payload)
@@ -1030,12 +1059,13 @@ def get_analysis_status(task_id: str) -> TaskStatus:
                 (raw_result or {}).get("report_language") if isinstance(raw_result, dict) else None
             )
             stock_name = get_localized_stock_name(record.name, record.code, report_language)
+            display_stock_code = _display_stock_code_from_index(record.code)
 
             # Extract current_price / change_pct from context_snapshot
             skills = None
             context_snapshot = parse_json_field(getattr(record, 'context_snapshot', None))
             analysis_context_pack_overview = extract_analysis_context_pack_overview(context_snapshot)
-            market_phase_summary = extract_market_phase_summary(context_snapshot)
+            market_phase_summary = _display_market_phase_summary(record.code, context_snapshot)
             api_context_snapshot = sanitize_context_snapshot_for_api(context_snapshot)
             if context_snapshot and isinstance(context_snapshot, dict):
                 raw_skills = context_snapshot.get("skills")
@@ -1083,7 +1113,7 @@ def get_analysis_status(task_id: str) -> TaskStatus:
                 meta=ReportMeta(
                     id=record.id,
                     query_id=task_id,
-                    stock_code=record.code,
+                    stock_code=display_stock_code,
                     stock_name=stock_name,
                     report_type=getattr(record, 'report_type', None),
                     report_language=report_language,
@@ -1117,15 +1147,15 @@ def get_analysis_status(task_id: str) -> TaskStatus:
                 result=AnalysisResultResponse(
                     query_id=task_id,
                     trace_id=task_id,
-                    stock_code=record.code,
+                    stock_code=display_stock_code,
                     stock_name=stock_name,
                     report=report_dict,
                     diagnostic_summary=build_run_diagnostic_summary(
                         context_snapshot=context_snapshot,
                         raw_result=raw_result,
                         report_saved=True,
                         query_id=task_id,
-                        stock_code=record.code,
+                        stock_code=display_stock_code,
                     ),
                     created_at=record.created_at.isoformat() if record.created_at else datetime.now().isoformat()
                 ),
@@ -1215,9 +1245,10 @@ def _build_analysis_report(
         or (context_snapshot or {}).get("report_language")
         or getattr(Config.get_instance(), "report_language", "zh")
     )
+    display_stock_code = _display_stock_code_from_index(meta_data.get("stock_code", stock_code))
     localized_stock_name = get_localized_stock_name(
         meta_data.get("stock_name", stock_name),
-        meta_data.get("stock_code", stock_code),
+        display_stock_code,
         report_language,
     )
     realtime_fields = extract_realtime_detail_fields(context_snapshot)
@@ -1227,15 +1258,19 @@ def _build_analysis_report(
     change_pct = meta_data.get("change_pct")
     if change_pct is None:
         change_pct = realtime_fields.get("change_pct")
-    market_phase_summary = extract_market_phase_summary(context_snapshot)
+    raw_stock_code = meta_data.get("stock_code", stock_code)
+    market_phase_summary = _display_market_phase_summary(raw_stock_code, context_snapshot)
     if market_phase_summary is None:
         meta_phase_summary = meta_data.get("market_phase_summary")
         if meta_phase_summary is not None:
-            market_phase_summary = render_market_phase_summary(meta_phase_summary)
+            market_phase_summary = _display_market_phase_summary(
+                raw_stock_code,
+                {"market_phase_summary": meta_phase_summary},
+            )
 
     meta = ReportMeta(
         query_id=meta_data.get("query_id", query_id),
-        stock_code=meta_data.get("stock_code", stock_code),
+        stock_code=display_stock_code,
         stock_name=localized_stock_name,
         report_type=meta_data.get("report_type", "detailed"),
         report_language=report_language,

api/v1/endpoints/history.py

@@ -259,6 +259,7 @@ def get_stock_bar(
         from datetime import date as date_type
         from src.utils.data_processing import parse_json_field
 
+        service = HistoryService(db_manager)
         start = date_type.fromisoformat(start_date) if start_date else None
         end = date_type.fromisoformat(end_date) if end_date else None
 
@@ -274,7 +275,8 @@ def get_stock_bar(
         # Deduplicate by normalized code, keeping the record with highest id
         seen: dict = {}
         for record in records:
-            norm_code = _normalize_code_for_grouping(record.code or "")
+            display_code = service._display_stock_code(record.code or "")
+            norm_code = _normalize_code_for_grouping(display_code)
             if norm_code not in seen or record.id > seen[norm_code].id:
                 seen[norm_code] = record
 
@@ -295,16 +297,15 @@ def get_stock_bar(
                 ),
             )
 
+            display_stock_code = service._display_stock_code(record.code)
             analysis_count = db_manager.get_analysis_history_paginated(
-                code=HistoryService._history_code_filter_candidates(
-                    record.code or "",
-                ),
+                code=HistoryService._history_code_filter_candidates(display_stock_code),
                 limit=1,
             )[1]
             items.append(
                 StockBarItem(
                     id=record.id,
-                    stock_code=record.code or "",
+                    stock_code=display_stock_code,
                     stock_name=record.name,
                     report_type=record.report_type,
                     sentiment_score=record.sentiment_score,
@@ -316,7 +317,10 @@ def get_stock_bar(
                         record.created_at.isoformat() if record.created_at else None
                     ),
                     model_used=normalize_model_used(model_used),
-                    market_phase_summary=extract_market_phase_summary(getattr(record, "context_snapshot", None)),
+                    market_phase_summary=service._display_market_phase_summary(
+                        record.code,
+                        getattr(record, "context_snapshot", None),
+                    ),
                 )
             )
 
@@ -385,7 +389,9 @@ def get_history_detail(
         # 同时不混用 `change_60d`（60 日累计涨跌幅）作为日内 change_pct 的兜底。
         context_snapshot = result.get("context_snapshot")
         analysis_context_pack_overview = extract_analysis_context_pack_overview(context_snapshot)
-        market_phase_summary = extract_market_phase_summary(context_snapshot)
+        market_phase_summary = result.get("market_phase_summary")
+        if market_phase_summary is None:
+            market_phase_summary = extract_market_phase_summary(context_snapshot)
         api_context_snapshot = sanitize_context_snapshot_for_api(context_snapshot)
         realtime_fields = extract_realtime_detail_fields(context_snapshot)
         current_price = realtime_fields.get("current_price")
@@ -453,7 +459,7 @@ def get_history_detail(
 
         fallback_fundamental = db_manager.get_latest_fundamental_snapshot(
             query_id=result.get("query_id", ""),
-            code=result.get("stock_code", ""),
+            code=result.get("storage_stock_code") or result.get("stock_code", ""),
         )
         extracted_fundamental = extract_fundamental_detail_fields(
             context_snapshot=result.get("context_snapshot"),

apps/dsa-web/src/components/StockAutocomplete/SuggestionsList.tsx

@@ -1,8 +1,5 @@
 /**
- * SuggestionsList Component
- *
- * Stock search suggestion list
- * Displays matched stock options
+ * Stock search suggestion list.
  */
 
 import type { CSSProperties } from 'react';
@@ -42,7 +39,7 @@ export function SuggestionsList({
         ...style,
         backgroundColor: 'hsl(var(--card) / 0.85)',
         borderColor: 'var(--border-accent)',
-        boxShadow: '0 10px 25px -5px rgba(0, 0, 0, 0.3), 0 8px 10px -6px rgba(0, 0, 0, 0.3), -4px 0 15px -3px rgba(0, 0, 0, 0.2), 4px 0 15px -3px rgba(0, 0, 0, 0.2)'
+        boxShadow: '0 10px 25px -5px rgba(0, 0, 0, 0.3), 0 8px 10px -6px rgba(0, 0, 0, 0.3), -4px 0 15px -3px rgba(0, 0, 0, 0.2), 4px 0 15px -3px rgba(0, 0, 0, 0.2)',
       }}
       role="listbox"
     >
@@ -52,18 +49,16 @@ export function SuggestionsList({
           role="option"
           aria-selected={index === highlightedIndex}
           className={cn(
-            "px-4 py-1 cursor-pointer flex items-center justify-between",
-            "hover:bg-[var(--autocomplete-hover-bg)]/25",
-            index === highlightedIndex && "bg-[var(--autocomplete-hover-bg)]/25"
+            'px-4 py-1 cursor-pointer flex items-center justify-between',
+            'hover:bg-[var(--autocomplete-hover-bg)]/25',
+            index === highlightedIndex && 'bg-[var(--autocomplete-hover-bg)]/25',
           )}
           onClick={() => onSelect(suggestion)}
           onMouseEnter={() => onMouseEnter(index)}
         >
           <div className="flex items-center gap-3">
-            {/* Market badge */}
             <MarketBadge market={suggestion.market} />
 
-            {/* Name and code */}
             <div className="flex flex-col">
               <span className="text-sm font-medium text-primary-text">
                 {suggestion.nameZh}
@@ -74,19 +69,19 @@ export function SuggestionsList({
             </div>
           </div>
 
-          {/* Match type badge */}
           <MatchTypeBadge matchType={suggestion.matchType} />
         </li>
       ))}
     </ul>
   );
 }
 
-// Helper component: Market badge
 const MARKET_BADGE_CONFIG = {
   CN: { label: 'A股', className: 'border-danger/25 bg-danger/10 text-danger' },
   HK: { label: '港股', className: 'border-success/25 bg-success/10 text-success' },
   US: { label: '美股', className: 'border-cyan/25 bg-cyan/10 text-cyan' },
+  JP: { label: '日股', className: 'border-indigo-500/25 bg-indigo-500/10 text-indigo-500' },
+  KR: { label: '韩股', className: 'border-rose-500/25 bg-rose-500/10 text-rose-500' },
   INDEX: { label: '指数', className: 'border-purple/25 bg-purple/10 text-purple' },
   ETF: { label: 'ETF', className: 'border-warning/25 bg-warning/10 text-warning' },
   BSE: { label: '北交所', className: 'border-orange-500/25 bg-orange-500/10 text-orange-500' },
@@ -100,13 +95,12 @@ function MarketBadge({ market }: { market: string }) {
   }
 
   return (
-    <Badge variant="default" size="sm" className={cn("min-w-[3rem] justify-center shadow-none", config.className)}>
+    <Badge variant="default" size="sm" className={cn('min-w-[3rem] justify-center shadow-none', config.className)}>
       {config.label}
     </Badge>
   );
 }
 
-// Helper component: Match type badge
 function MatchTypeBadge({ matchType }: { matchType: string }) {
   const configMap = {
     exact: { label: '精确', className: 'border-cyan/25 bg-cyan/10 text-cyan' },
@@ -118,7 +112,7 @@ function MatchTypeBadge({ matchType }: { matchType: string }) {
   const config = configMap[matchType as keyof typeof configMap] || configMap.fuzzy;
 
   return (
-    <Badge variant="default" size="sm" className={cn("shrink-0 shadow-none", config.className)}>
+    <Badge variant="default" size="sm" className={cn('shrink-0 shadow-none', config.className)}>
       {config.label}
     </Badge>
   );