0
0

springboot整合Activiti-常用方法（部署、启动、查询、执行任务）

Activiti-常用方法

一、springboot整合activiti7

ps：activiti7强依赖security，所以还需要整合security，这里就当整合成功了。

真不会整合，就看我下面这个博文
日常记录-SpringBoot整合SpringSecurity（前后分离）+JWT+Redis

1、activiti7的核心依赖

<!--引入activiti的springboot启动器 7.1.0.M6是支持jdk1.8的最后一个版本--><dependency><groupId>org.activiti</groupId><artifactId>activiti-spring-boot-starter</artifactId><version>7.1.0.M6</version><exclusions><exclusion><!-- 排除activiti的mybatis，避免和外面的mybatis-plus冲突 --><artifactId>mybatis</artifactId><groupId>org.mybatis</groupId></exclusion></exclusions></dependency><!-- 依赖：spring-security --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-security</artifactId></dependency>

2、yml配置

spring:activiti:#自动更新数据库结构#1.flase：默认值。activiti在启动时，对比数据库表中保存的版本，如果没有表或者版本不匹配，将抛出异常#2.true： activiti会对数据库中所有表进行更新操作。如果表不存在，则自动创建#3.create_drop： 在activiti启动时创建表，在关闭时删除表（必须手动关闭引擎，才能删除表）#4.drop-create： 在activiti启动时删除原来的旧表，然后在创建新表（不需要手动关闭引擎）database-schema-update:false#activiti7默认不生成历史信息表，开启历史表db-history-used:false#记录历史等级 可配置的历史级别有none, activity, audit, full#none：不保存任何的历史数据，因此，在流程执行过程中，这是最高效的。#activity：级别高于none，保存流程实例与流程行为，其他数据不保存。#audit：除activity级别会保存的数据外，还会保存全部的流程任务及其属性。audit为history的默认值。#full：保存历史数据的最高级别，除了会保存audit级别的数据外，还会保存其他全部流程相关的细节数据，包括一些流程参数等。history-level: none
    # =============================#自动检查、部署流程定义文件check-process-definitions:false# 关闭 SpringAutoDeployment never-faildeployment-mode: never-fail
    # asyncExecutorActivate是指activiti在流程引擎启动就激活AsyncExecutor,异步：true-开启（默认）、false-关闭async-executor-activate:true#流程定义文件存放目录,要具体到某个目录#      process-definition-location-prefix: classpath:/processes/holliday/#process-definition-location-suffixes: #流程文件格式#  - **.bpmn20.xml#  - **.bpmn

3、activiti7默认生成的表

启动成功后就看到下面的表

  1. activiti7默认不生成act_hi历史表
  2. 如果不生成历史表，还需要禁用插入历史数据【spring.activiti.history-level:=none】

在这里插入图片描述
activiti常用的服务

@AutowiredprivateRepositoryService repositoryService;@AutowiredprivateRuntimeService runtimeService;@AutowiredprivateTaskService taskService;

二、部署流程

1、静态部署流程

java代码

//使用RepositoryService进行部署DeploymentBuilder builder = repositoryService.createDeployment();
builder.addClasspathResource("bpmn/demo1/demo1.bpmn20.xml");
builder.addClasspathResource("bpmn/demo1/demo1.png");
builder.tenantId("212121");//区分同一个流程所属系统，该值主要用于记录启动的流程实例归属于哪个系统。
builder.name("串行并行配置工作流");Deployment deployment = builder.deploy();//输出部署信息System.out.println("流程部署id："+ deployment.getId());System.out.println("流程部署名称："+ deployment.getName());

bpmn文件路径
在这里插入图片描述

2、动态部署流程

controller代码

/**
     * 部署流程
     * @param fileBpmn bpmn文件
     * @param fileSvg  svg图片
     * @param name     流程名称
     * @param key      流程key
     * @param tenantId 系统标识 -> 同一个流程可以部署多次，互不干扰，系统标识必须唯一
     * @return
     */@PostMapping(value="/saveDeploy")publicApiResultsaveDeploy(@RequestPart(name ="fileBpmn", required =true)MultipartFile fileBpmn,@RequestPart(name ="fileSvg", required =true)MultipartFile fileSvg,@RequestParam("name")String name,@RequestParam("key")String key,@RequestParam("tenantId")String tenantId){
        
        activitiService.saveDeploy(fileBpmn,fileSvg,name,key,tenantId);returnApiResult.ok("成功");}

service代码

voidsaveDeploy(MultipartFile fileBpmn,MultipartFile fileSvg,String name,String key,String tenantId);

serviceImpl代码

