Flowable 单任务节点转会签节点
2019-05-17 本文已影响0人
爱_别离
在Flowable开发中可能需要把普通单人审批的任务节点转成会签节点 可以参考以下代码,代码是在当前节点把下一个普通节点转会签节点 直接上代码!
package com.luyang.service.workflow.business;
import com.luyang.framework.util.StringUtil;
import org.flowable.bpmn.model.Process;
import org.flowable.bpmn.model.*;
import org.flowable.common.engine.impl.el.ExpressionManager;
import org.flowable.engine.*;
import org.flowable.engine.impl.bpmn.behavior.ParallelMultiInstanceBehavior;
import org.flowable.engine.impl.bpmn.behavior.UserTaskActivityBehavior;
import org.flowable.engine.impl.cfg.ProcessEngineConfigurationImpl;
import org.flowable.task.api.Task;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
* 自定义 Flowable Api
* @author: Lu Yang
* @data: 2019-05-17 10:27
*/
@Component
public class FlowableApi {
/**
* 提供所有公开BPM和工作流操作服务的访问.
*/
// private final ProcessEngine processEngine;
/**
* 提供流程任务访问和表单操作服务.
*/
private final TaskService taskService;
/**
* 提供流程定义部署存储库访问服务.
*/
private final RepositoryService repositoryService;
@Autowired
public FlowableApi(RepositoryService repositoryService, TaskService taskService) {
this.repositoryService = repositoryService;
this.taskService = taskService;
}
/**
* 普通节点转会签节点.
* @author: Lu Yang
* @date: 2019-05-17 13:09
* @param processDefinitionId 流程定义ID.
* @param taskId 当前节点ID.
* @return: void
*/
public void toCountersign (String processDefinitionId, String taskId) {
if (StringUtil.isEmpty(processDefinitionId, taskId)) {
}
// 根据任务ID获取当前任务对象.
Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
if (null == task) {
}
// 根据流程定义ID获取流程bpmnModel.
BpmnModel bpmnModel = repositoryService.getBpmnModel(processDefinitionId);
// 获取当前流程对象.
Process process = bpmnModel.getProcesses().get(0);
// 根据当前节点ID获取对应任务节点对象.
UserTask currenUserTask = (UserTask) process.getFlowElement(task.getTaskDefinitionKey());
// 获取当前节点出线信息.
SequenceFlow sequenceFlow = currenUserTask.getOutgoingFlows().get(0);
// 根据当前节点出线信息获取下一节点元素.
FlowElement flowElement = process.getFlowElement(sequenceFlow.getTargetRef());
// 判断下一节点元素是否为任务节点.
if (!(flowElement instanceof UserTask)) {
}
// 配置会签所需条件.
MultiInstanceLoopCharacteristics multiInstanceLoopCharacteristics = new MultiInstanceLoopCharacteristics();
// 配置节点人员办理顺序 串行:true 并行:false.
multiInstanceLoopCharacteristics.setSequential(false);
// 配置会签集合变量名称.
multiInstanceLoopCharacteristics.setInputDataItem("${assigneeList}");
// 配置会签集合遍历名称.
multiInstanceLoopCharacteristics.setElementVariable("assignee");
// 将下一节点元素转换为任务节点对象.
UserTask nextUserTask = (UserTask) flowElement;
// 设置下一节点处理人表达式 引用会签条件activiti:elementVariable="assignee".
nextUserTask.setAssignee("${assignee}");
// 下一任务节点设置会签循环特征.
nextUserTask.setLoopCharacteristics(multiInstanceLoopCharacteristics);
// 获取流程引擎配置实现类.
ProcessEngineConfigurationImpl processEngineConfiguration = (ProcessEngineConfigurationImpl) ProcessEngines.getDefaultProcessEngine().getProcessEngineConfiguration();
// 创建新的任务实例.
UserTaskActivityBehavior userTaskActivityBehavior = processEngineConfiguration.getActivityBehaviorFactory().createUserTaskActivityBehavior(nextUserTask);
// 创建BPMN 2.0规范中描述的多实例功能.
ParallelMultiInstanceBehavior behavior = new ParallelMultiInstanceBehavior(nextUserTask, userTaskActivityBehavior);
// 设置下一节点多实例行为.
nextUserTask.setBehavior(behavior);
// 设置多实例元素变量.
behavior.setCollectionElementVariable("assignee");
// 注入表达式.
ExpressionManager expressionManager = processEngineConfiguration.getExpressionManager();
// 设置多实例集合表达式.
behavior.setCollectionExpression(expressionManager.createExpression("${assigneeList}"));
}
}