| | |
| | | import springfox.documentation.annotations.ApiIgnore; |
| | | import java.util.Map; |
| | | import java.util.List; |
| | | import java.util.Set; |
| | | import java.util.stream.Collectors; |
| | | import javax.servlet.http.HttpServletResponse; |
| | | |
| | | /** |
| | |
| | | wrapper.or().like("candidate_num",deptId).or().like("candidate_num",userId); |
| | | IPage<EvaluateTaskEntity> pages = evaluateTaskService.page(Condition.getPage(query), wrapper); |
| | | |
| | | // 处理获取当前部门的用户 |
| | | // 处理获取当前部门的用户 type为0时 |
| | | List<EvaluateTaskVO> records = EvaluateTaskWrapper.build().listVO(pages.getRecords()); |
| | | for (EvaluateTaskVO vo: records) { |
| | | if (vo.getType() == 0) { |
| | | List<CandidateJsonObj> candidateJsonObjs = JSONArray.parseArray(JSON.toJSONString(vo.getCandidateNum()),CandidateJsonObj.class); |
| | | for (CandidateJsonObj obj:candidateJsonObjs) { |
| | | if (deptId.equals(obj.getDeptId()) && obj.getUsers().size() > 0) { |
| | | vo.setSelfCandidate(obj.getUsers()); |
| | | break; |
| | | } else if(deptId.equals(obj.getDeptId()) && obj.getUsers().size() == 0) { |
| | | QueryWrapper<User> userQueryWrapper = new QueryWrapper<>(); |
| | | userQueryWrapper.like("dept_id", deptId); |
| | | List<User> users = userService.list(userQueryWrapper); |
| | | |
| | | for (CandidateJsonObj obj:candidateJsonObjs) { |
| | | if (deptId.equals(obj.getDeptId()) && obj.getUsers().size() > 0) { |
| | | |
| | | //处理自己部门用户 |
| | | List<Object> commonItems = obj.getUsers().stream() |
| | | .filter(item1 -> users.stream() |
| | | .anyMatch(item2 -> item1.getId().equals(item2.getId()))) |
| | | .collect(Collectors.toList()); |
| | | |
| | | vo.setSelfCandidate(commonItems); |
| | | |
| | | break; |
| | | } else if(deptId.equals(obj.getDeptId()) && obj.getUsers().size() == 0) { |
| | | |
| | | vo.setSelfCandidate(users); |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | |
| | | } |
| | | IPage<EvaluateTaskVO> pageVo = new Page<>(pages.getCurrent(), pages.getSize(), pages.getTotal()); |