当前位置: 代码迷 >> Web前端 >> JavaWeb Project 中使用JBPM,使用JUnit 四
  详细解决方案

JavaWeb Project 中使用JBPM,使用JUnit 四

热度:1306   发布时间:2013-11-16 23:15:33.0
JavaWeb Project 中使用JBPM,使用JUnit 4

JBPM

? ? ? ? ?JBPM,全称是Java Business Process Management(业务流程管理),它是覆盖了业务流程管理、工作流、服务协作等领域的一个开源的、灵活的、易扩展的可执行流程语言框架。jBPM是公开源代码项目,使用它要遵循 ASL(Apache License Version 2.0)和EULA(JBoss End User License Agreement)协议。

?

?JBPM的运行需要数据库的支持,因此系统设计时要选定所用数据库。

?

这里使用Oracle作为数据库。使用JBPM的版本是?jbpm-jpdl-3.2.3。

?

一、建表空间,建用户

--创建表空间
CREATE TABLESPACE jbpm
DATAFILE 'E:\orcl_tblspace\jbpm.DBF'
SIZE 10M
AUTOEXTEND ON NEXT 32M MAXSIZE UNLIMITED
LOGGING
EXTENT MANAGEMENT LOCAL
SEGMENT SPACE MANAGEMENT AUTO; //以分号结束

--创建用户
CREATE USER jbpm
IDENTIFIED BY jbpm
DEFAULT TABLESPACE jbpm;

--把CONNECT、RESOURCE角色授予用户jbpm
GRANT CONNECT,RESOURCE TO jbpm

?

三、导入JBPM的表,在jbpm-jpdl-3.2.3/db下找到jbpm.jpdl.oracle,把他导入到新建的数据库用户中,先把该sql文件中的 drop table JBPM_ACTION cascade constraints; 之类语句先删掉。接着,数据库中会多了32张表。

?

?

二、建JavaWeb Project

1.在jbpm-jpdl-3.2.3/config中把如下4个文件复制到新建的JavaWeb?Project中的src目录下。

a.hibernate.cfg

b.jbpm.cfg

c.jbpm.mail.templates

d.log4j.properties

?

2.把jbpm-jpdl-3.2.3/lib中的jar文件做成一个自定义的类库,然后导入到Java Project中。

?

3.导入Oracle的数据库驱动包。

?

4.修改hibernate.cfg配置文件中的dialect、driver_class、url、username和password。

?

5.顺便导入JUnit 4的类库,待会用作测试。

?

6.在JavaWeb?Project中新建一工作流文件夹,例如workflow,用来存放流程图。

?

?

三、新建工作流文件(流程开始时带任务人)

1.

?

2.

?

3.

?

PS:gpd.xml文件可能会报错,不用管,编码问题而已,也不需要打开查看。

?

4.打开processdefinition.xml文件。开始画流程图

?

5.流程图的一些解释。


?

?

6.员工申请报销 流程的设置

Description那里写的是 staff.apply


?

?Assignment是指分派任务,Actor有可以指定作用域或者直接指定人名,例如Jack。

?

7.部门经理审批 的流程设置

Description那里写的是 manager.approve




?

?

这次的分配任务交给一个Java类来处理,选择Handler,这个类要实现AssignmentHandler这个接口。

?

8.财务审批 流程的设置



?

?

?这里也是直接指定财务人。

?

9.通知员工 的流程设置



?

?

?

这里的Actor所指定的角色必须要和 员工申请报销 流程里的Actor所指定的角色一样。

?

10.当设置好流程图的属性的时候,就可以开始部署了。



?

输入一个名字,然后按打开就行了。

?

接着,点击Save Without Deploying... 这个按钮,你就发现你所选择的目录里会多了一个.zip压缩包。

?

11.此时,需要一个Java类,把流程图的属性写入到数据库中

package org.jbpm.util;

import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.util.zip.ZipInputStream;
import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.graph.def.ProcessDefinition;

/**
 * 部署类
 * 
 * @author miao
 * 
 */
