添加清除每次上板成交数据日志

Administrator

2025-03-03 21b5c7f9b5b63c1c23f257fd5bc5cbe78059dce8

添加清除每次上板成交数据日志

 l2/l2_data_manager_new.py

@@ -883,7 +883,7 @@
        params_desc = cls.__l2PlaceOrderParamsManagerDict[code].get_buy_rank_desc()
        l2_log.debug(code, params_desc)
        #################清除本次下单的大单数据###############
        EveryLimitupBigDealOrderManager.clear(code)
        EveryLimitupBigDealOrderManager.clear(code,"下单成功")
        ############记录下单时的数据############
        try:
            jx_blocks, jx_blocks_by = KPLCodeJXBlockManager().get_jx_blocks_cache(

 l2/l2_transaction_data_processor.py

@@ -99,7 +99,7 @@
            current_price_process_manager.set_trade_price(code, datas[-1][1])
            if limit_up_price > datas[-1][1]:
                # 没有涨停
                EveryLimitupBigDealOrderManager.open_limit_up(code)
                EveryLimitupBigDealOrderManager.open_limit_up(code, f"最新成交价：{datas[-1][1]}")
                radical_buy_strategy.clear_data(code)
        except:
            pass

 servers/huaxin_trade_server.py

@@ -469,7 +469,7 @@
            # 即将炸开
            total_deal_big_order_info = radical_buy_data_manager.get_total_deal_big_order_info(code, limit_up_price)
            if total_deal_big_order_info and total_deal_big_order_info[0] <= 0:
                EveryLimitupBigDealOrderManager.clear(code)
                EveryLimitupBigDealOrderManager.clear(code,"板上放量")
                # 大单足够
                l2_trade_single_callback.process_limit_up_active_buy(code, [], is_almost_open_limit_up=True,
                                                                     l2_market_time_str=time_str)
@@ -879,7 +879,7 @@
                                                                 no_left_limit_up_sell=no_left_limit_up_sell)
        if can_clear_before_data:
            # 清除
            EveryLimitupBigDealOrderManager.clear(code)
            EveryLimitupBigDealOrderManager.clear(code, "处理涨停成交数据")


# 回调

 trade/buy_radical/radical_buy_data_manager.py

@@ -1676,14 +1676,14 @@
    __deal_big_order_no_dict = {}

    @classmethod
    def open_limit_up(cls, code):
    def open_limit_up(cls, code, msg=""):
        if code in cls.__deal_big_order_infos_dict:
            cls.__deal_big_order_infos_dict[code].clear()
            async_log_util.info(logger_l2_radical_buy_data, f"清除每次涨停大单数据：{code}")
            async_log_util.info(logger_l2_radical_buy_data, f"清除每次涨停大单数据({msg})：{code}")

    @classmethod
    def clear(cls, code):
        cls.open_limit_up(code)
    def clear(cls, code, msg=""):
        cls.open_limit_up(code, msg)

    @classmethod
    def add_big_buy_order_deal(cls, code, order_infos: list):