| | |
| | | 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: |
| | |
| | | @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 |
| | | |