| | |
|---|
| | | if buy_progress_index is not None: |
|---|
| | | buy_progress_index_changed = cls.__TradeBuyQueue.set_traded_index(code, buy_progress_index, |
|---|
| | | total_datas) |
|---|
| | | |
|---|
| | | async_log_util.info(logger_l2_trade_buy_queue, "获取成交位置成功： code-{} index-{}", code, |
|---|
| | | buy_progress_index) |
|---|
| | | |
|---|
| | | GCancelBigNumComputer().set_trade_progress(code, order_begin_pos.buy_single_index, buy_progress_index) |
|---|
| | | |
|---|
| | | LCancelBigNumComputer().set_trade_progress(code, order_begin_pos.buy_single_index, buy_progress_index, |
|---|
| | | total_datas) |
|---|
| | | |
|---|
| | | if is_placed_order: |
|---|
| | | GCancelBigNumComputer().set_trade_progress(code, order_begin_pos.buy_single_index, |
|---|
| | | buy_progress_index) |
|---|
| | | LCancelBigNumComputer().set_trade_progress(code, order_begin_pos.buy_single_index, |
|---|
| | | buy_progress_index, |
|---|
| | | total_datas) |
|---|
| | | cancel_result = FCancelBigNumComputer().need_cancel_for_deal_fast(code, buy_progress_index) |
|---|
| | | if cancel_result[0]: |
|---|
| | | L2TradeDataProcessor.cancel_buy(code, f"F撤:{cancel_result[1]}") |
|---|
