jbpm example

===========工作流程=======================================================================================
<?xml version="1.0" encoding="UTF-8"?>

<process-definition
  xmlns=""  name="exceptionReporter">
   <start-state name="開始">
      <transition name="to_report" to="呈報考勤異常">
         <action name="start_report" class="com.ccc.handler.StartReprotExceptionActionHandler"></action>
      </transition>
   </start-state>
   <task-node name="課級主管審核">
      <task name="submit_exception">
       <assignment class="com.ccc.handler.AttendanceExceptionCheckAssignmentHandler"></assignment>
      </task>     
      <transition name="to_confirm" to="高階主管審核">
       <assignment class="com.ccc.handler.AttendanceExceptionCheckAssignmentHandler"></assignment>
      </transition>
      <transition name="to_reapply" to="呈報考勤異常">
    
      </transition>
   </task-node>
   <task-node name="高階主管審核">
 <task name="to_summit">  
  <assignment class="com.ccc.handler.AttendanceExceptionCheckAssignmentHandler"></assignment> 
 </task>
      <transition name="to_finish" to="結束">
      <!-- 結束任務 -->
     
      </transition>
      <transition name="to_recofirm" to="課級主管審核">
      <!-- 退給課級主管 -->
      <assignment class="com.ccc.handler.AttendanceExceptionCheckAssignmentHandler"></assignment>
      </transition>
   </task-node>
   <end-state name="結束"></end-state>
   <task-node name="呈報考勤異常">
      <task name="report_exception">
      <assignment actor-id="#{initiator}"></assignment>
      </task>
      <transition name="to_apply" to="課級主管審核"></transition>
   </task-node>
</process-definition>

==================================發起流程================================================================
 public JbpmContext doJbpmAction(final String employeeId, final String empNo,
   final String empName,final String formId)
   throws Exception {
  return (JbpmContext)jbpmTemplate.execute(new JbpmCallback() {
   @SuppressWarnings("unchecked")
   public Object doInJbpm(JbpmContext jbpmContext) throws JbpmException {
   try {
    
    //取得考勤異常提報的流程定義
    ProcessDefinition process = processDefinitionManager.getLastestProcessDefinition("exceptionReporter");
    ProcessInstance processinstance = new ProcessInstance(process);
    //流程發起者
    processinstance.getContextInstance().setVariable("initiator",employeeId);
    //開啟流程
    jbpmContext.save(processinstance);
    //同時完成下個個流程 ,對該任務進行指派
    processinstance.signal("to_report");
    jbpmTemplate.getHibernateTemplate().flush();
    //記錄該任務相關信息
    List<TaskInstance> taskInstances = (List<TaskInstance>)jbpmContext.getTaskList(employeeId);
    //
    //查找該提報人所在的課級組織信息
     CommOrganizationInfo org1 =baseManager.findOrganizationInfoByEmployeeIdAndOrgLevel(Long.valueOf(employeeId),HrConstant.COMM_ORGANIZATION_LEVEL_CLASS);
     //查找該員工課級主管信息

    List<CommEmployeeInfo> list = organizationManager.getParentCommOrganizationInfoMasterByOrganizationId(org1.getOrganizationId());
    if(taskInstances!=null){
     try{
     for (TaskInstance ti : taskInstances) {  
      if(ti.getName().equals("report_exception")){
         ContextInstance ci = ti.getContextInstance();
      //表單id
      ci.setVariable("requestId",formId);
      ci.setVariable("empName",empName);
      ci.setVariable("employeeId",employeeId);
      ci.setVariable("empNo", empNo);
      ci.setVariable("managerList", list);
      ti.end();
      jbpmContext.save(ti);
      }
      
     }
     }catch(Exception e)
     {
      e.printStackTrace();
     }
    }  
   }catch(JbpmException e1){ 
    e1.printStackTrace();
    throw e1;
   }catch(Exception e2){
    e2.printStackTrace();
   }finally{
    jbpmTemplate.getHibernateTemplate().flush();
   } 
    
    
    return jbpmContext;
   }

  });
  
 }
