ah_tobusiness_billtraceactionhandler.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.graph.def.ActionHandler;
import org.jbpm.graph.exe.ExecutionContext;
import org.jbpm.graph.exe.ProcessInstance;
import org.jbpm.taskmgmt.exe.TaskInstance;

import com.xiangfeng.model.Bill_Trace;
import com.xiangfeng.util.hibernateUtil.HibernateUtil;

public class AH_tobusiness_BillTraceActionHandler implements ActionHandler{

	public void execute(ExecutionContext ctx) throws Exception {
		
		System.out.println("触发了AH_tobusiness_BillTraceActionHandler----客服中心提交给商家");
		//String billNO= ctx.getProcessInstance().getKey();
		//System.out.println("$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$billNO is "+billNO);
		 String billIid=(String)ctx.getContextInstance().getVariable("billIid");
		String username=(String)ctx.getContextInstance().getVariable("username");
	
		
		
		System.out.println("username is "+username);
		
		Bill_Trace bt = new Bill_Trace();
		bt.setBActive(true);
		//bt.setCBillNo(billNO);
		bt.setCBillStatus("客服中心提交给商家");
		//bt.setTCreate(new Date());
		bt.setTBegin(new Date());
		bt.setTActor(username);
		//Bill bill =null;
		Session session = HibernateUtil.getSession();

		try {
			session.beginTransaction();
			session.save(bt);
			
			
			List tasks=	ctx.getJbpmContext().getTaskMgmtSession().findTaskInstances("billadmin");
			System.out.println("tasks.size()  is "+tasks.size());
			//TaskInstance taskInstance = (TaskInstance)tasks.get(0);
			for (Iterator iter = tasks.iterator(); iter.hasNext();) {
				
				TaskInstance taskInstance = (TaskInstance) iter.next();
				ProcessInstance instance =  taskInstance.getProcessInstance();
				System.out.println("$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$instance.getKey is "+instance.getKey());
			}
		session.getTransaction().commit();
		
	
		} catch (Exception e) {

			session.getTransaction().rollback();
			e.printStackTrace();
		} finally {
			HibernateUtil.closeSession(session);
		}	
		
	}

}