From 2e6cbd3ee1c2d7e1aa73f4392c79bfbfacbcb67d Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Mon, 15 Dec 2025 14:03:36 +0800
Subject: [PATCH] feat(okx): 支持多账号WebSocket连接管理

---
 src/main/java/com/xcong/excoin/modules/okxNewPrice/zhanghu/ApiMessageServiceImpl.java |   11 ++++++-----
 1 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/zhanghu/ApiMessageServiceImpl.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/zhanghu/ApiMessageServiceImpl.java
index 6402d0f..c8b8f0e 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/zhanghu/ApiMessageServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/zhanghu/ApiMessageServiceImpl.java
@@ -19,13 +19,14 @@
         quantApiMessage.setExchange(okx);
         quantApiMessage.setMemberId(1L);
 
-
-        quantApiMessage.setAccountType(ExchangeInfoEnum.OKX_UAT.isAccountType()? "true":"false");
+        // 根据传入的账号名称获取对应的账号信息
+        ExchangeInfoEnum account = ExchangeInfoEnum.valueOf(okx);
+        quantApiMessage.setAccountType(account.isAccountType()? "true":"false");
         quantApiMessage.setState(1);
         quantApiMessage.setIsTrade(1);
-        quantApiMessage.setASecretkey(ExchangeInfoEnum.OKX_UAT.getApiKey());
-        quantApiMessage.setBSecretkey(ExchangeInfoEnum.OKX_UAT.getSecretKey());
-        quantApiMessage.setPassPhrass(ExchangeInfoEnum.OKX_UAT.getPassphrase());
+        quantApiMessage.setASecretkey(account.getApiKey());
+        quantApiMessage.setBSecretkey(account.getSecretKey());
+        quantApiMessage.setPassPhrass(account.getPassphrase());
         return quantApiMessage;
     }
 

--
Gitblit v1.9.1