Administrator
2024-12-03 9b3f208f4def3bea3998767feb75d6ea6ef64fb5
删除日志
2个文件已修改
8 ■■■■■ 已修改文件
l2/huaxin/huaxin_target_codes_manager.py 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
trade/current_price_process_manager.py 6 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
l2/huaxin/huaxin_target_codes_manager.py
@@ -150,7 +150,7 @@
            yesterday_codes = kpl_data_manager.get_yesterday_limit_up_codes()
            if yesterday_codes is None:
                yesterday_codes = set()
            current_price_process_manager.accept_prices(tick_datas, request_id, in_blocks[:20], yesterday_codes)
            current_price_process_manager.accept_prices(tick_datas, request_id, in_blocks[:30], yesterday_codes)
        except Exception as e:
            logger_debug.exception(e)
        finally:
trade/current_price_process_manager.py
@@ -88,11 +88,9 @@
    @param top_in_blocks: 净流入前几的代码
    @return:
    """
    logger_debug.debug(f"接收L1数据测试:流入前20-{top_in_blocks}")
    # logger_debug.debug(f"接收L1数据测试:流入前20-{top_in_blocks}")
    if True:
        today_history_limit_up_codes = set([d[3] for d in LimitUpDataConstant.history_limit_up_datas])
        _code_list = []
        _delete_list = []
        temp_prices = []
@@ -126,7 +124,7 @@
        # -------------------------------处理交易位置分配---------------------------------
        # 排序
        new_code_list = sorted(_code_list, key=lambda e: (e[2], -e[0]))
        logger_debug.debug(f"接收L1数据测试:排序过后的代码-{new_code_list[:75]}")
        # logger_debug.debug(f"接收L1数据测试:排序过后的代码-{new_code_list[:75]}")
        # -------------------------------处理L2监听---------------------------------
        max_count = constant.HUAXIN_L2_MAX_CODES_COUNT