JBPM3动态分支的实现
1,大领导分发文件给中层领导（不同部门），中层领导发给下属，部门下属看完，提交汇总到秘书处有朋友也遇到这方面的问题，我就贴个贴子，不再一一回复了，参考了论坛上的一些资料，代码如下：
public class ForkManageActionHandler implements ActionHandler { public void execute(ExecutionContext executionContext) throws Exception {
ProcessInstance pi = executionContext.getProcessInstance();
ContextInstance ci = executionContext.getContextInstance();
Token rootToken = pi.getRootToken();
ForkVariableVoforkVariableVo = (ForkVariableVo)ci.getVariable(Constants.FORK_VARIABLE_VO);
//角色发送和多人签收分支
if(forkVariableVo.isRoleSend() && forkVariableVo.isMorePeopleSign()){
Node node = rootToken.getNode();
List<String> sendUserList = new ArrayList<String>() ;
List<ForkedTransition> forkTransitions = new ArrayList<ForkedTransition>();
Map<String,String> roleSendAndMorePeopleMap = forkVariableVo.getRoleSendAndMorePeople();
for(int j=0;j<node.getLeavingTransitions().size();j++){
Transition trans = (Transition)node.getLeavingTransitions().get(j);
//考虑到有多个角色发送和多人签收的分支情况，MAP过滤,获取动态分支用户
String activityId = trans.getName() ;
if(roleSendAndMorePeopleMap.get(activityId)!=null){
if(forkVariableVo.mOfficeTargetUser.get(activityId)!=null){
sendUserList = (List<String>)forkVariableVo.mOfficeTargetUser.get(activityId);
}else{
sendUserList = (List<String>)forkVariableVo.noMOfficeTargetUser.get(activityId);
}
}
if(sendUserList ==null || sendUserList.size() ==0){
continue;
}
//创建分支Token及Transition
for(int i=1; i<sendUserList.size(); i++){
String tokenName = this.getTokenName(rootToken,activityId, i);
Token loopToken = new Token(rootToken,tokenName);
loopToken.setTerminationImplicit(true);
executionContext.getJbpmContext().getSession().save(loopToken);
ExecutionContext newExecutionContext = new ExecutionContext(
loopToken);
//newExecutionContext.getContextInstance().createVariable(String.valueOf(i),
//(String)sendUserList.get(i), loopToken);
// 记录下每一transition
ForkedTransition forkTransition = new ForkedTransition();
forkTransition.executionContext = newExecutionContext;
forkTransition.transition = trans;
forkTransitions.add(forkTransition);
}
sendUserList = null ;
}
for (ForkedTransition forkTransition : forkTransitions) {
node.leave(forkTransition.executionContext, forkTransition.transition);
}
}
} /**
* 获取Token名称
* @param parent
* @param transitionName
* @param loopIndex
* @return
*/
protected String getTokenName(Token parent, String transitionName,int loopIndex) {
String tokenName = null;
if (transitionName != null) {
if (!parent.hasChild(transitionName)) {
tokenName = transitionName;
} else {
int i = 2;
tokenName = transitionName + Integer.toString(i);
while (parent.hasChild(tokenName)) {
i++;
tokenName = transitionName + Integer.toString(i);
}
}
} else {
// 没有转向
int size = (parent.getChildren() != null ? parent.getChildren()
.size() + 1 : 1);
tokenName = Integer.toString(size);
}
return tokenName + "." + loopIndex;
}
private class ForkedTransition {
private ExecutionContext executionContext;
private Transition transition;
}
}在FORK节点的node-enter中配置该ACTION类，凭借原来那条分支，根据发送的用户的LIST，动态去构建TOKEN，每个TOKEN指向其原分支上的transition，中间那部分角色发送是我自己的需求而写的，重要的是创建分支这一部分。
页:
[1]