From 1e6caf51e09e3eb06b865fc36ba987ebdba26d69 Mon Sep 17 00:00:00 2001 From: blade <8019068@qq.com> Date: Thu, 16 Oct 2025 16:17:35 +0800 Subject: [PATCH] update market data as first action. --- huge_volume_main.py | 10 +++++++++- market_data_main.py | 2 +- 2 files changed, 10 insertions(+), 2 deletions(-) diff --git a/huge_volume_main.py b/huge_volume_main.py index 52b4f0e..4371658 100644 --- a/huge_volume_main.py +++ b/huge_volume_main.py @@ -166,7 +166,6 @@ class HugeVolumeMain: for symbol in self.market_data_main.symbols: for bar in self.market_data_main.bars: try: - self.market_data_main.update_data(symbol, bar) self.update_volume_spike(symbol, bar, window_size) except Exception as e: logger.error( @@ -666,6 +665,15 @@ def batch_update_volume_spike(threshold: float = 2.0, is_us_stock: bool = False) ): window_sizes = [50, 80, 100, 120] huge_volume_main = HugeVolumeMain(threshold, is_us_stock, is_binance=False) + + for symbol in huge_volume_main.market_data_main.symbols: + for bar in huge_volume_main.market_data_main.bars: + try: + huge_volume_main.market_data_main.update_data(symbol, bar) + except Exception as e: + logger.warning( + f"更新交易数据失败: {symbol} {bar}: {e}" + ) for window_size in window_sizes: huge_volume_main.batch_update_volume_spike(window_size=window_size) diff --git a/market_data_main.py b/market_data_main.py index 3341a06..f589378 100644 --- a/market_data_main.py +++ b/market_data_main.py @@ -117,8 +117,8 @@ class MarketDataMain: if bar == "1m": if isinstance(start, str): start_time_ts = transform_date_time_to_timestamp(start) - # start为end_time_ts的前十五天 if end_time_ts - start_time_ts > 86400000 * 15: + # start为end_time_ts的前十五天 start_time_ts = end_time_ts - 86400000 * 15 start = timestamp_to_datetime(start_time_ts) elif isinstance(start, int):