Administrator
6 days ago bccc54b8b005e424ac9937ac421f2be4a52910e1
feat(okxWs): 添加批量订单WebSocket支持

- 新增BATCH_ORDERSWS_CHANNEL常量用于批量订单频道
- 修改订单事件处理逻辑使用批量订单频道替代原订单频道
- 更新WebSocket连接ID生成和JSON对象构建以支持批量订单
- 调整订单发送逻辑适配新的批量订单频道配置
1 files modified
7 ■■■■■ changed files
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/TradeOrderWs.java 7 ●●●●● patch | view | raw | blame | history
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) {
@@ -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);
    }