| | |
| | | from code_attribute import gpcode_manager |
| | | from l2 import l2_data_util, l2_data_manager, transaction_progress |
| | | from l2.cancel_buy_strategy import LCancelRateManager, DCancelBigNumComputer, LCancelBigNumComputer, \ |
| | | SecondCancelBigNumComputer |
| | | SecondCancelBigNumComputer, HourCancelBigNumComputer |
| | | from l2.l2_data_manager_new import L2TradeDataProcessor |
| | | from l2.l2_data_util import L2DataUtil |
| | | from log_module import async_log_util |
| | |
| | | cls.__TradeBuyQueue.set_traded_index(code, buy_progress_index) |
| | | async_log_util.info(logger_l2_trade_buy_queue, "获取成交位置成功: code-{} index-{}", code, |
| | | buy_progress_index) |
| | | limit_up_price = gpcode_manager.get_limit_up_price(code) |
| | | # limit_up_price = gpcode_manager.get_limit_up_price(code) |
| | | # 注释掉D撤单 |
| | | # if buy_exec_index and buy_exec_index > -1: |
| | | # m_base_val = L2PlaceOrderParamsManager.get_base_m_val(code) |
| | |
| | | SecondCancelBigNumComputer().set_transaction_index( |
| | | code, |
| | | buy_progress_index) |
| | | if buy_exec_index and buy_exec_index > -1: |
| | | HourCancelBigNumComputer().set_transaction_index(code, buy_progress_index) |
| | | else: |
| | | pass |
| | | except Exception as e: |