创建Activiti工作流主要包含以下几步：
1、定义流程，按照BPMN的规范，使用流程定义工具，用流程符号把整个流程描述出来
2、部署流程，把画好的流程定义文件，加载到数据库中，生成表的数据
3、启动流程，使用java代码来操作数据库表中的内容
-
部署操作
@Test
void testDepoYment(){
//1:创建ProcessEngine
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//2:获取RepositoryService
RepositoryService repositoryService = processEngine.getRepositoryService();
//3:使用Service进行流程部署,定义流程名字 把bpmn和png部署到数据库里面
Deployment deploy = repositoryService.createDeployment()
.name("出差申请流程")
.addClasspathResource("bmpn/evection.bpmn")
.addClasspathResource("bmpn/evection.png")
.deploy();
//4: 输出部署信息
System.out.println("流程部署的id"+deploy.getId());
System.out.println("流程部署的名称"+deploy.getName());
}
一次部署流程会操作三张表
-
act_re_deployment流程部署表，每部署一次就会新增一条记录 -
act_re_procdef流程定义表 生成流程定义信息 注意:act_re_deployment和act_re_procdef是一对多的关系 在procdef表中可以有多条记录，每条记录对应一个流程的定义信息-
启动流程实例
/**
* 启动流程实例
*/
@Test
void testStartProcess() {
//1:创建ProcessEngine
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//2:获取Run timeService activiti的流程运行管理类
RuntimeService runtimeService = processEngine.getRuntimeService();
//3:根据流程定义的id启动流程 id-> bpmn文件的名命id 也就是act_re_procdef 表中的key
ProcessInstance instance = runtimeService.startProcessInstanceByKey("myEvevtion");
//4:s数处内容
System.err.println("流程定义Id"+instance.getProcessDefinitionId());
System.err.println("流程实例Id"+instance.getId());
System.err.println("当前活动的id"+instance.getActivityId());
}
-
启动流程实例会操作四张表
act_re_deployment 流程部署表 每次部署都会添加进来数据
act_re_procdef 流程定义表
act_ge_bytearray 通用数据表 流程资源表
act_hi_actinst 流程实例执行历史
act_hi_actinst 流程参与者的历史信息
act_hi_procinst 流程实例的历史信息
act_hi_taskinst 任务的历史信息
act_ru_execution 流程执行的信息
act_ru_identitylink 流程参与者的信息
act_ru_task 任务信息
-
查询个人待执行的任务
/**
* 查询个人待执行的任务
*/
@Test
void testFindPersonalTaskList(){
//1:获取流程引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//2:使用TaskService acticviti的任务管理类
TaskService taskService = processEngine.getTaskService();
//3:根据流程的key 和人物的负责人 查询任务
List<Task> taskList = taskService.createTaskQuery()
// 流程的key
.processDefinitionKey("myEvevtion")
// 要查询的负责人
.taskAssignee("zhangsan")
.list();
//4:输出
for (Task task : taskList) {
System.out.println("流程实例id"+task.getProcessInstanceId());
System.out.println("任务id"+task.getId());
System.out.println("任务负责人"+task.getAssignee());
System.out.println("任务名称"+task.getName());
}
}
主要操作表
act_ru_task act_re_procdef
-
完成个人任务
/**
* 完成任务
*/
@Test
void completeTask() {
//1:获取流程引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//2:使用TaskService acticviti的任务管理类
TaskService taskService = processEngine.getTaskService();
// 根据任务id完成任务
taskService.complete("20fea024-a64e-11eb-8ccf-005056c00008");
}
主要操作表：
act_hi_taskinst INSERT
act_hi_actinst
act_hi_identitylink
act_ru_task
act_ru_identitylink
act_hi_taskinst UPDATE
act_ru_execution UPDATE
act_hi_actinst
act_ru_task
-
查询流程定义
/**
* 查询流程定义
*/
@Test
void queryProcessDefinition(){
// 获取流程引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
// 获取RepositoryService activiti的资源管理类
RepositoryService repositoryService = processEngine.getRepositoryService();
// createProcessDefinitionQuery
ProcessDefinitionQuery deploymentQuery = repositoryService.createProcessDefinitionQuery();
// 查询当前所有流程的定义
//processDefinitionKey(流程定义的key)
// 根据orderByProcessDefinitionVersion 进行排序
// decs 倒叙排序
// list 所有的内容
List<ProcessDefinition> myEvevtion = deploymentQuery.processDefinitionKey("myEvevtion").
orderByProcessDefinitionVersion().desc().list();
for (ProcessDefinition processDefinition : myEvevtion) {
System.out.println("流程定义的id:" +processDefinition.getId());
System.out.println("流程定义的名称:" +processDefinition.getName());
System.out.println("流程定义的key:" +processDefinition.getKey());
System.out.println("流程定义的版本:" +processDefinition.getVersion());
System.out.println("流程部署的id:" +processDefinition.getDeploymentId());
}
}
-
删除流程部署信息
历史信息不会被删除
/**
* 删除流程部署信息
*/
@Test
void deleteDeployMent() {
// 获取流程引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
// 获取RepositoryService activiti的资源管理类
RepositoryService repositoryService = processEngine.getRepositoryService();
// 通过部署的id来删除流程部署信息
String deployMentId = "7c90ab1b-a642-11eb-85c9-005056c00008";
repositoryService.deleteDeployment(deployMentId);
}
删除注意事项 :当前的流程如果没有完成,想要删除的话需要使用特殊方式 原理就是 级联删除
repositoryService.deleteDeployment(deployMentId, true);
主要操作表
act_re_deployment 流程部署表 每次部署都会删除
act_re_procdef 流程定义表
act_ge_bytearray 通用数据表 流程资源表
-
下载资源文件
/**
* 下载资源文件
* 方案1: 使用Activiti 提供的api 来下载文件，保存到文件目录还是要使用io操作
* 方案2: 自己写代码从数据库中下载文件 使用jdbc 对blob 类型 clob类型数据读取出来 保存到文件目录
* 解决Io 操作 commons-jo.jar
* 我们这里使用方案1 使用repositoryService
*/
@Test
void getDelpyMent() throws IOException {
// 获取流程引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
// 获取RepositoryService activiti的资源管理类
RepositoryService repositoryService = processEngine.getRepositoryService();
// // createProcessDefinitionQuery 查询流程定义
ProcessDefinitionQuery deploymentQuery = repositoryService.createProcessDefinitionQuery();
ProcessDefinition myEvevtion = deploymentQuery.processDefinitionKey("myEvevtion").
singleResult();
// 获取部署id 和资源名称
String deploymentId = myEvevtion.getDeploymentId();
String pngName = myEvevtion.getDiagramResourceName();
// 通过部署id 获取资源信息(png/bpmn) 获取照片的资源
InputStream pngInput = repositoryService.getResourceAsStream(deploymentId, pngName);
// 获取bpmn的流
String bpmnName = myEvevtion.getResourceName();
InputStream bpmnInput = repositoryService.getResourceAsStream(deploymentId, bpmnName);
// 构造OutputStream流
File pngFile = new File("E:\\test\\evectionflopw01.png");
File bpmmnFile = new File("E:\\test\\evectionflopw01.bpmn");
FileOutputStream pngFileStream = new FileOutputStream(pngFile);
FileOutputStream bpmmnFileStream = new FileOutputStream(bpmmnFile);
// 输入流，输出流转换
IOUtils.copy(pngInput, pngFileStream);
IOUtils.copy(bpmnInput, bpmmnFileStream);
//关闭流
pngFileStream.close();
bpmmnFileStream.close();
pngInput.close();
bpmnInput.close();
}
-
查询历史信息
/**
* 查询历史信息
*/
@Test
void findHistoryInfo(){
// 获取流程引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
// 获取HistoryService
HistoryService historyService = processEngine.getHistoryService();
//获取actinset包查询对象
HistoricActivityInstanceQuery instanceQuery = historyService.createHistoricActivityInstanceQuery();
// 条件根据 InstanceId 和 DefinitionId 条件不同
// instanceQuery.processInstanceId("20faf6a0-a64e-11eb-8ccf-005056c00008");
instanceQuery.processDefinitionId("myEvevtion:1:7ca5448e-a642-11eb-85c9-005056c00008");
//增加排序操作 根据开始时间排序 升序操作
instanceQuery.orderByHistoricActivityInstanceStartTime().asc();
// 查询所有内容
List<HistoricActivityInstance> historicActivityInstanceList = instanceQuery.list();
//输出
for (HistoricActivityInstance instance : historicActivityInstanceList) {
System.out.println(instance.getActivityId());
System.out.println(instance.getActivityName());
System.out.println(instance.getProcessDefinitionId());
System.out.println(instance.getProcessDefinitionId());
}
}
