Administrator
2023-10-31 5abf971a584cec748e3c691e1a359815d649d2f6
l2/cancel_buy_strategy.py
@@ -16,6 +16,7 @@
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
@@ -576,10 +577,12 @@
                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))))
@@ -606,6 +609,7 @@
                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,
@@ -1476,6 +1480,7 @@
                if left_count > 0:
                    total_count += left_count
                    if total_count >= 2:
                        l2_log.f_cancel_debug(code, f"交易进度距离下单位置纯买单数超过2单")
                        return False
        return True