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

标签: activiti 工作流 开发 | 发表时间:2012-07-26 14:32 | 作者:
出处:http://www.iteye.com

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

 

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

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


串行会签
串行会签

并行会签


 

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


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


activiti会签流程设计

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

会签规则设计

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

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

Java代码 复制代码  收藏代码
  1. <userTask activiti:assignee="${assignee}" id="SignTask1" name="领导会签">   
  2. <extensionElements>   
  3. <activiti:taskListener  class="com.hotent.platform.service.bpm.listener.TaskSignCreateListener" event="create"/>   
  4. <activiti:taskListener  class="com.hotent.platform.service.bpm.listener.TaskAssignListener" event="assignment"/>   
  5. <activiti:taskListener  class="com.hotent.platform.service.bpm.listener.TaskCompleteListener" event="complete"/>   
  6. </extensionElements>   
  7. <multiInstanceLoopCharacteristics activiti:elementVariable="assignee" isSequential="false" activiti:collection="${taskUserAssignService.getSignUser(execution)}">   
  8. <completionCondition>${signComplete.isComplete(execution)}</completionCondition>   
  9. </multiInstanceLoopCharacteristics>   
  10. </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)。其获取会签的用户值来自两个方面,一个在界面中指定的会签人员,另一个在后台会签节点上配置的人员。

会签人员设置
后台会签节点人员设置

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

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

