修改更新设备状态逻辑

data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbPqsCommunicateImpl.java

@@ -124,6 +124,8 @@ 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());
@@ -132,7 +134,6 @@ public class InfluxdbPqsCommunicateImpl implements IPqsCommunicate {
 
         deviceFeignClient.updateDevComFlag(devComFlagDTO);
     }
-    }
 
 
     /**