|
|
@ -70,24 +70,24 @@ public class SchBaseTaskServiceImpl extends ServiceImpl<SchBaseTaskMapper, SchBa |
|
|
|
String point_code = ObjectUtil.isNotEmpty(whereJson.get("point_code")) ? whereJson.get("point_code").toString() : null; |
|
|
|
String begin_time = ObjectUtil.isNotEmpty(whereJson.get("begin_time")) ? whereJson.get("begin_time").toString() : null; |
|
|
|
String end_time = ObjectUtil.isNotEmpty(whereJson.get("end_time")) ? whereJson.get("end_time").toString() : null; |
|
|
|
String more_task_status = ObjectUtil.isNotEmpty(whereJson.get("more_task_status")) ? whereJson.get("more_task_status").toString() : null; |
|
|
|
List<String> collect = ObjectUtil.isNotEmpty(more_task_status) ? Arrays.stream(more_task_status.split(",")).collect(Collectors.toList()) : null; |
|
|
|
String more_task_status = ObjectUtil.isNotEmpty(whereJson.get("task_status")) ? whereJson.get("task_status").toString() : null; |
|
|
|
String unFinished = null; |
|
|
|
if (collect != null) { |
|
|
|
if (collect.contains(TaskStatus.UNFINISHED.getCode())) { |
|
|
|
collect = null; |
|
|
|
if(ObjectUtil.isNotEmpty(more_task_status)){ |
|
|
|
if (more_task_status.contains(TaskStatus.UNFINISHED.getCode())) { |
|
|
|
unFinished = TaskStatus.EXECUTING.getCode(); |
|
|
|
more_task_status = ""; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
LambdaQueryWrapper<SchBaseTask> lam = new LambdaQueryWrapper<>(); |
|
|
|
lam.eq(ObjectUtil.isNotEmpty(task_code), SchBaseTask::getTask_code, task_code) |
|
|
|
.eq(ObjectUtil.isNotEmpty(vehicle_code), SchBaseTask::getVehicle_code, vehicle_code) |
|
|
|
.eq(ObjectUtil.isNotEmpty(point_code), SchBaseTask::getPoint_code1, point_code) |
|
|
|
.ge(ObjectUtil.isNotEmpty(begin_time), SchBaseTask::getCreate_time, begin_time) |
|
|
|
.le(ObjectUtil.isNotEmpty(end_time), SchBaseTask::getCreate_time, end_time) |
|
|
|
.in(ObjectUtil.isNotEmpty(collect), SchBaseTask::getTask_status, collect) |
|
|
|
.eq(ObjectUtil.isNotEmpty(more_task_status), SchBaseTask::getTask_status, more_task_status) |
|
|
|
.le(ObjectUtil.isNotEmpty(unFinished), SchBaseTask::getTask_status, unFinished) |
|
|
|
.orderByDesc(SchBaseTask::getUpdate_time); |
|
|
|
.orderByDesc(SchBaseTask::getCreate_time); |
|
|
|
IPage<SchBaseTask> pages = new Page<>(page.getPage() + 1, page.getSize()); |
|
|
|
schBaseTaskMapper.selectPage(pages, lam); |
|
|
|
return pages; |
|
|
|