安科网

JBPM的简单总结

xiaowanggedege

xiaowanggedege

2010-02-24

关注 关注

安装JBPM

-引入Hibernate依赖包

-引入JBPM依赖包

*bsh.jar

*jcr-1.0.jar

*jbpm-identity.jar

*jbpm-jpdl.jar

-引入数据库驱动

定义相关配置文件

-Hibernate配置文件

*提供hibernate配置文件（可以从config/目录下拷贝，并修改其中的数据库连接设置即可）

定义流程的文档
public class Document {   

    private int id;   


    private String title;   


    private String content;   


    private String creator;   


    private Long processIntanceId;   

}  
public class Document {
	private int id;
	private String title;
	private String content;
	private String creator;
	private Long processIntanceId;
}

//在数据库中创建表格

JbpmConfiguration.getInstance().createSchema();

//部署流程
JbpmConfiguration jbpmConfiguration = JbpmConfiguration.getInstance();    
JbpmContext context = jbpmConfiguration.createJbpmContext();   

try{   

    context.deployProcessDefinition(processDefinition);   

}finally{   


    //context对象需要关闭   

    context.close();   
}  
JbpmConfiguration jbpmConfiguration = JbpmConfiguration.getInstance(); 
JbpmContext context = jbpmConfiguration.createJbpmContext();
try{
    context.deployProcessDefinition(processDefinition);
}finally{
	//context对象需要关闭
	context.close();
}

//创建公文

//创建流程实例,将公文并与流程实例绑定
JbpmContext context = jbpmConfiguration.createJbpmContext();   
        context.setSessionFactory(HibernateUtils.getSessionFactory());   
           

        //从数据库中加载ProcessDefinition对象   


        ProcessDefinition definition = context.getGraphSession().findLatestProcessDefinition("文档测试流程");   

           

        //从流程中创建一个流程实例   


        ProcessInstance processInstance = new ProcessInstance(definition);   

           

        //存储流程实例   

        context.save(processInstance);   
           

        //加载公文   


        Document doc = (Document)context.getSession().load(Document.class, 1);   

           

        //绑定流程实例到公文   

        doc.setProcessIntanceId(processInstance.getId());   
           

        //绑定公文到流程实例(ContextInstance相当于一个变量的容器)   


        processInstance.getContextInstance().createVariable("document", doc.getId());   

           
        context.close();  
JbpmContext context = jbpmConfiguration.createJbpmContext();
		context.setSessionFactory(HibernateUtils.getSessionFactory());
		
		//从数据库中加载ProcessDefinition对象
		ProcessDefinition definition = context.getGraphSession().findLatestProcessDefinition("文档测试流程");
		
		//从流程中创建一个流程实例
		ProcessInstance processInstance = new ProcessInstance(definition);
		
		//存储流程实例
		context.save(processInstance);
		
		//加载公文
		Document doc = (Document)context.getSession().load(Document.class, 1);
		
		//绑定流程实例到公文
		doc.setProcessIntanceId(processInstance.getId());
		
		//绑定公文到流程实例(ContextInstance相当于一个变量的容器)
		processInstance.getContextInstance().createVariable("document", doc.getId());
		
		context.close();

获得流程实例对象，并触发流程实例走向下一步

JbpmContext context = jbpmConfiguration.createJbpmContext();   
        context.setSessionFactory(HibernateUtils.getSessionFactory());   
           

        Document doc = (Document)context.getSession().load(Document.class, 1);   

           
        ProcessInstance processInstance = context.getProcessInstance(doc.getProcessIntanceId());   
           

        //触发流程实例走向下一步   

        processInstance.getRootToken().signal();   

        //获得当前流程节点的名字   

        processInstance.getRootToken().getNode().getName()   
        context.close();  
JbpmContext context = jbpmConfiguration.createJbpmContext();
		context.setSessionFactory(HibernateUtils.getSessionFactory());
		
		Document doc = (Document)context.getSession().load(Document.class, 1);
		
		ProcessInstance processInstance = context.getProcessInstance(doc.getProcessIntanceId());
		
		//触发流程实例走向下一步
		processInstance.getRootToken().signal();
		//获得当前流程节点的名字
		processInstance.getRootToken().getNode().getName()
		context.close();

