10点之前辨识度无论净流入首封回封都买

Administrator

2025-03-25 859c8713783bd3527533dd7525e420382e71a1bb

10点之前辨识度无论净流入首封回封都买

 l2/huaxin/huaxin_delegate_postion_manager.py

@@ -59,6 +59,11 @@
    # 获取下单信息
    @classmethod
    def get_order_info(cls, code):
        """

        @param code:
        @return: ([(量,价格, order_ref)], 下单时最新的L2数据,时间戳, 执行位 )
        """
        info = cls.__place_order_info_dict.get(code)
        TIME_SPACE_THRESHHOD = 3 if tool.is_sz_code(code) else 20
        if info and time.time() - info[2] > TIME_SPACE_THRESHHOD:

 l2/l2_data_manager_new.py

@@ -325,7 +325,7 @@
                cls.unreal_buy_dict.pop(code)

    @classmethod
    def set_real_place_order_index(cls, code, index, order_begin_pos: OrderBeginPosInfo):
    def set_real_place_order_index(cls, code, index, order_begin_pos: OrderBeginPosInfo, last_data):
        trade_record_log_util.add_real_place_order_position_log(code, index, order_begin_pos.buy_single_index)
        total_datas = local_today_datas.get(code)
        use_time = tool.trade_time_sub_with_ms(L2DataUtil.get_time_with_ms(total_datas[index]["val"]) , L2DataUtil.get_time_with_ms(
@@ -405,13 +405,13 @@
            code, order_info, pre_real_order_index, compute_type)
        if real_order_index and pre_real_order_index != real_order_index:
            try:
                exec_index = order_info[6]
                exec_index = order_info[3]
                order_begin_pos = cls.__get_order_begin_pos(
                    code)
                async_log_util.info(logger_debug,
                                    f"下单位矫正：真实下单位-{real_order_index} 订单信息-{order_info}  下单信息-{order_begin_pos.to_dict()}")
                if order_begin_pos and order_begin_pos.buy_exec_index == exec_index:
                    cls.set_real_place_order_index(code, real_order_index, order_begin_pos)
                    cls.set_real_place_order_index(code, real_order_index, order_begin_pos, order_info[1])
                    async_log_util.info(logger_real_place_order_position,
                                        f"真实下单位置矫正：{code}-({real_order_index},1)")
            except Exception as e:
@@ -494,7 +494,7 @@
                        if place_order_index:
                            order_begin_pos = cls.__get_order_begin_pos(
                                code)
                            cls.set_real_place_order_index(code, place_order_index, order_begin_pos)
                            cls.set_real_place_order_index(code, place_order_index, order_begin_pos, order_info[1])
                            try:
                                cls.__re_compute_threading_pool.submit(
                                    cls.__recompute_real_order_index, code, place_order_index, order_info,

 ocr/ocr_util.py

@@ -52,4 +52,4 @@


if __name__ == "__main__":
    print(re.match("首..注", "首版关注"))
    pass

 trade/buy_radical/radical_buy_data_manager.py

@@ -1254,6 +1254,9 @@
        if LimitUpCodesBlockRecordManager().is_new_block(block):
            # 今日新板块不考虑净流入
            return True, False
        # 10点之前不考虑净流入
        if tool.get_now_time_as_int()<=100000:
            return True, False

        # 辨识度不在流入的票打回封(回封已经在订阅的时候处理了)
        if is_for_buy:

 trade/current_price_process_manager.py

@@ -115,7 +115,8 @@
    else:
        # 尚未涨停过的代码，订阅板块有辨识度的前6
        for b in blocks:
            if b not in top_in_blocks:
            if b not in top_in_blocks and tool.get_now_time_as_int() >= 100000:
                # 10点之后才考虑净流入
                continue
            index = top_in_blocks.index(b)
            special_codes = BlockSpecialCodesManager().get_block_codes(b)