| | |
|---|
| | | buy_one_price_ = decimal.Decimal(round(float(buy_one_price), 2)).quantize( |
|---|
| | | decimal.Decimal("0.00")) |
|---|
| | | # 获取执行位时间 |
|---|
| | | |
|---|
| | | buy_single_index, buy_exec_index, compute_index, num, count, max_num_set, volume_rate = l2_data_manager.TradePointManager().get_buy_compute_start_data( |
|---|
| | | code) |
|---|
| | | order_begin_pos = l2_data_manager.TradePointManager().get_buy_compute_start_data_cache(code) |
|---|
| | | if True: |
|---|
| | | # 只有下单过后才获取交易进度 |
|---|
| | | exec_time = None |
|---|
| | | try: |
|---|
| | | if buy_exec_index: |
|---|
| | | if order_begin_pos.buy_exec_index and order_begin_pos.buy_exec_index > -1: |
|---|
| | | exec_time = \ |
|---|
| | | l2.l2_data_util.local_today_datas.get(code)[buy_exec_index]["val"][ |
|---|
| | | "time"] |
|---|
| | | l2.l2_data_util.local_today_datas.get(code)[order_begin_pos.buy_exec_index]["val"]["time"] |
|---|
| | | except: |
|---|
| | | pass |
|---|
| | | buy_progress_index = self.tradeBuyQueue.compute_traded_index(code, |
|---|
| | |
|---|
| | | buy_queue_result_list, |
|---|
| | | exec_time) |
|---|
| | | if buy_progress_index is not None: |
|---|
| | | LCancelBigNumComputer().set_trade_progress(code, buy_progress_index, |
|---|
| | | LCancelBigNumComputer().set_trade_progress(code, order_begin_pos.buy_single_index, buy_progress_index, |
|---|
| | | l2.l2_data_util.local_today_datas.get( |
|---|
| | | code)) |
|---|
| | | |
|---|
