"feat:dynamic-check-today-data-availability"

sync_data.py

@@ -387,39 +387,86 @@ def get_target_daily(code: str, start_date: str, market: str) -> Optional[pd.Dat
             time.sleep(1)
     return None
 
+def check_today_data_available() -> bool:
+    """
+    探测当日数据是否已更新可用
+    通过尝试获取一只活跃股票（平安银行 000001）的当日数据来判断
+    
+    Returns:
+        True: 当日数据已可用
+        False: 当日数据尚未更新
+    """
+    try:
+        today = get_beijing_time().strftime('%Y%m%d')
+        
+        # 优先使用 Tushare 探测
+        if TUSHARE_AVAILABLE:
+            try:
+                import tushare as ts
+                ts.set_token(TUSHARE_TOKENS[0])
+                pro = ts.pro_api()
+                df = pro.daily(ts_code='000001.SZ', trade_date=today)
+                if df is not None and not df.empty:
+                    logger.debug(f"Tushare check: today data available")
+                    return True
+            except Exception:
+                pass
+        
+        # 回退到 AkShare 探测
+        try:
+            df = ak.stock_zh_a_spot_em()
+            if df is not None and not df.empty:
+                # 检查是否有今日数据
+                logger.debug(f"AkShare check: today data available")
+                return True
+        except Exception:
+            pass
+            
+    except Exception as e:
+        logger.debug(f"Check today data failed: {e}")
+    
+    return False
+
+
 def get_last_trading_day() -> str:
-    """获取最近一个交易日（优先使用交易日历）
+    """获取最近一个交易日（通过探测数据可用性）
     
-    注意：由于数据在收盘后获取，如果今天是交易日但当前时间 < 20:00，
-    则返回前一个交易日，避免获取不完整的当天数据。
+    逻辑：
+    1. 先尝试获取当日数据（探测 000001.SZ）
+    2. 如果能获取到，说明当日数据已更新，返回今日
+    3. 如果获取不到，说明当日数据未更新，返回上一个交易日
     """
     now = get_beijing_time()
     today = now.date()
-    current_hour = now.hour
+    today_str = today.strftime('%Y-%m-%d')
     
-    try:
-        # 获取交易日历（新浪接口，包含未来日期）
-        df = ak.tool_trade_date_hist_sina()
-        if df is not None and not df.empty:
-            # 转换为日期格式
-            df['trade_date'] = pd.to_datetime(df['trade_date']).dt.date
-            
-            # 找到今天的交易日（如果今天是交易日）
-            today_is_trading_day = today in df['trade_date'].values
-            
-            # 如果今天是交易日但当前时间 < 20:00，则排除今天
-            if today_is_trading_day and current_hour < 20:
-                last_day = df[df['trade_date'] < today]['trade_date'].iloc[-1]
-                logger.info(f"Today is trading day but current time is {now.strftime('%H:%M')} (< 20:00), using previous trading day: {last_day}")
-            else:
-                # 否则使用 <= 今天的最后一个交易日
-                last_day = df[df['trade_date'] <= today]['trade_date'].iloc[-1]
-            
-            return last_day.strftime('%Y-%m-%d')
-    except Exception as e:
-        logger.warning(f"Failed to get trading calendar: {e}")
+    # 探测当日数据是否可用
+    logger.info(f"Checking if today ({today_str}) data is available...")
+    
+    if check_today_data_available():
+        logger.info(f"Today data is available, using today: {today_str}")
+        return today_str
+    else:
+        # 获取上一个交易日
+        try:
+            # 使用交易日历获取上一个交易日
+            df = ak.tool_trade_date_hist_sina()
+            if df is not None and not df.empty:
+                df['trade_date'] = pd.to_datetime(df['trade_date']).dt.date
+                prev_trading_days = df[df['trade_date'] < today]['trade_date']
+                if not prev_trading_days.empty:
+                    last_day = prev_trading_days.iloc[-1]
+                    logger.info(f"Today data not available yet, using previous trading day: {last_day}")
+                    return last_day.strftime('%Y-%m-%d')
+        except Exception as e:
+            logger.warning(f"Failed to get previous trading day: {e}")
+        
+        # 回退：昨天
+        yesterday = (today - timedelta(days=1)).strftime('%Y-%m-%d')
+        logger.info(f"Using yesterday as fallback: {yesterday}")
+        return yesterday
 
-    # 回退：使用指数行情
+    # 备用：使用指数行情获取
     try:
         df = ak.stock_zh_index_daily_em(symbol="sh000300")
         if df is not None and not df.empty: