首页 > 其他分享 >jbpm5.1介绍（7）

jbpm5.1介绍（7）

时间：2023-01-04 18:00:36浏览次数：31  
标签：WorkItem ksession 介绍 processInstance jbpm5.1 params new bpmn2


Junit测试评估流程

评估流程的界面如下：


这个示例里边用到了Script Task，Service Task和User Task

Log执行记录日志的功能，打印出一段信息

RegisterRequest调用外部预定义的程序或者其它引擎的程序

Two调用人工任务

看一下调用的测试程序



​​?​​ 


public void testEvaluationProcess() throws Exception {
         KnowledgeBase kbase = createKnowledgeBase("BPMN2-EvaluationProcess.bpmn2");
         StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
         ksession.getWorkItemManager().registerWorkItemHandler("Human Task", new SystemOutWorkItemHandler());
         ksession.getWorkItemManager().registerWorkItemHandler("RegisterRequest", new SystemOutWorkItemHandler());
         Map< String , Object> params = new HashMap< String , Object>();
         params.put("employee", "UserId-12345");
         ProcessInstance processInstance = ksession.startProcess("Evaluation", params);
         assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);
     }



 在程序中注册工作处理程序

ksession.getWorkItemManager().registerWorkItemHandler("Human Task", new SystemOutWorkItemHandler());
 ksession.getWorkItemManager().registerWorkItemHandler("RegisterRequest", new SystemOutWorkItemHandler());

看一下SystemOutWorkItemHandler中的内容



​​?​​ 


public class SystemOutWorkItemHandler implements WorkItemHandler {
  
     public void executeWorkItem(WorkItem workItem, WorkItemManager manager) {
         System.out.println("Executing work item " + workItem);
         manager.completeWorkItem(workItem.getId(), null);
     }
  
     public void abortWorkItem(WorkItem workItem, WorkItemManager manager) {
         System.out.println("Aborting work item " + workItem);
         manager.abortWorkItem(workItem.getId());
     }
  
}



看一下WorkItemHandler，这个接口

Method Summary

void

abortWorkItem(WorkItem workItem, WorkItemManager

The given work item should be aborted.

void

executeWorkItem(WorkItem workItem, WorkItemManager

The given work item should be executed.

有两个方法，一个是要执行的工作任务，一个是忽略的工作任务

运行junit测试，会发现输出了

Loading process BPMN2-EvaluationProcess.bpmn2
Processing evaluation for employee UserId-12345
Executing work item WorkItem 1 [name=RegisterRequest, state=0, processInstanceId=1, parameters{employeeId=UserId-12345}]
Executing work item WorkItem 2 [name=Human Task, state=0, processInstanceId=1, parameters{}]
先是执行RegisterRequest这个里边的executeWorkItem方法

然后执行了Human Task里的executeWorkItem方法

最后使用

assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);

判断状态完成，执行成功

 

Junit测试评估流程2

评估流程的界面如下，同样的流程，打开BPMN2-EvaluationProcess2.bpmn2文件


同前边的示例一下，看一下测试2的示例程序



​​?​​ 


public void testEvaluationProcess2() throws Exception {
         KnowledgeBase kbase = createKnowledgeBase("BPMN2-EvaluationProcess2.bpmn2");
         StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
         ksession.getWorkItemManager().registerWorkItemHandler("Human Task", new SystemOutWorkItemHandler());
         Map< String , Object> params = new HashMap< String , Object>();
         params.put("employee", "UserId-12345");
         ProcessInstance processInstance = ksession.startProcess("com.sample.evaluation", params);
         assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);
     }



 执行完成后的结果如下：

Loading process BPMN2-EvaluationProcess2.bpmn2
 Executing work item WorkItem 1 [name=Human Task, state=0, processInstanceId=1, parameters{ActorId=UserId-12345, Comment=You need to perform a self evaluation, Skippable=false, Content=, TaskName=Performance Evaluation, Priority=1}]
 Executing work item WorkItem 2 [name=Human Task, state=0, processInstanceId=1, parameters{ActorId=john, Comment=You need to perform an evaluation for employee UserId-12345, Skippable=false, Content=, TaskName=Performance Evaluation, Priority=1}]
 Executing work item WorkItem 3 [name=Human Task, state=0, processInstanceId=1, parameters{ActorId=mary, Comment=You need to perform an evaluation for employee UserId-12345, Skippable=false, Content=, TaskName=Performance Evaluation, Priority=1}]


