fix(issue-1234): [bug]-北交所股票处理差异，异常

Author: ZhuLinsen

apps/dsa-web/src/components/StockAutocomplete/__tests__/StockAutocomplete.test.tsx

@@ -79,6 +79,16 @@ const hkSuggestion = {
   score: 100,
 };
 
+const bseSuggestion = {
+  canonicalCode: "920493.BJ",
+  displayCode: "920493",
+  nameZh: "示例北交所股票",
+  market: "BSE" as const,
+  matchType: "exact" as const,
+  matchField: "code" as const,
+  score: 100,
+};
+
 describe('StockAutocomplete', () => {
   const mockOnChange = vi.fn();
   const mockOnSubmit = vi.fn();
@@ -416,6 +426,40 @@ describe('StockAutocomplete', () => {
       expect(mockOnChange).toHaveBeenCalledWith('00700');
       expect(mockOnSubmit).toHaveBeenCalledWith('00700.HK', '腾讯控股', 'autocomplete');
     });
+
+    it('submits the highlighted BSE suggestion using the canonical .BJ code', () => {
+      autocompleteHookImpl = () => ({
+        query: '',
+        setQuery: vi.fn(),
+        suggestions: [bseSuggestion],
+        isOpen: true,
+        highlightedIndex: 0,
+        setHighlightedIndex: vi.fn(),
+        highlightPrevious: vi.fn(),
+        highlightNext: vi.fn(),
+        handleSelect: vi.fn(),
+        close: vi.fn(),
+        reset: vi.fn(),
+        isComposing: false,
+        setIsComposing: vi.fn(),
+        runtimeFallback: false,
+        error: null,
+      });
+
+      render(
+        <StockAutocomplete
+          value="920493"
+          onChange={mockOnChange}
+          onSubmit={mockOnSubmit}
+        />
+      );
+
+      const input = screen.getByDisplayValue('920493');
+      fireEvent.keyDown(input, { key: 'Enter' });
+
+      expect(mockOnChange).toHaveBeenCalledWith('920493');
+      expect(mockOnSubmit).toHaveBeenCalledWith('920493.BJ', '示例北交所股票', 'autocomplete');
+    });
   });
 
   describe('runtime boundary', () => {

docs/CHANGELOG.md

@@ -22,6 +22,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/).
 - [改进] 设置项帮助窗口支持键盘焦点限制、Esc 关闭和关闭后焦点恢复，并移除短描述重复 hover tooltip。
 - [文档] 新增设置页配置帮助维护说明，明确帮助元数据字段、首批覆盖范围、事实源和多语言文案同步规则。
 - [测试] 补充设置项帮助元数据、API schema、前端弹窗交互测试，并修复 Bot 名称路由与调度时间 provider 测试的离线 CI 稳定性问题。
+- [修复] 修正分析 API 对北交所 `BJ` 前缀与 `.BJ` 后缀股票代码的校验，保持前端自动补全与 Tushare `ts_code` 调用格式一致。
 
 ## [3.15.0] - 2026-05-05
 

docs/full-guide.md

@@ -1142,7 +1142,7 @@ python main.py --serve-only --host 0.0.0.0 --port 8888
 | 类型 | 格式 | 示例 |
 |------|------|------|
 | A股 | 6位数字 | `600519`、`000001`、`300750` |
-| 北交所 | 8/4/92 开头 6 位 | `920748`、`838163`、`430047` |
+| 北交所 | 8/4/92 开头 6 位，支持 `BJ` 前缀或 `.BJ` 后缀 | `920748`、`BJ920493`、`920493.BJ` |
 | 港股 | hk + 5位数字 | `hk00700`、`hk09988` |
 | 美股 | 1-5 字母（可选 .X 后缀） | `AAPL`、`TSLA`、`BRK.B` |
 | 美股指数 | SPX/DJI/IXIC 等 | `SPX`、`DJI`、`NASDAQ`、`VIX` |

docs/full-guide_EN.md

@@ -981,7 +981,7 @@ python main.py --serve-only --host 0.0.0.0 --port 8888
 | Type | Format | Examples |
 |------|------|------|
 | A-shares | 6-digit number | `600519`, `000001`, `300750` |
-| BSE (Beijing) | 8/4/92 prefix, 6-digit | `920748`, `838163`, `430047` |
+| BSE (Beijing) | 8/4/92 prefix, 6-digit; supports `BJ` prefix or `.BJ` suffix | `920748`, `BJ920493`, `920493.BJ` |
 | HK stocks | hk + 5-digit number | `hk00700`, `hk09988` |
 
 ### Notes

docs/openclaw-skill-integration.md

@@ -75,7 +75,7 @@
 | 类型 | 格式 | 示例 |
 |------|------|------|
 | A股 | 6位数字 | `600519`、`000001`、`300750` |
-| 北交所 | 8/4/92 开头 6 位 | `920748`、`838163`、`430047` |
+| 北交所 | 8/4/92 开头 6 位，支持 `BJ` 前缀或 `.BJ` 后缀 | `920748`、`BJ920493`、`920493.BJ` |
 | 港股 | hk + 5位数字 | `hk00700`、`hk09988` |
 | 美股 | 1-5 字母（可选 .X 后缀） | `AAPL`、`TSLA`、`BRK.B` |
 | 美股指数 | SPX/DJI/IXIC 等 | `SPX`、`DJI`、`NASDAQ`、`VIX` |
@@ -145,6 +145,7 @@ metadata:
 ## 股票代码格式
 
 - A股：6位数字（600519、000001）
+- 北交所：8/4/92 开头 6 位，支持 BJ 前缀或 .BJ 后缀（920748、BJ920493、920493.BJ）
 - 港股：hk + 5位数字（hk00700）
 - 美股：1–5 字母（AAPL、TSLA、BRK.B）
 - 美股指数：SPX、DJI、IXIC 等

src/services/stock_code_utils.py

@@ -15,13 +15,15 @@
     "SH": (6,),
     "SZ": (6,),
     "SS": (6,),
+    "BJ": (6,),
     "HK": (1, 2, 3, 4, 5),
 }
 
 _SUFFIX_DIGIT_LENS: dict = {
     ".SH": (6,),
     ".SZ": (6,),
     ".SS": (6,),
+    ".BJ": (6,),
     ".HK": (1, 2, 3, 4, 5),
 }
 
