Activiti 工作流会签开发设计思路

wangcaipang

2012-07-26

在流程业务管理中，任务是通常都是由一个人去处理的，而多个人同时处理一个任务，这种任务我们称之为会签任务。这种业务需求也很常见，如一个请款单，领导审批环节中，就需要多个部门领导签字。在流程业务中，我们可以把每个领导签字的环节都定义为任务，但若这样，这个流程业务有一点是固定的，就是签批人是固定的。而任务是由一个领导签完再到另一领导，当然也可以由多个领导同时签字。

传统的用流程业务来解决可以采用以下的做法：

串行会签

并行会签

前者在流程业务中，叫串行会签，也即是由一个领导签完再至另一领导签。后者我们称之为并行会签，表示几个领导同时进行签发，而不清楚最终是谁先签。

以上的解决方式有两大业务需求下是不能满足的，若会签的领导不是固定的，即可以由上一任务审批人提交前随意进行选择，另一种是对于会签业务中，要求若其中一部分领导审批通过，即直接往下走，不需要全部领导进行审批。另外，对于这种情况下，统计最终领导会签的结果也是比较困难的，即对审批单的意见是同意还是否决没有办法清楚。以上两种业务需求也是很常见的日常需求，但我们若采用了固定的流程节点，则不能实现。在这里，可以采用Activiti的节点多实例来处理，以上流程则可以简化为下：

何谓多任务实例节点？在Activiti5上的解析则为动态的多任务节点，可以根据传入的动态人员数进行动态生成任务。生成的任务数则不固定，可以进行并行会签，也可以进行串行会签。会签任务最终是否需要往下执行，由会签设置的规则来进行约束。如我们可以常规去设置“一票通过”、“一票否决”、“少数服务多数”等会签规则。因此，我们需要在会签节点上绑定我们的设计规则。会签规则设置界面如下：

通过会签设计规则，可以清楚最终会签人员的投票结果。其数据结构如下所示:

会签任务的定义本身已经由Activiti来实现了，但需要动态传入动态的人员数

<userTask activiti:assignee="${assignee}" id="SignTask1" name="领导会签">   
<extensionElements>   

<activiti:taskListener class="com.hotent.platform.service.bpm.listener.TaskSignCreateListener" event="create"/>   


<activiti:taskListener class="com.hotent.platform.service.bpm.listener.TaskAssignListener" event="assignment"/>   


<activiti:taskListener class="com.hotent.platform.service.bpm.listener.TaskCompleteListener" event="complete"/>   

</extensionElements>   

<multiInstanceLoopCharacteristics activiti:elementVariable="assignee" isSequential="false" activiti:collection="${taskUserAssignService.getSignUser(execution)}">   

<completionCondition>${signComplete.isComplete(execution)}</completionCondition>   
</multiInstanceLoopCharacteristics>   
</userTask>

<userTask activiti:assignee="${assignee}" id="SignTask1" name="领导会签">
<extensionElements>
<activiti:taskListener class="com.hotent.platform.service.bpm.listener.TaskSignCreateListener" event="create"/>
<activiti:taskListener class="com.hotent.platform.service.bpm.listener.TaskAssignListener" event="assignment"/>
<activiti:taskListener class="com.hotent.platform.service.bpm.listener.TaskCompleteListener" event="complete"/>
</extensionElements>
<multiInstanceLoopCharacteristics activiti:elementVariable="assignee" isSequential="false" activiti:collection="${taskUserAssignService.getSignUser(execution)}">
<completionCondition>${signComplete.isComplete(execution)}</completionCondition>
</multiInstanceLoopCharacteristics>
</userTask>

其中，isSequential为true则为串行会签，若为false则为并行会签，而activiti:collection可以来自我们Spring容器中的接口及方法，表示获取会签用户集合，taskUserAssignService.getSignUser(execution)。其获取会签的用户值来自两个方面，一个在界面中指定的会签人员，另一个在后台会签节点上配置的人员。

后台会签节点人员设置

任务审批面上选择下一任务会签人员

<completeCondition>为完成会签的条件signComplete.isComplete(execution)，可以在这里根据我们的会签规则及目前的会签情况，决定会签是否完成。其实现如下所示：

最终实现逻辑：

@Override  

