fix: ntripcaster

This commit is contained in:
yarnom 2025-07-30 09:44:13 +08:00
parent b25a26b2c6
commit fbde58faf6

View File

@ -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());