From db20bd0f93753b07d13021a1e4f798fe5620fe8a Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Mon, 15 Dec 2025 10:55:39 +0800
Subject: [PATCH] fix(okxNewPrice): 修正未实现盈亏比较逻辑,加入手续费计算

---
 src/main/java/com/xcong/excoin/modules/okxNewPrice/celue/CaoZuoServiceImpl.java |   12 ++++++++----
 1 files changed, 8 insertions(+), 4 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 5f7685c..320423e 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
@@ -186,12 +186,12 @@
                             return OrderParamEnums.HOLDING.getValue();
                         }
                     }else {
-                        if (uplValue.compareTo(imrValue)  >= 0) {
+                        if (uplValue.compareTo(imrValue.add(feeValue))  >= 0) {
                             WsMapBuild.saveStringToMap(OrderInfoWs.ORDERINFOWSMAP, "orderPrice", String.valueOf(markPx));
-                            log.info("当前未实现盈亏:{}大于预计收益>{},赚钱咯", uplValue, realizedPnlValue);
+                            log.info("当前未实现盈亏:{}大于预计收益>{},赚钱咯", uplValue, imrValue.add(feeValue));
                             return OrderParamEnums.SELL.getValue();
                         }else{
-                            log.info("当前未实现盈亏:{}没有大于预计收益>{},钱在路上了", uplValue, realizedPnlValue);
+                            log.info("当前未实现盈亏:{}没有大于预计收益>{},钱在路上了", uplValue, imrValue.add(feeValue));
                             return OrderParamEnums.HOLDING.getValue();
                         }
                     }
@@ -212,7 +212,11 @@
         //判断当前价格和开仓价格直接间隔除以间距,取整,获取的数量是否大于等于0,如果大于0,则下单基础张数*倍数
         String buyCntTime = InstrumentsWs.INSTRUMENTSWSMAP.get(CoinEnums.BUY_CNT_TIME.name());
         BigDecimal subtract = avgPx.subtract(markPx);
-        BigDecimal divide = subtract.divide(new BigDecimal(buyCntTime), 0, RoundingMode.DOWN).add(BigDecimal.ONE);
+        BigDecimal divide = subtract.divide(new BigDecimal(buyCntTime), 0, RoundingMode.DOWN);
+        if (divide.compareTo(BigDecimal.ZERO) <= 0){
+            log.warn("加仓次数间隔时间小于0,不加仓");
+            return false;
+        }
         return WsMapBuild.saveStringToMap(TradeOrderWs.TRADEORDERWSMAP, "buyCntTime",String.valueOf(divide));
     }
 

--
Gitblit v1.9.1