jbpm ssh oa 源代码

package com.zhy.manager.impl; import java.io.ByteArrayInputStream; import java.util.ArrayList; import java.util.Collection; import java.util.Iterator; import java.util.List; 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 org.springframework.orm.hibernate3.support.HibernateDaoSupport; import com.zhy.manager.WorkflowManager; import com.zhy.model.Document; import com.zhy.model.Workflow; public class WorkflowManagerImpl extends HibernateDaoSupport implements WorkflowManager { private JbpmConfiguration jbpmConfiguration; public long addProcessInstance(String workflowName, int documentId) { JbpmContext context = getContext(); //从JBPM中加载流程定义 ProcessDefinition definition = context.getGraphSession().findLatestProcessDefinition(workflowName); //SQLServer 执行到此时，如果该定义已经创建了公文就不能继续创建公文，问题尚未解决 ProcessInstance instance = new ProcessInstance(definition); //将公文标识绑定到流程实例 instance.getContextInstance().createVariable("document", documentId); context.save(instance); //存储流程实例的信息 return instance.getId(); } public void delProcessInstance(long processInstanceId) { JbpmContext context = getContext(); //删除流程实例 context.getGraphSession().deleteProcessInstance(processInstanceId); } public void delWorkflow(int workflowId) { //在OA中删除流程的定义 Workflow workflow = (Workflow)getHibernateTemplate().load(Workflow.class, workflowId); getHibernateTemplate().delete(workflow); //在JBPM中删除流程定义 //JBPM对流程定义按版本进行管理，所以在同一个时刻，可能存在同一个流程定义的多个不同的版本 //如果需要对其删除，则应该删除所有的版本 //查找对应流程定义的所有版本 List defs = getContext().getGraphSession().findAllProcessDefinitionVersions(workflow.getName()); for (Iterator iter = defs.iterator(); iter.hasNext();) { ProcessDefinition def = (ProcessDefinition) iter.next(); getContext().getGraphSession().deleteProcessDefinition(def); } } public void deployProcessDefinition(byte[] processDefinition, byte[] processImage) { //通过byte[]创建ProcessDefinition对象 ProcessDefinition def = ProcessDefinition.parseXmlInputStream( new ByteArrayInputStream(processDefinition)); //将流程定义文件部署到JBPM getContext().deployProcessDefinition(def); //首先查找一下Workflow对象是否已经存在 Workflow workflow = (Workflow)getSession() .createQuery("select w from Workflow w where w.name = ? ") .setParameter(0, def.getName()) .uniqueResult(); //如果流程尚未存在，则创建 if(workflow == null){ workflow = new Workflow(); workflow.setName(def.getName()); workflow.setProcessDefinition(processDefinition); workflow.setProcessImage(processImage); getHibernateTemplate().save(workflow); return; } //如果流程已经存在，则更新 workflow.setName(def.getName()); workflow.setProcessDefinition(processDefinition); workflow.setProcessImage(processImage); getHibernateTemplate().save(workflow); } public Workflow findWorkflow(int workflowId) { return (Workflow)getHibernateTemplate().load(Workflow.class, workflowId); } public String flowToNextStep(String username, long processInstanceId, String transitionName) { JbpmContext context = getContext(); String status = null; ProcessInstance instance = context.getProcessInstance(processInstanceId); //当前节点 String currentNodeName = instance.getRootToken().getNode().getName(); //起始节点 String startNodeName = instance.getProcessDefinition().getStartState().getName(); //如果是在起始节点，因为起始节点不会跟任何人相关联（即不会将任务分配给任何人） if(currentNodeName.equals(startNodeName)){ //需要使用流程实例的signal()方法来触发流程向下一步流动！ instance.getRootToken().signal(transitionName); }else{ //首先找出用户的当前任务 List tasks = context.getTaskMgmtSession().findTaskInstances(username); for (Iterator iter = tasks.iterator(); iter.hasNext();) { TaskInstance taskInstance = (TaskInstance) iter.next(); if(taskInstance.getProcessInstance().getId() == processInstanceId){ //这就是当前文档对应的任务，需要结束这个任务，从而触发流程向下一步骤移动！ taskInstance.end(transitionName); break; } } } //将公文当前所处节点作为状态信息返回 status = instance.getRootToken().getNode().getName(); //判断当前的状态是否已经结束！ if(instance.hasEnded()){ status = Document.STATUS_END; } return status; } @SuppressWarnings("unchecked") public List<Workflow> searchAllWorkflows() { return getHibernateTemplate().find("from Workflow"); } public List<Integer> searchApprovingDocuments(String username) { JbpmContext context = getContext(); List<Integer> docIds = new ArrayList<Integer>(); //首先获得流转到用户的任务列表 List tasks = context.getTaskMgmtSession().findTaskInstances(username); for (Iterator iter = tasks.iterator(); iter.hasNext();) { TaskInstance taskInstance = (TaskInstance) iter.next(); //任务实例是否正在等待审批，如果不是，则忽略（即不应该被列到待审批列表中！） if(!taskInstance.isSignalling()){ continue; } //根据其对应的流程实例，获得公文标识 Integer docId = (Integer)taskInstance.getProcessInstance().getContextInstance().getVariable("document"); docIds.add(docId); } return docIds; } //下一步都有哪些流向？ @SuppressWarnings("unchecked") public List<String> searchNextTransitions(String username,long processInstanceId) { JbpmContext context = getContext(); List<String> transitions = new ArrayList<String>(); //根据流程实例标识查找流程实例 ProcessInstance instance = context.getProcessInstance(processInstanceId); // //根据流程实例，获得当前的节点，从而得到在当前节点下有哪些流向 // List nextSteps = instance.getRootToken().getNode().getLeavingTransitions(); //当前节点 String currentNodeName = instance.getRootToken().getNode().getName(); System.err.println("当前节点名"+currentNodeName); //起始节点 String startNodeName = instance.getProcessDefinition().getStartState().getName(); System.err.println("起始节点名"+startNodeName); Collection nextSteps = null; //如果是在起始节点，因为起始节点不会跟任何人相关联（即不会将任务分配给任何人） if(currentNodeName.equals(startNodeName)){ //需要使用流程实例的signal()方法来触发流程向下一步流动！ nextSteps = instance.getRootToken().getAvailableTransitions(); System.err.println("nextSteps为："+nextSteps); System.err.println("instance.getRootToken().getFullName()为："+instance.getRootToken().getName()); }else{ //首先找出用户的当前任务 List<TaskInstance> tasks = context.getTaskMgmtSession().findTaskInstances(username); for (Iterator iter = tasks.iterator(); iter.hasNext();) { TaskInstance taskInstance = (TaskInstance) iter.next(); if(taskInstance.getProcessInstance().getId() == processInstanceId){ nextSteps = taskInstance.getAvailableTransitions(); break; } } } for (Iterator iter = nextSteps.iterator(); iter.hasNext();) { Transition transition = (Transition) iter.next(); transitions.add(transition.getName()); } return transitions; } /** * 获取JbpmContext对象，需要将JbpmContext的session设置为当前的session对象 * @return */ private JbpmContext getContext(){ JbpmContext context = jbpmConfiguration.createJbpmContext(); context.setSession(getSession()); return context; } public void setJbpmConfiguration(JbpmConfiguration jbpmConfiguration) { this.jbpmConfiguration = jb