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

fix: 尝试修复断联问题

Browse Source
This commit is contained in:
yarnom 2025-10-28 16:00:46 +08:00
parent 11ef555eea
commit 9e110d1218
1 changed files with 4 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -122,21 +122,14 @@ public class D331RtcmMessageExecutor implements Executor<D331RtcmMessage, Void>
deviceBs.setGeoidSeparation(gga.getGeoidSeparation()); deviceBs.setGeoidSeparation(gga.getGeoidSeparation());
} }
// 添加NTRIP处理 + rtkCluster 推送 // 添加NTRIP处理
if(deviceBs.getForwardToNtrip()) { if(deviceBs.getForwardToNtrip()) {
byte[] srcdata = message.getSrcData(); byte[] srcdata = message.getSrcData();
String hex = ByteUtil.bytesToHexString(srcdata); String rtcm = ByteUtil.bytesToHexString(srcdata);
// 1) NTRIP：发送提取后的 RTCM 帧 sendToNtrip(id, rtcm);
sendToNtrip(id, hex);
// 2) rtkCluster：优先发送干净的 RTCM 帧（去除任何封装），退化时发送原始数据
try { try {
String rtcmsHex = RtcmGgaUtil.getRtcms(hex).toString(); rtkClusterService.sendRtcm(id, rtcm);
if (rtcmsHex != null && !rtcmsHex.isEmpty()) {
rtkClusterService.sendRtcmBytes(id, ByteUtil.hexStringTobyte(rtcmsHex));
} else {
rtkClusterService.sendRtcmBytes(id, srcdata);
}
} catch (Exception e) { } catch (Exception e) {
logger.debug("send to rtkCluster failed for {}: {}", id, e.getMessage()); logger.debug("send to rtkCluster failed for {}: {}", id, e.getMessage());
} }