位置: IT常识 - 正文

【工作流Activiti7】3、Activiti7 回退与会签(工作流activity)

编辑:rootadmin
【工作流Activiti7】3、Activiti7 回退与会签

推荐整理分享【工作流Activiti7】3、Activiti7 回退与会签(工作流activity),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:工作流active,工作流activity教程,activiti6.0工作流引擎深度解析,工作流active,工作流引擎activiti表结构和代码详解,工作流activity,工作流引擎activiti功能介绍,工作流activity,内容如对您有帮助,希望把文章链接给更多的朋友!

1.  回退(驳回)

回退的思路就是动态更改节点的流向。先遇水搭桥,最后再过河拆桥。

具体操作如下:

取得当前节点的信息取得当前节点的上一个节点的信息保存当前节点的流向新建流向,由当前节点指向上一个节点将当前节点的流向设置为上面新建的流向当前节点完成任务将当前节点的流向还原取得之前上个节点的执行人设置上个节点的assignee为之前的执行人

代码实现起来可能是这样的: 

@Testpublic void huitui() throws Exception { ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); TaskService taskService = processEngine.getTaskService(); Task task = taskService.createTaskQuery().processInstanceId("55001").singleResult(); backProcess(task);}/** * 驳回 / 回退 * 按照这种方法,可以回退至任意节点 * @param task * @throws Exception */public void backProcess(Task task) throws Exception { ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); HistoryService historyService = processEngine.getHistoryService(); RepositoryService repositoryService = processEngine.getRepositoryService(); TaskService taskService = processEngine.getTaskService(); String processInstanceId = task.getProcessInstanceId(); // 获取所有历史任务(按创建时间降序) List<HistoricTaskInstance> hisTaskList = historyService.createHistoricTaskInstanceQuery() .processInstanceId(processInstanceId) .orderByTaskCreateTime() .desc() .list(); List<HistoricActivityInstance> hisActivityList = historyService.createHistoricActivityInstanceQuery() .processInstanceId(processInstanceId).list(); if (CollectionUtils.isEmpty(hisTaskList) || hisTaskList.size() < 2) { return; } // 当前任务 HistoricTaskInstance currentTask = hisTaskList.get(0); // 前一个任务 HistoricTaskInstance lastTask = hisTaskList.get(1); // 当前活动 HistoricActivityInstance currentActivity = hisActivityList.stream().filter(e -> currentTask.getId().equals(e.getTaskId())).collect(Collectors.toList()).get(0); // 前一个活动 HistoricActivityInstance lastActivity = hisActivityList.stream().filter(e -> lastTask.getId().equals(e.getTaskId())).collect(Collectors.toList()).get(0); BpmnModel bpmnModel = repositoryService.getBpmnModel(task.getProcessDefinitionId()); // 获取前一个活动节点 FlowNode lastFlowNode = (FlowNode) bpmnModel.getMainProcess().getFlowElement(lastActivity.getActivityId()); // 获取当前活动节点 FlowNode currentFlowNode = (FlowNode) bpmnModel.getMainProcess().getFlowElement(currentActivity.getActivityId()); // 临时保存当前活动的原始方向 List<SequenceFlow> originalSequenceFlowList = new ArrayList<>(); originalSequenceFlowList.addAll(currentFlowNode.getOutgoingFlows()); // 清理活动方向 currentFlowNode.getOutgoingFlows().clear(); // 建立新方向 SequenceFlow newSequenceFlow = new SequenceFlow(); newSequenceFlow.setId("newSequenceFlowId"); newSequenceFlow.setSourceFlowElement(currentFlowNode); newSequenceFlow.setTargetFlowElement(lastFlowNode); List<SequenceFlow> newSequenceFlowList = new ArrayList<>(); newSequenceFlowList.add(newSequenceFlow); // 当前节点指向新的方向 currentFlowNode.setOutgoingFlows(newSequenceFlowList); // 完成当前任务 taskService.complete(task.getId()); // 重新查询当前任务 Task nextTask = taskService.createTaskQuery().processInstanceId(processInstanceId).singleResult(); if (null != nextTask) { taskService.setAssignee(nextTask.getId(), lastTask.getAssignee()); } // 恢复原始方向 currentFlowNode.setOutgoingFlows(originalSequenceFlowList);}

