‘功能完善

Administrator

4 天以前 5ada2a7d9e603c845be2b918420b67737fe6cf91

‘功能完善

 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,7 +276,11 @@
        """
        codes = []
        for d in big_orders:
            try:
            code = d[0]
                # 只计算200w以上的买单
                if d[2][2] < 200e4:
                    continue
            if d[1] == 0:
                # 买单
                if code not in self.big_order_buy:
@@ -289,6 +293,8 @@
                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))