| | |
|---|
| | | from l2.huaxin import huaxin_target_codes_manager |
|---|
| | | from log_module.log import logger_system, logger_l2_codes_subscript |
|---|
| | | from third_data import block_info |
|---|
| | | from third_data.code_plate_key_manager import KPLCodeJXBlockManager |
|---|
| | | from third_data.history_k_data_util import HistoryKDatasUtils, JueJinApi |
|---|
| | | from third_data.kpl_data_manager import KPLDataManager |
|---|
| | | from third_data.kpl_util import KPLDataType |
|---|
| | |
|---|
| | | root_data = socket_util.encryp_client_params_sign(root_data) |
|---|
| | | pipe_l2.send(json.dumps(root_data)) |
|---|
| | | print("设置L2代码结束") |
|---|
| | | # 如果在9:24-9:30 需要加载板块 |
|---|
| | | if int("092400") < int(tool.get_now_time_str().replace(":", "")) < int("093000"): |
|---|
| | | for d in datas: |
|---|
| | | KPLCodeJXBlockManager().load_jx_blocks(d[0], gpcode_manager.get_price(d[0]), float(d[2])) |
|---|
| | | logger_l2_codes_subscript.info("({})发送到华鑫L2代码处理队列：数量-{}", request_id, len(datas)) |
|---|
| | | except Exception as e: |
|---|
| | | logging.exception(e) |
|---|
