From 917000befa702ed94fa12c4bf7395b940080eb71 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Tue, 02 Jun 2026 11:35:23 +0800
Subject: [PATCH] fix(okx): 修复账户余额获取和API请求处理问题
---
src/main/java/com/xcong/excoin/modules/okxNewPrice/gridWs/OkxPositionsChannelHandler.java | 6 +++++-
1 files changed, 5 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/gridWs/OkxPositionsChannelHandler.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/gridWs/OkxPositionsChannelHandler.java
index 5749544..51ae155 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/gridWs/OkxPositionsChannelHandler.java
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/gridWs/OkxPositionsChannelHandler.java
@@ -20,10 +20,12 @@
private static final String CHANNEL_NAME = "positions";
private final String instId;
+ private final String instFamily;
private final OkxGridTradeService gridTradeService;
public OkxPositionsChannelHandler(String instId, OkxGridTradeService gridTradeService) {
this.instId = instId;
+ this.instFamily = instId.contains("-") ? instId.substring(0, instId.lastIndexOf("-")) : instId;
this.gridTradeService = gridTradeService;
}
@@ -36,12 +38,13 @@
JSONObject arg = new JSONObject();
arg.put("channel", CHANNEL_NAME);
arg.put("instType", "SWAP");
+ arg.put("instFamily", instFamily);
msg.put("op", "subscribe");
JSONArray args = new JSONArray();
args.add(arg);
msg.put("args", args);
ws.send(msg.toJSONString());
- log.info("[OKX-WS] {} 订阅成功", CHANNEL_NAME);
+ log.info("[OKX-WS] {} 订阅成功, instFamily:{}", CHANNEL_NAME, instFamily);
}
@Override
@@ -50,6 +53,7 @@
JSONObject arg = new JSONObject();
arg.put("channel", CHANNEL_NAME);
arg.put("instType", "SWAP");
+ arg.put("instFamily", instFamily);
msg.put("op", "unsubscribe");
JSONArray args = new JSONArray();
args.add(arg);
--
Gitblit v1.9.1