每个人的工作任务自动向下执行。

 

Junit测试评估流程3

评估流程的界面如下，同第一个是一样的


看一下示例程序



​​?​​




 执行之后看结果

Loading process BPMN2-EvaluationProcess3.bpmn2
Processing evaluation for employee john2
Executing work item WorkItem 1 [name=Human Task, state=0, processInstanceId=1, parameters{}]

可以看到只执行了Human Task，默认情况下注册进来的多个Handler如果不指定的话会默认执行Human Tas

public void testEvaluationProcess3() throws Exception {
         KnowledgeBase kbase = createKnowledgeBase("BPMN2-EvaluationProcess3.bpmn2");
         StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
         ksession.getWorkItemManager().registerWorkItemHandler("Human Task", new SystemOutWorkItemHandler());
         ksession.getWorkItemManager().registerWorkItemHandler("RegisterRequest", new SystemOutWorkItemHandler());
         Map< String , Object> params = new HashMap< String , Object>();
         params.put("employee", "john2");
         ProcessInstance processInstance = ksession.startProcess("Evaluation", params);
         assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);
     }

k，如果指定了就先指定执行的，如第一个示例再执行Human Task

 

Junit测试用户任务

接下来的示例是测试用户任务的示例，打开BPMN2-UserTask.bpmn2文件，流程定义文件如下


指定了ActorId为john


看测试用例程序



​​?​​ 


public void testUserTask() throws Exception {
         KnowledgeBase kbase = createKnowledgeBase("BPMN2-UserTask.bpmn2");
         StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
         TestWorkItemHandler workItemHandler = new TestWorkItemHandler();
         ksession.getWorkItemManager().registerWorkItemHandler("Human Task", workItemHandler);
         ProcessInstance processInstance = ksession.startProcess("UserTask");
         assertTrue(processInstance.getState() == ProcessInstance.STATE_ACTIVE);
         ksession = restoreSession(ksession, true);
         WorkItem workItem = workItemHandler.getWorkItem();
         assertNotNull(workItem);
         assertEquals("john", workItem.getParameter("ActorId"));
         ksession.getWorkItemManager().completeWorkItem(workItem.getId(), null);
         assertProcessInstanceCompleted(processInstance.getId(), ksession);
     }



 先定义了一个TestWorkItemHandler，然后将这个handler定义为人工任务

然后判断节点状态是否是激活状态

然后判断流程中执行的是john在执行这个任务并且完成，最后判断流程完成

TestWorkItemHandler中的内容如下：



​​?​​ 


public static class TestWorkItemHandler implements WorkItemHandler {
          
         private List< WorkItem > workItems = new ArrayList< WorkItem >();
          
         public void executeWorkItem(WorkItem workItem, WorkItemManager manager) {
             workItems.add(workItem);
         }
          
         public void abortWorkItem(WorkItem workItem, WorkItemManager manager) {
         }
          
         public WorkItem getWorkItem() {
             System.out.println("执行test workitem");
             if (workItems.size() == 0) {
                 return null;
             }
             if (workItems.size() == 1) {
                 WorkItem result = workItems.get(0);
                 this.workItems.clear();
                 return result;
             } else {
                 throw new IllegalArgumentException("More than one work item active");
             }
         }
          
         public List< WorkItem > getWorkItems() {
             List< WorkItem > result = new ArrayList< WorkItem >(workItems);
             workItems.clear();
             return result;
         }
          
     }


执行结果如下显示

Loading process BPMN2-UserTask.bpmn2
执行test workitem

 

Junit测试泳道

接下来的示例是一个测试泳道的例子，泳道的概念可以理解成一个角色或者一个组，就是相当于一组人

看流程图


