前言
Activiti項目是一項新的基于Apache許可的開源BPM平臺,從基礎開始構建,旨在提供支持新的BPMN 2.0標準,包括支持對象管理組(OMG),面對新技術的機遇,諸如互操作性和云架構,提供技術實現。
創始人Tom Baeyens是JBoss jBPM的項目架構師,以及另一位架構師Joram Barrez,一起加入到創建 Alfresco這項首次實現Apache開源許可的BPMN 2.0引擎開發中來。
Activiti是一個獨立運作和經營的開源項目品牌,并將獨立于Alfresco開源ECM系統運行。 Activiti將是一種輕量級,可嵌入的BPM引擎,而且還設計適用于可擴展的云架構。 Activiti將提供寬松的Apache許可2.0,以便這個項目可以廣泛被使用,同時促進Activiti BPM引擎和BPMN 2.0的匹配,該項目現正由OMG通過標準審定。 加入Alfresco Activiti項目的是VMware的SpringSource分支,Alfresco的計劃把該項目提交給Apache基礎架構,希望吸引更多方面的BPM專家和促進BPM的創新。
代碼實現
- 流程部署、查詢流程定義
- 啟動流程、查詢流程
- 待辦任務、完成任務
- 已結束流程、已完成任務
<dependency><groupId>org.activiti</groupId><artifactId>activiti-spring-boot-starter</artifactId><version>7.1.0.M6</version>
</dependency>
# 服務配置
server:port: 8088# spring配置
spring:# 數據源配置datasource:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://127.0.0.1:3306/boot_activiti?useUnicode=true&useSSL=false&serverTimezone=UTC&characterEncoding=UTF8&nullCatalogMeansCurrent=trueusername: rootpassword: root# activiti7配置activiti:# 建表策略,可選值:true,false,create-drop,drop-createdatabase-schema-update: true# 自動部署檢查,默認校驗resources下的processes文件夾里的流程文件check-process-definitions: false# 保存歷史數據等級,可選值:none,activity,audit,fullhistory-level: full# 檢測歷史表是否存在db-history-used: true
package com.qiangesoft.activiti.config;import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
import org.springframework.security.core.userdetails.User;
import org.springframework.security.core.userdetails.UserDetailsService;
import org.springframework.security.crypto.factory.PasswordEncoderFactories;
import org.springframework.security.crypto.password.PasswordEncoder;
import org.springframework.security.provisioning.InMemoryUserDetailsManager;@Configuration
@EnableWebSecurity
public class WebSecurityConfig {@Beanpublic UserDetailsService userDetailsService() {PasswordEncoder encoder = PasswordEncoderFactories.createDelegatingPasswordEncoder();InMemoryUserDetailsManager manager = new InMemoryUserDetailsManager();manager.createUser(User.withUsername("admin").password(encoder.encode("123456")).roles("USER").build());return manager;}
}
package com.qiangesoft.activiti.controller;import com.qiangesoft.activiti.constant.ProcessConstant;
import com.qiangesoft.activiti.constant.R;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.repository.Deployment;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.List;/*** 流程定義 控制器** @author lq* @date 2024-02-27*/
@RestController
@RequestMapping("/definition")
public class ProcessDefinitionController {@Autowiredprivate RepositoryService repositoryService;@GetMapping("/deploy")public R deploy() {// 部署流程Deployment deployment = repositoryService.createDeployment().addClasspathResource("bpmn/test.bpmn20.xml").deploy();return R.ok(deployment);}@GetMapping("/list")public R list() {// 查詢部署流程List<Deployment> deploymentList = repositoryService.createDeploymentQuery().deploymentKey(ProcessConstant.PROCESS_KEY)
// .deploymentName("").orderByDeploymenTime().desc().list();return R.ok(deploymentList);}@GetMapping("/get")public R get() {Deployment deployment = repositoryService.createDeploymentQuery().deploymentKey(ProcessConstant.PROCESS_KEY)
// .deploymentName("").latest().singleResult();return R.ok(deployment);}}
package com.qiangesoft.activiti.controller;import com.qiangesoft.activiti.constant.ProcessConstant;
import com.qiangesoft.activiti.constant.R;
import org.activiti.engine.RuntimeService;
import org.activiti.engine.runtime.ProcessInstance;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.List;/*** 流程實例 控制器** @author lq* @date 2024-02-27*/
@RestController
@RequestMapping("/instance")
public class ProcessInstanceController {@Autowiredprivate RuntimeService runtimeService;@GetMapping("/start")public R start() {// 啟動流程:提供流程key,業務key,主題String businessId = "101";ProcessInstance processInstance = runtimeService.createProcessInstanceBuilder().processDefinitionKey(ProcessConstant.PROCESS_KEY).businessKey(ProcessConstant.BUSINESS_KEY_PREFIX + businessId).name("請假流程").start();return R.ok(processInstance.toString());}@GetMapping("/list")public R list() {// 查詢進行中的流程實例List<ProcessInstance> processInstanceList = runtimeService.createProcessInstanceQuery().processDefinitionKey(ProcessConstant.PROCESS_KEY)
// .deploymentId("")
// .processInstanceId("")
// .processInstanceBusinessKey("")
// .processInstanceNameLike("請假流程").active().orderByProcessInstanceId().desc().list();return R.ok(processInstanceList.toString());}@GetMapping("/get")public R get(String instanceId) {// 某個實例ProcessInstance processInstance = runtimeService.createProcessInstanceQuery().processInstanceId(instanceId).singleResult();return R.ok(processInstance == null ? null : processInstance.toString());}}
package com.qiangesoft.activiti.controller;import com.qiangesoft.activiti.constant.R;
import org.activiti.engine.TaskService;
import org.activiti.engine.task.Task;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.List;/*** 流程待辦 控制器** @author lq* @date 2024-02-27*/
@RestController
@RequestMapping("/task")
public class TaskController {@Autowiredprivate TaskService taskService;@GetMapping("/mine")public R mine() {// 某人的待辦任務:按照時間倒序String userId = "zhangsan";List<Task> taskList = taskService.createTaskQuery()
// .processDefinitionKey("")
// .taskCandidateOrAssigned("").taskAssignee(userId).active().orderByTaskCreateTime().desc().list();return R.ok(taskList.toString());}@GetMapping("/handle")public R handle(String taskId) {// 完成任務taskService.complete(taskId);return R.ok();}}
package com.qiangesoft.activiti.controller;import com.qiangesoft.activiti.constant.ProcessConstant;
import com.qiangesoft.activiti.constant.R;
import org.activiti.engine.HistoryService;
import org.activiti.engine.history.HistoricProcessInstance;
import org.activiti.engine.history.HistoricTaskInstance;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.List;/*** 歷史 控制器** @author lq* @date 2024-02-27*/
@RestController
@RequestMapping("/history")
public class HistoryController {@Autowiredprivate HistoryService historyService;@GetMapping("/finished")public R finished() {// 已結束的流程:按照結束時間倒序List<HistoricProcessInstance> processInstanceList = historyService.createHistoricProcessInstanceQuery()
// .processInstanceId("")
// .deploymentId("")
// .processDefinitionName("")
// .processInstanceBusinessKey("").processDefinitionKey(ProcessConstant.PROCESS_KEY).finished().orderByProcessInstanceEndTime().desc().list();return R.ok(processInstanceList.toString());}@GetMapping("/completed")public R completed() {// 某人已完成的任務:按照完成時間倒序String userId = "zhangsan";List<HistoricTaskInstance> processInstanceList = historyService.createHistoricTaskInstanceQuery()
// .processInstanceId("")
// .deploymentId("")
// .processDefinitionName("")
// .processInstanceBusinessKey("").taskAssignee(userId).processDefinitionKey(ProcessConstant.PROCESS_KEY).finished().orderByHistoricTaskInstanceEndTime().desc().list();return R.ok(processInstanceList.toString());}}
點擊下載