最终实现逻辑:
Java代码 复制代码  收藏代码
  1. @Override  
  2. public  boolean isComplete(ActivityExecution execution) {   
  3.        
  4.     logger.debug("entert the SignComplete isComplete method...");   
  5.        
  6.     String nodeId=execution.getActivity().getId();   
  7.     String actInstId=execution.getProcessInstanceId();   
  8.        
  9.     ProcessDefinition processDefinition=bpmService.getProcessDefinitionByProcessInanceId(actInstId);   
  10.     //取得会签设置的规则   
  11.     BpmNodeSign bpmNodeSign=bpmNodeSignService.getByDefIdAndNodeId(processDefinition.getId(), nodeId);   
  12.     //完成会签的次数   
  13.     Integer completeCounter=(Integer)execution.getVariable("nrOfCompletedInstances");   
  14.     //总循环次数   
  15.     Integer instanceOfNumbers=(Integer)execution.getVariable("nrOfInstances");   
  16.     //计算投票结果。   
  17.     VoteResult voteResult=calcResult(bpmNodeSign, actInstId, nodeId, completeCounter,instanceOfNumbers);   
  18.        
  19.     String signResult=voteResult.getSignResult();   
  20.      boolean isCompleted=voteResult.getIsComplete();   
  21.        
  22.     /**  
  23.     * 会签完成做的动作。  
  24.     * 1.删除会签的流程变量。  
  25.     * 2.将会签数据更新为完成。  
  26.     * 3.设置会签结果变量。  
  27.     * 4.更新会签节点结果。  
  28.     * 5.清除会签用户。  
  29.     */  
  30.      if(isCompleted){   
  31.         //删除会签的变量。   
  32.         //删除 assignee,loopCounter变量。   
  33.         bpmService.delLoopAssigneeVars(execution.getId());   
  34.         logger.debug("set the sign result + " + signResult);   
  35.         //将会签数据更新为完成。   
  36.         taskSignDataService.batchUpdateCompleted(actInstId, nodeId);   
  37.         //设置会签的结果   
  38.         execution.setVariable("signResult_" + nodeId , signResult);   
  39.         //更新会签节点的状态。   
  40.         Short status=TaskOpinion.STATUS_PASSED;   
  41.          if(signResult.equals(SIGN_RESULT_REFUSE)){   
  42.             status=TaskOpinion.STATUS_NOT_PASSED;   
  43.         }   
  44.         //更新会签节点的状态。   
  45.         bpmProStatusDao.updStatus(actInstId, nodeId,status);   
  46.         //清除会签用户。   
  47.         taskUserAssignService.clearSignUser();   
  48.     }   
  49.        
  50.      return isCompleted;   
  51. }   
  52.   
  53. **   
  54.  * 根据会签规则计算投票结果。   
  55.  * <pre>   
  56.  * 1.如果会签规则为空,那么需要所有的人同意通过会签,否则不通过。   
  57.  * 2.否则按照规则计算投票结果。   
  58.  * </pre>   
  59.  * @param bpmNodeSign       会签规则   
  60.  * @param actInstId         流程实例ID   
  61.  * @param nodeId            节点id名称   
  62.  * @param completeCounter       循环次数   
  63.  * @param instanceOfNumbers     总的会签次数。   
  64.  * @return  
  65.  */   
  66. private VoteResult calcResult(BpmNodeSign bpmNodeSign,String actInstId,String nodeId,Integer completeCounter,Integer instanceOfNumbers){   
  67.     VoteResult voteResult= new VoteResult();   
  68.     //没有会签实例   
  69.      if(instanceOfNumbers==0){   
  70.          return voteResult;   
  71.     }   
  72.     //投同意票数   
  73.     Integer agreeVotesCounts=taskSignDataService.getAgreeVoteCount(actInstId, nodeId);   
  74.     //没有设置会签规则   
  75.     //(那么得全部会签通过才通过,否则不通过)   
  76.      if(bpmNodeSign== null){   
  77.         //还没有完成可以退出。   
  78.          if(completeCounter<instanceOfNumbers){   
  79.              return voteResult;   
  80.         }   
  81.          else{   
  82.             //完成了 (全部同意才通过)   
  83.              if(agreeVotesCounts.equals(instanceOfNumbers)){   
  84.                  return  new VoteResult(SIGN_RESULT_PASS, true);   
  85.             }   
  86.              else{   
  87.                  return  new VoteResult(SIGN_RESULT_REFUSE, true);   
  88.             }   
  89.         }   
  90.     }   
  91.        
  92.     //投反对票数   
  93.     Integer refuseVotesCounts=taskSignDataService.getRefuseVoteCount(actInstId, nodeId);   
  94.        
  95.     //检查投票是否完成   
  96.      if(BpmNodeSign.VOTE_TYPE_PERCENT.equals(bpmNodeSign.getVoteType())){   
  97.          float percents=0;   
  98.         //按同意票数进行决定   
  99.          if(BpmNodeSign.DECIDE_TYPE_PASS.equals(bpmNodeSign.getDecideType())){   
  100.             percents=agreeVotesCounts/instanceOfNumbers;   
  101.             //投票同意票符合条件   
  102.              if(percents>=bpmNodeSign.getVoteAmount()){   
  103.                 voteResult= new VoteResult(SIGN_RESULT_PASS,  true);   
  104.             }   
  105.             //投票已经全部完成   
  106.              else  if(completeCounter.equals(instanceOfNumbers)){   
  107.                 voteResult= new VoteResult(SIGN_RESULT_REFUSE,  true);   
  108.             }   
  109.         }   
  110.         //按反对票数进行决定   
  111.          else{   
  112.             percents=refuseVotesCounts/instanceOfNumbers;   
  113.             //投票   
  114.              if(percents>=bpmNodeSign.getVoteAmount()){   
  115.                 voteResult= new VoteResult(SIGN_RESULT_REFUSE,  true);   
  116.             }   
  117.             //投票已经全部完成   
  118.              else  if(completeCounter.equals(instanceOfNumbers)){   
  119.                 voteResult= new VoteResult(SIGN_RESULT_PASS,  true);   
  120.             }   
  121.         }   
  122.     }   
  123.     //按绝对票数投票   
  124.      else{   
  125.         //按同意票数进行决定   
  126.          if(BpmNodeSign.DECIDE_TYPE_PASS.equals(bpmNodeSign.getDecideType())){   
  127.             //投票同意票符合条件   
  128.              if(agreeVotesCounts>=bpmNodeSign.getVoteAmount()){   
  129.                 voteResult= new VoteResult(SIGN_RESULT_PASS,  true);   
  130.             }   
  131.             //投票已经全部完成   
  132.              else  if(completeCounter.equals(instanceOfNumbers)){   
  133.                 voteResult= new VoteResult(SIGN_RESULT_REFUSE,  true);   
  134.             }   
  135.         }   
  136.         //按反对票数进行决定   
  137.          else{   
  138.             //投票   
  139.              if(refuseVotesCounts>=bpmNodeSign.getVoteAmount()){   
  140.                 voteResult= new VoteResult(SIGN_RESULT_REFUSE,  true);   
  141.             }   
  142.             //投票已经全部完成   
  143.              else  if(completeCounter.equals(instanceOfNumbers)){   
  144.                 voteResult= new VoteResult(SIGN_RESULT_PASS,  true);   
  145.             }   
  146.         }   
  147.     }   
  148.      return voteResult;   
  149. }  
	@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;
	}
 


