Activiti基础知识

创建Activiti工作流主要包含以下几步：

1、定义流程，按照BPMN的规范，使用流程定义工具，用流程符号把整个流程描述出来

2、部署流程，把画好的流程定义文件，加载到数据库中，生成表的数据

3、启动流程，使用java代码来操作数据库表中的内容

部署操作

  @Test
    void testDepoYment(){
        //1:创建ProcessEngine
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        //2:获取RepositoryService
        RepositoryService repositoryService = processEngine.getRepositoryService();
        //3:使用Service进行流程部署,定义流程名字 把bpmn和png部署到数据库里面
        Deployment deploy = repositoryService.createDeployment()
                .name("出差申请流程")
                .addClasspathResource("bmpn/evection.bpmn")
                .addClasspathResource("bmpn/evection.png")
                .deploy();
        //4: 输出部署信息
        System.out.println("流程部署的id"+deploy.getId());
        System.out.println("流程部署的名称"+deploy.getName());
    }

一次部署流程会操作三张表

act_re_deployment 流程部署表，每部署一次就会新增一条记录
act_re_procdef 流程定义表生成流程定义信息
注意:act_re_deployment和act_re_procdef是一对多的关系在procdef表中可以有多条记录，每条记录对应一个流程的定义信息
启动流程实例

 /**
     * 启动流程实例
     */
    @Test
    void testStartProcess() {
         //1:创建ProcessEngine
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        //2:获取Run timeService activiti的流程运行管理类
        RuntimeService runtimeService = processEngine.getRuntimeService();
        //3:根据流程定义的id启动流程 id-> bpmn文件的名命id 也就是act_re_procdef 表中的key
        ProcessInstance instance = runtimeService.startProcessInstanceByKey("myEvevtion");
        //4:s数处内容
        System.err.println("流程定义Id"+instance.getProcessDefinitionId());
        System.err.println("流程实例Id"+instance.getId());
        System.err.println("当前活动的id"+instance.getActivityId());

    }

启动流程实例会操作四张表

act_re_deployment 流程部署表每次部署都会添加进来数据
act_re_procdef 流程定义表
act_ge_bytearray 通用数据表流程资源表

act_hi_actinst 流程实例执行历史
act_hi_actinst 流程参与者的历史信息
act_hi_procinst 流程实例的历史信息
act_hi_taskinst 任务的历史信息
act_ru_execution 流程执行的信息
act_ru_identitylink 流程参与者的信息
act_ru_task 任务信息

查询个人待执行的任务

 /**
     * 查询个人待执行的任务
     */
    @Test
    void testFindPersonalTaskList(){
        //1:获取流程引擎
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        //2:使用TaskService acticviti的任务管理类
        TaskService taskService = processEngine.getTaskService();
        //3:根据流程的key 和人物的负责人 查询任务
        List<Task> taskList = taskService.createTaskQuery()
                // 流程的key
                .processDefinitionKey("myEvevtion")
                // 要查询的负责人
                .taskAssignee("zhangsan")
                .list();
        //4:输出
        for (Task task : taskList) {
            System.out.println("流程实例id"+task.getProcessInstanceId());
            System.out.println("任务id"+task.getId());
            System.out.println("任务负责人"+task.getAssignee());
            System.out.println("任务名称"+task.getName());
        }
    }

主要操作表
act_ru_task act_re_procdef

完成个人任务

  /**
     * 完成任务
     */
    @Test
    void completeTask() {
        //1:获取流程引擎
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        //2:使用TaskService acticviti的任务管理类
        TaskService taskService = processEngine.getTaskService();
        // 根据任务id完成任务
        taskService.complete("20fea024-a64e-11eb-8ccf-005056c00008");
    }

主要操作表：
act_hi_taskinst INSERT
act_hi_actinst
act_hi_identitylink
act_ru_task
act_ru_identitylink
act_hi_taskinst UPDATE
act_ru_execution UPDATE
act_hi_actinst
act_ru_task

查询流程定义

  /**
     * 查询流程定义
     */
    @Test
    void queryProcessDefinition(){
        // 获取流程引擎
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        // 获取RepositoryService  activiti的资源管理类
        RepositoryService repositoryService = processEngine.getRepositoryService();
        // createProcessDefinitionQuery
        ProcessDefinitionQuery deploymentQuery = repositoryService.createProcessDefinitionQuery();
        // 查询当前所有流程的定义
        //processDefinitionKey(流程定义的key)
        // 根据orderByProcessDefinitionVersion 进行排序
        // decs 倒叙排序
        // list 所有的内容
        List<ProcessDefinition> myEvevtion = deploymentQuery.processDefinitionKey("myEvevtion").
                orderByProcessDefinitionVersion().desc().list();

        for (ProcessDefinition processDefinition : myEvevtion) {
            System.out.println("流程定义的id:" +processDefinition.getId());
            System.out.println("流程定义的名称:" +processDefinition.getName());
            System.out.println("流程定义的key:" +processDefinition.getKey());
            System.out.println("流程定义的版本:" +processDefinition.getVersion());
            System.out.println("流程部署的id:" +processDefinition.getDeploymentId());
        }
    }

