Springboot整合工作流引擎Activiti(一)

环境:Springboot2.2.11.RELEASE + Activiti7.1.0.M6 + MySQL

环境说明:

不要通过如下方式引包

<dependencyManagement> 		<dependencies> 			<dependency> 				<groupId>org.activiti.dependencies</groupId> 				<artifactId>activiti-dependencies</artifactId> 				<version>7.1.0.M6</version> 				<scope>import</scope> 				<type>pom</type> 			</dependency> 		</dependencies> </dependencyManagement>

如果通过上面的方式引入会有各种问题。

正确方式:

<dependencies> 		<dependency> 			<groupId>org.activiti.dependencies</groupId> 			<artifactId>activiti-dependencies</artifactId> 			<version>7.1.0.M6</version> 			<type>pom</type> 		</dependency> 		<dependency> 			<groupId>org.activiti</groupId> 			<artifactId>activiti-spring-boot-starter</artifactId> 			<version>7.1.0.M6</version> 		</dependency> 		<dependency> 			<groupId>org.springframework.boot</groupId> 			<artifactId>spring-boot-starter-security</artifactId> 		</dependency> 		<dependency> 			<groupId>org.springframework.boot</groupId> 			<artifactId>spring-boot-starter-web</artifactId> 		</dependency> 		<dependency> 			<groupId>org.mybatis.spring.boot</groupId> 			<artifactId>mybatis-spring-boot-starter</artifactId> 			<version>2.1.4</version> 		</dependency> 		<dependency> 			<groupId>mysql</groupId> 			<artifactId>mysql-connector-java</artifactId> 			<scope>runtime</scope> 		</dependency> 		<dependency> 			<groupId>org.springframework.boot</groupId> 			<artifactId>spring-boot-starter-test</artifactId> 			<scope>test</scope> 			<exclusions> 				<exclusion> 					<groupId>org.junit.vintage</groupId> 					<artifactId>junit-vintage-engine</artifactId> 				</exclusion> 			</exclusions> 		</dependency> </dependencies>

不知为何activit7中要吧这security强关联。。。

以上是pom.xml中所要引入的依赖。


所有的表:

Springboot整合工作流引擎Activiti(一)

ACT_RE_*: 'RE’表示repository。这个前缀的表包含了流程定义和流程 静态资源(图片、规则等等)

ACT_RU_*: 'RU’表示runtime。这些运行时的表,包含流程实例,认为,变量,异步任务等运行中的数据。Activiti只在流程实例执行过程中保持这些数据,在流程结束时就会删除这些记录。这样运行时表可以一直很小速度很快。

ACT_HI_*: 'HI’表示history。这些表包含历史数据,比如历史流程实例,遍历,任务等等。

ACT_GE_*: 'GE’表示general。通用数据,用于不同场景。

数据表分类

通用数据(act_ge_*)

Springboot整合工作流引擎Activiti(一)

流程定义(act_re_*)

Springboot整合工作流引擎Activiti(一)

来源网络

运行实例(act_ru_*)

Springboot整合工作流引擎Activiti(一)

来源网络

历史流程(act_hi_*)

Springboot整合工作流引擎Activiti(一)

来源网络

其他

Springboot整合工作流引擎Activiti(一)

来源网络


核心类

ProcessEngine

    流程引擎的抽象,可以通过此类获取需要的所有服务。

    通过ProcessEngine获取,Activiti将不同生命周期的服务封装在不同Service中,包括定义、部署、运行。通过服务类可获取相关生命周期中的服务信息。

TaskService

    流程运行过程中,每个任务节点的相关操作接口,如complete,delete,delegate等。
RepositoryService

    流程定义和部署相关的存储服务。
RuntimeService

    流程运行时相关的服务,如根据流程好启动流程实例startProcessInstanceByKey。
HistoryService

    历史记录相关服务接口。


关于eclipse中安装插件就不说了,我是把插件下载下来安装的,在线安装不上。

在src/main/resources下新建processes文件夹,springboot下默认的流程文件定义路径前缀及文件后缀如下:

Springboot整合工作流引擎Activiti(一)

这里可以在application.yml配置文件中更改。

设计一个请假的流程holiday.bpmn

Springboot整合工作流引擎Activiti(一)

