工作流Activiti初体验【一】

2024-06-24 13:32
文章标签 工作 初体验 activiti

本文主要是介绍工作流Activiti初体验【一】,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在这里记录一下我的Activiti历程:(以下示例不涉及真实业务,所有逻辑均建立在学习的基础上)

bpmn图
bpmn

发起任务我设置了一个权限组user1,只要是这个权限的用户都可以发起任务
权限组
分发任务我设置了一个用户组,用户组中每个用户都可以处理这步流程,只要有一个人处理这步任务,分发的流程就算结束了
分发任务
分发任务这一环节还有个判断,允许任务下发和不允许任务下发
判断
任务分发完成则来到子流程,每个被分到任务的人需要执行任务,所以需要派生出多个实例。子流程里面用户集users包含着每一个user
子流程
子流程里面开始的事件需要接收用户参数生产每个实例
执行任务
后面的步骤跟前面差不多,就不细说了


代码部分

配置文件xml

<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsd"><!-- 配置流程引擎配置对象 --><bean id="processEngineConfiguration"class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration"><property name="jdbcDriver" value="com.mysql.cj.jdbc.Driver" /><property name="jdbcUrl" value="jdbc:mysql://127.0.0.1:3306/activiti?characterEncoding=utf8&amp;useSSL=false&amp;nullCatalogMeansCurrent=true" /><property name="jdbcUsername" value="root" /><property name="jdbcPassword" value="MySQLadmin1!" /><!-- 建表策略:若没有工作流表则创建,若存在工作流表则更新 --><property name="databaseSchemaUpdate" value="true" /></bean><!-- 配置一个流程引擎工厂bean,用于创建流程引擎对象 --><bean id="processEngine" class="org.activiti.spring.ProcessEngineFactoryBean"><!-- 通过set方法注入流程引擎配置对象 --><property name="processEngineConfiguration" ref="processEngineConfiguration" /></bean>
</beans>

ActivitiConfig.java

package com.avanty.activiti;import org.activiti.engine.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class ActivitiConfig {/*** 配合xml配置文件使用*/@Beanpublic ProcessEngine processEngine() {String resource = "activiti/activitiConfig.xml";String beanName = "processEngineConfiguration";ProcessEngineConfiguration conf = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource(resource, beanName);return conf.buildProcessEngine();}/*** @Bean可以用xml配置,也可以代码配置* @Bean public ProcessEngine processEngine() { //创建Activiti配置对象实例*       ProcessEngineConfiguration configuration =*       ProcessEngineConfiguration.createStandaloneInMemProcessEngineConfiguration();*       configuration.setJdbcDriver("com.mysql.cj.jdbc.Driver");*       configuration.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/activiti?characterEncoding=utf8&useSSL=false&nullCatalogMeansCurrent=true");*       configuration.setJdbcUsername("root");*       configuration.setJdbcPassword("MySQLadmin1!"); //设置建表策略*       configuration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);*       //得到引擎实例 return configuration.buildProcessEngine(); }*/@Beanpublic RepositoryService repositoryService(ProcessEngine processEngine) {return processEngine.getRepositoryService();}@Beanpublic RuntimeService runtimeService(ProcessEngine processEngine) {return processEngine.getRuntimeService();}@Beanpublic TaskService taskService(ProcessEngine processEngine) {return processEngine.getTaskService();}@Beanpublic HistoryService historyService(ProcessEngine processEngine) {return processEngine.getHistoryService();}@Beanpublic ManagementService managementService(ProcessEngine processEngine) {return processEngine.getManagementService();}@Beanpublic IdentityService identityService(ProcessEngine processEngine) {return processEngine.getIdentityService();}}

用来测试的DeployActiviti.java

