From 5ad0a0e614c3097be78589bda57e82ff7ec546e2 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Fri, 12 Dec 2025 14:27:25 +0800
Subject: [PATCH] feat(okx): 处理下单推送结果并更新持仓数据

---
 src/main/java/com/xcong/excoin/modules/okxNewPrice/celue/CaoZuoServiceImpl.java |   13 +++++++++----
 1 files changed, 9 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 af63cd9..a85f4ae 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
@@ -105,14 +105,19 @@
             }
         }
 
-        BigDecimal ordFrozImr = ObjectUtil.isEmpty(PositionsWs.POSITIONSWSMAP.get("imr")) ? BigDecimal.ZERO : PositionsWs.POSITIONSWSMAP.get("imr");
-        if (BigDecimal.ZERO.compareTo( ordFrozImr) >= 0) {
-            log.error("占用保证金为零,进行初始化订单");
+        if (PositionsWs.POSITIONSWSMAP.get("pos") == null){
+            log.error("没有获取到持仓数量,等待初始化......");
+            return null;
+        }
+        BigDecimal pos = PositionsWs.POSITIONSWSMAP.get("pos");
+        if (BigDecimal.ZERO.compareTo( pos) >= 0) {
+            log.error("持仓数量为零,进行初始化订单");
             WsMapBuild.saveStringToMap(InstrumentsWs.INSTRUMENTSWSMAP, CoinEnums.STATE.name(), OrderParamEnums.STATE_4.getValue());
             return OrderParamEnums.INIT.getValue();
         }
         // 判断是否保证金超标
-        BigDecimal totalOrderUsdt = WsMapBuild.parseBigDecimalSafe(InstrumentsWs.INSTRUMENTSWSMAP.get(CoinEnums.TOTAL_ORDER_USDT.name()));
+        BigDecimal ordFrozImr = PositionsWs.POSITIONSWSMAP.get("imr");
+        BigDecimal totalOrderUsdt = WsMapBuild.parseBigDecimalSafe(AccountWs.ACCOUNTWSMAP.get(CoinEnums.TOTAL_ORDER_USDT.name()));
         if (ordFrozImr.compareTo(totalOrderUsdt) >= 0){
             log.error("已满仓......");
             return OrderParamEnums.HOLDING.getValue();

--
Gitblit v1.9.1