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>
其中,isSequential为true则为串行会签,若为false则为并行会签,而activiti:collection可以来自我们Spring容器中的接口及方法,表示获取会签用户集合,taskUserAssignService.getSignUser(execution)。其获取会签的用户值来自两个方面,一个在界面中指定的会签人员,另一个在后台会签节点上配置的人员。
后台会签节点人员设置
任务审批面上选择下一任务会签人员
<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.}
最终实现效果,可以在线访问
http://www.jee-soft.cn:10080/bpm3/login.jsp
csx/1
可以通过访问流程管理体验效果
最终展示视频可以看以下链接:
http://www.jee-soft.cn/htsite/html/cpjfw/zxjc/bpmx3/index.html
分享到:
相关推荐
java activity工作流 java activity工作流 java activity工作流
分享一个web端绘制流程图,感觉很实用。下载解压后直接导入eclipse,运行方式 HTTP Preview,访问地址http://localhost:8080/estd/index.html 希望能帮助到大家。
activity工作流,在线流程编辑器activity工作流,在线流程编辑器activity工作流,在线流程编辑器
activiti工作流视频加源代码,超详细,从0基础开始入门,包括数据库介绍、核心api等介绍,满足日常开发所需
基于activity工作流产品 的基本功能。Activiti项目是一项新的基于Apache许可的开源BPM平台,从基础开始构建,旨在提供支持新的BPMN 2.0标准,包括支持对象管理组(OMG),面对新技术的机遇,诸如互操作性和云架构,...
这是一个Activity开发的请假流程实例,可以作为用Activity开发工作流的参考;项目采用spring+hibernate+strus2+activity开发,可以运行;数据库采用mysql;
activity介绍
activity工作流demo和数据库结构数据
RuoYi-process多模块activity工作流项目代码;
activity 5.4 工作流学习资料,数据库表结构说明文档,视频讲解,开发jar包。整合SSH项目开发
工作流activity5.22.0,包含war下面的网页;加压后即可使用
审批分为:员工用户、部门经理、boss三种角色
activity工作流的demo例子,采用hibernate+mysql,activity工作引擎启迪时,不会重复的创建表,并且不会报错,解决了好久,终于搞定了,分享给大家参考
原创博客:https://blog.csdn.net/a704020443/article/details/107939512 里面有介绍
工作流 Activity 视频教程
activiti 工作流23张表详细介绍activiti 工作流23张表详细介绍activiti 工作流23张表详细介绍activiti 工作流23张表详细介绍activiti 工作流23张表详细介绍activiti 工作流23张表详细介绍activiti 工作流23张表详细...
2.2.1 MVC设计思想 4 2.2.2 MVC的具体实现 5 2.2.3 MVC的不足 6 2.3 JSP技术介绍 6 2.3.1 JSP的运行原理 7 2.3.2 JSP的生命周期 8 2.3.3 Servlet和JavaBean技术介绍 8 2.3.4 Java 虚拟机 9 2.3.5 JSP访问SQL Server ...