From 1fefaefc56960c2900f40084aab2d501c1c1eddf Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Wed, 10 Dec 2025 14:23:38 +0800
Subject: [PATCH] feat(okxNewPrice): 实现加仓逻辑以优化持仓管理
---
src/main/java/com/xcong/excoin/modules/okxNewPrice/celue/CaoZuoServiceImpl.java | 19 +++++++++++++++++++
1 files changed, 19 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/celue/CaoZuoServiceImpl.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/celue/CaoZuoServiceImpl.java
index a8cc452..ea2f2bb 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/celue/CaoZuoServiceImpl.java
+++ b/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;
+ }
+
/**
* 根据订单价格更新开仓和平仓队列的内容。
* 若该价格不在对应队列中则加入；若已存在，则从队列中移除。
--
Gitblit v1.9.1