| | |
|---|
| | | rate = round(total_deal_nums / (thresh_hold_money // (float(limit_up_price) * 100)), 2) |
|---|
| | | LCancelRateManager().set_big_num_deal_rate(code, rate) |
|---|
| | | |
|---|
| | | if buy_progress_index is not None: |
|---|
| | | # 获取执行位时间 |
|---|
| | | buy_single_index, buy_exec_index, compute_index, num, count, max_num_set, volume_rate = l2_data_manager.TradePointManager().get_buy_compute_start_data_cache( |
|---|
| | | code) |
|---|
| | | buy_single_index, buy_exec_index, compute_index, num, count, max_num_set, volume_rate = l2_data_manager.TradePointManager().get_buy_compute_start_data_cache(code) |
|---|
| | | if buy_progress_index is not None: |
|---|
| | | cls.__TradeBuyQueue.set_traded_index(code, buy_progress_index) |
|---|
| | | async_log_util.info(logger_l2_trade_buy_queue, "获取成交位置成功： code-{} index-{}", code, |
|---|
| | | buy_progress_index) |
|---|
| | |
|---|
| | | HourCancelBigNumComputer().set_transaction_index(code, buy_progress_index) |
|---|
| | | else: |
|---|
| | | pass |
|---|
| | | if buy_exec_index and buy_exec_index > -1: |
|---|
| | | # 触发L撤上重新计算 |
|---|
| | | LCancelBigNumComputer().re_compute_l_up_watch_indexes(code) |
|---|
| | | |
|---|
| | | except Exception as e: |
|---|
| | | hx_logger_l2_transaction.exception(e) |
|---|
| | | finally: |
|---|
