成交之后强制撤单

Administrator

2023-09-22 1f2243e9357a19d489f874e9bc7e4ab8acf5f5d4

 third_data/code_plate_key_manager.py

@@ -421,11 +421,13 @@

    @classmethod
    def __remove_from_l2(cls, code, msg):
        # TODO 暂时不根据身位移除代码
        return
        # 下过单的代码不移除
        if trade_manager.CodesTradeStateManager().get_trade_state_cache(code) != trade_manager.TRADE_STATE_NOT_TRADE:
            # 只要下过单的就不移除
            return
        l2_trade_util.forbidden_trade(code)
        l2_trade_util.forbidden_trade(code, msg=msg)
        logger_kpl_block_can_buy.info(msg)

    @classmethod
@@ -534,8 +536,11 @@
    # 返回：是否可以下单,消息,板块类型
    @classmethod
    def can_buy(cls, code):
        # if constant.TEST:
        #     return True, cls.BLOCK_TYPE_NONE
        if constant.TEST:
            return True, cls.BLOCK_TYPE_NONE
        if True:
            # 测试
            return True, "不判断板块身位"
        return cls.__can_buy_compute_result_dict.get(code)

    @classmethod
@@ -610,15 +615,18 @@
                                 before_blocks_dict):
        # 加载涨停代码的目标板块
        def load_code_block():
            for d in limit_up_record_datas:
                if d[2] in constant.KPL_INVALID_BLOCKS and d[3] in before_blocks_dict:
                    code_limit_up_reason_dict[d[3]] = list(before_blocks_dict.get(d[3]))[0]
                else:
                    code_limit_up_reason_dict[d[3]] = d[2]
            if limit_up_record_datas:
                for d in limit_up_record_datas:
                    if d[2] in constant.KPL_INVALID_BLOCKS and d[3] in before_blocks_dict:
                        code_limit_up_reason_dict[d[3]] = list(before_blocks_dict.get(d[3]))[0]
                    else:
                        code_limit_up_reason_dict[d[3]] = d[2]
            return code_limit_up_reason_dict

        if current_limit_up_datas is None:
            current_limit_up_datas = []
        if limit_up_record_datas is None:
            limit_up_record_datas = []
        code_limit_up_reason_dict = {}
        load_code_block()
        can_buy, msg = cls.__is_block_can_buy(code, block, current_limit_up_datas, code_limit_up_reason_dict,