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 92bb98e..e6210f8 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
@@ -124,14 +124,15 @@ public class InfluxdbPqsCommunicateImpl implements IPqsCommunicate {
         //如果不存数据或者状态不一样则插入数据
        if(CollectionUtils.isEmpty(pqsCommunicates)|| !Objects.equals( pqsCommunicates.get(0).getType(),pqsCommunicateDto.getType())){
            pqsCommunicateMapper.insertOne(pqsCommunicate);
-            //更新mysql数据
-           DevComFlagDTO devComFlagDTO = new DevComFlagDTO();
-           devComFlagDTO.setId(pqsCommunicateDto.getDevId());
-           devComFlagDTO.setDate(LocalDateTime.parse(pqsCommunicateDto.getTime(), DATE_TIME_FORMATTER));
-           devComFlagDTO.setStatus(pqsCommunicateDto.getType());
 
-           deviceFeignClient.updateDevComFlag(devComFlagDTO);
        }
+        //更新mysql数据
+        DevComFlagDTO devComFlagDTO = new DevComFlagDTO();
+        devComFlagDTO.setId(pqsCommunicateDto.getDevId());
+        devComFlagDTO.setDate(LocalDateTime.parse(pqsCommunicateDto.getTime(), DATE_TIME_FORMATTER));
+        devComFlagDTO.setStatus(pqsCommunicateDto.getType());
+
+        deviceFeignClient.updateDevComFlag(devComFlagDTO);
     }