Middleware/cn-data-platform
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改更新设备状态逻辑

Browse Source
This commit is contained in:
hzj
2025-08-11 15:58:27 +08:00
parent 9176f88c01
commit 0383bff7fd
2 changed files with 13 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/LnDataDealServiceImpl.java
View File

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

2
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbPqsCommunicateImpl.java
View File

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