From c8b80dc38d75e89aa44574659b154ddea2e8fce5 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Wed, 07 Jan 2026 14:16:32 +0800
Subject: [PATCH] refactor(okx): 重构WebSocket客户端实现止盈止损逻辑
---
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/LoginWs.java | 14 ++++++++------
1 files changed, 8 insertions(+), 6 deletions(-)
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..eb3e416 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
@@ -2,8 +2,8 @@
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
-import com.xcong.excoin.modules.okxNewPrice.okxpi.config.ExchangeInfoEnum;
-import com.xcong.excoin.modules.okxNewPrice.okxpi.config.utils.SignUtils;
+import com.xcong.excoin.modules.okxNewPrice.okxWs.enums.ExchangeInfoEnum;
+import com.xcong.excoin.modules.okxNewPrice.utils.SignUtils;
import com.xcong.excoin.modules.okxNewPrice.utils.WsParamBuild;
import lombok.extern.slf4j.Slf4j;
import org.java_websocket.client.WebSocketClient;
@@ -13,16 +13,18 @@
*/
@Slf4j
public class LoginWs {
- public static void websocketLogin(WebSocketClient webSocketClient) {
+ public static void websocketLogin(WebSocketClient webSocketClient, ExchangeInfoEnum account) {
+
+// log.info("开始执行LoginWs......");
try {
JSONArray argsArray = new JSONArray();
JSONObject loginArgs = new JSONObject();
// 获取登录凭证信息（需要从配置或Redis中获取）
- String apiKey = ExchangeInfoEnum.OKX_UAT.getApiKey();
- String passphrase = ExchangeInfoEnum.OKX_UAT.getPassphrase();
+ String apiKey = account.getApiKey();
+ String passphrase = account.getPassphrase();
String timestamp = String.valueOf(System.currentTimeMillis() /1000);
- String sign = SignUtils.signWebsocket(timestamp, ExchangeInfoEnum.OKX_UAT.getSecretKey());
+ String sign = SignUtils.signWebsocket(timestamp, account.getSecretKey());
loginArgs.put("apiKey", apiKey);
loginArgs.put("passphrase", passphrase);
--
Gitblit v1.9.1