| | |
| | | from db import redis_manager_delegate as redis_manager |
| | | from db.redis_manager_delegate import RedisUtils |
| | | from l2.l2_data_manager import OrderBeginPosInfo |
| | | from log_module import async_log_util |
| | | from utils import tool |
| | | from l2.transaction_progress import TradeBuyQueue |
| | | from trade import trade_queue_manager, l2_trade_factor, trade_record_log_util |
| | |
| | | self.__compute_watch_index(code, buy_single_index) |
| | | except Exception as e: |
| | | l2_log.h_cancel_debug(code, "设置成交进度位置出错:{}", str(e)) |
| | | logger_l2_h_cancel.exception(e) |
| | | async_log_util.exception(logger_l2_h_cancel, e) |
| | | |
| | | # 设置真实下单位置 |
| | | def set_real_place_order_index(self, code, index, buy_single_index): |
| | | if buy_single_index is None: |
| | | return |
| | | try: |
| | | # 计算触发位置 |
| | | min_num = int(5000 / (float(gpcode_manager.get_limit_up_price(code)))) |
| | |
| | | temp_index = int(temp_count * 9 / 10) |
| | | self.__start_compute_index_dict[code] = not_cancel_indexes[temp_index] |
| | | except Exception as e: |
| | | async_log_util.exception(logger_l2_h_cancel,e) |
| | | l2_log.h_cancel_debug(code, "设置真实下单位置出错:{}", str(e)) |
| | | |
| | | def need_cancel(self, code, buy_single_index, buy_exec_index, start_index, end_index, total_data, |
| | |
| | | if left_count > 0: |
| | | total_count += left_count |
| | | if total_count >= 2: |
| | | l2_log.f_cancel_debug(code, f"交易进度距离下单位置纯买单数超过2单") |
| | | return False |
| | | return True |
| | | |