@OverridepublicvoidsaveDeploy(MultipartFile fb,MultipartFile fg,String name,String key,String tenantId){//1:使用File 类创建一个要操作的文件路径//File file = new File("D:" + File.separator + bpmnZip);/* File fileBpmn = new File("D:" + File.separator + fb);
        File fileSvg = new File("D:" + File.separator + fg);*///System.out.println(file.getPath());InputStream inputStreamBpmn =null;InputStream inputStreamSvg =null;try{
            inputStreamBpmn = fb.getInputStream();
            inputStreamSvg = fg.getInputStream();/*
            这是压缩包部署
            ZipInputStream zipInputStream = new ZipInputStream(inputStream);
            System.out.println(inputStream);
            */// 流程部署Deployment deployment = repositoryService.createDeployment().name(name).key(key).addInputStream(fb.getOriginalFilename(),inputStreamBpmn).addInputStream(fg.getOriginalFilename(),inputStreamSvg)//.category("vvvv").tenantId(tenantId)//.addZipInputStream(zipInputStream).deploy();System.out.println("流程部署id："+ deployment.getId());System.out.println("流程部署名称："+ deployment.getName());}catch(Exception e){
            e.printStackTrace();}finally{try{
                inputStreamBpmn.close();
                inputStreamSvg.close();}catch(Exception e){
                e.printStackTrace();}}}

3、部署流程相关联表

部署成功后，这几张表会有数据

act_ge_bytearray（二进制数据表，存储通用的流程定义和流程资源）
在这里插入图片描述
act_re_deployment（部署单元信息表）
在这里插入图片描述
act_re_procdef（已部署的流程定义）
在这里插入图片描述

三、启动流程

1、startProcessInstanceByKey（推荐使用）

//参数 processDefinitionKey -> act_re_procdef.KEY_//参数 businessKey -> 一般是你业务的唯一标识，把该流程和你的业务绑定一起//参数 Map<String, Object> variables -> 流程变量ProcessInstancestartProcessInstanceByKey(String processDefinitionKey);ProcessInstancestartProcessInstanceByKey(String processDefinitionKey,String businessKey);ProcessInstancestartProcessInstanceByKey(String processDefinitionKey,Map<String,Object> variables);ProcessInstancestartProcessInstanceByKey(String processDefinitionKey,String businessKey,Map<String,Object> variables);

2、startProcessInstanceByKeyAndTenantId（推荐使用）

//参数 processDefinitionKey -> act_re_procdef.KEY_//参数 businessKey -> 一般是你业务的唯一标识，把该流程和你的业务绑定一起//参数 Map<String, Object> variables -> 流程变量//参数 tenantId -> 系统唯一标识（类似同一型号的手机有不同的串码）ProcessInstancestartProcessInstanceByKeyAndTenantId(String processDefinitionKey,String tenantId);ProcessInstancestartProcessInstanceByKeyAndTenantId(String processDefinitionKey,String businessKey,String tenantId);ProcessInstancestartProcessInstanceByKeyAndTenantId(String processDefinitionKey,Map<String,Object> variables,String tenantId);ProcessInstancestartProcessInstanceByKeyAndTenantId(String processDefinitionKey,String businessKey,Map<String,Object> variables,String tenantId);

3、startProcessInstanceById

//参数 processDefinitionId-> act_re_procdef.ID_//参数 businessKey -> 一般是你业务的唯一标识，把该流程和你的业务绑定一起//参数 Map<String, Object> variables -> 流程变量ProcessInstancestartProcessInstanceById(String processDefinitionId);ProcessInstancestartProcessInstanceById(String processDefinitionId,String businessKey);ProcessInstancestartProcessInstanceById(String processDefinitionId,Map<String,Object> variables);ProcessInstancestartProcessInstanceById(String processDefinitionId,String businessKey,Map<String,Object> variables);

获取processDefinitionId的java代码

//一般来说，你也不会设置key和tenantId一样的数据ProcessDefinitionQuery processDefinitionQuery = repositoryService.createProcessDefinitionQuery();ProcessDefinition processDefinition = processDefinitionQuery.processDefinitionKey("demo1").processDefinitionTenantId("212121").singleResult();System.out.println("processDefinition的主键ID："+processDefinition.getId());//通过processDefinitionId启动流程ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinition.getId());//输出实例信息System.out.println("流程定义id："+ processInstance.getProcessDefinitionId());System.out.println("流程实例id："+ processInstance.getId());System.out.println("当前活动Id："+ processInstance.getActivityId());

4、startProcessInstanceByMessage

部署流程的时候没有配tenantId

