From de95a25027e24db8e752db2eddd919bf6c572d64 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Wed, 10 Dec 2025 14:35:50 +0800
Subject: [PATCH] fix(okxNewPrice): 修正持仓数量判断逻辑
---
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/TradeOrderWs.java | 7 +++++++
1 files changed, 7 insertions(+), 0 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 aa3610d..093ac5e 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
@@ -23,6 +23,12 @@
public static void orderEvent(WebSocketClient webSocketClient, RedisUtils redisUtils, String side) {
+ log.info("开始执行TradeOrderWs......");
+ if (StrUtil.isBlank( side)){
+ log.warn("止损了，下次再战...");
+ return;
+ }
+
String buyCnt = null;
String ctval = getRedisValue(redisUtils, InstrumentsWs.INSTRUMENTSWS_CHANNEL, ":ctVal");
String buyCntNormal = getRedisValue(redisUtils, PositionsWs.POSITIONSWS_CHANNEL, ":buyCnt");
@@ -39,6 +45,7 @@
buyCnt = ctval;
}
} else if (OrderParamEnums.OUT.getValue().equals(side)) {
+ log.info(OrderParamEnums.getNameByValue(OrderParamEnums.OUT.getValue()));
side = OrderParamEnums.SELL.getValue();
buyCnt = pos;
} else if (OrderParamEnums.BUY.getValue().equals(side)){
--
Gitblit v1.9.1