| | |
| | | |
| | | 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.enums.BusinessType; |
| | |
| | | List<SysUser> sysUsers = sysUserService.selectAllList(); |
| | | List<TLocation> locationList = locationService.list(); |
| | | if (StringUtils.hasLength(query.getDeptName())){ |
| | | List<String> projectIds = projectDeptService.lambdaQuery().like(TProjectDept::getProjectName, query.getDeptName()).list() |
| | | List<TProjectDept> list = projectDeptService.lambdaQuery().like(TProjectDept::getProjectName, query.getDeptName()).list(); |
| | | List<String> listIds = projectDeptService.lambdaQuery().like(TProjectDept::getProjectName, query.getDeptName()).list() |
| | | .stream().map(TProjectDept::getId).collect(Collectors.toList()); |
| | | for (TProjectDept tProjectDept : list) { |
| | | if (tProjectDept.getParentId().equals("0")){ |
| | | List<String> collect = projectDeptService.lambdaQuery().eq(TProjectDept::getParentId, tProjectDept.getId()).list() |
| | | .stream().map(TProjectDept::getId).collect(Collectors.toList()); |
| | | listIds.addAll(collect); |
| | | } |
| | | } |
| | | List<String> deptIds = deptService.lambdaQuery().like(TDept::getDeptName, query.getDeptName()).list() |
| | | .stream().map(TDept::getId).collect(Collectors.toList()); |
| | | projectIds.addAll(deptIds); |
| | | if (projectIds.isEmpty()){ |
| | | return R.ok(new PageInfo<>()); |
| | | listIds.addAll(deptIds); |
| | | if (listIds.isEmpty()){ |
| | | listIds.add("0"); |
| | | } |
| | | query.setPatrolInspectorIds(sysUsers.stream().filter(e->listIds.contains(e.getDeptId())).map(SysUser::getUserId) |
| | | .collect(Collectors.toList())); |
| | | if (StringUtils.hasLength(query.getPhonenumber())){ |
| | | List<Long> patrolInspectorIds = sysUsers.stream().filter(sysUser -> |
| | | sysUser.getPhonenumber().equals(query.getPhonenumber()) |
| | | && projectIds.contains(sysUser.getDeptId()) |
| | | && listIds.contains(sysUser.getDeptId()) |
| | | ).map(SysUser::getUserId).collect(Collectors.toList()); |
| | | if (patrolInspectorIds.isEmpty()){ |
| | | return R.ok(new PageInfo<>()); |
| | |
| | | } |
| | | if (query.getClearStatus()!=null){ |
| | | List<String> collect = tTaskDetailService.lambdaQuery().eq(TTaskDetail::getClearStatus, query.getClearStatus()) |
| | | .list().stream().distinct().map(TTaskDetail::getTaskId).collect(Collectors.toList()); |
| | | .eq(TTaskDetail::getHandleType,1) |
| | | .groupBy(TTaskDetail::getTaskId) |
| | | .orderByDesc(BaseModel::getCreateTime) |
| | | .list().stream().map(TTaskDetail::getTaskId).collect(Collectors.toList()); |
| | | |
| | | query.setTaskIds(collect); |
| | | if (collect.isEmpty()){ |
| | | return R.ok(new PageInfo<>()); |
| | |
| | | query.setLocationIds(collect); |
| | | return R.ok(new PageInfo<>()); |
| | | }else{ |
| | | collect = collect.stream().filter(query.getLocationIds()::contains).collect(Collectors.toList()); |
| | | if (collect.isEmpty()){ |
| | | return R.ok(new PageInfo<>()); |
| | | if (query.getLocationIds()!=null){ |
| | | collect = collect.stream().filter(query.getLocationIds()::contains).collect(Collectors.toList()); |
| | | if (collect.isEmpty()){ |
| | | return R.ok(new PageInfo<>()); |
| | | } |
| | | } |
| | | query.setLocationIds(collect); |
| | | } |