<?xml version="1.0" encoding="UTF-8"?> <definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.pack.org">   <process id="holiday" name="holiday" isExecutable="true">     <startEvent id="startevent1" name="Start"></startEvent>     <endEvent id="endevent1" name="End"></endEvent>     <userTask id="usertask1" name="部门经理审批" activiti:assignee="${mgr}"></userTask>     <userTask id="usertask2" name="总经理审批" activiti:assignee="${top}"></userTask>     <sequenceFlow id="flow2" sourceRef="usertask1" targetRef="usertask2"></sequenceFlow>     <sequenceFlow id="flow3" sourceRef="usertask2" targetRef="endevent1"></sequenceFlow>     <userTask id="usertask3" name="填写审批单" activiti:assignee="${assignee}"></userTask>     <sequenceFlow id="flow4" sourceRef="startevent1" targetRef="usertask3"></sequenceFlow>     <sequenceFlow id="flow5" sourceRef="usertask3" targetRef="usertask1"></sequenceFlow>   </process>   <bpmndi:BPMNDiagram id="BPMNDiagram_holiday">     <bpmndi:BPMNPlane bpmnElement="holiday" id="BPMNPlane_holiday">       <bpmndi:BPMNShape bpmnElement="startevent1" id="BPMNShape_startevent1">         <omgdc:Bounds height="35.0" width="35.0" x="505.0" y="60.0"></omgdc:Bounds>       </bpmndi:BPMNShape>       <bpmndi:BPMNShape bpmnElement="endevent1" id="BPMNShape_endevent1">         <omgdc:Bounds height="35.0" width="35.0" x="505.0" y="550.0"></omgdc:Bounds>       </bpmndi:BPMNShape>       <bpmndi:BPMNShape bpmnElement="usertask1" id="BPMNShape_usertask1">         <omgdc:Bounds height="55.0" width="105.0" x="470.0" y="290.0"></omgdc:Bounds>       </bpmndi:BPMNShape>       <bpmndi:BPMNShape bpmnElement="usertask2" id="BPMNShape_usertask2">         <omgdc:Bounds height="55.0" width="105.0" x="470.0" y="420.0"></omgdc:Bounds>       </bpmndi:BPMNShape>       <bpmndi:BPMNShape bpmnElement="usertask3" id="BPMNShape_usertask3">         <omgdc:Bounds height="55.0" width="105.0" x="470.0" y="170.0"></omgdc:Bounds>       </bpmndi:BPMNShape>       <bpmndi:BPMNEdge bpmnElement="flow2" id="BPMNEdge_flow2">         <omgdi:waypoint x="522.0" y="345.0"></omgdi:waypoint>         <omgdi:waypoint x="522.0" y="420.0"></omgdi:waypoint>       </bpmndi:BPMNEdge>       <bpmndi:BPMNEdge bpmnElement="flow3" id="BPMNEdge_flow3">         <omgdi:waypoint x="522.0" y="475.0"></omgdi:waypoint>         <omgdi:waypoint x="522.0" y="550.0"></omgdi:waypoint>       </bpmndi:BPMNEdge>       <bpmndi:BPMNEdge bpmnElement="flow4" id="BPMNEdge_flow4">         <omgdi:waypoint x="522.0" y="95.0"></omgdi:waypoint>         <omgdi:waypoint x="522.0" y="170.0"></omgdi:waypoint>       </bpmndi:BPMNEdge>       <bpmndi:BPMNEdge bpmnElement="flow5" id="BPMNEdge_flow5">         <omgdi:waypoint x="522.0" y="225.0"></omgdi:waypoint>         <omgdi:waypoint x="522.0" y="290.0"></omgdi:waypoint>       </bpmndi:BPMNEdge>     </bpmndi:BPMNPlane>   </bpmndi:BPMNDiagram> </definitions>

上面的每一个节点(任务)都动态的指派了用户执行。

填写审批单:${assignee};

部门经理审批: ${mgr};

总经理审批:${top};

每一个节点执行完成时都需要指明下一个节点的执行人。