以请假为例

<process id="holiday" name="holiday" isExecutable="true"> <startEvent id="startevent1" name="Start"></startEvent> <userTask id="usertask1" name="填写请假单" activiti:assignee="${assignee1}"></userTask> <sequenceFlow id="flow1" sourceRef="startevent1" targetRef="usertask1"></sequenceFlow> <userTask id="usertask2" name="部门经理审批" activiti:assignee="${assignee2}"></userTask> <sequenceFlow id="flow2" sourceRef="usertask1" targetRef="usertask2"></sequenceFlow> <userTask id="usertask3" name="人事审批" activiti:candidateUsers="tom,jerry"></userTask> <sequenceFlow id="flow3" sourceRef="usertask2" targetRef="usertask3"></sequenceFlow> <endEvent id="endevent1" name="End"></endEvent> <sequenceFlow id="flow4" sourceRef="usertask3" targetRef="endevent1"></sequenceFlow></process>

假设现在已经到“人事审批”这个节点了,当前活动是usertask3

接下来,我们运行上面的代码,回退到上一个节点“部门经理审批”,于是

流程重新从“部门经理审批”节点开始往下走,当流程走完以后

证明,思路正确,写法没啥问题。但是,上面的代码可以简化一下,如下:

/** * 跳到最开始的任务节点(直接打回) * @param task 当前任务 */public void jumpToStart(Task task) { ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); HistoryService historyService = processEngine.getHistoryService(); RepositoryService repositoryService = processEngine.getRepositoryService(); TaskService taskService = processEngine.getTaskService(); String processInstanceId = task.getProcessInstanceId(); // 获取所有历史任务(按创建时间升序) List<HistoricTaskInstance> hisTaskList = historyService.createHistoricTaskInstanceQuery() .processInstanceId(processInstanceId) .orderByTaskCreateTime() .asc() .list(); if (CollectionUtils.isEmpty(hisTaskList) || hisTaskList.size() < 2) { return; } // 第一个任务 HistoricTaskInstance startTask = hisTaskList.get(0); // 当前任务 HistoricTaskInstance currentTask = hisTaskList.get(hisTaskList.size() - 1); BpmnModel bpmnModel = repositoryService.getBpmnModel(task.getProcessDefinitionId()); // 获取第一个活动节点 FlowNode startFlowNode = (FlowNode) bpmnModel.getMainProcess().getFlowElement(startTask.getTaskDefinitionKey()); // 获取当前活动节点 FlowNode currentFlowNode = (FlowNode) bpmnModel.getMainProcess().getFlowElement(currentTask.getTaskDefinitionKey()); // 临时保存当前活动的原始方向 List<SequenceFlow> originalSequenceFlowList = new ArrayList<>(); originalSequenceFlowList.addAll(currentFlowNode.getOutgoingFlows()); // 清理活动方向 currentFlowNode.getOutgoingFlows().clear(); // 建立新方向 SequenceFlow newSequenceFlow = new SequenceFlow(); newSequenceFlow.setId("newSequenceFlowId"); newSequenceFlow.setSourceFlowElement(currentFlowNode); newSequenceFlow.setTargetFlowElement(startFlowNode); List<SequenceFlow> newSequenceFlowList = new ArrayList<>(); newSequenceFlowList.add(newSequenceFlow); // 当前节点指向新的方向 currentFlowNode.setOutgoingFlows(newSequenceFlowList); // 完成当前任务 taskService.complete(task.getId()); // 重新查询当前任务 Task nextTask = taskService.createTaskQuery().processInstanceId(processInstanceId).singleResult(); if (null != nextTask) { taskService.setAssignee(nextTask.getId(), startTask.getAssignee()); } // 恢复原始方向 currentFlowNode.setOutgoingFlows(originalSequenceFlowList);}

2.  会签

多个人同时处理一个任务,这种任务我们称之为会签任务 。Activiti实现会签是基于多实例任务,将节点设置成多实例,主要通过在UserTask节点的属性上配置。

会签的种类:

按数量通过: 达到一定数量的通过表决后,会签通过。按比例通过: 达到一定比例的通过表决后,会签通过。一票否决: 只要有一个表决时否定的,会签通过。一票通过: 只要有一个表决通过的,会签通过。【工作流Activiti7】3、Activiti7 回退与会签(工作流activity)

