用5个步骤实现Activiti7与SpringBoot的无缝集成

2024-02-23 21:51:23

通过集成 Activiti 7 和 SpringBoot 提升工作流管理

简介

在当今快速发展的数字时代，工作流管理已成为现代软件开发不可或缺的一部分。它使企业能够自动化复杂的任务，从而提高工作效率并释放宝贵的人力资源。Activiti 7 是一款强大的开源工作流引擎，以其灵活性、可扩展性和用户友好性而著称。将其与 SpringBoot 相结合，这一流行的 Java 框架，可以轻松构建一个全面的工作流管理系统。

入门

创建 SpringBoot 项目： 首先，创建一个新的 SpringBoot 项目，使用 Spring Boot CLI 或集成开发环境（例如 IntelliJ IDEA）。
添加 Activiti 7 依赖项： 将 Activiti 7 依赖项添加到项目中。

<dependency>
  <groupId>org.activiti</groupId>
  <artifactId>activiti-spring-boot-starter</artifactId>
  <version>7.2.0.Final</version>
</dependency>

配置 Activiti 7： 在 application.properties 文件中，配置 Activiti 7 设置。

spring.activiti.database-schema-update=true
spring.activiti.database-type=h2

创建数据库表： 创建 Activiti 7 所需的数据库表，例如使用 Spring Boot 的自动表创建功能。

CREATE TABLE ACT_RE_PROCDEF (
  ID_ VARCHAR(64) NOT NULL,
  NAME_ VARCHAR(255) NOT NULL,
  KEY_ VARCHAR(255) NOT NULL,
  VERSION_ INT NOT NULL,
  DEPLOYMENT_ID_ VARCHAR(64),
  RESOURCE_NAME_ VARCHAR(255),
  DGRM_RESOURCE_NAME_ VARCHAR(255),
  DESCRIPTION_ VARCHAR(4000),
  HAS_START_FORM_KEY_ TINYINT NOT NULL,
  HAS_GRAPHICAL_NOTATION_ TINYINT NOT NULL,
  SUSPENSION_STATE_ INT NOT NULL,
  TENANT_ID_ VARCHAR(255),
  PRIMARY KEY (ID_)
);

创建和启动工作流

创建工作流定义： 使用 BPMN 2.0 定义工作流，将其保存在 .bpmn 文件中。

<?xml version="1.0" encoding="UTF-8"?>
<process xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.omg.org/spec/BPMN/20100524/MODEL BPMN20.xsd" id="MyProcess" name="My Process" isExecutable="true">
  <startEvent id="StartEvent_1" name="Start"></startEvent>
  <sequenceFlow id="Flow_1" sourceRef="StartEvent_1" targetRef="Task_1"></sequenceFlow>
  <task id="Task_1" name="Task 1"></task>
  <sequenceFlow id="Flow_2" sourceRef="Task_1" targetRef="EndEvent_1"></sequenceFlow>
  <endEvent id="EndEvent_1" name="End"></endEvent>
</process>

创建控制器： 在 SpringBoot 控制器中，使用 Activiti API 启动工作流并获取任务。

import org.activiti.engine.RuntimeService;
import org.activiti.engine.TaskService;
import org.activiti.engine.runtime.ProcessInstance;
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.RestController;

@RestController
public class MyProcessController {

    @Autowired
    private RuntimeService runtimeService;

    @Autowired
    private TaskService taskService;

    @GetMapping("/start-process")
    public String startProcess() {
        ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("MyProcess");
        return "Process started with ID: " + processInstance.getId();
    }

    @GetMapping("/get-tasks")
    public List<Task> getTasks() {
        List<Task> tasks = taskService.createTaskQuery().list();
        return tasks;
    }
}