详析工作流Activity5.13

野性酷女 2022-01-25 14:20 287阅读 0赞

详析工作流Activity5.13

一、了解工作流

工作流(Workflow)，就是“业务过程的部分或整体在计算机应用环境下的自动化”，它主要解决的是“使在多个参与者之间按照某种预定义的规则传递文档、信息或任务的过程自动进行，从而实现某个预期的业务目标，或者促使此目标的实现”。
工作流管理系统(Workflow Management System, WfMS)是一个软件系统，它完成工作量的定义和管理，并按照在系统中预先定义好的工作流逻辑进行工作流实例的执行。工作流管理系统不是企业的业务系统，而是为企业的业务系统的运行提供了一个软件的支撑环境。

常见的工作流框架
Activity5.13、JBPM4.4、OSWorkFlow、WorkFlow
工作流框架底层需要有数据库提供支持，activiti5.13版本，有23张表。JBPM4.4框架底层有数据库支持，18张表。JBPM底层使用hibernate操作数据库。Activiti框架底层使用的mybatis操作数据库。

二、初始化表结构

1.使用Activiti框架提供的建表语句

下载的Activiti框架的包中 /activiti-x.xx/database/ceate/ 目录中提供各种数据库的建表语句。

2.使用Activiti框架自动建表

2.1 不使用配置文件
  1. @Test
  2.     public void test1() { 
  3.         // 创建一个流程引擎配置对象
  4.         ProcessEngineConfiguration configuration = ProcessEngineConfiguration.createStandaloneProcessEngineConfiguration();
  6.         // 设置数据源信息
  7.         configuration.setJdbcDriver("com.mysql.jdbc.Driver");
  8.         configuration.setJdbcUrl("jdbc:mysql://localhost:3306/activiti");
  9.         configuration.setJdbcUsername("root");
  10.         configuration.setJdbcPassword("");
  12.         // 设置自动建表
  13.         configuration.setDatabaseSchemaUpdate("true");
  15.         // 创建一个流程引擎对象，在创建流程引擎对象中会自动建表
  16.         ProcessEngine processEngine = configuration.buildProcessEngine();
  17.     }
2.2 使用自定义配置文件

actitviti-context.xml (名字随意)

  1. <!-- 配置流程引擎配置对象 -->
  2.     <bean id="processEngineConfiguration"
  3.         class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
  4.         <property name="jdbcDriver" value="com.mysql.jdbc.Driver" />
  5.         <property name="jdbcUrl" value="jdbc:mysql:///activiti" />
  6.         <property name="jdbcUsername" value="root" />
  7.         <property name="jdbcPassword" value="" />
  8.         <property name="databaseSchemaUpdate" value="true" />
  9.     </bean>

Test.java

  1. @Test
  2.     /** * 使用框架提供的自动建表（提供配置文件） */
  3.     public void test2() { 
  4.         String resource = "actitviti-context.xml";//配置文件名称
  5.         String beanName = "processEngineConfiguration";//配置id值
  6.         //加载配置文件
  7.         ProcessEngineConfiguration configuration = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource(resource, beanName);
  8.        //创建流程引擎对象
  9.         ProcessEngine processEngine = configuration.buildProcessEngine();
  10.     }
3.3 使用Activiti框架提供的默认配置文件

要求配置文件名称必须为activiti-context.xml或者activiti.cfg.xml。

配置流程引擎配置对象的id必须为 processEngineConfiguration
创建流程引擎对象的id必须为processEngine
activiti-context.xml

  1. <!-- 配置流程引擎配置对象 -->
  2.     <bean id="processEngineConfiguration"
  3.         class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
  4.         <property name="jdbcDriver" value="com.mysql.jdbc.Driver" />
  5.         <property name="jdbcUrl" value="jdbc:mysql:///activiti" />
  6.         <!--<property name="jdbcUrl" value="jdbc:mysql:///activiti_web" />-->
  7.         <property name="jdbcUsername" value="root" />
  8.         <property name="jdbcPassword" value="" />
  9.         <property name="databaseSchemaUpdate" value="true" />
  10.     </bean>
  12.     <!-- 配置一个流程引擎工厂bean，用于创建流程引擎对象 -->
  13.     <bean id="processEngine" class="org.activiti.spring.ProcessEngineFactoryBean">
  14.         <!-- 通过set方法注入流程引擎配置对象 -->
  15.         <property name="processEngineConfiguration" ref="processEngineConfiguration" />
  16.     </bean>

