diff --git a/pqs-bpm/bpm-boot/src/main/java/com/njcn/bpm/service/task/impl/BpmProcessInstanceServiceImpl.java b/pqs-bpm/bpm-boot/src/main/java/com/njcn/bpm/service/task/impl/BpmProcessInstanceServiceImpl.java index 2acfbb600..d2512e185 100644 --- a/pqs-bpm/bpm-boot/src/main/java/com/njcn/bpm/service/task/impl/BpmProcessInstanceServiceImpl.java +++ b/pqs-bpm/bpm-boot/src/main/java/com/njcn/bpm/service/task/impl/BpmProcessInstanceServiceImpl.java @@ -143,13 +143,15 @@ public class BpmProcessInstanceServiceImpl implements IBpmProcessInstanceService //流程状态排除不通过的,不通过会放在待办中,一直到该流程通过 processInstanceQuery.variableValueNotEquals(BpmConstants.PROCESS_INSTANCE_VARIABLE_STATUS, BpmTaskStatusEnum.REJECT.getStatus()); + if (Objects.nonNull(bpmProcessInstancePageParam.getSearchBeginTime()) && Objects.nonNull(bpmProcessInstancePageParam.getSearchEndTime())) { + String beginTimeStr = bpmProcessInstancePageParam.getSearchBeginTime(); + String endTimeStr = bpmProcessInstancePageParam.getSearchEndTime(); + LocalDateTime beginTime = LocalDateTimeUtil.parse(beginTimeStr, DatePattern.NORM_DATE_PATTERN); + LocalDateTime endTime = PubUtils.endTimeToLocalDateTime(endTimeStr); + processInstanceQuery.startedBefore(DateUtils.of(endTime)); + processInstanceQuery.startedAfter(DateUtils.of(beginTime)); + } - String beginTimeStr = bpmProcessInstancePageParam.getSearchBeginTime(); - String endTimeStr = bpmProcessInstancePageParam.getSearchEndTime(); - LocalDateTime beginTime = LocalDateTimeUtil.parse(beginTimeStr, DatePattern.NORM_DATE_PATTERN); - LocalDateTime endTime = PubUtils.endTimeToLocalDateTime(endTimeStr); - processInstanceQuery.startedBefore(DateUtils.of(endTime)); - processInstanceQuery.startedAfter(DateUtils.of(beginTime)); // 查询数量 long processInstanceCount = processInstanceQuery.count(); if (processInstanceCount == 0) { diff --git a/pqs-bpm/bpm-boot/src/main/java/com/njcn/bpm/service/task/impl/BpmTaskServiceImpl.java b/pqs-bpm/bpm-boot/src/main/java/com/njcn/bpm/service/task/impl/BpmTaskServiceImpl.java index 6eda4c886..b00b337cb 100644 --- a/pqs-bpm/bpm-boot/src/main/java/com/njcn/bpm/service/task/impl/BpmTaskServiceImpl.java +++ b/pqs-bpm/bpm-boot/src/main/java/com/njcn/bpm/service/task/impl/BpmTaskServiceImpl.java @@ -142,12 +142,14 @@ public class BpmTaskServiceImpl implements IBpmTaskService { if (StrUtil.isNotBlank(bpmTaskQueryParam.getSearchValue())) { taskQuery.processDefinitionNameLike("%" + bpmTaskQueryParam.getSearchValue() + "%"); } - String beginTimeStr = bpmTaskQueryParam.getSearchBeginTime(); - String endTimeStr = bpmTaskQueryParam.getSearchEndTime(); - LocalDateTime beginTime = LocalDateTimeUtil.parse(beginTimeStr, DatePattern.NORM_DATE_PATTERN); - LocalDateTime endTime = PubUtils.endTimeToLocalDateTime(endTimeStr); - taskQuery.taskCreatedBefore(DateUtils.of(endTime)); - taskQuery.taskCreatedAfter(DateUtils.of(beginTime)); + if (Objects.nonNull(bpmTaskQueryParam.getSearchBeginTime()) && Objects.nonNull(bpmTaskQueryParam.getSearchEndTime())) { + String beginTimeStr = bpmTaskQueryParam.getSearchBeginTime(); + String endTimeStr = bpmTaskQueryParam.getSearchEndTime(); + LocalDateTime beginTime = LocalDateTimeUtil.parse(beginTimeStr, DatePattern.NORM_DATE_PATTERN); + LocalDateTime endTime = PubUtils.endTimeToLocalDateTime(endTimeStr); + taskQuery.taskCreatedBefore(DateUtils.of(endTime)); + taskQuery.taskCreatedAfter(DateUtils.of(beginTime)); + } // 执行查询 long count = taskQuery.count(); if (count == 0) { diff --git a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/LineWarningServiceImpl.java b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/LineWarningServiceImpl.java index 82703f999..32f319d69 100644 --- a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/LineWarningServiceImpl.java +++ b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/LineWarningServiceImpl.java @@ -224,7 +224,9 @@ public class LineWarningServiceImpl extends MppServiceImpl queryWrapper = new QueryWrapper<>(); - queryWrapper.between("A.alarm_time", param.getSearchBeginTime(), param.getSearchEndTime()); + if (Objects.nonNull(param.getSearchBeginTime()) && Objects.nonNull(param.getSearchEndTime())) { + queryWrapper.between("A.alarm_time", param.getSearchBeginTime(), param.getSearchEndTime()); + } //监测点id if (CollUtil.isNotEmpty(lineList)) { queryWrapper.in("A.line_id", lineList); diff --git a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/QuitRunningDeviceServiceImpl.java b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/QuitRunningDeviceServiceImpl.java index 07a611581..17c8fcec3 100644 --- a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/QuitRunningDeviceServiceImpl.java +++ b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/QuitRunningDeviceServiceImpl.java @@ -160,10 +160,11 @@ public class QuitRunningDeviceServiceImpl extends ServiceImpl page = this.baseMapper.page(new Page<>(PageFactory.getPageNum(supervisionDevMainReportQuery), PageFactory.getPageSize(supervisionDevMainReportQuery)), queryWrapper); page.getRecords().forEach(temp -> { diff --git a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/SupervisionTempLineDebugPOServiceImpl.java b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/SupervisionTempLineDebugPOServiceImpl.java index 53f4511e8..e610cb15b 100644 --- a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/SupervisionTempLineDebugPOServiceImpl.java +++ b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/SupervisionTempLineDebugPOServiceImpl.java @@ -244,9 +244,11 @@ public class SupervisionTempLineDebugPOServiceImpl extends ServiceImpl(PageFactory.getPageNum(supervisionTempLineDebugQuery), PageFactory.getPageSize(supervisionTempLineDebugQuery)), queryWrapper); } @@ -271,9 +273,11 @@ public class SupervisionTempLineDebugPOServiceImpl extends ServiceImpl(PageFactory.getPageNum(supervisionTempLineDebugQuery), PageFactory.getPageSize(supervisionTempLineDebugQuery)), queryWrapper); } diff --git a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/SupervisionTempLineReportServiceImpl.java b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/SupervisionTempLineReportServiceImpl.java index d8762a264..fb355d0fe 100644 --- a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/SupervisionTempLineReportServiceImpl.java +++ b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/SupervisionTempLineReportServiceImpl.java @@ -173,9 +173,11 @@ public class SupervisionTempLineReportServiceImpl extends ServiceImpl(PageFactory.getPageNum(supervisionTempLineReportQuery), PageFactory.getPageSize(supervisionTempLineReportQuery)), queryWrapper); } diff --git a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/leaflet/impl/WarningLeafletServiceImpl.java b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/leaflet/impl/WarningLeafletServiceImpl.java index 0f5e94de0..558939b36 100644 --- a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/leaflet/impl/WarningLeafletServiceImpl.java +++ b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/leaflet/impl/WarningLeafletServiceImpl.java @@ -130,10 +130,12 @@ public class WarningLeafletServiceImpl extends ServiceImpl warningPageData(WarningLeafletParam.WarningLeafletQueryParam warningLeafletQueryParam) { QueryWrapper warningLeafletVOQueryWrapper = new QueryWrapper<>(); if (Objects.nonNull(warningLeafletQueryParam)) { - //添加上时间范围 - warningLeafletVOQueryWrapper.between("supervision_warning_leaflet.Create_Time", - DateUtil.beginOfDay(DateUtil.parse(warningLeafletQueryParam.getSearchBeginTime())), - DateUtil.endOfDay(DateUtil.parse(warningLeafletQueryParam.getSearchEndTime()))); + if (Objects.nonNull(warningLeafletQueryParam.getSearchBeginTime()) && Objects.nonNull(warningLeafletQueryParam.getSearchEndTime())) { + //添加上时间范围 + warningLeafletVOQueryWrapper.between("supervision_warning_leaflet.Create_Time", + DateUtil.beginOfDay(DateUtil.parse(warningLeafletQueryParam.getSearchBeginTime())), + DateUtil.endOfDay(DateUtil.parse(warningLeafletQueryParam.getSearchEndTime()))); + } } //筛选负责单位 @@ -336,10 +338,12 @@ public class WarningLeafletServiceImpl extends ServiceImpl alarmPageData(WarningLeafletParam.WarningLeafletQueryParam warningLeafletQueryParam) { QueryWrapper warningLeafletVOQueryWrapper = new QueryWrapper<>(); if (Objects.nonNull(warningLeafletQueryParam)) { - //添加上时间范围 - warningLeafletVOQueryWrapper.between("supervision_warning_leaflet.Create_Time", - DateUtil.beginOfDay(DateUtil.parse(warningLeafletQueryParam.getSearchBeginTime())), - DateUtil.endOfDay(DateUtil.parse(warningLeafletQueryParam.getSearchEndTime()))); + if (Objects.nonNull(warningLeafletQueryParam.getSearchBeginTime()) && Objects.nonNull(warningLeafletQueryParam.getSearchEndTime())) { + //添加上时间范围 + warningLeafletVOQueryWrapper.between("supervision_warning_leaflet.Create_Time", + DateUtil.beginOfDay(DateUtil.parse(warningLeafletQueryParam.getSearchBeginTime())), + DateUtil.endOfDay(DateUtil.parse(warningLeafletQueryParam.getSearchEndTime()))); + } } warningLeafletVOQueryWrapper .and(w -> w.in("supervision_warning_leaflet.status", Arrays.asList(BpmTaskStatusEnum.RUNNING.getStatus(), diff --git a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/survey/impl/SurveyPlanServiceImpl.java b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/survey/impl/SurveyPlanServiceImpl.java index 1af98c5bd..f74a57b80 100644 --- a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/survey/impl/SurveyPlanServiceImpl.java +++ b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/survey/impl/SurveyPlanServiceImpl.java @@ -81,9 +81,11 @@ public class SurveyPlanServiceImpl extends ServiceImpl surveyPlanVOQueryWrapper = new QueryWrapper<>(); if (Objects.nonNull(surveyPlanQueryParam)) { //添加上时间范围 - surveyPlanVOQueryWrapper.and(x -> x.between("supervision_survey_plan.plan_start_time", - DateUtil.beginOfDay(DateUtil.parse(surveyPlanQueryParam.getSearchBeginTime())), - DateUtil.endOfDay(DateUtil.parse(surveyPlanQueryParam.getSearchEndTime()))).or().isNull("supervision_survey_plan.plan_start_time")); + if (Objects.nonNull(surveyPlanQueryParam.getSearchBeginTime()) && Objects.nonNull(surveyPlanQueryParam.getSearchEndTime())) { + surveyPlanVOQueryWrapper.and(x -> x.between("supervision_survey_plan.plan_start_time", + DateUtil.beginOfDay(DateUtil.parse(surveyPlanQueryParam.getSearchBeginTime())), + DateUtil.endOfDay(DateUtil.parse(surveyPlanQueryParam.getSearchEndTime()))).or().isNull("supervision_survey_plan.plan_start_time")); + } //根据工程名称模糊搜索 if (StrUtil.isNotBlank(surveyPlanQueryParam.getSearchValue())) { surveyPlanVOQueryWrapper.like("supervision_survey_plan.plan_name", surveyPlanQueryParam.getSearchValue()); diff --git a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/survey/impl/SurveyTestServiceImpl.java b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/survey/impl/SurveyTestServiceImpl.java index 6bc182dbd..d64702654 100644 --- a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/survey/impl/SurveyTestServiceImpl.java +++ b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/survey/impl/SurveyTestServiceImpl.java @@ -90,23 +90,24 @@ public class SurveyTestServiceImpl extends ServiceImpl surveyTestVOQueryWrapper = new QueryWrapper<>(); List deptIds = new ArrayList<>(); if (Objects.nonNull(surveyTestQueryParam)) { - //添加上时间范围 - surveyTestVOQueryWrapper.and(wrapper -> - wrapper.between("supervision_survey_plan.plan_start_time", - DateUtil.beginOfDay(DateUtil.parse(surveyTestQueryParam.getSearchBeginTime())), - DateUtil.endOfDay(DateUtil.parse(surveyTestQueryParam.getSearchEndTime()))) + if (Objects.nonNull(surveyTestQueryParam.getSearchBeginTime()) && Objects.nonNull(surveyTestQueryParam.getSearchEndTime())) { + //添加上时间范围 + surveyTestVOQueryWrapper.and(wrapper -> + wrapper.between("supervision_survey_plan.plan_start_time", + DateUtil.beginOfDay(DateUtil.parse(surveyTestQueryParam.getSearchBeginTime())), + DateUtil.endOfDay(DateUtil.parse(surveyTestQueryParam.getSearchEndTime()))) .or(x-> //未完成的技术监督计划,也要展示出来,不受时间限制 x.isNull("supervision_survey_test.complete_time") - .le("supervision_survey_plan.plan_start_time", surveyTestQueryParam.getSearchBeginTime()) + .le("supervision_survey_plan.plan_start_time", surveyTestQueryParam.getSearchBeginTime()) ) .or(x-> x.between("supervision_survey_test.complete_time", DateUtil.beginOfDay(DateUtil.parse(surveyTestQueryParam.getSearchBeginTime())), DateUtil.endOfDay(DateUtil.parse(surveyTestQueryParam.getSearchEndTime()))) ) - ); - + ); + } //根据工程名称模糊搜索 if (Objects.nonNull(surveyTestQueryParam.getSearchValue())) { LambdaQueryWrapper surveyPlanLambdaQueryWrapper = new LambdaQueryWrapper<>();