diff --git a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D341LocationMessageExecutor.java b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D341LocationMessageExecutor.java index 4448da94..45f8fa91 100644 --- a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D341LocationMessageExecutor.java +++ b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D341LocationMessageExecutor.java @@ -84,7 +84,7 @@ public class D341LocationMessageExecutor implements Executor { - gnssCalcService.calcSingle(message,true); - // 原始码流输出到日志文件 -- INFO 级别 - if(device.getLoggingmode() == GnssDevice.LOGGING_MODE_FULL){ - logger.info("receive {} d341 message: {}", message.getId(), DataTypeUtil.getHexString(message.getSrcData())); - } + if(device.getDeviceType() == Device.DEVICE_ROVER) { + ThreadManager.getFixedThreadPool().submit(() -> { + gnssCalcService.calcSingle(message, true); + // 原始码流输出到日志文件 -- INFO 级别 + if (device.getLoggingmode() == GnssDevice.LOGGING_MODE_FULL) { + logger.info("receive {} d341 message: {}", message.getId(), DataTypeUtil.getHexString(message.getSrcData())); + } /*else { Gga gga1 = message.getGga(); if (gga1 != null && !gga1.isFixed()) { @@ -107,7 +108,8 @@ public class D341LocationMessageExecutor implements Executor