Activiti工作流会签二 启动流程

2024-06-04 03:38
文章标签 流程 启动 工作 activiti 会签

本文主要是介绍Activiti工作流会签二 启动流程，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

上一篇文单中简单说了一下工作流中流程定义，下面面我们在简单聊一聊启动流程。

启动工作流

在我的项目中启动一个工作流调用本地的API有点多，这里就只把核心的代码帖出来。

public String startProcess(ActBusiness actBusiness) {String userId = securityUtil.getCurrUser().getId();// 权限判断ActProcess actProcess = actProcessMapper.selectById(actBusiness.getProcDefId());if(actProcess==null){throw new TbootException("流程定义不存在");}if(actProcess.getAllUser()!=null&&!actProcess.getAllUser()){// 判断有无权限if(!actStarterService.hasRecord(actBusiness.getProcDefId(), userId)){throw new TbootException("抱歉，您无权发起该流程");}}// 启动流程用户identityService.setAuthenticatedUserId(userId);// 启动流程 需传入业务表id变量actBusiness.getParams().put("tableId", actBusiness.getTableId());ProcessInstance pi = runtimeService.startProcessInstanceById(actBusiness.getProcDefId(), actBusiness.getId(), actBusiness.getParams());// 设置流程实例名称runtimeService.setProcessInstanceName(pi.getId(), actBusiness.getTitle());List<Task> tasks = taskService.createTaskQuery().processInstanceId(pi.getId()).list();for(Task task : tasks){if(actBusiness.getFirstGateway()){// 网关类型List<User> users = getNode(task.getTaskDefinitionKey()).getUsers();// 如果下个节点未分配审批人为空 取消结束流程if(users==null||users.size()==0){throw new TbootException("有任务节点未分配任何候选审批人，发起流程失败");}else{// 分配了节点负责人分发给全部for(User user : users){taskService.addCandidateUser(task.getId(), user.getId());// 异步发消息messageUtil.sendActMessage(user.getId(), ActivitiConstant.MESSAGE_TODO_CONTENT, actBusiness.getSendMessage(),actBusiness.getSendSms(), actBusiness.getSendEmail());}}}else {// 分配第一个任务用户for (String assignee : actBusiness.getAssignees()) {taskService.addCandidateUser(task.getId(), assignee);// 异步发消息messageUtil.sendActMessage(assignee, ActivitiConstant.MESSAGE_TODO_CONTENT, actBusiness.getSendMessage(),actBusiness.getSendSms(), actBusiness.getSendEmail());}}// 设置任务优先级taskService.setPriority(task.getId(), actBusiness.getPriority());}return pi.getId();}

下面我们简单介绍一下上面的代码。
第一步： 我先获取了当前用户的id，判断当前用户有没有发起流程的权限，此一步纯属本项目中的业务，可以不做。

第二步：设置当前流程是谁启动的到activiti中。identityService 是activiti自带的bean对象，直接注入就行。

 @Autowiredprivate IdentityService identityService;// 启动流程用户identityService.setAuthenticatedUserId(userId);

第三步： 我们就可以启动流程了。第一个参数是流程定义id: leave:1:7 第二个参数是随机的id,这里因为业务需要所以才传的actBusiness表中的id和工作流本身无关。第三个参数是传入到这个流程实例中的参数，我们可以在别的地方获取里面的参数。这里是不是有点像Netty中给channel管理设置参数呢？

  // 启动流程 需传入业务表id变量actBusiness.getParams().put("tableId", actBusiness.getTableId());ProcessInstance pi = runtimeService.startProcessInstanceById(actBusiness.getProcDefId(), 						actBusiness.getId(), actBusiness.getParams());

第四步：设置流程实例名称

runtimeService.setProcessInstanceName(pi.getId(), actBusiness.getTitle());

第四步： 下面就是给人分配任务了， 代码中的逻辑是给任务分配人。 这也是这个工作流框架的设计思想吧。 如果以人为核心开发就没有办法和业务分离了， 因此这个框架就是把任务分离，然后在把人和业务填充到工作流框架中。

在这里我们就获取所有的任务，然后判断第一个节点是不是网关， 然后获取网关的用户，给分配任务。
如果不是网关就直接分配任务， 这里使用了循环，是因为一个任务可能是交给好几个人来做的，所以是有好几个人。

  @Autowiredprivate TaskService taskService;List<Task> tasks = taskService.createTaskQuery().processInstanceId(pi.getId()).list();for(Task task : tasks){if(actBusiness.getFirstGateway()){// 网关类型List<User> users = getNode(task.getTaskDefinitionKey()).getUsers();// 如果下个节点未分配审批人为空 取消结束流程if(users==null||users.size()==0){throw new TbootException("有任务节点未分配任何候选审批人，发起流程失败");}else{// 分配了节点负责人分发给全部for(User user : users){taskService.addCandidateUser(task.getId(), user.getId());// 异步发消息messageUtil.sendActMessage(user.getId(), ActivitiConstant.MESSAGE_TODO_CONTENT, actBusiness.getSendMessage(),actBusiness.getSendSms(), actBusiness.getSendEmail());}}}else {// 分配第一个任务用户for (String assignee : actBusiness.getAssignees()) {taskService.addCandidateUser(task.getId(), assignee);// 异步发消息messageUtil.sendActMessage(assignee, ActivitiConstant.MESSAGE_TODO_CONTENT, actBusiness.getSendMessage(),actBusiness.getSendSms(), actBusiness.getSendEmail());}}

这里需要注意的一点是，我们只获取到了流程定义中的第一个需要处理的任务，因此我们在并行网关中一次性设置了两个，所以这个地方会获取到两个任务，他不会提示这是一个网关，因此我们需要在前把这是一个网关传过来。 在这里进行判断。
为了方便观看，我把流程设计图在这里在粘贴一次。

在这里插入图片描述

判断是不是网关

我们在介绍启动工作流的时候其实是少了一部分的工作还没有做。 下面我们简单介绍一下。

在整个工作流的中，通过流程定义id获取第一个任务节点。 这其实就是我们想做的，如果第一个任务节点是普通任务，我们就拼接一些信息给前端返回，后果不是任务节点是网关，我就把网关类型返回，这样在启动流程的时候我们就知道应第一个节点是不是网关了。如果是网关的话，根据网关类型来处理任务。

 public ProcessNodeVo getFirstNode(String procDefId) {BpmnModel bpmnModel = repositoryService.getBpmnModel(procDefId);ProcessNodeVo node = new ProcessNodeVo();List<Process> processes = bpmnModel.getProcesses();Collection<FlowElement> elements = processes.get(0).getFlowElements();// 流程开始节点StartEvent startEvent = null;for (FlowElement element : elements) {if (element instanceof StartEvent) {startEvent = (StartEvent) element;break;}}FlowElement e = null;// 判断开始后的流向节点SequenceFlow sequenceFlow = startEvent.getOutgoingFlows().get(0);for (FlowElement element : elements) {if(element.getId().equals(sequenceFlow.getTargetRef())){if(element instanceof UserTask){e = element;node.setType(ActivitiConstant.NODE_TYPE_TASK);break;}else if(element instanceof ExclusiveGateway){e = element;node.setType(ActivitiConstant.NODE_TYPE_EG);break;}else if(element instanceof ParallelGateway){e = element;node.setType(ActivitiConstant.NODE_TYPE_PG);break;}else{throw new TbootException("流程设计错误，开始节点后只能是用户任务节点、排他网关、并行网关");}}}// 排他、平行网关直接返回if(e instanceof ExclusiveGateway || e instanceof ParallelGateway){return node;}node.setTitle(e.getName());// 是否为自选用户节点Boolean customUser = actNodeService.hasCustomUser(e.getId());if(customUser){node.setType(ActivitiConstant.NODE_TYPE_CUSTOM);}else{// 设置关联用户List<User> users = getNodetUsers(e.getId());node.setUsers(removeDuplicate(users));}return node;}

好了到此为止，我们的启动流程就介绍完了， 在重新梳理一下逻辑，在启动流程之前我们先去获取第一个节点是不是网关，在启动流程之后，我们去获取第一个任务， 在根据第一个节点的情况来处理任务。也就是给任务分配处理人员。

交个朋友

在这里插入图片描述

这篇关于Activiti工作流会签二 启动流程的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1028957。

相关文章

Security OAuth2 单点登录流程

Security OAuth2 单点登录流程

单点登录（英语：Single sign-on，缩写为 SSO），又译为单一签入，一种对于许多相互关连，但是又是各自独立的软件系统，提供访问控制的属性。当拥有这项属性时，当用户登录时，就可以获取所有系统的访问权限，不用对每个单一系统都逐一登录。这项功能通常是以轻型目录访问协议（LDAP）来实现，在服务器上会将用户信息存储到LDAP数据库中。相同的，单一注销（single sign-off）就是指
阅读更多...
Spring Security基于数据库验证流程详解

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明（认真看哦） AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证，则会调用 #attemptAuthentica
阅读更多...
MySQL数据库宕机，启动不起来，教你一招搞定！

MySQL数据库宕机，启动不起来，教你一招搞定！

作者介绍：老苏，10余年DBA工作运维经验，擅长Oracle、MySQL、PG、Mongodb数据库运维（如安装迁移，性能优化、故障应急处理等）公众号：老苏畅谈运维欢迎关注本人公众号，更多精彩与您分享。 MySQL数据库宕机，数据页损坏问题，启动不起来，该如何排查和解决，本文将为你说明具体的排查过程。 查看MySQL error日志 查看 MySQL error日志，排查哪个表（表空间
阅读更多...
springboot3打包成war包，用tomcat8启动

springboot3打包成war包，用tomcat8启动

1、在pom中，将打包类型改为war <packaging>war</packaging> 2、pom中排除SpringBoot内置的Tomcat容器并添加Tomcat依赖，用于编译和测试,         *依赖时一定设置 scope 为 provided （相当于 tomcat 依赖只在本地运行和测试的时候有效，         打包的时候会排除这个依赖）<scope>provided
阅读更多...
内核启动时减少log的方式

内核启动时减少log的方式

内核引导选项 内核引导选项大体上可以分为两类：一类与设备无关、另一类与设备有关。与设备有关的引导选项多如牛毛，需要你自己阅读内核中的相应驱动程序源码以获取其能够接受的引导选项。比如，如果你想知道可以向 AHA1542 SCSI 驱动程序传递哪些引导选项，那么就查看 drivers/scsi/aha1542.c 文件，一般在前面 100 行注释里就可以找到所接受的引导选项说明。大多数选项是通过"_
阅读更多...
用命令行的方式启动.netcore webapi

用命令行的方式启动.netcore webapi

用命令行的方式启动.netcore web项目 进入指定的项目文件夹，比如我发布后的代码放在下面文件夹中 在此地址栏中输入“cmd”，打开命令提示符，进入到发布代码目录 命令行启动.netcore项目的命令为:  dotnet 项目启动文件.dll --urls="http://*:对外端口" --ip="本机ip" --port=项目内部端口 例： dotnet Imagine.M
阅读更多...
Linux服务器Java启动脚本

Linux服务器Java启动脚本

Linux服务器Java启动脚本 1、初版2、优化版本3、常用脚本仓库 本文章介绍了如何在Linux服务器上执行Java并启动jar包， 通常我们会使用nohup直接启动，但是还是需要手动停止然后再次启动， 那如何更优雅的在服务器上启动jar包呢，让我们一起探讨一下吧。 1、初版 第一个版本是常用的做法，直接使用nohup后台启动jar包， 并将日志输出到当前文件夹n
阅读更多...
衡石分析平台使用手册-单机安装及启动

衡石分析平台使用手册-单机安装及启动

单机安装及启动​ 本文讲述如何在单机环境下进行 HENGSHI SENSE 安装的操作过程。 在安装前请确认网络环境，如果是隔离环境，无法连接互联网时，请先按照 离线环境安装依赖的指导进行依赖包的安装，然后按照本文的指导继续操作。如果网络环境可以连接互联网，请直接按照本文的指导进行安装。 准备工作​ 请参考安装环境文档准备安装环境。 配置用户与安装目录。 在操作前请检查您是否有 sud
阅读更多...
SpringBoot项目是如何启动

SpringBoot项目是如何启动

启动步骤 概念 运行main方法，初始化SpringApplication 从spring.factories读取listener ApplicationContentInitializer运行run方法读取环境变量，配置信息创建SpringApplication上下文预初始化上下文，将启动类作为配置类进行读取调用 refresh 加载 IOC容器，加载所有的自动配置类，创建容器在这个过程
阅读更多...
嵌入式Openharmony系统构建与启动详解

嵌入式Openharmony系统构建与启动详解

大家好，今天主要给大家分享一下，如何构建Openharmony子系统以及系统的启动过程分解。 第一：OpenHarmony系统构建      首先熟悉一下，构建系统是一种自动化处理工具的集合，通过将源代码文件进行一系列处理，最终生成和用户可以使用的目标文件。这里的目标文件包括静态链接库文件、动态链接库文件、可执行文件、脚本文件、配置文件等。      我们在编写hellowor
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2