From a170fef04b7013590d112596cb0785bb84dafe71 Mon Sep 17 00:00:00 2001
From: yarnom <admin@yarnom.com>
Date: Wed, 30 Jul 2025 10:06:16 +0800
Subject: [PATCH] fix: ntripcaster

---
 .../sideslope/executor/D331RtcmMessageExecutor.java  | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

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<D331RtcmMessage, Void>
     }
 
     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());