From 33b9fae9ef244c8b5f69f6869474b743d052d553 Mon Sep 17 00:00:00 2001 From: xy <748613696@qq.com> Date: Wed, 14 Jan 2026 20:41:24 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BE=AE=E8=B0=83?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/njcn/stat/service/impl/StatServiceImpl.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/iot-analysis/analysis-stat/stat-boot/src/main/java/com/njcn/stat/service/impl/StatServiceImpl.java b/iot-analysis/analysis-stat/stat-boot/src/main/java/com/njcn/stat/service/impl/StatServiceImpl.java index fdd5888..79839b1 100644 --- a/iot-analysis/analysis-stat/stat-boot/src/main/java/com/njcn/stat/service/impl/StatServiceImpl.java +++ b/iot-analysis/analysis-stat/stat-boot/src/main/java/com/njcn/stat/service/impl/StatServiceImpl.java @@ -3,6 +3,7 @@ package com.njcn.stat.service.impl; import cn.hutool.core.collection.CollectionUtil; import com.alibaba.nacos.shaded.com.google.gson.Gson; import com.njcn.access.api.CsLineLatestDataFeignClient; +import com.njcn.access.pojo.po.CsLineLatestData; import com.njcn.access.utils.ChannelObjectUtil; import com.njcn.common.pojo.exception.BusinessException; import com.njcn.common.utils.PubUtils; @@ -153,10 +154,10 @@ public class StatServiceImpl implements IStatService { //influx数据批量入库 influxDbUtils.batchInsert(influxDbUtils.getDbName(), "", InfluxDB.ConsistencyLevel.ALL, TimeUnit.MILLISECONDS, recordList); //记录监测点最新数据时间 -// CsLineLatestData csLineLatestData = new CsLineLatestData(); -// csLineLatestData.setLineId(lineId); -// csLineLatestData.setTimeId(Objects.isNull(time) ? LocalDateTime.now() : time); -// csLineLatestDataFeignClient.addData(csLineLatestData); + CsLineLatestData csLineLatestData = new CsLineLatestData(); + csLineLatestData.setLineId(lineId); + csLineLatestData.setTimeId(Objects.isNull(time) ? LocalDateTime.now() : time); + csLineLatestDataFeignClient.addData(csLineLatestData); } } }