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

Author: ZhuLinsen

src/notification_sender/feishu_sender.py

@@ -27,6 +27,20 @@
 logger = logging.getLogger(__name__)
 
 
+def _contains_markdown_table(content: str) -> bool:
+    """Return whether content contains consecutive Markdown table rows."""
+    table_row_count = 0
+    for raw_line in content.splitlines():
+        stripped = raw_line.strip()
+        if stripped.startswith("|") and "|" in stripped[1:]:
+            table_row_count += 1
+            if table_row_count >= 2:
+                return True
+            continue
+        table_row_count = 0
+    return False
+
+
 class FeishuSender:
 
     def __init__(self, config: Config):
@@ -148,7 +162,8 @@ def _send_feishu_chunked(self, content: str, max_bytes: int) -> bool:
         """
         分批发送长消息到飞书
         
-        按股票分析块（以 --- 或 ### 分隔）智能分割，确保每批不超过限制
+        按股票分析块（以 --- 或 ### 分隔）智能分割，确保每批不超过限制。
+        包含表格时先转成飞书友好的安全文本，避免分片后丢失表头上下文。
         
         Args:
             content: 完整消息内容
@@ -157,8 +172,9 @@ def _send_feishu_chunked(self, content: str, max_bytes: int) -> bool:
         Returns:
             是否全部发送成功
         """
+        chunk_source = format_feishu_markdown(content) if _contains_markdown_table(content) else content
         try:
-            chunks = chunk_content_by_max_bytes(content, max_bytes, add_page_marker=True)
+            chunks = chunk_content_by_max_bytes(chunk_source, max_bytes, add_page_marker=True)
         except ValueError as e:
             logger.error("飞书消息分片失败，单片预算不足以安全分页（关键词过长或 max_bytes 过小）: %s", e)
             return False

tests/test_notification_sender.py

@@ -229,6 +229,37 @@ def test_send_markdown_table_uses_structured_card_elements(self, mock_post):
         self.assertNotIn("```", serialized)
         self.assertNotIn("| 指标 |", serialized)
 
+    @mock.patch("src.notification_sender.feishu_sender.time.sleep", return_value=None)
+    @mock.patch("src.notification_sender.feishu_sender.requests.post")
+    def test_chunked_markdown_table_does_not_promote_data_rows_to_headers(self, mock_post, _mock_sleep):
+        mock_post.return_value = _response(200, {"code": 0})
+        cfg = _config(feishu_webhook_url="https://feishu.example/hook", feishu_max_bytes=130)
+        sender = FeishuSender(cfg)
+        rows = "\n".join(
+            f"| {index:06d} | 股票{index:02d} | {index} |"
+            for index in range(1, 10)
+        )
+        content = f"""# 人气股票
+
+| 代码 | 名称 | 热度 |
+| --- | --- | --- |
+{rows}
+"""
+
+        result = sender.send_to_feishu(content)
+
+        self.assertTrue(result)
+        self.assertGreater(mock_post.call_count, 1)
+        continuation_elements = [
+            call.kwargs["json"]["card"]["elements"]
+            for call in mock_post.call_args_list[1:]
+        ]
+        serialized = json.dumps(continuation_elements, ensure_ascii=False)
+        self.assertIn("000004", serialized)
+        self.assertIn("000006", serialized)
+        self.assertNotIn("**000002**", serialized)
+        self.assertNotIn("**000006**", serialized)
+
     @mock.patch("src.notification_sender.feishu_sender.requests.post")
     def test_send_error_response_returns_false(self, mock_post):
         mock_post.return_value = _response(200, {"code": 19024, "msg": "keyword not found"})