From d2cf8a7f7bcf49ace058d9eec587d75c4f764a2e Mon Sep 17 00:00:00 2001
From: xieb <vip_xiaobin810@163.com>
Date: Tue, 02 Jan 2024 11:56:13 +0800
Subject: [PATCH] 考核任务设置被考核人
---
src/main/java/org/springblade/modules/evaluate/service/impl/EvaluateResultServiceImpl.java | 95 ++++++-----------------------------------------
1 files changed, 12 insertions(+), 83 deletions(-)
diff --git a/src/main/java/org/springblade/modules/evaluate/service/impl/EvaluateResultServiceImpl.java b/src/main/java/org/springblade/modules/evaluate/service/impl/EvaluateResultServiceImpl.java
index 2f0f5da..ab3a20c 100644
--- a/src/main/java/org/springblade/modules/evaluate/service/impl/EvaluateResultServiceImpl.java
+++ b/src/main/java/org/springblade/modules/evaluate/service/impl/EvaluateResultServiceImpl.java
@@ -23,6 +23,8 @@
import lombok.AllArgsConstructor;
import org.springblade.common.cache.SysCache;
import org.springblade.common.cache.UserCache;
+import org.springblade.core.redis.cache.BladeRedis;
+import org.springblade.core.tool.utils.Func;
import org.springblade.core.tool.utils.StringUtil;
import org.springblade.modules.assessment.wrapper.CandidateJsonObj;
import org.springblade.modules.assessment.wrapper.UserJsonObj;
@@ -49,6 +51,8 @@
import java.util.ArrayList;
import java.util.List;
+import static org.springblade.common.cache.CacheNames.EVALUATE_CANDIDATE_DEPT_KEY;
+
/**
* 评优结果 服务实现类
*
@@ -65,6 +69,8 @@
private final IEvaluateCandidateService evaluateCandidateService;
+ private final BladeRedis bladeRedis;
+
@Override
public IPage<EvaluateResultVO> selectEvaluateResultPage(IPage<EvaluateResultVO> page, EvaluateResultVO evaluateResult) {
return page.setRecords(baseMapper.selectEvaluateResultPage(page, evaluateResult));
@@ -73,6 +79,11 @@
@Override
public IPage<EvaluateResultVO> selectEvaluateResultGroupBeId(IPage<EvaluateResultVO> page, EvaluateResultVO evaluateResult,List<Long> userIds) {
return page.setRecords(EvaluateResultWrapper.build().listVO(baseMapper.selectEvaluateResultGroupBeId(page, evaluateResult, userIds)));
+ }
+
+ @Override
+ public IPage<EvaluateResultVO> selectEvaluateResultByScoreIdsGroupBeId(IPage<EvaluateResultVO> page, EvaluateResultVO evaluateResult, List<Long> scoreUserIds) {
+ return page.setRecords(EvaluateResultWrapper.build().listVO(baseMapper.selectEvaluateResultGroupBeId(page, evaluateResult, scoreUserIds)));
}
@Override
@@ -87,90 +98,8 @@
@Override
@Transactional
public boolean saveOrUpdate(EvaluateResultEntity evaluateResult) {
- boolean ret = super.saveOrUpdate(evaluateResult);
- // 是否评分完成判断此操作
- if (ret) {
- EvaluateTaskEntity taskPO = evaluateTaskService.getById(evaluateResult.getEvaluateTaskId());
-
- //判断评分是否完成 0:type 判断设置的部门员工是否完成评分 1：type 判断设置的部门是否完成评分
- if (evaluateResult.getType() == 0) {
- List<CandidateJsonObj> candidateJsonObjs = JSONArray.parseArray(JSON.toJSONString(taskPO.getCandidateNum()),CandidateJsonObj.class);
- List<Long> deptIds = new ArrayList<>();
- for (CandidateJsonObj obj:candidateJsonObjs) {
- deptIds.add(obj.getDeptId());
- }
-
- //根据部门获取所有用户数量
- QueryWrapper<User> queryWrapper = new QueryWrapper();
- queryWrapper.in("dept_id", deptIds);
- // 拿到设置部门所有用户数量
- Long userByDeptIdsCount = userService.count(queryWrapper);
-
- //用户数量和评优数据进行匹配 相同需要设置任务状态为已完成
- QueryWrapper<EvaluateResultEntity> resultEntityQueryWrapper = new QueryWrapper<>();
- resultEntityQueryWrapper.eq("evaluate_task_id", evaluateResult.getEvaluateTaskId());
- Long evaluateResultCount = count(resultEntityQueryWrapper);
-
- // 相同需要设置任务状态为已完成 不同不处理
- if (userByDeptIdsCount == evaluateResultCount) {
- taskPO.setCandidateState(2);//结束
- evaluateTaskService.updateById(taskPO);
-
- //保存候选人信息
- for (CandidateJsonObj obj:candidateJsonObjs) {
- Integer val = obj.getVal();
-
- Page<EvaluateResultVO> page = new Page<>();
- page.setCurrent(1);
- page.setSize(val);
- EvaluateResultVO vo = new EvaluateResultVO();
- vo.setType(0);
- vo.setEvaluateTaskId(evaluateResult.getEvaluateTaskId());
- List<Long> userIds = new ArrayList<>();
- for (UserJsonObj userJsonObj:obj.getUsers()) {
- userIds.add(userJsonObj.getId());
- }
-
- IPage<EvaluateResultVO> evaluateResultVOIPage = selectEvaluateResultGroupBeId(page,vo,userIds);
-
- for (EvaluateResultVO resultVO:evaluateResultVOIPage.getRecords()) {
- EvaluateCandidateEntity evaluateCandidate = new EvaluateCandidateEntity();
- evaluateCandidate.setEvaluateTaskId(evaluateResult.getEvaluateTaskId());
- evaluateCandidate.setEvaluateTaskName(taskPO.getTaskName());
- User user = UserCache.getUser(resultVO.getBeId());
- evaluateCandidate.setUserId(user.getId());
- evaluateCandidate.setUserName(user.getName());
- evaluateCandidate.setDeptName(SysCache.getDeptName(Long.valueOf(user.getDeptId())));
- evaluateCandidate.setPostName(SysCache.getPostName(Long.valueOf(user.getPostId())));
- evaluateCandidateService.save(evaluateCandidate);
- }
- }
-
- }
-
- } else if (evaluateResult.getType() == 1) {
- QueryWrapper<EvaluateResultEntity> resultEntityQueryWrapper = new QueryWrapper<>();
- resultEntityQueryWrapper.eq("evaluate_task_id", evaluateResult.getEvaluateTaskId());
- Long evaluateResultCount = count(resultEntityQueryWrapper);
-
- //部门评优数量和所有用户匹配 修改为选定的评定人
- List<CandidateJsonObj> candidateJsonObjs = JSONArray.parseArray(JSON.toJSONString(taskPO.getCandidateNum()),CandidateJsonObj.class);
- int setUserCount = 0;
- for (CandidateJsonObj obj:candidateJsonObjs) {
- List<UserJsonObj> userJsonObjs = obj.getUsers();
- setUserCount += userJsonObjs.size();
- }
-
- // 相同需要设置任务状态为已完成 不同不处理
- if (setUserCount == evaluateResultCount) {
- taskPO.setEvaluateState(2);//结束
- evaluateTaskService.updateById(taskPO);
- }
- }
- }
-
- return ret;
+ return super.saveOrUpdate(evaluateResult);
}
}
--
Gitblit v1.9.3