jpdl 流程定义语言的使用

本文主要是介绍jpdl 流程定义语言的使用，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

一、jpdl 流程定义语言的使用

l process（流程）

l transition （连线、转移）

l 流转控制活动

• start （开始活动）

• end、end-error、end-cancel （结束活动）

• state （状态活动）

• task （任务活动）

• decision （判断活动）

• fork、join （分支/聚合活动）

1、 process 节点是jpdl 流程描述的根节点，任何流程都要定义

process 节点的属性：

name 属性：流程名称（用于显示）

key属性：流程关键字（用于查询，通常没有中文），每个流程key应该是不同，如果没有指定key ，将会采用name 的值（一般用key查询）

注：同样key的流程，name必须相同

version属性：流程版本号每次发布同样key 流程，自动+1，如果指定了version，可能存在冲突问题，冲突就报错

pdId 规则：key加上’-’加上version号例：holiday-1

2、 transition连线、转移

作用：用来连接活动节点，完成流程运转

开始节点只能有一个transition 。结束节点不能用 transition，可以有多个。

常用属性

name属性：转移连线名称（通常只有一个transition节点，可以不指定name，有些节点具有多个transition，此时必须指定name属性，并且name要唯一）

to属性：必须的，指定另一个活动节点名称

注意：有name的transition向后一步操作时，需要指定 transition的name

无name的transition向后一步，无需指定流转

3、 start活动节点和end活动节点

start开始节点，在一个活动图中只能有一个开始节点。

end结束节点，在一个活动图中可以有多个结束节点。

中止流程代码（不管运行到哪个节点，停止该流程）

processEngine.getExecutionService().endProcessInstance(processInstanceId,ProcessInstance.STATE_ENDED);

4、 state节点（状态节点、等待节点）

当执行到state节点时，和task节点一样需要等待

和task节点区别： task节点需要指定人来完成任务， state节点通常不需要人工干预，就可以继续执行节点

例如：报销的时候申请完要经理处理，经理处理就为一个task，处理完后自动转账就为一个state

Task节点完成时，需要调用 taskService.completeTask() 完成任务。

State 节点完成时，只能调用 executionService.signalExecutionById 向后一步。

5、 decision 判断节点

条件判断节点，主要用于在流程中，可以根据不同条件转向不同分支

decisition 判断节点也可以制作循环效果

控制流程流转的方向

方式一：通过在<transition>节点中添加 <condition> 节点，通过expr属性执行条件

变量表达式 #{表达式内容}

<decision name="exclusive1" g="186,221,48,48"><transition name="to end1" to="end1" g="-47,-17"><!-- 如果agreeinfo 是流程变量，值为 agree 结束流程 --><condition expr="#{agreeinfo == 'agree'}"/></transition><transition name="to 重新申请" to="重新申请" g="320,278:-71,-17"><!-- 如果agreeinfo 是流程变量，值为 noagree 重新申请 --><condition expr="#{agreeinfo == 'noagree'}"/></transition></decision>

简化以上配置也可写为：

   <decision name="exclusive1" g="186,221,48,48" expre="#{agreeinfo}"><transition name="agree" to="end1" g="-47,-17" /><transition name="noagree" to="重新申请" g="320,278:-71,-17" /></decision>

方式二：使用Handler，要实现DecisionHandler接口（更加灵活）

在 <decision>元素中配置<handler>元素，通过handler的decide方法返回String字符串代表跳转transition的name属性

    <decision name="exclusive1" g="186,221,48,48"><handler class="cn.itcast.jbpm.handler.MyDecisionHandler" /><transition name="agree" to="end1" g="-47,-17"/><transition name="noagree" to="重新申请" g="320,278:-71,-17"/></decision>

//判断节点 handler对象
public class MyDecisionHandler implements DecisionHandler {@Overridepublic String decide(OpenExecution openExecution) {// openExecution可以通过getVariable来获得流程中的变量String agreeinfo = (String) openExecution.getVariable("agreeinfo");// 返回 agreeinfo的值 对应的是 <transition> 的name属性return agreeinfo;}
}

只需要在经理审批后，在变量中保存 agreeinfo信息，通过变量决定流转方向

注：推荐使用方式二，灵活性更好，可以在handler中写入代码逻辑。

6、 fork 分支/ join 聚合节点

fork和join必须成对出现，用来解决业务流程中并发活动问题

注：只有fork中所有并发活动都完成，才能继续执行，如果有一个并发活动没出来都需要等待。 fork结束后，必须join

