网上cad画图兼职 当前位置:首页>网上cad画图兼职>正文

网上cad画图兼职

发布时间:2018-10-18

原标题:jBPM学习之利用API完成流程实例

jBPM学习之利用API完成流程实例


流程引擎对象ProcessEngine是jBPM4所有的Service API之源。在jBPM4中各种服务相互依存,但所有的Service API都从ProcessEngine中获得,由此可见ProcessEngine是jBPM4工作流API的核心。ProcessEngine是由Configuration类构建的,即工作流引擎根据配置产生。ProcessEngine是线程安全的,因此他可以保存在静态变量中。

因此,我们可以把获取ProcessEngine的代码编写如下:

package com.springchang.jbpm01;

import org.jbpm.api.Configuration;
import org.jbpm.api.ProcessEngine;
import org.junit.Test;

public class MyTest01 {
    private static ProcessEngine processEngine; //直接将流程引擎写成静态变量
    
    //静态代码块,获取processEngine
    static {
        Configuration cfg = new Configuration();
        cfg.setResource("jbpm.cfg.xml");  
        processEngine = cfg.buildProcessEngine();
    }

    // 1,部署流程定义文档
    @Test
    public void testDeployProcessDefinition() throws Exception {
        String deploymentId = processEngine.getRepositoryService() //调用processEngine提供的接口
                .createDeployment()
                .addResourceFromClasspath("com/springchang/jbpm01/HelloWorld.jpdl.xml") //加载HelloWorld.jpdl.xml文件
                .addResourceFromClasspath("com/springchang/jbpm01/HelloWorld.png")      //加载Helloworld.png图片
                .deploy(); //发布流程定义
        System.out.println(deploymentId);
    }

}

而本节的重点是调用jBPM4.4中给定的各种API,从流程的发起,部署,办理任务到历史任务查询等一系列的操作。首先,流程定义如图所示:
流程定义

对应的jPDL:

<?xml version="1.0" encoding="UTF-8"?>

<process name="process" xmlns="http://jbpm.org/4.4/jpdl">
   <start g="118,16,48,48" name="start1">
      <transition g="-66,-22" name="to state1" to="state1"/>
   </start>
   <!-- state活动是等待活动,需要收到一个外部的执行信号才能流转通过 -->
   <state g="96,96,92,52" name="state1">
      <transition g="-60,-22" name="to task1" to="task1"/>
   </state>
   <!-- task活动是等待活动,在这里被分配给用户Spring Chang办理,Spring Chang办理完成提交任务后才能流转通过 -->
   <task assignee="Spring Chang" g="96,180,92,52" name="task1">
      <transition g="-57,-22" name="to end1" to="end1"/>
   </task>
   <end g="118,264,48,48" name="end1"/>
</process>

使用jBPM Service API发起并完成上面名为process的流程定义。代码如下:

package com.springchang.jbpm01;

import static org.junit.Assert.*;

import org.jbpm.api.Configuration;
import org.jbpm.api.Execution;
import org.jbpm.api.ProcessEngine;
import org.jbpm.api.ProcessInstance;
import org.jbpm.api.history.HistoryProcessInstance;
import org.jbpm.api.history.HistoryTask;
import org.jbpm.api.task.Task;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;

public class ProcessTest {
    
    private ProcessEngine processEngine;
    
    private String deploymentId;
    
    @Before
    public void setUp() throws Exception {
        processEngine = Configuration.getProcessEngine();
        deploymentId = processEngine.getRepositoryService().createDeployment()
                     .addResourceFromClasspath("com/springchang/jbpm01/process.jpdl.xml")
                     .addResourceFromClasspath("com/springchang/jbpm01/process.png")
                     .deploy();
    }

    @After
    public void tearDown() throws Exception {
        processEngine.getRepositoryService().deleteDeploymentCascade(deploymentId);
    }

    @Test
    public void test() {
        //使用执行任务,根据已经部署的名陈process,发起流程实例
        ProcessInstance processInstance = processEngine.getExecutionService().startProcessInstanceByKey("process");
        //获取流程实例id
        String pid = processInstance.getId();
        System.out.println("pid:" + pid);
        //获取当前活动的执行对象
        Execution executionInState = processInstance.findActiveExecutionIn("state1");
        //断言当前活动是state1
        assertNotNull(executionInState);
        //使用执行服务:发出执行信号结束当前活动,继续流程的执行
        String executionId = executionInState.getId();
        System.out.println("executionId:" + executionId);
        processEngine.getExecutionService().signalExecutionById(executionId);
        //使用执行服务:从持久化层中获取“最新”的流程实例对象
        processInstance = processEngine.getExecutionService().findProcessInstanceById(pid);
        //获取当前活动的执行对象
        Execution executionInTask = processInstance.findActiveExecutionIn("task1");
        //断言当前活动即为task
        assertNotNull(executionInTask);
        //使用任务服务:获取用户Spring Chang的任务,即task活动产生的任务
        Task task = processEngine.getTaskService().findPersonalTasks("Spring Chang").get(0);
        assertEquals("Spring Chang", task.getAssignee());
        //使用任务服务,完成任务
        processEngine.getTaskService().completeTask(task.getId());
        //使用历史服务:创建历史任务查询
        HistoryTask historyTask = processEngine.getHistoryService().createHistoryTaskQuery()
                                  .taskId(task.getId()).uniqueResult();
        //断言上一步完成的任务已经成为历史,即可通过历史任务查询获取到它
        assertNotNull(historyTask);
        //断言该流程已经结束
        //assertProcessInstanceEnded(pid);
        //使用历史服务:创建历史流程实例查询
        HistoryProcessInstance historyProcessInst = processEngine.getHistoryService()
                                                    .createHistoryProcessInstanceQuery()
                                                    .processInstanceId(pid)
                                                    .uniqueResult();
        //断言该流程已经成为历史,即可通过历史流程实例查询获取它
        assertNotNull(historyProcessInst);
    }
}

上诉单元测试的代码setUp方法是部署流程定义,并调用addResourceFromClasspath方法加载流程实例文档来部署流程定义。tearDown方法作用是删除刚才部署的流程定义,并将与其相关的关联表的内容一并清空,主要的代码放在test测试方法里面。

当前文章:http://thrksw.com/html/html/201308/15/4390485.html

发布时间:2018-10-18 11:04:22

网赚加粉推广 聊城夜班兼职招聘信息 信用卡如何月赚100万 怎样理财最赚钱 穷人用体力和时间赚钱 不要本钱干什么挣钱快 在网上挣钱的方法 手机赚钱的软件排行 加微信网赚 学生打字赚钱软件

95288 16387 83100 48195 41177 2898178405 95310 17402

责任编辑:龙北马

随机推荐