ZQ/laws-sinotruk-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update 项目合规评估流程 提交时人员去重

Browse Source
This commit is contained in:
lijiarao
2023-12-18 15:18:03 +08:00
parent 73ec80b490
commit c731efbed2
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
laws-modules/src/main/java/com/jero/modules/activiti/process/projectassess/service/ProcessProjectAssessService.java
+4 -1
View File
@@ -5,6 +5,7 @@ import java.util.List;
import cn.hutool.core.collection.CollStreamUtil; import cn.hutool.core.collection.CollStreamUtil;
import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.stream.StreamUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.jero.common.api.vo.ResultCommon; import com.jero.common.api.vo.ResultCommon;
import com.jero.common.constant.CommonConstant; import com.jero.common.constant.CommonConstant;
@@ -479,6 +480,7 @@ public class ProcessProjectAssessService extends ServiceImpl<ProcessProjectAsses
if (moduleOwnerIds.isEmpty()) { if (moduleOwnerIds.isEmpty()) {
throw new JeroBootException(ResultCommon.ProjectAssess); throw new JeroBootException(ResultCommon.ProjectAssess);
} }
moduleOwnerIds = moduleOwnerIds.stream().distinct().collect(Collectors.toList());
processHandleService.saveNodeUserLink(processDTO.getProcessInstanceId(), ProcessProjectAssessCommon.GBMZGJLDXF, moduleOwnerIds); processHandleService.saveNodeUserLink(processDTO.getProcessInstanceId(), ProcessProjectAssessCommon.GBMZGJLDXF, moduleOwnerIds);
// 完成任务 // 完成任务
String taskId = processDTO.getTaskId(); String taskId = processDTO.getTaskId();
@@ -552,6 +554,7 @@ public class ProcessProjectAssessService extends ServiceImpl<ProcessProjectAsses
if (designEngineerIds.isEmpty()) { if (designEngineerIds.isEmpty()) {
throw new JeroBootException(ResultCommon.ProjectAssess); throw new JeroBootException(ResultCommon.ProjectAssess);
} }
designEngineerIds = designEngineerIds.stream().distinct().collect(Collectors.toList());
processHandleService.saveNodeUserLink(processDTO.getProcessInstanceId(), ProcessProjectAssessCommon.SJGCSPG, designEngineerIds); processHandleService.saveNodeUserLink(processDTO.getProcessInstanceId(), ProcessProjectAssessCommon.SJGCSPG, designEngineerIds);
// 完成任务 // 完成任务
String taskId = processDTO.getTaskId(); String taskId = processDTO.getTaskId();
@@ -656,7 +659,7 @@ public class ProcessProjectAssessService extends ServiceImpl<ProcessProjectAsses
break; break;
//模块负责人修改 //模块负责人修改
case ProcessProjectAssessCommon.MKFZRXG: case ProcessProjectAssessCommon.MKFZRXG:
nodeId = ProcessProjectAssessCommon.GBMZGJLDSP; nodeId = ProcessProjectAssessCommon.GBMZGJLDXF;
break; break;
default: default:
} }