| | |
| | | import time |
| | | |
| | | import constant |
| | | from l2 import l2_data_manager_new |
| | | from l2 import l2_data_manager_new, l2_log |
| | | from l2.huaxin import huaxin_target_codes_manager |
| | | from log_module.log import hx_logger_l2_upload, hx_logger_contact_debug, hx_logger_trade_callback, \ |
| | | hx_logger_l2_orderdetail, hx_logger_l2_transaction, hx_logger_trade_debug |
| | |
| | | code = data["code"] |
| | | datas = data["data"] |
| | | hx_logger_l2_orderdetail.info(f"{code}#{datas}") |
| | | l2_log.threadIds[code] = random.randint(0, 100000) |
| | | l2_data_manager_new.L2TradeDataProcessor.process_huaxin(code, datas) |
| | | sk.sendall(json.dumps({"code": 0}).encode(encoding='utf-8')) |
| | | |