Imdroid/security-monitor
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix: ntripcaster

Browse Source
This commit is contained in:
yarnom 2025-07-30 10:06:16 +08:00
parent fbde58faf6
commit a170fef04b
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D331RtcmMessageExecutor.java
View File

@ -282,17 +282,19 @@ public class D331RtcmMessageExecutor implements Executor<D331RtcmMessage, Void>
} }
private void sendToNtrip(String deviceId, String hexData) { 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)) Optional.ofNullable(RtcmGgaUtil.getRtcms(hexData))
.ifPresent(rtcm -> { .ifPresent(rtcm -> {
//System.out.println("挂载点: " + mountpoint); //System.out.println("挂载点: " + mountpoint);
//System.out.println("RTCM数据: " + rtcm); //System.out.println("RTCM数据: " + rtcm);
ntripServer.send(deviceId, rtcm); ntripServer.send(deviceId, rtcm);
}); });
// 检查设备是否启用TCP转发
if (!rtcmPortConfigManager.isDeviceEnabled(deviceId)) {
logger.info("Device {} not enabled for TCP forwarding", deviceId);
return;
}
try { try {
// 添加原始数据日志 // 添加原始数据日志
logger.info("Processing hex data for device {}, data length: {}", deviceId, hexData.length()); logger.info("Processing hex data for device {}, data length: {}", deviceId, hexData.length());