网站能带来什么,做宠物食品的网站,新闻cms静态网站模板下载,做废旧金属的网站任务分配和流程变量
1.任务分配
1.1 固定分配 固定分配就是我们前面介绍的#xff0c;在绘制流程图或者直接在流程文件中通过Assignee来指定的方式
1.2 表达式分配 Flowable使用UEL进行表达式解析。UEL代表Unified Expression Language#xff0c;是EE6规范的一部分.Flo…任务分配和流程变量
1.任务分配
1.1 固定分配 固定分配就是我们前面介绍的在绘制流程图或者直接在流程文件中通过Assignee来指定的方式
1.2 表达式分配 Flowable使用UEL进行表达式解析。UEL代表Unified Expression Language是EE6规范的一部分.Flowable支持两种UEL表达式 UEL-value 和UEL-method
1.2.1 值表达式 值表达式 Value expression: 解析为一个值。默认情况下所有流程变量都可以使用。若使用Spring所有的Spring bean也可以用在表达式里。例如
${myVar}
${myBean.myProperty}案例讲解 可以看到通过表达式处理的效果 先部署流程然后在启动流程实例的时候绑定表达式对应的值
/*** 启动流程实例*/Testpublic void testRunProcess(){// 获取流程引擎对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();// 启动流程实例通过 RuntimeService 对象RuntimeService runtimeService processEngine.getRuntimeService();// 设置 assignee 的取值MapString,Object variables new HashMap();variables.put(assignee0,张三) ;variables.put(assignee1,李四); // 启动流程实例第一个参数是流程定义的idProcessInstance processInstance runtimeService.startProcessInstanceById(MyHolidayUI:1:4, variables);// 启动流程实例// 输出相关的流程实例信息System.out.println(流程定义的ID processInstance.getProcessDefinitionId());System.out.println(流程实例的ID processInstance.getId());System.out.println(当前活动的ID processInstance.getActivityId());}1.2.2 方法表达式 方法表达式 Method expression: 调用一个方法可以带或不带参数。**当调用不带参数的方法时要确保在方法名后添加空括号以避免与值表达式混淆。**传递的参数可以是字面值(literal value)也可以是表达式它们会被自动解析。例如
${printer.print()}
${myBean.addNewOrder(orderName)}
${myBean.doSomething(myVar, execution)}myBean是Spring容器中的个Bean对象表示调用的是bean的addNewOrder方法
1.3 监听器分配
可以使用监听器来完成很多Flowable的流程业务。
我们在此处使用监听器来完成负责人的指定那么我们在流程设计的时候就不需要指定assignee
创建自定义监听器
/*** 自定义的监听器*/
public class MyTaskListener implements TaskListener {Overridepublic void notify(DelegateTask delegateTask) {System.out.println(监听器触发了 delegateTask.getName());if(提交请假流程.equals(delegateTask.getName()) create.equals(delegateTask.getEventName())){// 指定任务的负责人delegateTask.setAssignee(小明);}else {delegateTask.setAssignee(小张);}}
}然后在FlowableUI中关联对应的监听器 create:任务创建后触发 assignment:任务分配后触发 Delete:任务完成后触发 All所有事件都触发 然后我们先部署流程然后执行查看效果 然后在Task表中我们可以看到对应的分配人为小明说明通过监听也完成了任务分配的工作了 2.流程变量 流程实例按步骤执行时需要使用一些数据。在Flowable中这些数据称作变量(variable)并会存储在数据库中。变量可以用在表达式中例如在排他网关中用于选择正确的出口路径也可以在Java服务任务(service task)中用于调用外部服务例如为服务调用提供输入或结果存储等等。 流程实例可以持有变量称作流程变量 process variables用户任务以及执行(executions)——流程当前活动节点的指针——也可以持有变量。流程实例可以持有任意数量的变量每个变量存储为ACT_RU_VARIABLE数据库表的一行。 所有的startProcessInstanceXXX方法都有一个可选参数用于在流程实例创建及启动时设置变量。例如在RuntimeService中
ProcessInstance startProcessInstanceByKey(String processDefinitionKey, MapString, Object variables);2.1 全局变量 流程变量的默认作用域是流程实例。当一个流程变量的作用域为流程实例时可以称为 global 变量
注意如 Global变量userId变量名、zhangsan变量值 global 变量中变量名不允许重复设置相同名称的变量后设置的值会覆盖前设置的变量值。
2.2 局部变量 任务和执行实例仅仅是针对一个任务和一个执行实例范围范围没有流程实例大 称为 local 变量。 Local 变量由于在不同的任务或不同的执行实例中作用域互不影响变量名可以相同没有影响。Local 变量名也可以和 global 变量名相同没有影响。
2.3 案例讲解
需求员工创建出差申请单由部门经理审核部门经理申请通过后3天以下由财务直接申批3天以上先由总经理审批总经理审批通过后再由财务审批。 连接先设置条件 部署流程
Test
public void deploy(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RepositoryService repositoryService processEngine.getRepositoryService();Deployment deploy repositoryService.createDeployment().addClasspathResource(出差申请单.bpmn20.xml).name(请假流程...).category(请假) // 分类.tenantId(dpb) // 租户id.deploy();System.out.println(deploy.getId() deploy.getId());System.out.println(deploy.getName() deploy.getName());System.out.println(deploy.getCategory() deploy.getCategory());
}启动流程实例并且指定全局流程变量
/*** 在启动流程实例的时候设置流程变量*/Testpublic void runProcess(){// 获取流程引擎对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();// 启动流程实例通过 RuntimeService 对象RuntimeService runtimeService processEngine.getRuntimeService();// 设置流程变量MapString,Object variables new HashMap();// 设置assignee的取值variables.put(assignee0,张三);variables.put(assignee1,李四);variables.put(assignee2,王五);variables.put(assignee3,赵财务);// 启动流程实例第一个参数是流程定义的idProcessInstance processInstance runtimeService.startProcessInstanceById(evection:1:4,variables);// 启动流程实例// 输出相关的流程实例信息System.out.println(流程定义的ID processInstance.getProcessDefinitionId());System.out.println(流程实例的ID processInstance.getId());System.out.println(当前活动的ID processInstance.getActivityId());}完成Task任务同时也可以指定流程变量
/*** 完成任务时指定流程变量*/Testpublic void completeTask(){// 获取流程引擎对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();Task task taskService.createTaskQuery().processDefinitionId(evection:1:4).taskAssignee(李四).singleResult();// 添加流程变量MapString, Object map task.getProcessVariables();map.put(num,4);// 完成任务taskService.complete(task.getId(),map);}当然我们也可以在处理流程之外通过Task编号来修改流程变量
/*** 通过当前任务设置*/Testpublic void currentTask(){// 当前待办任务id// 获取processEngineProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();Task task taskService.createTaskQuery().processDefinitionId(evection:1:4).taskAssignee(王五).singleResult();// 添加流程变量MapString, Object map task.getProcessVariables();map.put(num,1);// 一次设置多个值 设置局部变量taskService.setVariables(task.getId(), map);}二、候选人和候选人组 在流程定义中在任务结点的 assignee 固定设置任务负责人在流程定义时将参与者固定设置在.bpmn 文件中如果临时任务负责人变更则需要修改流程定义系统可扩展性差。针对这种情况可以给任务设置多个候选人或者候选人组可以从候选人中选择参与者来完成任务。
1.候选人
1.1 定义流程图 定义流程图同时指定候选人多个候选人会通过,连接 1.2 部署和启动流程实例 部署流程并且在启动流程实例的时候对UEL表达式赋值 /*** 部署流程*/Testpublic void deploy(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RepositoryService repositoryService processEngine.getRepositoryService();Deployment deploy repositoryService.createDeployment().addClasspathResource(请假流程-候选人.bpmn20.xml).name(请求流程-候选人).deploy();System.out.println(deploy.getId() deploy.getId());System.out.println(deploy.getName());}/*** 启动流程实例*/Testpublic void runProcess(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RuntimeService runtimeService processEngine.getRuntimeService();// 给流程定义中的UEL表达式赋值MapString,Object variables new HashMap();variables.put(candidate1,张三);variables.put(candidate2,李四);variables.put(candidate3,王五);runtimeService.startProcessInstanceById(holiday-candidate:1:4,variables);}在对应的表结构中我们可以看到流程变量已经有了但是对于的Task的Assignee还是为空。 1.3 任务的查询 根据当前登录的用户查询对应的候选任务
/*** 根据登录的用户查询对应的可以拾取的任务**/Testpublic void queryTaskCandidate(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();ListTask list taskService.createTaskQuery()//.processInstanceId(2501).processDefinitionId(holiday-candidate:1:4).taskCandidateUser(李四) # 注意.list();for (Task task : list) {System.out.println(task.getId() task.getId());System.out.println(task.getName() task.getName());}}1.4 任务的拾取 知道了我有可拾取的任务后拾取任务。
/*** 拾取任务* 一个候选人拾取了这个任务之后其他的用户就没有办法拾取这个任务了* 所以如果一个用户拾取了任务之后又不想处理了那么可以退还*/Testpublic void claimTaskCandidate(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();Task task taskService.createTaskQuery()//.processInstanceId(2501).processDefinitionId(holiday-candidate:1:4).taskCandidateUser(李四).singleResult();if(task ! null){// 拾取对应的任务taskService.claim(task.getId(),李四);System.out.println(任务拾取成功);}}1.5 任务的归还 拾取任务后不想操作那么就归还任务 /*** 退还任务* 一个候选人拾取了这个任务之后其他的用户就没有办法拾取这个任务了* 所以如果一个用户拾取了任务之后又不想处理了那么可以退还*/Testpublic void unclaimTaskCandidate(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();Task task taskService.createTaskQuery()//.processInstanceId(2501).processDefinitionId(holiday-candidate:1:4).taskAssignee(张三).singleResult();if(task ! null){// 拾取对应的任务taskService.unclaim(task.getId());System.out.println(归还拾取成功);}}1.6 任务的交接 拾取任务后如果不想操作也不想归还可以直接交接给另外一个人来处理 /*** 任务的交接* 如果我获取了任务但是不想执行那么我可以把这个任务交接给其他的用户*/Testpublic void taskCandidate(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();Task task taskService.createTaskQuery()//.processInstanceId(2501).processDefinitionId(holiday-candidate:1:4).taskAssignee(李四).singleResult();if(task ! null){// 任务的交接taskService.setAssignee(task.getId(),王五);System.out.println(任务交接给了王五);}}1.7 任务的完成 正常的任务处理
/*** 完成任务*/Testpublic void completeTask(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();Task task taskService.createTaskQuery()//.processInstanceId(2501).processDefinitionId(holiday-candidate:1:4).taskAssignee(王五).singleResult();if(task ! null){// 完成任务taskService.complete(task.getId());System.out.println(完成Task);}}
2.候选人组 当候选人很多的情况下我们可以分组来处理。先创建组然后把用户分配到这个组中。
2.1 管理用户和组
2.1.1 用户管理 我们需要先单独维护用户信息。后台对应的表结构是ACT_ID_USER.
/*** 维护用户*/Testpublic void createUser(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();// 通过 IdentityService 完成相关的用户和组的管理IdentityService identityService processEngine.getIdentityService();User user identityService.newUser(田佳);user.setFirstName(田);user.setLastName(jia);user.setEmail(tianjiaqq.com);identityService.saveUser(user);}2.1.2 Group管理 维护对应的Group信息后台对应的表结构是ACT_ID_GROUP /*** 创建用户组*/Testpublic void createGroup(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();IdentityService identityService processEngine.getIdentityService();// 创建Group对象并指定相关的信息Group group identityService.newGroup(group2);group.setName(开发部);group.setType(type1);// 创建Group对应的表结构数据identityService.saveGroup(group);}2.1.3 用户分配组 用户和组是一个多对多的关联关联我们需要做相关的分配后台对应的表结构是ACT_ID_MEMBERSHIP /*** 将用户分配给对应的Group*/Testpublic void userGroup(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();IdentityService identityService processEngine.getIdentityService();// 根据组的编号找到对应的Group对象Group group identityService.createGroupQuery().groupId(group1).singleResult();ListUser list identityService.createUserQuery().list();for (User user : list) {// 将用户分配给对应的组identityService.createMembership(user.getId(),group.getId());}}2.2 候选人组应用 搞清楚了用户和用户组的关系后我们就可以来使用候选人组的应用了
2.2.1 创建流程图 2.2.2 流程的部署运行 然后我们把流程部署和运行注意对UEL表达式赋值关联上Group
/*** 部署流程*/Testpublic void deploy(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RepositoryService repositoryService processEngine.getRepositoryService();Deployment deploy repositoryService.createDeployment().addClasspathResource(请假流程-候选人组.bpmn20.xml).name(请求流程-候选人).deploy();System.out.println(deploy.getId() deploy.getId());System.out.println(deploy.getName());}/*** 启动流程实例*/Testpublic void runProcess(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();IdentityService identityService processEngine.getIdentityService();Group group identityService.createGroupQuery().groupId(group1).singleResult();RuntimeService runtimeService processEngine.getRuntimeService();// 给流程定义中的UEL表达式赋值MapString,Object variables new HashMap();// variables.put(g1,group1);variables.put(g1,group.getId()); // 给流程定义中的UEL表达式赋值runtimeService.startProcessInstanceById(holiday-group:1:17504,variables);}对应表结构中就有对应的体现
2.2.3 任务的拾取和完成 然后完成任务的查询拾取和处理操作
/*** 根据登录的用户查询对应的可以拾取的任务**/Testpublic void queryTaskCandidateGroup(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();// 根据当前登录的用户找到对应的组IdentityService identityService processEngine.getIdentityService();// 当前用户所在的组Group group identityService.createGroupQuery().groupMember(邓彪).singleResult();TaskService taskService processEngine.getTaskService();ListTask list taskService.createTaskQuery()//.processInstanceId(2501).processDefinitionId(holiday-group:1:17504).taskCandidateGroup(group.getId()).list();for (Task task : list) {System.out.println(task.getId() task.getId());System.out.println(task.getName() task.getName());}}/*** 拾取任务* 一个候选人拾取了这个任务之后其他的用户就没有办法拾取这个任务了* 所以如果一个用户拾取了任务之后又不想处理了那么可以退还*/Testpublic void claimTaskCandidate(){String userId 田佳;ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();// 根据当前登录的用户找到对应的组IdentityService identityService processEngine.getIdentityService();// 当前用户所在的组Group group identityService.createGroupQuery().groupMember(userId).singleResult();TaskService taskService processEngine.getTaskService();Task task taskService.createTaskQuery()//.processInstanceId(2501).processDefinitionId(holiday-group:1:17504).taskCandidateGroup(group.getId()).singleResult();if(task ! null) {// 任务拾取taskService.claim(task.getId(),userId);System.out.println(任务拾取成功);}} /*** 完成任务*/Testpublic void completeTask(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();Task task taskService.createTaskQuery()//.processInstanceId(2501).processDefinitionId(holiday-group:1:17504).taskAssignee(邓彪).singleResult();if(task ! null){// 完成任务taskService.complete(task.getId());System.out.println(完成Task);}}三、网关
网关用来控制流程的流向
1.排他网关 排他网关exclusive gateway也叫异或网关 XOR gateway或者更专业的基于数据的排他网关 exclusive data-based gateway用于对流程中的决策建模。当执行到达这个网关时会按照所有出口顺序流定义的顺序对它们进行计算。选择第一个条件计算为true的顺序流当没有设置条件时认为顺序流为true继续流程。 请注意这里出口顺序流的含义与BPMN 2.0中的一般情况不一样。一般情况下会选择所有条件计算为true的顺序流并行执行。而使用排他网关时只会选择一条顺序流。当多条顺序流的条件都计算为true时会且仅会选择在XML中最先定义的顺序流继续流程。如果没有可选的顺序流会抛出异常。
图示 排他网关用内部带有’X’图标的标准网关菱形表示X’图标代表异或的含义。请注意内部没有图标的网关默认为排他网关。BPMN 2.0规范不允许在同一个流程中混合使用有及没有X的菱形标志。 案例 /*** 部署流程*/Testpublic void deploy(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RepositoryService repositoryService processEngine.getRepositoryService();Deployment deploy repositoryService.createDeployment().addClasspathResource(请假流程-排他网关.bpmn20.xml).name(请求流程-排他网关).deploy();System.out.println(deploy.getId() deploy.getId());System.out.println(deploy.getName());}/*** 启动流程实例*/Testpublic void runProcess(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RuntimeService runtimeService processEngine.getRuntimeService();// 给流程定义中的UEL表达式赋值MapString,Object variables new HashMap();// variables.put(g1,group1);variables.put(num,3); // 给流程定义中的UEL表达式赋值runtimeService.startProcessInstanceById(holiday-exclusive:1:4,variables);}/*** 启动流程实例*/Testpublic void setVariables(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RuntimeService runtimeService processEngine.getRuntimeService();// 给流程定义中的UEL表达式赋值MapString,Object variables new HashMap();// variables.put(g1,group1);variables.put(num,4); // 给流程定义中的UEL表达式赋值runtimeService.setVariables(12503,variables);}/*** 完成任务*/Testpublic void completeTask(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();Task task taskService.createTaskQuery()//.processInstanceId(2501).processDefinitionId(holiday-exclusive:1:4).taskAssignee(zhangsan).singleResult();if(task ! null){// 完成任务taskService.complete(task.getId());System.out.println(完成Task);}}如果从网关出去的线所有条件都不满足的情况下会抛出系统异常 但是要注意任务没有介绍还是原来的任务我们可以重置流程变量 Testpublic void setVariables(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RuntimeService runtimeService processEngine.getRuntimeService();// 给流程定义中的UEL表达式赋值MapString,Object variables new HashMap();// variables.put(g1,group1);variables.put(num,4); // 给流程定义中的UEL表达式赋值runtimeService.setVariables(12503,variables);}2.并行网关 并行网关允许将流程分成多条分支也可以把多条分支汇聚到一起并行网关的功能是基于进入和外出顺序流的 fork分支并行后的所有外出顺序流为每个顺序流都创建一个并发分支。 join汇聚 所有到达并行网关在此等待的进入分支 直到所有进入顺序流的分支都到达以后 流程就会通过汇聚网关。 注意如果同一个并行网关有多个进入和多个外出顺序流 它就同时具有分支和汇聚功能。 这时网关会先汇聚所有进入的顺序流然后再切分成多个并行分支。
与其他网关的主要区别是并行网关不会解析条件。 即使顺序流中定义了条件也会被忽略。
案例 当我们执行了创建请假单后到并行网关的位置的时候在ACT_RU_TASK表中就有两条记录
然后同时在ACT_RU_EXECUTION中有三条记录一个任务对应的有两个执行实例
3.包含网关 包含网关可以看做是排他网关和并行网关的结合体。 和排他网关一样你可以在外出顺序流上定义条件包含网关会解析它们。 但是主要的区别是包含网关可以选择多于一条顺序流这和并行网关一样。
包含网关的功能是基于进入和外出顺序流的 分支 所有外出顺序流的条件都会被解析结果为true的顺序流会以并行方式继续执行 会为每个顺序流创建一个分支。 汇聚所有并行分支到达包含网关会进入等待状态 直到每个包含流程token的进入顺序流的分支都到达。 这是与并行网关的最大不同。换句话说包含网关只会等待被选中执行了的进入顺序流。 在汇聚之后流程会穿过包含网关继续执行。
4.事件网关 事件网关允许根据事件判断流向。网关的每个外出顺序流都要连接到一个中间捕获事件。 当流程到达一个基于事件网关网关会进入等待状态会暂停执行。与此同时会为每个外出顺序流创建相对的事件订阅。 事件网关的外出顺序流和普通顺序流不同这些顺序流不会真的执行 相反它们让流程引擎去决定执行到事件网关的流程需要订阅哪些事件。 要考虑以下条件
事件网关必须有两条或以上外出顺序流事件网关后只能使用intermediateCatchEvent类型activiti不支持基于事件网关后连接ReceiveTask连接到事件网关的中间捕获事件必须只有一个入口顺序流。
