From 53d014edd19f57125c355abe71ec5b478500e610 Mon Sep 17 00:00:00 2001
From: 无关风月 <443237572@qq.com>
Date: 星期二, 05 八月 2025 09:57:40 +0800
Subject: [PATCH] 保洁巡检所有代码
---
ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/WorkbenchesController.java | 149 ++++++++++++++++++++++++++++++++++++++++++-------
1 files changed, 128 insertions(+), 21 deletions(-)
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/WorkbenchesController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/WorkbenchesController.java
index 5501de8..231298c 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/WorkbenchesController.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/WorkbenchesController.java
@@ -260,9 +260,20 @@
map.put("totalLocationNum", locationList.size());
}
// 超级管理员 查询所有的任务列表
- List<TTask> taskList = new ArrayList<>();
+ List<TTask> taskList = taskCleanService.list(Wrappers.lambdaQuery(TTask.class)
+ .in(TTask::getPatrolInspector, userId));
if(CollectionUtils.isEmpty(query.getProjectId())){
- taskList = taskCleanService.list(Wrappers.lambdaQuery(TTask.class));
+ // 查询点位类型
+// if(StringUtils.isNotEmpty(query.getLocationTypeId())){
+// // 查询点位
+// List<TLocation> locationList = locationService.list(Wrappers.lambdaQuery(TLocation.class)
+// .in(TLocation::getLocationType, query.getLocationTypeId()));
+// if(!CollectionUtils.isEmpty(locationList)){
+// List<String> locationIds = locationList.stream().map(TLocation::getId).collect(Collectors.toList());
+// taskList = taskCleanService.list(Wrappers.lambdaQuery(TTask.class)
+// .in(TTask::getLocationId, locationIds));
+// }
+// }
// 查询所有项目部的任务列表
List<TProjectDept> tProjectDeptList = projectDeptService.list(Wrappers.lambdaQuery(TProjectDept.class)
.eq(TProjectDept::getStatus, 1));
@@ -461,10 +472,21 @@
}
}
// 超级管理员 查询所有的任务列表
- List<TTask> taskList = new ArrayList<>();
+ List<TTask> taskList = taskCleanService.list(Wrappers.lambdaQuery(TTask.class)
+ .in(TTask::getPatrolInspector, userId));
if(CollectionUtils.isEmpty(query.getProjectId())){
- taskList = taskCleanService.list(Wrappers.lambdaQuery(TTask.class)
- .between(TTask::getImplementTime, query.getStartTime(), query.getEndTime()));
+ // 查询点位类型
+// if(StringUtils.isNotEmpty(query.getLocationTypeId())){
+// // 查询点位
+// List<TLocation> locationList = locationService.list(Wrappers.lambdaQuery(TLocation.class)
+// .in(TLocation::getLocationType, query.getLocationTypeId()));
+// if(!CollectionUtils.isEmpty(locationList)){
+// List<String> locationIds = locationList.stream().map(TLocation::getId).collect(Collectors.toList());
+// taskList = taskCleanService.list(Wrappers.lambdaQuery(TTask.class)
+// .in(TTask::getLocationId, locationIds)
+// .between(TTask::getImplementTime, query.getStartTime(), query.getEndTime()));
+// }
+// }
// 查询所有项目部的任务列表
List<TProjectDept> tProjectDeptList = projectDeptService.list(Wrappers.lambdaQuery(TProjectDept.class)
.eq(TProjectDept::getStatus, 1));
@@ -537,7 +559,17 @@
List<String> taskIds = tasks.stream().map(TTask::getId).collect(Collectors.toList());
List<TTaskDetail> taskDetails = tTaskDetailService.list(Wrappers.lambdaQuery(TTaskDetail.class)
.in(TTaskDetail::getTaskId, taskIds)
+ .eq(TTaskDetail::getHandleType,1)
.orderByDesc(TTaskDetail::getCreateTime));
+ taskDetails = new ArrayList<>(taskDetails.stream()
+ .collect(Collectors.groupingBy(
+ TTaskDetail::getTaskId,
+ Collectors.collectingAndThen(
+ Collectors.toList(),
+ listAll -> listAll.get(0)
+ )
+ ))
+ .values());
int qualifiedWarn = 0;
for (TTask task : list) {
TTaskDetail tTaskDetail = taskDetails.stream().filter(taskDetail -> taskDetail.getTaskId().equals(task.getId())).findFirst().orElse(null);
@@ -574,7 +606,11 @@
if(tTasks.isEmpty()){
taskSituationDayVO.setCompleteRate(BigDecimal.ZERO);
}else {
- taskSituationDayVO.setCompleteRate(new BigDecimal(qualifiedWarnChild).divide(new BigDecimal(taskSituationDayVO.getCompletedNum()), 2, RoundingMode.HALF_DOWN));
+ if (taskSituationDayVO.getCompletedNum() != 0){
+ taskSituationDayVO.setCompleteRate(new BigDecimal(qualifiedWarnChild).divide(new BigDecimal(taskSituationDayVO.getCompletedNum()), 2, RoundingMode.HALF_DOWN));
+ }else{
+ taskSituationDayVO.setCompleteRate(BigDecimal.ZERO);
+ }
}
taskSituationDayVOList.add(taskSituationDayVO);
}
@@ -596,6 +632,9 @@
String startTime = LocalDate.now() + " 00:00:00";
String endTime = LocalDate.now() + " 23:59:59";
// wrapper.between(TTask::getImplementTime, startTime, endTime);
+
+ List<TTask> result = new ArrayList<>();
+
if (userId != 1L) {
// 查询点位类型
if(StringUtils.isNotEmpty(query.getLocationTypeId())){
@@ -678,6 +717,20 @@
}
}
+ for (TTask task : list) {
+ TLocation tLocation = locations.stream().filter(location -> location.getId().equals(task.getLocationId())).findFirst().orElse(null);
+ if(Objects.nonNull(tLocation)) {
+ task.setLocationName(tLocation.getLocationName());
+ }
+ }
+
+ for (TEarlyWarning earlyWarning : earlyWarnings) {
+ List<TTask> tTasks = list.stream().filter(task -> earlyWarning.getTaskId().contains(task.getId())).collect(Collectors.toList());
+ tTasks.forEach(task -> {
+ task.setWarningType(earlyWarning.getWarningType());
+ });
+ result.addAll(tTasks);
+ }
// List<TTask> result = list.stream().filter(task -> task.getStatus() == 2).collect(Collectors.toList());
// List<TTask> tasks = list.stream().filter(task -> task.getStatus() == 1 || task.getStatus() == 2).collect(Collectors.toList());
// if(CollectionUtils.isEmpty(tasks)){
@@ -701,13 +754,7 @@
// }
// }
// }
-// for (TTask task : result) {
-// TLocation tLocation = locations.stream().filter(location -> location.getId().equals(task.getLocationId())).findFirst().orElse(null);
-// if(Objects.nonNull(tLocation)) {
-// task.setLocationName(tLocation.getLocationName());
-// }
-// }
- return R.ok(list);
+ return R.ok(result);
}else {
// 超级管理员
// 查询点位类型
@@ -722,8 +769,19 @@
}
// 超级管理员 查询所有的任务列表
List<TTask> taskList = taskCleanService.list(Wrappers.lambdaQuery(TTask.class)
- .between(TTask::getImplementTime, startTime, endTime));
+ .in(TTask::getPatrolInspector, userId));
if(CollectionUtils.isEmpty(query.getProjectId())){
+ // 查询点位类型
+// if(StringUtils.isNotEmpty(query.getLocationTypeId())){
+// // 查询点位
+// List<TLocation> locationList = locationService.list(Wrappers.lambdaQuery(TLocation.class)
+// .in(TLocation::getLocationType, query.getLocationTypeId()));
+// if(!CollectionUtils.isEmpty(locationList)){
+// List<String> locationIds = locationList.stream().map(TLocation::getId).collect(Collectors.toList());
+// taskList = taskCleanService.list(Wrappers.lambdaQuery(TTask.class)
+// .in(TTask::getLocationId, locationIds).between(TTask::getImplementTime, startTime, endTime));
+// }
+// }
// 查询所有项目部的任务列表
List<TProjectDept> tProjectDeptList = projectDeptService.list(Wrappers.lambdaQuery(TProjectDept.class)
.eq(TProjectDept::getStatus, 1));
@@ -767,6 +825,21 @@
}
}
+ for (TTask task : list) {
+ TLocation tLocation = locations.stream().filter(location -> location.getId().equals(task.getLocationId())).findFirst().orElse(null);
+ if(Objects.nonNull(tLocation)) {
+ task.setLocationName(tLocation.getLocationName());
+ }
+ }
+
+ for (TEarlyWarning earlyWarning : earlyWarnings) {
+ List<TTask> tTasks = list.stream().filter(task -> earlyWarning.getTaskId().contains(task.getId())).collect(Collectors.toList());
+ tTasks.forEach(task -> {
+ task.setWarningType(earlyWarning.getWarningType());
+ });
+ result.addAll(tTasks);
+ }
+
// List<TTask> result = list.stream().filter(task -> task.getStatus() == 2).collect(Collectors.toList());
// List<TTask> tasks = list.stream().filter(task -> task.getStatus() == 1 || task.getStatus() == 2).collect(Collectors.toList());
// if(CollectionUtils.isEmpty(tasks)){
@@ -796,7 +869,7 @@
// task.setLocationName(tLocation.getLocationName());
// }
// }
- return R.ok(list);
+ return R.ok(result);
}
}
@@ -892,9 +965,20 @@
}
}
// 超级管理员 查询所有的任务列表
- List<TTask> taskList = new ArrayList<>();
+ List<TTask> taskList = taskCleanService.list(Wrappers.lambdaQuery(TTask.class)
+ .in(TTask::getPatrolInspector, userId));
if(CollectionUtils.isEmpty(query.getProjectId())){
- taskList = taskCleanService.list(Wrappers.lambdaQuery(TTask.class));
+ // 查询点位类型
+// if(StringUtils.isNotEmpty(query.getLocationTypeId())){
+// // 查询点位
+// List<TLocation> locationList = locationService.list(Wrappers.lambdaQuery(TLocation.class)
+// .in(TLocation::getLocationType, query.getLocationTypeId()));
+// if(!CollectionUtils.isEmpty(locationList)){
+// List<String> locationIds = locationList.stream().map(TLocation::getId).collect(Collectors.toList());
+// taskList = taskCleanService.list(Wrappers.lambdaQuery(TTask.class)
+// .in(TTask::getLocationId, locationIds));
+// }
+// }
// 查询所有项目部的任务列表
List<TProjectDept> tProjectDeptList = projectDeptService.list(Wrappers.lambdaQuery(TProjectDept.class)
.eq(TProjectDept::getStatus, 1));
@@ -1052,9 +1136,20 @@
}
}
// 超级管理员 查询所有的任务列表
- List<TTask> taskList = new ArrayList<>();
+ List<TTask> taskList = taskCleanService.list(Wrappers.lambdaQuery(TTask.class)
+ .in(TTask::getPatrolInspector, userId));
if(CollectionUtils.isEmpty(query.getProjectId())){
- taskList = taskCleanService.list(Wrappers.lambdaQuery(TTask.class));
+ // 查询点位类型
+// if(StringUtils.isNotEmpty(query.getLocationTypeId())){
+// // 查询点位
+// List<TLocation> locationList = locationService.list(Wrappers.lambdaQuery(TLocation.class)
+// .in(TLocation::getLocationType, query.getLocationTypeId()));
+// if(!CollectionUtils.isEmpty(locationList)){
+// List<String> locationIds = locationList.stream().map(TLocation::getId).collect(Collectors.toList());
+// taskList = taskCleanService.list(Wrappers.lambdaQuery(TTask.class)
+// .in(TTask::getLocationId, locationIds));
+// }
+// }
// 查询所有项目部的任务列表
List<TProjectDept> tProjectDeptList = projectDeptService.list(Wrappers.lambdaQuery(TProjectDept.class)
.eq(TProjectDept::getStatus, 1));
@@ -1229,6 +1324,7 @@
analysisUnqualifiedCleaningDetailVO.setCount(tTaskDetails.size());
analysisUnqualifiedCleaningDetailVOS.add(analysisUnqualifiedCleaningDetailVO);
}
+ analysisUnqualifiedCleaningDetailVOS.sort(Comparator.comparingInt(AnalysisUnqualifiedCleaningDetailVO::getCount).reversed());
analysisUnqualifiedCleaningVO.setAnalysisUnqualifiedCleaningDetailVOS(analysisUnqualifiedCleaningDetailVOS);
}else {
// 超级管理员
@@ -1243,9 +1339,20 @@
}
}
// 超级管理员 查询所有的任务列表
- List<TTask> taskList = new ArrayList<>();
+ List<TTask> taskList = taskCleanService.list(Wrappers.lambdaQuery(TTask.class)
+ .in(TTask::getPatrolInspector, userId));
if(CollectionUtils.isEmpty(query.getProjectId())){
- taskList = taskCleanService.list(Wrappers.lambdaQuery(TTask.class));
+ // 查询点位类型
+// if(StringUtils.isNotEmpty(query.getLocationTypeId())){
+// // 查询点位
+// List<TLocation> locationList = locationService.list(Wrappers.lambdaQuery(TLocation.class)
+// .in(TLocation::getLocationType, query.getLocationTypeId()));
+// if(!CollectionUtils.isEmpty(locationList)){
+// List<String> locationIds = locationList.stream().map(TLocation::getId).collect(Collectors.toList());
+// taskList = taskCleanService.list(Wrappers.lambdaQuery(TTask.class)
+// .in(TTask::getLocationId, locationIds));
+// }
+// }
// 查询所有项目部的任务列表
List<TProjectDept> tProjectDeptList = projectDeptService.list(Wrappers.lambdaQuery(TProjectDept.class)
.eq(TProjectDept::getStatus, 1));
--
Gitblit v1.7.1