public class DelpoymentUtil {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// 上下文
		JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
		// 该目录是画完流程图之后的部署位置
		String url = "C:\\Homework\\JaveSpace\\workStream\\leave.zip";
		try {
			// 输入流
			InputStream is = new FileInputStream(new File(url));
			// ZipInputStream是InputStream的子类,通过此类可以方便地读取ZIP格式的压缩文件
			ZipInputStream zis = new ZipInputStream(is);
			// 流程定义类
			ProcessDefinition pd = ProcessDefinition.parseParZipInputStream(zis);
			jbpmContext.deployProcessDefinition(pd);
			zis.close();
			is.close();
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			jbpmContext.close();
		}
	}

}

?

运行这个类之后,会在数据库里的?JBPM_TASK 表和?JBPM_TASKINSTANCE 表发现数据。

?

四、编码

做个简单的申请报销处理类

package org.jbpm.process;

import org.jbpm.graph.exe.ExecutionContext;
import org.jbpm.taskmgmt.def.AssignmentHandler;
import org.jbpm.taskmgmt.exe.Assignable;

/**
 * 报销类
 * 
 * @author miao
 * 
 */
public class ApplyProcess implements AssignmentHandler {

	public void assign(Assignable assignable, ExecutionContext context) throws Exception {
		// 该名字就是流程图里员工申请报销的那位,通过上下文获取
		String name = context.getContextInstance().getVariable("issueperson").toString();
		if ("user1".equals(name)) {
			assignable.setActorId("manager1");
		} else if ("user2".equals(name)) {
			assignable.setActorId("manager2");
		}
	}

}

?

?

五、测试类

package org.jbpm.test;

import java.util.List;
import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.context.exe.ContextInstance;
import org.jbpm.graph.def.ProcessDefinition;
import org.jbpm.graph.exe.ProcessInstance;
import org.jbpm.taskmgmt.exe.TaskInstance;
import org.junit.BeforeClass;
import org.junit.Test;

/**
 * 测试员工报销
 * 
 * @author miao
 * 
 */
public class TestApplyMoney {

	@BeforeClass
	public static void setUpBeforeClass() throws Exception {
	}

	@Test
	public void testProcess() {

		// 1.员工提交申请
		submitForm("user1");
		// 2.部门经理审核
		//managerApprove("manager1");
		// 3.财务拨款
		//cashierApprove("ali");
		// 4.员工领款
		//getMoney("user1");
	}

	/**
	 * 1.添加员工提交申请
	 * 
	 * @param actorId
	 */
	public void submitForm(String actorId) {
		JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
		try {
			ProcessDefinition pd = jbpmContext.getGraphSession().findLatestProcessDefinition(
					"applyMoney");
			ProcessInstance pi = pd.createProcessInstance();
			ContextInstance ci = pi.getContextInstance();
			jbpmContext.setActorId(actorId);
			ci.setVariable("issueperson", actorId);
			TaskInstance ti = pi.getTaskMgmtInstance().createStartTaskInstance();
			ti.end();
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			jbpmContext.close();
		}
	}

	/**
	 * 2.部门经理审批
	 * 
	 * @param actorId
	 */
	public void managerApprove(String actorId) {
		JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
		try {
			@SuppressWarnings("unchecked")
			List<TaskInstance> list = jbpmContext.getTaskList(actorId);
			for (TaskInstance taskInstance : list) {
				taskInstance.end();
			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			jbpmContext.close();
		}
	}

	/**
	 * 3.财务拨款
	 * 
	 * @param actorId
	 */
	public void cashierApprove(String actorId) {
		JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
		try {
			@SuppressWarnings("unchecked")
			List<TaskInstance> list = jbpmContext.getTaskList(actorId);
			for (TaskInstance taskInstance : list) {
				taskInstance.end();
			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			jbpmContext.close();
		}
	}

	/**
	 * 4.员工领款
	 * 
	 * @param actorId
	 */
	public void getMoney(String actorId) {
		JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
		try {
			@SuppressWarnings("unchecked")
			List<TaskInstance> list = jbpmContext.getTaskList(actorId);
			for (TaskInstance taskInstance : list) {
				taskInstance.end();
			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			jbpmContext.close();
		}
	}

}

?

每测试一个方法,就会在数据库中的 JBPM_TASKINSTANCE 表看见相应的数据。

?

六、demo(该例子中也包含复杂一点的流程处理,带分支判断,流程开始时不带任务人)

E276-JBPM.zip

  相关解决方案