diff --git a/data_platform/daily_all_update.py b/data_platform/daily_all_update.py index 0110d5de..bec02312 100644 --- a/data_platform/daily_all_update.py +++ b/data_platform/daily_all_update.py @@ -129,6 +129,8 @@ def fetch_tencent_daily(code: str, start_date: str, end_date: str) -> Optional[p for c in ["open", "close", "high", "low", "volume", "amount"]: df[c] = pd.to_numeric(df[c], errors="coerce").fillna(0) df["date"] = pd.to_datetime(df["date"]).dt.strftime("%Y-%m-%d") + # 确保date为字符串比较 + df["date"] = df["date"].astype(str) mask = (df["date"] >= start_date) & (df["date"] <= end_date) result = df.loc[mask, ["date", "open", "high", "low", "close", "volume", "amount"]] return result if not result.empty else None