工作流Jpbm4.4工作流知识点总结（工作流开发宝典） 第一章 工作流框架的搭建第二章 工作流框架的流程开发2. 执行流程实例第三章 jbpm与spring整合

Jbpm工作流开发过程中的一些知识点总结，方便以后开发使用！

目录：

二、工作流框架的流程开发

　　1、管理流程定义

　　　　①部署流程定义

　　　　②查询流程定义

　　　　③删除流程定义

　　　　④获取部署对象中的文件资源内容

　　　　⑤ 获取流程图中某活动的坐标

　　2、执行流程实例

　　　　①启动流程实例

　　　　②向后执行一步

　　　　③查询任务

　　　　④完成任务

　　　　⑤拾取任务

　　　　⑥获取流程中的变量

三、Jbpm和spring整合

${JBPM_HOME}/jbpm.jar（核心包）

JBPM_HOME/lib/*.jar，不添加以下jar包：servlet-api.jar, junit.jar。其中junit.jar一定不要添加，因为是3.8.2版本，与我们使用的junit4有冲突。

所使用的数据库对应的驱动的jar包（第2步所添加的jar包中已包含mysql的jdbc驱动jar包）。

配置文件可以从JBPM_HOME/examples/src/中拷贝：

jbpm.cfg.xml、

logging.properties、//要注意版本的问题,接口和实现类要相同版本

jbpm.hibernate.cfg.xml。

修改logging.properties中的日志输出级别为WARNING： java.util.logging.ConsoleHandler.level=WARNING

修改jbpm.hibernate.cfg.xml中的数据库连接信息。如果使用MySQL，使用的方言一定要是org.hibernate.dialect.MySQL5InnoDBDialect。

数据库连接编码一定要是UTF-8。否则可能会在部署含有中文字符的流程定义时会抛异常，说sql语法错误。

注意区分Deployment与ProcessDefinition

String deploymentId = processEngine.getRepositoryService()

.createDeployment()

.addResourceFromClasspath("process/test.jpdl.xml")

.addResourceFromClasspath("process/test.png")

.deploy();

.addResourcesFromZipInputStream(zipInputStream)

1， .addResourceFromClasspath(resource); 可以调用多次以添加多个文件。文件重复添加也不会报错。

2， .addResourceFromInputStream(resourceName, inputStream)添加一个文件（使用InputStream）

3， .addResourcesFromZipInputStream(zipInputStream)添加多个文件，里面也可以有文件夹。

4， 以上方法可以在一起调用。

repositoryService.deleteDeployment(deploymentId);

repositoryService.deleteDeploymentCascade(deploymentId);

关联：关联的流程实例，就是流程定义中执行过的那些实例【已经放到了历史表中，级联删除的就是同时删除那些执行过了的实例】，

RepositoryService.createProcessDefinitionQuery()

// 1，构建查询

ProcessDefinitionQuery pdQuery = processEngine.getRepositoryService() 

.createProcessDefinitionQuery()// 

.orderAsc(ProcessDefinitionQuery.PROPERTY_NAME)//

.orderDesc(ProcessDefinitionQuery.PROPERTY_VERSION);

// 2，查询出总数量与数据列表

long count = pdQuery.count();

List<ProcessDefinition> list = pdQuery.page(0, 100).list();// 分页：取出前100条记录

// 3，显示结果

System.out.println(count);

for (ProcessDefinition pd : list) {

System.out.println("id=" + pd.getId()//

+ ",deploymentId=" + pd.getDeploymentId()//

+ ",name=" + pd.getName()//

+ ",version=" + pd.getVersion()//

+ ",key=" + pd.getKey()); //

}

// 1，查询，按version升序排序，则最大版本排在最后面

List<ProcessDefinition> all = processEngine.getRepositoryService()//

.createProcessDefinitionQuery()//

.orderAsc(ProcessDefinitionQuery.PROPERTY_VERSION)

.list();

// 2，过滤出所有不同Key的最新版本（因为最大版本在最后面）

Map<String, ProcessDefinition> map = new HashMap<String, ProcessDefinition>(); // map的key是流程定义的key，map的vlaue是流程定义对象

for (ProcessDefinition pd : all) {

map.put(pd.getKey(), pd);

Collection<ProcessDefinition> result = map.values();

for (ProcessDefinition pd : result) {

System.out.println("deploymentId=" + pd.getDeploymentId()// 

+ ",\t id=" + pd.getId()// 流程定义的id，格式：{key}-{version}

+ ",\t name=" + pd.getName()

+ ",\t key=" + pd.getKey()

+ ",\t version=" + pd.getVersion());

// 资源的名称，就是 jbpm4_lob 表中的 NAME_ 列表值

String deploymentId = "90001";

String resourceName = "test.png"; 

InputStream in = processEngine.getRepositoryService()

.getResourceAsStream(deploymentId, resourceName);

String processDefinitionId = "test-1"; // 流程定义的id

String activityName = "start1"; // 活动的名称

ActivityCoordinates c = processEngine.getRepositoryService()

.getActivityCoordinates(processDefinitionId, activityName);

System.out.println("x=" + c.getX() 

+ ",y=" + c.getY() 

+ ",width=" + c.getWidth() 

+ ",height=" + c.getHeight());

说明：流程实例创建后，直接就到开始活动后的第一个活动，不会在开始活动停留。

ProcessInstance pi = processEngine.getExecutionService()

.startProcessInstanceByKey(processDefinitionKey);

// 准备流程变量

Map<String, Object> variables = new HashMap<String, Object>();

variables.put("申请人", "张三");

variables.put("报销金额", 1000.00);

// 启动流程实例，并设置一些流程变量

.startProcessInstanceByKey(processDefinitionKey, variables);

processEngine.getExecutionService().signalExecutionById(executionId);

variables.put("审批结果", "同意");

processEngine.getExecutionService()

.signalExecutionById(executionId, variables);

String outcome= "to end1";

.signalExecutionById(executionId, outcome);

.signalExecutionById(executionId, outcome, variables);

方式1：TaskService.findPersonalTasks(userId);

方式2：List<Task> list = taskService.createTaskQuery()

.assignee(userId)

// 显示任务信息

for (Task task : taskList) {

System.out.println("id=" + task.getId()// 任务的id

+ ",name=" + task.getName()// 任务的名称

+ ",assignee=" + task.getAssignee()// 任务的办理人

+ ",createTime=" + task.getCreateTime() // 任务的创建（生成）的时间

+ ",executionId=" + task.getExecutionId());// 任务所属流程实例的id

方式1： taskService.findGroupTasks(userId);

方式2： List<Task> list = processEngine.getTaskService()//

.createTaskQuery()//

.candidate(userId)//

String taskId = "420001";

processEngine.getTaskService().completeTask(taskId);

processEngine.getTaskService().completeTask(taskId, outcome);

processEngine.getTaskService().completeTask(taskId, outcome, variables);

// 1，设置为false代表：办理完任务后不向后移动（默认为true）

TaskImpl taskImpl = (TaskImpl) processEngine

.getTaskService().getTask(taskId);

taskImpl.setSignalling(false); 

// 2，办理完任务

1， TaskService.takeTask(taskId, userId)，拾取组任务到个人任务列表中，如果任务有assignee，则会抛异常。

2， processEngine.getTaskService().assignTask(taskId, userId)，转交任务给其他人，（如果任务有assignee，则执行这个方法代表重新分配。也可以把assignee设为null表示组任务没有人办理了）

ExecutionService.setVariable(executionId, name, value);

Object obj = executionService.getVariable(executionId, "请假人");

TaskService.setVariables(taskId, variables); // 一次设置多个变量

7.2. Variable types

jBPM supports following Java types as process variables:

 java.lang.String 

 java.lang.Long 

 java.lang.Double 

 java.util.Date 

 java.lang.Boolean 

 java.lang.Character 

 java.lang.Byte 

 java.lang.Short 

 java.lang.Integer 

 java.lang.Float 

 byte[] (byte array) 

 char[] (char array) 

 hibernate entity with a long id 

 hibernate entity with a string id 

 serializable

For persistence of these variable, the type of the variable is checked in the order of this list. The first match will determine how the variable is stored. 

String processInstanceId =  "test.10001";

.endProcessInstance(processInstanceId, ProcessInstance.STATE_ENDED);

1，删除配置：<import resource="jbpm.tx.hibernate.cfg.xml" />

2，增加配置：<import resource="jbpm.tx.spring.cfg.xml" />

<!-- 配置ProcessEngine（整合jBPM4） -->

<!-- jbpmCfg是相对于classpath的相对路径，默认值为jbpm.cfg.xml -->

<bean id="springHelper" 

class="org.jbpm.pvm.internal.processengine.SpringHelper">

<property name="jbpmCfg" value="jbpm.cfg.xml"></property>

</bean>

<bean id="processEngine" factory-bean="springHelper" 

factory-method="createProcessEngine" />

@Test // 测试ProcessEngine

public void testProcessEngine() {

ProcessEngine processEngine = (ProcessEngine)ac.getBean("processEngine");

Assert.assertNotNull(processEngine);

如果做了JBPM4.4与Spring整合（使用了jbpm.tx.spring.cfg.xml），则在程序中就一定要使用Spring注入ProcessEngine，千万不能使用Configuration.getProcessEngine()生成ProcessEngine，因为这时内部的代码有以下逻辑：如果整合了Spring但没有ApplicationContext，就默认读取applicationContext.xml创建ApplicationContext实例并从中获取名为”ProcessEngine”的对象。而这时如果把pe = Configuration.getProcessEngine()写成某Spring中管理的bean的初始化代码，就会有无限循环，不停的创建ApplicationContext了！

1， 修改 jbpm.tx.hibernate.cfg.xml

a) 不让jBPM自行管理事务：去掉<standard-transaction-interceptor />

b) 让Jbpm使用SessionFactory.getCurrentSession()：修改为 <hibernate-session current="true" />

2， 配置可以使用SessionFactory.getCurrentSession()，在jbpm.hibernate.cfg.xml 中配置：<property name="hibernate.current_session_context_class">thread</property>

3， 要使用同一个SessionFactory，且都要使用 SessionFactory.getCurrentSession() 获取 Session：

a) 同一个SessionFactory：SessionFactory sf = processEngine.get(SessionFactory.class)

b) 在 BaseDaoImpl 中增加：

getSession() { return HibernateUtils.getSessionFactory().getCurrentSession(); }

getProcessEngine(){ return org.jbpm.api.Configuration.getProcessEngine(); }

4， 统一的打开与提交或回滚事务：使用 OpenSessionInViewFilter 控制事务。

at org.apache.jsp.WEB_002dINF.jsp.UserAction.loginUI_jsp._jspInit(loginUI_jsp.java:39)

at org.apache.jasper.runtime.HttpJspBase.init(HttpJspBase.java:52)

at org.apache.jasper.servlet.JspServletWrapper.getServlet(JspServletWrapper.java:159)

at org.apache.jasper.servlet.JspServletWrapper.service(JspServletWrapper.java:329)

at org.apache.jasper.servlet.JspServlet.serviceJspFile(JspServlet.java:320)

at org.apache.jasper.servlet.JspServlet.service(JspServlet.java:266)

... 40 more

说明：原因是Jbpm的juel.jar, juel-engine.jar, juel-impl.jar包和Tomcat6.0中的el-api.jar包冲突了。

有三个解决办法：

1，方法一：在MyEclipse的Preferences -> MyEclipse -> Application Servers -> Tomcat -> .. -> Paths 中配置 Append to classpath，选中 juel.jar, juel-engine.jar, juel-impl.jar 这三个jar包就可以了。

2，方法二：将 juel.jar, juel-engine.jar, juel-impl.jar 这三个包复制到tomcat6下 lib/ 中，并删除原来的el-api.jar，

切记还要把工程中 WEB-INF\lib 下的 juel.jar, juel-engine.jar, juel-impl.jar 删除，不然还是要冲突。

3，方法三：换成tomcat5.5，就没有问题了。

com.mysql.jdbc.exceptions.MySQLIntegrityConstraintViolationException: Cannot delete or update a parent row: a foreign key constraint fails (`itcastoa_20100909/jbpm4_execution`, CONSTRAINT `FK_EXEC_INSTANCE` FOREIGN KEY (`INSTANCE_`) REFERENCES `jbpm4_execution` (`DBID_`))

解决办法：把方言设为 MySQL5InnoDBDialect，不能是 MySQLDialect。