| 提交 | 用户 | 时间 | ||
| e7c126 | 1 | package com.iailab.module.bpm.framework.flowable.core.behavior; |
| H | 2 | |
| 3 | import cn.hutool.core.collection.CollUtil; | |
| 4 | import cn.hutool.core.lang.Assert; | |
| 5 | import cn.hutool.core.util.RandomUtil; | |
| 6 | import com.iailab.module.bpm.framework.flowable.core.candidate.BpmTaskCandidateInvoker; | |
| 7 | import lombok.Setter; | |
| 8 | import lombok.extern.slf4j.Slf4j; | |
| 9 | import org.flowable.bpmn.model.UserTask; | |
| 10 | import org.flowable.common.engine.impl.el.ExpressionManager; | |
| 11 | import org.flowable.engine.delegate.DelegateExecution; | |
| 12 | import org.flowable.engine.impl.bpmn.behavior.UserTaskActivityBehavior; | |
| 13 | import org.flowable.engine.impl.cfg.ProcessEngineConfigurationImpl; | |
| 14 | import org.flowable.engine.impl.util.TaskHelper; | |
| 15 | import org.flowable.task.service.TaskService; | |
| 16 | import org.flowable.task.service.impl.persistence.entity.TaskEntity; | |
| bb2880 | 17 | import org.springframework.transaction.annotation.Transactional; |
| e7c126 | 18 | |
| H | 19 | import java.util.List; |
| 20 | import java.util.Set; | |
| 21 | ||
| 22 | /** | |
| 23 | * 自定义的【单个】流程任务的 assignee 负责人的分配 | |
| 24 | * 第一步，基于分配规则，计算出分配任务的【单个】候选人。如果找不到，则直接报业务异常，不继续执行后续的流程； | |
| 25 | * 第二步，随机选择一个候选人，则选择作为 assignee 负责人。 | |
| 26 | * | |
| 27 | * @author iailab | |
| 28 | */ | |
| 29 | @Slf4j | |
| 30 | public class BpmUserTaskActivityBehavior extends UserTaskActivityBehavior { | |
| 31 | ||
| 32 | @Setter | |
| 33 | private BpmTaskCandidateInvoker taskCandidateInvoker; | |
| 34 | ||
| 35 | public BpmUserTaskActivityBehavior(UserTask userTask) { | |
| 36 | super(userTask); | |
| 37 | } | |
| 38 | ||
| 39 | @Override | |
| bb2880 | 40 | @Transactional(rollbackFor = Exception.class) |
| e7c126 | 41 | protected void handleAssignments(TaskService taskService, String assignee, String owner, |
| bb2880 | 42 | List<String> candidateUsers, List<String> candidateGroups, TaskEntity task, ExpressionManager expressionManager, |
| H | 43 | DelegateExecution execution, ProcessEngineConfigurationImpl processEngineConfiguration) { |
| e7c126 | 44 | // 第一步，获得任务的候选用户 |
| H | 45 | Long assigneeUserId = calculateTaskCandidateUsers(execution); |
| 46 | // 第二步，设置作为负责人 | |
| bb2880 | 47 | if (assigneeUserId != null) { |
| H | 48 | TaskHelper.changeTaskAssignee(task, String.valueOf(assigneeUserId)); |
| 49 | } | |
| e7c126 | 50 | } |
| H | 51 | |
| 52 | private Long calculateTaskCandidateUsers(DelegateExecution execution) { | |
| 53 | // 情况一，如果是多实例的任务，例如说会签、或签等情况，则从 Variable 中获取。 | |
| 54 | // 顺序审批可见 BpmSequentialMultiInstanceBehavior，并发审批可见 BpmSequentialMultiInstanceBehavior | |
| 55 | if (super.multiInstanceActivityBehavior != null) { | |
| 56 | return execution.getVariable(super.multiInstanceActivityBehavior.getCollectionElementVariable(), Long.class); | |
| 57 | } | |
| 58 | ||
| 59 | // 情况二，如果非多实例的任务，则计算任务处理人 | |
| 60 | // 第一步，先计算可处理该任务的处理人们 | |
| bb2880 | 61 | Set<Long> candidateUserIds = taskCandidateInvoker.calculateUsersByTask(execution); |
| H | 62 | if (CollUtil.isEmpty(candidateUserIds)) { |
| 63 | return null; | |
| 64 | } | |
| e7c126 | 65 | // 第二步，后随机选择一个任务的处理人 |
| H | 66 | // 疑问：为什么一定要选择一个任务处理人？ |
| 67 | // 解答：项目对 bpm 的任务是责任到人，所以每个任务有且仅有一个处理人。 | |
| 68 | // 如果希望一个任务可以同时被多个人处理，可以考虑使用 BpmParallelMultiInstanceBehavior 实现的会签 or 或签。 | |
| 69 | int index = RandomUtil.randomInt(candidateUserIds.size()); | |
| 70 | return CollUtil.get(candidateUserIds, index); | |
| 71 | } | |
| 72 | ||
| 73 | } | |