定义了泳道“MyLane”

在hello上指定了ActorId是john，在Goodbye上没有指定人

看流程示例



​​?​​ 



public void testLane() throws Exception {
         KnowledgeBase kbase = createKnowledgeBase("BPMN2-Lane.bpmn2");
         StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
         TestWorkItemHandler workItemHandler = new TestWorkItemHandler();
         ksession.getWorkItemManager().registerWorkItemHandler("Human Task",
                 workItemHandler);
         ProcessInstance processInstance = ksession.startProcess("UserTask");
         assertTrue(processInstance.getState() == ProcessInstance.STATE_ACTIVE);
         ksession = restoreSession(ksession, true);
         ksession.getWorkItemManager().registerWorkItemHandler("Human Task",
                 workItemHandler);
         WorkItem workItem = workItemHandler.getWorkItem();
         assertNotNull(workItem);
         assertEquals("john", workItem.getParameter("ActorId"));
         Map< String , Object> results = new HashMap< String , Object>();
         results.put("ActorId", "mary");
         ksession.getWorkItemManager().completeWorkItem(workItem.getId(),
                 results);
         ksession = restoreSession(ksession, true);
         ksession.getWorkItemManager().registerWorkItemHandler("Human Task",
                 workItemHandler);
         workItem = workItemHandler.getWorkItem();
         assertNotNull(workItem);
         assertEquals("mary", workItem.getParameter("ActorId"));
         ksession.getWorkItemManager().completeWorkItem(workItem.getId(), null);
         assertProcessInstanceCompleted(processInstance.getId(), ksession);
     }



 定义任务并且执行，并且可以看到第一个用户任务的执行人是john，然后向里传入了第二个用户，mary

这个用户将被赋到泳道MyLane上

然后在看执行用户变成了mary，最后流程结束

看输出结果

Loading process BPMN2-Lane.bpmn2
 执行test workitemWorkItem 1 [name=Human Task, state=0, processInstanceId=1, parameters{ActorId=john}]
 执行test workitemWorkItem 2 [name=Human Task, state=0, processInstanceId=1, parameters{ActorId=mary}]

 

Junit测试异或流程

接下来的示例是测试gateway的异或流程，看一下示例

流程图如下


就是说只需要执行其中的一个流程，就可以让流程继续向下执行，这个示例是根据传入的变量X来看向哪执行

看测试代码



​​?​​ 


public void testExclusiveSplit() throws Exception {
         KnowledgeBase kbase = createKnowledgeBase("BPMN2-ExclusiveSplit.bpmn2");
         StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
         ksession.getWorkItemManager().registerWorkItemHandler("Email",
                 new SystemOutWorkItemHandler());
         Map< String , Object> params = new HashMap< String , Object>();
         params.put("x", "First");
         params.put("y", "Second");
         ProcessInstance processInstance = ksession.startProcess(
                 "com.sample.test", params);
         assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);
     }



 执行测试流程结果如下

Loading process BPMN2-ExclusiveSplit.bpmn2
 x=First
 Executing work item WorkItem 1 [name=Email, state=0, processInstanceId=1, parameters{Body=This is an urgent email First, Subject=Urgent email !, [email protected], [email protected]}]


即当流程执行到其中有一个后则流程自动向下执行

 

Junit测试异或流程高级1

接下来的示例是测试，看如下流程定义


这个是根据动态传入的看结点的值是不是a如果是a则走上边的流程，如果不是则走下边的流程



​​?​​ 


public void testExclusiveSplitXPathAdvanced() throws Exception {
         KnowledgeBase kbase = createKnowledgeBase("BPMN2-ExclusiveSplitXPath-advanced.bpmn2");
         StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
         ksession.getWorkItemManager().registerWorkItemHandler("Email",
                 new SystemOutWorkItemHandler());
         Map< String , Object> params = new HashMap< String , Object>();
         Document doc = DocumentBuilderFactory.newInstance()
                 .newDocumentBuilder().newDocument();
         Element hi = doc.createElement("hi");
         Element ho = doc.createElement("ho");
         hi.appendChild(ho);
         Attr attr = doc.createAttribute("value");
         ho.setAttributeNode(attr);
         attr.setValue("a");
         params.put("x", hi);
         params.put("y", "Second");
         ProcessInstance processInstance = ksession.startProcess(
                 "com.sample.test", params);
         assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);
     }



 根据传入的结点执行流程

