refactor(gateApi): 移除首次挂单成交标记及相关逻辑

Administrator

1 days ago 2ca49cc931d2f2f9e9a98cce9b4c22120c077904

 src/main/java/com/xcong/excoin/modules/gateApi/GateGridTradeService.java

@@ -364,6 +364,7 @@
     * @param closePrice K 线收盘价（即当前最新成交价）
     */
    public void onKline(BigDecimal closePrice) {

        lastKlinePrice = closePrice;

        //初始化0位置的开仓，并且用空的开仓价格，作为价格基准来划分网格
@@ -391,9 +392,7 @@
            return;
        }


//        checkProfitAndReset();

        checkProfitAndReset();

        if (state == StrategyState.ACTIVE &&
                longActive == false &&
@@ -412,25 +411,18 @@
    /** Gate 永续合约 taker 费率 0.05% */
    private static final BigDecimal TAKER_FEE_RATE = new BigDecimal("0.0005");
    private void checkProfitAndReset() {
        if (state == StrategyState.STOPPED || state == StrategyState.WAITING_KLINE) {
            return;
        }
        try {

            BigDecimal target = initialPrincipal.add(config.getExpectedProfit());

            FuturesAccount account = futuresApi.listFuturesAccounts(SETTLE);
            BigDecimal unrealisedPnl = new BigDecimal(account.getCrossUnrealisedPnl());
            BigDecimal available = new BigDecimal(account.getCrossAvailable());
            BigDecimal totalEquity = unrealisedPnl.add(available);
            BigDecimal totalEquity = new BigDecimal(account.getTotal()).add(new BigDecimal(account.getUnrealisedPnl()));

            // 估算平仓手续费：(多仓张数+空仓张数) × 合约面值 × 当前价 × taker费率
            BigDecimal totalSize = longPositionSize.abs().add(shortPositionSize.abs());
            BigDecimal closeContractValue =
                    totalSize.multiply(config.getContractMultiplier()).multiply(lastKlinePrice != null ? lastKlinePrice : BigDecimal.ZERO);
            BigDecimal estimatedFee = closeContractValue.multiply(TAKER_FEE_RATE);
            BigDecimal netEquity = totalEquity.subtract(estimatedFee);
            log.info("[Gate] 盈亏检查,总张数：{}, upl:{}, avail:{}, 合计:{}, 估手续费:{}, 净权益:{}, 目标:{}",
                    totalSize,unrealisedPnl, available, totalEquity, estimatedFee, netEquity, target);
            if (netEquity.compareTo(target) > 0) {
                log.info("[Gate] 盈亏达标(净权益{}>目标{})，重置策略", netEquity, target);
            if (totalEquity.compareTo(target) > 0) {
                log.info("[Gate] 盈亏达标(净权益{}>目标{})，重置策略", totalEquity, target);
                state = StrategyState.STOPPED;
                try {
                    futuresApi.cancelPriceTriggeredOrderList(SETTLE, config.getContract());
@@ -605,7 +597,7 @@
            longTakeProfitTraderIdParam(longTpElem, null, false);
            log.info("[Gate] 多仓止盈触发 gridId:{}, orderId:{}", longTpElem.getId(), orderId);
            cancelFarthestLongStopLoss();
            checkLastTakeProfitAndRestart();
//            checkLastTakeProfitAndRestart();
            return;
        }
        // [Gate-需求1] 空仓止盈触发：清空止盈状态 + 取消最远空仓止损 + 检查是否最后一个止盈
@@ -614,7 +606,7 @@
            shortTakeProfitTraderIdParam(shortTpElem, null, false);
            log.info("[Gate] 空仓止盈触发 gridId:{}, orderId:{}", shortTpElem.getId(), orderId);
            cancelFarthestShortStopLoss();
            checkLastTakeProfitAndRestart();
//            checkLastTakeProfitAndRestart();
            return;
        }

@@ -638,22 +630,54 @@
                shortEntryTraderIdParam(shortGridElement, null, false);
                // [Gate-需求2] 加仓后先撤空仓所有止盈+止损，再查交易所持仓后重挂
                cancelAllShortTakeProfitsAndStopLosses();
                int posSize = queryPositionSize(Position.ModeEnum.DUAL_SHORT);
                // REST 查询可能因交易所延迟返回旧值，与 WS 本地缓存取最大值兜底
                int posSize = Math.max(queryPositionSize(Position.ModeEnum.DUAL_SHORT), shortPositionSize.intValue());
                extendShortStopLoss(posSize, shortGridElement.getId());
                accumulatedShortLossCount = 0; // 加仓订单成交，重置止损累计
                log.info("[Gate] 空单成交 gridId:{}, 当前持仓:{}张", filledQty, posSize);

                // 空仓持仓超过baseQuantity时，从gridId-2开始向外追挂止盈
//                int tpGridId = 0;
//                GridElement tpElem = GridElement.findById(tpGridId);
//                // 已有止盈单先取消再重挂
//                String existingShortTpId = tpElem.getShortTakeProfitOrderId();
//                if (existingShortTpId != null) {
//                    executor.cancelConditionalOrder(existingShortTpId, oid -> {
//                        shortTakeProfitTraderIdParam(tpElem, null, false);
//                        log.info("[Gate] 空仓止盈取消(gridId:{})，准备重挂", tpGridId);
//                    });
//                }
//                BigDecimal tpPrice = tpElem.getGridPrice();
//                int finalTpGridId = tpGridId;
//                executor.placeTakeProfit(
//                        tpPrice,
//                        FuturesPriceTrigger.RuleEnum.NUMBER_2,
//                        ORDER_TYPE_CLOSE_SHORT,
//                        config.getQuantity(),
//                        profitId -> {
//                            shortTakeProfitTraderIdParam(tpElem, profitId, true);
//                            log.info("[Gate] 空仓止盈挂单, gridId:{}, 触发价:{}, takeProfitId:{}",
//                                    finalTpGridId, tpPrice, profitId);
//                        }
//                );

                // 空仓持仓超过baseQuantity时，先找多仓第一个止损位置，从该位置向下挂止盈（间隔=1）
                BigDecimal shortBaseQty = new BigDecimal(config.getBaseQuantity());
                BigDecimal shortGridQty = new BigDecimal(config.getQuantity());
                if (BigDecimal.valueOf(posSize).compareTo(shortBaseQty) > 0) {
                    BigDecimal shortExcess = BigDecimal.valueOf(posSize).subtract(shortBaseQty);
                    int shortExcessCount = shortExcess.divide(shortGridQty, 0, RoundingMode.DOWN).intValue();

//                    // 找多仓第一个（最近的）止损位置
//                    int firstLongSlId = 0;
//                    for (GridElement e : config.getGridElements()) {
//                        if (e.getLongStopLossOrderId() != null) {
//                            if (firstLongSlId == 0 || e.getId() > firstLongSlId) {
//                                firstLongSlId = e.getId();
//                            }
//                        }
//                    }

                    for (int i = 0; i < shortExcessCount; i++) {
                        int tpGridId = shortGridElement.getId() - 2 - i;
                        if (i > 0){
                            tpGridId = tpGridId - 1;
                        }
                        int tpGridId = shortGridElement.getId() - 2 * (i + 1);
                        GridElement tpElem = GridElement.findById(tpGridId);
                        if (tpElem == null || tpElem.getShortTakeProfitOrderId() != null) {
                            continue;
@@ -683,23 +707,54 @@
                longEntryTraderIdParam(longGridElement, null, false);
                // [Gate-需求2] 加仓后先撤多仓所有止盈+止损，再查交易所持仓后重挂
                cancelAllLongTakeProfitsAndStopLosses();
                int posSize = queryPositionSize(Position.ModeEnum.DUAL_LONG);
                // REST 查询可能因交易所延迟返回旧值，与 WS 本地缓存取最大值兜底
                int posSize = Math.max(queryPositionSize(Position.ModeEnum.DUAL_LONG), longPositionSize.intValue());
                extendLongStopLoss(posSize, longGridElement.getId());
                accumulatedLongLossCount = 0; // 加仓订单成交，重置止损累计
                log.info("[Gate] 多单成交 gridId:{}, 当前持仓:{}张", filledQty, posSize);

                // 多仓持仓超过baseQuantity时，从gridId+2开始向外追挂止盈
//                int tpGridId = 0;
//                GridElement tpElem = GridElement.findById(tpGridId);
//                // 已有止盈单先取消再重挂
//                String existingLongTpId = tpElem.getLongTakeProfitOrderId();
//                if (existingLongTpId != null) {
//                    executor.cancelConditionalOrder(existingLongTpId, oid -> {
//                        longTakeProfitTraderIdParam(tpElem, null, false);
//                        log.info("[Gate] 多仓止盈取消(gridId:{})，准备重挂", tpGridId);
//                    });
//                }
//                BigDecimal tpPrice = tpElem.getGridPrice();
//                int finalTpGridId = tpGridId;
//                executor.placeTakeProfit(
//                        tpPrice,
//                        FuturesPriceTrigger.RuleEnum.NUMBER_1,
//                        ORDER_TYPE_CLOSE_LONG,
//                        negate(config.getQuantity()),
//                        profitId -> {
//                            longTakeProfitTraderIdParam(tpElem, profitId, true);
//                            log.info("[Gate] 多仓止盈挂单, gridId:{}, 触发价:{}, takeProfitId:{}",
//                                    finalTpGridId, tpPrice, profitId);
//                        }
//                );

                // 多仓持仓超过baseQuantity时，先找空仓第一个止损位置，从该位置向上挂止盈（间隔=1）
                BigDecimal longBaseQty = new BigDecimal(config.getBaseQuantity());
                BigDecimal longGridQty = new BigDecimal(config.getQuantity());
                if (BigDecimal.valueOf(posSize).compareTo(longBaseQty) > 0) {
                    BigDecimal longExcess = BigDecimal.valueOf(posSize).subtract(longBaseQty);
                    int longExcessCount = longExcess.divide(longGridQty, 0, RoundingMode.DOWN).intValue();
                    for (int i = 0; i < longExcessCount; i++) {
                        int tpGridId = longGridElement.getId() + 2 + i;
                        if (i > 0){
                            tpGridId = tpGridId + 1;
                        }

//                    // 找空仓第一个（最近的）止损位置
//                    int firstShortSlId = 0;
//                    for (GridElement e : config.getGridElements()) {
//                        if (e.getShortStopLossOrderId() != null) {
//                            if (firstShortSlId == 0 || e.getId() < firstShortSlId) {
//                                firstShortSlId = e.getId();
//                            }
//                        }
//                    }

                    for (int i = 0; i < longExcessCount; i++) {
                        int tpGridId = longGridElement.getId() + 2 * (i + 1);
                        GridElement tpElem = GridElement.findById(tpGridId);
                        if (tpElem == null || tpElem.getLongTakeProfitOrderId() != null) {
                            continue;
@@ -799,6 +854,43 @@
            baseGridElement.setShortOrderId(baseShortTraderParam.getEntryOrderId());
            baseGridElement.setHasShortOrder(true);

//            // 空仓止损对应的多仓止盈：多仓止盈挂在ID=3
//            int tpGridIdLong = 3;
//            GridElement tpElemLong = GridElement.findById(tpGridIdLong);
//            BigDecimal triggerPriceLong = tpElemLong.getGridPrice();
//            String sizeLong = config.getBaseQuantity();
//            executor.placeTakeProfit(
//                    triggerPriceLong,
//                    FuturesPriceTrigger.RuleEnum.NUMBER_1,
//                    ORDER_TYPE_CLOSE_LONG,
//                    negate(sizeLong),
//                    profitId -> {
//                        tpElemLong.setLongTakeProfitOrderId(profitId);
//                        GridElement.refreshIndices();
//                        log.info("[Gate] 多仓止盈已挂(gridId:{}多止盈), 触发价:{}, takeProfitId:{}",
//                                tpGridIdLong, triggerPriceLong, profitId);
//                    }
//            );
//
//
//            // 多仓止损对应的空仓止盈：空仓止盈挂在ID=-3
//            int tpGridIdShort = -3;
//            GridElement tpElemShort = GridElement.findById(tpGridIdShort);
//            BigDecimal triggerPriceShort = tpElemShort.getGridPrice();
//            String sizeShort = config.getBaseQuantity();
//            executor.placeTakeProfit(
//                    triggerPriceShort,
//                    FuturesPriceTrigger.RuleEnum.NUMBER_2,
//                    ORDER_TYPE_CLOSE_SHORT,
//                    sizeShort,
//                    profitId -> {
//                        tpElemShort.setShortTakeProfitOrderId(profitId);
//                        GridElement.refreshIndices();
//                        log.info("[Gate] 空仓止盈已挂(gridId:{}空止盈), 触发价:{}, takeProfitId:{}",
//                                tpGridIdShort, triggerPriceShort, profitId);
//                    }
//            );

//            int shortTime = 2;
//            GridElement elemShort = GridElement.findById(shortTime);
//            if (elemShort != null) {
@@ -859,6 +951,7 @@
            }



            int longTime = Integer.parseInt(config.getBaseQuantity()) / Integer.parseInt(config.getQuantity()) + 1;
            for (int id = -2; id >= -longTime; id--) {
                GridElement elem = GridElement.findById(id);
@@ -881,7 +974,7 @@
                );
            }

            log.info("[Gate] 止损单已全部挂完, 空仓止损: 2~{}, 多仓止损: -2~-{}", shortTime, longTime);
            log.info("[Gate] 止损止盈单已全部挂完, 空仓止损:2~{}, 多仓止损:-2~-{}", shortTime, longTime);

            state = StrategyState.ACTIVE;
        }
@@ -1200,8 +1293,9 @@
    private void handleLongStopLossTriggered(GridElement gridElement) {
        gridElement.setLongStopLossOrderId(null);

        accumulatedLongLossCount++;
        int gridId = gridElement.getId();
        log.info("[Gate] 多仓止损触发 gridId:{}, 开始追单", gridId);
        log.info("[Gate] 多仓止损触发 gridId:{}, 止损次数:{}, 开始追单", gridId, accumulatedLongLossCount);
        int newEntryGridId = gridId + 1;

        GridElement newEntryGrid = GridElement.findById(newEntryGridId);
@@ -1215,15 +1309,37 @@
        if (!newEntryGrid.isHasLongOrder()) {
            BigDecimal triggerPrice = newEntryGrid.getGridPrice();

            // 累计止损张数 + 当前止损量作为追单size，不再依赖positionSize（避免WS竞态）
            accumulatedLongLossCount += Integer.parseInt(config.getQuantity());
            String size = String.valueOf(accumulatedLongLossCount + Integer.parseInt(config.getQuantity()));
            log.info("[Gate] 多仓止损触发 gridId:{}, 在gridId:{}挂{}基础张多单",
                    gridId, newEntryGridId, size);

            newEntryGrid.getLongTraderParam().setQuantity(size);
            placeEntryOrderWithPreFlag(newEntryGrid, true, triggerPrice,
                    FuturesPriceTrigger.RuleEnum.NUMBER_1, size);
            // 止损触发后持仓在减少，取REST和WS缓存中较小值更准确
            int posSize = Math.min(queryPositionSize(Position.ModeEnum.DUAL_LONG), longPositionSize.intValue());
            int maxPos = config.getMaxPositionSize();
            // 止损阶梯：止损次数≤阈值时挂单量=单笔数量，超过后恢复默认逻辑(quantity*2)
            int targetAmount;
            if (config.getStopLossCount() > 0 && accumulatedLongLossCount <= config.getStopLossCount()) {
                targetAmount = Integer.parseInt(config.getQuantity());
            } else {
                targetAmount = Integer.parseInt(config.getQuantity()) * 2; // quantity + 本次止损量
            }
            int addSize;
            if (maxPos > 0) {
                int remainingRoom = maxPos - posSize;
                if (remainingRoom <= 0) {
                    log.warn("[Gate] 多仓止损触发 gridId:{}, 当前持仓{}/{}已达上限，跳过追单",
                            gridId, posSize, maxPos);
                    addSize = 0;
                } else {
                    addSize = Math.min(remainingRoom, targetAmount);
                }
            } else {
                addSize = targetAmount;
            }
            if (addSize > 0) {
                String size = String.valueOf(addSize);
                log.info("[Gate] 多仓止损触发 gridId:{}, 止损次数:{}, 在gridId:{}补{}张多单(当前{}/上限{})",
                        gridId, accumulatedLongLossCount, newEntryGridId, size, posSize, maxPos > 0 ? maxPos : "无");
                newEntryGrid.getLongTraderParam().setQuantity(size);
                placeEntryOrderWithPreFlag(newEntryGrid, true, triggerPrice,
                        FuturesPriceTrigger.RuleEnum.NUMBER_1, size);
            }
        }else{
            log.warn("[Gate] 多仓止损触发 gridId:{}, 目标gridId:{}已有挂单，跳过重复下单", gridId, newEntryGridId);
        }
@@ -1259,8 +1375,9 @@
    private void handleShortStopLossTriggered(GridElement gridElement) {
        gridElement.setShortStopLossOrderId(null);

        accumulatedShortLossCount++;
        int gridId = gridElement.getId();
        log.info("[Gate] 空仓止损触发 gridId:{}, 开始追单", gridId);
        log.info("[Gate] 空仓止损触发 gridId:{}, 止损次数:{}, 开始追单", gridId, accumulatedShortLossCount);
        int newEntryGridId = gridId - 1;

        GridElement newEntryGrid = GridElement.findById(newEntryGridId);
@@ -1274,14 +1391,37 @@
        if (!newEntryGrid.isHasShortOrder()) {
            BigDecimal triggerPrice = newEntryGrid.getGridPrice();

            // 累计止损张数 + 当前止损量作为追单size，不再依赖positionSize（避免WS竞态）
            accumulatedShortLossCount += Integer.parseInt(config.getQuantity());
            String size = String.valueOf(accumulatedShortLossCount + Integer.parseInt(config.getQuantity()));
            log.info("[Gate] 空仓止损触发 gridId:{}, 在gridId:{}挂{}基础张空单",
                    gridId, newEntryGridId, size);
            newEntryGrid.getShortTraderParam().setQuantity(size);
            placeEntryOrderWithPreFlag(newEntryGrid, false, triggerPrice,
                    FuturesPriceTrigger.RuleEnum.NUMBER_2, negate(size));
            // 止损触发后持仓在减少，取REST和WS缓存中较小值更准确
            int posSize = Math.min(queryPositionSize(Position.ModeEnum.DUAL_SHORT), shortPositionSize.intValue());
            int maxPos = config.getMaxPositionSize();
            // 止损阶梯：止损次数≤阈值时挂单量=单笔数量，超过后恢复默认逻辑(quantity*2)
            int targetAmount;
            if (config.getStopLossCount() > 0 && accumulatedShortLossCount <= config.getStopLossCount()) {
                targetAmount = Integer.parseInt(config.getQuantity());
            } else {
                targetAmount = Integer.parseInt(config.getQuantity()) * 2; // quantity + 本次止损量
            }
            int addSize;
            if (maxPos > 0) {
                int remainingRoom = maxPos - posSize;
                if (remainingRoom <= 0) {
                    log.warn("[Gate] 空仓止损触发 gridId:{}, 当前持仓{}/{}已达上限，跳过追单",
                            gridId, posSize, maxPos);
                    addSize = 0;
                } else {
                    addSize = Math.min(remainingRoom, targetAmount);
                }
            } else {
                addSize = targetAmount;
            }
            if (addSize > 0) {
                String size = String.valueOf(addSize);
                log.info("[Gate] 空仓止损触发 gridId:{}, 止损次数:{}, 在gridId:{}补{}张空单(当前{}/上限{})",
                        gridId, accumulatedShortLossCount, newEntryGridId, size, posSize, maxPos > 0 ? maxPos : "无");
                newEntryGrid.getShortTraderParam().setQuantity(size);
                placeEntryOrderWithPreFlag(newEntryGrid, false, triggerPrice,
                        FuturesPriceTrigger.RuleEnum.NUMBER_2, negate(size));
            }
        }else{
            log.warn("[Gate] 空仓止损触发 gridId:{}, 目标gridId:{}已有挂单，跳过重复下单", gridId, newEntryGridId);
        }
@@ -1498,6 +1638,29 @@
        log.info("[Gate] 已提交取消所有空仓止盈+止损");
    }

    /**
     * 首次挂单成交时，取消初始化阶段挂的所有止盈单（多+空），止损单保留不动。
     */
    private void cancelAllInitialTakeProfits() {


        GridElement tpElemLong = GridElement.findById(3);
        String longTpId = tpElemLong.getLongTakeProfitOrderId();
        if (longTpId != null) {
            longTakeProfitTraderIdParam(tpElemLong, null, false);
            executor.cancelConditionalOrder(longTpId, oid -> {});
        }

        GridElement tpElemShort = GridElement.findById(-3);
        String shortTpId = tpElemShort.getShortTakeProfitOrderId();
        if (shortTpId != null) {
            shortTakeProfitTraderIdParam(tpElemShort, null, false);
            executor.cancelConditionalOrder(shortTpId, oid -> {});
        }
        GridElement.refreshIndices();
        log.info("[Gate] 首次成交，取消所有初始化止盈单");
    }

    // ========== 止损追单 ==========

    private void extendLongStopLoss(int filledQty,int gridId) {
@@ -1508,33 +1671,96 @@
            }
        }

        int interval  = 1;
        if (furthestSlId == 0) {
            furthestSlId = gridId;
            interval = 2;
        }
        int stopLossCount = filledQty / Integer.parseInt(config.getQuantity());
        log.info("[Gate] 多仓追挂止损, 当前最远止损gridId:{}, 成交{}张, 追加{}个止损单", furthestSlId, filledQty, stopLossCount);
        for (int i = 0; i < stopLossCount; i++) {
            int newSlId = furthestSlId - i - interval;
//        int interval  = 1;
//        if (furthestSlId == 0) {
//            furthestSlId = gridId;
//            interval = 2;
//        }
//        int stopLossCount = filledQty / Integer.parseInt(config.getQuantity());
//        log.info("[Gate] 多仓追挂止损, 当前最远止损gridId:{}, 成交{}张, 追加{}个止损单", furthestSlId, filledQty, stopLossCount);
//        for (int i = 0; i < stopLossCount; i++) {
//            int newSlId = furthestSlId - i - interval;
//            GridElement elem = GridElement.findById(newSlId);
//            if (elem == null) {
//                continue;
//            }
//            BigDecimal triggerPrice = elem.getGridPrice();
//            int finalSlId = newSlId;
//            executor.placeTakeProfit(
//                    triggerPrice,
//                    FuturesPriceTrigger.RuleEnum.NUMBER_2,
//                    ORDER_TYPE_CLOSE_LONG,
//                    negate(config.getQuantity()),
//                    profitId -> {
//                        elem.setLongStopLossOrderId(profitId);
//                        GridElement.refreshIndices();
//                        log.info("[Gate] 多仓止损追加, gridId:{}, 触发价:{}, stopLossId:{}", finalSlId, triggerPrice, profitId);
//                    }
//            );
//        }

        int parseInt = Integer.parseInt(config.getQuantity());
        int total = filledQty - parseInt;
        if (total > parseInt) {
            String firstNum = String.valueOf(total);
            log.info("[Gate] 多仓追挂止损, 当前最远止损gridId:{}, 成交{}张, 追加{}个止损单", furthestSlId, filledQty, 2);
            int newSlId = gridId - 2;
            GridElement elem = GridElement.findById(newSlId);
            if (elem == null) {
                continue;
            if (elem != null) {
                BigDecimal triggerPrice = elem.getGridPrice();
                int finalSlId = newSlId;
                executor.placeTakeProfit(
                        triggerPrice,
                        FuturesPriceTrigger.RuleEnum.NUMBER_2,
                        ORDER_TYPE_CLOSE_LONG,
                        negate(firstNum),
                        profitId -> {
                            elem.setLongStopLossOrderId(profitId);
                            GridElement.refreshIndices();
                            log.info("[Gate] 多仓止损追加, gridId:{}, 触发价:{}, 数量:{}, stopLossId:{}", finalSlId, triggerPrice, firstNum, profitId);
                        }
                );
            }
            BigDecimal triggerPrice = elem.getGridPrice();
            int finalSlId = newSlId;
            executor.placeTakeProfit(
                    triggerPrice,
                    FuturesPriceTrigger.RuleEnum.NUMBER_2,
                    ORDER_TYPE_CLOSE_LONG,
                    negate(config.getQuantity()),
                    profitId -> {
                        elem.setLongStopLossOrderId(profitId);
                        GridElement.refreshIndices();
                        log.info("[Gate] 多仓止损追加, gridId:{}, 触发价:{}, stopLossId:{}", finalSlId, triggerPrice, profitId);
                    }
            );
            int newSecendSlId = gridId - 3;
            GridElement elemSecend = GridElement.findById(newSecendSlId);
            if (elemSecend != null) {
                BigDecimal triggerPrice = elemSecend.getGridPrice();
                int finalSlId = newSecendSlId;
                executor.placeTakeProfit(
                        triggerPrice,
                        FuturesPriceTrigger.RuleEnum.NUMBER_2,
                        ORDER_TYPE_CLOSE_LONG,
                        negate(config.getQuantity()),
                        profitId -> {
                            elemSecend.setLongStopLossOrderId(profitId);
                            GridElement.refreshIndices();
                            log.info("[Gate] 多仓止损追加, gridId:{}, 触发价:{}, 数量:{}, stopLossId:{}", finalSlId, triggerPrice, config.getQuantity(), profitId);
                        }
                );
            }
        }
        if (total == parseInt){
            String firstNum = config.getQuantity();
            log.info("[Gate] 多仓追挂止损, 当前最远止损gridId:{}, 成交{}张, 追加{}个止损单", furthestSlId, filledQty, 1);
            int newSlId = gridId - 2;
            GridElement elem = GridElement.findById(newSlId);
            if (elem != null) {
                BigDecimal triggerPrice = elem.getGridPrice();
                int finalSlId = newSlId;
                executor.placeTakeProfit(
                        triggerPrice,
                        FuturesPriceTrigger.RuleEnum.NUMBER_2,
                        ORDER_TYPE_CLOSE_LONG,
                        negate(firstNum),
                        profitId -> {
                            elem.setLongStopLossOrderId(profitId);
                            GridElement.refreshIndices();
                            log.info("[Gate] 多仓止损追加, gridId:{}, 触发价:{}, 数量:{}, stopLossId:{}", finalSlId, triggerPrice, firstNum, profitId);
                        }
                );
            }
        }

    }

    private void extendShortStopLoss(int filledQty, int gridId) {
@@ -1545,33 +1771,96 @@
            }
        }

        int interval  = 1;
        if (furthestSlId == 0) {
            furthestSlId = gridId;
            interval = 2;
        }
        int stopLossCount = filledQty / Integer.parseInt(config.getQuantity());
        log.info("[Gate] 空仓追挂止损, 当前最远止损gridId:{}, 成交{}张, 追加{}个止损单", furthestSlId, filledQty, stopLossCount);
        for (int i = 0; i < stopLossCount; i++) {
            int newSlId = furthestSlId + i + interval;
//        int interval  = 1;
//        if (furthestSlId == 0) {
//            furthestSlId = gridId;
//            interval = 2;
//        }
//        int stopLossCount = filledQty / Integer.parseInt(config.getQuantity());
//        log.info("[Gate] 空仓追挂止损, 当前最远止损gridId:{}, 成交{}张, 追加{}个止损单", furthestSlId, filledQty, stopLossCount);
//        for (int i = 0; i < stopLossCount; i++) {
//            int newSlId = furthestSlId + i + interval;
//            GridElement elem = GridElement.findById(newSlId);
//            if (elem == null) {
//                continue;
//            }
//            BigDecimal triggerPrice = elem.getGridPrice();
//            int finalSlId = newSlId;
//            executor.placeTakeProfit(
//                    triggerPrice,
//                    FuturesPriceTrigger.RuleEnum.NUMBER_1,
//                    ORDER_TYPE_CLOSE_SHORT,
//                    config.getQuantity(),
//                    profitId -> {
//                        elem.setShortStopLossOrderId(profitId);
//                        GridElement.refreshIndices();
//                        log.info("[Gate] 空仓止损追加, gridId:{}, 触发价:{}, stopLossId:{}", finalSlId, triggerPrice, profitId);
//                    }
//            );
//        }

        int parseInt = Integer.parseInt(config.getQuantity());
        int total = filledQty - parseInt;
        if (total > parseInt) {
            String firstNum = String.valueOf(total);
            log.info("[Gate] 空仓追挂止损, 当前最远止损gridId:{}, 成交{}张, 追加{}个止损单", furthestSlId, filledQty, 2);
            int newSlId = gridId + 2;
            GridElement elem = GridElement.findById(newSlId);
            if (elem == null) {
                continue;
            if (elem != null) {
                BigDecimal triggerPrice = elem.getGridPrice();
                int finalSlId = newSlId;
                executor.placeTakeProfit(
                        triggerPrice,
                        FuturesPriceTrigger.RuleEnum.NUMBER_1,
                        ORDER_TYPE_CLOSE_SHORT,
                        firstNum,
                        profitId -> {
                            elem.setShortStopLossOrderId(profitId);
                            GridElement.refreshIndices();
                            log.info("[Gate] 空仓止损追加, gridId:{}, 触发价:{}, 数量:{}, stopLossId:{}", finalSlId, triggerPrice, firstNum, profitId);
                        }
                );
            }
            BigDecimal triggerPrice = elem.getGridPrice();
            int finalSlId = newSlId;
            executor.placeTakeProfit(
                    triggerPrice,
                    FuturesPriceTrigger.RuleEnum.NUMBER_1,
                    ORDER_TYPE_CLOSE_SHORT,
                    config.getQuantity(),
                    profitId -> {
                        elem.setShortStopLossOrderId(profitId);
                        GridElement.refreshIndices();
                        log.info("[Gate] 空仓止损追加, gridId:{}, 触发价:{}, stopLossId:{}", finalSlId, triggerPrice, profitId);
                    }
            );
            int newSecendSlId = gridId + 2;
            GridElement elemSecend = GridElement.findById(newSecendSlId);
            if (elemSecend != null) {
                BigDecimal triggerPrice = elemSecend.getGridPrice();
                int finalSlId = newSecendSlId;
                executor.placeTakeProfit(
                        triggerPrice,
                        FuturesPriceTrigger.RuleEnum.NUMBER_1,
                        ORDER_TYPE_CLOSE_SHORT,
                        config.getQuantity(),
                        profitId -> {
                            elemSecend.setShortStopLossOrderId(profitId);
                            GridElement.refreshIndices();
                            log.info("[Gate] 空仓止损追加, gridId:{}, 触发价:{}, 数量:{}, stopLossId:{}", finalSlId, triggerPrice, config.getQuantity(), profitId);
                        }
                );
            }
        }
        if (total == parseInt) {
            String firstNum = config.getQuantity();
            log.info("[Gate] 空仓追挂止损, 当前最远止损gridId:{}, 成交{}张, 追加{}个止损单", furthestSlId, filledQty, 1);
            int newSlId = gridId + 2;
            GridElement elem = GridElement.findById(newSlId);
            if (elem != null) {
                BigDecimal triggerPrice = elem.getGridPrice();
                int finalSlId = newSlId;
                executor.placeTakeProfit(
                        triggerPrice,
                        FuturesPriceTrigger.RuleEnum.NUMBER_1,
                        ORDER_TYPE_CLOSE_SHORT,
                        firstNum,
                        profitId -> {
                            elem.setShortStopLossOrderId(profitId);
                            GridElement.refreshIndices();
                            log.info("[Gate] 空仓止损追加, gridId:{}, 触发价:{}, 数量:{}, stopLossId:{}", finalSlId, triggerPrice, firstNum, profitId);
                        }
                );
            }
        }

    }

    // ---- 工具 ----