l2/huaxin/huaxin_target_codes_manager.py
@@ -63,6 +63,7 @@ @classmethod def set_level_1_codes_datas(cls, datas): logger_l2_codes_subscript.info("接受到L1的数据,开始预处理") yesterday_codes = kpl_data_manager.get_yesterday_limit_up_codes() # 订阅的代码 flist = [] @@ -98,6 +99,7 @@ "zyltgb": zyltgb // 10000, "zyltgbUnit": 1} flist.append(fitem) code_volumn_manager.set_today_volumns(temp_volumns) logger_l2_codes_subscript.info("接受到L1的数据,预处理完成") try: tick_datas = first_target_code_data_processor.process_first_codes_datas(flist) current_price_process_manager.accept_prices(tick_datas)