Test.java

  1. @Test
  2.     /** * 使用框架提供的自动建表（使用默认配置文件） */
  3.     public void test() { 
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.     }

三、了解Activiti框架中的二十三张表

Activiti的后台是有数据库的支持，所有的表都以ACT_开头。 第二部分是表示表的用途的两个字母标识。 用途也和服务的API对应。

  1. ACT_RE_*: ‘RE’表示repository。 这个前缀的表包含了流程定义和流程静态资源 （图片，规则，等等）。
  2. ACT_RU_*: ‘RU’表示runtime。 这些运行时的表，包含流程实例，任务，变量，异步任务，等运行中的数据。 Activiti只在流程实例执行过程中保存这些数据， 在流程结束时就会删除这些记录。 这样运行时表可以一直很小速度很快。
  3. ACT_ID_*: ‘ID’表示identity。 这些表包含身份信息，比如用户，组等等。
  4. ACT_HI_*: ‘HI’表示history。 这些表包含历史数据，比如历史流程实例， 变量，任务等等。
  5. ACT_GE_*: 通用数据， 用于不同场景下。

四、Activiti框架的基本使用

1.部署流程定义

1.1 使用Eclipse或Idea的BPMN编辑插件绘制流程图，并导出 流程图.bpmn和 流程图.png
2.2 使用Java代码部署流程流程定义

Test.java

  1. @Test
  2.     /** * 部署流程定义 * 操作的数据表： * act_re_deloyment（部署表） 部署一次 插入一条记录 * act_re_procdef 可以认为是部署表的扩展表 流程定义表 * act_ge_bytearray:流程定义文件被序列化存在数据表中 */
  3.     public void test() { 
  4.         //使用默认配置文件创建流程引擎
  5.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  6.         // 获得一个部署构建器对象，用于加载流程定义文件（test.bpmn test.png）完成流程定义的部署
  7.         DeploymentBuilder builder = processEngine.getRepositoryService().createDeployment();
  8.         // 加载流程定义文件
  9.         builder.addClasspathResource("/process/test.bpmn");
  10.         builder.addClasspathResource("/process/test.png");
  11.         // 部署流程定义
  12.         Deployment deployment = builder.deploy();
  13.     }

2. 查询流程定义列表

  1. /** * 查询流程定义列表 */
  2.     @Test
  3.     public void test() { 
  4.         //使用默认配置文件创建流程引擎
  5.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  6.         // 流程定义查询对象，用于查询act_re_procdef
  7.         ProcessDefinitionQuery query = processEngine.getRepositoryService().createProcessDefinitionQuery();
  8.         //添加过滤条件
  9.         query.processDefinitionKey("myProcess_1");
  10.         // 添加排序条件
  11.         query.orderByProcessDefinitionVersion().desc();
  12.         //添加分页查询
  13.         query.listPage(0, 10);
  14.         List<ProcessDefinition> list = query.list();
  15.         for (ProcessDefinition pd : list) { 
  16.             System.out.println(pd.getId());
  17.         }
  18.     }

3.启动流程实例

流程实例是根据一个流程定义具体的一次执行过程就是一个流程实例,一个流程定义对应多个流程实例(一对多关系)。

  1. /** * 根据流程定义 启动一个流程实例 * 根据流程定义的一次具体执行过程，就是一个流程实例 */
  2.     @Test
  3.     public void test() { 
  4.         //使用默认配置文件创建流程引擎
  5.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  6.         String processDefinitionId = "myProcess_1:7:1004";//流程定义id可在act_re_procdef表中查询到
  7.         ProcessInstance processInstance = processEngine.getRuntimeService().startProcessInstanceById(processDefinitionId);
  8.         System.out.println(processInstance.getId());
  9.     }

4.查询个人任务列表

  1. /** * 查询个人任务列表 */
  2.     @Test
  3.     public void test() { 
  4.         //使用默认配置文件创建流程引擎
  5.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  6.         //创建任务查询
  7.         TaskQuery taskQuery = processEngine.getTaskService().createTaskQuery();
  8.       //添加查询条件 办理人为王五
  9.         String assignee = "王五";
  10.         taskQuery.taskAssignee(assignee);
  11.         List<Task> list = taskQuery.list();//查询所有
  12.         for (Task task : list) { 
  13.             System.out.println(task.getId() + "——" + task.getName());
  14.         }
  15.     }

