PromoterAssignmentProvider類(lèi)源碼
package com.bstek.bdf2.jbpm4.view.assignment.provider.impl.promoter;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import org.apache.commons.lang.StringUtils;
import org.jbpm.api.model.OpenExecution;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import com.bstek.bdf2.jbpm4.model.AssignmentInfo;
import com.bstek.bdf2.jbpm4.model.PrincipalDef;
import com.bstek.bdf2.jbpm4.service.IBpmService;
import com.bstek.bdf2.jbpm4.view.assignment.provider.IAssignmentProvider;
/**
 * 流程發(fā)起人任務(wù)分配方式
 * @author Jacky.gao
 * @since 2013-3-23
 */
@Component
public class PromoterAssignmentProvider implements IAssignmentProvider {
 @Value("${bdf2.jbpm4.disablePromoterAssignment}")
 private boolean disabled;
 @Autowired
 @Qualifier(IBpmService.BEAN_ID)
 private IBpmService bmpService;
 public String getUrl() {
 return null;
 }
 public String getTypeId() {
 return "promoter";
 }
 public String getTypeName() {
 return "流程實(shí)例發(fā)起人";
 }
 public Collection<AssignmentInfo> getAssignmentInfos(String assignmentDefId) {
 List<AssignmentInfo> info=new ArrayList<AssignmentInfo>();
 AssignmentInfo a=new AssignmentInfo();
 a.setName("流程實(shí)例發(fā)起人");
a.setValue("從流程實(shí)例中取名為["+IBpmService.PROCESS_INSTANCE_PROMOTER+"]的變量值,這個(gè)變量值表
示流程實(shí)例發(fā)起人用戶名");
 info.add(a);
 return info;
 }
 public Collection<PrincipalDef> getTaskPrincipals(String assignmentDefId,OpenExecution execution) {
 List<PrincipalDef> usernames=new ArrayList<PrincipalDef>();
 String username=(String)execution.getVariable(IBpmService.PROCESS_INSTANCE_PROMOTER);
 if(StringUtils.isEmpty(username)){
 throw new RuntimeException("Variable not found ["+IBpmService.PROCESS_INSTANCE_PROMOTER+"]
in current process instance");
 }
 PrincipalDef p=new PrincipalDef();
 p.setId(username);
 usernames.add(p);
 return usernames;
 }
 public void deleteAssignmentInfos(String assignmentDefId){
 //do nothing
 }
 public boolean isDisabled(){
 return disabled;
 }
}

SpecifyUserAssignmentProvider類(lèi)源碼
package com.bstek.bdf2.jbpm4.view.assignment.provider.impl.specifyuser;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.hibernate.Session;
import org.jbpm.api.model.OpenExecution;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import com.bstek.bdf2.jbpm4.Jbpm4HibernateDao;
import com.bstek.bdf2.jbpm4.model.AssignmentInfo;
import com.bstek.bdf2.jbpm4.model.InternalAssignment;
import com.bstek.bdf2.jbpm4.model.PrincipalDef;
import com.bstek.bdf2.jbpm4.view.assignment.provider.IAssignmentProvider;
/**
 * 指定一個(gè)用戶作為任務(wù)處理人
 * @author Jacky.gao
 * @since 2013-3-23
 */
@Component
public class SpecifyUserAssignmentProvider extends Jbpm4HibernateDao implements
IAssignmentProvider {
 @Value("${bdf2.jbpm4.disableSpecifyUserAssignment}")
 private boolean disabled;
 public String getUrl() {
 return "bdf2.jbpm4.view.assignment.provider.impl.specifyuser.SpecifyUserProvider";
 }
 public String getTypeId() {
 return "specify_user";
 }
 public String getTypeName() {
 return "指定一個(gè)用戶";
 }
 public Collection<AssignmentInfo> getAssignmentInfos(String assignmentDefId) {
 String hql="from "+InternalAssignment.class.getName()+" where assignmentDefId=:assignmentDefId";
 Map<String,Object> map=new HashMap<String,Object>();
 map.put("assignmentDefId", assignmentDefId);
 List<InternalAssignment> internals=this.query(hql, map);
 List<AssignmentInfo> infos=new ArrayList<AssignmentInfo>();
 for(InternalAssignment internal:internals){
 AssignmentInfo info=new AssignmentInfo();
 info.setName("一個(gè)用戶");
 info.setValue(internal.getName());
 infos.add(info);
 }
 return infos;
 }
 public Collection<PrincipalDef> getTaskPrincipals(String assignmentDefId,OpenExecution execution) {
 String hql="from "+InternalAssignment.class.getName()+" where assignmentDefId=:assignmentDefId";
 Map<String,Object> map=new HashMap<String,Object>();
 map.put("assignmentDefId", assignmentDefId);
 List<InternalAssignment> internals=this.query(hql, map);
 List<PrincipalDef> result=new ArrayList<PrincipalDef>();
 for(InternalAssignment internal:internals){
 PrincipalDef def=new PrincipalDef();
 def.setId(internal.getValue());
 result.add(def);
 }
 return result;
 }
 public void deleteAssignmentInfos(String assignmentDefId){
 String hql="delete "+InternalAssignment.class.getName()+" where assignmentDefId=:assignmentDefId";
 Map<String,Object> map=new HashMap<String,Object>();
 map.put("assignmentDefId", assignmentDefId);
 Session session=this.getSessionFactory().openSession();
 try{
 session.createQuery(hql).setString("assignmentDefId", assignmentDefId).executeUpdate();
 }finally{
 session.flush();
 session.close();
 }
 }
 public boolean isDisabled() {
 return disabled;
 }
}

定義一個(gè)任務(wù)分配方式，確認(rèn)后，再次打開(kāi)任務(wù)節(jié)點(diǎn)配置界面，就可以看到定義的任務(wù)分配方式，如下圖所示：

任務(wù)處理人配置好之后，就可以利用這個(gè)配置與監(jiān)控對(duì)流程模版進(jìn)行測(cè)試了，通過(guò)點(diǎn)擊工具欄上的“創(chuàng)建實(shí)例”按鈕就可以創(chuàng)建一個(gè)新的流程實(shí)例，以這個(gè)流程模版為例，新的流程實(shí)例產(chǎn)生后，流程將會(huì)流轉(zhuǎn)到初審節(jié)點(diǎn)，右上邊的任務(wù)列表中也會(huì)出現(xiàn)這個(gè)初審節(jié)點(diǎn)上產(chǎn)生的任務(wù)，點(diǎn)擊其上的“查看流程圖按鈕”，可以看到當(dāng)前流程實(shí)例所處位置，如下圖所示：