From 7981067b68ee94b27d22dd4619c98acdddc3379b Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Mon, 15 Dec 2025 11:09:59 +0800
Subject: [PATCH] feat(okxNewPrice): 添加防止重复初始化的机制
---
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/AccountWs.java | 9 +++------
1 files changed, 3 insertions(+), 6 deletions(-)
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 61a303d..401ad3b 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
@@ -49,14 +49,14 @@
String connId = MallUtils.getOrderNum(ACCOUNTWS_CHANNEL);
JSONObject jsonObject = WsParamBuild.buildJsonObject(connId, option, argsArray);
webSocketClient.send(jsonObject.toJSONString());
- log.info("发送账户频道:{}", option);
+// log.info("发送账户频道:{}", option);
} catch (Exception e) {
log.error("订阅账户频道构建失败", e);
}
}
public static void initEvent(JSONObject response) {
- log.info("订阅成功: {}", response.getJSONObject("arg"));
+// log.info("订阅成功: {}", response.getJSONObject("arg"));
JSONObject arg = response.getJSONObject("arg");
initParam(arg);
}
@@ -69,7 +69,7 @@
public static void handleEvent(JSONObject response) {
- log.info("开始执行AccountWs......{}",ACCOUNTWS_CHANNEL);
+// log.info("开始执行AccountWs......{}",ACCOUNTWS_CHANNEL);
try {
JSONArray dataArray = response.getJSONArray("data");
if (dataArray == null || dataArray.isEmpty()) {
@@ -88,9 +88,6 @@
for (int j = 0; j < detailsArray.size(); j++) {
JSONObject detail = detailsArray.getJSONObject(j);
-// log.info("账户详情: {}", JSONUtil.formatJsonStr(String.valueOf(detail)));
- //需要获取的参数
-
initParam(detail);
}
} catch (Exception innerEx) {
--
Gitblit v1.9.1