From a2de31dc41cfab969a863eaaea3a916404362851 Mon Sep 17 00:00:00 2001 From: hzj <826100833@qq.com> Date: Thu, 7 Aug 2025 11:04:53 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=9B=B4=E6=96=B0=E8=AE=BE?= =?UTF-8?q?=E5=A4=87=E7=8A=B6=E6=80=81=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/influxdb/InfluxdbPqsCommunicateImpl.java | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) 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); }