feat(okxWs): 添加批量订单WebSocket支持

Administrator

6 days ago bccc54b8b005e424ac9937ac421f2be4a52910e1

 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);
    }