diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbPqsCommunicateImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbPqsCommunicateImpl.java index 6c4d058..6a771f2 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbPqsCommunicateImpl.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbPqsCommunicateImpl.java @@ -121,7 +121,7 @@ public class InfluxdbPqsCommunicateImpl implements IPqsCommunicate { long end1 = System.currentTimeMillis(); - log.info("更新device表:" + (end1 - start) + " ms"); + log.info("查询通讯表最新数据:" + (end1 - start) + " ms"); PqsCommunicate pqsCommunicate = new PqsCommunicate(); pqsCommunicate.setTime(LocalDateTime.parse(pqsCommunicateDto.getTime(), DATE_TIME_FORMATTER).atZone(ZoneId.systemDefault()).toInstant()); pqsCommunicate.setDevId(pqsCommunicateDto.getDevId()); @@ -133,7 +133,7 @@ public class InfluxdbPqsCommunicateImpl implements IPqsCommunicate { } long end2 = System.currentTimeMillis(); - log.info("更新device表:" + (end2 - end1) + " ms"); + log.info("更新通讯表最新数据:" + (end2 - end1) + " ms"); //更新mysql数据 DevComFlagDTO devComFlagDTO = new DevComFlagDTO();