| | |
| | | List<Long> startTimeList = platformLogList.stream().filter(i->Objects.nonNull(i.getParam1())) |
| | | .filter(i->Objects.nonNull(i.getParam1())&&i.getParam1().indexOf(today)>=0) |
| | | .map(i->DateUtil.fromStringToDate("yyyy-MM-dd HH:mm:ss",i.getParam1()).getTime()).collect(Collectors.toList()); |
| | | Long startTime = Collections.min(startTimeList); |
| | | Long startTime = null ; |
| | | if(CollectionUtils.isNotEmpty(startTimeList)){ |
| | | startTime = Collections.min(startTimeList); |
| | | } |
| | | //获取结束时间 |
| | | List<Long> endTimeList = platformLogList.stream() |
| | | .filter(i->Objects.nonNull(i.getParam2())&&i.getParam2().indexOf(today)>=0) |
| | | .map(i->DateUtil.fromStringToDate("yyyy-MM-dd HH:mm:ss",i.getParam2()).getTime()).collect(Collectors.toList()); |
| | | Long endTime = Collections.max(endTimeList); |
| | | Long endTime = null ; |
| | | if(CollectionUtils.isNotEmpty(endTimeList)){ |
| | | endTime = Collections.max(endTimeList); |
| | | } |
| | | if(Objects.isNull(startTime) |
| | | || Objects.isNull(endTime) || (startTime>=endTime)){ |
| | | return BigDecimal.ZERO; |
| | |
| | | .selectAs(Platform::getName,PlatformWarnEvent::getPlatformName) |
| | | .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) |
| | | .eq(PlatformWarnEvent::getIsdeleted,Constants.ZERO) |
| | | .apply("to_days(t.create_date) = to_days(now())") |
| | | //.apply(" to_days(t.create_date) = to_days(now()) ") |
| | | .apply(" ( t.create_date > now() - INTERVAL 10 MINUTE ) ") |
| | | .orderByDesc(PlatformWarnEvent::getCreateDate) |
| | | .last(" limit "+limit) |
| | | ); |