From fbde58faf653d6d8014d866e89f82d3904d83bad Mon Sep 17 00:00:00 2001
From: yarnom <admin@yarnom.com>
Date: Wed, 30 Jul 2025 09:44:13 +0800
Subject: [PATCH] fix: ntripcaster

---
 .../sideslope/executor/D331RtcmMessageExecutor.java        | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

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 c4d6f89d..06798d52 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
@@ -287,7 +287,12 @@ public class D331RtcmMessageExecutor implements Executor<D331RtcmMessage, Void>
             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);
+                });
         try {
             // 添加原始数据日志
             logger.info("Processing hex data for device {}, data length: {}", deviceId, hexData.length());