===================================第一步審核==========================================================================
public boolean submitExceptionHanele(final String empNo, final String taskId,
   final String operatorFlag, final long employeeId,final CommEmployeeInfo commitEmp) throws Exception {

  return (Boolean) jbpmTemplate.execute(new JbpmCallback() {
   public Boolean doInJbpm(JbpmContext jbpmContext)
     throws JbpmException {
    try{
     TaskInstance ti = jbpmContext.getTaskInstance(Long.parseLong(taskId));
     if (operatorFlag.equals("pass")) { 
      try{
      //查找該審核人所在的處級組織信息
       CommOrganizationInfo org1 =baseManager.findOrganizationInfoByEmployeeIdAndOrgLevel(Long.valueOf(employeeId),HrConstant.COMM_ORGANIZATION_LEVEL_SECTION);
      //查找該員工高階主管信息
      List<CommEmployeeInfo> list = organizationManager.getParentCommOrganizationInfoMasterByOrganizationId(org1.getOrganizationId());
      ContextInstance ci = ti.getContextInstance();
      //表單id
      ci.setVariable("formId", ti.getVariable("requestId"));
      //審核人工號
      ci.setVariable("empNo", empNo);
      ci.setVariable("empName", ti.getVariable("empName"));
      ci.setVariable("employeeId", employeeId);
      ci.setVariable("managerList", list);
      ti.end("to_confirm");
      jbpmContext.save(ti);
      }catch(Exception e1)
      {
       e1.printStackTrace();
      }
      jbpmTemplate.getHibernateTemplate().flush();
     } else {    
      //執行退回動作
      //ContextInstance ci = ti.getContextInstance();
      //ci.setVariable("formId", ti.getVariable("requestId"));
      //ci.setVariable("empNo", empNo);
      //ci.setVariable("empName", ti.getVariable("empName"));
      //ci.setVariable("employeeId", employeeId);
      //ArrayList<CommEmployeeInfo> alist =new ArrayList<CommEmployeeInfo>();
      //alist.add(commitEmp); 
      //ci.setVariable("initiator", String.valueOf(commitEmp.getEmployeeId()));
      //jbpmTemplate.getHibernateTemplate().flush();
      ti.end("to_reapply");
      jbpmTemplate.getHibernateTemplate().flush();
      jbpmContext.save(ti);
     }
    }catch(Exception e2)
    {
     e2.printStackTrace();
    }
    return true;
   }
  });
 
 }
===================================第二步審核=======================================================================
public boolean confirmExceptionHanele(final String empNo,final String taskId,
   final String operatorFlag, final long employeeId) throws Exception {
  return (Boolean) jbpmTemplate.execute(new JbpmCallback() {
   public Boolean doInJbpm(JbpmContext jbpmContext)
     throws JbpmException {
    try{
     TaskInstance ti = jbpmContext.getTaskInstance(Long.parseLong(taskId));
     if (operatorFlag.equals("pass")) { 
      try{
      ContextInstance ci = ti.getContextInstance();
      //表單id
      ci.setVariable("formId", ti.getVariable("requestId"));
      //審核人工號
      ci.setVariable("empNo", empNo);
      ci.setVariable("empName", ti.getVariable("empName"));
      ci.setVariable("employeeId", employeeId);
      ti.end("to_finish");
      jbpmContext.save(ti);
      }catch(Exception e1)
      {
       e1.printStackTrace();
      }
      jbpmTemplate.getHibernateTemplate().flush();
     } else { 
      //重新給課級主管指派任務
      //查找該異常人所在高階主管____課級主管
       //CommOrganizationInfo org1 =baseManager.findOrganizationInfoByEmployeeIdAndOrgLevel(Long.valueOf(employeeId),HrConstant.COMM_ORGANIZATION_LEVEL_CLASS);
       //查找該員工課級主管信息
      //List<CommEmployeeInfo> list = organizationManager.getParentCommOrganizationInfoMasterByOrganizationId(org1.getOrganizationId());
      try{
//       ContextInstance ci = ti.getContextInstance();
//       //表單id
//       ci.setVariable("formId", ti.getVariable("requestId"));
//       //審核人工號
//       ci.setVariable("empNo", empNo);
//       ci.setVariable("empName", ti.getVariable("empName"));
//       ci.setVariable("employeeId", employeeId);
//       ci.setVariable("managerList", list);
       ti.end("to_recofirm");
       jbpmContext.save(ti);
       jbpmTemplate.getHibernateTemplate().flush();
       }catch(Exception e1)
       {
        e1.printStackTrace();
       }
       jbpmTemplate.getHibernateTemplate().flush();
     }
    }catch(Exception e2)
    {
     e2.printStackTrace();
    }
    return true;
   }
  });
 }