第一个节点对应的用户登录，应该能够查询到其当前的任务（有公文等待其审批）

*Listtasks=context.getTaskMgmtSession().findTaskInstances("张三");-查找张三的任务列表

*列表元素是TaskInstance实例

*通过：taskInstance.getProcessInstance().getContextInstance().getVariable("document");可以找到其绑定的公文ID

JbpmContext context = jbpmConfiguration.createJbpmContext();   
        context.setSessionFactory(HibernateUtils.getSessionFactory());   
  

        List tasks = context.getTaskMgmtSession().findTaskInstances("张三");   


        System.err.println("张三的文档有：");   


        for (Iterator iter = tasks.iterator(); iter.hasNext();) {   

            TaskInstance taskInstance = (TaskInstance) iter.next();   

            Integer docId = (Integer)taskInstance.getProcessInstance().getContextInstance().getVariable("document");   

            System.err.println(docId);   
        }   
           

        List tasks1 = context.getTaskMgmtSession().findTaskInstances("李四");   


        System.err.println("李四的文档有：");   


        for (Iterator iter = tasks1.iterator(); iter.hasNext();) {   

            TaskInstance taskInstance = (TaskInstance) iter.next();   

            Integer docId = (Integer)taskInstance.getProcessInstance().getContextInstance().getVariable("document");   

            System.err.println(docId);   
        }   
           
           

        List tasks2 = context.getTaskMgmtSession().findTaskInstances("王五");   


        System.err.println("王五的文档有：");   


        for (Iterator iter = tasks2.iterator(); iter.hasNext();) {   

            TaskInstance taskInstance = (TaskInstance) iter.next();   

            Integer docId = (Integer)taskInstance.getProcessInstance().getContextInstance().getVariable("document");   

            System.err.println(docId);   
        }   
           
           
        context.close();  
JbpmContext context = jbpmConfiguration.createJbpmContext();
		context.setSessionFactory(HibernateUtils.getSessionFactory());

		List tasks = context.getTaskMgmtSession().findTaskInstances("张三");
		System.err.println("张三的文档有：");
		for (Iterator iter = tasks.iterator(); iter.hasNext();) {
			TaskInstance taskInstance = (TaskInstance) iter.next();
			Integer docId = (Integer)taskInstance.getProcessInstance().getContextInstance().getVariable("document");
			System.err.println(docId);
		}
		
		List tasks1 = context.getTaskMgmtSession().findTaskInstances("李四");
		System.err.println("李四的文档有：");
		for (Iterator iter = tasks1.iterator(); iter.hasNext();) {
			TaskInstance taskInstance = (TaskInstance) iter.next();
			Integer docId = (Integer)taskInstance.getProcessInstance().getContextInstance().getVariable("document");
			System.err.println(docId);
		}
		
		
		List tasks2 = context.getTaskMgmtSession().findTaskInstances("王五");
		System.err.println("王五的文档有：");
		for (Iterator iter = tasks2.iterator(); iter.hasNext();) {
			TaskInstance taskInstance = (TaskInstance) iter.next();
			Integer docId = (Integer)taskInstance.getProcessInstance().getContextInstance().getVariable("document");
			System.err.println(docId);
		}
		
		
		context.close();

-查找到当前的任务对应的公文之后，即可对其审批，并继续往下走

* taskInstance.end();
JbpmContext context = jbpmConfiguration.createJbpmContext();   
        context.setSessionFactory(HibernateUtils.getSessionFactory());   
  

        List tasks = context.getTaskMgmtSession().findTaskInstances("张三");   


for (Iterator iter = tasks.iterator(); iter.hasNext();) {   

            TaskInstance taskInstance = (TaskInstance) iter.next();   
               

            //张三已经审批结束，继续提交，这将触发流程继续向下流动！   

            taskInstance.end();   
               

            Integer docId = (Integer)taskInstance.getProcessInstance().getContextInstance().getVariable("document");   


            System.err.println(docId+"已被审批完成");   

        }  
JbpmContext context = jbpmConfiguration.createJbpmContext();
		context.setSessionFactory(HibernateUtils.getSessionFactory());

		List tasks = context.getTaskMgmtSession().findTaskInstances("张三");
