From b898d3275b4282d6849be108262da0391c87b211 Mon Sep 17 00:00:00 2001
From: konbai <1527468660@qq.com>
Date: Thu, 12 May 2022 01:46:24 +0800
Subject: [PATCH] =?UTF-8?q?add=20--=20=E6=B5=81=E7=A8=8B=E8=AE=BE=E8=AE=A1?=
 =?UTF-8?q?=E6=B7=BB=E5=8A=A0"=E4=BC=9A=E7=AD=BE"=E5=92=8C"=E6=88=96?=
 =?UTF-8?q?=E7=AD=BE"=E6=96=B9=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../handler/MultiInstanceHandler.java         | 64 +++++++++++++++
 .../plugins/package/penal/PropertiesPanel.vue |  2 +-
 .../penal/task/task-components/UserTask.vue   | 80 ++++++++++++++++++-
 3 files changed, 142 insertions(+), 4 deletions(-)
 create mode 100644 ruoyi-system/src/main/java/com/ruoyi/workflow/handler/MultiInstanceHandler.java

diff --git a/ruoyi-system/src/main/java/com/ruoyi/workflow/handler/MultiInstanceHandler.java b/ruoyi-system/src/main/java/com/ruoyi/workflow/handler/MultiInstanceHandler.java
new file mode 100644
index 00000000..bdac85de
--- /dev/null
+++ b/ruoyi-system/src/main/java/com/ruoyi/workflow/handler/MultiInstanceHandler.java
@@ -0,0 +1,64 @@
+package com.ruoyi.workflow.handler;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.ObjectUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.ruoyi.common.core.domain.entity.SysUser;
+import com.ruoyi.common.utils.spring.SpringUtils;
+import com.ruoyi.flowable.common.constant.ProcessConstants;
+import com.ruoyi.system.mapper.SysUserMapper;
+import com.ruoyi.system.mapper.SysUserRoleMapper;
+import lombok.AllArgsConstructor;
+import org.flowable.bpmn.model.FlowElement;
+import org.flowable.bpmn.model.UserTask;
+import org.flowable.engine.delegate.DelegateExecution;
+import org.springframework.stereotype.Component;
+
+import java.util.HashSet;
+import java.util.LinkedHashSet;
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * 多实例处理类
+ *
+ * @author KonBAI
+ */
+@AllArgsConstructor
+@Component("multiInstanceHandler")
+public class MultiInstanceHandler {
+
+    public HashSet<String> getUserIds(DelegateExecution execution) {
+        HashSet<String> candidateUserIds = new LinkedHashSet<>();
+        FlowElement flowElement = execution.getCurrentFlowElement();
+        if (ObjectUtil.isNotEmpty(flowElement) && flowElement instanceof UserTask) {
+            UserTask userTask = (UserTask) flowElement;
+            String dataType = userTask.getAttributeValue(ProcessConstants.NAMASPASE, ProcessConstants.PROCESS_CUSTOM_DATA_TYPE);
+            if ("USERS".equals(dataType) && CollUtil.isNotEmpty(userTask.getCandidateUsers())) {
+                candidateUserIds.addAll(userTask.getCandidateUsers());
+            } else if (CollUtil.isNotEmpty(userTask.getCandidateGroups())) {
+                List<String> groups = userTask.getCandidateGroups()
+                    .stream().map(item -> item.substring(4)).collect(Collectors.toList());
+                if ("ROLES".equals(dataType)) {
+                    SysUserRoleMapper userRoleMapper = SpringUtils.getBean(SysUserRoleMapper.class);
+                    groups.forEach(item -> {
+                        List<String> userIds = userRoleMapper.selectUserIdsByRoleId(Long.parseLong(item))
+                            .stream().map(String::valueOf).collect(Collectors.toList());
+                        candidateUserIds.addAll(userIds);
+                    });
+                } else if ("DEPTS".equals(dataType)) {
+                    SysUserMapper userMapper = SpringUtils.getBean(SysUserMapper.class);
+                    LambdaQueryWrapper<SysUser> lambdaQueryWrapper = new LambdaQueryWrapper<SysUser>()
+                        .select(SysUser::getUserId);
+                    groups.forEach(item -> {
+                        List<String> userIds = userMapper.selectList(lambdaQueryWrapper.eq(SysUser::getDeptId, Long.parseLong(item)))
+                            .stream().map(k -> String.valueOf(k.getDeptId())).collect(Collectors.toList());
+                        candidateUserIds.addAll(userIds);
+                    });
+
+                }
+            }
+        }
+        return candidateUserIds;
+    }
+}
diff --git a/ruoyi-ui/src/plugins/package/penal/PropertiesPanel.vue b/ruoyi-ui/src/plugins/package/penal/PropertiesPanel.vue
index 2aca9ed6..443000a2 100644
--- a/ruoyi-ui/src/plugins/package/penal/PropertiesPanel.vue
+++ b/ruoyi-ui/src/plugins/package/penal/PropertiesPanel.vue
@@ -21,7 +21,7 @@
         <div slot="title" class="panel-tab__title"><i class="el-icon-s-claim"></i>任务</div>
         <element-task :id="elementId" :type="elementType" />
       </el-collapse-item>
-      <el-collapse-item name="multiInstance" v-if="elementType.indexOf('Task') !== -1" key="multiInstance">
+      <el-collapse-item name="multiInstance" v-if="elementType.indexOf('Task') !== -1 && elementType !== 'UserTask'" key="multiInstance">
         <div slot="title" class="panel-tab__title"><i class="el-icon-s-help"></i>多实例</div>
         <element-multi-instance :business-object="elementBusinessObject" :type="elementType" />
       </el-collapse-item>