@@ -57,7 +59,7 @@ def is_code_like(value: str) -> bool:
         return True
     if re.match(r"^[A-Z]{1,5}(?:\.(?:US|[A-Z]))?$", text):
         return True
-    # Support exchange-prefixed codes: SH600519, SZ000001, HK00700
+    # Support exchange-prefixed codes: SH600519, SZ000001, BJ920493, HK00700
     if _strip_exchange_prefix(text) is not None:
         return True
     return False
@@ -69,7 +71,7 @@ def normalize_code(raw: str) -> Optional[str]:
     Supports:
     - Plain digit codes: 600519, 00700
     - Suffix format: 600519.SH, 600519.SZ, 00700.HK
-    - Prefix format: SH600519, SZ000001, HK00700 (case-insensitive)
+    - Prefix format: SH600519, SZ000001, BJ920493, HK00700 (case-insensitive)
     - US ticker symbols: AAPL, TSLA
     """
     text = raw.strip().upper()
@@ -82,7 +84,7 @@ def normalize_code(raw: str) -> Optional[str]:
     stripped_suffix = _strip_exchange_suffix(text)
     if stripped_suffix is not None:
         return stripped_suffix
-    # Support exchange-prefixed codes: SH600519 -> 600519, HK00700 -> 00700
+    # Support exchange-prefixed codes: SH600519 -> 600519, BJ920493 -> 920493
     stripped = _strip_exchange_prefix(text)
     if stripped is not None:
         return stripped

tests/test_analysis_api_contract.py

@@ -689,6 +689,42 @@ def test_trigger_analysis_accepts_hk_suffix_code_from_autocomplete(self) -> None
             notify=True,
         )
 
+    def test_trigger_analysis_accepts_bse_suffix_code_from_autocomplete(self) -> None:
+        if trigger_analysis is None:
+            self.skipTest("fastapi is not installed in this test environment")
+
+        queue = MagicMock()
+        queue.submit_tasks_batch.return_value = ([], [])
+
+        with patch("api.v1.endpoints.analysis.get_task_queue", return_value=queue), \
+             patch("api.v1.endpoints.analysis.resolve_name_to_code") as resolve_mock:
+            response = trigger_analysis(
+                request=SimpleNamespace(
+                    stock_code="920493.BJ",
+                    stock_codes=None,
+                    stock_name="示例北交所股票",
+                    original_query="920493",
+                    selection_source="autocomplete",
+                    report_type="detailed",
+                    force_refresh=False,
+                    async_mode=True,
+                    notify=True,
+                ),
+                config=SimpleNamespace(),
+            )
+
+        self.assertEqual(response.status_code, 202)
+        resolve_mock.assert_not_called()
+        queue.submit_tasks_batch.assert_called_once_with(
+            stock_codes=["920493.BJ"],
+            stock_name="示例北交所股票",
+            original_query="920493",
+            selection_source="autocomplete",
+            report_type="detailed",
+            force_refresh=False,
+            notify=True,
+        )
+
     def test_trigger_analysis_accepts_hk_prefixed_code(self) -> None:
         if trigger_analysis is None:
             self.skipTest("fastapi is not installed in this test environment")

tests/test_name_to_code_resolver.py

@@ -33,6 +33,10 @@ def test_a_share_5_digits(self):
     def test_a_share_6_digits(self):
         assert _is_code_like("300750") is True
 
+    def test_bse_with_exchange_hint(self):
+        assert _is_code_like("920493.BJ") is True
+        assert _is_code_like("BJ920493") is True
+
     def test_hk_5_digits(self):
         assert _is_code_like("00700") is True
 
@@ -61,6 +65,10 @@ def test_preserves_valid_a_share(self):
     def test_strips_suffix(self):
         assert _normalize_code("600519.SH") == "600519"
         assert _normalize_code("000001.SZ") == "000001"
+        assert _normalize_code("920493.BJ") == "920493"
+
+    def test_strips_bse_prefix(self):
+        assert _normalize_code("BJ920493") == "920493"
 
     def test_preserves_us_stock(self):
         assert _normalize_code("AAPL") == "AAPL"
@@ -99,6 +107,7 @@ class TestResolveNameToCode:
     def test_code_like_input_returned_normalized(self):
         assert resolve_name_to_code("600519") == "600519"
         assert resolve_name_to_code("600519.SH") == "600519"
+        assert resolve_name_to_code("920493.BJ") == "920493"
         assert resolve_name_to_code("  AAPL  ") == "AAPL"
 
     def test_local_map_exact_match(self):

tests/test_stock_code_bse.py

@@ -120,6 +120,12 @@ def test_bse_returns_bj_suffix(self):
         self.assertEqual(fetcher._convert_stock_code("838163"), "838163.BJ")
         self.assertEqual(fetcher._convert_stock_code("430047"), "430047.BJ")
 
+    def test_bse_explicit_exchange_hint_is_preserved(self):
+        """BSE prefix/suffix forms should keep the BJ Tushare ts_code."""
+        fetcher = TushareFetcher()
+        self.assertEqual(fetcher._convert_stock_code("920493.BJ"), "920493.BJ")
+        self.assertEqual(fetcher._convert_stock_code("BJ920493"), "920493.BJ")
+
 
 @unittest.skipIf(not _AKSHARE_IMPORTS_OK, f"akshare fetcher imports failed: {_AKSHARE_IMPORT_ERROR}")
 class TestAkshareToSinaTxSymbol(unittest.TestCase):

tests/test_stock_code_utils.py

@@ -27,6 +27,9 @@ def test_suffix_sh(self):
     def test_suffix_sz(self):
         assert is_code_like("000001.SZ") is True
 
+    def test_suffix_bj(self):
+        assert is_code_like("920493.BJ") is True
+
     def test_suffix_lowercase(self):
         assert is_code_like("600519.sh") is True
 
@@ -56,6 +59,9 @@ def test_prefix_sh_lower(self):
     def test_prefix_sz(self):
         assert is_code_like("SZ000001") is True
 
+    def test_prefix_bj(self):
+        assert is_code_like("BJ920493") is True
+
     def test_prefix_hk(self):
         assert is_code_like("HK00700") is True
 
@@ -104,6 +110,9 @@ def test_suffix_sh_strips(self):
     def test_suffix_sz_strips(self):
         assert normalize_code("000001.SZ") == "000001"
 
+    def test_suffix_bj_strips(self):
+        assert normalize_code("920493.BJ") == "920493"
+
     def test_suffix_ss_strips(self):
         assert normalize_code("600000.SS") == "600000"
 
@@ -132,6 +141,9 @@ def test_prefix_sh_lower(self):
     def test_prefix_sz(self):
         assert normalize_code("SZ000001") == "000001"
 
+    def test_prefix_bj(self):
+        assert normalize_code("BJ920493") == "920493"
+
     def test_prefix_hk(self):
         assert normalize_code("HK00700") == "00700"