for (Iterator iter = tasks.iterator(); iter.hasNext();) {
			TaskInstance taskInstance = (TaskInstance) iter.next();
			
			//张三已经审批结束，继续提交，这将触发流程继续向下流动！
			taskInstance.end();
			
			Integer docId = (Integer)taskInstance.getProcessInstance().getContextInstance().getVariable("document");
			System.err.println(docId+"已被审批完成");
		}

-如此，直到结束

* processInstance.hasEnded() - 如果流程已经到达终点，本调用将返回true
  

//部署流程定义   

getJbpmContext().deployProcessDefinition(pdf);   
  

//删除流程定义   

List defs = getJbpmContext().getGraphSession().findAllProcessDefinitionVersions(workFlow.getName());   

for (Iterator iterator = defs.iterator(); iterator.hasNext();) {   

    ProcessDefinition pdf = (ProcessDefinition) iterator.next();   
    getJbpmContext().getGraphSession().deleteProcessDefinition(pdf);               
}   
  
  

//创建流程实例,先根据流程定义的名称获得流程定义对象，获得流程定义(GraphSession对象)   

GraphSession graphSession = context.getGraphSession();   

//findLatestProcessDefinition查找最新的流程定义，根据流程名称   

ProcessDefinition process = context.getGraphSession().findLatestProcessDefinition(workFlowName);   
  

ProcessInstance instance = new ProcessInstance(process);   


//绑定到文档，根据文档的ID   


instance.getContextInstance().createVariable("documnet", documentId);   

context.save(instance);   
  

//删除流程实例   

context.getGraphSession().deleteProcessInstance(processInstanceId);   
  

//获得一个流程实例，根据ID   

ProcessInstance processInstance = jbpmContext.getProcessInstance(doc.getProcessIntanceId());   
  

//获量(TaskInstance)流程实例的数组(根据用户名字)   

List task = context.getTaskMgmtSession().findTaskInstances(username);   

for (Iterator iterator = task.iterator(); iterator.hasNext();) {   

    TaskInstance taskInstance = (TaskInstance)iterator.next();   

    //是否   


    if(!taskInstance.isSignalling()){   


        continue;   

    }   

    //先获得ProcessInstance,再获得ContextInstance,再getVariable,(创建的时候是setVariable)   


    //得到的是文档的ID   


    Integer i = (Integer) taskInstance.getProcessInstance().getContextInstance().getVariable("document");   

    docIds.add(i);   
}   
  

//获得当前节点和起始节点   

String currentNodeName = instance.getRootToken().getNode().getName();   
String startNodeName = instance.getProcessDefinition().getStartState().getName();   
  

/**  
     * 搜索下一步的流向，即下一步都可以走哪些路径   
     * Parameters:  
     * username  
     * processInstanceId  
     * Returns:  
     * 流向的名称列表  
     */    
       

    public List searchNextTransitions(String username, long processInstanceId) {   

        JbpmContext context = getJbpmContext();   

        List transitions = new ArrayList();   

           
        ProcessInstance instance = context.getProcessInstance(processInstanceId);   
           
        String currentNodeName = instance.getRootToken().getNode().getName();   
        String startNodeName = instance.getProcessDefinition().getStartState().getName();   
           

        Collection nextSteps = null;   


        //如果当前节点和起始节点相等   


        if(currentNodeName.equals(startNodeName)){   


            //获得走向的Set集合   

            nextSteps = instance.getRootToken().getAvailableTransitions();   

        }else{   


            //如果当前节点不是起始节点,获得用户的TaskInstance   

            List list = context.getTaskMgmtSession().findTaskInstances(username);   

            for (Iterator iterator = list.iterator(); iterator.hasNext();) {   

                TaskInstance taskInstance = (TaskInstance) iterator.next();   

                //如果相等，获得走向的Set集合   


                if(taskInstance.getProcessInstance().getId()==processInstanceId){   

                    nextSteps = taskInstance.getAvailableTransitions();   

                    break;   

                }                  
            }              
        }   

        //只获得名字   


        for (Iterator iterator = nextSteps.iterator(); iterator.hasNext();) {   

            Transition transition = (Transition) iterator.next();   
            transitions.add(transition.getName());   
        }          

        return transitions;   

    }   
  

