Administrator
2 days ago dd57fe4d1c954f6d451dc74c479984d1ac69f67e
feat(newPrice): 添加对永续合约持仓量订阅的支持

- 新增永续合约交易对列表 INST_IDS_INTEREST
- 修改订阅逻辑以使用永续合约交易对
- 保留原有现货交易对列表 INST_IDS 不变
- 更新 WebSocket 订阅参数以适配持仓量频道
- 确保心跳机制兼容新的订阅类型
1 files modified
6 ■■■■ changed files
src/main/java/com/xcong/excoin/modules/newPrice/OkxNewPriceWebSocketClient.java 6 ●●●● patch | view | raw | blame | history
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);