工作流（activiti）

---

工作流简介

业务过程的部分或整体在计算机应用环境下的自动化
工作流就是多个参与者，按照某种预定义的规则，传递业务信息，进行审核的功能一个框架（activiti）

核心

23张表

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

7个Service

RepositoryService：管理流程定义。是Activiti的仓库服务类。所谓的仓库指流程定义文档的两个文件：bpmn文件和流程图片。
RuntimeService：执行管理，包括启动、推进、删除流程实例等操作。是activiti的流程执行服务类。可以从这个服务类中获取很多关于流程执行相关的信息。
TaskService：任务管理。是activiti的任务服务类。可以从这个类中获取任务的信息。
HistoryService：历史管理(执行完的数据的管理)。是activiti的查询历史信息的类。在一个流程执行完成后，这个对象为我们提供查询历史信息。
IdentityService：组织机构管理。
FormService：一个可选服务，任务表单管理。

示例使用的流程：

创建Activiti 流程引擎的两种方式

第一种
采用java代码的方式,设置连接数据库，创建工作流核心对象，ProcessEngine

ProcessEngineConfiguration configuration = ProcessEngineConfiguration.createStandaloneProcessEngineConfiguration();
// 连接数据库配置
configuration.setJdbcDriver("com.mysql.jdbc.Driver");
configuration.setJdbcUrl("jdbc:mysql://localhost:3306/activiti_db2");
configuration.setJdbcUsername("root");
configuration.setJdbcPassword("123456");// 是否自动创建23张核心表
// DB_SCHEMA_UPDATE_CREATE_DROP 先删除表再创建表
// DB_SCHEMA_UPDATE_FALSE 不能自动创建表，需要表存在
// DB_SCHEMA_UPDATE_TRUE 如果表不存在，自动创建表
configuration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);// 创建工作流核心对象，ProcessEngine对象
ProcessEngine processEngine = configuration.buildProcessEngine();// 验证是否创建成功
System.out.println(processEngine);

第二种
采用配置文件的方式连接数据库，配置文件的名称一定为 activiti.cfg.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd"><bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration"><property name="jdbcDriver" value="comg.mysql.jdbc.Driver" /><property name="jdbcUrl" value="jdbc:mysql://localhost:3306/activiti_db2" /><property name="jdbcUsername" value="root" /><property name="jdbcPassword" value="123456" /><!-- 是否自动创建表结构 --><property name="databaseSchemaUpdate" value="true"/></bean>
</beans>

java文件中使用

// 加载配置文件创建ProcessEngine对象
ProcessEngine processEngine = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml").buildProcessEngine();// 验证是否创建成功
System.out.println(processEngine);

或者

// 使用ProcessEngines的getDefaultProcessEngine() 方法会自动加载classpath下面的activiti.cfg.xml文件
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();// 验证是否创建成功
System.out.println(processEngine);

部署流程定义

processEngine 为
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

// 与流程定义和部署有关的Service
RepositoryService repositoryService = processEngine.getRepositoryService();// 创建流程部署对象
DeploymentBuilder deployment = repositoryService.createDeployment();
// 流程部署名称
deployment.name("这是我的测试环境");//使用zip格式文件完成部署
// ZipInputStream zipInputStream = new ZipInputStream(this.getClass().getClassLoader().getResourceAsStream("diagrams/decision.zip"));
// deployment.addZipInputStream(zipInputStream);// 加载部署资源文件，一次只能加载一个
deployment.addInputStream("decision.bpmn", this.getClass().getClassLoader().getResourceAsStream("diagrams/decision.bpmn"));
deployment.addInputStream("decision.png", this.getClass().getClassLoader().getResourceAsStream("diagrams/decision.png"));
deployment.category("投决流程");
// 完成部署
Deployment deploy = deployment.deploy();System.out.println("流程实例ID：" + deploy.getId());
System.out.println("流程实例名称：" + deploy.getName());
System.out.println("流程实例分类：" + deploy.getCategory());
System.out.println("流程实例开始时间：" + deploy.getDeploymentTime());

启动流程实例

// 启动流程实例有两种方式
// 1、通过流程实例ID
// 2、通过流程实例KEY
// 使用KEY的好处 : 自动使用最新版本的流程实例
String ProcessInstanceByKey = "decisionProcessId";
RuntimeService runtimeService = processEngine.getRuntimeService();
runtimeService.startProcessInstanceByKey(ProcessInstanceByKey);

查询流程实例

RepositoryService repositoryService = processEngine.getRepositoryService();
List<ProcessDefinition> list = repositoryService.createProcessDefinitionQuery()//查询条件，可以点出来.orderByDeploymentId().asc().list();
if (list != null && list.size() > 0) {for (ProcessDefinition definition : list) {System.out.println("流程定义ID：" + definition.getId());//流程定义的KEY+版本+随机生成的数System.out.println("流程定义名称：" + definition.getName());//与bpmn文件的name属性相对应System.out.println("流程定义KEY：" + definition.getKey());//与bpmn文件的id属性相对应System.out.println("流程定义版本：" + definition.getVersion());System.out.println("流程部署ID：" + definition.getDeploymentId());System.out.println("资源名称BPMN文件：" + definition.getResourceName());System.out.println("流程部署资源名称：" + definition.getDiagramResourceName());System.out.println("##############################################################");}
}

流程定义的KEY相同 Version从 1 开始升级

删除流程定义

RepositoryService repositoryService = processEngine.getRepositoryService();
// 不带级联删除，只能删除没有启动的流程，如果流程启动就会抛出异常
// repositoryService.deleteDeployment("1101");// 带级联删除，不管流程是否启动，都可以删除
// 参数：（流程实例ID，是否级联）deleteDeployment("1101") == deleteDeployment("1101", false)
repositoryService.deleteDeployment("1101", true);

保存流程实例资源图片

// 部署实例ID
String deployId = "301";
RepositoryService repositoryService = processEngine.getRepositoryService();// 获取资源名称
String resourceName = "";
List<String> list = repositoryService.getDeploymentResourceNames(deployId);
if (list != null && list.size() > 0) {for (String name : list) {if (name.lastIndexOf(".png") >= 0) {resourceName = name;break;}}
}InputStream resourceAsStream = repositoryService.getResourceAsStream(deployId, resourceName);// 把图片写入到指定的文件中
// org.apache.commons.io.FileUtils
FileUtils.copyInputStreamToFile(resourceAsStream, new File("D:\\" + resourceName));