spingboot整合activity7实践代码

import org.activiti.engine.*; import org.activiti.engine.history.HistoricActivityInstance; import org.activiti.engine.history.HistoricActivityInstanceQuery; import org.activiti.engine.repository.Deployment; import org.activiti.engine.repository.ProcessDefinition; import org.activiti.engine.repository.ProcessDefinitionQuery; import org.activiti.engine.runtime.ProcessInstance; import org.activiti.engine.task.Task; import org.apache.commons.io.IOUtils; import org.junit.Test; import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.util.List; import java.util.zip.ZipInputStream; /** * 工作流引擎创建 、流程部署、查询流程定义、任务查看、个人任务完成、删除部署、删除流程定义、下载资源、查看历史信息 * @param * @author 张延分 * @date 2020-01-05 * @return **/ public class TestActivitiDemo { /*创建数据表结构*/ @Test public void testCreateDb(){ // 工作流引擎（ProcessEngine）相当于一个门面接口，通过ProcessEngineConfiguration创建，通过ProcessEngine创建各个Service //1、默认创建方式，配置文件名只能为activiti.cfg.xml // ProcessEngine processEngine= ProcessEngines.getDefaultProcessEngine(); //2、使用自定义方式 获取工作流引擎；配置文件名可自定义名称 ProcessEngineConfiguration pec=ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml"); // 创建一个流程引擎对象，在创建流程引擎对象时会自动建表 ProcessEngine processEngine=pec.buildProcessEngine(); System.out.println(processEngine); System.out.println("数据表创建完毕"); } /** * 1-部署流程定义(第一种方式） * 下面三个表会保存流程的定义信息 * act_re_deployment ： 部署信息 * act_re_procdef ： 流程定义的相关信息 * act_ge_bytearray ： 流程定义的bpmn文件及png文件 */ @Test public void testDeployed(){ //1、默认创建方式，配置文件名只能为activiti.cfg.xml ProcessEngine processEngine= ProcessEngines.getDefaultProcessEngine(); //2、读取RepositoryService RepositoryService repositoryService = processEngine.getRepositoryService(); //3、使用service进行流程部署，定义一个流程名字，把bpmn和png部署到数据库汇总 Deployment deployment = repositoryService.createDeployment() // 创建一个部署对象 .name("请假申请流程")// 添加部署的名称 .addClasspathResource("bpmn/evection.bpmn") .addClasspathResource("bpmn/evection.png") .deploy();// 完成部署 //4、输出部署 System.out.println("流程部署Id："+deployment.getId()); System.out.println("流程部署key："+deployment.getKey()); System.out.println("流程部署名称："+deployment.getName()); System.out.println("流程部署版本号："+deployment.getVersion()); System.out.println("流程部署时间："+deployment.getDeploymentTime()); // 流程部署Id：1 // 流程部署key：null // 流程部署名称：请假申请流程 // 流程部署版本号：1 // 流程部署时间：Fri Sep 17 10:35:43 CST 2021 } /** * 1- 部署流程定义(第二种方式） * 新建文件夹，把 .bpmn 文件和 .png 文件放入文件夹，再把改文件夹压缩成zip包 */ public void testDeployedByZip() { //1、获取ProcessEngine 流程引擎对象 ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); //2、获取 RepositoryService 实例 RepositoryService repositoryService = processEngine.getRepositoryService(); //3、读取资源文件并创建 zip 流 InputStream inputStream = TestActivitiDemo.class .getClassLoader() .getResourceAsStream("bpmn/evetion.zip"); //用inputstream 构建 ZipInputStream ZipInputStream zipInputStream = new ZipInputStream(inputStream); //4、部署 Deployment deployment = repositoryService.createDeployment() .addZipInputStream(zipInputStream) .name("请假申请流程") .deploy(); //5、查看结果 System.out.println("流程部署Id："+deployment.getId()); System.out.println("流程部署key："+deployment.getKey()); System.out.println("流程部署名称："+deployment.getName()); System.out.println("流程部署版本号："+deployment.getVersion()); System.out.println("流程部署时间："+deployment.getDeploymentTime()); } /** * 2-启动流程 * * 启动流程后，在如下的表中会增加会更新数据 * act_ru_task -- (只有节点为UserTask该表才会有数据)：正在执行的任务表 * act_ru_execution -- 正在执行的执行对象表 * act_ru_identitylink -- 参与者信息 * act_hi_procinst -- 流程实例历史表 * act_hi_taskinst -- (只有节点为UserTask该表才会有数据)：任务历史表 * act_hi_actinst -- 所有活动的历史表 * act_hi_identitylink -- 参与者信息 */ @Test public void testStartProcessInstance(){ //流程定义的key.,key对应evection.bpmn文件中id的属性值，使用key值启动，默认是按照最新版本的流程定义启动 String processDefinitionKey = "myEvection"; //1、获取ProcessEngine 流程引擎对象 ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); //2、获取RuntimeService RuntimeService runtimeService = processEngine.getRuntimeService();//与正在执行的流程实例和执行对象相关的Service //3、根据流程定义的id启动流程 ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(processDefinitionKey);//使用流程定义的key启动流程实例 //4、查看结果 System.out.println("流程部署ID:"+processInstance.getDeploymentId()); System.out.println("流程定义ID:"+processInstance.getProcessDefinitionId()); System.out.println("流程实例ID:"+processInstance.getId()); System.out.println("流程定义的key:"+processInstance.getProcessDefinitionKey()); System.out.println("当前活动(运行中流程)ID:"+processInstance.getActivityId()); System.out.println("StartUserId:"+processInstance.getStartUserId()); // 流程部署ID:null // 流程定义ID:myEvection:1:4 // 流程实例ID:2501 // 流程定义的key:myEvection // 当前活动(运行中流程)ID:null // StartUserId:null } /** * 3-查询个人待执行任务 */ @Test public void testFindTaskList() { //1、获取流程引擎 ProcessEngine 对象 ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); //2、获取 TaskService 对象 TaskService taskService = processEngine.getTaskService();//与正在执行的任务管理相关的Service //3、根据 key 和 当前实例任务负责人 进行查询 List<Task> taskList = taskService.createTaskQuery() //创建任务查询对象 .processDefinitionKey("myEvection")//流程key /**查询条件（where部分）*/ .taskAssignee("zhangsan")//查询的负责人 // .taskCandidateUser(candidateUser)//组任务的办理人查询 // .processDefinitionId(processDefinitionId)//使用流程定义ID查询 // .p