
多喝灬丶烫水
V1
2023/05/22阅读:12主题:默认主题
flowable动态创建多级流程模板
flowable动态创建多级流程模板
-
引入Maven依赖
<dependency>
<groupId>org.flowable</groupId>
<artifactId>flowable-spring-boot-starter</artifactId>
<version>6.6.0</version>
</dependency> -
动态创建流程节点工具类
/**
* 动态创建流程节点
*/
@Slf4j
@Component
@RequiredArgsConstructor
public class FlowableBpmnHandler {
/**
* 创建开始节点信息
*
* @return
*/
public static FlowElement createStartFlowElement(String id, String name) {
StartEvent startEvent = new StartEvent();
startEvent.setId(id);
startEvent.setName(name);
return startEvent;
}
/**
* 创建结束节点信息
*
* @param id
* @param name
* @return
*/
public static FlowElement createEndFlowElement(String id, String name) {
EndEvent endEvent = new EndEvent();
endEvent.setId(id);
endEvent.setName(name);
return endEvent;
}
/**
* 循环创建普通任务节点信息
*
* @param processEntity 流程实体
* @return
*/
public static List<UserTask> createCommonUserTask(ProcessEntity processEntity) {
List<ProcessNode> processNodes = processEntity.getProcessNodeList();
List<UserTask> userTaskList = Lists.newLinkedList();
for (int i = 0; i < processNodes.size(); i++) {
ProcessNode node = processNodes.get(i);
node.setNodeId(UUIDHelper.randomUUID());
node.setNodeLevel(i + 1);
UserTask userTask = new UserTask();
userTask.setId(TypeEnum.getProcessKey(processEntity.getType()) + "_task_" + node.getNodeId());
userTask.setCategory(String.valueOf(i + 1));
userTask.setDocumentation(i == processNodes.size() - 1 ? "true" : "false");
userTask.setName(node.getNodeName());
userTaskList.add(userTask);
}
return userTaskList;
}
/**
* 创建排它网关节点
*
* @return
*/
public static ExclusiveGateway createExclusiveGateway(Integer i) {
ExclusiveGateway gateway = new ExclusiveGateway();
gateway.setName("getaway_name_" + i);
gateway.setId("getaway_id_" + i);
return gateway;
}
} -
动态创建流程模板工具类
/**
* 动态创建流程模板
*
* @author ll
* @date 2023/04/19 14:28
**/
@Slf4j
@Component
public class DynamicProcessDefinition {
@Resource
private RepositoryService repositoryService;
public String createProcessDefinition(ProcessEntity processEntity) {
//数据校验:传入的数据节点字段:流程配置id、节点id、节点顺序、节点描述
List<ProcessNode> nodeList = processEntity.getProcessNodeList();
if (CollUtil.isEmpty(nodeList)) {
throw new RuntimeException("流程节点不能少于一个,请配置发起人节点和至少一个审批节点");
}
BpmnModel bpmnModel = new BpmnModel();
Process process = new Process();
bpmnModel.addProcess(process);
// 流程标识
process.setId(TypeEnum.getProcessKey(processEntity.getType()));
process.setName(TypeEnum.getProcessKey(processEntity.getType()));
//开始事件
FlowElement startEvent = FlowableBpmnHandler.createStartFlowElement("start", "开始");
process.addFlowElement(startEvent);
//结束事件--任务正常完成
FlowElement endEvent = FlowableBpmnHandler.createEndFlowElement("end", "结束");
process.addFlowElement(endEvent);
//创建用户节点任务
List<UserTask> userTaskList = FlowableBpmnHandler.createCommonUserTask(processEntity);
//构建流程模板
buildProcessTemplate(process, startEvent, endEvent, userTaskList);
//该流程的流程xml字符串
//BpmnXMLConverter bpmnXMLConverter = new BpmnXMLConverter();
//byte[] convertToXML = bpmnXMLConverter.convertToXML(bpmnModel);
//String bytes = new String(convertToXML);
//log.info("该流程的流程xml为:{}", bytes);
// 创建一个新的部署
Deployment deploy = repositoryService.createDeployment().key(TypeEnum.getProcessKey(processEntity.getType()))
.name(TypeEnum.getProcessKey(processEntity.getType()))
.addBpmnModel(TypeEnum.getProcessKey(processEntity.getType()) + ".bpmn", bpmnModel)
.deploy();
log.info("部署id:{}", deploy.getId());
return deploy.getId();
}
/**
* 构建流程模板
*
* @param process
* @param startEvent
* @param endEvent
* @param userTaskList
* @return void
* @author ll
* @date 2023/04/24 08:53
*/
private void buildProcessTemplate(Process process, FlowElement startEvent, FlowElement endEvent, List<UserTask> userTaskList) {
for (int i = 0; i < userTaskList.size(); i++) {
//用户任务
UserTask userTask = userTaskList.get(i);
process.addFlowElement(userTask);
//创建排它网关节点
ExclusiveGateway exclusiveGateway = FlowableBpmnHandler.createExclusiveGateway(i);
process.addFlowElement(exclusiveGateway);
//开始事件到第一个节点
if (i == 0) {
// 开始节点到第一级节点
SequenceFlow startSequenceFlow = new SequenceFlow(startEvent.getId(), userTask.getId());
process.addFlowElement(startSequenceFlow);
}
//用户任务到网关节点
SequenceFlow sequenceFlow = new SequenceFlow(userTask.getId(), exclusiveGateway.getId());
sequenceFlow.setName(userTask.getName() + "_开始审批");
process.addFlowElement(sequenceFlow);
//同意:取下一步用户任务的节点id,可能为结束节点或者用户任务节点
String nextUserTaskId = endEvent.getId();
if (userTaskList.size() - i > 1) {
nextUserTaskId = userTaskList.get(i + 1).getId();
}
SequenceFlow sequenceFlowAgree = new SequenceFlow(exclusiveGateway.getId(), nextUserTaskId);
sequenceFlowAgree.setConditionExpression("${auditResult}");
sequenceFlowAgree.setName("同意");
process.addFlowElement(sequenceFlowAgree);
//不同意:回退到上一步,取上一步的节点id
String preUserTaskId = userTaskList.get(0).getId();
if (i != 0) {
preUserTaskId = userTaskList.get(i - 1).getId();
}
SequenceFlow sequenceFlowRefuse = new SequenceFlow(exclusiveGateway.getId(), preUserTaskId);
sequenceFlowRefuse.setConditionExpression("${!auditResult}");
sequenceFlowRefuse.setName("拒绝");
process.addFlowElement(sequenceFlowRefuse);
}
}
} -
保存流程配置模板的接口
@Resource
private DynamicProcessDefinition dynamicProcessDefinition;
@RequestMapping("/save")
public Result<String> save(@RequestBody ProcessEntity processEntity) {
return dynamicProcessDefinition.createProcessDefinition(processEntity);;
} -
开启流程接口
@RequestMapping("/start")
public String start(@RequestBody AuditData auditData) {
//业务自己定义key
String businessKey = auditData.getBusinessKey();
//流程定义key
String processKey = auditData.getType();
// 判断是否启动流程
boolean isStartProcess = null != runtimeService.createProcessInstanceQuery()
.processDefinitionKey(processKey)
.processInstanceBusinessKey(businessKey)
.singleResult();
if (!isStartProcess) {
//记录开启流程的用户
HashMap<String, Object> variable = Maps.newHashMap();
//启动流程
ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(processKey, businessKey, variable);
log.info("启动流程实例成功:processInstanceId={}", processInstance.getId());
}
return !isStartProcess ? "流程启动成功" : "流程启动失败";
}
作者介绍

多喝灬丶烫水
V1