QR/laws_chery_serve
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix:87473

Browse Source
This commit is contained in:
梁琦涛
2024-07-26 13:50:46 +08:00
parent abb8a06f4c
commit 8b02102e6a
1 changed files with 12 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/service/ProcessAllService.java
+12 -1
View File
@@ -298,7 +298,7 @@ public class ProcessAllService extends ServiceImpl<ProcessAllMapper, ProcessAll>
} }
@Transactional(rollbackFor = JeroBootException.class) @Transactional(rollbackFor = JeroBootException.class)
public void delegateTask(DelegateTaskParam param) { public synchronized void delegateTask(DelegateTaskParam param) {
String taskId = param.getTaskId(); String taskId = param.getTaskId();
String userId = param.getUserId(); String userId = param.getUserId();
Integer prcType = param.getPrcType(); Integer prcType = param.getPrcType();
@@ -326,6 +326,17 @@ public class ProcessAllService extends ServiceImpl<ProcessAllMapper, ProcessAll>
if(Objects.isNull(processNode)){ if(Objects.isNull(processNode)){
throw new JeroBootException("数据不存在"); throw new JeroBootException("数据不存在");
} }
// 不可重复加签
LambdaQueryWrapper<ProcessNodeLink> queryProcessNodeLink = new LambdaQueryWrapper<>();
queryProcessNodeLink.eq(ProcessNodeLink::getProcessDefinitionId,processDefinitionId);
queryProcessNodeLink.eq(ProcessNodeLink::getProcessNodeId,processNode.getId());
queryProcessNodeLink.eq(ProcessNodeLink::getProcessDefinitionId, processDefinitionId);
queryProcessNodeLink.eq(ProcessNodeLink::getUserId,userId);
long l = processNodeLinkService.count(queryProcessNodeLink);
if(l > 0){
throw new JeroBootException("加签人员重复");
}
processNodeLink.setProcessNodeId(processNode.getId()); processNodeLink.setProcessNodeId(processNode.getId());
processNodeLink.setUserId(userId); processNodeLink.setUserId(userId);
processNodeLinkService.save(processNodeLink); processNodeLinkService.save(processNodeLink);