fix(okxWs): 修正账户和持仓WebSocket参数配置
- 移除多余的注释代码块
- 恢复正确的参数设置逻辑
- 确保币种和合约参数正确传递
- 清理无效的额外参数配置
- 优化JSON参数构建流程
- 保持WebSocket连接ID生成一致性
| | |
| | | JSONArray argsArray = new JSONArray(); |
| | | JSONObject args = new JSONObject(); |
| | | args.put("channel", ACCOUNTWS_CHANNEL); |
| | | // args.put(CCY_KEY, CoinEnums.USDT.getCode()); |
| | | JSONObject updateInterval = new JSONObject(); |
| | | updateInterval.put("updateInterval",CoinEnums.UPDATEINTERVAL.getCode()); |
| | | args.put("extraParams", updateInterval); |
| | | args.put(CCY_KEY, CoinEnums.USDT.getCode()); |
| | | argsArray.add(args); |
| | | |
| | | String connId = MallUtils.getOrderNum(ACCOUNTWS_CHANNEL); |
| | |
| | | JSONObject args = new JSONObject(); |
| | | args.put("channel", POSITIONSWS_CHANNEL); |
| | | args.put("instType", CoinEnums.INSTTYPE_SWAP.getCode()); |
| | | // args.put("instId", CoinEnums.HE_YUE.getCode()); |
| | | JSONObject updateInterval = new JSONObject(); |
| | | updateInterval.put("updateInterval",CoinEnums.UPDATEINTERVAL.getCode()); |
| | | args.put("extraParams", updateInterval); |
| | | args.put("instId", CoinEnums.HE_YUE.getCode()); |
| | | argsArray.add(args); |
| | | |
| | | String connId = MallUtils.getOrderNum(POSITIONSWS_CHANNEL); |