From dd57fe4d1c954f6d451dc74c479984d1ac69f67e Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Fri, 12 Dec 2025 15:31:24 +0800
Subject: [PATCH] feat(newPrice): 添加对永续合约持仓量订阅的支持
---
src/main/java/com/xcong/excoin/modules/newPrice/OkxNewPriceWebSocketClient.java | 6 +++++-
1 files changed, 5 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/newPrice/OkxNewPriceWebSocketClient.java b/src/main/java/com/xcong/excoin/modules/newPrice/OkxNewPriceWebSocketClient.java
index 5226806..012cdca 100644
--- a/src/main/java/com/xcong/excoin/modules/newPrice/OkxNewPriceWebSocketClient.java
+++ b/src/main/java/com/xcong/excoin/modules/newPrice/OkxNewPriceWebSocketClient.java
@@ -48,6 +48,10 @@
private static final String[] INST_IDS = {
"BTC-USDT", "ETH-USDT", "XRP-USDT", "LTC-USDT", "BCH-USDT", "ETC-USDT"
};
+ //BTC-USDT-SWAP
+ private static final String[] INST_IDS_INTEREST = {
+ "BTC-USDT-SWAP", "ETH-USDT-SWAP", "XRP-USDT-SWAP", "LTC-USDT-SWAP", "BCH-USDT-SWAP", "ETC-USDT-SWAP"
+ };
// 心跳超时时间(秒)，小于30秒
private static final int HEARTBEAT_TIMEOUT = 10;
@@ -189,7 +193,7 @@
subscribeMsg.put("op", "subscribe");
JSONArray argsArray = new JSONArray();
- for (String instId : INST_IDS) {
+ for (String instId : INST_IDS_INTEREST) {
JSONObject arg = new JSONObject();
arg.put("channel", CHANNEL_OPEN_INTEREST);
arg.put("instId", instId);
--
Gitblit v1.9.1