public boolean isComplete(ActivityExecution execution) {   

       

    logger.debug("entert the SignComplete isComplete method...");   

       
    String nodeId=execution.getActivity().getId();   
    String actInstId=execution.getProcessInstanceId();   
       
    ProcessDefinition processDefinition=bpmService.getProcessDefinitionByProcessInanceId(actInstId);   

    //取得会签设置的规则   

    BpmNodeSign bpmNodeSign=bpmNodeSignService.getByDefIdAndNodeId(processDefinition.getId(), nodeId);   

    //完成会签的次数   


    Integer completeCounter=(Integer)execution.getVariable("nrOfCompletedInstances");   


    //总循环次数   


    Integer instanceOfNumbers=(Integer)execution.getVariable("nrOfInstances");   


    //计算投票结果。   

    VoteResult voteResult=calcResult(bpmNodeSign, actInstId, nodeId, completeCounter,instanceOfNumbers);   
       
    String signResult=voteResult.getSignResult();   

    boolean isCompleted=voteResult.getIsComplete();   

       

    /**  
    * 会签完成做的动作。  
    * 1.删除会签的流程变量。  
    * 2.将会签数据更新为完成。  
    * 3.设置会签结果变量。  
    * 4.更新会签节点结果。  
    * 5.清除会签用户。  
    */  

    if(isCompleted){   


        //删除会签的变量。   


        //删除 assignee，loopCounter变量。   

        bpmService.delLoopAssigneeVars(execution.getId());   

        logger.debug("set the sign result + " + signResult);   


        //将会签数据更新为完成。   

        taskSignDataService.batchUpdateCompleted(actInstId, nodeId);   

        //设置会签的结果   


        execution.setVariable("signResult_" + nodeId , signResult);   


        //更新会签节点的状态。   

        Short status=TaskOpinion.STATUS_PASSED;   

        if(signResult.equals(SIGN_RESULT_REFUSE)){   

            status=TaskOpinion.STATUS_NOT_PASSED;   
        }   

        //更新会签节点的状态。   

        bpmProStatusDao.updStatus(actInstId, nodeId,status);   

        //清除会签用户。   

        taskUserAssignService.clearSignUser();   
    }   
       

    return isCompleted;   

}   
  
**   
 * 根据会签规则计算投票结果。   
 * <pre>   

 * 1.如果会签规则为空，那么需要所有的人同意通过会签，否则不通过。   


 * 2.否则按照规则计算投票结果。   

 * </pre>   

 * @param bpmNodeSign       会签规则   


 * @param actInstId         流程实例ID   


 * @param nodeId            节点id名称   


 * @param completeCounter       循环次数   


 * @param instanceOfNumbers     总的会签次数。   


 * @return  

 */   

private VoteResult calcResult(BpmNodeSign bpmNodeSign,String actInstId,String nodeId,Integer completeCounter,Integer instanceOfNumbers){   


    VoteResult voteResult=new VoteResult();   


    //没有会签实例   


    if(instanceOfNumbers==0){   


        return voteResult;   

    }   

    //投同意票数   

    Integer agreeVotesCounts=taskSignDataService.getAgreeVoteCount(actInstId, nodeId);   

    //没有设置会签规则   


    //（那么得全部会签通过才通过，否则不通过)   


    if(bpmNodeSign==null){   


        //还没有完成可以退出。   


        if(completeCounter<instanceOfNumbers){   


            return voteResult;   

        }   

        else{   


            //完成了 (全部同意才通过)   


            if(agreeVotesCounts.equals(instanceOfNumbers)){   


                return new VoteResult(SIGN_RESULT_PASS,true);   

            }   

            else{   


                return new VoteResult(SIGN_RESULT_REFUSE,true);   

            }   
        }   
    }   
       

    //投反对票数   

    Integer refuseVotesCounts=taskSignDataService.getRefuseVoteCount(actInstId, nodeId);   
       

    //检查投票是否完成   


    if(BpmNodeSign.VOTE_TYPE_PERCENT.equals(bpmNodeSign.getVoteType())){   


        float percents=0;   


        //按同意票数进行决定   


        if(BpmNodeSign.DECIDE_TYPE_PASS.equals(bpmNodeSign.getDecideType())){   

            percents=agreeVotesCounts/instanceOfNumbers;   

            //投票同意票符合条件   


            if(percents>=bpmNodeSign.getVoteAmount()){   


                voteResult=new VoteResult(SIGN_RESULT_PASS, true);   

            }   

            //投票已经全部完成   


            else if(completeCounter.equals(instanceOfNumbers)){   


                voteResult=new VoteResult(SIGN_RESULT_REFUSE, true);   

            }   
        }   

        //按反对票数进行决定   


        else{   

            percents=refuseVotesCounts/instanceOfNumbers;   

            //投票   


            if(percents>=bpmNodeSign.getVoteAmount()){   


                voteResult=new VoteResult(SIGN_RESULT_REFUSE, true);   

            }   

            //投票已经全部完成   


            else if(completeCounter.equals(instanceOfNumbers)){   


                voteResult=new VoteResult(SIGN_RESULT_PASS, true);   

            }   
        }   
    }   

    //按绝对票数投票   


    else{   


        //按同意票数进行决定   


        if(BpmNodeSign.DECIDE_TYPE_PASS.equals(bpmNodeSign.getDecideType())){   


            //投票同意票符合条件   


            if(agreeVotesCounts>=bpmNodeSign.getVoteAmount()){   


                voteResult=new VoteResult(SIGN_RESULT_PASS, true);   

            }   

            //投票已经全部完成   


            else if(completeCounter.equals(instanceOfNumbers)){   


                voteResult=new VoteResult(SIGN_RESULT_REFUSE, true);   

            }   
        }   

        //按反对票数进行决定   


        else{   


            //投票   


            if(refuseVotesCounts>=bpmNodeSign.getVoteAmount()){   


                voteResult=new VoteResult(SIGN_RESULT_REFUSE, true);   

            }   

            //投票已经全部完成   


            else if(completeCounter.equals(instanceOfNumbers)){   


                voteResult=new VoteResult(SIGN_RESULT_PASS, true);   

            }   
        }   
    }   

    return voteResult;   

}

