当前位置： 首页 > news >正文

辽源市住房和城乡建设局网站,企点协同,论文发表最正规网站,网站建设速成班1、什么是工作流 工作流(Workflow)#xff0c;就是通过计算机对业务流程自动化执行管理。它主要解决的是“使在多个参与者之间按照某种预定义的规则自动进行传递文档、信息或任务的过程#xff0c;从而实现某个预期的业务目标#xff0c;或者促使此目标的实现”。 1.2、工作…1、什么是工作流 工作流(Workflow)就是通过计算机对业务流程自动化执行管理。它主要解决的是“使在多个参与者之间按照某种预定义的规则自动进行传递文档、信息或任务的过程从而实现某个预期的业务目标或者促使此目标的实现”。 1.2、工作流系统 一个软件系统中具有工作流的功能我们把它称为工作流系统一个系统中工作流的功能是什么就是对系统的业务流程进行自动化管理所以工作流是建立在业务流程的基础上所以一个软件的系统核心根本上还是系统的业务流程工作流只是协助进行业务流程管理。即使没有工作流业务系统也可以开发运行只不过有了工作流可以更好的管理业务流程提高系统的可扩展性。 1.3、Activiti概述 Activiti是一个工作流引擎 activiti可以将业务系统中复杂的业务流程抽取出来使用专门的建模语言BPMN2.0进行定义业务流程按照预先定义的流程进行执行实现了系统的流程由activiti进行管理减少业务系统由于流程变更进行系统升级改造的工作量从而提高系统的健壮性同时也减少了系统开发维护成本。 1.4、BPM BPM即业务流程管理是一种规范化的构造端到端的业务流程以持续的提高组织业务效率。 idea插件安装https://plugins.jetbrains.com/plugin/7429-actibpm/versions 将下载的jar包插件直接整到idea当中在settings当中的插件当中导入本地插件导入插件之后重启idea即可。 2、Activiti工作流环境搭建 引入相关依赖主要MySQL的版本和自己本地需要一致 properties     slf4j.version1.6.6/slf4j.version     log4j.version1.2.12/log4j.version     activiti.version7.0.0.Beta1/activiti.version /properties dependencies     dependency         groupIdorg.activiti/groupId         artifactIdactiviti-engine/artifactId         version\({activiti.version}/version     /dependency     dependency         groupIdorg.activiti/groupId         artifactIdactiviti-spring/artifactId         version\){activiti.version}/version     /dependency     !– bpmn 模型处理 –     dependency         groupIdorg.activiti/groupId         artifactIdactiviti-bpmn-model/artifactId         version\({activiti.version}/version     /dependency     !-- bpmn 转换 --     dependency         groupIdorg.activiti/groupId         artifactIdactiviti-bpmn-converter/artifactId         version\){activiti.version}/version     /dependency     !– bpmn json数据转换 –     dependency         groupIdorg.activiti/groupId         artifactIdactiviti-json-converter/artifactId         version\({activiti.version}/version     /dependency     !-- bpmn 布局 --     dependency         groupIdorg.activiti/groupId         artifactIdactiviti-bpmn-layout/artifactId         version\){activiti.version}/version     /dependency     !– activiti 云支持 –     dependency         groupIdorg.activiti.cloud/groupId         artifactIdactiviti-cloud-services-api/artifactId         version\({activiti.version}/version     /dependency     !-- mysql驱动 --     dependency         groupIdmysql/groupId         artifactIdmysql-connector-java/artifactId         version8.0.23/version     /dependency     !-- mybatis --     dependency         groupIdorg.mybatis/groupId         artifactIdmybatis/artifactId         version3.4.5/version     /dependency     !-- 链接池 --     dependency         groupIdcommons-dbcp/groupId         artifactIdcommons-dbcp/artifactId         version1.4/version     /dependency     dependency         groupIdjunit/groupId         artifactIdjunit/artifactId         version4.12/version     /dependency     !-- log start --     dependency         groupIdlog4j/groupId         artifactIdlog4j/artifactId         version\){log4j.version}/version     /dependency     dependency         groupIdorg.slf4j/groupId         artifactIdslf4j-api/artifactId         version\({slf4j.version}/version     /dependency     dependency         groupIdorg.slf4j/groupId         artifactIdslf4j-log4j12/artifactId         version\){slf4j.version}/version     /dependency /dependencies   使用log4j日志直接在resources下创建log4j.properties日志文件路径根据实际路径修改