每个实例有以下变量:

nrOfInstances: 实例总数

nrOfActiveInstances: 当前激活的(未完成的)实例总数。 如果串行执行,则改值永远是1

nrOfCompletedInstances: 已完成的实例总数

条件${nrOfInstances == nrOfCompletedInstances}表示所有人员审批完成后会签结束。

条件${ nrOfCompletedInstances == 1}表示一个人完成审批,该会签就结束。

其他条件依次类推,同时这里也可以写自己添加的流程变量。

相关文档如下:

下面举个例子:

<process id="countersign" name="countersign" isExecutable="true"> <startEvent id="startevent1" name="Start"></startEvent> <userTask id="usertask1" name="申请" activiti:assignee="zhangsan"></userTask> <sequenceFlow id="flow1" sourceRef="startevent1" targetRef="usertask1"></sequenceFlow> <userTask id="usertask2" name="会签审批" activiti:assignee="${approver}"> <multiInstanceLoopCharacteristics isSequential="false" activiti:collection="${approverList}" activiti:elementVariable="approver"> <completionCondition>${nrOfCompletedInstances == nrOfInstances}</completionCondition> </multiInstanceLoopCharacteristics> </userTask> <sequenceFlow id="flow2" sourceRef="usertask1" targetRef="usertask2"></sequenceFlow> <userTask id="usertask3" name="备案" activiti:assignee="tianqi"></userTask> <sequenceFlow id="flow3" sourceRef="usertask2" targetRef="usertask3"></sequenceFlow> <endEvent id="endevent1" name="End"></endEvent> <sequenceFlow id="flow4" sourceRef="usertask3" targetRef="endevent1"></sequenceFlow></process>

编写代码:

// 部署流程定义RepositoryService repositoryService = processEngine.getRepositoryService();Deployment deployment = repositoryService.createDeployment() .addClasspathResource("diagram/countersign.bpmn") .name("会签示例") .key("countersign") .deploy();// 启动流程实例RuntimeService runtimeService = processEngine.getRuntimeService();Map<String, Object> variables = new HashMap<>();variables.put("approverList", Arrays.asList("lisi","wangwu","zhaoliu"));ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("countersign", variables);// 完成任务TaskService taskService = processEngine.getTaskService();Task task = taskService.createTaskQuery().processInstanceId("107501").taskAssignee("zhaoliu").singleResult();if (null != task) { taskService.complete(task.getId());}

流程启动后,首先是zhangsan审批

当zhangsan完成自己的任务后,进入会签环节,于是我们看到当前有3个激活的任务

当lisi完成任务以后,当前任务剩下2个

当wangwu和zhaoliu都完成任务了以后,会签任务完成,进入下一个环节

刚才的例子中没有考虑到审批不通过的情况,接下来我们完善一下,考虑下面的流程

<process id="countersign" name="countersign" isExecutable="true"> <startEvent id="startevent1" name="Start"></startEvent> <userTask id="usertask1" name="申请" activiti:assignee="zhangsan"></userTask> <sequenceFlow id="flow1" sourceRef="startevent1" targetRef="usertask1"></sequenceFlow> <userTask id="usertask2" name="会签审批" activiti:assignee="${approver}"> <multiInstanceLoopCharacteristics isSequential="false" activiti:collection="${approverList}" activiti:elementVariable="approver"> <completionCondition>${nrOfCompletedInstances / nrOfInstances == 1 || pass == false}</completionCondition> </multiInstanceLoopCharacteristics> </userTask> <sequenceFlow id="flow2" sourceRef="usertask1" targetRef="usertask2"></sequenceFlow> <userTask id="usertask3" name="备案" activiti:assignee="tianqi"></userTask> <exclusiveGateway id="exclusivegateway1" name="Exclusive Gateway"></exclusiveGateway> <sequenceFlow id="flow5" sourceRef="usertask2" targetRef="exclusivegateway1"></sequenceFlow> <sequenceFlow id="flow6" name="通过" sourceRef="exclusivegateway1" targetRef="usertask3"> <conditionExpression xsi:type="tFormalExpression"><![CDATA[${pass == true}]]></conditionExpression> </sequenceFlow> <sequenceFlow id="flow7" name="拒绝" sourceRef="exclusivegateway1" targetRef="usertask1"> <conditionExpression xsi:type="tFormalExpression"><![CDATA[${pass == false}]]></conditionExpression> </sequenceFlow> <endEvent id="endevent1" name="End"></endEvent> <sequenceFlow id="flow8" sourceRef="usertask3" targetRef="endevent1"></sequenceFlow></process>

