From 03e99bd05fdb5f266c5dc9e6c63a2d690ada491b Mon Sep 17 00:00:00 2001
From: shy3130 <415333856@qq.com>
Date: Tue, 7 Jul 2026 13:07:59 +0800
Subject: [PATCH] =?UTF-8?q?feat(stock-sdk):=20=E5=8F=96=E6=95=B0=E5=85=A5?=
 =?UTF-8?q?=E5=8F=A3=E8=A1=A5=E5=85=85=20INFO=20=E6=97=A5=E5=BF=97,=20?=
 =?UTF-8?q?=E4=BE=BF=E4=BA=8E=E7=A1=AE=E8=AE=A4=E5=88=87=E6=8D=A2=E5=90=8E?=
 =?UTF-8?q?=E5=AE=9E=E9=99=85=E8=B5=B0=20stock-sdk?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 backend/app/plugins/stocksdk/provider.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/backend/app/plugins/stocksdk/provider.py b/backend/app/plugins/stocksdk/provider.py
index 569b8cf..6922055 100644
--- a/backend/app/plugins/stocksdk/provider.py
+++ b/backend/app/plugins/stocksdk/provider.py
@@ -67,6 +67,7 @@ class StockSDKProvider:
     ) -> pl.DataFrame:
         if not symbols:
             return pl.DataFrame()
+        logger.info("stock-sdk daily 拉取开始(%d symbols)", len(symbols))
         frames: list[pl.DataFrame] = []
         chunks = chunked(symbols, _BATCH)
         for i, chunk in enumerate(chunks):
@@ -141,6 +142,7 @@ class StockSDKProvider:
         if not symbols:
             return pl.DataFrame()
         period = "".join(ch for ch in str(freq) if ch.isdigit()) or "5"
+        logger.info("stock-sdk minute 拉取开始(%d symbols, period=%s)", len(symbols), period)
         frames: list[pl.DataFrame] = []
         chunks = chunked(symbols, _BATCH)
         for i, chunk in enumerate(chunks):
@@ -193,6 +195,7 @@ class StockSDKProvider:
 
     # ---- realtime (全市场快照) ----
     def get_realtime(self) -> list[dict]:
+        logger.info("stock-sdk realtime 拉取开始(全市场快照)")
         try:
             result = bridge.run_job({"op": "realtime"}, timeout=120)
         except bridge.StockSDKBridgeError as e: