From 5ada2a7d9e603c845be2b918420b67737fe6cf91 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 18 六月 2025 10:57:30 +0800
Subject: [PATCH] ‘功能完善
---
strategy/strategy_manager.py | 34 ++++++++++++++++++++--------------
1 files changed, 20 insertions(+), 14 deletions(-)
diff --git a/strategy/strategy_manager.py b/strategy/strategy_manager.py
index 0f2d336..97874bc 100644
--- a/strategy/strategy_manager.py
+++ b/strategy/strategy_manager.py
@@ -8,7 +8,7 @@
from db.mysql_data_delegate import Mysqldb
from db.redis_manager_delegate import RedisUtils
from log_module import async_log_util
-from log_module.log import logger_trade
+from log_module.log import logger_trade, logger_debug
from strategy.data_analyzer import KPLLimitUpDataAnalyzer
from strategy.low_suction_strategy import LowSuctionOriginDataExportManager
from strategy.strategy_params_settings import StrategyParamsSettingsManager
@@ -276,19 +276,25 @@
"""
codes = []
for d in big_orders:
- code = d[0]
- if d[1] == 0:
- # 涔板崟
- if code not in self.big_order_buy:
- self.big_order_buy[code] = []
- self.big_order_buy[code].append(d[2])
- else:
- # 鍗栧崟
- if code not in self.big_order_sell:
- self.big_order_sell[code] = []
- self.big_order_sell[code].append(d[2])
- if code not in codes:
- codes.append(code)
+ try:
+ code = d[0]
+ # 鍙绠�200w浠ヤ笂鐨勪拱鍗�
+ if d[2][2] < 200e4:
+ continue
+ if d[1] == 0:
+ # 涔板崟
+ if code not in self.big_order_buy:
+ self.big_order_buy[code] = []
+ self.big_order_buy[code].append(d[2])
+ else:
+ # 鍗栧崟
+ if code not in self.big_order_sell:
+ self.big_order_sell[code] = []
+ self.big_order_sell[code].append(d[2])
+ if code not in codes:
+ codes.append(code)
+ except Exception as e:
+ logger_debug.error(f"{d}")
# 椹卞姩涓嬪崟
for code in codes:
self.__run(code, self.stock_variables_dict.get(code))
--
Gitblit v1.8.0