在会签审批完成任务时就要加上流程变量pass了

RuntimeService runtimeService = processEngine.getRuntimeService();TaskService taskService = processEngine.getTaskService();Task task = taskService.createTaskQuery().processInstanceId("152501").taskAssignee("lisi").singleResult();if (null != task) { Map<String, Object> variables = new HashMap<>(); variables.put("pass", true);// variables.put("pass", false); taskService.complete(task.getId(), variables); runtimeService.getVariable(task.getExecutionId(), "nrOfCompletedInstances");}

zhaoliu审批的时候pass传的false,于是流程又走到zhangsan那里,流程重新又走了一遍才全部完成

回退和会签就先讲到这里 

本文链接地址:https://www.jiuchutong.com/zhishi/277908.html 转载请保留说明!

上一篇:局域网故障怎么排除?(局域网故障可能的原因)

下一篇:win1020H2打开第三方软件模糊的解决方法(win10打开第二个桌面快捷键)

  • 金融行业网络营销的几种方法(金融行业网络营销策略)

    金融行业网络营销的几种方法(金融行业网络营销策略)

  • 团购作为成都去年餐饮企业主要推广方式 占比已达34%(成团购买)

    团购作为成都去年餐饮企业主要推广方式 占比已达34%(成团购买)

  • 2021元旦祝福语图片海报(2021元旦祝福语朋友圈)(2021元旦祝福语简短创意发朋友圈)

    2021元旦祝福语图片海报(2021元旦祝福语朋友圈)(2021元旦祝福语简短创意发朋友圈)

  • 怎样恢复华为自带的浏览器(怎样恢复华为自带的备忘录软件)

    怎样恢复华为自带的浏览器(怎样恢复华为自带的备忘录软件)

  • 发微信朋友圈文字不折叠的方法(发微信朋友圈文字加图片怎么发)

    发微信朋友圈文字不折叠的方法(发微信朋友圈文字加图片怎么发)

  • 哔哩哔哩防沉迷的取消方法是什么(哔哩哔哩防沉迷系统怎么关闭)

    哔哩哔哩防沉迷的取消方法是什么(哔哩哔哩防沉迷系统怎么关闭)

  • 网上购物拼团什么意思(网购拼团什么意思)

    网上购物拼团什么意思(网购拼团什么意思)

  • 华为mate30pro铃声渐强怎么取消(华为mate30pro铃声大小怎么调)

    华为mate30pro铃声渐强怎么取消(华为mate30pro铃声大小怎么调)

  • 实体店通用红包为什么用不了

    实体店通用红包为什么用不了

  • 抖音怎么取消同城推送(抖音怎么取消同城)

    抖音怎么取消同城推送(抖音怎么取消同城)

  • 分布式文件系统和并行文件系统的特点

    分布式文件系统和并行文件系统的特点

  • 省电模式充电快还是慢(手机剩余多少电量充电合适)

    省电模式充电快还是慢(手机剩余多少电量充电合适)

  • 苹果6s plus连不上wifi是怎么回事(苹果6s plus连不上app store)

    苹果6s plus连不上wifi是怎么回事(苹果6s plus连不上app store)

  • 微信擦汗表情什么意思(微信里擦汗的表情)

    微信擦汗表情什么意思(微信里擦汗的表情)

  • 电脑安装更新时间过长怎么办(电脑安装更新时间10个小时)

    电脑安装更新时间过长怎么办(电脑安装更新时间10个小时)

  • che1一cl20是什么型号(che1-ch20)

    che1一cl20是什么型号(che1-ch20)

  • word ppt excel统称什么

    word ppt excel统称什么

  • vue背景音乐怎么设置(vue怎么添加音乐)

    vue背景音乐怎么设置(vue怎么添加音乐)

  • 如何取消拼多多的抽奖(如何取消拼多多快捷支付协议)

    如何取消拼多多的抽奖(如何取消拼多多快捷支付协议)

  • 怎么看快手他关注了谁(怎么看快手他关注我的人)

    怎么看快手他关注了谁(怎么看快手他关注我的人)

  • 苹果手机未接电话小红点怎么消(苹果手机未接电话怎么不显示在锁屏上)

    苹果手机未接电话小红点怎么消(苹果手机未接电话怎么不显示在锁屏上)

  • 快手怎么申请解封(快手怎么申请解封账号)

    快手怎么申请解封(快手怎么申请解封账号)

  • 苹果非原装充电线充不进去电(苹果非原装充电头会损坏手机吗)

    苹果非原装充电线充不进去电(苹果非原装充电头会损坏手机吗)

  • 微信设置铃声在哪里(微信设置铃声在哪个地方)

    微信设置铃声在哪里(微信设置铃声在哪个地方)

  • pvck命令  检测物理卷LVM元数据一致性(怎么检测pvc中含量)

    pvck命令 检测物理卷LVM元数据一致性(怎么检测pvc中含量)

  • 纳税人未缴少缴税款
  • 支付税金怎么算
  • 一般纳税人缴纳税金分录
  • 招标押金如何做账务处理?
  • 企业变更法人的流程网上申请变更
  • 新成立的公司残保金如何申报
  • 发票红冲重新开
  • 残值要不要做分录
  • 增值税可以做平吗
  • 公司收到的拆迁补偿款计入哪个科目
  • 销售费用的进项税额转出会计分录
  • 销售商品收入确认的五个条件
  • 用于研发的设备会计分录
  • 股东利润分配怎么交税
  • 发生应收账款如何入账可避税
  • 未分配利润可以转盈余公积吗
  • 逾期包装物押金消费税会计分录
  • 企业利润怎么拿出来
  • 印花税零申报怎么填样本
  • 增资印花税增加哪个税目
  • 适用简易计税方法的口诀
  • 高新技术企业所得税税率
  • 怎样冲回多提应收账款?
  • 注销税务登记后多久注销工商登记
  • 国债逆回购会跌吗
  • 红字发票怎么填申报表表二
  • 出口退税操作步骤
  • 关闭win10系统更新有什么后果
  • 利息收入结转的正确分录
  • 房产证办理流程图
  • 个体户转企业怎么做账
  • 出口退税款的会计科目
  • thinkphp跨域解决方案
  • 小规模纳税人本年累计金额
  • bert获取中文词向量
  • 不能抵扣的福利发票要勾选吗为什么
  • spring security功能
  • php怎么转go
  • 在网上怎么样查个人征信
  • 什么是固定资产?其特征有哪些
  • 法人想从公司户提钱自己用有事吗
  • 研发费用怎么体现
  • mysql数据库uuid
  • mongodb的安装过程和操作命令
  • 单位出租厂房需交税吗
  • 合并报表中的抵消分录是什么意思?
  • 什么情况填an
  • 先收款后给发票合法吗
  • 不能抵扣的普通发票如何做分录
  • 进口关税,增值税是进口设备重置成本中的从属费用
  • 电商平台返佣金个人税点
  • 房地产老项目简易计税开专票
  • 民间非营利组织会计制度
  • 预收账款账务处理分录
  • 市政配套费减免政策
  • 红字发票开出的单价可以比蓝字发票高吗?
  • mysql innode
  • ftp的安装
  • Linux系统下findmnt命令使用全解
  • win8系统怎么设置密码
  • win7老是自动开机启动是怎么回事啊
  • 为什么电脑显示windows10即将终止服务
  • windowsxp教程
  • win8系统如何卸载软件
  • win7系统登录QQ失败提示QQ软件已被破坏或部分文件已经丢失的解决方法
  • 电脑ahci模式什么意思
  • 如何解决win10系统开机一直转圈圈的问题
  • window10 弹窗广告
  • linux小技巧
  • 麒麟系统怎么执行命令
  • alt用不了
  • ubuntu重新安装网卡驱动
  • js绑定onchange
  • Node.js中的全局对象有
  • js辅助器下载
  • unity每秒执行一次
  • python怎么多进程
  • jquery实例
  • 山东省省级政务服务区有哪些
  • 税收优惠政策有哪些企业
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设