5.办理任务

  1. /** * 办理业务 */
  2.     @Test
  3.     public void test() { 
  4.         //使用默认配置文件创建流程引擎
  5.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  6.         String taskId = "602";//任务id可在act_ru_task表中查询到
  7.         processEngine.getTaskService().complete(taskId);//传入任务id办理业务
  8.         System.out.println("办理成功");
  9.     }

五、Activiti提供的Service对象

在以上的代码中有很多Servie，接下来说明一下这些Service的区别。

RepositoryService——操作静态的资源（流程定义，bpmn、png）
RuntimeService——-操作流程实例（启动流程实例、查询流程实例、结束流程实例）
TaskService——-操作任务（查询任务、办理任务）
HistoryService——操作历史数据

六、Activiti框架提供的对象(和表有对应关系)

Deployment——-act_re_deployment
ProcessDefinition——act_re_procdef
ProcessInstance——-act_ru_execution
Task——-act_ru_task

七、使用Activiti框架提供的网页版流程设计器

1.将Activiti的包中activiti-explorer.war复制到tomcat的/webapps目录中。
2.启动Tomcat，访问 http://lcoalhost:8080/activiti-explorer
3.登录。登录账号和密码为：admin

八、使用Activiti框架的API操作流程

1.部署流程定义的两种方法

1.1 读取单个的流程定义文件
  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         //创建流程部署对象
  6.         DeploymentBuilder deploymentBuilder = processEngine.getRepositoryService().createDeployment();
  8.         //读取单个的流程定义文件
  9.         deploymentBuilder.addClasspathResource("/process/test.bpmn");
  10.         deploymentBuilder.addClasspathResource("/process/test.png");
  11.         Deployment deployment = deploymentBuilder.deploy();//部署流程
1.2 读取ZIP压缩文件

将test.bpmn和test.png放到同一个zip压缩包中。

  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         //创建流程部署对象
  6.         DeploymentBuilder deploymentBuilder = processEngine.getRepositoryService().createDeployment();
  8.         //读取ZIP压缩文件
  9.         //读取资源文件
  10.         ZipInputStream zipInputStream = new ZipInputStream(this.getClass().getClassLoader().getResourceAsStream("/process/process.zip"));
  11.         deploymentBuilder.addZipInputStream(zipInputStream);
  12.         deploymentBuilder.name("请假流程部署");//设置流程定义名称
  13.         Deployment deployment1 = deploymentBuilder.deploy();//部署流程
  14.     }

2.查询流程部署列表 （act_re_deployment表）

  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         //部署查询对象，查询act_re_deployment 部署表
  6.         DeploymentQuery deploymentQuery = processEngine.getRepositoryService().createDeploymentQuery();
  7.         List<Deployment> list = deploymentQuery.list();
  8.         for (Deployment deployment : list) { 
  9.             String id = deployment.getId();
  10.             System.out.println(id);
  11.         }
  12.     }

3.删除部署信息

  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         String deloymentId = "7504"; //流程部署id 在act_re_deployment表中
  6.         //deleteDeployment有两个参数 第一个删除 部署的内容的id，第二个是否级联删除，默认为false
  7.         processEngine.getRepositoryService().deleteDeployment(deloymentId, true);
  8.     }

4.删除流程定义（通过删除部署信息达到删除流程定义的目的）

  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         String deloymentId = "1001";
  6.         //deleteDeployment有两个参数 第一个删除 部署的内容的id，第二个是否级联删除，默认为false
  7.         processEngine.getRepositoryService().deleteDeployment(deloymentId, true);
  8.     }

5.查询流程定义列表

  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         //流程定义查询对象，查询表act_re_procdef
  6.         ProcessDefinitionQuery processDefinitionQuery = processEngine.getRepositoryService().createProcessDefinitionQuery();
  7.         List<ProcessDefinition> list = processDefinitionQuery.list();
  8.         for (ProcessDefinition pd : list) { 
  9.             System.out.println(pd.getName() + "———" + pd.getId());
  10.         }
  11.     }

