1

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()