diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/service/distribution/Impl/PwEventMonitorReportServiceImpl.java b/pqs-event/event-boot/src/main/java/com/njcn/event/service/distribution/Impl/PwEventMonitorReportServiceImpl.java index 2c1ae8d99..9dcca4222 100644 --- a/pqs-event/event-boot/src/main/java/com/njcn/event/service/distribution/Impl/PwEventMonitorReportServiceImpl.java +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/service/distribution/Impl/PwEventMonitorReportServiceImpl.java @@ -79,13 +79,15 @@ public class PwEventMonitorReportServiceImpl implements PwEventMonitorReportServ // Map eventStatisMapByCode = eventStatisList.stream().collect(Collectors.toMap(DictData::getCode, data -> data)); //查询暂态事件明细 - List detailList; - if (BizParamConstant.STAT_BIZ_MONTH.equals(type + "")) { //按月查 - detailList = rmpEventDetailMapper.getDetailsOfTransientEventsByMonth(monitorIdList, null, startTime, endTime); - } else { //按日查 - detailList = rmpEventDetailMapper.getDetailsOfTransientEvents(monitorIdList, null, startTime, endTime); + List detailList = new ArrayList<>(); + List> partition = ListUtils.partition(monitorIdList, 20000); + for (List list : partition) { + if (BizParamConstant.STAT_BIZ_MONTH.equals(type + "")) { //按月查 + detailList.addAll(rmpEventDetailMapper.getDetailsOfTransientEventsByMonth(list, null, startTime, endTime)); + } else { //按日查 + detailList.addAll( rmpEventDetailMapper.getDetailsOfTransientEvents(list, null, startTime, endTime)); + } } - if (CollUtil.isNotEmpty(detailList)) { //todo 获取监测点信息接口 pwPmsMonitorParam.setMonitorName(eventMonitorReportParam.getMonitorName());