6.查询一次部署对应的流程定义文件和对应的输入流（bpmn，png）

  1. @Test
  2.     public void test() throws IOException { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         String deploymentId = "901";
  6.         List<String> list = processEngine.getRepositoryService().getDeploymentResourceNames(deploymentId);
  7.         for (String name : list) { 
  8.             System.out.println(name);
  9.             InputStream inputStream = processEngine.getRepositoryService().getResourceAsStream(deploymentId, name);
  10.             //将文件保存到本地磁盘
  11.          org.apache.commons.io.FileUtils.copyInputStreamToFile(inputStream, new File("d:\\" + name));
  12.             inputStream.close();
  13.         }
  14.     }

7.获得png文件的输入流

  1. @Test
  2.     public void test() throws IOException { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         String processDefinitionId = "myProcess_1:6:904";
  6.         InputStream PngInputStream = processEngine.getRepositoryService().getProcessDiagram(processDefinitionId);
  7.         FileUtils.copyInputStreamToFile(PngInputStream, new File("d:\\my.png"));
  8.     }

8.启动流程实例的两种方法

8.1 方式一：根据流程定义的id启动
  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         //方式一：根据流程定义的id启动
  6.        String processDefinitionId = "myProcess_1:6:904";
  7.         ProcessInstance processInstance = processEngine.getRuntimeService().startProcessInstanceById(processDefinitionId);
  8.         System.out.println(processInstance.getId());
  9. }

8.2 方式二：根据流程定义的key启动（自动选择最新版本的流程定义启动流程实例）

  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         //方式二：根据流程定义的key启动（自动选择最新版本的流程定义启动流程实例）
  6.         String processDefinitionKey = "myProcess_1";
  7.         ProcessInstance processInstance = processEngine.getRuntimeService().startProcessInstanceByKey(processDefinitionKey);
  8.         System.out.println(processInstance.getId());
  9.     }

9.查询流程实例列表，查询act_ru_execution表

  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         //流程实例查询对象，查询act_ru_execution表
  6.         ProcessInstanceQuery query = processEngine.getRuntimeService().createProcessInstanceQuery();
  7.         query.processDefinitionKey("myProcess_1");
  8.         query.orderByProcessDefinitionId().desc();
  9.         query.listPage(0, 3);
  10.         List<ProcessInstance> list = query.list();
  11.         for (ProcessInstance pi : list) { 
  12.             System.out.println(pi.getId() + "--" + pi.getActivityId());
  13.         }
  14.     }

10.结束流程实例

操作的表：act_re_excution,act_ru_task

  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         String processInstanceId = "1601";
  6.         processEngine.getRuntimeService().deleteProcessInstance(processInstanceId, "不想要了");
  7.     }

11.查询任务列表

  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         //任务查询对象，查询任务表 act_ru_task表
  6.         TaskQuery query = processEngine.getTaskService().createTaskQuery();
  7.         //按照办理人进行过滤
  8.         String assignee = "李四";
  9.         query.taskAssignee(assignee);
  10.         query.orderByTaskCreateTime().desc();
  11.         List<Task> list = query.list();
  12.         for (Task task : list) { 
  13.             System.out.println(task.getId());
  14.         }
  15.     }

12.办理任务

  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         String taskId = "1404";
  6.         processEngine.getTaskService().complete(taskId);
  7.     }

13.直接将流程向下执行一步

  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         String executionId = "1401"; //流程实例id
  6.         processEngine.getRuntimeService().signal(executionId);
  7.     }

14.查询最新版本的流程定义列表

  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         ProcessDefinitionQuery query = processEngine.getRepositoryService().createProcessDefinitionQuery();
  6.         query.orderByProcessDefinitionVersion().asc();
  7.         List<ProcessDefinition> list = query.list();
  8.         Map<String, ProcessDefinition> map = new HashMap<>();
  9.         for (ProcessDefinition pd : list) { 
  10.             map.put(pd.getKey(),pd);
  11.         }
  12.         System.out.println(map);
  13.     }

15.流程的修改

流程的修改：添加新的流程版本，如果已经在执行的流程，按照原来的流程继续执行。新的流程按照最新版本进行执行。

16.历史数据查询

16.1 查询历史流程实例列表

查询历史流程实例列表 act_hi_procinst

  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         HistoricProcessInstanceQuery query = processEngine.getHistoryService().createHistoricProcessInstanceQuery();
  6.         List<HistoricProcessInstance> list = query.list();
  7.         for (HistoricProcessInstance hi : list) { 
  8.             System.out.println(hi.getId());
  9.         }
  10.     }
16.2 查询历史活动数据