   <task name="购物" g="181,82,92,52"><transition name="to fork1" to="fork1" g="-53,-17"/></task><!--分支--><fork name="fork1" g="207,143,48,48"><transition name="to 收钱" to="收钱" g="-47,-17"/><transition name="to 送货" to="送货" g="-47,-17"/></fork><task name="收钱" g="83,209,92,52"><transition name="to join1" to="join1" g="-53,-17"/></task><task name="送货" g="306,210,92,52"><transition name="to join1" to="join1" g="-53,-17"/></task><!—合并--><join name="join1" g="206,274,48,48"><transition name="to end1" to="end1" g="-47,-17"/></join>

7、 task节点（最常用的节点） ----任务节点

1）个人任务

第一种： <task assignee=”指定任务负责人”>

<task assignee="#{employee}"> 通过变量 employee 设置该任务负责人，需要手动添加变量

第二种： <task>

<assignment-handler class=””> 通过handler程序，指定任务负责人

编写类实现 AssignmentHandler接口

//通过 handler 指定 个人任务 负责人
public class MyPersonalTaskAssignmentHandler implements AssignmentHandler {@Override// assignable 为任务 指定负责人  、 openExecution 获得流程变量public void assign(Assignable assignable, OpenExecution openExecution)throws Exception {assignable.setAssignee("王五");//改变负责人为王五}
}
第三种 ： 通过taskService的assignTask方法，传入(任务id, 负责个人)即可。
处理流程：执行到task节点，查询我的个人任务 taskService.findPersonalTasks(userId);通过task.getId()获得办理任务的编号，  再通过taskService.completeTask(task.getId());来完成任务TaskService taskService = processEngine.getTaskService();// 查询 jbpm4_task 条件 assignee字段List<Task> tasks = taskService.findPersonalTasks(userId);for (Task task : tasks) {System.out.println("编号：" + task.getId());System.out.println("名称： " + task.getName());// 办理任务taskService.completeTask(task.getId());}// 改变任务负责人，可通过TaskService的assignTask方法processEngine.getTaskService().assignTask("30002", "赵六");

2）组任务

存在一个任务，任务由指定一组人来完成，组内每个人都有完成任务的能力（将任务交给一组人来负责）

例如：公司所有员工都有请假的权利 ----- 需要将公司所有员工放入一个组，进行管理

常见操作流程：先根据用户查询组任务 processEngine.getTaskService().findGroupTasks(userId);

对组任务进行拾取操作，组任务被拾取后变为个人任务 taskService.takeTask(taskid, user);

可以完成个人任务 taskService.completeTask …

改变任务负责人 taskService.assignTask(taskId, userId) ---- 如果userId为null任务将重新变为组任务

（组任务和个人任务查询是分开的）

第一种：通过<task>元素的 candidate-users 属性或者 candidate-groups 属性都可以设置多个人负责组任务

数据表的变化：在jbpm4_task插入任务数据，向jbpm4_participation 存入组内用户

candidate-users（<task candidate-users="张三,李四,王五">）

// 组任务 （candidate-users 指定组内负责人）
public void demo2() {Configuration configuration = new Configuration();ProcessEngine processEngine = configuration.buildProcessEngine();// 发布RepositoryService repositoryService = processEngine.getRepositoryService();repositoryService.createDeployment().addResourceFromClasspath("holiday2.jpdl.	xml").deploy();// 启动processEngine.getExecutionService().startProcessInstanceByKey("holiday2");String userId = "李四";// 通过findGroupTasks查询李四的组任务List<Task> list = processEngine.getTaskService().findGroupTasks(userId);// 拾取任务，也就是李四完成这个任务，这是组任务就变成个人任务了processEngine.getTaskService().takeTask("8", userId);// 如果李四完成不了任务了，也可改变任务负责人（如果userId为null任务将重新变为组任务）processEngine.getTaskService().assignTask("8", "小丽");
}
candidate-groups（<task candidate-groups="myusers">）创建组// 组任务 （candidate-groups 指定组）
public void demo3() {Configuration configuration = new Configuration();ProcessEngine processEngine = configuration.buildProcessEngine();// 发布RepositoryService repositoryService = processEngine.getRepositoryService();repositoryService.createDeployment().addResourceFromClasspath("holiday4.jpdl.	xml").deploy();// 通过IdentityService创建组IdentityService identityService = processEngine.getIdentityService();identityService.createGroup("myusers"); // 建组//创建组员createUser(userid,givenName,familyNames)identityService.createUser("张三", "张三", "张"); identityService.createUser("李四", "李四", "李"); //通过createMembership将组员加入identityService.createMembership("张三", "myusers");identityService.createMembership("李四", "myusers");// 启动流程processEngine.getExecutionService().startProcessInstanceByKey("holiday4");
}	
数据表的变化：在 jbpm4_id_group 存放组信息 、jbpm4_id_user 存放用户 、jbpm4_id_membership 存放关系 第二种：通过AssignmentHandler指定负责人 （重点）
//为任务 指定组负责人
public class MyGroupTaskAssignmentHandler implements AssignmentHandler {@Overridepublic void assign(Assignable assignable, OpenExecution openExecution)throws Exception {// 使用 candidate-users方式assignable.addCandidateUser("张三");assignable.addCandidateUser("李四");assignable.addCandidateUser("王五");// 使用candidate-groups 方式// 添加组创建代码 ---- 仍需另外使用 IdentityService创建组assignable.addCandidateGroup("myusers");}
}

第三种：直接使用 TaskService 为任务添加组用户

方法：addTaskParticipatingUser(taskId, userId, participationType)

addTaskParticipatingGroup(taskId,groupId, participationType)

3）泳道 swimlanes

在UML 活动图中，通过泳道来描述一类用户和活动节点之间关系，从泳道得知哪些活动是属于哪类用户的！

JBPM的泳道解决问题，某个用户或者某组用户，在JBPM流程中的连续操作。

举例：张三填写请假条，经理没批（请假原因不详细），必须由张三补充请假理由。而原来的组管理中，如果经理没有批准请假，回到重新申请请假的环节，这是又变成了组任务，张三、李四等人都可以完成，显然不符合实际，泳道的作用就是解决这种问题的。

泳道支持的三个属性：<swimlane name=" " assignee=" " candidate-groups=" " candidate-users=" "></swimlane>

assignee 指定泳道属于哪一个人

candidate-groups、candidate-users 指定泳道属于哪一组人

作用：确保整个流程多个活动节点由一个人或者一组人来完成

二、自定义活动节点和事件（了解）