近期在學習  JBPM  工作流，上一篇博文描述了實現一個簡單請假工作流的過程

之後花了好幾天的時間來實現一個基於泳道的任務釋出工作流：

簡要流程如下：

某級部門（暫定為A級部門）manager 啟動一個新任務釋出工作流

通過泳道將該任務釋出給A級部門的子部門（B）和孫子部門(C）

B和C部門的所有成員都能夠看到該任務，並可以點選連結檢視該任務的詳細資訊

一旦有成員apply 該任務，則其他人都不能再次apply該任務

如果該成員只是C級部門的成員，不具有manager 的角色，則該次申請還需要提交給C級部門的經理進行稽核。

如果該成員是C級部門的經理，則不需要稽核，直接進入tryfinish 待辦任務

當獲取了任務的assignee 認為自己完成了該項任務時，則可以提交tryfinish 任務，然後該請求進入工作流釋出人的待辦任務列表中

如果工作流釋出者批准該次任務完成，則該次工作流結束。否則重新進入tryfinish 環節。

具體jbpm。xml  程式碼如下所示

<?xml version="1.0" encoding="UTF-8"?>

<process name="assignment" xmlns="http://jbpm.org/4.4/jpdl">
    <swimlane candidate-groups="#{assignGroup}" name="assignmentswin">
    </swimlane>
   <start g="336,33,64,58" name="start1">
      <transition to="assign"/>
   </start>
   <task assignee="#{assignOwner}" form="/SSH/LeaveJSP/assign_add.jsp" g="322,107,80,40" name="assign">
      <transition to="tryAssign"/>
   </task>
   <task form="/SSH/LeaveJSP/assign_trytake.jsp" g="323,180,92,52" name="tryAssign" swimlane="assignmentswin">
      <transition to="exclusive1"/>
   </task>
   <decision expr="#{role=='manager'? 'totryFinish':'tomanagerAprove'}" g="351,278,48,48" name="exclusive1">
      <transition g="-92,-18" name="tomanagerAprove" to="managerAprove"/>
      <transition to="tryFinish" name="totryFinish"/>
   </decision><!--
   <task assignee="#{assignManager}" form="leaveAction!toAssign_Manager.action" g="118,287,92,52" name="managerAprove">
   -->
  
    <task  form="leaveAction!toAssign_Manager.action" g="118,287,92,52" name="managerAprove">
  
     <assignment-handler class="com.util.AssignTask"> 
    <field name="assignee"> 
        <string value="1"/> 
     </field> 
  </assignment-handler> 
   
      <transition g="-61,-18" name="approveTry" to="tryFinish"/>
      <transition g="-59,-18" name="notApproveTry" to="tryAssign"/>
   </task>
   <task form="leaveAction!toAssign_tryFinish.action" g="332,464,92,52" name="tryFinish" swimlane="assignmentswin">
      <transition to="ifFinish"/>
   </task>
   <end g="355,711,48,48" name="end1"/>
   <task assignee="#{assignOwner}" form="leaveAction!toAssign_ifFinish.action" g="339,611,92,52" name="ifFinish">
      <transition name="AcceptFinish" to="end1" g="-65,-18"/>
      <transition g="504,599:-82,-18" name="NotAcceptFinish" to="tryFinish"/>
   </task>
</process>

這個版本的jbpm。xml 檔案採用了 assignment-handler  來實現根據C級部門成員apply 任務時確定C級部門的manager ，即確定批准C級成員apply 該任務的manager。

我這次的工作就花了很長的時間在確定manager 上。

當C級部門成員apply 該才任務時，工作流進入了部門manager 批准的環節，在這個環節中使用到了 assignment-handler，通過該環節的executionId來獲取到該次工作流的歷史任務列表。然後從歷史人物列表的最後一個歷史任務中取到apply 任務的C級部門成員的assign name。取到了上一個任務的assign name ，也就可以將 assign 所在部門的manager name 放入到當前任務的assingee 。從而確定了當前任務的assignee。

下面是AssignTask   的程式碼。

AssignTask.java    

package com.util;

import java.util.List;

import org.jbpm.api.ProcessEngine;
import org.jbpm.api.TaskService;
import org.jbpm.api.history.HistoryTask;
import org.jbpm.api.model.OpenExecution;
import org.jbpm.api.task.Assignable;
import org.jbpm.api.task.AssignmentHandler;
import org.jbpm.api.task.Task;
import org.jbpm.pvm.internal.history.model.HistoryTaskImpl;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.model.User;
import com.service.UserService;
import com.service.imp.UserServiceImp;

public class AssignTask implements AssignmentHandler{
    String assignee;
 private UserService userService;
 private ProcessEngine processEngine;
 
 @Override
 public void assign(Assignable assignable, OpenExecution openExecution) throws Exception {
 
 ApplicationContext context=new ClassPathXmlApplicationContext("applicationContext.xml");
processEngine=(ProcessEngine) context.getBean("processEngine");
userService=(UserService)context.getBean("userService");
 
    String executionId= openExecution.getId();
    System.out.println("executionId-----------"+executionId);
    List <HistoryTask>list = processEngine.getHistoryService().createHistoryTaskQuery().executionId(executionId).list();
    String tryAssignUserName="";
    for(int i=0;i<list.size();i++){
     HistoryTaskImpl taskImpl=(HistoryTaskImpl)list.get(i);
     tryAssignUserName=    taskImpl.getAssignee();
               
         Task task = processEngine.getTaskService().getTask(list.get(i).getId());

               if(task!=null&&task.getName().equals("tryAssign")){
             
               
               }
      
         }
 if(!tryAssignUserName.equals("")){
  User user1=userService.findUserByName(tryAssignUserName);
  User assignManager=user1.getDepartment().getManagerUser();
  assignable.setAssignee(assignManager.getUsername());
 
 }
  
   
 }

}

對這段程式碼需要作如下的說明：

// 我們已經知道了上一個任務節點的名稱是“tryAssign”，所以可以對歷史任務列表中的每一個歷史任務進行取出任務名稱並和“tryAssign”進行比對，如果相同，則將該歷史任務的assignee 取出。該assingee 就是C級部門apply 任務的組成員名。

不過在這裡只能取到 tryAssign  的HistoryTaskImpl 而不能取到 task，不過由於上一個任務節點肯定是在歷史任務列表的最後一個位置，所以可以通過取巧的方式獲取到歷史人物列表最後一個HistoryTaskImpl 的assignee 來確定tryAssign 的assingee。

對泳道的說明：

在jbpm.xml 檔案中，有兩處swimlane="assignmentswin"   ，分別是在tryAssign 和tryFinish  任務節點時。

因為在tryAssign 時，泳道確定了獲取tryAssign 任務的assignee ，則jbpm 會將assignee 儲存起來，在下次D任務節點用到swimlane="assignmentswin"   時，D任務節點會將任務的assingee 自動分配給這個泳道的assignee

下面是action 中tryAssign 方法的程式碼：

   public String applayAssign(){
       Map map=new HashMap();
       String tryAssignUserName="";
       User user=(User)ActionContext.getContext().getSession().get("user");
       User user2=user.getDepartment().getManagerUser();
       if(user.equals(user2)){
           map.put("role", "manager");
          
       }
       else {map.put("role", "common");
           }
       map.put("tryTime", tryTime);
       map.put("tryCondition", tryCondition);
      
       taskService.takeTask(taskId,user.getUsername() );
      
       String executionId = processEngine.getTaskService().getTask(taskId).getExecutionId();
       List <HistoryTask>list = processEngine.getHistoryService().createHistoryTaskQuery().executionId(executionId).list();

       for(int i=0;i<list.size();i++){
HistoryTaskImpl taskImpl=(HistoryTaskImpl)list.get(i);
            String tempName=    taskImpl.getAssignee();
          
       Task task = processEngine.getTaskService().getTask(list.get(i).getId());

          if(task!=null&&task.getName().equals("tryAssign")){
              tryAssignUserName=tempName;
             
          }
   
       }
      User user4= this.userServcie.findUserByName(tryAssignUserName);
      User assignManager=user4.getDepartment().getManagerUser();
    //  map.put("assignManager", assignManager.getUsername());
       taskService.completeTask(taskId,map);
       return "addLeaveApplay";
   }

方法一和方法二在這裡的區別，就是沒有將   assignManager進行賦值並傳遞給 managerAprove  任務中。