@Override
	public boolean isComplete(ActivityExecution execution) {
		
		logger.debug("entert the SignComplete isComplete method...");
		
		String nodeId=execution.getActivity().getId();
		String actInstId=execution.getProcessInstanceId();
		
		ProcessDefinition processDefinition=bpmService.getProcessDefinitionByProcessInanceId(actInstId);
		//取得会签设置的规则
		BpmNodeSign bpmNodeSign=bpmNodeSignService.getByDefIdAndNodeId(processDefinition.getId(), nodeId);
		//完成会签的次数
		Integer completeCounter=(Integer)execution.getVariable("nrOfCompletedInstances");
		//总循环次数
		Integer instanceOfNumbers=(Integer)execution.getVariable("nrOfInstances");
		//计算投票结果。
		VoteResult voteResult=calcResult(bpmNodeSign, actInstId, nodeId, completeCounter,instanceOfNumbers);
		
		String signResult=voteResult.getSignResult();
		boolean isCompleted=voteResult.getIsComplete();
		
		/**
		* 会签完成做的动作。
		* 1.删除会签的流程变量。
		* 2.将会签数据更新为完成。
		* 3.设置会签结果变量。
		* 4.更新会签节点结果。
		* 5.清除会签用户。
		*/
		if(isCompleted){
			//删除会签的变量。
			//删除 assignee，loopCounter变量。
			bpmService.delLoopAssigneeVars(execution.getId());
			logger.debug("set the sign result + " + signResult);
			//将会签数据更新为完成。
			taskSignDataService.batchUpdateCompleted(actInstId, nodeId);
			//设置会签的结果
			execution.setVariable("signResult_" + nodeId , signResult);
			//更新会签节点的状态。
			Short status=TaskOpinion.STATUS_PASSED;
			if(signResult.equals(SIGN_RESULT_REFUSE)){
				status=TaskOpinion.STATUS_NOT_PASSED;
			}
			//更新会签节点的状态。
			bpmProStatusDao.updStatus(actInstId, nodeId,status);
			//清除会签用户。
			taskUserAssignService.clearSignUser();
		}
		
		return isCompleted;
	}

