| | |
| | | from code_attribute import gpcode_manager, gpcode_first_screen_manager, global_data_loader, code_nature_analyse, \ |
| | | code_volumn_manager |
| | | from code_attribute.code_data_util import ZYLTGBUtil |
| | | from log_module.log import logger_first_code_record |
| | | from log_module.log import logger_first_code_record, logger_l2_codes_subscript |
| | | from third_data import kpl_api, block_info |
| | | from third_data.code_plate_key_manager import CodesHisReasonAndBlocksManager |
| | | from third_data.history_k_data_util import HistoryKDatasUtils |
| | |
| | | |
| | | |
| | | def process_first_codes_datas(dataList): |
| | | logger_l2_codes_subscript.info("加载l2代码相关数据") |
| | | print("首板代码数量:", len(dataList)) |
| | | limit_up_price_dict = {} |
| | | temp_codes = [] |
| | |
| | | block_info.init_code(code) |
| | | |
| | | if new_add_codes: |
| | | gpcode_manager.set_first_gp_codes_with_data(HistoryKDatasUtils.get_gp_latest_info(codes, |
| | | fields="symbol,sec_name,sec_type,sec_level")) |
| | | gpcode_manager.FirstGPCodesManager().set_first_gp_codes_with_data(HistoryKDatasUtils.get_gp_latest_info(codes, |
| | | fields="symbol,sec_name,sec_type,sec_level")) |
| | | # 加入首板历史记录 |
| | | logger_first_code_record.info("新增首板:{}", new_add_codes) |
| | | |
| | |
| | | "limit_up": is_limit_up}) |
| | | if code in new_add_codes: |
| | | if is_limit_up: |
| | | place_order_count = trade_data_manager.placeordercountmanager.get_place_order_count( |
| | | place_order_count = trade_data_manager.PlaceOrderCountManager().get_place_order_count( |
| | | code) |
| | | if place_order_count == 0: |
| | | trade_data_manager.placeordercountmanager.place_order(code) |
| | | trade_data_manager.PlaceOrderCountManager().place_order(code) |
| | | |
| | | gpcode_first_screen_manager.process_ticks(prices) |
| | | |
| | | logger_l2_codes_subscript.info("l2代码相关数据加载完成") |
| | | return tick_datas |