Set root category priority to INFO and its only appender to CONSOLE.

#log4j.rootCategoryINFO, CONSOLE debug info warn error fatal log4j.rootCategorydebug, CONSOLE, LOGFILE

Set the enterprise logger category to FATAL and its only appender to CONSOLE.

log4j.logger.org.apache.axis.enterpriseFATAL, CONSOLE

CONSOLE is set to be a ConsoleAppender using a PatternLayout.

log4j.appender.CONSOLEorg.apache.log4j.ConsoleAppender log4j.appender.CONSOLE.layoutorg.apache.log4j.PatternLayout log4j.appender.CONSOLE.layout.ConversionPattern%d{ISO8601} %-6r[%15.15t] %-5p %30.30c %x - %m\n

LOGFILE is set to be a File appender using a PatternLayout.

log4j.appender.LOGFILEorg.apache.log4j.FileAppender log4j.appender.LOGFILE.FileE:\workFile\log4jLog\activiti.log log4j.appender.LOGFILE.Appendtrue log4j.appender.LOGFILE.layoutorg.apache.log4j.PatternLayout log4j.appender.LOGFILE.layout.ConversionPattern%d{ISO8601} %-6r[%15.15t] %-5p %30.30c %x - %m\n添加activiti配置文件使用activiti提供的默认方式来创建mysql的表。默认方式是在 resources 下创建 activiti.cfg.xml 文件注意默认方式目录和文件名不能修改因为activiti的源码中已经设置到固定的目录读取固定文件名的文件。默认要在在activiti.cfg.xml中bean的名字叫processEngineConfiguration名字不可修改在这里直接连接到本地数据库activiti这个库。 ?xml version1.0 encodingUTF-8? beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:contexthttp://www.springframework.org/schema/contextxmlns:txhttp://www.springframework.org/schema/txxsi:schemaLocationhttp://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/contex http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd!– 默认id对应的值 为processEngineConfiguration –!– processEngine Activiti的流程引擎 – !– bean idprocessEngineConfiguration– !– classorg.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration– !– property namejdbcDriver valuecom.mysql.cj.jdbc.Driver/– !– property namejdbcUrl valuejdbc:mysql:///activiti?autoReconnecttrue/– !– property namejdbcUsername valueroot/– !– property namejdbcPassword value123456/– !– property namedatabaseSchemaUpdate valuetrue/– !– /bean–!– 这里可以使用 链接池 dbcp–bean iddataSource classorg.apache.commons.dbcp.BasicDataSourceproperty namedriverClassName valuecom.mysql.cj.jdbc.Driver /property nameurl valuejdbc:mysql:///activiti?autoReconnecttrue /property nameusername valueroot /property namepassword value123456 /property namemaxActive value3 /property namemaxIdle value1 //beanbean idprocessEngineConfigurationclassorg.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration!– 引用数据源 上面已经设置好了–property namedataSource refdataSource /!– activiti数据库表处理策略 –property namedatabaseSchemaUpdate valuetrue//bean/beans创建一个测试类调用activiti的工具类生成acitivti需要的数据库表。直接使用activiti提供的工具类ProcessEngines会默认读取classpath下的activiti.cfg.xml文件读取其中的数据库配置创建 ProcessEngine在创建ProcessEngine 时会自动创建表。代码执行完成之后在数据库当中进行查看对应的表是否都创建出来了。   import org.activiti.engine.ProcessEngine; import org.activiti.engine.ProcessEngineConfiguration; import org.activiti.engine.ProcessEngines; import org.junit.jupiter.api.Test; import org.springframework.boot.test.context.SpringBootTest;SpringBootTest class SpringbootHelloApplicationTests {Testvoid contextLoads() {//使用classpath下的activiti.cfg.xml中的配置创建processEngineProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();System.out.println(processEngine);// 而除了使用默认配置进行创建工作流引擎对象还可以通过自定义的方式进行创建。// 自定义配置文件名ProcessEngineConfiguration processEngineConfigurationFromResource ProcessEngineConfiguration.createProcessEngineConfigurationFromResource(activiti.cfg.xml);System.out.println(processEngineConfigurationFromResource);// 自定义配置文件名 bean对象idProcessEngineConfiguration processEngineConfigurationFromResource1 ProcessEngineConfiguration.createProcessEngineConfigurationFromResource(activiti.cfg.xml, processEngineConfiguration);System.out.println(processEngineConfigurationFromResource1);}} 执行完数据库生成25张表。 3、Activiti 类、配置文件之间的关系 3.1、activiti.cfg.xml         activiti的引擎配置文件包括ProcessEngineConfiguration的定义、数据源定义、事务管理器等此文件其实就是一个spring配置文件。 3.2、流程引擎配置类         流程引擎的配置类ProcessEngineConfiguration通过ProcessEngineConfiguration可以创建工作流引擎ProceccEngine常用的两种方法如下 3.2.1、StandaloneProcessEngineConfiguration 使用StandaloneProcessEngineConfigurationActiviti可以单独运行来创建ProcessEngineActiviti会自己处理事务。配置文件方式通常在activiti.cfg.xml配置文件中定义一个id为 processEngineConfiguration 的bean见环境搭建模块就是使用这种方式进行配置的。 3.2.2、SpringProcessEngineConfiguration 通过org.activiti.spring.SpringProcessEngineConfiguration 与Spring整合。 3.3、Servcie服务接口         Service是工作流引擎提供用于进行工作流部署、执行、管理的服务接口我们使用这些接口可以就是操作服务对应的数据表并且在这里通过processEngine对象get对应的service就可以获取到service对象了。 4、流程的创建与操作 4.1 流程图的绘制安装bpmn插件 将文件后缀bpmn改为xml打开文件如下 4.2.1 单个文件部署方式 将上面的流程部署到activiti的数据库中就是流程定义部署。 /*** 单个文件部署流程/Testpublic void develop() {// 创建流程对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();// 获取service对象RepositoryService repositoryService processEngine.getRepositoryService();// 流程部署 设置名字 将bpmn和png部署进去Deployment deploy repositoryService.createDeployment().addClasspathResource(bpmn/hello.bpmn).addClasspathResource(bpmn/hello.png).name(请假流程).deploy();System.out.println(id deploy.getId());System.out.println(name deploy.getName());} 之后直接启动这个测试方法进行流程部署可以观察日志整个部署的过程当中总共操作了三张表 act_re_deployment 流程定义部署表每部署一次增加一条记录act_re_procdef 流程定义表部署每个新的流程定义都会在这张表中增加一条记录act_ge_bytearray 流程资源表act_re_deployment 和 act_re_procdef一对多关系一次部署在流程部署表生成一条记录但一次部署可以部署多个流程定义每个流程定义在流程定义表生成一条记录。每一个流程定义在act_ge_bytearray会存在两个资源记录bpmn和png。 4.2.2 使用压缩包的方式 /** 压缩包的方式部署/Testpublic void devoZip(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RepositoryService repositoryService processEngine.getRepositoryService();InputStream inputStream this.getClass().getClassLoader().getResourceAsStream(bpmn/hello.zip);ZipInputStream zipInputStream new ZipInputStream(inputStream);Deployment deploy repositoryService.createDeployment().addZipInputStream(zipInputStream).deploy();System.out.println(id deploy.getId());System.out.println(name deploy.getName());} 4.3 开始流程 启动一个流程表示发起一个新的请假申请这就相当于java类与java对象的关系类定义好后需要new创建一个对象使用当然可以new多个对象。对于请出差申请流程发起一个请假申请单需要启动一个流程实例请假申请单发起请假也需要启动一个流程实例。 流程实例的key查看数据库 /** 开始流程/Testpublic void start(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RuntimeService runtimeService processEngine.getRuntimeService();// 根据流程id启动流程 act_re_procdef表里的keyProcessInstance instance runtimeService.startProcessInstanceByKey(myProcess_1);System.out.println(流程id instance.getProcessDefinitionId());System.out.println(实例id instance.getId());System.out.println(活动id instance.getActivityId());} 流程开始成功。 4.4 任务查询 流程启动后任务的负责人就可以查询自己当前需要处理的任务查询出来的任务都是该用户的待办任务。 /** 查找任务/Testpublic void findTask(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();// act_ru_task表里的assignee字段就是处理人 可以手动设置ListTask list taskService.createTaskQuery().processDefinitionKey(myProcess_1).taskAssignee(cxb).list();for (Task task : list){System.out.println(流程id task.getProcessInstanceId());System.out.println(任务id task.getId());System.out.println(任务负责人 task.getAssignee());System.out.println(任务名称 task.getName());}} 而对应的查询语句也是根据流程的Key以及负责人去task当中查询任务。 SELECT DISTINCT RES. FROM ACT_RU_TASK RES INNER JOIN ACT_RE_PROCDEF D ON RES.PROC_DEFID D.ID_ WHERE RES.ASSIGNEE_ yueyue AND D.KEY_ myLeave ORDER BY RES.ID_ ASC LIMIT 2147483647 OFFSET 0 这里设置处理人。 4.5 任务推动 在前面我们可以获取到负责人所有的任务并且可以获取到相对应的任务id这里只需要获取id进行推动流程即可。 /*** 任务推动/Testpublic void next(){ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();taskService.complete(5005);// 获取单个流程数据进行操作替换掉上面的2505// Task task taskService.createTaskQuery().processDefinitionKey(myProcess_1).taskAssignee(zhangsan).singleResult();// taskService.complete(task.getId());System.out.println(任务完成);} 任务推动之后还是和查询任务一致的查询语句获取当前负责人的数据也可以直接查看 act_ru_task这张表的流程数据推动了没而之前的流程会保存在 act_hi_taskinst 这张表当中。而这里对后续的几个流程的推动也是相同的道理就不继续进行流程推动了当最后一步的流程走完之后整个流程已经结束在act_ru_task这张表就不会存在当前这个流程的数据了。 4.6 流程定义信息查询 查询流程相关信息包含流程定义流程部署流程定义版本 /** 流程定义信息查询/Testpublic void processInfo() {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RepositoryService repositoryService processEngine.getRepositoryService();ProcessDefinitionQuery processDefinitionQuery repositoryService.createProcessDefinitionQuery();ListProcessDefinition list processDefinitionQuery.processDefinitionKey(myProcess_1).orderByProcessDefinitionVersion().desc().list();for (ProcessDefinition definition : list) {System.out.println(id definition.getId());System.out.println(name definition.getName());System.out.println(key definition.getKey());System.out.println(version definition.getVersion());}} 4.7 流程删除 /** 删除流程/Testpublic void deleteProcess() {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RepositoryService repositoryService processEngine.getRepositoryService(); // repositoryService.deleteDeployment(1);// 如果该流程定义下存在已经运行的流程使用普通删除报错可用级联删除方法将流程及相关记录全部删除。// 先删除没有完成流程节点最后就可以完全删除流程定义信息repositoryService.deleteDeployment(1, true);} 4.8 下载资源文件 首先可以知道资源文件存在 act_ge_bytearray 这张表当中而对于流程的数据bpmn和png文件的DEPLOYMENT_ID这个字段是相同的因此只需要获取到这个id就能得到相对应的数据这个id如何获取呢在前面4.6获取流程信息当中就可以获取到这个id因此把之前获取全部改为获取单个就能拿到这个id了。而后续根据repositoryService来进行获取需要两个参数一个就是这个id另外一个就是文件的路径文件的路径可以在 act_re_procdef 当中进行获取。   /** 下载资源文件* throws IOException*/Testpublic void getBolb() throws IOException {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RepositoryService repositoryService processEngine.getRepositoryService();ProcessDefinitionQuery processDefinitionQuery repositoryService.createProcessDefinitionQuery();ProcessDefinition definition processDefinitionQuery.processDefinitionKey(myProcess_1).orderByProcessDefinitionVersion().desc().singleResult();// 获取流程id 文件名String deploymentId definition.getDeploymentId();String diagramResourceName definition.getDiagramResourceName();String resourceName definition.getResourceName();// 得到input流InputStream pngInput repositoryService.getResourceAsStream(deploymentId, diagramResourceName);InputStream bpmnInput repositoryService.getResourceAsStream(deploymentId, resourceName);File pngFile new File(d:/leave.png);File bpmnFile new File(d:/leave.bpmn);FileOutputStream pngOutputStream new FileOutputStream(pngFile);FileOutputStream bpmnOutputStream new FileOutputStream(bpmnFile);// 输入输出转换IOUtils.copy(pngInput, pngOutputStream);IOUtils.copy(bpmnInput, bpmnOutputStream);pngInput.close();pngOutputStream.close();bpmnInput.close();bpmnOutputStream.close();} 并且这里使用到的IOUtils工具类是apache提供的需要引入新的依赖 dependencygroupIdcommons-io/groupIdartifactIdcommons-io/artifactIdversion2.6/version/dependency4.9 流程历史信息查看 即使流程定义已经删除了流程执行的历史信息通过前面的分析依然保存在activiti的acthi相关的表中。所以我们还是可以查询流程执行的历史信息可以通过HistoryService来查看相关的历史记录。 /** 查看流程历史信息/Testpublic void findHistory() {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();HistoryService historyService processEngine.getHistoryService();// 设置查询条件进行查询ListHistoricActivityInstance list historyService.createHistoricActivityInstanceQuery().orderByHistoricActivityInstanceStartTime().asc().processInstanceId(12501).list();for (HistoricActivityInstance historiy : list) {System.out.println(activiti id historiy.getActivityId());System.out.println(activiti name historiy.getActivityName());System.out.println(process definition id historiy.getProcessDefinitionId());System.out.println(process instance id historiy.getProcessInstanceId());System.out.println(start time new SimpleDateFormat(yyyy-MM-dd HH:mm:ss).format(historiy.getStartTime()));System.out.println();}} 4.10、给流程实例添加Businesskey业务标识 启动流程实例时指定的businesskey就会在act_ru_execution #流程实例的执行表中存储businesskey。 Businesskey业务标识通常为业务表的主键业务标识和流程实例一一对应。业务标识来源于业务系统。存储业务标识就是根据业务标识来关联查询业务系统的数据。 /** 增加业务标识/Testpublic void addLeaveKey() {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RuntimeService runtimeService processEngine.getRuntimeService();ProcessInstance myLevel runtimeService.startProcessInstanceByKey(myProcess_1, 1001);System.out.println(myLevel.getBusinessKey());} 4.11 流程的挂起与激活 4.11.1、全部流程实例挂起 操作流程定义为挂起状态该流程定义下边所有的流程实例全部暂停流程定义为挂起状态该流程定义将不允许启动新的流程实例同时该流程定义下所有的流程实例将全部挂起暂停执行。 /** 全部流程实例挂起/Testpublic void suspendAll() {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RepositoryService repositoryService processEngine.getRepositoryService();ProcessDefinition definition repositoryService.createProcessDefinitionQuery().processDefinitionKey(myProcess_1).singleResult();// 是否暂停boolean suspended definition.isSuspended();String id definition.getId();if (suspended) {repositoryService.activateProcessDefinitionById(id, true, null);System.out.println(id id 激活);} else {repositoryService.suspendProcessDefinitionById(id, true, null);System.out.println(id id 挂起);}} 4.11.2、单个流程实例挂起 操作流程实例对象针对单个流程执行挂起操作某个流程实例挂起则此流程不再继续执行完成该流程实例的当前任务将报异常。 Testpublic void suspendOne() {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RuntimeService runtimeService processEngine.getRuntimeService();ProcessInstance processInstance runtimeService.createProcessInstanceQuery().processInstanceId(12501).singleResult();boolean suspended processInstance.isSuspended();String id processInstance.getId();if (suspended) {runtimeService.activateProcessInstanceById(id);System.out.println(id id 激活);} else {runtimeService.suspendProcessInstanceById(id);System.out.println(id id 挂起);}}4.11.3 流程实例推动 在前面我们对一个整个的流程以及单个流程进行了激活和挂起操作之后可以编写一段代码来进行推动流程操作主要是用来当流程被挂起后流程还能否被继续推动。很显然当挂起的流程去进行流程推动是不允许推动流程的必须是流程是激活状态下才能够被推动。 具体的实例id和assignee值根据自己数据库的值来进行处理。 /** 流程实例推动/Testpublic void complete() {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();Task task taskService.createTaskQuery().processInstanceId(15001).taskAssignee(cxb).singleResult();System.out.println(id task.getId());System.out.println(name task.getName());System.out.println(assignee task.getAssignee());taskService.complete(task.getId());}5、个人任务 5.1、分配任务责任人 5.1.1、固定负责人 在进行业务流程建模时指定固定的任务负责人直接在bpmn当中指定assignee。 5.1.2、表达式分配 由于固定分配方式任务只管一步一步执行任务执行到每一个任务将按照 bpmn 的配置去分配任务负责人。和前面一样进行指定使用${变量名}的方式进行指定。而指定之后的这些变量在流程启动的时候可以通过一个map对象来进行赋值。 /** 表达式分配/Testpublic void startDistribution () {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RuntimeService runtimeService processEngine.getRuntimeService();// 根据流程id启动流程MapString, Object map new HashMap();map.put(assignee, huangyueyue);map.put(director, yueyueniao);map.put(manager, zhangsan);ProcessInstance instance runtimeService.startProcessInstanceByKey(myProcess_1, map);} 5.1.3、监听器分配 任务监听器的Event的选项包含 Create任务创建后触发Assignment任务分配后触发Delete任务完成后触发All所有事件发生都触发 定义任务监听类且类必须实现 org.activiti.engine.delegate.TaskListener 接口 package com.cxb.springboot.listener;import org.activiti.engine.delegate.DelegateTask; import org.activiti.engine.delegate.TaskListener;public class MyTaskListener implements TaskListener {Overridepublic void notify(DelegateTask delegateTask) {if (delegateTask.getName().equals(请假申请) delegateTask.getEventName().equals(create)) {// 这里指定任务负责人delegateTask.setAssignee(黄阅阅);}} } userTask activiti:exclusivetrue id_3 name请假申请extensionElementsactiviti:taskListener classcom.cxb.springboot.listener.MyTaskListener eventall//extensionElements/userTask 5.2、查询任务 在前面就已经可以通过流程key和负责人就可以查询出这个人负责的流程单而实际应用时查询待办任务可能要显示出业务系统的一些相关信息。这里可以通过 businessKey业务标识 关联查询业务系统的数据。 /** 查询任务/Testpublic void findProcessInstance() {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();RuntimeService runtimeService processEngine.getRuntimeService();Task task taskService.createTaskQuery().processDefinitionKey(myProcess_1).taskAssignee(cxb).singleResult();String processInstanceId task.getProcessInstanceId();ProcessInstance processInstance runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();String businessKey processInstance.getBusinessKey();System.out.println(businessKey businessKey);} 查询业务标识码 5.3、任务推动 在之前可以通过TaskService这个类的complate方法推动任务的流动而在这里我们还需要对当前用户是否拥有推动该流程的权限只需要先通过查询当前负责人的所有流程进行判断即可。有该流程即可推动反之无法推动流程。 Testpublic void completeTask() {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();Task task taskService.createTaskQuery().taskId(20005).taskAssignee(cxb).singleResult();if (task ! null) {taskService.complete(20005);System.out.println(完成任务);}} 6、流程变量与组任务 6.1、流程变量概述 6.1.1、流程变量是什么 流程变量在 activiti 中是一个非常重要的角色流程运转有时需要靠流程变量业务系统和 activiti 结合时少不了流程变量流程变量就是 activiti 在管理工作流时根据管理需要而设置的变量。 虽然流程变量中可以存储业务数据可以通过activiti的api查询流程变量从而实现查询业务数据但是不建议这样使用因为业务数据查询由业务系统负责activiti设置流程变量是为了流程执行需要而创建。 6.1.2、流程变量作用域 流程变量的作用域可以是一个流程实例或一个任务或一个执行实例 1、global变量         流程变量的默认作用域是流程实例。当一个流程变量的作用域为流程实例时可以称为 global 变量。         global 变量中变量名不允许重复设置相同名称的变量后设置的值会覆盖前设置的变量值。 2、local变量         任务和执行实例仅仅是针对一个任务和一个执行实例范围范围没有流程实例大 称为 local 变量。         Local 变量由于在不同的任务或不同的执行实例中作用域互不影响变量名可以相同没有影响。         Local 变量名也可以和 global 变量名相同没有影响。 6.2、使用global变量控制流程 还是和前面的整个流程一样现在对流程的分支进行控制通过流程变量来进行控制当天数大于或等于三天还需要通过经理审批反之直接通过主管审批就结束了整个流程。 这里的话使用的UEL表达式使用的是uel-method来进行赋值所以在这里需要一个实体类来进行值的给予先定义一个类。该类当中必须包含这个day变量也就是在bpmn文件当中指定的变量以及该类必须实例化。并且加上getset方法。 public class Leave implements Serializable {private Double day; }6.2.1、启动流程时设置变量 在启动流程时设置流程变量变量的作用域是整个流程实例。通过Mapkey,value设置流程变量map中可以设置多个变量这个key就是流程变量的名字。后续通过TaskService的compele方法来进行推动流程实例的代码就不给出了直接获取taskid进行推动查看流程的走向。 /** 单个文件部署流程/Testpublic void developGlobal() {// 创建流程对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();// 获取service对象RepositoryService repositoryService processEngine.getRepositoryService();// 流程部署 设置名字 将bpmn和png部署进去Deployment deploy repositoryService.createDeployment().addClasspathResource(bpmn/hello-global.bpmn).addClasspathResource(bpmn/hello-global.png).name(请假流程全局设置变量).deploy();System.out.println(id deploy.getId());System.out.println(name deploy.getName());}/** 启动流程时设置变量/Testpublic void startSetGlobal() {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RuntimeService runtimeService processEngine.getRuntimeService();Leave leave new Leave();leave.setDay(4d);Map map new HashMap();map.put(leave, leave);map.put(assignee, yueyueniao);map.put(director, 张三);map.put(manager, 黄阅阅);ProcessInstance processInstance runtimeService.startProcessInstanceByKey(myProcess_1, map);System.out.println(processInstance);} 6.2.2 任务办理时设置变量 在完成任务时设置流程变量该流程变量只有在该任务完成后其它结点才可使用该变量它的作用域是整个流程实例如果设置的流程变量的key在流程实例中已存在相同的名字则后设置的变量替换前边设置的变量。这样对前面6.2.1的代码当中往map对象当中添加leave的代码注掉。 /** 任务办理时设置变量/Testpublic void completeSet() {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();Leave leave new Leave();leave.setDay(4d);Map map new HashMap();map.put(leave, leave);Task task taskService.createTaskQuery().processDefinitionKeyLike(myLeaveGlabal).taskAssignee(张三).singleResult();if (task ! null) {taskService.complete(task.getId(), map);}} 6.2.3 通过当前流程实例设置 通过流程实例id设置全局变量该流程实例必须未执行完成。 Testpublic void setGlobalVariableByExecutionId() {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RuntimeService runtimeService processEngine.getRuntimeService();Leave leave new Leave();leave.setDay(4d);runtimeService.setVariable(75001, leave, leave);}6.2.4 通过当前任务设置 Testpublic void setGlobalVariableByTaskId() {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();Leave leave new Leave();leave.setDay(4d);taskService.setVariable(75001, leave, leave);}6.3 组任务办理流程** 1查询组任务 指定候选人查询该候选人当前的待办任务。候选人不能立即办理任务。 2拾取任务 该组任务的所有候选人都能拾取。将候选人的组任务变成个人任务。原来候选人就变成了该任务的负责人。如果拾取后不想办理该任务需要将已经拾取的个人任务归还到组里边将个人任务变成了组任务。 3查询个人任务 查询方式同个人任务部分根据assignee查询用户负责的个人任务。 4办理个人任务 首先创建一个bpmn文件在user当中可以对candidateUsers进行设置多个人员之间用都好进行隔开而对应的xml如下 userTask activiti:candidateUserszhangsan,lisi activiti:exclusivetrue id_3 name申请-group/userTask activiti:candidateUserswangwu,zhaoliu activiti:exclusivetrue id_4 name审核-group/之后将该bpmn进行部署并且启动任务。 6.3.1 查询组任务 根据候选人查询组任务可以看到这个task在act_ru_task这张表当中的assignee却是一个null也就是该用户虽然可以查询出该任务却无法对该任务进行处理。 Testpublic void findGroup() {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();ListTask list taskService.createTaskQuery().processDefinitionKey(myLeaveGroup).taskCandidateUser(zhangsan).list();for (Task task : list) {System.out.println(instance id task.getProcessInstanceId());System.out.println(id task.getId());System.out.println(assignee task.getAssignee());System.out.println(name task.getName());}}6.3.2 拾取任务 候选人员拾取组任务后该任务变为自己的个人任务。用户拾取任务之后对应的act_ru_task表对应的行数据的assignee就会变成相对应的人员。 Testpublic void getTask() {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();Task task taskService.createTaskQuery().taskId(87505).taskCandidateUser(zhangsan).singleResult();if (task ! null) {taskService.claim(87505, zhangsan);System.out.println(用户拾取);}}6.3.3 归还组任务 直接通过assignee进行查询查询到数据再将assignee置空也就表示归还了任务。同理任务的交接就不用设置为空了直接设置给另一个用户即可。 Testpublic void returnTask() {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();Task task taskService.createTaskQuery().taskId(87505).taskAssignee(zhangsan).singleResult();if (task ! null) {taskService.setAssignee(87505, null);System.out.println(用户归还);}}7、网关 7.1 排他网关 排他网关用来在流程中实现决策。 当流程执行到这个网关所有分支都会判断条件是否为true如果为true则执行该分支注意排他网关只会选择一个为true的分支执行。如果有两个分支条件都为true排他网关会选择id值较小的一条分支去执行。 在这里对A流程后设置一个排他网关进行流程分支这两条分支线也就对应两个uel表达式进行判断而后就可以直接把这个流程进行部署部署之后在启动流程的时候就给这个day进行设置值直接进行推动流程查看流程的流转。 Testpublic void startSet() {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RuntimeService runtimeService processEngine.getRuntimeService();Leave leave new Leave();leave.setDay(-4d);Map map new HashMap();map.put(leave, leave);ProcessInstance processInstance runtimeService.startProcessInstanceByKey(gateway-pt, map);}Testpublic void compete() {ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();Task task taskService.createTaskQuery().processDefinitionKey(gateway-pt).taskAssignee(张三).singleResult();if (task ! null) {taskService.complete(task.getId());}}7.2 并行网关 并行网关允许将流程分成多条分支也可以把多条分支汇聚到一起并行网关的功能是基于进入和外出顺序流的 fork分支并行后的所有外出顺序流为每个顺序流都创建一个并发分支。 join汇聚所有到达并行网关在此等待的进入分支 直到所有进入顺序流的分支都到达以后 流程就会通过汇聚网关。 并行网关的测试代码和前面排他网关的代码基本一致在首先进行部署之后启动流程给流程设置一个天数而之后推动任务之后首先进入到并行网关这里并不会进行判断这里的意思是表示B和C都可以进行对该任务流程进行操作并且只有到B和C都做了相关的操作流程才会继续往后流转后面接的排他网关直接通过最开始设置的值再进行判断做流程的流转。 7.3 包含网关 包含网关可以看做是排他网关和并行网关的结合体。和排他网关一样可以在外出顺序流上定义条件包含网关会解析它们。 但是主要的区别是包含网关可以选择多于一条顺序流这和并行网关一样。 1、分支所有外出顺序流的条件都会被解析结果为true的顺序流会以并行方式继续执行 会为每个顺序流创建一个分支。         2、汇聚所有并行分支到达包含网关会进入等待状态 直到每个包含流程token的进入顺序流的分支都到达。 这是与并行网关的最大不同。换句话说包含网关只会等待被选中执行了的进入顺序流。 在汇聚之后流程会穿过包含网关继续执行。         和之前的网关一样进行部署推动流程可以发现在进入到包含网关的时候网关会对条件进行判断再进行流转。二里面的包含又相当于并行网关当并行的流程都执行完成之后再由包含网关进行汇聚。之后走排他网关进行判断流转。 7.4 事件网关 事件网关允许根据事件判断流向。网关的每个外出顺序流都要连接到一个中间捕获事件。 当流程到达一个基于事件网关网关会进入等待状态会暂停执行。与此同时会为每个外出顺序流创建相对的事件订阅。 事件网关的外出顺序流和普通顺序流不同这些顺序流不会真的执行 相反它们让流程引擎去决定执行到事件网关的流程需要订阅哪些事件。 要考虑以下条件 1、事件网关必须有两条或以上外出顺序流         2、事件网关后只能使用intermediateCatchEvent类型activiti不支持基于事件网关后连接ReceiveTask         3、连接到事件网关的中间捕获事件必须只有一个入口顺序流。 参考