activiti入坑总结

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中,我们是可以配置全局的监听器的,完全不需要每次都去配置。


activiti全局监听器

我们只需要实现ActivitiEventListener接口,就可以监听activiti所有的事件,我们可以写个工厂事件处理器,去处理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集合的初始变量

将这个参数作为activiti启动参数放入即可。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 212,383评论 6 493
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,522评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 157,852评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,621评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,741评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,929评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,076评论 3 410
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,803评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,265评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,582评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,716评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,395评论 4 333
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,039评论 3 316
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,798评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,027评论 1 266
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,488评论 2 361
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,612评论 2 350

推荐阅读更多精彩内容