From 083c414ff683ab12e65069c6c0ba6871ed1ed09f Mon Sep 17 00:00:00 2001 From: 无关风月 <443237572@qq.com> Date: 星期六, 12 七月 2025 10:19:09 +0800 Subject: [PATCH] 保洁巡检本周代码 --- ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TLocationController.java | 51 ++++++++++++++++++++++++++++++++++++++++++--------- 1 files changed, 42 insertions(+), 9 deletions(-) diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TLocationController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TLocationController.java index 94562b9..289c532 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TLocationController.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TLocationController.java @@ -5,14 +5,18 @@ import cn.afterturn.easypoi.excel.ExcelImportUtil; import cn.afterturn.easypoi.excel.entity.ExportParams; import cn.afterturn.easypoi.excel.entity.ImportParams; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.ruoyi.common.annotation.Log; import com.ruoyi.common.basic.PageInfo; +import com.ruoyi.common.core.domain.BaseModel; import com.ruoyi.common.core.domain.R; import com.ruoyi.common.core.domain.entity.SysUser; import com.ruoyi.common.core.exception.ServiceException; import com.ruoyi.common.enums.BusinessType; import com.ruoyi.common.utils.WebUtils; import com.ruoyi.common.utils.bean.BeanUtils; +import com.ruoyi.framework.web.service.TokenService; import com.ruoyi.system.dto.LocationDTO; import com.ruoyi.system.importExcel.TLocationImportExcel; import com.ruoyi.system.model.*; @@ -72,6 +76,8 @@ private TDeptService deptService; @Resource private ISysUserService sysUserService; + @Resource + private TokenService tokenService; @ApiOperation(value = "点位管理分页列表") @PostMapping(value = "/pageList") @@ -130,10 +136,23 @@ .eq(query.getStatus() != null, TTask::getStatus, query.getStatus()) .in(query.getPatrolInspectorIds() != null && query.getPatrolInspectorIds().isEmpty(), TTask::getPatrolInspector, query.getPatrolInspectorIds()) .in(query.getTaskIds() != null && query.getTaskIds().isEmpty(), TTask::getId, query.getTaskIds()).list(); + List<String> collect = list.stream().map(TTask::getId).collect(Collectors.toList()); - list = list.stream().skip((long) (query.getPageNum() - 1) * query.getPageSize()).limit(query.getPageSize()).collect(Collectors.toList()); - pageInfo.setTotal(list.size()); List<LocationListTaskVO> res = new ArrayList<>(); + List<TTaskDetail> taskDetails = tTaskDetailService.list(Wrappers.lambdaQuery(TTaskDetail.class) + .in(TTaskDetail::getTaskId,collect) + .eq(TTaskDetail::getClearStatus, 2) + .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()); for (TTask tTask : list) { LocationListTaskVO temp = new LocationListTaskVO(); TLocation tLocation = locationList.stream().filter(e -> e.getId().equals(tTask.getLocationId())).findFirst().orElse(null); @@ -161,21 +180,32 @@ } } }); + locationTypeList.stream().filter(e -> e.getId().equals(tLocation.getLocationType())).findFirst() + .ifPresent(tLocationType -> temp.setLocationTypeName(tLocationType.getLocationName())); + } - TTaskDetail one = tTaskDetailService.lambdaQuery().eq(TTaskDetail::getTaskId, tTask.getId()) - .orderByDesc(TTaskDetail::getCreateTime).last("limit 1").one(); - if (one!=null){ - temp.setClearStatus(one.getClearStatus()); - temp.setPicture(one.getPicture()); + TTaskDetail tTaskDetail = taskDetails.stream().filter(e -> e.getTaskId().equals(tTask.getId())).findFirst().orElse(null); + if (tTaskDetail!=null){ + temp.setPicture(tTaskDetail.getPicture()); + temp.setClearStatus(tTaskDetail.getClearStatus()); + if (query.getClearStatus()!=null){ + if (query.getClearStatus().equals(tTaskDetail.getClearStatus())){ + res.add(temp); + } + }else{ + res.add(temp); + } } temp.setTaskType(tTask.getTaskType()); temp.setStatus(tTask.getStatus()); temp.setTaskId(tTask.getId()); temp.setImplementTime(tTask.getImplementTime()); - res.add(temp); + } + res = res.stream().skip((long) (query.getPageNum() - 1) * query.getPageSize()).limit(query.getPageSize()).collect(Collectors.toList()); + pageInfo.setTotal(res.size()); pageInfo.setRecords(res); - return R.ok(); + return R.ok(pageInfo); } @ApiOperation(value = "根据片区id查询保洁员列表 不分页") @GetMapping(value = "/listCleaner") @@ -187,6 +217,7 @@ public R<List<TLocation>> listLocation(@RequestParam String id) { return R.ok(locationService.lambdaQuery().eq(TLocation::getLocationCleaner,id).list()); } + @ApiOperation(value = "查询部门 项目部列表 不分页") @GetMapping(value = "/listDepts") public R<List<DeptNoLimitVO>> listDepts() { @@ -271,6 +302,8 @@ @GetMapping("/import-template") public void importTemplate() { List<TLocationImportExcel> locationImportExcels = new ArrayList<>(); + TLocationImportExcel tLocationImportExcel = new TLocationImportExcel(); + locationImportExcels.add(tLocationImportExcel); Workbook workbook = ExcelExportUtil.exportExcel(new ExportParams(), TLocationImportExcel.class, locationImportExcels); HttpServletResponse response = WebUtils.response(); ServletOutputStream outputStream = null; -- Gitblit v1.7.1