Microservice/iot
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

微调

Browse Source
This commit is contained in:
xy
2026-01-14 20:41:24 +08:00
parent a369ae6160
commit 33b9fae9ef
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
iot-analysis/analysis-stat/stat-boot/src/main/java/com/njcn/stat/service/impl/StatServiceImpl.java
View File

@@ -3,6 +3,7 @@ package com.njcn.stat.service.impl;
import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.CollectionUtil;
import com.alibaba.nacos.shaded.com.google.gson.Gson; import com.alibaba.nacos.shaded.com.google.gson.Gson;
import com.njcn.access.api.CsLineLatestDataFeignClient; import com.njcn.access.api.CsLineLatestDataFeignClient;
import com.njcn.access.pojo.po.CsLineLatestData;
import com.njcn.access.utils.ChannelObjectUtil; import com.njcn.access.utils.ChannelObjectUtil;
import com.njcn.common.pojo.exception.BusinessException; import com.njcn.common.pojo.exception.BusinessException;
import com.njcn.common.utils.PubUtils; import com.njcn.common.utils.PubUtils;
@@ -153,10 +154,10 @@ public class StatServiceImpl implements IStatService {
//influx数据批量入库 //influx数据批量入库
influxDbUtils.batchInsert(influxDbUtils.getDbName(), "", InfluxDB.ConsistencyLevel.ALL, TimeUnit.MILLISECONDS, recordList); influxDbUtils.batchInsert(influxDbUtils.getDbName(), "", InfluxDB.ConsistencyLevel.ALL, TimeUnit.MILLISECONDS, recordList);
//记录监测点最新数据时间 //记录监测点最新数据时间
// CsLineLatestData csLineLatestData = new CsLineLatestData(); CsLineLatestData csLineLatestData = new CsLineLatestData();
// csLineLatestData.setLineId(lineId); csLineLatestData.setLineId(lineId);
// csLineLatestData.setTimeId(Objects.isNull(time) ? LocalDateTime.now() : time); csLineLatestData.setTimeId(Objects.isNull(time) ? LocalDateTime.now() : time);
// csLineLatestDataFeignClient.addData(csLineLatestData); csLineLatestDataFeignClient.addData(csLineLatestData);
} }
} }
} }