diff --git a/pqs-advance/advance-boot/src/main/java/com/njcn/advance/service/impl/EventRelevantAnalysisServiceImpl.java b/pqs-advance/advance-boot/src/main/java/com/njcn/advance/service/impl/EventRelevantAnalysisServiceImpl.java index 884110d7e..1fe5c5541 100644 --- a/pqs-advance/advance-boot/src/main/java/com/njcn/advance/service/impl/EventRelevantAnalysisServiceImpl.java +++ b/pqs-advance/advance-boot/src/main/java/com/njcn/advance/service/impl/EventRelevantAnalysisServiceImpl.java @@ -48,6 +48,7 @@ import io.swagger.models.auth.In; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import net.sf.json.JSONObject; +import org.apache.commons.lang.StringUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -733,7 +734,7 @@ public class EventRelevantAnalysisServiceImpl extends ServiceImpl advanceEventDetailVOLsit = querySagEventsAll(startTime, endTime); - + advanceEventDetailVOLsit = advanceEventDetailVOLsit.stream().filter(temp-> StringUtils.isNotEmpty(temp.getAdvanceType())).collect(Collectors.toList()); for (AdvanceEventDetailVO advanceEventDetailVO : advanceEventDetailVOLsit) { // 获取监测点线路序号 //母线id String nodePhysics = advanceEventDetailVO.getVoltageId(); diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/ReportServiceImpl.java b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/ReportServiceImpl.java index 7e983d17f..a7bb89340 100644 --- a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/ReportServiceImpl.java +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/ReportServiceImpl.java @@ -291,7 +291,14 @@ public class ReportServiceImpl implements ReportService { .le(StrUtil.isNotBlank(businessParam.getSearchEndTime()), RmpEventDetailPO::getStartTime, DateUtil.endOfDay(DateUtil.parse(businessParam.getSearchEndTime()))) .orderByDesc(RmpEventDetailPO::getSeverity).last(" limit 20") ); - info = BeanUtil.copyToList(eventDetails, EventDetailNew.class); + info = eventDetails.stream().map(temp->{ + EventDetailNew eventDetailNew = new EventDetailNew(); + BeanUtils.copyProperties(temp,eventDetailNew); + eventDetailNew.setStartTime(LocalDateTimeUtil.format(temp.getStartTime(),DatePattern.NORM_DATETIME_MS_PATTERN)); + return eventDetailNew; + }).collect(Collectors.toList()); + +// info = BeanUtil.copyToList(eventDetails, EventDetailNew.class); } else { throw new BusinessException(DeviceResponseEnum.DEPT_LINE_EMPTY); } @@ -309,6 +316,7 @@ public class ReportServiceImpl implements ReportService { if (detail.getLineId().equals(vo.getLineId())) { BeanUtils.copyProperties(detail, waveTypeVO); BeanUtils.copyProperties(vo, waveTypeVO); + waveTypeVO.setStartTime(LocalDateTimeUtil.parse(detail.getStartTime(),DatePattern.NORM_DATETIME_MS_PATTERN)); result.add(waveTypeVO); } } @@ -343,7 +351,7 @@ public class ReportServiceImpl implements ReportService { count.put(datum.getName(), 0); } //过滤掉原因的是空的 - info = info.stream().filter(temp->Objects.nonNull(temp.getAdvanceReason())).collect(Collectors.toList()); + info = info.stream().filter(temp->StringUtils.isNotEmpty(temp.getAdvanceReason())).collect(Collectors.toList()); //替值 for (EventDetail eventDetail : info) { // if (dictData.getId().equals(eventDetail.getEventType())) { @@ -978,7 +986,7 @@ public class ReportServiceImpl implements ReportService { cell9.setCellStyle(bodyStyle); cell0.setCellValue(i + 1); - cell1.setCellValue(vo.getStartTime()); + cell1.setCellValue(LocalDateTimeUtil.format(vo.getStartTime(),DatePattern.NORM_DATETIME_MS_PATTERN)); cell2.setCellValue(vo.getGdName()); cell3.setCellValue(vo.getSubName()); cell4.setCellValue(vo.getLineName()); @@ -1101,7 +1109,7 @@ public class ReportServiceImpl implements ReportService { } public void sheet4(HSSFWorkbook sheets, HSSFCellStyle cellStyle, HSSFCellStyle bodyStyle, DeviceInfoParam.BusinessParam businessParam) { - sheets.createSheet("详细事件列表"); + sheets.createSheet("暂降事件列表"); HSSFSheet sheetAt = sheets.getSheetAt(3); sheetAt.setColumnWidth(0, 24 * 256); sheetAt.setColumnWidth(1, 24 * 256); diff --git a/pqs-event/event-common/src/main/java/com/njcn/event/common/service/impl/EventDetailServiceImpl.java b/pqs-event/event-common/src/main/java/com/njcn/event/common/service/impl/EventDetailServiceImpl.java index 2ed52a256..7c2f68217 100644 --- a/pqs-event/event-common/src/main/java/com/njcn/event/common/service/impl/EventDetailServiceImpl.java +++ b/pqs-event/event-common/src/main/java/com/njcn/event/common/service/impl/EventDetailServiceImpl.java @@ -191,6 +191,11 @@ public class EventDetailServiceImpl extends ServiceImpl eventDetailList = influxDBResultMapper.toPOJO(monitorQuery, EventDetailNew.class); - Map> map = eventDetailList.stream().filter(x -> x.getEventType() == "1").collect(Collectors.groupingBy(s -> s.getStartTime().substring(0, 10))); + Map> map = eventDetailList.stream().filter(x -> x.getEventType() == "1").collect(Collectors.groupingBy(s ->s.getStartTime().substring(0, 10))); Set keySet = map.keySet(); LocalDate parse1 = LocalDate.parse(startTime);