From 8b91d6757e37ee94187077e712552888ccd22099 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Sat, 13 Dec 2025 15:50:07 +0800
Subject: [PATCH] feat(okxNewPrice): 实现动态开仓张数计算逻辑

---
 src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/TradeOrderWs.java |    8 ++++++--
 1 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/TradeOrderWs.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/TradeOrderWs.java
index 5151fd4..2ae3e93 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/TradeOrderWs.java
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/TradeOrderWs.java
@@ -45,10 +45,14 @@
         }else if (OrderParamEnums.INIT.getValue().equals(side)){
             log.info("当前状态为初始化");
             side = OrderParamEnums.BUY.getValue();
-            buyCnt = InstrumentsWs.INSTRUMENTSWSMAP.get(CoinEnums.BUY_CNT.name());
+            String buyCntTime = OrderInfoWs.ORDERINFOWSMAP.get("buyCntTime");
+            String buyCntStr = InstrumentsWs.INSTRUMENTSWSMAP.get(CoinEnums.BUY_CNT.name());
+            buyCnt = String.valueOf(new BigDecimal(buyCntTime).multiply(new BigDecimal(buyCntStr)));
         }else if (OrderParamEnums.BUY.getValue().equals(side)){
             log.info("当前状态为加仓");
-            buyCnt = InstrumentsWs.INSTRUMENTSWSMAP.get(CoinEnums.BUY_CNT.name());
+            String buyCntTime = OrderInfoWs.ORDERINFOWSMAP.get("buyCntTime");
+            String buyCntStr = InstrumentsWs.INSTRUMENTSWSMAP.get(CoinEnums.BUY_CNT.name());
+            buyCnt = String.valueOf(new BigDecimal(buyCntTime).multiply(new BigDecimal(buyCntStr)));
         }else if (OrderParamEnums.SELL.getValue().equals(side)){
             log.info("当前状态为减仓");
             buyCnt = String.valueOf(PositionsWs.POSITIONSWSMAP.get("pos"));

--
Gitblit v1.9.1