ProcessInstancestartProcessInstanceByMessage(String messageName);ProcessInstancestartProcessInstanceByMessage(String messageName,String businessKey);ProcessInstancestartProcessInstanceByMessage(String messageName,Map<String,Object> processVariables);ProcessInstancestartProcessInstanceByMessage(String messageName,String businessKey,Map<String,Object> processVariables);

5、startProcessInstanceByMessageAndTenantId

部署流程的时候有配tenantId

ProcessInstancestartProcessInstanceByMessageAndTenantId(String messageName,String tenantId);ProcessInstancestartProcessInstanceByMessageAndTenantId(String messageName,String businessKey,String tenantId);ProcessInstancestartProcessInstanceByMessageAndTenantId(String messageName,Map<String,Object> processVariables,String tenantId);ProcessInstancestartProcessInstanceByMessageAndTenantId(String messageName,String businessKey,Map<String,Object> processVariables,String tenantId);

实例
在这里插入图片描述

message 和 process 是同级的
<messageid="myMessage"name="testMessage"/>

如果start事件用了messageRef，一定要配相应的message

act_ru_event_subscr表（运行时事件），部署成功就有数据了
在这里插入图片描述
java代码1

ProcessInstance processInstance = runtimeService.startProcessInstanceByMessageAndTenantId("testMessage","888888");//输出实例信息System.out.println("流程定义id："+ processInstance.getProcessDefinitionId());System.out.println("流程实例id："+ processInstance.getId());System.out.println("当前活动Id："+ processInstance.getActivityId());

java代码2

//<message id="myMessage" name="testMessage"/>Execution execution = runtimeService.createExecutionQuery().messageEventSubscriptionName("testMessage").singleResult();
log.info("execution = {}", execution);
runtimeService.messageEventReceived("testMessage",execution.getId());

四、任务执行

1、任务查询

//TaskService已经封装好了，根据自己的业务查询，这里只是简单的演示//根据流程key查询任务List<Task> list = taskService.createTaskQuery().processDefinitionKey("demo1")//act_re_procdef.KEY_//.taskAssignee() //任务负责人 .list();for(Task task : list){System.out.println("流程实例id："+ task.getProcessInstanceId());System.out.println("任务id："+ task.getId());System.out.println("任务负责人："+ task.getAssignee());System.out.println("任务名称："+ task.getName());}

2、拾取任务

// 可以拾取任务//参数1 任务id//参数2 负责人名称
taskService.claim("41691bf7-47c9-11ee-af01-002b67defec7","负责人名称");

3、归还任务

// 如果设置为null，归任务没有负责人
taskService.setAssignee("41691bf7-47c9-11ee-af01-002b67defec7",null);

4、查询任务候选人

//查询任务候选人//参数1 任务idList<IdentityLink> identityLinkList = taskService.getIdentityLinksForTask("41691bf7-47c9-11ee-af01-002b67defec7");for(IdentityLink identityLink : identityLinkList){System.out.println(identityLink.getUserId());}

5、查询当前用户待审核的任务

// 查看当前用户待审核记录(任务给别人拾取也能查询)//参数1 你定义的用户名称或用户idList<Task> list = taskService.createTaskQuery().taskInvolvedUser("user1").orderByTaskCreateTime().desc().list();// 代办列表for(Task task : list){System.out.println("流程实例id："+ task.getProcessInstanceId());System.out.println("任务id："+ task.getId());System.out.println("任务负责人："+ task.getAssignee());System.out.println("任务名称："+ task.getName());}

6、执行待审核的任务

//先查询任务是否给当前用户拾取了Task task = taskService.createTaskQuery().taskId("任务id").taskAssignee("负责人名称").singleResult();//再执行任务if(task !=null){
    taskService.complete("任务id");System.out.println("完成任务");}

7、其他

常用的服务就这三个了，基本能满足大部分需求

@AutowiredprivateRepositoryService repositoryService;@AutowiredprivateRuntimeService runtimeService;@AutowiredprivateTaskService taskService;
标签： spring boot java 数据库
本文转载自: https://blog.csdn.net/qq407995680/article/details/132617227
版权归原作者 蜗牛+火箭 所有， 如有侵权，请联系我们删除。
登录后发布评论

“springboot整合Activiti-常用方法（部署、启动、查询、执行任务）”的评论:

还没有评论
关于作者
...
overfit同步小助手
文章同步
相关阅读

网络安全法-网络运行安全

使用selenium/drissionpage时如何阻止chrome自动跳转http到https

docker desktop 里部署的Open WebUI 管理员密码忘记了的处理方法

在ubuntu20.04中搭建onsite比赛运行环境

利用开源的低代码表单设计器FcDesigner高效管理和渲染复杂表单结构

Kafka学习笔记

【前端】浏览器输入url到页面呈现发生了什么？

文章导航