diff --git a/data/trading.db b/data/trading.db index a6dee37..0be008f 100644 Binary files a/data/trading.db and b/data/trading.db differ 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()