activiti入坑也有几个月的时间,这里做一下activiti的总结吧。
首先有一点要说的是,我这边使用的是activiti6.0版本,和5版本相比,代码有一定的差异,在6.0版本中,activiti做了大量的代码重构。不过功能上没有太大的差异,也就是说,如果你的版本是5.x,思想上可以值得借鉴。
表达式支持规则引擎:
在实际开发中,我们肯定会遇到非常复杂的场景,而activiti表达式过于简单,不能满足我们复杂的业务场景。这里,我们可能会想当然的想到,可以深入activiti源码去寻找扩展点去扩展activiti表达式,很好,我也是这样做的。比如,我要支持排他网关的表达式扩展,那么我就继承排他网关解析器,最后发现,这样做不靠谱!!!为什么?因为这样做,所有支持activiti表达式解析的地方都要去继承他的解析器,重写。比如,包容网关,又同样支持表达式解析,这里又要重写包重网关解析器,如果后面还有支持写表达式的地方呢,又要去继承去重写activiti里的解析方法 ,工作量巨大!且不易扩展。最重要的是,如果升级activiti版本,activiti底层代码重构之后,代码又要重写。
最终实现思路:
在表达式中,activiti支持使用${}或#{}调用java代码。如果和spring整合以后,还可以以bean的名字直接调用bean的方法,我们就可以利用这一特性进行扩展。比如,用户配置了表达式:
if(a>0) { return true;} else{ return false; }
我们在后台拼装xml的时候,如果用户选择的表达式引擎不是activiti自带的,那么我们偷梁换柱一下,调用我们写好的java代码。我们先准备好一个java bean,并加入spring容器中。
然后如果不是activiti自带引擎,我们就把他的表达式改成:
#{ruleExecutor.execute('用户配置的表达式','用户选择的规则类型',execution)}
这样就可以完美的解决自定义规则的情景了,其中的execution变量是activiti内置变量。
全局监听器:
在activiti流程中,我们可以配置很多我们的监听器,如UserTask节点,我们如果想要配置一个监听器,我们就配置一个,但其实,在activiti中,我们是可以配置全局的监听器的,完全不需要每次都去配置。
我们只需要实现ActivitiEventListener接口,就可以监听activiti所有的事件,我们可以写个工厂事件处理器,去处理activiti不同的事件。
最后,我们还加入以下配置代码:
activiti整合官方编译器:
activiti官方页面如果你不嫌弃,可以使用使用github热心程序员整合的官方编译器插件,这里有篇介绍:https://www.jianshu.com/p/cf766a713a86
流程节点回退:
工作流回退是一个“中国式”的需要,activiti官方没有给出相关的api,这时候我们就需要自己开动大脑了。
实现思路:
1、获取当前任务所在的节点
2、获取所在节点的流出方向
3、记录所在节点的流出方向,并将所在节点的流出方向清空
4、获取目标节点
5、创建新的方向
6、将新的方向set到所在节点的流出方向
7、完成当前任务
8、还原所在节点的流出方向
这里给出一段参考代码:
public void revoke(String currentTaskId, String revokeTaskId,String remark) {
final Task currentTask =taskService.createTaskQuery().taskId(currentTaskId).singleResult();
if(currentTask==null){
throw new ActivitiEngineException("当前任务不存在或已被办理完成,回退失败!");
}
final String processDefinitionId = currentTask.getProcessDefinitionId();
final BpmnModel bpmnModel =repositoryService.getBpmnModel(processDefinitionId);
final List historicActivityInstances =historyService
.createHistoricActivityInstanceQuery()
.executionId(currentTask.getExecutionId())
.finished()
.list();
HistoricActivityInstance revokeActInstance =null;
for (HistoricActivityInstance historicActivityInstance : historicActivityInstances) {
if(revokeTaskId.equals(historicActivityInstance.getTaskId())){
revokeActInstance = historicActivityInstance;
break;
}
}
if(revokeActInstance==null){
throw new ActivitiEngineException("要指定回滚的taskId="+ revokeTaskId +"节点不存在!");
}
final String revokeElementId = revokeActInstance.getActivityId();
final List taskFlows =taskManager.getTaskFlowList(currentTaskId,currentTask.getProcessInstanceId());
if(!taskFlows.contains(revokeElementId)){
throw new ActivitiEngineException("要指定回滚的taskId="+ revokeTaskId +"节点不存在,或不允许回滚!");
}
final FlowNode revokeFlowNode = (FlowNode)bpmnModel.getMainProcess()
.getFlowElement(revokeActInstance.getActivityId());
final Execution execution =runtimeService.createExecutionQuery()
.executionId(currentTask.getExecutionId())
.singleResult();
final FlowNode currentFlowNode = (FlowNode)bpmnModel.getMainProcess().getFlowElement(execution.getActivityId());
//记录原活动方向
List oriSequenceFlows =new ArrayList<>();
oriSequenceFlows.addAll(currentFlowNode.getOutgoingFlows());
//清理活动方向
currentFlowNode.getOutgoingFlows().clear();
//建立新方向
List newSequenceFlowList =new ArrayList<>();
SequenceFlow newSequenceFlow =new SequenceFlow();
newSequenceFlow.setId("newSequenceFlowId");
newSequenceFlow.setSourceFlowElement(currentFlowNode);
newSequenceFlow.setTargetFlowElement(revokeFlowNode);
newSequenceFlowList.add(newSequenceFlow);
currentFlowNode.setOutgoingFlows(newSequenceFlowList);
taskService.addComment(currentTaskId, currentTask.getProcessInstanceId(), ActivitiParamConstant.CommentType.MESSAGE, remark);
taskService.addComment(currentTaskId, currentTask.getProcessInstanceId(), ActivitiParamConstant.CommentType.ELEMENT_ID,revokeElementId);
Map currentVariables = Maps.newHashMap();
//完成任务
taskService.complete(currentTaskId,currentVariables);
//恢复原方向
currentFlowNode.setOutgoingFlows(oriSequenceFlows);
//清除已走过的任务节点信息
historyService.deleteHistoricTaskInstance(revokeTaskId);
}
多实例会签,指派多个审批人:
UserTask 我们可能会指定多个审批人去审批,要多个人审批完了后流程才会继续走下去。
需求,我们要支持在页面中,assignee = "1,2",我们使用逗号分隔审批人。
这时候,我们可以在拼接xml时候将userTask进行一些修改。修改后的结果如下:
<userTask activiti:candidateUsers="" activiti:candidateGroups="" activiti:assignee="1082927314755121154,1" activiti:formKey="" id="usertask_activity_JH2Z61550555114303" name="用户任务">
<extensionElements><activiti:taskListener event="create" class="com.haiyi.bank.listener.UserTaskListener"/></extensionElements>
<multiInstanceLoopCharacteristics activiti:collection="${publicityList_usertask_activity_JH2Z61550555114303}" activiti:elementVariable="publicity" isSequential="false"/>
</userTask>
其中加粗的部分是后台自动加上去的,并不需要在用户在页面上配置。 collection这个属性必须是一个集合,在任务创建前需要指定配置的命名的变量,这里的命名规则是以 publicityList_加上当前的元素id,elementVariable是每次循环这个集合中的当前变量,会把这个变量放到上下文中。
我们也同样动态添加一个监听器,我们通过监听器指定当前的指派人。
前面说过,我们elementVariable配置的变量名为publicity,所以,我们可以在这里面根据这个变量名publicity获取当前的指派人,并动态修改。
当然,我们还必须在任务启动前,指定collection集合里面定义的这个变量,否则activiti怎么知道有哪些人呢?
实现思路:我们在启动的时候,
1,启动这个流程图时,遍历所有userTask,获取当前的assignee。
2,将assignee分隔逗号,变成一个集合。
3,将这个集合的键以 publicityList_加上当前的元素id,值以前面获取到的集合放入activiti上下文。
将这个参数作为activiti启动参数放入即可。