//流向下一步   


    public String flowToNextStep(String username, long processInstanceId,   

            String transitionName) {   
        JbpmContext jbpmContext = getJbpmContext();   

        String status = null;   

        ProcessInstance instance = jbpmContext.getProcessInstance(processInstanceId);   
        String currentName = instance.getRootToken().getNode().getName();   
        String startName = instance.getProcessDefinition().getStartState().getName();   

        if(currentName.equals(startName)){   


            //起始节点,流向指定的transitionName   

            instance.getRootToken().signal(transitionName);   

        }else{   

            List task = jbpmContext.getTaskMgmtSession().findTaskInstances(username);   

            for (Iterator iterator = task.iterator(); iterator.hasNext();) {   

                TaskInstance taskInstance = (TaskInstance) iterator.next();   

                if(taskInstance.getProcessInstance().getId()==processInstanceId){   


                    //非起始节点,流向指定的transitionName   

                    taskInstance.end(transitionName);   

                    break;   

                }   
            }   
        }   

        //获得当前的Token   

        status = instance.getRootToken().getName();   

        if(instance.hasEnded()){   

            status = Document.STATUS_END;   
        }   

        return status;   

    }  
//部署流程定义
getJbpmContext().deployProcessDefinition(pdf);

//删除流程定义
List defs = getJbpmContext().getGraphSession().findAllProcessDefinitionVersions(workFlow.getName());
for (Iterator iterator = defs.iterator(); iterator.hasNext();) {
	ProcessDefinition pdf = (ProcessDefinition) iterator.next();
	getJbpmContext().getGraphSession().deleteProcessDefinition(pdf);			
}


//创建流程实例,先根据流程定义的名称获得流程定义对象，获得流程定义(GraphSession对象)
GraphSession graphSession = context.getGraphSession();
//findLatestProcessDefinition查找最新的流程定义，根据流程名称
ProcessDefinition process = context.getGraphSession().findLatestProcessDefinition(workFlowName);

ProcessInstance instance = new ProcessInstance(process);
//绑定到文档，根据文档的ID
instance.getContextInstance().createVariable("documnet", documentId);
context.save(instance);

//删除流程实例
context.getGraphSession().deleteProcessInstance(processInstanceId);

//获得一个流程实例，根据ID
ProcessInstance processInstance = jbpmContext.getProcessInstance(doc.getProcessIntanceId());

//获量(TaskInstance)流程实例的数组(根据用户名字)
List task = context.getTaskMgmtSession().findTaskInstances(username);
for (Iterator iterator = task.iterator(); iterator.hasNext();) {
	TaskInstance taskInstance = (TaskInstance)iterator.next();
	//是否
	if(!taskInstance.isSignalling()){
		continue;
	}
	//先获得ProcessInstance,再获得ContextInstance,再getVariable,(创建的时候是setVariable)
	//得到的是文档的ID
	Integer i = (Integer) taskInstance.getProcessInstance().getContextInstance().getVariable("document");
	docIds.add(i);
}

//获得当前节点和起始节点
String currentNodeName = instance.getRootToken().getNode().getName();
String startNodeName = instance.getProcessDefinition().getStartState().getName();

/**
	 * 搜索下一步的流向，即下一步都可以走哪些路径 
	 * Parameters:
	 * username
	 * processInstanceId
	 * Returns:
	 * 流向的名称列表
	 */	
	
	public List searchNextTransitions(String username, long processInstanceId) {
		JbpmContext context = getJbpmContext();
		List transitions = new ArrayList();
		
		ProcessInstance instance = context.getProcessInstance(processInstanceId);
		
		String currentNodeName = instance.getRootToken().getNode().getName();
		String startNodeName = instance.getProcessDefinition().getStartState().getName();
		
		Collection nextSteps = null;
		//如果当前节点和起始节点相等
		if(currentNodeName.equals(startNodeName)){
			//获得走向的Set集合
			nextSteps = instance.getRootToken().getAvailableTransitions();
		}else{
			//如果当前节点不是起始节点,获得用户的TaskInstance
			List list = context.getTaskMgmtSession().findTaskInstances(username);
			for (Iterator iterator = list.iterator(); iterator.hasNext();) {
				TaskInstance taskInstance = (TaskInstance) iterator.next();
				//如果相等，获得走向的Set集合
				if(taskInstance.getProcessInstance().getId()==processInstanceId){
					nextSteps = taskInstance.getAvailableTransitions();
					break;
				}				
			}			
		}
		//只获得名字
		for (Iterator iterator = nextSteps.iterator(); iterator.hasNext();) {
			Transition transition = (Transition) iterator.next();
			transitions.add(transition.getName());
		}		
		return transitions;
	}

