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 +++++++------
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/PositionsWs.java | 3 +++
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/InstrumentsWs.java | 1 +
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/LoginWs.java | 2 ++
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/OrderInfoWs.java | 2 ++
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/TradeOrderWs.java | 3 +++
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/AccountWs.java | 3 +++
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/BalanceAndPositionWs.java | 2 ++
8 files changed, 23 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();
diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/AccountWs.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/AccountWs.java
index 95021c4..478dd01 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/AccountWs.java
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/AccountWs.java
@@ -71,6 +71,9 @@
* @param redisUtils Redis 工具类实例，用于存储账户相关信息
*/
public static void handleEvent(JSONObject response, RedisUtils redisUtils) {
+
+
+ log.info("开始执行AccountWs......");
try {
JSONArray dataArray = response.getJSONArray(DATA_KEY);
if (dataArray == null || dataArray.isEmpty()) {
diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/BalanceAndPositionWs.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/BalanceAndPositionWs.java
index cd491d2..9667283 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/BalanceAndPositionWs.java
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/BalanceAndPositionWs.java
@@ -33,6 +33,8 @@
}
public static void handleEvent(JSONObject response) {
+
+ log.info("开始执行BalanceAndPositionWs......");
try {
JSONArray dataArray = response.getJSONArray("data");
if (dataArray == null || dataArray.isEmpty()) {
diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/InstrumentsWs.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/InstrumentsWs.java
index 58d4910..b0b6db3 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/InstrumentsWs.java
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/InstrumentsWs.java
@@ -14,6 +14,7 @@
public static final String INSTRUMENTSWS_CHANNEL = "instruments";
public static void handleEvent(RedisUtils redisUtils) {
+ log.info("开始执行InstrumentsWs......");
// 将账户数据保存到Redis中，设置过期时间为30分钟
try {
boolean setResult =
diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/LoginWs.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/LoginWs.java
index 6ef260d..db360ae 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/LoginWs.java
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/LoginWs.java
@@ -14,6 +14,8 @@
@Slf4j
public class LoginWs {
public static void websocketLogin(WebSocketClient webSocketClient) {
+
+ log.info("开始执行LoginWs......");
try {
JSONArray argsArray = new JSONArray();
diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/OrderInfoWs.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/OrderInfoWs.java
index e1efbd3..7feb78a 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/OrderInfoWs.java
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/OrderInfoWs.java
@@ -48,6 +48,8 @@
private static final String AVGPX_KEY = "avgPx";
private static final String STATE_KEY = "state";
public static void handleEvent(JSONObject response, RedisUtils redisUtils) {
+
+ log.info("开始执行OrderInfoWs......");
try {
JSONArray dataArray = response.getJSONArray(DATA_KEY);
if (dataArray == null || dataArray.isEmpty()) {
diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/PositionsWs.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/PositionsWs.java
index e18dcde..9379534 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/PositionsWs.java
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/PositionsWs.java
@@ -44,6 +44,9 @@
}
public static void handleEvent(JSONObject response, RedisUtils redisUtils) {
+
+
+ log.info("开始执行PositionsWs......");
try {
JSONArray dataArray = response.getJSONArray("data");
if (dataArray == null || dataArray.isEmpty()) {
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..f7ffced 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,8 @@
public static void orderEvent(WebSocketClient webSocketClient, RedisUtils redisUtils, String side) {
+ log.info("开始执行TradeOrderWs......");
+
String buyCnt = null;
String ctval = getRedisValue(redisUtils, InstrumentsWs.INSTRUMENTSWS_CHANNEL, ":ctVal");
String buyCntNormal = getRedisValue(redisUtils, PositionsWs.POSITIONSWS_CHANNEL, ":buyCnt");
@@ -39,6 +41,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