businesshandler_enter.java

这是一个jbpm的高级应用,是一个oa工作流的系统,里面用到了spring,hibernate技术等.实为学习jbpm的好资料!

package com.xiangfeng.jbpm.ActionHandler;

import java.util.Date;
import java.util.Iterator;
import java.util.List;

import org.hibernate.Session;
import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.graph.def.ActionHandler;
import org.jbpm.graph.exe.ExecutionContext;
import org.jbpm.graph.exe.ProcessInstance;
import org.jbpm.graph.exe.Token;
import org.jbpm.graph.node.TaskNode;
import org.jbpm.taskmgmt.def.Task;
import org.jbpm.taskmgmt.exe.TaskInstance;
import org.jbpm.taskmgmt.exe.TaskMgmtInstance;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

import com.xiangfeng.util.hibernateUtil.HibernateUtil;



public class BusinessHandler_enter  implements ActionHandler{
	
	public void execute(ExecutionContext ctx) throws Exception {
		System.out.println("--------------------------触发了进入商家 --------------------");
		System.out.println("-------------当前节点为  -----"+ctx.getProcessInstance().getRootToken().getNode().getName());
	
		//List tasks=	ctx.getJbpmContext().getTaskMgmtSession().findTaskInstances("businessadmin");
		//System.out.println("-------------------------------businessadmin tasks size is "+tasks.size());
		
		Token token = ctx.getToken();
	    TaskMgmtInstance tmi =ctx.getTaskMgmtInstance();
	    TaskNode taskNode = (TaskNode) ctx.getNode();
	    Task sub_bill = taskNode.getTask("拆分订单");
	   // changeNappy.s
	    
	    String billNO= ctx.getProcessInstance().getKey();
	    System.out.println("分配任务---------------------------------billNO  is "+billNO);
	  // Session session = HibernateUtil.getSession();
	   // ctx.getJbpmContext().setSession(session);
		try {
			//session.beginTransaction();
		/*	List subs =session.createQuery("from Bill_Ex be where be.CBillNo = ? ")
			.setParameter(0, billNO).list();
			if(subs.size()>0){
			
				//根据扩展表进行拆分 生成多个任务实例
				for(int i=0;i<subs.size();i++){
					
					TaskInstance temp=  tmi.createTaskInstance(sub_bill, token);
				
			}
			}*/
			System.out.println("----------------------------------开始创建任务实例");
			for(int i=0;i<3;i++){
				System.out.println("------------------------------创建任务实例");
				TaskInstance temp=	 tmi.createTaskInstance(sub_bill, token);
				//temp.setProcessInstance(arg0)
				System.out.println("------------------------------创建任务实例");
			}
		} catch (Exception e) {

			//session.getTransaction().rollback();
			e.printStackTrace();
		} finally {
			ctx.getJbpmContext().close();
			//HibernateUtil.closeSession(session);
		}
		
	
		
	}
	
	


}