Activiti7学习十一 网关

网关用来控制流程的流向
Activiti中的网关有三种:

排他网关ExclusiveGateway
排他网关就是只有一个流向满足条件才能通过,需要有条件来控制,和使用变量来控制流向差不多,
但是如果使用变量控制流向不满足表达式的话,会立即结束流程,而使用排他网关控制流向的话,如果不满足表达式,会跑出异常。

并行网关ParallelGateway
多个流向都需要处理后,到汇聚点处再处理下一个任务。

包含网关InclusiveGateway
既有排他网关,又有并行网管就是包含网关。

排他网关流程设计
在这里插入图片描述
代码

 /**
     * 部署流程  发布组任务流程
     */
    @Test
    public  void test02(){
        //获取引擎
        ProcessEngine engine=ProcessEngines.getDefaultProcessEngine();
        //获取资源服务
        RepositoryService service = engine.getRepositoryService();
        Deployment deploy = service.createDeployment()
                .addClasspathResource("bpmn/evection_gateway.bpmn")
                .addClasspathResource("bpmn/evection_gateway.svg")
                .name("网关测试")
                .deploy();
        System.out.println("部署的id:"+deploy.getId());
        System.out.println("部署的key:"+deploy.getKey());
        System.out.println("部署的名称:"+deploy.getName());
        System.out.println("部署的时间:"+deploy.getDeploymentTime());
    }

    /**
     * 开启一个实例
     */
    @Test
    public void test03(){
        ProcessEngine engine=ProcessEngines.getDefaultProcessEngine();
        RuntimeService service = engine.getRuntimeService();
        Evection evection = new Evection();
        evection.setNum(3);
        Map<String, Object> map = new HashMap<>();
        map.put("evection",evection);
//        ProcessInstance evectionInstance = service.startProcessInstanceByKey("Process_1655017372539",map);
        ProcessInstance evectionInstance = service.startProcessInstanceByKey("evecation_gateway",map);
//        ProcessInstance evection = service.startProcessInstanceById("27501");
        System.out.println(evectionInstance.getProcessDefinitionId());
        System.out.println(evectionInstance.getProcessDefinitionName());
        System.out.println(evectionInstance.getId());
        System.out.println(evectionInstance.getName());
    }

    /**
     * 查询任务,处理任务
     * 创建请假申请
     */
    @Test
    public void test04(){
        ProcessEngine engine=ProcessEngines.getDefaultProcessEngine();
        TaskService service = engine.getTaskService();
        //查询任务
        Task task = service.createTaskQuery()
                .taskAssignee("user3")
                .processDefinitionKey("evecation_gateway")
                .singleResult();
        service.complete(task.getId());
    }

并行网关即使设置了条件也没有用,都会等待所有的分支都执行完毕了才流向下一个节点


版权声明:本文为u011447164原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。