删除流程部署信息 历史信息不会被删除

    /**
     * 删除流程部署信息
     */
    @Test
    void deleteDeployMent() {
        // 获取流程引擎
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        // 获取RepositoryService  activiti的资源管理类
        RepositoryService repositoryService = processEngine.getRepositoryService();
        // 通过部署的id来删除流程部署信息
        String deployMentId = "7c90ab1b-a642-11eb-85c9-005056c00008";
        repositoryService.deleteDeployment(deployMentId);
    }

`删除注意事项 :当前的流程如果没有完成,想要删除的话需要使用特殊方式原理就是级联删除`

repositoryService.deleteDeployment(deployMentId, true);

主要操作表
act_re_deployment 流程部署表每次部署都会删除
act_re_procdef 流程定义表
act_ge_bytearray 通用数据表流程资源表

下载资源文件

/**
     * 下载资源文件
     * 方案1: 使用Activiti 提供的api 来下载文件，保存到文件目录还是要使用io操作
     * 方案2: 自己写代码从数据库中下载文件 使用jdbc 对blob 类型 clob类型数据读取出来 保存到文件目录
     * 解决Io 操作 commons-jo.jar
     * 我们这里使用方案1 使用repositoryService
     */
    @Test
    void getDelpyMent() throws IOException {
        // 获取流程引擎
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        // 获取RepositoryService  activiti的资源管理类
        RepositoryService repositoryService = processEngine.getRepositoryService();
//        // createProcessDefinitionQuery 查询流程定义
        ProcessDefinitionQuery deploymentQuery = repositoryService.createProcessDefinitionQuery();
        ProcessDefinition myEvevtion = deploymentQuery.processDefinitionKey("myEvevtion").
                singleResult();
        // 获取部署id 和资源名称
        String deploymentId = myEvevtion.getDeploymentId();
        String pngName = myEvevtion.getDiagramResourceName();
        // 通过部署id 获取资源信息(png/bpmn) 获取照片的资源
        InputStream pngInput = repositoryService.getResourceAsStream(deploymentId, pngName);
        // 获取bpmn的流
        String bpmnName = myEvevtion.getResourceName();
        InputStream bpmnInput = repositoryService.getResourceAsStream(deploymentId, bpmnName);
        // 构造OutputStream流
        File pngFile = new File("E:\\test\\evectionflopw01.png");
        File bpmmnFile = new File("E:\\test\\evectionflopw01.bpmn");
        FileOutputStream pngFileStream = new FileOutputStream(pngFile);
        FileOutputStream bpmmnFileStream = new FileOutputStream(bpmmnFile);

        // 输入流，输出流转换
        IOUtils.copy(pngInput, pngFileStream);
        IOUtils.copy(bpmnInput, bpmmnFileStream);
        //关闭流
        pngFileStream.close();
        bpmmnFileStream.close();
        pngInput.close();
        bpmnInput.close();
    }

查询历史信息

/**
     * 查询历史信息
     */
    @Test
    void findHistoryInfo(){
        // 获取流程引擎
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        // 获取HistoryService
        HistoryService historyService = processEngine.getHistoryService();
        //获取actinset包查询对象
        HistoricActivityInstanceQuery instanceQuery = historyService.createHistoricActivityInstanceQuery();
        // 条件根据 InstanceId 和 DefinitionId  条件不同
//        instanceQuery.processInstanceId("20faf6a0-a64e-11eb-8ccf-005056c00008");
        instanceQuery.processDefinitionId("myEvevtion:1:7ca5448e-a642-11eb-85c9-005056c00008");
        //增加排序操作 根据开始时间排序 升序操作
        instanceQuery.orderByHistoricActivityInstanceStartTime().asc();
        // 查询所有内容
        List<HistoricActivityInstance> historicActivityInstanceList = instanceQuery.list();
        //输出
        for (HistoricActivityInstance instance : historicActivityInstanceList) {
            System.out.println(instance.getActivityId());
            System.out.println(instance.getActivityName());
            System.out.println(instance.getProcessDefinitionId());
            System.out.println(instance.getProcessDefinitionId());
        }

    }

Activiti基础知识