| | |
|---|
| | | @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 = [] |
|---|
| | |
|---|
| | | # -------------------------------处理交易位置分配--------------------------------- |
|---|
| | | # 排序 |
|---|
| | | 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 |
|---|
| | | |
|---|
