Activiti 用户绑定申请审批全流程演示

朱雀 2023-01-07 13:30 922阅读 0赞

**[SpringBoot集成的Activiti6.0代码（绘制工具界面代码 + 审批代码）][SpringBoot_Activiti6.0_ _]**

最近的工作中需要使用到Activiti工作流引擎做二次开发工作，本文主要介绍工作流用户与组绑定及表单申请与审批全流程演示，特此记录便于日后查阅。

## **一、创建BPMN业务流程模型** ##

1.  将Activiti提供的流程设计器应用activiti-app.war部署到Tomcat的webapps目录。
2.  创建新的MySql数据库。修改activiti-app\\WEB-INF\\classes\\META-INF\\activiti-app目录下的activiti-app.properties配置文件，默认使用H2内存数据库，创建的模型重启后会丢失，改成使用MySql数据库。
3.  浏览器访问[http://localhost:8080/activiti-app][http_localhost_8080_activiti-app]，登录账户：admin：test
4.  创建一个请假审批流程图

![a479a779eb6c74ec7a0eed6a7d0e757e.png][]

*  给每个用户任务指派候选组（有权限执行当前任务的角色）
    
    ![6e9e7fda130e0665bf501637d0b898cd.png][]
    
    ![5a53cebfc0e36a1ea189b6b43e3a4119.png][]
 *  排他网关设置条件分支表达式
    
    ![b2fffb7618df1af959b4d58fc9fd5dc9.png][]
    
    ![36bf992b012d5f69f72c3f950aded4ac.png][]
    
     
    
    5.导出流程图为.bpmn20.xml文件
    
    ![5b4e98aa69eec05725f55ba9322d7c54.png][]

## 二、Spring Boot与Activiti 6.0整合 ##

**1、在POM文件中添加依赖**

<dependency>
        <groupId>org.activiti</groupId>
        <artifactId>activiti-spring-boot-starter-basic</artifactId>
        <version>6.0.0</version>
    </dependency>

将导出的.bpmn20.xml文件拷贝到项目文件夹/resources/processes下，application.properties文件添加配置项

spring.activiti.database-schema-update=true

databaseSchemaUpdate配置项可以设置流程引擎启动和关闭时数据库执行的策略。 databaseSchemaUpdate有以下四个值：

*  false：false为默认值，设置为该值后，Activiti在启动时，会对比数据库表中保存的版本，如果没有表或者版本不匹配时，将在启动时抛出异常。
 *  true：设置为该值后，Activiti会对数据库中所有的表进行更新，如果表不存在，则Activiti会自动创建。
 *  create-drop：Activiti启动时，会执行数据库表的创建操作，在Activiti关闭时，执行数据库表的删除操作。
 *  drop-create：Activiti启动时，执行数据库表的删除操作在Activiti关闭时，会执行数据库表的创建操作。

启动应用，会在数据库里创建28张表，表创建好之后停止应用。application.properties文件修改配置项

#每次应用启动不检查Activiti数据表是否存在及版本号是否匹配，提升应用启动速度
    spring.activiti.database-schema-update=false

**2、application.properties文件增加配置项**

#保存历史数据级别设置为full最高级别，便于历史数据的追溯
    spring.activiti.history-level=full

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

*  none：不保存任何的历史数据，因此，在流程执行过程中，这是最高效的。
 *  activity：级别高于none，保存流程实例与流程行为，其他数据不保存。
 *  audit：除activity级别会保存的数据外，还会保存全部的流程任务及其属性。audit为history的默认值。
 *  full：保存历史数据的最高级别，除了会保存audit级别的数据外，还会保存其他全部流程相关的细节数据，包括一些流程参数等。

**3、Activiti的7大接口**

完成以上步骤，就可以在程序中使用自动注入的方式，使用

@Autowired
    private RuntimeService runtimeService;
    
    @Autowired
    private TaskService taskService;
    
    @Autowired
    private IdentityService identityService;
    
    @Autowired
    private RepositoryService repositoryService;
    
    @Autowired
    private ProcessEngine processEngine;
    
    @Autowired
    private HistoryService historyService;

## 三、项目中的用户、角色与Activiti中的用户、用户组整合 ##

每个项目都有自己的用户、角色表，Activiti也有自己的用户、用户组表。因此项目中的用户、角色与Activiti中的用户、用户组要做整合。

//项目中每创建一个新用户，对应的要创建一个Activiti用户
    //两者的userId和userName一致
    User admin=identityService.newUser("1");
    admin.setLastName("admin");
    identityService.saveUser(admin);
    
    //项目中每创建一个角色，对应的要创建一个Activiti用户组
    Group adminGroup=identityService.newGroup("1");
    adminGroup.setName("admin");
    identityService.saveGroup(adminGroup);
    
    //用户与用户组关系绑定
    identityService.createMembership("1","1");

## 四、请假审批流程 ##

**1、请假申请和请假审批数据库表设计**

表设计原则：流程数据和业务数据相分离。Activiti相关表只负责流程的跳转、走向等。流程中产生的业务表单数据、审批意见、附件等存储在开发人员定义的业务表中。流程数据和业务数据之间通过processInstanceId(流程实例ID)和业务数据主键相互关联。

为什么不使用Activiti相关表来存储表单数据和附件？

![f1c6daee7f80418fa108673239bc3d84.png][]

Activiti为了应用的灵活性和通用性采用了纵表的方式存储表单数据。假设一条请假申请表单数据有10个字段，那就需要10条记录存储原本横表只需要一条记录存储的数据。采用纵表的方式会有如下问题：

*  会有大量的冗余数据并且数据量会急剧的增长
 *  查询语句复杂，查询效率低
 *  尤其不适合做后期的统计报表分析

![918855e8f3fa24384b7b844173a496e4.png][]

Activiti存储附件使用Blob数据格式，文件存储在数据库里，数据库的数据文件会变得超大，不利于数据库备份和迁移。  
请假申请表结构

![21fc8ca071ba10853fe840a87c23af37.png][]

![cf6cb12e99188f0e7164e188b98e4b59.png][]

**2、填写请假申请表单，启动流程实例**

![014f0703a57d66b96ae2062c27b3c2a6.png][]

//启动流程实例，字符串"vacation"是BPMN模型文件里process元素的id
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("vacation");
    //流程实例启动后，流程会跳转到请假申请节点
    Task vacationApply = taskService.createTaskQuery().processInstanceId(processInstance.getId()).singleResult();
    //设置请假申请任务的执行人
    taskService.setAssignee(vacationApply.getId(), req.getUserId().toString());
    
    //设置流程参数：请假天数和表单ID
    //流程引擎会根据请假天数days>3判断流程走向
    //formId是用来将流程数据和表单数据关联起来
    Map<String, Object> args = new HashMap<>();
    args.put("days", req.getDays());
    args.put("formId", formId);
    
    //完成请假申请任务
    taskService.complete(vacationApply.getId(), args);

**3、待审批列表**

![30363e7fe785408f7c8a4a8915f0789d.png][]

//查出当前登录用户所在的用户组
    List<Group> groups = identityService.createGroupQuery()
            .groupMember(String.valueOf(userId)).list();
    List<String> groupNames = groups.stream()
            .map(group -> group.getName()).collect(Collectors.toList());
    
    //查询用户组的待审批请假流程列表
    List<Task> tasks = taskService.createTaskQuery()
            .processDefinitionKey("vacation")
            .taskCandidateGroupIn(groupNames)
            .listPage(pageNum - 1, pageSize);
    
    //根据流程实例ID查询请假申请表单数据
    List<String> processInstanceIds = tasks.stream()
            .map(task -> task.getProcessInstanceId())
            .collect(Collectors.toList());
    List<VacationApplyBasicPO> vacationApplyList = 
            vacationRepository.getVacationApplyList(processInstanceIds);

**4、请假审批功能**

![b08a28658558a6855863973e46aeba55.png][]

//查询当前审批节点
    Task vacationAudit = taskService.createTaskQuery()
            .taskId(req.getTaskId()).singleResult();
    
    if (req.getAuditResult() == 1) {//审批通过
        //设置流程参数：审批ID
        Map<String, Object> args = new HashMap<>();
        args.put("auditId", auditId);
    
        //设置审批任务的执行人
        taskService.claim(vacationAudit.getId(), req.getUserId().toString());
        //完成审批任务
        taskService.complete(vacationAudit.getId(), args);
    } else {
        //审批不通过，结束流程
        runtimeService.deleteProcessInstance(vacationAudit.getProcessInstanceId(), auditId);
    }

**5、查看流程图功能**

![1883da54d60a9c14ff89e650758bfe87.png][]

//controller层代码
    @RequestMapping(value = "/image", method = RequestMethod.GET)
    public void image(HttpServletResponse response,
     @RequestParam String processInstanceId) {
        try {
            InputStream is = vacationService.getDiagram(processInstanceId);
            if (is == null)
                return;
    
            response.setContentType("image/png");
    
            BufferedImage image = ImageIO.read(is);
            OutputStream out = response.getOutputStream();
            ImageIO.write(image, "png", out);
    
            is.close();
            out.close();
        } catch (Exception ex) {
            logger.error("查看流程图失败", ex);
        }
    }
    
    //service层代码
    @Override
    public InputStream getDiagram(String processInstanceId) {
        //获得流程实例
        ProcessInstance processInstance = runtimeService.createProcessInstanceQuery()
                .processInstanceId(processInstanceId).singleResult();
        String processDefinitionId = StringUtils.EMPTY;
        if (processInstance == null) {
            //查询已经结束的流程实例
            HistoricProcessInstance processInstanceHistory =
                    historyService.createHistoricProcessInstanceQuery()
                            .processInstanceId(processInstanceId).singleResult();
            if (processInstanceHistory == null)
                return null;
            else
                processDefinitionId = processInstanceHistory.getProcessDefinitionId();
        } else {
            processDefinitionId = processInstance.getProcessDefinitionId();
        }
    
        //使用宋体
        String fontName = "宋体";
        //获取BPMN模型对象
        BpmnModel model = repositoryService.getBpmnModel(processDefinitionId);
        //获取流程实例当前的节点，需要高亮显示
        List<String> currentActs = Collections.EMPTY_LIST;
        if (processInstance != null)
            currentActs = runtimeService.getActiveActivityIds(processInstance.getId());
    
        return processEngine.getProcessEngineConfiguration()
                .getProcessDiagramGenerator()
                .generateDiagram(model, "png", currentActs, new ArrayList<String>(),
                        fontName, fontName, fontName, null, 1.0);
    }

最后，spring boot应用打成jar包部署的时候，需要注意部署文件目录一定不要出现中文。

[SpringBoot_Activiti6.0_ _]: https://download.csdn.net/download/qq_19734597/16788016
[http_localhost_8080_activiti-app]: http://localhost:8080/activiti-app
[a479a779eb6c74ec7a0eed6a7d0e757e.png]: /images/20221119/7e168a8d1f12406da3810cec9c5ce141.png
[6e9e7fda130e0665bf501637d0b898cd.png]: /images/20221119/ebf758290a584456a97cf39f56611b4d.png
[5a53cebfc0e36a1ea189b6b43e3a4119.png]: https://img-blog.csdnimg.cn/img_convert/5a53cebfc0e36a1ea189b6b43e3a4119.png
[b2fffb7618df1af959b4d58fc9fd5dc9.png]: https://img-blog.csdnimg.cn/img_convert/b2fffb7618df1af959b4d58fc9fd5dc9.png
[36bf992b012d5f69f72c3f950aded4ac.png]: https://img-blog.csdnimg.cn/img_convert/36bf992b012d5f69f72c3f950aded4ac.png
[5b4e98aa69eec05725f55ba9322d7c54.png]: https://img-blog.csdnimg.cn/img_convert/5b4e98aa69eec05725f55ba9322d7c54.png
[f1c6daee7f80418fa108673239bc3d84.png]: https://img-blog.csdnimg.cn/img_convert/f1c6daee7f80418fa108673239bc3d84.png
[918855e8f3fa24384b7b844173a496e4.png]: https://img-blog.csdnimg.cn/img_convert/918855e8f3fa24384b7b844173a496e4.png
[21fc8ca071ba10853fe840a87c23af37.png]: https://img-blog.csdnimg.cn/img_convert/21fc8ca071ba10853fe840a87c23af37.png
[cf6cb12e99188f0e7164e188b98e4b59.png]: https://img-blog.csdnimg.cn/img_convert/cf6cb12e99188f0e7164e188b98e4b59.png
[014f0703a57d66b96ae2062c27b3c2a6.png]: https://img-blog.csdnimg.cn/img_convert/014f0703a57d66b96ae2062c27b3c2a6.png
[30363e7fe785408f7c8a4a8915f0789d.png]: https://img-blog.csdnimg.cn/img_convert/30363e7fe785408f7c8a4a8915f0789d.png
[b08a28658558a6855863973e46aeba55.png]: https://img-blog.csdnimg.cn/img_convert/b08a28658558a6855863973e46aeba55.png
[1883da54d60a9c14ff89e650758bfe87.png]: https://img-blog.csdnimg.cn/img_convert/1883da54d60a9c14ff89e650758bfe87.png