| | |
|---|
| | | # GCancelBigNumComputer().set_big_sell_order_info(code, big_sell_order_info) |
|---|
| | | use_time_list.append(("处理卖单相关撤数据", time.time() - _start_time)) |
|---|
| | | _start_time = time.time() |
|---|
| | | HuaXinSellOrderStatisticManager.statistic_total_deal_volume(code, datas) |
|---|
| | | use_time_list.append(("统计成交量数据", time.time() - _start_time)) |
|---|
| | | except Exception as e: |
|---|
| | | async_log_util.error(logger_debug, f"卖单统计异常：{big_sell_order_info}") |
|---|
| | | logger_debug.exception(e) |
|---|
| | | |
|---|
| | | _start_time = time.time() |
|---|
| | | cls.__statistic_thread_pool.submit(cls.statistic_big_order_infos, code, datas, order_begin_pos) |
|---|
| | | |
|---|
| | |
|---|
| | | 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]}") |
|---|
| | | # if not cancel_result[0]: |
|---|
| | | # try: |
|---|
| | | # cancel_result = NBCancelBigNumComputer().need_cancel(code, buy_progress_index) |
|---|
| | | # if cancel_result[0]: |
|---|
| | | # L2TradeDataProcessor.cancel_buy(code, f"大市值无大单撤:{cancel_result[1]}") |
|---|
| | | # except: |
|---|
| | | # pass |
|---|
| | | if not cancel_result[0]: |
|---|
| | | try: |
|---|
| | | cancel_result = NBCancelBigNumComputer().need_cancel(code, buy_progress_index) |
|---|
| | | if cancel_result[0]: |
|---|
| | | L2TradeDataProcessor.cancel_buy(code, f"大市值无大单撤:{cancel_result[1]}") |
|---|
| | | except: |
|---|
| | | pass |
|---|
| | | |
|---|
| | | if not cancel_result[0] and buy_progress_index_changed: |
|---|
| | | try: |
|---|
