Flowable——环境构建及基本应用

港控/mmm° 2023-10-16 04:27 34阅读 0赞

#### 目录 ####

*   *  1、引入依赖
     *  2、创建流程引擎
     *  3、部署流程定义
     *  4、查询流程定义
     *  5、启动流程示例
     *  6、查看任务
     *  7、完成任务
     *  8、删除流程
     *  9、\#\# 查看历史信息

### 1、引入依赖 ###

<dependency>
        <groupId>org.flowable</groupId>
        <artifactId>flowable-engine</artifactId>
        <version>6.3.0</version>
    </dependency>
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>5.1.40</version>
    </dependency>
    <dependency>
        <groupId>junit</groupId>
        <artifactId>junit</artifactId>
        <version>4.12</version>
    </dependency>
    <dependency>
        <groupId>org.slf4j</groupId>
        <artifactId>slf4j-api</artifactId>
        <version>1.7.21</version>
    </dependency>
    <dependency>
        <groupId>org.slf4j</groupId>
        <artifactId>slf4j-log4j12</artifactId>
        <version>1.7.21</version>
    </dependency>

### 2、创建流程引擎 ###

ProcessEngineConfiguration cfg = new StandaloneProcessEngineConfiguration()
                    .setJdbcUrl("jdbc:mysql://localhost:3306/flowable?serverTimezone=UTC")
                    .setJdbcUsername("root")
                    .setJdbcPassword("123456")
                    .setJdbcDriver("com.mysql.jdbc.Driver")
                    .setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
            ProcessEngine processEngine = cfg.buildProcessEngine();

自动生成如下表：  
![在这里插入图片描述][f288deb8d7a5496eb3d61b2b0a9919d5.png]

### 3、部署流程定义 ###

![在这里插入图片描述][95f4f648e48541c487f72043cda7f082.png]

流程定义holiday-request.bpmn20.xml：

ProcessEngineConfiguration processEngineConfiguration = null;
    
    @Before
    public void before() {
        
        processEngineConfiguration = new StandaloneProcessEngineConfiguration()
                .setJdbcUrl("jdbc:mysql://localhost:3306/flowable?serverTimezone=UTC")
                .setJdbcUsername("root")
                .setJdbcPassword("123456")
                .setJdbcDriver("com.mysql.jdbc.Driver")
                .setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
    }
    
    
    @Test
    public void deploy() {
        
        // 获取流程引擎对象
        ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
        // 部署流程 获取RepositoryService对象
        RepositoryService repositoryService = processEngine.getRepositoryService();
        Deployment deployment = repositoryService.createDeployment()// 创建Deployment对象
                .addClasspathResource("holiday-request.bpmn20.xml") // 添加流程部署文件
                .name("请求流程") // 设置部署流程的名称
                .deploy(); // 执行部署操作
        System.out.println("deployment.getId() = " + deployment.getId());
        System.out.println("deployment.getName() = " + deployment.getName());
    }

deployment.getId() = 1
    deployment.getName() = 请求流程

### 4、查询流程定义 ###

@Test
    public void testDeployQuery(){
        
        // 获取流程引擎对象
        ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
        // 部署流程 获取RepositoryService对象
        RepositoryService repositoryService = processEngine.getRepositoryService();
        // 获取流程定义对象
        ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery()
                .processDefinitionKey("holidayRequest")
                .singleResult();
        System.out.println("processDefinition.getId() = " + processDefinition.getId());
        System.out.println("processDefinition.getName() = " + processDefinition.getName());
        System.out.println("processDefinition.getDeploymentId() = " + processDefinition.getDeploymentId());
        System.out.println("processDefinition.getDescription() = " + processDefinition.getDescription());
    }

processDefinition.getId() = holidayRequest:1:3
    processDefinition.getName() = Holiday Request
    processDefinition.getDeploymentId() = 1
    processDefinition.getDescription() = null

### 5、启动流程示例 ###

@Test
    public void testRunProcess(){
        
        // 获取流程引擎对象
        ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
        // 启动流程实例通过 RuntimeService 对象
        RuntimeService runtimeService = processEngine.getRuntimeService();
        // 构建流程变量
        Map<String,Object> variables = new HashMap<>();
        variables.put("employee","张三") ;// 谁申请请假
        variables.put("nrOfHolidays",3); // 请几天假
        variables.put("description","工作累了，想出去玩玩"); // 请假的原因
        // 启动流程实例，第一个参数是流程定义的id
        ProcessInstance processInstance = runtimeService
                .startProcessInstanceByKey("holidayRequest", variables);// 启动流程实例
        // 输出相关的流程实例信息
        System.out.println("流程定义的ID：" + processInstance.getProcessDefinitionId());
        System.out.println("流程实例的ID：" + processInstance.getId());
        System.out.println("当前活动的ID：" + processInstance.getActivityId());
    }