/**
	 * 根据会签规则计算投票结果。
	 * <pre>
	 * 1.如果会签规则为空，那么需要所有的人同意通过会签，否则不通过。
	 * 2.否则按照规则计算投票结果。
	 * </pre>
	 * @param bpmNodeSign		会签规则
	 * @param actInstId			流程实例ID
	 * @param nodeId			节点id名称
	 * @param completeCounter		循环次数
	 * @param instanceOfNumbers		总的会签次数。
	 * @return
	 */
	private VoteResult calcResult(BpmNodeSign bpmNodeSign,String actInstId,String nodeId,Integer completeCounter,Integer instanceOfNumbers){
		VoteResult voteResult=new VoteResult();
		//没有会签实例
		if(instanceOfNumbers==0){
			return voteResult;
		}
		//投同意票数
		Integer agreeVotesCounts=taskSignDataService.getAgreeVoteCount(actInstId, nodeId);
		//没有设置会签规则
		//（那么得全部会签通过才通过，否则不通过)
		if(bpmNodeSign==null){
			//还没有完成可以退出。
			if(completeCounter<instanceOfNumbers){
				return voteResult;
			}
			else{
				//完成了 (全部同意才通过)
				if(agreeVotesCounts.equals(instanceOfNumbers)){
					return new VoteResult(SIGN_RESULT_PASS,true);
				}
				else{
					return new VoteResult(SIGN_RESULT_REFUSE,true);
				}
			}
		}
		
		//投反对票数
		Integer refuseVotesCounts=taskSignDataService.getRefuseVoteCount(actInstId, nodeId);
		
		//检查投票是否完成
		if(BpmNodeSign.VOTE_TYPE_PERCENT.equals(bpmNodeSign.getVoteType())){
			float percents=0;
			//按同意票数进行决定
			if(BpmNodeSign.DECIDE_TYPE_PASS.equals(bpmNodeSign.getDecideType())){
				percents=agreeVotesCounts/instanceOfNumbers;
				//投票同意票符合条件
				if(percents>=bpmNodeSign.getVoteAmount()){
					voteResult=new VoteResult(SIGN_RESULT_PASS, true);
				}
				//投票已经全部完成
				else if(completeCounter.equals(instanceOfNumbers)){
					voteResult=new VoteResult(SIGN_RESULT_REFUSE, true);
				}
			}
			//按反对票数进行决定
			else{
				percents=refuseVotesCounts/instanceOfNumbers;
				//投票
				if(percents>=bpmNodeSign.getVoteAmount()){
					voteResult=new VoteResult(SIGN_RESULT_REFUSE, true);
				}
				//投票已经全部完成
				else if(completeCounter.equals(instanceOfNumbers)){
					voteResult=new VoteResult(SIGN_RESULT_PASS, true);
				}
			}
		}
		//按绝对票数投票
		else{
			//按同意票数进行决定
			if(BpmNodeSign.DECIDE_TYPE_PASS.equals(bpmNodeSign.getDecideType())){
				//投票同意票符合条件
				if(agreeVotesCounts>=bpmNodeSign.getVoteAmount()){
					voteResult=new VoteResult(SIGN_RESULT_PASS, true);
				}
				//投票已经全部完成
				else if(completeCounter.equals(instanceOfNumbers)){
					voteResult=new VoteResult(SIGN_RESULT_REFUSE, true);
				}
			}
			//按反对票数进行决定
			else{
				//投票
				if(refuseVotesCounts>=bpmNodeSign.getVoteAmount()){
					voteResult=new VoteResult(SIGN_RESULT_REFUSE, true);
				}
				//投票已经全部完成
				else if(completeCounter.equals(instanceOfNumbers)){
					voteResult=new VoteResult(SIGN_RESULT_PASS, true);
				}
			}
		}
		return voteResult;
	}

最终实现效果，可以在线访问

http://www.jee-soft.cn:10080/bpm3/login.jsp

csx/1

可以通过访问流程管理体验效果

最终展示视频可以看以下链接：

http://www.jee-soft.cn/htsite/html/cpjfw/zxjc/bpmx3/index.html

activiti 工作流设计思路

安科网

Activiti 工作流会签开发设计思路

wangcaipang

wangcaipang

相关推荐

java Activiti工作流引擎 websocket即时聊天发图片文字好友群组 SSM源码

springcloud vue.js 微服务分布式 activiti工作流前后分离集成代码生成器 shiro权限

springboot windows10风格 activiti 整合项目框架源码 shiro 安全框架 druid

springboot2+activiti 7 整合（四）用流程设计器设计一个流程

Activiti 工作流表单设计及开发

Activiti工作流框架学习（一）之通用数据表详细介绍

Activiti 工作流引擎流程审批后台框架源码 springmvc SSM

Activiti 工作流项目源码代码生成器 websocket即时通讯 springmvc SSM 框架

springboot windows10风格 activiti 整合项目框架源码 shiro 安全框架 druid

springboot windows10风格 activiti 整合项目框架源码 shiro 安全框架 druid

springboot windows10风格 activiti 整合项目框架源码 shiro 安全框架 druid

springcloud vue 微服务分布式 activiti工作流前后分离集成代码生成器 shiro权限

Activiti 工作流引擎 springmvc SSM 流程审批后台框架源码 shiro权

springboot windows10风格 activiti 整合项目框架源码 shiro 安全框架

springcloud vue 微服务分布式 activiti工作流前后分离集成代码生成器 shiro权限

Activiti入门之三--ORM框架MyBatis的基础及使用

Activiti 工作流表单设计及开发

工作流Activiti的学习总结（七）Activiti在线流程设计器

工作流Activiti的学习总结（四）Spring和Activiti的整合配置讲解

Activiti 5 在线流程设计器开发

wangcaipang