From 2ff53e439955a6c62c6adc5e2acf6e67bd704cb7 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Wed, 10 Dec 2025 13:49:15 +0800
Subject: [PATCH] feat(okx): 添加 WebSocket 处理日志记录
---
src/main/java/com/xcong/excoin/modules/okxNewPrice/celue/CaoZuoServiceImpl.java | 13 +++++++------
1 files changed, 7 insertions(+), 6 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 eca672a..d1cc961 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
@@ -53,12 +53,7 @@
*/
@Override
public String caoZuo() {
- log.info("开始执行操作......");
- String pos = (String) redisUtils.get(positionsPosKey);
- if (StrUtil.isBlank(pos) || BigDecimal.ZERO.compareTo( new BigDecimal(pos)) <= 0) {
- log.error("未获取到持仓数量");
- return OrderParamEnums.INIT.getValue();
- }
+ log.info("开始执行操作CaoZuoServiceImpl......");
// 获取合约执行操作状态
String state = (String) redisUtils.get(instrumentsStateKey);
@@ -79,6 +74,12 @@
return OrderParamEnums.HOLDING.getValue();
}
+ String pos = (String) redisUtils.get(positionsPosKey);
+ if (StrUtil.isBlank(pos) || BigDecimal.ZERO.compareTo( new BigDecimal(pos)) <= 0) {
+ log.error("未获取到持仓数量");
+ return OrderParamEnums.INIT.getValue();
+ }
+
String uplStr = (String) redisUtils.get(positionsUplKey);
if (StrUtil.isBlank(uplStr)){
return OrderParamEnums.INIT.getValue();
--
Gitblit v1.9.1