执行结果如下

Loading process BPMN2-ExclusiveSplitXPath-advanced.bpmn2
 x=[hi: null]
 Executing work item WorkItem 1 [name=Email, state=0, processInstanceId=1, parameters{[email protected], Subject=Urgent email !, [email protected], [email protected]}]

 

Junit测试异或流程高级2

接下来的示例是测试，如下流程图


流程结点定义


还是根据值来判断流向，这次只指定x

看测试程序



​​?​​ 


public void testExclusiveSplitXPathAdvanced2() throws Exception {
         KnowledgeBase kbase = createKnowledgeBase("BPMN2-ExclusiveSplitXPath-advanced-vars-not-signaled.bpmn2");
         StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
         ksession.getWorkItemManager().registerWorkItemHandler("Email",
                 new SystemOutWorkItemHandler());
         Map< String , Object> params = new HashMap< String , Object>();
         Document doc = DocumentBuilderFactory.newInstance()
                 .newDocumentBuilder().newDocument();
         Element hi = doc.createElement("hi");
         Element ho = doc.createElement("ho");
         hi.appendChild(ho);
         Attr attr = doc.createAttribute("value");
         ho.setAttributeNode(attr);
         attr.setValue("a");
         params.put("x", hi);
         params.put("y", "Second");
         ProcessInstance processInstance = ksession.startProcess(
                 "com.sample.test", params);
         assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);
     }



 执行的流程结果

Loading process BPMN2-ExclusiveSplitXPath-advanced-vars-not-signaled.bpmn2
 y=Second
 Executing work item WorkItem 1 [name=Email, state=0, processInstanceId=1, parameters{[email protected], Subject=Urgent email !, [email protected], [email protected]}]

Junit测试异或流程带参数

与上边几个程序基本一致，直接上代码吧



​​?​​ 

public void testExclusiveSplitXPathAdvancedWithVars() throws Exception {
         KnowledgeBase kbase = createKnowledgeBase("BPMN2-ExclusiveSplitXPath-advanced-with-vars.bpmn2");
         StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
         ksession.getWorkItemManager().registerWorkItemHandler("Email",
                 new SystemOutWorkItemHandler());
         Map< String , Object> params = new HashMap< String , Object>();
         Document doc = DocumentBuilderFactory.newInstance()
                 .newDocumentBuilder().newDocument();
         Element hi = doc.createElement("hi");
         Element ho = doc.createElement("ho");
         hi.appendChild(ho);
         Attr attr = doc.createAttribute("value");
         ho.setAttributeNode(attr);
         attr.setValue("a");
         params.put("x", hi);
         params.put("y", "Second");
         ProcessInstance processInstance = ksession.startProcess(
                 "com.sample.test", params);
         assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);
     }




 执行结果

Loading process BPMN2-ExclusiveSplitXPath-advanced-with-vars.bpmn2
 x=[hi: null]
 Executing work item WorkItem 1 [name=Email, state=0, processInstanceId=1, parameters{[email protected], Subject=Urgent email !, [email protected], [email protected]}]

Junit测试异或流程优先和默认

下面的两个流程和上边基本一致只是细节上有些不同，一个是根据优先级流向一个是根据默认值流向

优先



​​?​​ 


public void testExclusiveSplitPriority() throws Exception {
         KnowledgeBase kbase = createKnowledgeBase("BPMN2-ExclusiveSplitPriority.bpmn2");
         StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
         ksession.getWorkItemManager().registerWorkItemHandler("Email",
                 new SystemOutWorkItemHandler());
         Map< String , Object> params = new HashMap< String , Object>();
         params.put("x", "First");
         params.put("y", "Second");
         ProcessInstance processInstance = ksession.startProcess(
                 "com.sample.test", params);
         assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);
     }



 默认