diff --git a/ruoyi-ui/src/plugins/package/penal/task/task-components/UserTask.vue b/ruoyi-ui/src/plugins/package/penal/task/task-components/UserTask.vue
index bb68446c..deee7766 100644
--- a/ruoyi-ui/src/plugins/package/penal/task/task-components/UserTask.vue
+++ b/ruoyi-ui/src/plugins/package/penal/task/task-components/UserTask.vue
@@ -1,6 +1,7 @@
 <template>
-  <div style="margin-top: 16px">
+  <div>
     <el-row>
+      <h4><b>审批人设置</b></h4>
       <el-radio-group v-model="dataType" @change="changeDataType">
         <el-radio label="USERS">指定用户</el-radio>
         <el-radio label="ROLES">角色</el-radio>
@@ -47,6 +48,17 @@
         </tree-select>
       </div>
     </el-row>
+    <el-row>
+      <div v-show="showMultiFlog">
+        <el-divider />
+        <h4><b>多实例审批方式</b></h4>
+        <el-radio-group v-model="multiLoopType" @change="changeMultiLoopType">
+          <el-row><el-radio label="Null">无</el-radio></el-row>
+          <el-row><el-radio label="SequentialMultiInstance">会签（需所有审批人同意）</el-radio></el-row>
+          <el-row><el-radio label="ParallelMultiInstance">或签（一名审批人同意即可）</el-radio></el-row>
+        </el-radio-group>
+      </div>
+    </el-row>
 
     <!-- 候选用户弹窗 -->
     <el-dialog title="候选用户" :visible.sync="userOpen" width="60%" append-to-body>
@@ -118,6 +130,15 @@ const userTaskForm = {
   // priority: ''
 }
 
+const multiInstanceForm = {
+  completionCondition: "",
+  loopCardinality: "",
+  extensionElements: [],
+  asyncAfter: false,
+  asyncBefore: false,
+  exclusive: false
+}
+
 export default {
   name: "UserTask",
   props: {
@@ -151,7 +172,9 @@ export default {
       // 查询参数
       queryParams: {
         deptId: undefined
-      }
+      },
+      showMultiFlog: false,
+      multiLoopType: 'Null',
     };
   },
   watch: {
@@ -197,6 +220,7 @@ export default {
           }
         });
       }
+      this.getElementLoop(bpmnElementObj);
     },
     updateElementTask() {
       const taskAttr = Object.create(null);
@@ -298,10 +322,14 @@ export default {
         userTaskForm.assignee = data.userId;
         userTaskForm.text = data.nickName;
         userTaskForm.candidateUsers = null;
+        this.showMultiFlog = false;
+        this.multiLoopType = 'Null';
+        this.changeMultiLoopType(this.multiLoopType);
       } else {
         userTaskForm.candidateUsers = this.selectedUserDate.map(k => k.userId).join() || null;
         userTaskForm.text = this.selectedUserDate.map(k => k.nickName).join() || null;
         userTaskForm.assignee = null;
+        this.showMultiFlog = true;
       }
       this.updateElementTask()
       this.userOpen = false;
@@ -372,7 +400,53 @@ export default {
         userTaskForm.text = "流程发起人";
       }
       this.updateElementTask();
-    }
+      if (val === 'ROLES' || val === 'DEPTS' || (val === 'USERS' && userTaskForm.text.indexOf(',') > 0)) {
+        this.showMultiFlog = true;
+      } else {
+        this.showMultiFlog = false;
+      }
+      this.multiLoopType = 'Null';
+      this.changeMultiLoopType(this.multiLoopType);
+    },
+    getElementLoop(businessObject) {
+      if (!businessObject.loopCharacteristics) {
+        this.multiLoopType = "Null";
+        return;
+      }
+      if (businessObject.loopCharacteristics.isSequential) {
+        this.multiLoopType = "SequentialMultiInstance";
+      } else {
+        this.multiLoopType = "ParallelMultiInstance";
+      }
+    },
+    changeMultiLoopType(type) {
+      // 取消多实例配置
+      if (type === "Null") {
+        window.bpmnInstances.modeling.updateProperties(this.bpmnElement, { loopCharacteristics: null });
+        return;
+      }
+      // 完成条件
+      let completionCondition = null;
+      // 会签
+      if (type === "SequentialMultiInstance") {
+        this.multiLoopInstance = window.bpmnInstances.moddle.create("bpmn:MultiInstanceLoopCharacteristics", { isSequential: true });
+        completionCondition = window.bpmnInstances.moddle.create("bpmn:FormalExpression", { body: '${nrOfCompletedInstances >= nrOfInstances}' });
+      }
+      // 或签
+      if (type === "ParallelMultiInstance") {
+        this.multiLoopInstance = window.bpmnInstances.moddle.create("bpmn:MultiInstanceLoopCharacteristics");
+        completionCondition = window.bpmnInstances.moddle.create("bpmn:FormalExpression", { body: '${nrOfCompletedInstances > 0}' });
+      }
+      // 更新多实例配置
+      window.bpmnInstances.modeling.updateProperties(this.bpmnElement, {
+        loopCharacteristics: this.multiLoopInstance
+      });
+      // 更新模块属性信息
+      window.bpmnInstances.modeling.updateModdleProperties(this.bpmnElement, this.multiLoopInstance, {
+        collection: '${multiInstanceHandler.getUserIds(execution)}',
+        completionCondition
+      });
+    },
   }
 };
 </script>