mybatis:   mapper-locations: classpath:mapper/*.xml   type-aliases-package: com.pack.domain server:   port: 8080 spring:   activiti:     check-process-definitions: true     db-history-used: true     history-level: full     database-schema-update: true   datasource:     driverClassName: com.mysql.cj.jdbc.Driver     url: jdbc:mysql://localhost:3306/activiti?serverTimezone=GMT%2B8     username: root     password: xxxxxx     type: com.zaxxer.hikari.HikariDataSource     hikari:       minimumIdle: 10       maximumPoolSize: 200       autoCommit: true       idleTimeout: 30000       poolName: MasterDatabookHikariCP       maxLifetime: 1800000       connectionTimeout: 30000       connectionTestQuery: SELECT 1

spring.activiti.db-history-used表示是用历史表,如果不设置为true那么只会生成17张表,只有设置为true后才会生成25张表。如果不生成历史表那么,流程图及运行节点无法展示。

spring.activiti.history-level:对于历史数据,保存到何种粒度,Activiti提供了history-level属性对其进行配置。history-level属性有点像log4j的日志输出级别,该属性有以下四个值:

  • none:不保存任何的历史数据,因此,在流程执行过程中,这是最高效的。
  • activity:级别高于none,保存流程实例与流程行为,其他数据不保存。
  • audit:除activity级别会保存的数据外,还会保存全部的流程任务及其属性。audit为history的默认值。
  • full:保存历史数据的最高级别,除了会保存audit级别的数据外,还会保存其他全部流程相关的细节数据,包括一些流程参数等。
  • spring.activiti.check-process-definitions:如果不设置为true,那么流程定义必须手动进行部署。


    sprint security配置,放行任何请求:

    @Configuration public class SecurityConfig extends WebSecurityConfigurerAdapter { 	 	@Override 	protected void configure(HttpSecurity http) throws Exception { 		http 			.csrf().disable() 			.authorizeRequests() 			.antMatchers("/**") 			.permitAll() ; 			 	} 	 }

    服务工具类HolidayService

    @Service public class HolidayService {  	private static final Logger logger = LoggerFactory.getLogger(HolidayService.class);  	@Resource 	private ProcessEngine processEngine; 	@Resource 	private RepositoryService repositoryService ; 	@Resource 	private RuntimeService runtimeService ; 	@Resource 	private TaskService taskService ;  	/** 	 * <p> 	 * 流程定义的部署 activiti表有哪些?  	 * act_re_deployment 流程定义部署表,记录流程部署信息  	 * act_re_procdef 流程定义表,记录流程定义信息  	 * act_ge_bytearray 资源表(bpmn文件及png文件) 	 * </p> 	 * <p>时间:2021年1月22日-下午3:33:00</p> 	 * @author xg 	 * @return void 	 */ 	public void createDeploy() { 		Deployment deployment = repositoryService.createDeployment() 				.addClasspathResource("processes/holiday.bpmn") 				.addClasspathResource("processes/holiday.png") 				.name("请假申请单流程") 				.key("holiday") 				.category("InnerP") 				.deploy(); 		logger.info("流程部署id: {}", deployment.getId()); 		logger.info("流程部署名称: {}", deployment.getName()); 	}   // 注意这里这个方法是当我们没有开启自动部署流程定义时,就需要手动部署。 	/** 	 * <p> 	 * 	流程定义查询 	 * </p> 	 * <p>时间:2021年1月22日-下午3:45:02</p> 	 * @author xg 	 * @param processDefinition 	 * @return void 	 */ 	public List<ProcessDefinition> queryProcessDefinitionByKey(String processDefinition) { 		// 查询流程定义 		ProcessDefinitionQuery processDefinitionQuery = repositoryService.createProcessDefinitionQuery(); 		List<ProcessDefinition> list = processDefinitionQuery.processDefinitionKey(processDefinition).list(); 		list.forEach(pd -> { 			logger.info("------------------------------------------------"); 			logger.info("流程部署id:{}", pd.getDeploymentId()); 			logger.info("流程定义id:{}", pd.getId()); 			logger.info("流程定义名称:{}", pd.getName()); 			logger.info("流程定义key:{}", pd.getKey()); 			logger.info("流程定义版本:{}", pd.getVersion()); 			logger.info("------------------------------------------------"); 		}); 		return list ; 	}  	/** 	 * <p> 	 * 	删除流程 	 * </p> 	 * <p>时间:2021年1月22日-下午4:21:40</p> 	 * @author xg 	 * @return void 	 */ 	public void deleteDeployment(String deploymentId) { 		// 设置true 级联删除流程定义,即使该流程有流程实例启动也可以删除,设置为false非级别删除方式,如果流程 		repositoryService.deleteDeployment(deploymentId, true); 	}  	/** 	 * <p> 	 * 	启动流程实例(比如用户根据定义好的流程发起一个流程的实例(这里的请假流程申请)) 	 * <p>时间:2021年1月22日-下午4:54:56</p> 	 * @author xg 	 * @return void 	 */ 	public void startProcessInstanceById(String processDefinitionId) { 		ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinitionId) ; 		logger.info("流程定义ID: {}", processInstance.getProcessDefinitionId()); 		logger.info("流程实例ID: {}", processInstance.getId()); 	} 	 	/** 	 * <p> 	 * 	启动流程实例,指定业务Key(方便关联业务数据)(比如用户根据定义好的流程发起一个流程的实例(这里的请假流程申请)) 	 * 	Businesskey(业务标识) 		启动流程实例时,指定的businesskey,就会在act_ru_execution #流程实例的执行表中存储businesskey。 		Businesskey:业务标识,通常为业务表的主键,业务标识和流程实例一一对应。业务标识来源于业务系统。存储业务标识就是根据业务标识来关联查询业务系统的数据。 		比如:请假流程启动一个流程实例,就可以将请假单的id作为业务标识存储到activiti中, 		将来查询activiti的流程实例信息就可以获取请假单的id从而关联查询业务系统数据库得到请假单信息。 	 * <p>时间:2021年1月22日-下午4:54:56</p> 	 * @author xg 	 * @return void 	 */ 	public void startProcessInstanceToBussinessKey(String processDefinitionId, String bussinessKey) { 		ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinitionId, bussinessKey); 		logger.info("流程定义ID: {}", processInstance.getProcessDefinitionId()); 		logger.info("流程实例ID: {}", processInstance.getId()); 		logger.info("BussinessKey: {}", processInstance.getBusinessKey()) ; 	} 	 	/** 	 *  <p> 	 *  	设置assignee的取值,用户可以在界面上设置流程的执行人 	 *  </p> 	 *  <p>时间:2021年1月22日-下午8:30:39</p> 	 * @author xg 	 * @param processDefinitionId  	 * @return void 	 */ 	public void startProcessInstanceAssignVariables(String processDefinitionId, Map<String, Object> variables) { 		ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinitionId, variables); 		logger.info("流程定义ID: {}", processInstance.getProcessDefinitionId()); 		logger.info("流程实例ID: {}", processInstance.getId()); 		logger.info("BussinessKey: {}", processInstance.getBusinessKey()) ; 	} 	 	/** 	 *  <p> 	 *  	查询指派关联的用户任务 	 *  </p> 	 *  <p>时间:2021年1月23日-上午11:39:56</p> 	 * @author xg 	 * @param assignee 关联用户 	 * @return List<Task> 	 */ 	public List<Task> queryTasks(String assignee) { 		TaskQuery query = taskService.createTaskQuery() ; 		return query.taskAssignee(assignee).orderByTaskCreateTime().asc().list() ; 	} 	 	public void executionTask(Map<String, Object> variables, String instanceId) { 		Task task = taskService.createTaskQuery().processInstanceId(instanceId).singleResult() ; 		if (task == null) { 			logger.error("任务【{}】不存在", instanceId) ; 			throw new RuntimeException("任务【" + instanceId + "】不存在") ; 		} 		taskService.complete(task.getId(), variables) ; 	}  }

    HolidayController接口

    @RestController @RequestMapping("/holidays") public class HolidayController { 	 	@Resource 	private HolidayService holidayService ; 	 	/** 	 *  <p>查询制定key的流程审批</p> 	 *  <p>时间:2021年1月23日-上午11:17:02</p> 	 * @author xg 	 * @param key ProcessDefinitionKey 	 * @return R 	 */ 	@GetMapping("") 	public R lists(String key) { 		return R.success(holidayService.queryProcessDefinitionByKey(key)) ; 	} 	 	/** 	 *  <p>创建请假流程审批(私有)</p> 	 *  <p>时间:2021年1月23日-上午10:31:47</p> 	 * @author xg 	 * @return R 	 */ 	@GetMapping("/_deploy") 	public R createDeploy() { 		holidayService.createDeploy(); 		return R.success() ; 	} 	 	/** 	 *  <p>启动请假审批流程</p> 	 *  <p>时间:2021年1月23日-上午10:32:55</p> 	 * @author xg 	 * @param userId 	 * @param processDefinitionId 流程定义Id 	 * @return R 	 */ 	@GetMapping("/start") 	public R startProcess(String userId, String processDefinitionId) { 		Map<String, Object> variables = new HashMap<>() ; 		variables.put("assignee", userId) ; 		holidayService.startProcessInstanceAssignVariables(processDefinitionId, variables) ; 		return R.success() ; 	} 	 	/** 	 *  <p> 	 *  	查询指派给我的任务 	 *  </p> 	 *  <p>时间:2021年1月23日-上午11:41:21</p> 	 * @author xg 	 * @param userId 用户Id 	 * @return R 	 */ 	@GetMapping("/tasks") 	public R myTasks(String userId) { 		List<Task> list = holidayService.queryTasks(userId) ;     // 注意这里需要我们自己组装下数据,不然会报错。 		List<Map<String, Object>> result = list.stream().map(task -> { 			Map<String, Object> res = new HashMap<String, Object>() ; 			res.put("id", task.getId()) ; 			res.put("assignee", task.getAssignee()) ; 			res.put("createTime", task.getCreateTime()) ; 			res.put("bussinessKey", task.getBusinessKey()) ; 			res.put("category", task.getCategory()) ; 			res.put("dueDate", task.getDueDate()) ; // 到期日期 			res.put("desc", task.getDescription()) ; 			res.put("name", task.getName()) ; 			res.put("owner", task.getOwner()) ; 			res.put("instanceId", task.getProcessInstanceId()) ; 			res.put("variables", task.getProcessVariables()) ; 			return res ; 		}).collect(Collectors.toList()) ; 		return R.success(result) ; 	} 	 	/** 	 *  <p> 	 *  	填写审批单 	 *  </p> 	 *  <p>时间:2021年1月23日-上午11:57:30</p> 	 * @author xg 	 * @param Map取值如下 	 * @param days 请假天数 	 * @param explain 审批单说明 	 * @param instanceId 流程实例ID 	 * @param assignee 指定下一个流程执行人 	 * @return R 	 */ 	@GetMapping("/apply") 	public R fillApply(@RequestParam Map<String, Object> variables) { 		String instanceId = (String) variables.remove("instanceId") ; 		if (StringUtils.isEmpty(instanceId)) { 			return R.failure("未知任务") ; 		} 		holidayService.executionTask(variables, instanceId); 		return R.success() ;  	} 	 }

    测试:

    1、启动服务

    Springboot整合工作流引擎Activiti(一)

    这里放在processes中的流程定义文件已经被自动部署上了。查看表act_re_procdef

    Springboot整合工作流引擎Activiti(一)

    1. 查询制定key的流程审批
      接口:/holidays

    Springboot整合工作流引擎Activiti(一)

    1. 启动请假审批流程
      接口:/holidays/start

    Springboot整合工作流引擎Activiti(一)

    参数:
    processDefinitionId:流程定义中的ID。
    userId:要处理用户的id。

    查看表信息:

    Springboot整合工作流引擎Activiti(一)

    这时候就为用户id为:10000的生成了一个要处理的任务,填写审批单。

    1. 查询指派给我需要处理的任务
      接口:/holidays/tasks

    Springboot整合工作流引擎Activiti(一)

    1. 填写审批单
      接口:/holidays/apply

    Springboot整合工作流引擎Activiti(一)

    参数:
    mgr:指定下一个节点处理人。
    explain:请假原因。
    days:请假天数。

    这里根据自己的业务需要去设置。

    再次调用查询接口userId=10002

    Springboot整合工作流引擎Activiti(一)

    流程已经到了部门经理。

    再次调用/holidays/apply接口。

    Springboot整合工作流引擎Activiti(一)

    参数:
    top:指明总经理节点需要处理的userId。

    Springboot整合工作流引擎Activiti(一)

    再次调用/holidays/apply接口。(总经理处理)

    Springboot整合工作流引擎Activiti(一)

    查询对应的任务表信息,已经没有数据了。

    Springboot整合工作流引擎Activiti(一)

    查询表:act_hi_actinst

    Springboot整合工作流引擎Activiti(一)

    到此一个流程就走完了。

    Activity7.1.0 springboot activiti7 Activiti timezone Mybatis hashmap Eclipse 工作流引擎 https mysql error log4j http edge Java TLog 工作流 数据库 POI
    分享到:

    您可能还会对下面的文章感兴趣: