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:41:48 +08:00
parent a2de31dc41
commit 9176f88c01
2 changed files with 17 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
analysis/stat/stat-boot/src/main/java/com/njcn/stat/service/impl/MessageAnalysisServiceImpl.java
View File

@@ -68,22 +68,22 @@ public class MessageAnalysisServiceImpl implements MessageAnalysisService {
List<DataFlucDTO> dataFlucDTOList = new ArrayList<>(); List<DataFlucDTO> dataFlucDTOList = new ArrayList<>();
List<DataPltDTO> dataPltDTOList = new ArrayList<>(); List<DataPltDTO> dataPltDTOList = new ArrayList<>();
List<DataFlickerDTO> dataFlickerDTOList = new ArrayList<>(); List<DataFlickerDTO> dataFlickerDTOList = new ArrayList<>();
//移动到入库阶段做处理
//新增冗余，装置收到数据，判断装置当前的状态，如果为离线，则应该置为在线 // //新增冗余，装置收到数据，判断装置当前的状态，如果为离线，则应该置为在线
List<String> lineList = messageList.stream().map(MessageDataDTO::getMonitor).distinct().collect(Collectors.toList()); // List<String> lineList = messageList.stream().map(MessageDataDTO::getMonitor).distinct().collect(Collectors.toList());
//装置集合 // //装置集合
Set<String> devList = lineFeignClient.getDevListByLineIdList(lineList).getData(); // Set<String> devList = lineFeignClient.getDevListByLineIdList(lineList).getData();
//获取装置详细信息 // //获取装置详细信息
devList.forEach(dev->{ // devList.forEach(dev->{
DeviceDTO dto = deviceFeignClient.getDeviceInfo(dev).getData(); // DeviceDTO dto = deviceFeignClient.getDeviceInfo(dev).getData();
//判断装置通讯状态 如果装置还处于离线，则要反转装置的状态 // //判断装置通讯状态 如果装置还处于离线，则要反转装置的状态
if (Objects.equals(dto.getComFlag(),0)) { // if (Objects.equals(dto.getComFlag(),0)) {
com.njcn.device.pq.pojo.dto.DevComFlagDTO dto1 = new com.njcn.device.pq.pojo.dto.DevComFlagDTO(); // com.njcn.device.pq.pojo.dto.DevComFlagDTO dto1 = new com.njcn.device.pq.pojo.dto.DevComFlagDTO();
dto1.setId(dev); // dto1.setId(dev);
dto1.setStatus(1); // dto1.setStatus(1);
deviceFeignClient.updateDevComFlag(dto1); // deviceFeignClient.updateDevComFlag(dto1);
} // }
}); // });
messageList.forEach(messageDataDTO->{ messageList.forEach(messageDataDTO->{
Integer dataType = messageDataDTO.getDataType(); Integer dataType = messageDataDTO.getDataType();

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

@@ -90,6 +90,7 @@ public class LnDataDealServiceImpl implements LnDataDealService {
devIds.forEach(temp->{ devIds.forEach(temp->{
DevComFlagDTO devComFlagDTO = new DevComFlagDTO(); DevComFlagDTO devComFlagDTO = new DevComFlagDTO();
devComFlagDTO.setId(temp); devComFlagDTO.setId(temp);
devComFlagDTO.setStatus(1);
devComFlagDTO.setDate(dataVDTO.getTimeid()); devComFlagDTO.setDate(dataVDTO.getTimeid());
deviceFeignClient.updateDevComFlag(devComFlagDTO); deviceFeignClient.updateDevComFlag(devComFlagDTO);
}); });