diff --git a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D331RtcmMessageExecutor.java b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D331RtcmMessageExecutor.java index 06798d52..58dc3e54 100644 --- a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D331RtcmMessageExecutor.java +++ b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D331RtcmMessageExecutor.java @@ -282,17 +282,19 @@ public class D331RtcmMessageExecutor implements Executor } private void sendToNtrip(String deviceId, String hexData) { - // 检查设备是否启用TCP转发 - if (!rtcmPortConfigManager.isDeviceEnabled(deviceId)) { - logger.info("Device {} not enabled for TCP forwarding", deviceId); - return; - } Optional.ofNullable(RtcmGgaUtil.getRtcms(hexData)) .ifPresent(rtcm -> { //System.out.println("挂载点: " + mountpoint); //System.out.println("RTCM数据: " + rtcm); ntripServer.send(deviceId, rtcm); }); + + // 检查设备是否启用TCP转发 + if (!rtcmPortConfigManager.isDeviceEnabled(deviceId)) { + logger.info("Device {} not enabled for TCP forwarding", deviceId); + return; + } + try { // 添加原始数据日志 logger.info("Processing hex data for device {}, data length: {}", deviceId, hexData.length());