From 7e213a5e5a233ba19eaa148cc65c9f3cfa96986e Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Tue, 09 Dec 2025 14:45:57 +0800
Subject: [PATCH] feat(okx): 优化持仓策略与交易逻辑
---
src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxQuantWebSocketClient.java | 10 +++++-----
1 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxQuantWebSocketClient.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxQuantWebSocketClient.java
index 6a0183f..5dd4c16 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxQuantWebSocketClient.java
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxQuantWebSocketClient.java
@@ -263,10 +263,10 @@
} else if (PositionsWs.POSITIONSWS_CHANNEL.equals(channel)) {
PositionsWs.handleEvent(response, redisUtils);
- String avgPxKey = PositionsWs.POSITIONSWS_CHANNEL + ":" + CoinEnums.HE_YUE.getCode() + ":avgPx";
- String avgPx = (String) redisUtils.get(avgPxKey);
- if (StrUtil.isBlank(avgPx)) {
- log.error("未获取到持仓均价");
+ String posKey = PositionsWs.POSITIONSWS_CHANNEL + ":" + CoinEnums.HE_YUE.getCode() + ":pos";
+ String pos = (String) redisUtils.get(posKey);
+ if (StrUtil.isBlank(pos)) {
+ log.error("未获取到持仓数量");
TradeOrderWs.orderEvent(webSocketClient, redisUtils, OrderParamEnums.INIT.getValue());
return;
}
@@ -285,7 +285,7 @@
}
String side = caoZuoService.caoZuo();
- if (StrUtil.isNotBlank(avgPx)) {
+ if (StrUtil.isNotBlank(pos)) {
TradeOrderWs.orderEvent(webSocketClient, redisUtils, side);
}
} else if (BalanceAndPositionWs.CHANNEL_NAME.equals(channel)) {
--
Gitblit v1.9.1