SpringBoot 结合Activiti 进行单条实例工作流审批
1.建立maven项目,引入maven依赖
#因为我的项目单独引入了mybatis-plus所以这里对activiti排除一下mybatis的依赖
<dependency><groupId>org.activiti</groupId><artifactId>activiti-engine</artifactId><version>7.1.0.M6</version><exclusions><exclusion><groupId>org.mybatis</groupId><artifactId>mybatis</artifactId></exclusion></exclusions>
</dependency>
<dependency><groupId>org.activiti</groupId><artifactId>activiti-image-generator</artifactId><version>7.1.0.M6</version>
</dependency>
<dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId>
</dependency>
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.27</version>
</dependency>
<dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.4.2</version>
</dependency>
<dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.2.8</version>
</dependency>
logging:level:#日志输出org.activiti.engine.impl.persistence.entity: trace
2.我使用的是idea,所以需要引入插件,如果是eclipse也需要引入插件,在我之前的文章里有记录
3.使用idea的插件画一下流程图
idea对activiti的兼容性不如eclipse方便
3.1 右键创建文件
3.2创建一个文件后,在文件内部继续右击
3.3 出现画图的小页面,继续在小页面里边右击
3.4 流程指向 status 用于后边审批时候的条件
3.5 流程审批人 用于后边代码赋值
3.6 排他网关
4.增加Activiti的配置文件
import com.alibaba.druid.pool.DruidDataSource;
import org.activiti.engine.*;
import org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration;
import org.activiti.engine.impl.history.HistoryLevel;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.DependsOn;import javax.sql.DataSource;@Configuration
public class ActivitiConfig {/*** 数据源* @return*/@ConfigurationProperties(prefix = "spring.datasource")@Beanpublic DataSource dataSource(){return new DruidDataSource();}/*** 工作流流程引擎配置文件* @param dataSource* @return*/@Beanpublic ProcessEngineConfiguration processEngineConfiguration(DataSource dataSource){StandaloneProcessEngineConfiguration standaloneProcessEngineConfiguration = new StandaloneProcessEngineConfiguration();standaloneProcessEngineConfiguration.setDataSource(dataSource);//自动更新表结构,数据库表不存在时会自动创建表standaloneProcessEngineConfiguration.setDatabaseSchemaUpdate("true");//保存历史数据级别设置为full最高级别,便于历史数据的追溯standaloneProcessEngineConfiguration.setHistoryLevel(HistoryLevel.FULL);//关闭activiti自动部署(使用流程设计器部署,不使用具体文件访问方式)standaloneProcessEngineConfiguration.setDbHistoryUsed(true);return standaloneProcessEngineConfiguration;}/*** 工作流流程引擎* @param processEngineConfiguration* @return*/@Beanpublic ProcessEngine processEngine(ProcessEngineConfiguration processEngineConfiguration){return processEngineConfiguration.buildProcessEngine();}@Bean@DependsOn("processEngine")public RepositoryService repositoryService(ProcessEngine processEngine){return processEngine.getRepositoryService();}@Bean@DependsOn("processEngine")public RuntimeService runtimeService(ProcessEngine processEngine){return processEngine.getRuntimeService();}@Bean@DependsOn("processEngine")public TaskService taskService(ProcessEngine processEngine){return processEngine.getTaskService();}@Bean@DependsOn("processEngine")public HistoryService historyService(ProcessEngine processEngine){return processEngine.getHistoryService();}
5.创建一个接收参数的实体类,参数自己定义就可以,根据实际情况来
@Data
public class ProcessParam {/*** 流程定义id*/String processDefinitionId;/*** 流程实例id*/String processInstanceId;/*** 任务id*/String taskId;/*** 流程定义key*/String deploymentKey;/*** 流程定义名称*/String deploymentName;/*** 用户名称*/String userName;/*** 用户名称批量 英文逗号间隔*/String userNames;/*** 审批意见*/String comment;/*** 职位*/String position;/*** 审批状态*/Integer status;/*** 抄送人*/List<ProcessParam> processParamList;
}
6.创建工作流资源方面的控制类
具体查询或增删改操作都需要根据实际业务进行改动,以下代码仅供参考
上传资源后会在ACT_RE_PROCDEF、ACT_RE_DEPLOYMENT、ACT_GE_BYTEARRAY表中生成信息,如果同一资源上传多次会在ACT_RE_PROCDEF表中的版本号字段加1,
@RestController
public class RepositoryController {@Autowiredprivate RepositoryService repositoryService;@ApiOperation("上传工作流资源")@PostMapping("/uploadRepository")public Map<String,Object> uploadRepository(@RequestParam String processName,MultipartFile file){Map<String,Object> resultMap = new HashMap<>();InputStream inputStream = null;try {inputStream = file.getInputStream();} catch (IOException e) {e.printStackTrace();}if(inputStream == null){resultMap.put("error","请上传文件");return resultMap;}boolean contains = file.getOriginalFilename().endsWith(".zip");if(!contains){resultMap.put("error","请上传压缩文件");return resultMap;}Deployment deployment = repositoryService.createDeployment().name(processName).addZipInputStream(new ZipInputStream(inputStream)).deploy();resultMap.put("data",deployment);return resultMap;}@ApiOperation("删除工作流资源")@GetMapping("/deleteRepository")public Map<String,Object> deleteRepository(@RequestParam String id){Map<String,Object> resultMap = new HashMap<>();try {repositoryService.deleteDeployment(id);} catch (Exception e) {e.printStackTrace();resultMap.put("error","删除失败");return resultMap;}resultMap.put("data","删除成功");return resultMap;}@ApiOperation("查询工作流资源")@GetMapping("/searchRepository")public Map<String,Object> searchRepository(ProcessParam param,@RequestParam(name = "page",defaultValue = "1") Integer page,@RequestParam(name = "size",defaultValue = "10") Integer size){Map<String,Object> resultMap = new HashMap<>();DeploymentQuery deploymentQuery = repositoryService.createDeploymentQuery();if(StringUtils.isNotEmpty(param.getProcessDefinitionId())){deploymentQuery.deploymentId(param.getProcessDefinitionId());}if(StringUtils.isNotEmpty(param.getDeploymentKey())){deploymentQuery.deploymentKeyLike(param.getDeploymentKey());}if(StringUtils.isNotEmpty(param.getDeploymentName())){deploymentQuery.deploymentNameLike(param.getDeploymentName());}List<Deployment> deployments = deploymentQuery.listPage(page, size);resultMap.put("data",deployments);return resultMap;}
}
7.创建工作流发起的控制类
工作流发起后会在ACT_RU_EXECUTION、ACT_RU_TASK、ACT_RU_IDENTITYLINK、ACT_RU_VARIABLE、ACT_HI_ACTINST、ACT_HI_DETAIL、ACT_HI_IDENTITYLINK、ACT_HI_PROCINST、ACT_HI_TASKINST、ACT_HI_VARINST生成数据,当工作流程结束后,对应的ACT_RU**系列表中对应数据会清空,在历史表中数据会完善
@RestController
public class RuntimeController {@Autowiredprivate RuntimeService runtimeService;@ApiOperation("根据流程定义id发起流程")@PostMapping("/startProcess")public Map<String,Object> startProcess(@RequestBody ProcessParam param){Map<String,Object> resultMap = new HashMap<>();if(param == null){resultMap.put("error","参数错误");return resultMap;}Map<String,Object> paramMap = new HashMap<>();paramMap.put("username",param.getUserName());paramMap.put("status",param.getStatus());ProcessInstance processInstance = runtimeService.startProcessInstanceById(param.getProcessDefinitionId(), paramMap);resultMap.put("data",processInstance);return resultMap;}@ApiOperation("根据流程定义id查看发起的流程实例")@GetMapping("/searchRunTime")public Object searchRunTime(@RequestParam String processDefinitionId){List<ProcessInstance> processInstanceList = runtimeService.createProcessInstanceQuery().processDefinitionId(processDefinitionId).list();return processInstanceList;}@ApiOperation("根据流程实例id删除工作流")@GetMapping("/deleteRunTime")public void deleteRunTime(@RequestParam String processInstanceId,@RequestParam(required = false) String deleteReason){runtimeService.deleteProcessInstance(processInstanceId,deleteReason);}
}
8.创建工作流审批控制类
@RestController
public class RuntimeController {@Autowiredprivate TaskService taskService;@ApiOperation("审批流程")@PostMapping("/approvalTask")public Map<String,Object> approvalTask(@RequestBody ProcessParam param){Map<String,Object> resultMap = new HashMap<>();if(param == null){resultMap.put("error","参数错误");return resultMap;}Map<String,Object> paramMap = new HashMap<>();paramMap.put("username",param.getUserName());paramMap.put("status",param.getStatus());//添加审批意见if(StringUtils.isNotEmpty(param.getComment())){taskService.addComment(param.getTaskId(),param.getProcessInstanceId(),param.getComment());}//添加抄送人if(param.getProcessParamList() != null && param.getProcessParamList().size() > 0){List<ProcessParam> processParamList = param.getProcessParamList();for (ProcessParam processParam : processParamList) {Task task = taskService.newTask();task.setAssignee(processParam.getUserName());task.setParentTaskId(param.getTaskId());task.setName(processParam.getPosition());taskService.saveTask(task);}}//进行审批try {taskService.complete(param.getTaskId(),paramMap);} catch (Exception e) {e.printStackTrace();resultMap.put("error","操作失败");return resultMap;}resultMap.put("data","审批成功");return resultMap;}@ApiOperation("查询用户未完成任务")@GetMapping("/searchTask")public Object searchTask(ProcessParam param){List<Task> list = taskService.createTaskQuery().taskAssigneeLike(param.getUserName()).list();return list;}@ApiOperation("删除已审批节点或审批信息")@GetMapping("/deleteTask")public void deleteTask(ProcessParam param){taskService.deleteTask(param.getTaskId());taskService.deleteComments(param.getTaskId(),param.getProcessInstanceId());}
}
9.创建查看历史信息控制类
创建mapper已经对应的xml
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.config.controller.mapper.ActivitiMapper"><select id="unfinishedProcessByUserName" resultType="java.lang.String">select DISTINCT ahp.PROC_INST_ID_ from ACT_HI_PROCINST ahp INNER JOIN ACT_HI_TASKINST aht on ahp.PROC_INST_ID_ = aht.PROC_INST_ID_ where aht.ASSIGNEE_ = #{userName} and ahp.END_TIME_ is null</select><select id="endProcessByUserName" resultType="java.lang.String">select DISTINCT ahp.PROC_INST_ID_ from ACT_HI_PROCINST ahp INNER JOIN ACT_HI_TASKINST aht on ahp.PROC_INST_ID_ = aht.PROC_INST_ID_ where aht.ASSIGNEE_ = #{userName} and ahp.END_TIME_ is not null</select>
</mapper>
public interface ActivitiMapper {Set<String> unfinishedProcessByUserName(@Param("userName") String userName);Set<String> endProcessByUserName(@Param("userName") String userName);
}
@RestController
public class HistoryController {@Autowiredprivate HistoryService historyService;@Autowiredprivate ActivitiMapper activitiMapper;@ApiOperation("根据用户名查询当前用户已审批,单据未完结的工作流信息")@GetMapping("/searchHistory")public Object searchHistory(@RequestParam String userName){Set<String> processByUserName = activitiMapper.unfinishedProcessByUserName(userName);List<HistoricProcessInstance> historicProcessInstances = historyService.createHistoricProcessInstanceQuery().processInstanceIds(processByUserName).list();return historicProcessInstances;}@ApiOperation("根据用户名查询已经完结的工作流信息")@GetMapping("/searchendHistory")public Object searchendHistory(@RequestParam String userName){Set<String> processByUserName = activitiMapper.endProcessByUserName(userName);List<HistoricProcessInstance> historicProcessInstances = historyService.createHistoricProcessInstanceQuery().processInstanceIds(processByUserName).list();return historicProcessInstances;}
}
10.导出工作流信息
@Controller
public class HistoryController {@Autowiredprivate RepositoryService repositoryService;@Autowiredprivate RuntimeService runtimeService;@GetMapping("/exportActiviti")public void exportActiviti(@RequestParam String processDefinitionId,@RequestParam String executionId,HttpServletResponse response) throws Exception {BpmnModel bpmnModel = repositoryService.getBpmnModel(processDefinitionId);List<String> activeActivityIds = runtimeService.getActiveActivityIds(executionId);ProcessDiagramGenerator processDiagramGenerator = new DefaultProcessDiagramGenerator();InputStream inputStream = processDiagramGenerator.generateDiagram(bpmnModel, activeActivityIds, activeActivityIds, "宋体", "宋体", "宋体", true,"png");OutputStream outputStream = response.getOutputStream();IOUtils.copy(inputStream,outputStream);outputStream.flush();inputStream.close();outputStream.close();}
}
SpringBoot 结合Activiti 进行单条实例工作流审批相关推荐
- SpringBoot 整合Activiti(二)——流程审批完整示例
前两天做了一个SpringBoot整合Activiti的完整示例,功能包括:退回/通过(节点条件).指定办理人.生成流程图.高亮显示已办节点.查询任务列表(办理人)等,下面先简单记录(含完整代码),十 ...
- Activiti工作流使用之SpringBoot整合Activiti
Activiti工作流使用之SpringBoot整合Activiti 文章目录 Activiti工作流使用之SpringBoot整合Activiti 一.springboot整合Activiti环境依 ...
- SpringBoot集成activiti工作流
SpringBoot集成activiti工作流(模拟请假流程) 链接:https://pan.baidu.com/s/10BT_Zertm1WBBrlrdE-QWQ 提取码:zsq6 学习视频地址见 ...
- 《Activiti/Flowable 深入BPM工作流》- Activiti 与springboot 怎么进行整合?
<Activiti/Flowable 深入BPM工作流> -Activiti 与springboot 怎么进行整合? 一.问题 Activiti 如何与springboot进行整合? 1 ...
- SpringBoot整合Activiti工作流
依赖: 新建springBoot项目时勾选activiti,或者在已建立的springBoot项目添加以下依赖: <dependency><groupId>org.activi ...
- 《Activiti/Flowable 深入BPM工作流》-流程实例怎么实现挂起?
<Activiti/Flowable 深入BPM工作流>-流程实例怎么实现挂起? 一. 问题 1. 什么情况要进行流程的挂起? 2. 具体怎么将流程挂起? 二. 详情 1. 什么情况 ...
- # SpringBoot 整合 Activiti 工作流框架
SpringBoot 整合 Activiti 工作流框架 Activiti 介绍 Activiti是一个开源的工作流引擎,它实现了BPMN 2.0规范,可以发布设计好的流程定义,并通过api进行流程调 ...
- Springboot 整合activiti及使用案例
Springboot整合activiti 6.0 下载源码请点击这里 一 导入依赖 <dependencies><!--Activiti工作流 start--><depe ...
- Activiti学习(一)之工作流的介绍和使用
什么是工作流 1. 工作流介绍 工作流(Workflow),就是通过计算机对业务流程自动化执行管理.它主要解决的是"使在多个参与者之间按照某种预定义的规则自动进行传递文档.信息或任务的过程, ...
最新文章
- python申明文件编码_Python源代码文件的文本编码
- 【python记录】使用ip摄像头 vlc打开rtsp服务 python远程调用摄像头记录过程
- K-D Tree学习笔记
- python学习中文第五版_前5个学习Python的网站
- 采用光线跟踪绘制场景 c++_光线追踪的相干性聚集:硬件光线追踪的优势
- (47)System Verilog数组排序
- 机动车辆保费计算器 1.1新版发布
- 工程数学(数值分析)第二讲:非线性方程求根
- Win7 64bit IIS无法访问ACCESS数据库解决方案
- React中的state和props有什么区别?
- javascript函数的参数类型
- WiFi密码破解之Aircrack实战演示
- ubuntu下opencv3和opencv2共存
- 猫途鹰公布2019年“旅行者之选”全球最佳海滩榜单
- Python练手项目之微信机器人、恢复被撤回的微信消息
- 倾斜摄影房屋轮廓线提取思路
- 包和工具(读书笔记)
- Unity Shader - Get Screen Pos
- 你在SOA实现中应用筒仓分析了吗?
- 只要有心,学好Linux并非难事
热门文章
- assertcontains php,PHP PHPUnit assertNotContainsOnly()用法及代码示例
- c++使用ado访问数据库
- LaTeX导入图片不失帧的方法
- AttributeError: module ‘labelme.utils‘ has no attribute ‘draw_label‘
- 华硕主板无盘启动bios设置_华硕影驰 bios设置,详细教您华硕主板bios如何设置U盘启动...
- Qubole评论:自助式大数据分析
- 小程序通过 ajax读取的图片数据如何展示_一个常被忽略的intouch的小技巧—鼠标悬停...
- 【一周头条盘点】中国软件网(2017.11.20~2017.11.24)
- 教务系统自动评教_教务系统一键评教教程
- python怎么找项目做小生意_三个投资小回报大的项目,让你没钱也能做买卖!