jbpm-----封装
public interface WorkflowEngine{ /** 核心是：拿到定义，部署定义 *inputStream the content of process definition id of the new deployed process remark */ public long deployProcessDefinition(InputStream inputStream,String remark); /* *启动流程之后，第一个节点随之结束，执行点在第二个节点 pdname 流程定义的名称 starter 流程的启动者 version 流程定义的版本，如果不为空，则启动指定版本的流程 long 返回刚启动的流程实例的id varMap 变量列表，在工作流启动的时候，可以设置些变量进去 */ public String startProcess(Strin pname,String starter,String version,Map varMap); /** * 获取参与者指定状态的任务列表 actorId 参与者id status 任务的状态 PagedObject 分页后的结果集 */ public PagedObject getWorkList(String actorId,WorkitemCriteria wc); /** * 办理任务，主要实现任务的签收 actorId 任务参与者id wid 工作项id */ public String takeWorkitem(String actorId,String wid); /** *完成任务 */ public void completeWorkitem(String currentWorkItemId ,NextStep nextStep); }public class JbpmImpl implements WorkflowEngine{ public String deployProcessDefinition(InputStream inputStream,String remark){ JbpmContext jbpmContext = JbpmConfiguration.getInstance().getCurrentJbpmContext(); ProcessDefinition pd = ProcessDefinition.parseParZipInputStream(new ZipInputStream(inputStream)); jbpmContext.deployProcessDefinition(pd); //可以将remark存入我们自己扩充的表里 return Long.toString(pd.getId()); } public String startProcess(String pdname,String starter,String version,Map varMap){ ProcessDefinition pd = null; JbpmContext jbpmContext = JbpmConfiguration.getInstance().getCurrentJbpmContext(); if(version != null){ //如果version为空，则获得最新版本的流程定义 pd = jbpmContext.getGraphSession().findProcessDefinition(pdname,Integer.parseInt(version)); }else{ pd = jbpmContext.getGraphSession().findLatestProcessDefinition(pdname); } ProcessInstance pi = new ProcessInstance(pd); if(varMap != null){ for(Iterator it =varMap.keySet().iterator();it.hasNext()){ String varName = (String)it.next(); pi.getContextInstance().setVariable(varName,varMap.get(varName)); } } pi.getInstance().setVariable("starter",starter); //为了以后的节点可以拿到它 jbpmContext.setActorId(starter); //设置参与者 //如果开始节点有Task和没有Task的不同处理，如果没有Task，那么endTime当然可以不用设置 if(pi.getTaskMgmtInstance().getTaskMgmtDefinition().getStartTask() != null){ TaskInstance ti = pi.getTaskMgmtInstance().createStartTaskInstance(); ti.start(); ti.end() }else{ pi.signal(); } jbpmContext.save(pi); return Long.toString(pi.getId()); } public PagedObject getWorkList(String actorId,WorkitemCriteria wc){ PagedObject po = new PagedObject(); JbpmContext jbpmContext = JbpmConfiguration.getInstance().getCurrentJbpmContext(); Criteria rootCriteria = jbpmContext.getSession().createCriteria(TaskInstance.class); if(wc.getPdname() != null && !"".equals(wc.getPdname())) rootCriteria.createAlias("processInstance","pi") .createAlias("pi.processDefinition","pd") .add(Expression.like("pd.name"),wc.getPdname()); if(wc.getActorIdea() != null && !"".equals(wc.getActorIdea())) rootCriteria.add(Expression.eq("actorId",actorId)); if(wc.getTname()!= null && !"".equals(wc.getTname())) rootCriteria.add(Expression.like("name",wc.getTname())); if(wc.getStatus() != null){ if("0".equals(wc.getStatus())) //刚创建 rootCriteria.add(Expression.and(Expression.isNull("start"),Expression.isNull("end"))); if("1".equals(wc.getStatus())) //任务已经启动 rootCriteria.add(Expression.and(Expression.isNotNull("start"),Expression.isNull("end"))); if("2".equals(wc.getStatus())) //任务完成 rootCriteria.add(Expression.and(Expression.isNotNull("start"),Expression.isNotNull("end"))); } int total = (Integer)(rootCriteria.setProjection(org.hibernate.criterion.Projections.countDistinct("id")).uniqueResult()).intValue(); rootCriteria.setProjection(null); rootCriteria.setMaxResults(wc.getNeveryPage()); rootCriteria.setFirstResult(wc.getStart()); List list = rootCriteria.setResultTransformer(Criteria.DISINCT_ROOT_ENTITY).list(); po.setResult(list); po.setTotal(total); po.setNpages((total+wc.getNereryPage()-1)/wc.getNereryPage()); return po; } public String takeWorkitem(String actorId,String wid){ JbpmContext jbpmContext = JbmpConfiguration.getInstance().getCurrentJbpmContext(); TaskInstance ti = jbpmContext.loadTaskInstance(Long.parseLong(wid)); if(ti.getStart() != null){ ti.start(); if(actorId != null)ti.start(actorId); } String pdname = ti.getProcessInstance().getProcessDefinition().getName(); String view = ProcessViewMap.getView(pdname); return view } //完成任务的核心是 ti.end(),但是是需要end到下 public void completeWorkitem(String currentWorkItemId ,NextStep nextStep){ JbpmContext jbpmContext = JbpmConfiguration.getInstance().getCurrentJbpmContext(); TaskInstance ti = jbpmContext.loadTaskInstance(Long.parseLong(currentWorkItemId)); if(nextStep != null){ if(nextStep.getActorId() != null&&！"".equals(nextStep.getActorId())) //下一步可能有多个执行者，把这个设置进去 ti.getProcessInstance().getContextInstance().setVariable("actorId",nextStep.getActorId()); if(nextStep.getNextStepName() != null && !"".equals(nextStep.getNextStepName())){ ti.end(nextStep.getNextStepName()); } }else{ ti.end(); } }}public class ServiceLocator{ public static WorkflowEngine getWorkflowEngine(){ return new JbpmImpl(); }}public class PagedObject{ private int ncurrentPage; private static int N_EVERY_PAGE = 10; private List result; private int total; public int getNpages(){ return (total+N_EVERY_PAGE -1)/N_EVERY_PAGE; }}public class WorkitemCriteria{private String pdname;private String tname;private String status;private String actorId; private int start; private int maxResult;}public class NextStep{ private String nextStepName; private String actorId;}