Administrator
2023-03-28 c7b6f5be3e5850bbf66db5363e634c57ff9ca876
l2/l2_data_manager_new.py
@@ -23,7 +23,7 @@
from l2.l2_data_manager import L2DataException, TradePointManager
from l2.l2_data_util import local_today_datas, L2DataUtil, load_l2_data, local_today_num_operate_map, local_latest_datas
import l2.l2_data_util
from log import logger_l2_trade, logger_l2_trade_cancel, logger_l2_trade_buy, logger_l2_process, logger_l2_error
from log import logger_l2_trade, logger_l2_trade_cancel, logger_l2_trade_buy, logger_l2_process, logger_l2_error,logger_buy_score
# TODO l2数据管理
from trade.trade_data_manager import CodeActualPriceProcessor
@@ -235,7 +235,7 @@
            limit_up_time = limit_up_time_manager.get_limit_up_time(code)
            if limit_up_time is None:
                limit_up_time = tool.get_now_time_str()
            score = first_code_score_manager.get_score(code, volume_rate, limit_up_time)
            score = first_code_score_manager.get_score(code, volume_rate, limit_up_time,True)
            cls.__l2PlaceOrderParamsManagerDict[code] = l2_trade_factor.L2PlaceOrderParamsManager(code, is_first_code,
                                                                                                  volume_rate,
                                                                                                  volume_rate_index,
@@ -469,6 +469,7 @@
            return
        else:
            l2_log.debug(code, "可以下单,原因:{}", reason)
            logger_buy_score.info(f"{code}:{cls.__l2PlaceOrderParamsManagerDict[code].score_info}")
            try:
                l2_log.debug(code, "开始执行买入")
                trade_manager.start_buy(code, capture_timestamp, last_data,
@@ -654,8 +655,8 @@
            score = cls.__l2PlaceOrderParamsManagerDict[code].score
            if score_index < 0:
                return False, True, f"分值:{score}未达到需要买入的分数线"
            if -1 < score_index < 3:
                return True, False, f"分值:{score}达到主动买入的分数线,买入等级:f{score_index}"
            # if -1 < score_index < 3:
            #     return True, False, f"分值:{score}达到主动买入的分数线,买入等级:f{score_index}"
            is_limited_up = gpcode_manager.FirstCodeManager.is_limited_up(code)
            gpcode_manager.FirstCodeManager.add_limited_up_record([code])
            if not code_price_manager.Buy1PriceManager.is_can_buy(code):