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); } } }