From cfeda409154c3e0161a8030267d95aee85bd7831 Mon Sep 17 00:00:00 2001 From: aaron <> Date: Thu, 18 Sep 2025 22:39:51 +0800 Subject: [PATCH] 1 --- data/trading.db | Bin 352256 -> 352256 bytes scripts/data_collector.py | 26 ++++++++++++++++++++++++-- 2 files changed, 24 insertions(+), 2 deletions(-) diff --git a/data/trading.db b/data/trading.db index a6dee37f693234aecc87cbd2ed83110d2659ec6a..0be008f01f45ebea816f0eb4dc63ee774d7cee82 100644 GIT binary patch delta 43 zcmZoTAlh(1bb>VForyBejCVFB%$8?0wzM*`Xi{iXU~E%hYExitQ(#%9!0G@1O>_+} delta 43 zcmZoTAlh(1bb>VFt%)+ujJGx>%$8?0GO#i*Yf@-aU~E%hYExitQ(#%9!0G@1OUn%% diff --git a/scripts/data_collector.py b/scripts/data_collector.py index dd4174e..0d63d10 100755 --- a/scripts/data_collector.py +++ b/scripts/data_collector.py @@ -16,6 +16,9 @@ sys.path.insert(0, str(project_root)) from src.strategy.kline_pattern_strategy import KLinePatternStrategy from src.utils.config_loader import ConfigLoader +from src.data.data_fetcher import ADataFetcher +from src.utils.notification import NotificationManager +from src.database.database_manager import DatabaseManager from loguru import logger @@ -23,8 +26,27 @@ def run_strategy(): """运行策略扫描""" try: logger.info('开始运行策略扫描...') - config = ConfigLoader() - strategy = KLinePatternStrategy(config) + + # 初始化各个组件 + config_loader = ConfigLoader() + config = config_loader.config + + # 初始化数据获取器 + data_fetcher = ADataFetcher(config) + + # 初始化通知管理器 + notification_manager = NotificationManager(config) + + # 初始化数据库管理器 + db_manager = DatabaseManager() + + # 初始化策略 + strategy = KLinePatternStrategy( + data_fetcher=data_fetcher, + notification_manager=notification_manager, + config=config, + db_manager=db_manager + ) # 这里可以添加具体的策略运行逻辑 # strategy.scan_all_stocks()