From fc3d60a7ef82b5b17c3851359e060531d9ff9821 Mon Sep 17 00:00:00 2001
From: aaron <>
Date: Thu, 18 Sep 2025 22:47:44 +0800
Subject: [PATCH] 1

---
 scripts/data_collector.py | 28 ++++++++++++++++++++++++++--
 1 file changed, 26 insertions(+), 2 deletions(-)

diff --git a/scripts/data_collector.py b/scripts/data_collector.py
index 0d63d10..832366b 100755
--- a/scripts/data_collector.py
+++ b/scripts/data_collector.py
@@ -48,8 +48,32 @@ def run_strategy():
             db_manager=db_manager
         )
 
-        # 这里可以添加具体的策略运行逻辑
-        # strategy.scan_all_stocks()
+        # 执行市场K线形态扫描
+        logger.info("开始扫描市场K线形态...")
+        logger.info("⚠️  注意: 这可能需要较长时间，请耐心等待")
+
+        # 获取扫描股票数量配置
+        scan_count = strategy.config.get('scan_stocks_count', 20)
+        logger.info(f"扫描股票数量: {scan_count}")
+
+        results = strategy.scan_market(max_stocks=scan_count)
+
+        if results:
+            logger.info(f"📈 市场扫描结果 (发现 {len(results)} 只股票有信号):")
+
+            for stock_code, stock_results in results.items():
+                total_signals = sum(len(signals) for signals in stock_results.values())
+                logger.info(f"股票: {stock_code} (共{total_signals}个信号)")
+
+                for timeframe, signals in stock_results.items():
+                    if signals:
+                        logger.info(f"  {timeframe}: {len(signals)}个信号")
+                        # 只显示最新的信号
+                        latest_signal = signals[-1]
+                        logger.info(f"    最新: {latest_signal['date']} 突破价格 {latest_signal['breakout_price']:.2f}元")
+
+        else:
+            logger.info("未发现任何K线形态信号")
 
         logger.info('策略扫描完成')
     except Exception as e: