| | |
|---|
| | | from l2.l2_data_manager_new import L2TradeDataProcessor |
|---|
| | | from log_module import async_log_util |
|---|
| | | 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_l2_market_data, logger_l2_trade_buy_queue |
|---|
| | | hx_logger_l2_orderdetail, hx_logger_l2_transaction, hx_logger_l2_market_data, logger_l2_trade_buy_queue, \ |
|---|
| | | logger_l2_g_cancel |
|---|
| | | from third_data import block_info, kpl_api, kpl_data_manager |
|---|
| | | from third_data.code_plate_key_manager import KPLCodeJXBlockManager, CodePlateKeyBuyManager |
|---|
| | | from third_data.history_k_data_util import JueJinApi, HistoryKDatasUtils |
|---|
| | |
|---|
| | | code = data["code"] |
|---|
| | | timestamp = data.get("time") |
|---|
| | | datas = data["data"] |
|---|
| | | async_log_util.info(hx_logger_l2_orderdetail,f"{code}#{timestamp}->{int(time.time()*1000)}#{datas}") |
|---|
| | | async_log_util.info(hx_logger_l2_orderdetail, |
|---|
| | | f"{code}#耗时：{int(time.time() * 1000) - timestamp}#{datas}") |
|---|
| | | l2_log.threadIds[code] = random.randint(0, 100000) |
|---|
| | | l2_data_manager_new.L2TradeDataProcessor.process_huaxin(code, datas) |
|---|
| | | finally: |
|---|
| | |
|---|
| | | data = data_json["data"] |
|---|
| | | code = data["code"] |
|---|
| | | order_no = data["data"] |
|---|
| | | hx_logger_l2_upload.info(f"{code}-正在成交的订单撤单，order_no:{order_no}") |
|---|
| | | # buyno_map = l2_data_util.local_today_buyno_map.get(code) |
|---|
| | | # if buyno_map: |
|---|
| | | # l2_data = buyno_map.get(order_no) |
|---|
| | | # buyno_map.get(order_no) |
|---|
| | | # 执行撤单 |
|---|
| | | logger_l2_g_cancel.info(f"{code}-正在成交的订单撤单，order_no:{order_no}") |
|---|
| | | l2_data_manager_new.L2TradeDataProcessor.cancel_buy(code, "G撤撤单", "G撤") |
|---|
| | | else: |
|---|
| | | # 断开连接 |
|---|
