From 9050143664ca52eeef9e42365159de75977e17cf Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Sat, 13 Dec 2025 22:33:26 +0800
Subject: [PATCH] refactor(okxNewPrice): 调整订单价格存储逻辑

---
 src/main/java/com/xcong/excoin/modules/okxNewPrice/celue/CaoZuoServiceImpl.java |    4 +++-
 1 files changed, 3 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 3d35ad0..bf8443c 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
@@ -128,7 +128,6 @@
             // 处理订单价格在队列中的情况
             String orderPrice = OrderInfoWs.ORDERINFOWSMAP.get("orderPrice");
             handleOrderPriceInQueues(orderPrice, queueKaiCang, queuePingCang);
-            WsMapBuild.saveStringToMap(OrderInfoWs.ORDERINFOWSMAP, "orderPrice", String.valueOf(markPx));
             // 判断是加仓还是减仓
             if (avgPx.compareTo(markPx) > 0) {
                 log.info("开始加仓...");
@@ -140,6 +139,7 @@
                 DescBigDecimal kaiCang = queueKaiCang.peek();
                 if (kaiCang != null && markPx.compareTo(kaiCang.getValue()) <= 0 && avgPx.compareTo(kaiCang.getValue()) >= 0) {
                     log.info("开始加仓...开仓队列价格大于当前价格{}>{}", kaiCang.getValue(), markPx);
+                    WsMapBuild.saveStringToMap(OrderInfoWs.ORDERINFOWSMAP, "orderPrice", String.valueOf(markPx));
                     boolean buyCntTimeFlag = buyCntTimeEvent(avgPx, markPx);
                     if (buyCntTimeFlag){
                         log.info("加仓参数准备成功......");
@@ -173,6 +173,7 @@
                         BigDecimal realizedPnlValueZheng = realizedPnlValue.multiply(new BigDecimal("-1"));
                         if (uplValue.compareTo(realizedPnlValue) > 0 && uplValue.compareTo(imrValue.add(realizedPnlValueZheng))  >= 0) {
                             log.info("当前未实现盈亏:{}大于预计收益>{},赚钱咯", uplValue, imrValue);
+                            WsMapBuild.saveStringToMap(OrderInfoWs.ORDERINFOWSMAP, "orderPrice", String.valueOf(markPx));
                             return OrderParamEnums.SELL.getValue();
                         }else{
                             log.info("当前未实现盈亏:{}没有大于预计收益>{},钱在路上了", uplValue, imrValue);
@@ -180,6 +181,7 @@
                         }
                     }else {
                         if (uplValue.compareTo(imrValue)  >= 0) {
+                            WsMapBuild.saveStringToMap(OrderInfoWs.ORDERINFOWSMAP, "orderPrice", String.valueOf(markPx));
                             log.info("当前未实现盈亏:{}大于预计收益>{},赚钱咯", uplValue, imrValue);
                             return OrderParamEnums.SELL.getValue();
                         }else{

--
Gitblit v1.9.1