查询历史活动数据 act_hi_actinst 包括任务和事件

  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         HistoricActivityInstanceQuery query = processEngine.getHistoryService().createHistoricActivityInstanceQuery();
  6.         //按照流程实例排序
  7.         query.orderByProcessInstanceId().desc();
  8.         query.orderByHistoricActivityInstanceEndTime().asc();
  9.         List<HistoricActivityInstance> list = query.list();
  10.         for (HistoricActivityInstance hi : list) { 
  11.             System.out.println(hi.getActivityId() + "——" + hi.getActivityName() + "——" + hi.getActivityType());
  12.         }
  13.     }
16.3 查询历史任务数据

查询历史任务数据 act_hi_taskinst 单纯的只有任务

  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         HistoricTaskInstanceQuery query = processEngine.getHistoryService().createHistoricTaskInstanceQuery();
  6.         query.orderByProcessInstanceId().asc();
  7.         query.orderByHistoricTaskInstanceEndTime().asc();
  8.         List<HistoricTaskInstance> list = query.list();
  9.         for (HistoricTaskInstance hi:list){ 
  10.             System.out.println(hi.getAssignee()+"——"+hi.getName()+"——"+hi.getStartTime());
  11.         }
  12.     }

九、流程变量

在流程执行或者任务执行的过程中，用于设置和获取变量，使用流程变量在流程传递的过程中传递业务参数。

对应的表：
act_ru_variable：正在执行的流程变量表
act_hi_varinst：流程变量历史表

流程变量图解

img

流程变量.png

1.设置流程变量

1.1 在启动流程实例时设置
  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         String processDefinitionKey = "variable";
  6.         Map<String, Object> variables = new HashMap<>();
  7.         variables.put("key1", "value1");
  8.         variables.put("key2", 200);
  9.         ProcessInstance processInstance = processEngine.getRuntimeService().startProcessInstanceByKey(processDefinitionKey, variables);
  10.         System.out.println(processInstance.getId());
  11.     }
1.2 在办理任务时设置流程变量
  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         String taskId = "1206";
  6.         Map<String, Object> variables = new HashMap<>();
  7.         variables.put("user", new User(1, "小王"));
  8.         processEngine.getTaskService().complete(taskId, variables);
  9.     }
1.3 使用RuntimeService的方法设置
  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         String excutionId = "601";//流程实例Id
  6.         String variableName = "key3";
  7.         String value = "value3";
  8.         processEngine.getRuntimeService().setVariable(excutionId, variableName, value);
  9.     }
1.4 使用TaskService的方法设置
  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         String taskId = "704";
  6.         Map<String, Object> variables = new HashMap<>();
  7.         variables.put("key4", 400);
  8.         variables.put("k5", "v5");
  9.         processEngine.getTaskService().setVariables(taskId, variables);
  10.     }

2.流程变量支持的类型

Jdk中提供的数据类型（String、Integer、List 、Map…）
自定义的实体类（要求实现序列化接口），在variable表中只存bytearray_id 实例化内容存在bytearray表中。

3.获取流程变量

3.1 使用RuntimeService的方法获取
  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         String executionId = "1201";
  6.         Map<String, Object> variables = processEngine.getRuntimeService().getVariables(executionId);
  7.         System.out.println(variables);
  8.         Set<String> set = variables.keySet();//key2 key1 user
  9.         for (String key : set) { 
  10.             Object val = variables.get(key);
  11.             System.out.println(key + "=" + val);
  12.         }
  14.         //根据一个key获得一个value
  15.         Object value = processEngine.getRuntimeService().getVariable(executionId, "user");
  16.         System.out.println(value);
  18.         Collection<String> variableNames = new ArrayList<>();
  19.         variableNames.add("key2");
  20.         variableNames.add("user");
  21.         Map<String, Object> map = processEngine.getRuntimeService().getVariables(executionId, variableNames);
  22.         System.out.println(map);
3.2 使用TaskService的方法获取
  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         String taskId = "1305";
  6.         Map<String, Object> variables = processEngine.getTaskService().getVariables(taskId);
  7.     }

十、任务的类型

1.个人任务

由某一个负责办理，在任务表中通过assignee字段记录。

2.公共任务（组任务）

当前的任务可以由多个人其中的某一个人办理， 可以在设计流程图时指定多个办理人。Candidate Users 候选用户

img

公共任务图示.png