​​?​​ 


public void testExclusiveSplitDefault() throws Exception {
         KnowledgeBase kbase = createKnowledgeBase("BPMN2-ExclusiveSplitDefault.bpmn2");
         StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
         ksession.getWorkItemManager().registerWorkItemHandler("Email",
                 new SystemOutWorkItemHandler());
         Map< String , Object> params = new HashMap< String , Object>();
         params.put("x", "NotFirst");
         params.put("y", "Second");
         ProcessInstance processInstance = ksession.startProcess(
                 "com.sample.test", params);
         assertTrue(processInstance.getState() == ProcessInstance.STATE_COMPLETED);
     }



 分别的执行结果如下：

优先

Loading process BPMN2-ExclusiveSplitPriority.bpmn2
 y=Second
 Executing work item WorkItem 1 [name=Email, state=0, processInstanceId=1, parameters{Body=This is an urgent email First, Subject=Urgent email !, [email protected], [email protected]}]

默认

Loading process BPMN2-ExclusiveSplitDefault.bpmn2
 y=Second
 Executing work item WorkItem 1 [name=Email, state=0, processInstanceId=1, parameters{Body=This is an urgent email NotFirst, Subject=Urgent email !, [email protected], [email protected]}]

标签：WorkItem,ksession,介绍,processInstance,jbpm5.1,params,new,bpmn2
From： https://blog.51cto.com/u_4172728/5988776

相关文章

  • Zabbix 介绍及部署(超详细讲解)
    原文：https://mp.weixin.qq.com/s/7pDagRaWSG9dndHS1gWHBQ一、[zabbix]的基本概述zabbix是一个监控软件，其可以监控各种网络参数，保证企业服务架构安全运营，同时支持灵活的......
  • RocketMQ存储篇二：相关概念介绍（MappedFile)
    这篇文章介绍在RocketMQ存储中使用到的一些概念，包括和零拷贝相关的MappedFile看下MappedFile的类图结构，DefaultMappedFile实现了MappedFile接口，同时继承了ReferenceReso......
  • 02-插件介绍
    插件下载地址#1.手动在APP里创建templates文件(html写在里面)#2.在app中创建static文件夹:新建css/js(jquery)/img(图片)/plugins(插件)#3.下载......
  • 什么是网络攻击？常见网络攻击手段介绍！
    在当下，网络攻击事件已经屡见不鲜，无论是企业还是个人，从某种角度上来讲都遭受过网络攻击，只不过很多情况下未发现罢了。而想要有效应对网络攻击，我们必须对网络攻击有一定的......
  • python中正则表达式和模块函数介绍
    |符号|解释|示例|说明||-----------------......
  • .NET（C#、VB）APP开发——Smobiler平台控件介绍：TTS
    本文简述如何在Smobiler中使用TTS文字转语音。Step1.新建一个SmobilerForm窗体，并在窗体中加入TTS和Button，布局如下Button的点击事件代码：privatevoidbutt......
  • 4.3JS中的原型的介绍
    ​  JS中原型的使用当我们用构造方法创建一个类时,在内存会预先调用构造方法创建一个对象,这对象我们称之为原型对象,构造方法对象中有一个prototype属性指向该对象,......
  • 4.3JS中的原型的介绍
    ​  JS中原型的使用当我们用构造方法创建一个类时,在内存会预先调用构造方法创建一个对象,这对象我们称之为原型对象,构造方法对象中有一个prototype属性指向该对象,......
  • .NET（C#、VB）APP开发——Smobiler平台控件介绍：TTS
    本文简述如何在Smobiler中使用TTS文字转语音。Step1.新建一个SmobilerForm窗体，并在窗体中加入TTS和Button，布局如下Button的点击事件代码：privatevoidbut......
  • HarmonyOS多媒体框架介绍
    随着科技进步，我们的生活发生了翻天覆地的变化。过去几年音视频技术发展迅速，直播行业异军突起，在社交、娱乐、教育、医疗等领域高歌猛进。当前，对音视频技术的需求又将到达一个......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99