feat: 制修订流程征求意见选人特殊处理

laws-modules/src/main/java/com/jero/modules/activiti/service/ProcessNodeService.java

@@ -1,6 +1,7 @@
 package com.jero.modules.activiti.service;
 
 import cn.hutool.core.collection.CollStreamUtil;
+import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.jero.common.constant.enums.YesOrNoEnum;
@@ -8,6 +9,8 @@ import com.jero.modules.activiti.entity.ProcessModelNode;
 import com.jero.modules.activiti.entity.ProcessNode;
 import com.jero.modules.activiti.mapper.ProcessModelNodeMapper;
 import com.jero.modules.activiti.mapper.ProcessNodeMapper;
+import com.jero.modules.activiti.process.common.enums.ProcessType;
+import com.jero.modules.activiti.process.esRevision.entity.RevisionTaskNodeIdConstant;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -18,10 +21,10 @@ import javax.annotation.Resource;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
+import java.util.Objects;
 import java.util.stream.Collectors;
 
 /**
-  *
  * @author liJiaRao
  * @date 2023-09-26 15:12
  */
@@ -106,11 +109,63 @@ public class ProcessNodeService extends ServiceImpl<ProcessNodeMapper, ProcessNo
         wrapper.orderByAsc(ProcessNode::getSort);
         //List<ProcessNode> processNodeList = this.list(wrapper);
         List<ProcessNode> processNodeList = processNodeMapper.selectByIdPdIdAndPiId(processDefinitionId, processInstanceId);
+        // 制修订流程特殊处理
+        if (processDefinitionId.contains(ProcessType.ES_REVISION.getProcessKey())) {
+            specialProcessEsRevisionPre(processNodeList);
+        }
         // 可跳过节点判断
         processNodeList = processNodeList.stream().filter(v ->
                         YesOrNoEnum.NO.getValue().equals(v.getIsSkip())
                                 || (YesOrNoEnum.YES.getValue().equals(v.getIsSkip()) && StringUtils.isNotBlank(v.getLinkUserIds())))
                 .collect(Collectors.toList());
+        // 制修订流程特殊处理
+        if (processDefinitionId.contains(ProcessType.ES_REVISION.getProcessKey())) {
+            specialProcessEsRevisionEnd(processNodeList);
+        }
         return processNodeList;
     }
+
+    /**
+     * 前处理
+     * @param processNodeList
+     */
+    private void specialProcessEsRevisionPre(List<ProcessNode> processNodeList) {
+        String contactUser = null;
+        String adviceObject = null;
+        for (ProcessNode processNode : processNodeList) {
+            if (RevisionTaskNodeIdConstant.CONTACT_USER_DISTRIBUTE.equals(processNode.getXmlNodeId())) {
+                contactUser = processNode.getLinkUserIds();
+            }
+            if (RevisionTaskNodeIdConstant.ADVICE.equals(processNode.getXmlNodeId())) {
+                adviceObject = processNode.getLinkUserIds();
+            }
+        }
+        if (StrUtil.isNotBlank(contactUser) && StrUtil.isBlank(adviceObject)) {
+            processNodeList.forEach(r -> {
+                if (RevisionTaskNodeIdConstant.ADVICE.equals(r.getXmlNodeId())) {
+                    r.setLinkUserIds("tempUser");
+                }
+            });
+        }
+    }
+
+    /**
+     * 后处理
+     * @param processNodeList
+     */
+    private void specialProcessEsRevisionEnd(List<ProcessNode> processNodeList) {
+        String adviceObject = null;
+        for (ProcessNode processNode : processNodeList) {
+            if (RevisionTaskNodeIdConstant.ADVICE.equals(processNode.getXmlNodeId())) {
+                adviceObject = processNode.getLinkUserIds();
+            }
+        }
+        if ("tempUser".equals(adviceObject)) {
+            processNodeList.forEach(r -> {
+                if (RevisionTaskNodeIdConstant.ADVICE.equals(r.getXmlNodeId())) {
+                    r.setLinkUserIds(null);
+                }
+            });
+        }
+    }
 }