feat(gateApi): 添加网格策略重启跨度阈值功能

Administrator

7 days ago 7ebe033e5cf2011c76ce60c2bc0df3cb667f78e3

 src/main/java/com/xcong/excoin/modules/gateApi/GateKlineWebSocketClient.java

@@ -258,6 +258,12 @@
            }
            if ("subscribe".equals(event)) {
                log.info("[WS] {} 订阅成功: {}", channel, response.getJSONObject("result"));
                for (GateChannelHandler handler : channelHandlers) {
                    if (channel.equals(handler.getChannelName())) {
                        handler.setSubscribed(true);
                        break;
                    }
                }
                return;
            }
            if ("unsubscribe".equals(event)) {
@@ -282,6 +288,17 @@
        }
    }

    /**
     * 检查所有已注册的频道是否都已收到订阅成功确认。
     */
    public boolean areAllSubscribed() {
        if (channelHandlers.isEmpty()) return false;
        for (GateChannelHandler h : channelHandlers) {
            if (!h.isSubscribed()) return false;
        }
        return true;
    }

    // ---- heartbeat ----

    /**