//流向下一步
	public String flowToNextStep(String username, long processInstanceId,
			String transitionName) {
		JbpmContext jbpmContext = getJbpmContext();
		String status = null;
		ProcessInstance instance = jbpmContext.getProcessInstance(processInstanceId);
		String currentName = instance.getRootToken().getNode().getName();
		String startName = instance.getProcessDefinition().getStartState().getName();
		if(currentName.equals(startName)){
			//起始节点,流向指定的transitionName
			instance.getRootToken().signal(transitionName);
		}else{
			List task = jbpmContext.getTaskMgmtSession().findTaskInstances(username);
			for (Iterator iterator = task.iterator(); iterator.hasNext();) {
				TaskInstance taskInstance = (TaskInstance) iterator.next();
				if(taskInstance.getProcessInstance().getId()==processInstanceId){
					//非起始节点,流向指定的transitionName
					taskInstance.end(transitionName);
					break;
				}
			}
		}
		//获得当前的Token
		status = instance.getRootToken().getName();
		if(instance.hasEnded()){
			status = Document.STATUS_END;
		}
		return status;
	}

jbpm hibernate

xiaowanggedege

xiaowanggedege

0 关注 0 粉丝 0 动态

关注 关注

相关推荐

Jbpm4.4 整合Spring Hibernate4

Jbpm 4.4 整合 spring，数据库是mysql,hibernate大版本是4。但是 jbpm 在maven 仓库中可能down 不下了。故此在此值穿上jbpm的jar

whileinsist 2017-09-08

Jbpm4.4 整合Spring Hibernate4

Jbpm 4.4 整合 spring，数据库是mysql,hibernate大版本是4。但是 jbpm 在maven 仓库中可能down 不下了。故此在此值穿上jbpm的jar

MayMatrix 2017-09-08

JBPM学习之二（JBPM的部署）

JBPM开发可以采用Ant、juint来进行。因为项目需要，我采用的是直接web程序开发，下面为开发步骤：

zyljjf 2013-01-30

Myeclipse 安装 JBPM

4.勾选Personal Sites 下的 jBPM ，点击next5.点击JBPM 4 Graphical Editor and Tools，再点击 Apply6.显示安装 JBPM插件，点击 next，点击update7.安装完成

xnuzfm 2014-03-11

JBPM3.2.1 如何得到建立jbpm数据库表的sql脚本

JBPM3.2.1 如何得到建立jbpm数据库表的sql脚本？sqlServer,Oracle,Mysql的建表脚本怎么得到？请写得详细些，谢谢。确实删除那些就没有问题了，这个脚本似乎是为了升级老数据库才添加了很多alter。谁在用jbpm，我们交流一下。

spprogrammer 2013-12-18

jbpm4.4 myeclipse 8.5 安装

选择 Add from Archive File，然后浏览并选择jBPM-4.4\install\src\gpd\jbpm-gpd-site.zip文件，然后写一个名字并点击OK. 打开window 》 Preferences 》 Jboss jBPM 》

Gin工作室 2013-11-13

JBPM学习bug综汇

InnoDB锁定在行级并且也在SELECT语句提供一个Oracle风格一致的非锁定读。另外InnoDB是为处理巨大数据量时的最大性能设计。它的CPU效率可能是任何其它基于磁盘的关系数据库引擎所不能匹敌的。MySQLInnoDBDialect基于上也就有In

Gexrior 2012-08-25

开源工具流产品

StarFlow是一个轻量级的工作流引擎，它融入了我所接触的电信行业业务流程的特殊要求，提供了灵活的工作任务分派策略、业务流程版本管理策略、丰富的流程模式、灵活的组织模型和子流程等特性。StarFrame-Flow是StarFlow工作流的一个web应用工

新开源牛海龙 2012-02-18

