| | |
| | | # if need_cancel: |
| | | # L2TradeDataProcessor.cancel_buy(code, f"D撤:{msg}", source="d_cancel") |
| | | |
| | | LCancelBigNumComputer().set_trade_progress(code, buy_progress_index, total_datas) |
| | | LCancelBigNumComputer().set_trade_progress(code, order_begin_pos.buy_single_index, buy_progress_index, total_datas) |
| | | FastCancelBigNumComputer().set_trade_progress(code, buy_progress_index) |
| | | SecondCancelBigNumComputer().set_transaction_index( |
| | | code, |
| | | buy_progress_index) |
| | | if order_begin_pos and order_begin_pos.buy_exec_index and order_begin_pos.buy_exec_index > -1: |
| | | HourCancelBigNumComputer().set_transaction_index(code, buy_progress_index) |
| | | HourCancelBigNumComputer().set_transaction_index(code, order_begin_pos.buy_single_index, buy_progress_index) |
| | | else: |
| | | pass |
| | | if order_begin_pos and order_begin_pos.buy_exec_index and order_begin_pos.buy_exec_index > -1: |
| | | # 触发L撤上重新计算 |
| | | LCancelBigNumComputer().re_compute_l_up_watch_indexes(code) |
| | | LCancelBigNumComputer().re_compute_l_up_watch_indexes(code, order_begin_pos.buy_single_index) |
| | | |
| | | except Exception as e: |
| | | hx_logger_l2_transaction.exception(e) |