fix: 修改一些BUG

This commit is contained in:
fengyarnom 2025-06-24 19:34:21 +08:00
parent 8115e54fcc
commit 40813356a6

View File

@ -117,9 +117,6 @@ public class D331RtcmMessageExecutor implements Executor<D331RtcmMessage, Void>
ByteBuf buf = Unpooled.buffer();
buf.writeBytes(forwardBytes);
deviceChannel.writeAndFlush(buf);
if(deviceChannel != null && deviceChannel.isOnline()) {
if (logger.isDebugEnabled()) {
logger.debug("forward d331 rtcm from {} to device {}", id, deviceId);
}
} else if (baseStationModel == 0) {
//logger.info("Base station model is 0 for device: {}", deviceId);
@ -298,6 +295,11 @@ public class D331RtcmMessageExecutor implements Executor<D331RtcmMessage, Void>
return null;
}
@Override
public Class<?> getMessageType() {
return D331RtcmMessage.class;
}
private void sendToNtrip(String mountpoint, String hexData) {
try {
@ -332,5 +334,4 @@ public class D331RtcmMessageExecutor implements Executor<D331RtcmMessage, Void>
baseStation.getLastRxTime().isAfter(now.minusMinutes(30));
}
}