2.1 查询公共任务列表
  1. @Test
  2.     public void test() { 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         TaskQuery query = processEngine.getTaskService().createTaskQuery();
  6.         // 根据候选人过滤
  7.         String candidateUser = "李四";
  8.         query.taskCandidateUser(candidateUser);
  9.         List<Task> list = query.list();
  10.         for (Task task:list){ 
  11.             System.out.println(task.getName());
  12.         }
  13.     }
2.2 拾取公共任务（将公共任务变为个人任务）
  1. @Test
  2.     public void test(){ 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         String taskId="1602";
  6.         String userId="王五";
  7.         processEngine.getTaskService().claim(taskId,userId);
  8.     }
2.3 退回任务（将个人任务重新变为公共任务）
  1. @Test
  2.     public void test(){ 
  3.         //使用默认配置文件创建流程引擎
  4.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5.         String taskId="1602";
  6.         processEngine.getTaskService().setAssignee(taskId,null);
  7.     }

3.接受任务

接收任务不是由某个人负责办理，通过signal方法让流程执行的

img

接收任务图示.png

  1. /** * 处理接收任务 */
  2.     @Test
  3.     public void test() { 
  4.         //使用默认配置文件创建流程引擎
  5.         ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  6.         String excutionId = "2501";
  7.         processEngine.getRuntimeService().signal(excutionId);
  8.     }

十一、监听器（Listener）

1.执行监听器

监听流程实例的事件

第一步：按照框架的规则编写监听器类

  1. import org.activiti.engine.delegate.DelegateExecution;
  2. import org.activiti.engine.delegate.ExecutionListener;
  4. /** * @author Hiseico * @create 2018-06-07 16:41 * @desc 自定义执行监听器 **/
  5. public class MyExcutionListener implements ExecutionListener { 
  6.     //当监听事件发生时执行此方法
  7.     @Override
  8.     public void notify(DelegateExecution delegateExecution) throws Exception { 
  9.         System.out.println("自定义的监听器执行。。。2");
  10.     }
  11. }

第二步：设计流程图，注册监听器类

img

执行监听器设置图示.png

第三步：启动流程实例，Activiti框架通过反射调用监听器类

2.任务监听器

监听任务事件

第一步：按照activiti框架的规则编写一个任务监听器类

  1. import org.activiti.engine.delegate.DelegateTask;
  2. import org.activiti.engine.delegate.TaskListener;
  4. import java.util.Set;
  6. /** * @author Hiseico * @create 2018-06-07 17:10 * @desc 自定义任务监听器 **/
  7. public class MyTaskListener implements TaskListener { 
  8.     /** * 监听任务事件 * * @param delegateTask */
  9.     @Override
  10.     public void notify(DelegateTask delegateTask) { 
  11.         //任务办理人
  12.         String assignee = delegateTask.getAssignee();
  13.         //任务名称
  14.         String eventName = delegateTask.getEventName();
  15.         //事件名称
  16.         String name = delegateTask.getName();
  17.         //流程实例Id
  18.         String processInstanceId = delegateTask.getProcessInstanceId();
  19.         //获取当前流程实例范围内的所有流程变量的名字
  20.         Set<String> variableNames = delegateTask.getVariableNames();
  21.         for (String key : variableNames) { 
  22.             Object value = delegateTask.getVariable(key);
  23.             System.out.println(key + " = " + value);
  24.         }
  25.         System.out.println("一个["+name+"]任务被创建了，由["+assignee+"]负责办理");
  26.     }
  27. }

第二步：注册监听类

img

注册任务监听器图示.png

第三步：办理任务，由框架通过反射调用监听器类

十二、网关

1.排他网关（ExclusiveGateway）

用来在流程中实现决策。当流程执行到排他网关，所有数据就会被执行一遍，满足条件的就会让流程继续运行。需要注意的是：排他网关只会选择一条满足条件的执行。

第一步：设计流程图，使用排他网关

img

设置排他网关图示.png

第二步：执行流程，由框架根据设置的流程变量选择执行其中的一个分支，在分支的线上设置参数：Condition:#{bxje>200}

第三步：办理业务

  1. /** * 办理任务，设置流程变量 */
  2.     @Test
  3.     public void test() { 
  4.         String taskId = "802";
  5.         Map<String, Object> variables = new HashMap<>();
  6.         variables.put("bxje",600);//排他网关会自动判断 bxje 变量的值，选择执行分支
  7.         processEngine.getTaskService().complete(taskId,variables);
  8.     }