最终实现效果,可以在线访问
csx/1
可以通过访问流程管理体验效果
最终展示视频可以看以下链接:


已有 0 人发表留言,猛击->> 这里<<-参与讨论


ITeye推荐



相关 [activiti 工作流 开发] 推荐:

Activiti工作流demo

- - CSDN博客综合推荐文章
继上篇《 Activiti工作流的环境配置》.        前几篇对Activiti工作流进行了介绍,并讲解了其环境配置. 本篇将会用一个demo来展示Activiti工作流具体的体现,直接上干货.        以HelloWorld程序为例.       首先说一下业务流程,员工张三提交了一个申请,然后由部门经理李四审核,审核通过后再由总经理王五审核,通过则张三申请成功.

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

- - ITeye博客
Activiti 工作流会签开发设计思路. 在流程业务管理中,任务是通常都是由一个人去处理的,而多个人同时处理一个任务,这种任务我们称之为会签任务. 这种业务需求也很常见,如一个请款单,领导审批环节中,就需要多个部门领导签字. 在流程业务中,我们可以把每个领导签字的环节都定义为任务,但若这样,这个流程业务有一点是固定的,就是签批人是固定的.

activiti工作流使用

- - 行业应用 - ITeye博客
activiti 开发流程. JBPM 与 Activiti. jBPM项目于2002年3月由Tom Baeyens发起,2003年12月发布1.0版本. 2004年10月18日,发布了2.0版本,并在同一天加入了JBoss. 2011 年 jBPM的创建者Tom Baeyens离开JBoss了, 他的离开产生了两个结果:.

activiti工作流引擎思想探究

- - 开源软件 - ITeye博客
       研究activiti有一阵了,逐渐了解了开源activiti的相关api,但对期中的processinstanceId,executeId,taskId相关应用还是有些模糊,得益于activiti开源技术推广者临远同志的启发,明白了很多工作流引擎的核心思想源自佩特里网(英语:Petri net),采用token机制来执行流程.

Activiti用户指南之Activiti的API

- - ITeye博客
 一、流程引擎的API和服务(services).      引擎的API是影响Activiti最常见的一种方法. 我们一开始最关注的中心是ProcessEngine,像之前描述的那样,流程引擎可以被多种方式创建. 从这个流程引擎里面,你能获得各个包含workflow/BPM方法的服务. 流程引擎和这些获得的服务是线程安全的.

Activiti学习笔记

- - 企业架构 - ITeye博客
第一个Activiti的HelloWorld. 获取核心ProcessEngine对象 2. 根据需求,获取对应的服务实例 3. 使用服务方法,做事情 * * @author Administrator * */ public class HelloWorld {. // 加载核心API ProcessEngine.

Activiti - 设置会签

- - 企业架构 - ITeye博客
前些天在群里聊工作流和Activiti,群里有人分享了自己的工作流引擎开源项目,大伙纷纷问这问那(比如为什么突然自己搞个process engine、有没有eclipse plugin、能不能绘制流程图等等). 现实生活中的工作流程,我们也经常碰到需要会签的情况,支持会签是很必要的. 正好有两个人问道:支持会签吗.

ACTIVITI 学习笔记 - 监听

- - 企业架构 - ITeye博客
ACTIVITI 学习笔记 - 监听. 所有分发的事件都是org.activiti.engine.delegate.event.ActivitiEvent的子类. 监听器监听的流程引擎已经创建完毕,并准备好接受API调用. 监听器监听的流程引擎已经关闭,不再接受API调用. 创建了一个新实体,初始化也完成了.

Activiti安装配置(转)

- - 企业架构 - ITeye博客
原文地址:http://blog.csdn.net/zhang_xinxiu/article/details/38655311. 有一段时间没有更新文章了,虽然有一直在写文章,可是一直没有更新到博客内,这段时间写的文章大多还是以技术为主. 接下来的系列文章将会来讨论企业工作流的开发,主要是来研究开源工作流Activiti的使用.

Activiti入门篇之二 Spring 与Activiti的入门整合

- - 行业应用 - ITeye博客
Activiti相对Jbpm来说,与Spring整合更加完美,具体可见本文的详细介绍. 1.     Maven的环境任务,请参考第一篇 (Activiti入门篇—Maven的环境准备). 2.     Activiti的Eclipse插件安装.               插件更新地址:http://activiti.org/designer/update/.