流程定义的ID：holidayRequest:1:3
    流程实例的ID：2501
    当前活动的ID：null

启动流程实例涉及到的表结构：

*  act\_hi\_actinst 流程实例执行历史
 *  act\_hi\_identitylink 流程的参与用户的历史信息
 *  act\_hi\_procinst 流程实例历史信息
 *  act\_hi\_taskinst 流程任务历史信息
 *  act\_ru\_execution 流程执行信息
 *  act\_ru\_identitylink 流程的参与用户信息
 *  act\_ru\_task 任务信息

### 6、查看任务 ###

@Test
    public void testQueryTask(){
        
        // 获取流程引擎对象
        ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
        TaskService taskService = processEngine.getTaskService();
        List<Task> list = taskService.createTaskQuery()
                .processDefinitionKey("holidayRequest")
                .list();
        for (Task task : list) {
        
            System.out.println("task.getProcessDefinitionId() = " + task.getProcessDefinitionId());
            System.out.println("task.getId() = " + task.getId());
            System.out.println("task.getAssignee() = " + task.getAssignee());
            System.out.println("task.getName() = " + task.getName());
        }
    }

### 7、完成任务 ###

public class SendRejectionMail implements JavaDelegate {
        
        @Override
        public void execute(DelegateExecution delegateExecution) {
        
            System.out.println("请假被拒绝...老实搬砖吧");
        }
    }

@Test
    public void testCompleteTask(){
        
        // 获取流程引擎对象
        ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
        TaskService taskService = processEngine.getTaskService();
        Task task = taskService.createTaskQuery()
                .processDefinitionKey("holidayRequest")
                .singleResult();
        // 添加流程变量
        Map<String,Object> variables = new HashMap<>();
        variables.put("approved",false); // 拒绝请假
        // 完成任务
        taskService.complete(task.getId(),variables);
    }

请假被拒绝...老实搬砖吧

### 8、删除流程 ###

@Test
    public void testDeleteProcess(){
        
        // 获取流程引擎对象
        ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
        RepositoryService repositoryService = processEngine.getRepositoryService();
        // 删除流程定义，如果该流程定义已经有了流程实例启动则删除时报错
        // repositoryService.deleteDeployment("1");
        // 设置为TRUE 级联删除流程定义，及时流程有实例启动，也可以删除，设置为false 非级联删除操作。
        //查询
        ProcessDefinition pd = repositoryService.createProcessDefinitionQuery().processDefinitionKey("holidayRequest").singleResult();
        repositoryService.deleteDeployment(pd.getDeploymentId(),true);
    }

### 9、\#\# 查看历史信息 ###

选择使用Flowable这样的流程引擎的原因之一，是它可以自动存储所有流程实例的**审计数据**或**历史数据**。这些数据可以用于创建报告，深入展现组织运行的情况，瓶颈在哪里，等等。

例如，如果希望显示流程实例已经执行的时间，就可以从*ProcessEngine*获取*HistoryService*，并创建历史活动(historical activities)的查询。在下面的代码片段中，可以看到我们添加了一些额外的过滤条件：

*  只选择一个特定流程实例的活动
 *  只选择已完成的活动

结果按照结束时间排序，代表其执行顺序。

@Test
    public void testQueryHistory(){
        
        // 获取流程引擎对象
        ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
        HistoryService historyService = processEngine.getHistoryService();
        List<HistoricActivityInstance> list = historyService.createHistoricActivityInstanceQuery()
                .processDefinitionId("holidayRequest:1:7503")
                .finished()
                .orderByHistoricActivityInstanceEndTime().asc()
                .list();
        for (HistoricActivityInstance historicActivityInstance : list) {
        
            System.out.println(historicActivityInstance.getActivityId() + " took "
                    + historicActivityInstance.getDurationInMillis() + " milliseconds");
        }
    }

startEvent took 2 milliseconds
    approveTask took 71598 milliseconds
    decision took 11 milliseconds
    sendRejectionMail took 1 milliseconds
    rejectEnd took 1 milliseconds

[f288deb8d7a5496eb3d61b2b0a9919d5.png]: https://img-blog.csdnimg.cn/f288deb8d7a5496eb3d61b2b0a9919d5.png
[95f4f648e48541c487f72043cda7f082.png]: https://img-blog.csdnimg.cn/95f4f648e48541c487f72043cda7f082.png