From 0383bff7fdc2b67a438cfe18209edde76e1f27a1 Mon Sep 17 00:00:00 2001
From: hzj <826100833@qq.com>
Date: Mon, 11 Aug 2025 15:58:27 +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

---
 .../service/impl/LnDataDealServiceImpl.java     | 17 ++++++++++++-----
 .../influxdb/InfluxdbPqsCommunicateImpl.java    |  2 +-
 2 files changed, 13 insertions(+), 6 deletions(-)

diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/LnDataDealServiceImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/LnDataDealServiceImpl.java
index 4015234..960b463 100644
--- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/LnDataDealServiceImpl.java
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/LnDataDealServiceImpl.java
@@ -1,9 +1,12 @@
 package com.njcn.dataProcess.service.impl;
 
+import cn.hutool.core.date.DatePattern;
+import cn.hutool.core.date.LocalDateTimeUtil;
 import com.njcn.dataProcess.annotation.QueryBean;
 import com.njcn.dataProcess.dto.DataVDTO;
 import com.njcn.dataProcess.dto.LnDataDTO;
 import com.njcn.dataProcess.annotation.InsertBean;
+import com.njcn.dataProcess.pojo.dto.PqsCommunicateDto;
 import com.njcn.dataProcess.service.*;
 import com.njcn.device.pq.api.DeviceFeignClient;
 import com.njcn.device.pq.api.LineFeignClient;
@@ -60,6 +63,8 @@ public class LnDataDealServiceImpl implements LnDataDealService {
 
     @Autowired
     private LineFeignClient lineFeignClient;
+    @QueryBean
+    private IPqsCommunicate iPqsCommunicate;
 
     @Override
     public void batchInsertion(LnDataDTO lnDataDTO) {
@@ -88,11 +93,13 @@ public class LnDataDealServiceImpl implements LnDataDealService {
             }).distinct().collect(Collectors.toList());
 
             devIds.forEach(temp->{
-                DevComFlagDTO devComFlagDTO = new DevComFlagDTO();
-                devComFlagDTO.setId(temp);
-                devComFlagDTO.setStatus(1);
-                devComFlagDTO.setDate(dataVDTO.getTimeid());
-                deviceFeignClient.updateDevComFlag(devComFlagDTO);
+                PqsCommunicateDto pqsCommunicateDto = new PqsCommunicateDto();
+                pqsCommunicateDto.setTime(LocalDateTimeUtil.format(dataVDTO.getTimeid(), DatePattern.NORM_DATETIME_PATTERN));
+                pqsCommunicateDto.setDevId(temp);
+                pqsCommunicateDto.setType(1);
+
+
+                iPqsCommunicate.insertion(pqsCommunicateDto);
             });
 
 
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 e6210f8..6db13e6 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
@@ -110,7 +110,7 @@ public class InfluxdbPqsCommunicateImpl implements IPqsCommunicate {
 
     @Override
     public void insertion(PqsCommunicateDto pqsCommunicateDto) {
-        log.info("进出Influxdb实现类");
+//        log.info("进出Influxdb实现类");
         //获取最新一条数据
         PqsCommunicate dto = new PqsCommunicate();
         InfluxQueryWrapper influxQueryWrapper = new InfluxQueryWrapper(PqsCommunicate.class);