BPM4.3总结二 Jbpm4.3使用文档

jBPM是一个可扩展、灵活的流程引擎，它可以运行在独立的服务器上或者嵌入任何Java应用中。首先到jbpm安装目录，复制examples\src下的xml文件到你的项目src下。--改成自己的数据库链接默认是hsql，可以直接运行examples-->

tianhennan 2011-07-22

Spring配置我知道

若遇到named query not known便是该配置丢失导致。*、我认知的spring管理jbpm. spring整合jbpm的实现方式:jbpm.cfg.xml要增加对spring配置文件的引用，除此之外，spring配置文件。建议写物理路径的全路

MayMatrix 2017-01-05

jbpm设计缺陷

Map<String, String> variables = new HashMap<String, String>();variables.put("请假天数", "2天");variab

特 2016-10-21

jbpm 4中快速删除JBPM自带数据表数据的语句

delete from jbpm4_variable;delete from jbpm4_task;delete from jbpm4_property;delete from jbpm4_lob;delete from jbpm4_hist_actins

HEERY 2013-06-29

3.JBPM与SSH框架整合

使用Jbpm进行软件开发，最终不可避免的与Java软件应用开发框架的老大ssh完成整合。在ssh框架基础添加jar文件的话，需要的jar文件不多，主要是drools系列和jbpm核心jar包。这里建议jbpm使用数据库与业务系统使用数据库一致，不要再spr

什么什么高手 2013-02-27

JBPM最新情报

JBPM简介　　JBPM，全称是Java Business Process Management，它是覆盖了业务流程管理、工作流、服务协作等领域的一个开源的、灵活的、易扩展的可执行流程语言框架。jBPM是公开源代码项目，使用它要遵循 ASL和EULA协议。

易鲸捷大数据库 2013-01-05

JBPM介绍与项目搭建

　　JBPM在2004年10月18日，发布了2.0版本，并在同一天加入了JBoss，成为了JBoss企业中间件平台的一个组成部分，它的名称也改成JBoss jBPM。随着jBPM加入JBoss组织，jBPM也将进入一个全新的发展时代，它的前景是十分光明的。

bianruifeng 2012-08-27

揭秘jbpm流程引擎内核设计思想及构架

3什么是流程引擎内核？流程引擎内核仅是“满足Process基本运行”的最微小结构，而整个引擎则要复杂很多，包括“状态存储”、“事件处理”、“组织适配”、“时间调度”、“消息服务”等等外围的服务性功能。引擎内核，仅包含最基本的对象和服务，以及用于解决流程运行

CherrylinORC 2012-07-31

JBPM4.4 简的的应用

只接给大家点代码看看吧哈。。

liuqipao 2012-07-05

jbpm4.4安装配置

jBPM需要JDK 5或更高版本。jBPM下载包install目录中有一个ant的build.xml文件,切换到install目录下，使用ant-p你可以看到所有的安装。demo.setup.tomcat：安装tomcat，把jboss安装到tomcat中

园搬家测试账号 2011-12-09

揭秘jbpm流程引擎内核设计思想及构架

3什么是流程引擎内核？所以在此之前，国内尚未有一篇技术文章探讨工作流引擎内核的实现，当然也没有探讨jbpm引擎内核的文章了。本篇就是以jbpm为实例，来诠释工作流引擎的内核设计思路和结构。相比较而言，jbpm的模型比较复杂，而引擎内核实现的比较“精简”，非

特 2011-10-12

jbpm4 和 spring 的集成

jbpm4内置了和spring的集成支持，配置很简单，只需要在jbpm.cfg.xml中改两个地方就可

mxcsdn 2011-06-29
xiaowanggedege

xiaowanggedege

W3CSchool教程
HTML 教程
CSS 教程
Bootstrap 教程
Javascript 教程
jQuery 教程
后端教程
C 教程
Java 教程
PHP 教程
Python 教程
Go 教程
移动开发
Android 教程
Swift 教程
Kotlin 教程
jQuery Mobile 教程
ionic 教程
关于我们
新闻动态
联系方式
招聘英才
安科实验室
帮助与反馈

安科网(Ancii)，中国第一极客网

Copyright © 2013 - 2019 Ancii.com

京ICP备18063983号 京公网安备11010802014868号