| | |
| | | cls.pipe_l2.send( |
| | | json.dumps({"type": "set_l2_codes", "data": _data})) |
| | | else: |
| | | cls.process_command_thread_pool.submit(cls.__process_command, _type, None, val) |
| | | threading.Thread(target=lambda: cls.__process_command(_type, None, val), daemon=True).start() |
| | | except Exception as e: |
| | | logger_local_huaxin_trade_debug.exception(e) |
| | | logging.exception(e) |
| | |
| | | |
| | | # 依次处理 |
| | | cancel_data, cancel_msg = s_cancel(buy_single_index, buy_exec_index) |
| | | if not cancel_data: |
| | | cancel_data, cancel_msg = h_cancel(buy_single_index, buy_exec_index) |
| | | # if not cancel_data: |
| | | # cancel_data, cancel_msg = h_cancel(buy_single_index, buy_exec_index) |
| | | if not cancel_data: |
| | | cancel_data, cancel_msg = l_cancel(buy_single_index, buy_exec_index) |
| | | # l2_log.debug(code, "撤单计算结束") |