Activiti5工作流笔记三
时间:2022-07-24
本文章向大家介绍Activiti5工作流笔记三,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
组任务
直接指定办理人
流程图如下:
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.task.IdentityLink;
import org.activiti.engine.task.Task;
import org.junit.Test;
public class Task3Test {
@Test
public void testDeploy(){
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
processEngine.getRepositoryService()
.createDeployment()
.addClasspathResource("com/itheima10/activiti/task/task3.bpmn")
.deploy();
}
/*
* 当启动完流程实例以后,进入了电脑维修的任务
* <userTask id="电脑维修" name="电脑维修" activiti:candidateUsers="工程师1,工程师2,工程师3"></userTask>
* 所以在
* act_ru_identitylink
* 当当前任务结束以后,任务的候选人就从这里删除了
* act_hi_identitylink
* 这两张表中分别对应的数据工程师1有两个
* taskId:工程师1
* piid:工程师1
*/
@Test
public void testStartPI(){
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
processEngine.getRuntimeService()
.startProcessInstanceById("task3:1:1704");
}
/**
* 根据候选人查询组任务
*/
@Test
public void testQueryTaskByCandidate(){
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
List<Task> tasks = processEngine.getTaskService()
.createTaskQuery()
.taskCandidateUser("工程师1")
.list();
for (Task task : tasks) {
System.out.println(task.getName());
}
}
/**
* 根据组任务查看任务的候选人
*/
@Test
public void testQueryCandidateByTask(){
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
List<IdentityLink> identityLinks = processEngine.getTaskService()
.getIdentityLinksForTask("1804");
for (IdentityLink identityLink : identityLinks) {
System.out.println(identityLink.getUserId());
}
}
/**
* 候选人认领任务
*/
@Test
public void testClaimTask(){
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
processEngine.getTaskService()
.claim("1804","工程师1");
}
@Test
public void testFinishTask(){
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
processEngine.getTaskService()
.complete("1804");
}
}
使用类
流程图:
package com.itheima10.activiti.task;
import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.TaskListener;
public class MyTask4Listener implements TaskListener{
@Override
public void notify(DelegateTask delegateTask) {
// TODO Auto-generated method stub
/**
* 组任务的候选人应该来自于数据库的某一张表
*/
delegateTask.addCandidateUser("张三");
delegateTask.addCandidateUser("王五");
/**
* 直接把一个组赋值给一个任务的候选人
*/
delegateTask.addCandidateGroup("2201");// 参数为groupid
}
}
package com.itheima10.activiti.identity;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.Group;
import org.activiti.engine.identity.User;
import org.activiti.engine.impl.persistence.entity.GroupEntity;
import org.activiti.engine.impl.persistence.entity.UserEntity;
import org.junit.Test;
public class IdentityTest {
@Test
public void testIdentity(){
//创建组
Group group = new GroupEntity();
group.setName("咨询组");
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
processEngine.getIdentityService()
.saveGroup(group);
//创建组员
User user1 = new UserEntity();
user1.setId("咨询员1");
User user2 = new UserEntity();
user2.setId("咨询员2");
processEngine.getIdentityService().saveUser(user1);
processEngine.getIdentityService().saveUser(user2);
//建立组员与组的关系
processEngine.getIdentityService().createMembership(user1.getId(), group.getId());
processEngine.getIdentityService().createMembership(user2.getId(), group.getId());
}
@Test
//根据组ID删除组
public void testDeleteGroup(){
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
processEngine.getIdentityService()
.deleteGroup("2201");
}
}
package com.itheima10.activiti.task;
import java.util.List;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.task.IdentityLink;
import org.activiti.engine.task.Task;
import org.junit.Test;
public class Task4Test {
@Test
public void testDeploy(){
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
processEngine.getRepositoryService()
.createDeployment()
.addClasspathResource("com/itheima10/activiti/task/task4.bpmn")
.deploy();
}
@Test
public void testStartPI(){
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
processEngine.getRuntimeService()
.startProcessInstanceById("task4:1:2004");
}
}
相关表:
act_id_group 组
act_id_membership 组员
连线
之前的流程图都是错的,只是为了演示如何快速使用,下面通过连线学习如何画一个正确的流程图
例子1:
package com.itheima10.activiti.sequenceFlow;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.impl.persistence.entity.ProcessDefinitionEntity;
import org.activiti.engine.impl.pvm.PvmTransition;
import org.activiti.engine.impl.pvm.process.ActivityImpl;
import org.junit.Test;
public class SequenceFlowTest {
@Test
public void testDeploy(){
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
processEngine.getRepositoryService()
.createDeployment()
.addClasspathResource("com/itheima10/activiti/sequenceFlow/sequenceflow.bpmn")
.deploy();
}
@Test
public void testStartPi(){
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
processEngine.getRuntimeService()
.startProcessInstanceById("sequenceflow:2:3604");
}
/*
* 完成请假申请的任务
*/
@Test
public void testFinisTask(){
Map<String, Object> variables = new HashMap<String, Object>();
variables.put("day", 2);
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
processEngine.getTaskService()
.complete("3704",variables);
}
/**
* 完成部门经理审批的任务
*/
@Test
public void testFinisTask2(){
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
processEngine.getTaskService()
.complete("3803");//请假天数2天,直接审批通过
}
/**
* 获取部门经理审批节点的出处有几个,每一个的名称
*/
@Test
public void testGetOutGoing(){
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
/**
* ProcessDefinitionEntity 流程定义对象
*/
ProcessDefinitionEntity processDefinitionEntity = (ProcessDefinitionEntity)processEngine.getRepositoryService()
.getProcessDefinition("sequenceflow:2:3604");
/**
* 根据流程定义对象中的某一个节点的id的值,就可以得到该节点的ActitityImpl(节点对象)
*/
ActivityImpl activityImpl = processDefinitionEntity.findActivity("部门经理审批");
/**
* 该节点对象有多少sequenceFlow
*/
List<PvmTransition> pvmTransitions = activityImpl.getOutgoingTransitions();
for (PvmTransition pvmTransition : pvmTransitions) {
System.out.println(pvmTransition.getId());//输出sequenceFlow的id的值
System.out.println(pvmTransition.getDestination());//输出sequenceFlow的目标节点
}
}
}
例子2:
package com.itheima10.activiti.sequenceFlow;
import java.util.HashMap;
import java.util.Map;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.junit.Test;
public class SequenceFlow2Test {
@Test
public void testDeploy(){
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
processEngine.getRepositoryService()
.createDeployment()
.addClasspathResource("com/itheima10/activiti/sequenceFlow/sequenceflow2.bpmn")
.deploy();
}
@Test
public void testStartPi(){
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
processEngine.getRuntimeService()
.startProcessInstanceById("sequence2:1:4004");
}
@Test
public void testFinishTask(){
Person person = new Person();
person.setDay(2);
Map<String, Object> variables = new HashMap<String, Object>();
variables.put("person", person);
variables.put("day", 1);
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
processEngine.getTaskService()
.complete("4104", variables);
}
}
接收活动(receiveTask,即等待活动)
不需要审批的流程,例如审批后的归档操作
例子:
package com.itheima10.activiti.receivetask;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.junit.Test;
/**
* receiveTask不需要人工干预,不需要审批,直接把当前的事情做完以后,流向下一个节点即可
* @author zd
*
*/
public class ReceiveTaskTest {
@Test
public void testDeploy(){
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
processEngine.getRepositoryService()
.createDeployment()
.addClasspathResource("com/itheima10/activiti/receivetask/receivetask.bpmn")
.deploy();
}
@Test
/**
* act_ru_task表中不会有新的记录,因为不需要人审批此流程
* 在act_ru_execution表中可以看到当前流程实例
*/
public void testStartPI(){
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
processEngine.getRuntimeService()
.startProcessInstanceById("receive:1:4304");
}
@Test
public void testNextNode(){
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
processEngine.getRuntimeService()
/**
* 给当前的流程实例发一个信号:往下一个节点走
*/
.signal("4401");
}
}
- [mobile开发碎碎念]手机页面上显示PDF文件
- Windows Server 2008 R2 配置AD(Active Directory)域控制器
- ios开发基础知识 - 2
- ios开发基础知识 - 1
- 为UINavigationBar添加自定义背景
- UIScrollView无法响应touches的解决方法
- WCF技术剖析之十七:消息(Message)详解(下篇)
- UITextView自动滚动的解决方案
- MVC解决Json DataGrid返回的日期格式是/Date(20130450000365)
- Easyui 让DataGrid适应浏览器宽度
- Easyui 让Window弹出居中与最大化后居中
- WCF技术剖析之十六:数据契约的等效性和版本控制
- 构建ASP.NET MVC4+EF5+EasyUI+Unity2.x注入的后台管理系统(13)-系统日志和异常的处理③
- 构建ASP.NET MVC4+EF5+EasyUI+Unity2.x注入的后台管理系统(12)-系统日志和异常的处理②
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 在Pytorch中使用Mask R-CNN进行实例分割操作
- PHP类的自动加载机制实现方法分析
- strpos() 函数判断字符串中是否包含某字符串的方法
- Laravel框架基于ajax和layer.js实现无刷新删除功能示例
- 详解php伪造Referer请求反盗链资源
- Laravel框架基于ajax实现二级联动功能示例
- django haystack实现全文检索的示例代码
- 基于Python下载网络图片方法汇总代码实例
- 基于pytorch中的Sequential用法说明
- pytorch VGG11识别cifar10数据集(训练+预测单张输入图片操作)
- tp5(thinkPHP5)框架数据库Db增删改查常见操作总结
- PHP基于cookie实现统计在线人数功能示例
- PHP实现对数字分隔加千分号的方法
- PHP验证类的封装与使用方法详解
- Laravel框架实现的rbac权限管理操作示例