=============================================任務指派1=============================================================
package com.ccc.handler;

import java.util.Date;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.jbpm.context.exe.ContextInstance;
import org.jbpm.graph.exe.ExecutionContext;

import com.ccc.module.jbpm.handlers.MESActionHandlerManager;

public class StartReprotExceptionActionHandler extends MESActionHandlerManager{
 private transient final Log logger = LogFactory.getLog(StartReprotExceptionActionHandler.class);

 private static final long serialVersionUID = -7703930993012075081L;
 /**
  * 流程開始
  * @author F1632506
  * @date May 8, 2009 9:42:41 AM
  * @param param1
  * @see com.ccc.module.jbpm.empenter.action[#method([execute])]
  * @throws exceptionType
  *             如果...將拋出exceptionType異常.
  * @return returnType 返回類型描述
  */
 public void execute(ExecutionContext executionContext) throws Exception { 
  ContextInstance ci = executionContext.getContextInstance();
  String user = (String)ci.getVariable("initiator"); 
  logger.info(new Date()+user+"發起考勤異常提報流程..");
 }
}

==========
package com.ccc.handler;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.jbpm.context.exe.ContextInstance;
import org.jbpm.graph.exe.ExecutionContext;
import org.jbpm.taskmgmt.def.AssignmentHandler;
import org.jbpm.taskmgmt.exe.Assignable;
import org.springmodules.workflow.jbpm31.JbpmTemplate;

import com.ccc.module.jbpm.empenter.assignment.NewEmpAssignmentHandler;

 

public class AttendanceExceptionAssignmentHandler implements AssignmentHandler
{
 @SuppressWarnings("unused")
 private JbpmTemplate jbpmTemplate;
 @SuppressWarnings("unused")
 private String actor; 
 private transient final Log logger = LogFactory.getLog(NewEmpAssignmentHandler.class);
 private static final long serialVersionUID = 8742291098601946988L;

 
 /**
  * 把所以當日考勤信息的提報任務指派給發起人
  * <p>
  *
  * @author Daniel
  * @date Jun 10, 2009 3:34:19 PM
  * @param assignable
  *            type  public void assign(Assignable
  * @param executionContext
  *            type ExecutionContext
  *            <ul>
  *            <li>jbpm中定義的Assignable
  *            <li>jbpm中定義的ExecutionContext
  *            </ul>
  * @throws exceptionType
  *             如果...將拋出exceptionType異常.
  * @return void
  */
 
 public void assign(Assignable assignable, ExecutionContext executionContext) throws Exception {
  ContextInstance ci = executionContext.getContextInstance();  
  String user = (String)ci.getVariable("initiator");  
  assignable.setActorId(user);
  
 }
 public void setActor(String actor) {
  this.actor = actor;
 }
 
 
 public void setJbpmTemplate(JbpmTemplate jbpmTemplate) {
  this.jbpmTemplate = jbpmTemplate;
 }
}
==========================================任務指派2=======================================================
package com.ccc.handler;
import java.util.List;

import org.jbpm.context.exe.ContextInstance;
import org.jbpm.graph.exe.ExecutionContext;
import org.jbpm.taskmgmt.exe.Assignable;

import com.ccc.model.user.CommEmployeeInfo;
import com.ccc.module.jbpm.handlers.MESAssignmentHandlerManager;
public class AttendanceExceptionCheckAssignmentHandler  extends MESAssignmentHandlerManager
{
 private static final long serialVersionUID = 8067830912869790490L;;
 @SuppressWarnings("unchecked")
 public void assign(Assignable assignable, ExecutionContext executionContext) throws Exception {
  String temp[]=null;
  //取得上下文實例
  ContextInstance context = executionContext.getContextInstance();
  //獲取相應的部分主管
  List<CommEmployeeInfo> list = (List<CommEmployeeInfo>)context.getVariable("managerList"); 
  if(list!=null && list.size()>0)
  {
   int i=0;
   temp=new String[list.size()];
   for(CommEmployeeInfo employee:list)
   {
    
    temp[i++]=employee.getEmployeeId().toString();
    
   }
  }
   try{
   assignable.setPooledActors(temp);
   }catch(Exception e)
   {
    e.printStackTrace();
   } 
 }
}
===========================================end============================================================