2.并行网关（ParallelGateway）

它允许将流程分成多条分支，也可以把多条分支汇聚成一条。

分支：经过并行网关的所有流，都会并行执行

汇聚：等所有流都到达并行网关之后，流程才会通过并行网关。

并行网关，没有条件判断。流程通过网关之后，有几条分支，就会有几个执行对象同时执行。需要注意的是：并行网关一定是成对出现的，有分支也有汇聚。

img

并行网关图示.png

十三、Spring整合Activiti

第一步：提供spring配置文件，配置数据源、事务管理器、流程引擎配置对象、流程引擎对象
appplicationContext.xml

  1. <beans xmlns="http://www.springframework.org/schema/beans"
  2.        xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx"
  3.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.        xsi:schemaLocation="http://www.springframework.org/schema/beans
  5.                         http://www.springframework.org/schema/beans/spring-beans.xsd
  6.                         http://www.springframework.org/schema/context 
  7.                         http://www.springframework.org/schema/context/spring-context-2.5.xsd
  8.                         http://www.springframework.org/schema/tx 
  9.                         http://www.springframework.org/schema/tx/spring-tx-3.0.xsd">
  10.     <!--配置数据源-->
  11.     <bean id="ds" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
  12.         <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
  13.         <property name="url" value="jdbc:mysql:///activiti"/>
  14.         <property name="username" value="root"/>
  15.         <property name="password" value=""/>
  16.     </bean>
  18.     <!--事务管理器-->
  19.     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  20.         <property name="dataSource" ref="ds"/>
  21.     </bean>
  23.     <!--配置一个Spring提供的对象，用于创建一个流程引擎配置对象-->
  24.     <bean id="processEngineConfiguration" class="org.activiti.spring.SpringProcessEngineConfiguration">
  25.         <property name="transactionManager" ref="transactionManager"/>
  26.         <property name="dataSource" ref="ds"/>
  27.         <!--自动建表的配置-->
  28.         <property name="databaseSchemaUpdate" value="true"/>
  29.     </bean>
  31.     <!--创建流程引擎对象-->
  32.     <bean id="processEngine" class="org.activiti.spring.ProcessEngineFactoryBean">
  33.         <property name="processEngineConfiguration" ref="processEngineConfiguration"/>
  34.     </bean>
  35. </beans>

第二步：在Java程序中读取spring配置文件，创建spring工厂，获取流程引擎对象

  1. public class SpringActivitiTest { 
  2.     @Test
  3.     public void test() { 
  4.         ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring/applicationContext.xml");
  5.        ProcessEngine processEngine = (ProcessEngine) applicationContext.getBean("processEngine");
  6.         DeploymentBuilder deploymentBuilder = processEngine.getRepositoryService().createDeployment();
  7.         deploymentBuilder.addClasspathResource("spring/variable.bpmn");
  8.         Deployment deployment = deploymentBuilder.deploy();
  9.     }
  10. }

作者：Hiseico

链接：https://www.jianshu.com/p/33085a975e47

来源：简书

发表评论

表情：
评论列表 （有 0 条评论，287人围观）

还没有评论，来说两句吧...

相关阅读

    相关 Activiti工作流

    秋招结束，幸运得以经验的前辈指点和同龄伙伴互助，拿到满意offer.社会很残酷，但是让我欲望和动力空前膨胀。这是一个全新的阶段，现当跟随科技最前沿，把技术做到深入层次，把前端熟

    柔情只为你懂柔情只为你懂/ 0 赞/ 390 阅读

    相关 Activity工作流

    内容安排： 1. 工作流概念 2. 常见的工作流框架 3. 在eclipse中安装activiti框架的流程设计器插件 4. activiti框架提供的数据库表结构

    忘是亡心i忘是亡心i/ 0 赞/ 540 阅读

    相关 详析工作流Activity5.13

    详析工作流Activity5.13 一、了解工作流 工作流(Workflow)，就是“业务过程的部分或整体在计算机应用环境下的自动化”，它主要解决的是“使在多个参与

    野性酷女野性酷女/ 0 赞/ 288 阅读

    相关 activiti工作流总结

    一 概念 1 工作流(Workflow)，就是“业务过程的部分或整体在计算机应用环境下的自动化”，它主要解决的是“使在多个参与者之间按照某种预定义的规则传递文档、信息或任务的

    怼烎@怼烎@/ 0 赞/ 546 阅读