From bccc54b8b005e424ac9937ac421f2be4a52910e1 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Tue, 06 Jan 2026 17:28:50 +0800
Subject: [PATCH] feat(okxWs): 添加批量订单WebSocket支持
---
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/TradeOrderWs.java | 9 +++++----
1 files changed, 5 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/TradeOrderWs.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/TradeOrderWs.java
index e8454e4..389952d 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/TradeOrderWs.java
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/TradeOrderWs.java
@@ -34,6 +34,7 @@
}
public static final String ORDERWS_CHANNEL = "order";
+ public static final String BATCH_ORDERSWS_CHANNEL = "batch-orders";
public static void orderEvent(WebSocketClient webSocketClient, TradeRequestParam tradeRequestParam) {
@@ -148,7 +149,6 @@
}
JSONArray argsArray = new JSONArray();
- JSONObject args = new JSONObject();
for (TradeRequestParam tradeRequestParam : tradeRequestParams){
String accountName = tradeRequestParam.getAccountName();
String markPx = tradeRequestParam.getMarkPx();
@@ -197,6 +197,7 @@
* 平空：买入平空（side 填写 buy； posSide 填写 short ） 需要检验仓位通道是否准备就绪
*/
+ JSONObject args = new JSONObject();
args.put("instId", instId);
args.put("tdMode", tdMode);
args.put("clOrdId", clOrdId);
@@ -209,10 +210,10 @@
argsArray.add(args);
}
- String connId = WsParamBuild.getOrderNum(ORDERWS_CHANNEL);
- JSONObject jsonObject = WsParamBuild.buildJsonObject(connId, ORDERWS_CHANNEL, argsArray);
+ String connId = WsParamBuild.getOrderNum(BATCH_ORDERSWS_CHANNEL);
+ JSONObject jsonObject = WsParamBuild.buildJsonObject(connId, BATCH_ORDERSWS_CHANNEL, argsArray);
webSocketClient.send(jsonObject.toJSONString());
- log.info("发送止盈止损下单频道:{}",argsArray);
+ log.info("发送止盈止损批量下单频道:{}",argsArray);
}
--
Gitblit v1.9.1