大单统计优化

Administrator

2025-03-20 9fc792923848e96fffc72a99d266e931525c2e49

 l2/l2_transaction_data_processor.py

@@ -61,7 +61,10 @@
        """

        def statistic_big_buy_data():
            use_time_list = []
            __start_time = time.time()
            buy_datas, bigger_buy_datas = HuaXinBuyOrderManager.statistic_big_buy_data(code, fdatas, limit_up_price)
            use_time_list.append((time.time() - __start_time, "买单统计"))
            if buy_datas:
                BigOrderDealManager().add_buy_datas(code, buy_datas)
                active_big_buy_orders = []
@@ -71,6 +74,7 @@
                            # (买单号, 成交金额, 最后成交时间)
                            active_big_buy_orders.append((x[0], x[2], x[4]))
                EveryLimitupBigDealOrderManager.add_big_buy_order_deal(code, active_big_buy_orders)
                use_time_list.append((time.time() - __start_time, "买单统计结果处理"))
            try:
                is_placed_order = l2_data_manager.TradePointManager.is_placed_order(order_begin_pos)
                if is_placed_order:
@@ -88,12 +92,22 @@
                                                                           order_begin_pos.buy_single_index)
            except Exception as e:
                logger_debug.exception(e)
            if use_time_list and use_time_list[-1][0] > 0.005:
                l2_log.info(code, hx_logger_l2_upload,
                            f"买单统计+处理耗时：{use_time_list[-1][0]}  详情:{use_time_list}")

            return buy_datas

        def statistic_big_sell_data():
            use_time_list = []
            __start_time = time.time()
            sell_datas = HuaXinSellOrderStatisticManager.statistic_big_sell_data(code, fdatas)
            if sell_datas:
                BigOrderDealManager().add_sell_datas(code, sell_datas)
            use_time_list.append((time.time() - __start_time, "卖单统计"))
            if use_time_list and use_time_list[-1][0] > 0.005:
                l2_log.info(code, hx_logger_l2_upload,
                            f"卖单统计+处理耗时：{use_time_list[-1][0]}  详情:{use_time_list}")
            return sell_datas

        def statistic_big_data(f1_, f2_):
@@ -137,7 +151,6 @@
        temp_time_dict.clear()

        __start_time = time.time()
        limit_up_price = gpcode_manager.get_limit_up_price_as_num(code)
        # 设置成交价
        try:
            current_price_process_manager.set_trade_price(code, fdatas[-1][0][1])