package com.avanty.activiti;import org.activiti.engine.ProcessEngine;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.RuntimeService;
import org.activiti.engine.TaskService;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
import org.activiti.engine.task.TaskQuery;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component;import java.io.InputStream;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;@Component
public class DeployActiviti implements ApplicationRunner {/*** 流程部署相关表 `ACT_RE_DEPLOYMENT` `ACT_RE_MODEL` `ACT_GE_BYTEARRAY`* `ACT_GE_PROPERTY` `ACT_RE_PROCDEF`*//*** 流程运行相关表 `ACT_RU_EXECUTION` `ACT_RU_IDENTITYLINK` `ACT_RU_JOB` `ACT_RU_TASK`* `ACT_RU_VARIABLE`*//*** 流程历史相关表 `ACT_HI_IDENTITYLINK` `ACT_HI_VARINST` `ACT_HI_ACTINST`* `ACT_HI_TASKINST`*//*** TaskQuery taskQuery = taskService.createTaskQuery();* taskQuery.taskCandidateGroupIn(roleList);* taskQuery.taskCandidateOrAssigned(usrnames);* taskQuery.includeProcessVariables(); taskList = taskQuery.list();*/@AutowiredProcessEngine processEngine;@AutowiredRuntimeService runtimeService;@AutowiredTaskService taskService;@Overridepublic void run(ApplicationArguments args) {finish();}private void deployProcess() {RepositoryService service = processEngine.getRepositoryService();InputStream bpmn = this.getClass().getResourceAsStream("/activiti/Process.bpmn");Deployment deployment = service.createDeployment().name("任务流程").addInputStream("Process.bpmn", bpmn).deploy();System.out.println(deployment.getName());System.out.println(deployment.getId());}/*** 发起任务*/private void step1() {String processInstanceByKey = "Process";ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(processInstanceByKey);System.out.println(processInstance.getId());}/*** 查看发起任务*/private void findStep1() {TaskQuery taskQuery = taskService.createTaskQuery();List<String> roleCodeList = new ArrayList<>();roleCodeList.add("user1");taskQuery.taskCandidateGroupIn(roleCodeList);taskQuery.includeProcessVariables();List<Task> tasks = taskQuery.list();for (Task task : tasks) {System.out.println(task.getId());System.out.println(task.getProcessInstanceId());System.out.println(task.getName());System.out.println(task.getAssignee());}}/*** 分发任务*/private void step2() {TaskQuery taskQuery = taskService.createTaskQuery();List<String> roleCodeList = new ArrayList<>();roleCodeList.add("user1");taskQuery.taskCandidateGroupIn(roleCodeList);taskQuery.includeProcessVariables();Task task = taskQuery.singleResult();Map<String, Object> variables = new HashMap<>();List<String> users = new ArrayList<>();users.add("Michael");users.add("Zhan");variables.put("users", users);taskService.complete(task.getId(), variables);System.out.println("finish");}/*** 查看分发任务*/private void findStep2() {String assignee = "Zhan";// String assignee = "Michael";List<Task> tasks1 = taskService.createTaskQuery().taskCandidateUser(assignee).list();for (Task task1 : tasks1) {System.out.println(task1.getId());System.out.println(task1.getName());}}/*** 子流程-执行任务*/private void step3() {TaskQuery taskQuery = taskService.createTaskQuery();taskQuery.taskCandidateOrAssigned("Michael");taskQuery.includeProcessVariables();Task task = taskQuery.singleResult();System.out.println(task.getId());Map<String, Object> variables = new HashMap<>();List<String> users = new ArrayList<>();users.add("admin");users.add("root");variables.put("users", users);variables.put("isPass", 1);taskService.complete(task.getId(), variables);System.out.println("finish");}/*** 子流程-查看执行任务*/private void findStep3() {String assignee = "admin";
//		String assignee = "root";List<Task> tasks = taskService.createTaskQuery().taskCandidateOrAssigned(assignee).list();for (Task task : tasks) {System.out.println(task.getId());System.out.println(task.getProcessInstanceId());System.out.println(task.getName());}}/*** 子流程-验收任务*/private void step4() {String assignee = "admin";Task task = taskService.createTaskQuery().taskCandidateOrAssigned(assignee).singleResult();System.out.println(task.getId());Map<String, Object> variables = new HashMap<>();List<String> users = new ArrayList<>();if (assignee.equals("root")) {users.add("administrator");users.add("su");}else if(assignee.equals("admin")) {users.add("alex");users.add("sudo");}variables.put("users", users);taskService.complete(task.getId(), variables);System.out.println("finish");}/*** 子流程-查看验收任务*/private void findStep4() {
//		 String assignee = "administrator";
//		String assignee = "su";
//		String assignee = "alex";String assignee = "sudo";List<Task> tasks = taskService.createTaskQuery().taskCandidateOrAssigned(assignee).list();for (Task task : tasks) {System.out.println(task.getId());System.out.println(task.getProcessInstanceId());System.out.println(task.getName());}}/*** 子流程-完成*/private void finish() {String assignee = "alex";Task task = taskService.createTaskQuery().taskCandidateOrAssigned(assignee).singleResult();Map<String, Object> variables = new HashMap<>();variables.put("isPass", 1);taskService.complete(task.getId(), variables);System.out.println("finish");}}

最后,附上项目地址 Activiti-Test
项目是用Eclipse写的,不用IDEA的原因是Eclipse的Activiti插件比IDEA的好,有自动对齐功能,强迫症的福音呐!

这篇关于工作流Activiti初体验【一】的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1090286

相关文章

SpringBoot集成LiteFlow工作流引擎的完整指南

《SpringBoot集成LiteFlow工作流引擎的完整指南》LiteFlow作为一款国产轻量级规则引擎/流程引擎,以其零学习成本、高可扩展性和极致性能成为微服务架构下的理想选择,本文将详细讲解Sp... 目录一、LiteFlow核心优势二、SpringBoot集成实战三、高级特性应用1. 异步并行执行2

Spring @Scheduled注解及工作原理

《Spring@Scheduled注解及工作原理》Spring的@Scheduled注解用于标记定时任务,无需额外库,需配置@EnableScheduling,设置fixedRate、fixedDe... 目录1.@Scheduled注解定义2.配置 @Scheduled2.1 开启定时任务支持2.2 创建

SpringBoot整合Flowable实现工作流的详细流程

《SpringBoot整合Flowable实现工作流的详细流程》Flowable是一个使用Java编写的轻量级业务流程引擎,Flowable流程引擎可用于部署BPMN2.0流程定义,创建这些流程定义的... 目录1、流程引擎介绍2、创建项目3、画流程图4、开发接口4.1 Java 类梳理4.2 查看流程图4

LiteFlow轻量级工作流引擎使用示例详解

《LiteFlow轻量级工作流引擎使用示例详解》:本文主要介绍LiteFlow是一个灵活、简洁且轻量的工作流引擎,适合用于中小型项目和微服务架构中的流程编排,本文给大家介绍LiteFlow轻量级工... 目录1. LiteFlow 主要特点2. 工作流定义方式3. LiteFlow 流程示例4. LiteF

SpringBoot集成LiteFlow实现轻量级工作流引擎的详细过程

《SpringBoot集成LiteFlow实现轻量级工作流引擎的详细过程》LiteFlow是一款专注于逻辑驱动流程编排的轻量级框架,它以组件化方式快速构建和执行业务流程,有效解耦复杂业务逻辑,下面给大... 目录一、基础概念1.1 组件(Component)1.2 规则(Rule)1.3 上下文(Conte

详解如何使用Python构建从数据到文档的自动化工作流

《详解如何使用Python构建从数据到文档的自动化工作流》这篇文章将通过真实工作场景拆解,为大家展示如何用Python构建自动化工作流,让工具代替人力完成这些数字苦力活,感兴趣的小伙伴可以跟随小编一起... 目录一、Excel处理:从数据搬运工到智能分析师二、PDF处理:文档工厂的智能生产线三、邮件自动化:

基于Python开发一个有趣的工作时长计算器

《基于Python开发一个有趣的工作时长计算器》随着远程办公和弹性工作制的兴起,个人及团队对于工作时长的准确统计需求日益增长,本文将使用Python和PyQt5打造一个工作时长计算器,感兴趣的小伙伴可... 目录概述功能介绍界面展示php软件使用步骤说明代码详解1.窗口初始化与布局2.工作时长计算核心逻辑3

RabbitMQ工作模式中的RPC通信模式详解

《RabbitMQ工作模式中的RPC通信模式详解》在RabbitMQ中,RPC模式通过消息队列实现远程调用功能,这篇文章给大家介绍RabbitMQ工作模式之RPC通信模式,感兴趣的朋友一起看看吧... 目录RPC通信模式概述工作流程代码案例引入依赖常量类编写客户端代码编写服务端代码RPC通信模式概述在R

Go 语言中的select语句详解及工作原理

《Go语言中的select语句详解及工作原理》在Go语言中,select语句是用于处理多个通道(channel)操作的一种控制结构,它类似于switch语句,本文给大家介绍Go语言中的select语... 目录Go 语言中的 select 是做什么的基本功能语法工作原理示例示例 1:监听多个通道示例 2:带

kotlin中的模块化结构组件及工作原理

《kotlin中的模块化结构组件及工作原理》本文介绍了Kotlin中模块化结构组件,包括ViewModel、LiveData、Room和Navigation的工作原理和基础使用,本文通过实例代码给大家... 目录ViewModel 工作原理LiveData 工作原理Room 工作原理Navigation 工