| | |
| | | from db.redis_manager_delegate import RedisUtils |
| | | from l2 import l2_data_util, l2_data_manager, transaction_progress, l2_data_source_util |
| | | from l2.cancel_buy_strategy import LCancelRateManager, LCancelBigNumComputer, \ |
| | | SecondCancelBigNumComputer, HourCancelBigNumComputer, FastCancelBigNumComputer, UCancelBigNumComputer |
| | | SecondCancelBigNumComputer, HourCancelBigNumComputer, FastCancelBigNumComputer, UCancelBigNumComputer, \ |
| | | GCancelBigNumComputer |
| | | from l2.l2_data_manager_new import L2TradeDataProcessor |
| | | from l2.l2_data_util import L2DataUtil, local_today_canceled_buyno_map |
| | | from log_module import async_log_util |
| | |
| | | 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) |
| | | |
| | | FastCancelBigNumComputer().set_trade_progress(code, buy_progress_index) |
| | | SecondCancelBigNumComputer().set_transaction_index( |
| | | code, |