| | |
|---|
| | | origin_datas.clear() |
|---|
| | | |
|---|
| | | @classmethod |
|---|
| | | def __recompute_real_order_index(cls, code, pre_real_order_index, order_info): |
|---|
| | | def __recompute_real_order_index(cls, code, pre_real_order_index, order_info, compute_type): |
|---|
| | | # 因为数据慢的问题重新计算 |
|---|
| | | real_order_index = huaxin_delegate_postion_manager.recompute_for_slow_time(code, order_info, |
|---|
| | | pre_real_order_index) |
|---|
| | | pre_real_order_index, compute_type) |
|---|
| | | if real_order_index: |
|---|
| | | try: |
|---|
| | | exec_index = order_info[6] |
|---|
| | |
|---|
| | | # cls.set_real_place_order_index(code, place_order_index, order_begin_pos.buy_single_index) |
|---|
| | | else: |
|---|
| | | # 获取下单位置 |
|---|
| | | place_order_index, order_info = huaxin_delegate_postion_manager.get_l2_place_order_position( |
|---|
| | | place_order_index, order_info, compute_type = huaxin_delegate_postion_manager.get_l2_place_order_position( |
|---|
| | | code, float( |
|---|
| | | gpcode_manager.get_limit_up_price(code)), add_datas) |
|---|
| | | if place_order_index: |
|---|
| | |
|---|
| | | cls.set_real_place_order_index(code, place_order_index, order_begin_pos) |
|---|
| | | try: |
|---|
| | | cls.__re_compute_threading_pool.submit( |
|---|
| | | cls.__recompute_real_order_index, code, place_order_index, order_info) |
|---|
| | | cls.__recompute_real_order_index, code, place_order_index, order_info, compute_type) |
|---|
| | | except: |
|---|
| | | pass |
|---|
| | | async_log_util.info(logger_l2_process, f"code:{code} 获取到下单真实位置：{place_order_index}") |
|---|
| | |
|---|
| | | if cancel_index is None: |
|---|
| | | cancel_index = total_datas[-1]["index"] |
|---|
| | | cls.__LatestCancelIndexManager.set_latest_cancel_index(code, cancel_index) |
|---|
| | | |
|---|
| | | # 记录撤单日志 |
|---|
| | | real_place_order_index = SCancelBigNumComputer().get_real_place_order_index_cache(code) |
|---|
| | | # 添加撤单日志记录 |
|---|
| | | trade_record_log_util.add_cancel_msg_log(code, msg) |
|---|
| | | trade_record_log_util.add_cancel_msg_log(code, real_place_order_index, msg) |
|---|
| | | cancel_result = cls.__cancel_buy(code) |
|---|
| | | if cancel_result: |
|---|
| | | trade_result_manager.real_cancel_success(code, order_begin_pos.buy_single_index, |
|---|
