code_attribute/first_target_code_data_processor.py
@@ -22,6 +22,8 @@ def process_first_codes_datas(dataList, request_id=None): logger_l2_codes_subscript.info(f"{request_id}加载l2代码相关数据") print("首板代码数量：", len(dataList)) # 获取最近5天的交易日期，为后面的数据计算做准备 HistoryKDatasUtils.get_latest_trading_date_cache(5) limit_up_price_dict = {} temp_codes = [] codes = [] @@ -160,6 +162,7 @@ # volumes_data) except Exception as e: logger_first_code_record.error(f"{code}:{str(e)}") logger_first_code_record.exception(e) gpcode_manager.FirstCodeManager().add_record(codes) # 初始化板块信息，暂时删除 # for code in codes:
