From 69feff48c5b26b01d3d1849d476bc8cd6071b4cd Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Wed, 10 Dec 2025 17:33:34 +0800
Subject: [PATCH] feat(okx): 调整交易订单事件处理逻辑

---
 src/main/java/com/xcong/excoin/modules/okxNewPrice/celue/CaoZuoServiceImpl.java |    5 ++++-
 1 files changed, 4 insertions(+), 1 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 0c34edd..77858e1 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
@@ -150,6 +150,7 @@
                     log.info("加仓过程中发现持仓过小 :{}",isAddCang);
                     if (isAddCang){
                         log.info("触发加仓......,持仓过小");
+                        redisUtils.set(positionsOrderPriceKey, String.valueOf(markPx), 0);
                         return OrderParamEnums.BUY.getValue();
                     }
                     log.info("未触发加仓......,等待");
@@ -184,6 +185,7 @@
                                 log.info("减仓过程中发现持仓过小 :{}",isAddCang);
                                 if (isAddCang){
                                     log.info("触发加仓......,持仓过小");
+                                    redisUtils.set(positionsOrderPriceKey, String.valueOf(markPx), 0);
                                     return OrderParamEnums.BUY.getValue();
                                 }
                                 log.info("当前未实现盈亏:{}没有大于预计收益>{},钱在路上了", uplValue, imrValue);
@@ -202,6 +204,7 @@
                                 log.info("减仓过程中发现持仓过小 :{}",isAddCang);
                                 if (isAddCang){
                                     log.info("触发加仓......,持仓过小");
+                                    redisUtils.set(positionsOrderPriceKey, String.valueOf(markPx), 0);
                                     return OrderParamEnums.BUY.getValue();
                                 }
                                 log.info("当前未实现盈亏:{}没有大于预计收益>{},钱在路上了", uplValue, imrValue);
@@ -228,7 +231,7 @@
 
     private boolean doAddCang() {
         String imr = (String) redisUtils.get(positionsImrKey);
-        BigDecimal imrValue = new BigDecimal(imr).multiply(new BigDecimal(OrderParamEnums.PING_CANG_SHOUYI.getValue()));
+        BigDecimal imrValue = new BigDecimal(StrUtil.isBlank(imr) ? "0" : imr);
         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