- 浏览: 328957 次
- 性别:
- 来自: 天津
文章分类
最新评论
-
xing0029:
这样配置的话 事物不成功啊 还有什么地方需要注意的么 可以加我 ...
JTA集成JOTM或Atomikos配置分布式事务(Tomcat应用服务器) -
mengqingyu:
liuxiaolu 写道jotm的我的没有成功,楼主能否帮助一 ...
JTA集成JOTM或Atomikos配置分布式事务(Tomcat应用服务器) -
liuxiaolu:
jotm的我的没有成功,楼主能否帮助一下
JTA集成JOTM或Atomikos配置分布式事务(Tomcat应用服务器) -
aptech406328627:
求解救,没弄好QQ:1053942353
Spring邮件发送(可带附件,模板,群发,异步发送等功能) -
ghpaas:
web可视化自定义表单推荐使用GForms开发平台(http: ...
在线表单设计器设计原理
集成JBPM到OA系统,并实现JbpmFacade接口
- 第一步:创建数据库表
* 拷贝依赖包:bsh.jar/jcr-1.0.jar/jbpm-identity.jar/jbpm-jpdl.jar
* 修改hibernate.cfg.xml,添加JBPM的映射配置,以及缓存属性的配置
- 拷贝JBPM中的hibernate配置文件到当前项目
- 修改build.xml文件,在"生成Hibernate配置文件"的任务中,添加一个属性:
mergecfgxml="${basedir}/hibernate_for_jbpm.cfg.xml"
* 因为JBPM中的User类与OA系统中的User类在名称上有冲突,所以需要修改OA
系统中的User类的auto-import="false",并更改查询User对象的HQL语句,加上
全路径的类名进行查找,可以参考UserManagerImpl类。
- 第二步:与spring集成
* 集成spring与JBPM,需要用到第三方的类库:spring-modules-0.8.zip
* 将其中的spring-modules-jbpm31.jar拷贝到web-inf/lib下面即可
* 集成JBPM与spring的方法是:将JbpmConfiguration对象交给spring来创建
* 所以,需要在spring配置文件里面配置JbpmConfiguration对象的创建
<bean id="jbpmConfiguration" class="org.springmodules.workflow.jbpm31.LocalJbpmConfigurationFactoryBean">
<property name="configuration" value="classpath:jbpm.cfg.xml"></property>
</bean>
* 这个时候,需要拷贝jbpm.cfg.xml到类路径中
(可以从jbpm-jpdl-3.2.GA\src\jpdl\org\jbpm目录中拷贝(default.jbpm.cfg.xml)文件,
并重命名即可)
- 第三步:如何实现业务逻辑类
* 用到jbpmConfiguration的时候,需要注入
* 当我们使用jbpmContext对象来操纵JBPM的时候,需要将JbpmContext内部的Hibernate session对象设置为当前的
hibernate session对象。
private JbpmContext getJbpmContext(){
JbpmContext context = jbpmConfiguration.createJbpmContext();
context.setSession(getSession());
return context;
}
* 当我们使用jbpmContext操纵JBPM数据结束的时候,注意不要关闭jbpmContext!!
- 第一步:创建数据库表
* 拷贝依赖包:bsh.jar/jcr-1.0.jar/jbpm-identity.jar/jbpm-jpdl.jar
* 修改hibernate.cfg.xml,添加JBPM的映射配置,以及缓存属性的配置
- 拷贝JBPM中的hibernate配置文件到当前项目
- 修改build.xml文件,在"生成Hibernate配置文件"的任务中,添加一个属性:
mergecfgxml="${basedir}/hibernate_for_jbpm.cfg.xml"
* 因为JBPM中的User类与OA系统中的User类在名称上有冲突,所以需要修改OA
系统中的User类的auto-import="false",并更改查询User对象的HQL语句,加上
全路径的类名进行查找,可以参考UserManagerImpl类。
- 第二步:与spring集成
* 集成spring与JBPM,需要用到第三方的类库:spring-modules-0.8.zip
* 将其中的spring-modules-jbpm31.jar拷贝到web-inf/lib下面即可
* 集成JBPM与spring的方法是:将JbpmConfiguration对象交给spring来创建
* 所以,需要在spring配置文件里面配置JbpmConfiguration对象的创建
<bean id="jbpmConfiguration" class="org.springmodules.workflow.jbpm31.LocalJbpmConfigurationFactoryBean">
<property name="configuration" value="classpath:jbpm.cfg.xml"></property>
</bean>
* 这个时候,需要拷贝jbpm.cfg.xml到类路径中
(可以从jbpm-jpdl-3.2.GA\src\jpdl\org\jbpm目录中拷贝(default.jbpm.cfg.xml)文件,
并重命名即可)
- 第三步:如何实现业务逻辑类
* 用到jbpmConfiguration的时候,需要注入
* 当我们使用jbpmContext对象来操纵JBPM的时候,需要将JbpmContext内部的Hibernate session对象设置为当前的
hibernate session对象。
private JbpmContext getJbpmContext(){
JbpmContext context = jbpmConfiguration.createJbpmContext();
context.setSession(getSession());
return context;
}
* 当我们使用jbpmContext操纵JBPM数据结束的时候,注意不要关闭jbpmContext!!
package com.bjsxt.oa.manager; import java.util.List; import com.bjsxt.oa.model.Document; public interface JbpmFacade { /** * 部署流程定义 * @param processDef 流程定义文件的数据 * @return 流程名称 */ public String deployProcessDefinition(byte[] processDef); /** * 删除流程定义 * @param processName 流程名称 */ public void delProcessDefinition(String processName); /** * 添加流程实例 * @param processName 流程实例对应的流程名称 * @param docId 公文ID * @return 流程实例 */ public long addProcessInstance(String processName,Document document); /** * 删除流程实例对象 * @param processInstanceId 删除流程实例对象 */ public void delProcessInstance(long processInstanceId); /** * 搜索某个用户手上的公文列表 * @param actorId 用户帐号 * @return List中的元素是docId */ public List searchMyTaskList(String actorId); /** * 查询下一步Transition列表 * @param processInstanceId 流程实例标识 * @param actorId 用户帐号 * @return List中的元素是Transition对象的名称 */ public List searchNextTransitions(long processInstanceId,String actorId); /** * 触发JBPM引擎流转到下一步 * @param processInstanceId 流程实例标识 * @param actorId 用户帐号 * @param transitionName transition Name * @return 流转之后,当前流程实例所对应的rootToken所指向的节点的名称 */ public String nextStep(long processInstanceId,String actorId,String transitionName); } package com.bjsxt.oa.manager.impl; import java.io.ByteArrayInputStream; import java.util.ArrayList; import java.util.Collection; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Set; import org.jbpm.JbpmConfiguration; import org.jbpm.JbpmContext; import org.jbpm.graph.def.ProcessDefinition; import org.jbpm.graph.def.Transition; import org.jbpm.graph.exe.ProcessInstance; import org.jbpm.taskmgmt.exe.TaskInstance; import com.bjsxt.oa.manager.JbpmFacade; import com.bjsxt.oa.model.Document; public class JbpmFacadeImpl extends AbstractManager implements JbpmFacade { private JbpmConfiguration jbpmConfiguration; public long addProcessInstance(String processName, Document document) { JbpmContext context = getJbpmContext(); ProcessDefinition def = context.getGraphSession().findLatestProcessDefinition(processName); ProcessInstance instance = new ProcessInstance(def); instance.getContextInstance().setVariable("document", document.getId()); //将公文的标题放到流程实例变量中,以便在发送email的时候使用 instance.getContextInstance().setVariable("docTitle", document.getTitle()); //将公文的相关属性设置到流程实例变量中 Map props = document.getProperties(); if(props != null){ Set entries = props.entrySet(); for (Iterator iterator = entries.iterator(); iterator.hasNext();) { Map.Entry entry = (Map.Entry) iterator.next(); String propertyName = (String)entry.getKey(); Object obj = document.getProperty(propertyName); //将变量放入流程实例中 instance.getContextInstance().setVariable(propertyName, obj); } } context.save(instance); return instance.getId(); } public void delProcessDefinition(String processName) { JbpmContext context = getJbpmContext(); List defs = context.getGraphSession().findAllProcessDefinitionVersions(processName); for (Iterator iterator = defs.iterator(); iterator.hasNext();) { ProcessDefinition def = (ProcessDefinition) iterator.next(); context.getGraphSession().deleteProcessDefinition(def); } } public void delProcessInstance(long processInstanceId) { JbpmContext context = getJbpmContext(); context.getGraphSession().deleteProcessInstance(processInstanceId); } public String deployProcessDefinition(byte[] processDef) { JbpmContext context = getJbpmContext(); ProcessDefinition def = ProcessDefinition.parseXmlInputStream( new ByteArrayInputStream(processDef) ); context.deployProcessDefinition(def); return def.getName(); } public String nextStep(long processInstanceId, String actorId, String transitionName) { JbpmContext context = getJbpmContext(); ProcessInstance instance = context.getProcessInstance(processInstanceId); //当前节点 String currentNodeName = instance.getRootToken().getNode().getName(); //起点的名称 String startNodeName = instance.getProcessDefinition().getStartState().getName(); //如果是在起点 if(startNodeName.equals(currentNodeName)){ if(transitionName == null){ instance.signal(); }else{ instance.signal(transitionName); } }else{ List taskInstances = context.getTaskMgmtSession().findTaskInstances(actorId); for (Iterator iterator = taskInstances.iterator(); iterator .hasNext();) { TaskInstance ti = (TaskInstance) iterator.next(); if(ti.getProcessInstance().getId() == processInstanceId){ if(transitionName == null){ ti.end(); }else{ ti.end(transitionName); } break; } } //查询actorId所属组的任务实例 List pooledTaskInstances = context.getTaskMgmtSession().findPooledTaskInstances(actorId); for (Iterator iterator = pooledTaskInstances.iterator(); iterator .hasNext();) { TaskInstance ti = (TaskInstance) iterator.next(); if(ti.getProcessInstance().getId() == processInstanceId){ if(transitionName == null){ ti.end(); }else{ ti.end(transitionName); } break; } } } //返回转向之后的节点名称 return instance.getRootToken().getNode().getName(); } public List searchMyTaskList(String actorId) { JbpmContext context = getJbpmContext(); List docIds = new ArrayList(); //查询所有未结束的任务实例 List taskInstances = context.getTaskMgmtSession().findTaskInstances(actorId); for (Iterator iterator = taskInstances.iterator(); iterator.hasNext();) { TaskInstance ti = (TaskInstance) iterator.next(); Integer docId = (Integer)ti.getProcessInstance().getContextInstance().getVariable("document"); docIds.add(docId); } //查询actorId所属组的任务实例 List pooledTaskInstances = context.getTaskMgmtSession().findPooledTaskInstances(actorId); for (Iterator iterator = pooledTaskInstances.iterator(); iterator .hasNext();) { TaskInstance ti = (TaskInstance) iterator.next(); Integer docId = (Integer)ti.getProcessInstance().getContextInstance().getVariable("document"); docIds.add(docId); } return docIds; } public List searchNextTransitions(long processInstanceId, String actorId) { JbpmContext context = getJbpmContext(); ProcessInstance instance = context.getProcessInstance(processInstanceId); //当前节点 String currentNodeName = instance.getRootToken().getNode().getName(); //起点的名称 String startNodeName = instance.getProcessDefinition().getStartState().getName(); Collection transitions = null; //如果是在起点 if(startNodeName.equals(currentNodeName)){ transitions = instance.getRootToken().getAvailableTransitions(); }else{ List taskInstances = context.getTaskMgmtSession().findTaskInstances(actorId); for (Iterator iterator = taskInstances.iterator(); iterator .hasNext();) { TaskInstance ti = (TaskInstance) iterator.next(); if(ti.getProcessInstance().getId() == processInstanceId){ transitions = ti.getAvailableTransitions(); break; } } //查询actorId所属组的任务实例 List pooledTaskInstances = context.getTaskMgmtSession().findPooledTaskInstances(actorId); for (Iterator iterator = pooledTaskInstances.iterator(); iterator .hasNext();) { TaskInstance ti = (TaskInstance) iterator.next(); if(ti.getProcessInstance().getId() == processInstanceId){ transitions = ti.getAvailableTransitions(); break; } } } List transitionNames = new ArrayList(); //为了不把Transition对象直接暴露给OA系统,需要将其转换为名称列表 for (Iterator iterator = transitions.iterator(); iterator.hasNext();) { Transition transition = (Transition) iterator.next(); transitionNames.add(transition.getName()); } return transitionNames; } private JbpmContext getJbpmContext(){ JbpmContext context = jbpmConfiguration.createJbpmContext(); context.setSession(getSession()); return context; } public void setJbpmConfiguration(JbpmConfiguration jbpmConfiguration) { this.jbpmConfiguration = jbpmConfiguration; } }
发表评论
-
基于Mybatis封装的增删改查实现通用自动化sql
2014-12-07 20:59 41271.基于map或javaBean的增删改查可实现不写dao接口 ... -
S2SH读取XML扩展点
2014-07-27 01:39 684由于struts2、hibernate通过默认配置文件不支持通 ... -
导出Word、Excel、PPT通用功能设计思路
2014-03-07 16:25 1807工作中经常 ... -
HttpClient抓取解析网站支持多种验证方式
2014-03-06 10:10 1399工作中遇到了抓取多个项目数据并且有多种验证方式包括Http标准 ... -
Tomcat架构分析及性能调优
2014-02-16 17:59 3189一.Tomcat容器层级结构 分为四个等级,由四个子容器组成 ... -
基于FLEX,MINA消息推送核心代码
2013-10-21 16:15 1686import java.util.List; impor ... -
(转载)拦截器与过滤器的区别
2013-05-10 15:36 996拦截器与过滤器的区别 : 1.拦截器是基于java的反射机制 ... -
(转载)Struts中默认的拦截器栈
2013-05-10 13:19 5038Struts中默认的拦截器栈 ... -
Java并发模式
2013-04-02 12:58 2235在公司做培训时用到,顺便在这里做个总结。 1.生产者消费者模式 ... -
海量数据、高并发优化方案
2013-03-16 18:53 8468一.应用服务器负载均衡 1.链路负载均衡 通过DNS解析域 ... -
Lucene 详解
2013-03-01 11:10 14891.什么是全文检索 对于搜索,按被搜索的资源类 ... -
Spring JDBC批量操作
2013-01-20 02:51 271、使用JdbcTemplate进行批 ... -
Spring MVC 文件上传
2010-03-23 16:45 1124MultipartHttpServletRequest mul ... -
导出Excel(jxl)
2009-08-05 09:15 526Action代码: import java.io.IOExce ... -
Hibernate笔记(常用技术)
2009-07-21 17:13 2125一.对象关系映射基础 1.hibernate对象属性映射 ...
相关推荐
一、流程定义的基本概念: 二、流程执行的基本概念: 三、流程引擎核心调度过程 ----------------------- jbpm的实现流程图全文共3页,当前为第1页。 jbpm的实现流程图全文共3页,当前为第2页。 ࠀ࠘ࠚࠜࣾऀंऄआ...
jbpm5_持久化及流转流程剖析
jbpm4整合流程例子及附代web流程设计器可以进行流程设计
JBPM采购申请系统——08_JBPM流程节点.7z JBPM采购申请系统——08_JBPM流程节点.7z JBPM采购申请系统——08_JBPM流程节点.7z JBPM采购申请系统——08_JBPM流程节点.7z JBPM采购申请系统——08_JBPM流程节点.7z JBPM...
JBPM流程监控的实现过程
一个请假流程的实现(struts2.1.8+spring2.5+hibernate3集成jbpm4.4)
jbpm4.1实现报销流程 人员定置,流程走读
jbpm工作流程jbpm工作流程jbpm工作流程jbpm工作流程jbpm工作流程
文档详细介绍了如何利用JBPM开发流程应用,从框架构造到节点处理。
jBPM2-流程图与JBPM API.ppt jBPM2-流程图与JBPM API.ppt
jbpm4.4流程图
一个Jbpm员工请假流程的实例(doc)
JBPM是JBOSS公司的一个开源工作流产品,它功能强大,商业工作流所提供的功能它基本上都有。然而在JBPM中没有提供流程监控的功能的相关API,这点让很多使用JBPM做企业应用的开发人员颇为头疼。
jbpm4.3,jbpm4.3工作流程管理例子
一个Jbpm员工请假流程的实例(源代码)
使用JBoss jBPM实现流程访问和执行的授权
jbpm5 持久化及流转流程剖析 使用线程启动TaskServer,初始化持久化OrganizationEntity,将流程中需要使用到的 groupId,actorId.全部初始化到表中。
jbpm4.3 请假流程实例示例jbpm4.3 请假流程实例示例jbpm4.3 请假流程实例示例jbpm4.3 请假流程实例示例jbpm4.3 请假流程实例示例
JBPM流程代码演示
jbpm4流程提交及执行完整代码,把每个文件放到对应的位置即可。 生成流程跟踪图的方法见: http://download.csdn.net/source/2905937