feat(okxNewPrice): 实现加仓逻辑以优化持仓管理

Administrator

2025-12-10 1fefaefc56960c2900f40084aab2d501c1c1eddf

feat(okxNewPrice): 实现加仓逻辑以优化持仓管理

- 在减仓过程中增加判断是否需要加仓的逻辑
- 新增 doAddCang 方法用于判断当前持仓是否过小
- 当未实现盈亏未达到预期收益时，根据条件触发加仓操作
- 提高资金利用率，避免因持仓过小导致的收益不足问题

 src/main/java/com/xcong/excoin/modules/okxNewPrice/celue/CaoZuoServiceImpl.java

@@ -172,6 +172,12 @@
                                redisUtils.set(positionsOrderPriceKey, String.valueOf(pingCang.getValue()), 0);
                                return OrderParamEnums.SELL.getValue();
                            }else{
                                //判断是否加仓（当前持仓过小，可以加仓）
                                boolean isAddCang = doAddCang(imrValue);
                                log.info("减仓过程中没有收获，发现是持仓过小 ：{}",isAddCang);
                                if (isAddCang){
                                    return OrderParamEnums.BUY.getValue();
                                }
                                log.info("当前未实现盈亏：{}没有大于预计收益>{}，钱在路上了", uplValue, imrValue);
                                redisUtils.set(positionsOrderPriceKey, String.valueOf(pingCang.getValue()), 0);
                                return OrderParamEnums.HOLDING.getValue();
@@ -183,6 +189,13 @@
                                redisUtils.set(positionsOrderPriceKey, String.valueOf(pingCang.getValue()), 0);
                                return OrderParamEnums.SELL.getValue();
                            }else{

                                //判断是否加仓（当前持仓过小，可以加仓）
                                boolean isAddCang = doAddCang(imrValue);
                                log.info("减仓过程中没有收获，发现是持仓过小 ：{}",isAddCang);
                                if (isAddCang){
                                    return OrderParamEnums.BUY.getValue();
                                }
                                log.info("当前未实现盈亏：{}没有大于预计收益>{}，钱在路上了", uplValue, imrValue);
                                redisUtils.set(positionsOrderPriceKey, String.valueOf(pingCang.getValue()), 0);
                                return OrderParamEnums.HOLDING.getValue();
@@ -205,6 +218,12 @@
        }
    }

    private boolean doAddCang(BigDecimal imrValue) {
        String everyTimeUsdt = (String) redisUtils.get(AccountWs.ACCOUNTWS_CHANNEL + ":" + CoinEnums.USDT.getCode() + ":everyTimeUsdt");
        BigDecimal everyTimeUsdtValue = new BigDecimal(everyTimeUsdt);
        return everyTimeUsdtValue.compareTo(imrValue) >= 0;
    }

    /**
     * 根据订单价格更新开仓和平仓队列的内容。
     * 若该价格不在对应队列中则加入；若已存在，则从队列中移除。