百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术文章 > 正文

SpringBoot整合Activiti工作流(附源码)

ccwgpt 2024-11-01 11:31 28 浏览 0 评论

依赖:

新建springBoot项目时勾选activiti,或者在已建立的springBoot项目添加以下依赖:

<dependency>
????<groupId>org.activiti</groupId>
????<artifactId>activiti-spring-boot-starter-basic</artifactId>
????<version>6.0.0</version>
</dependency>

配置:

数据源和activiti配置:

server:
??port:?8081

spring:
??datasource:
????url:?jdbc:mysql://localhost:3306/act5?useSSL=true
????driver-class-name:?com.mysql.jdbc.Driver
????username:?root
????password:?root

??#?activiti?default?configuration
??activiti:
????database-schema-update:?true
????check-process-definitions:?true
????process-definition-location-prefix:?classpath:/processes/
#????process-definition-location-suffixes:
#??????-?**.bpmn
#??????-?**.bpmn20.xml
????history-level:?full

在activiti的默认配置中,process-definition-location-prefix 是指定activiti流程描述文件的前缀(即路径),启动时,activiti就会去寻找此路径下的流程描述文件,并且自动部署;suffix 是一个String数组,表示描述文件的默认后缀名,默认以上两种。

springMVC配置:

package?com.yawn.config;

import?org.springframework.context.annotation.Configuration;
import?org.springframework.format.FormatterRegistry;
import?org.springframework.http.HttpStatus;
import?org.springframework.web.servlet.config.annotation.*;

/**
?*?Created?by?yawn?on?2017/8/5.
?*/
@EnableWebMvc
@Configuration
public?class?MvcConfig?extends?WebMvcConfigurerAdapter?{

????@Override
????public?void?addResourceHandlers(ResourceHandlerRegistry?registry)?{
????????registry.addResourceHandler("/static/**").addResourceLocations("classpath:/static/");
????????registry.addResourceHandler("/templates/**").addResourceLocations("classpath:/templates/");
????????super.addResourceHandlers(registry);
????}

????@Override
????public?void?addViewControllers(ViewControllerRegistry?registry)?{
????????registry.addViewController("/index");
????????registry.addViewController("/user");
????????registry.addRedirectViewController("/","/templates/login.html");
//????????registry.addStatusController("/403",?HttpStatus.FORBIDDEN);
????????super.addViewControllers(registry);
????}
}

这里配置静态资源和直接访问的页面:在本示例项目中,添加了thymeleaf依赖解析视图,主要采用异步方式获取数据,通过angularJS进行前端数据的处理和展示。

使用activiti:

配置了数据源和activiti后,启动项目,activiti 的各个服务组件就已经被加入到spring容器中了,所以就可以直接注入使用了。如果在未自动配置的spring环境中,可以使用通过指定bean的init-method来配置activiti的服务组件。

案例:

以以下请假流程为例:

1. 开始流程并“申请请假”(员工)

????private?static?final?String?PROCESS_DEFINE_KEY?=?"vacationProcess";


????public?Object?startVac(String?userName,?Vacation?vac)?{

????????identityService.setAuthenticatedUserId(userName);
????????//?开始流程
????????ProcessInstance?vacationInstance?=?runtimeService.startProcessInstanceByKey(PROCESS_DEFINE_KEY);
????????//?查询当前任务
????????Task?currentTask?=?taskService.createTaskQuery().processInstanceId(vacationInstance.getId()).singleResult();
????????//?申明任务
????????taskService.claim(currentTask.getId(),?userName);

????????Map<String,?Object>?vars?=?new?HashMap<>(4);
????????vars.put("applyUser",?userName);
????????vars.put("days",?vac.getDays());
????????vars.put("reason",?vac.getReason());
????????//?完成任务
????????taskService.complete(currentTask.getId(),?vars);

????????return?true;
????}

在此方法中,Vaction 是申请时的具体信息,在完成“申请请假”任务时,可以将这些信息设置成参数。

2. 审批请假(老板)

(1)查询需要自己审批的请假

????public?Object?myAudit(String?userName)?{
????????List<Task>?taskList?=?taskService.createTaskQuery().taskCandidateUser(userName)
????????????????.orderByTaskCreateTime().desc().list();
//????????/?多此一举?taskList中包含了以下内容(用户的任务中包含了所在用户组的任务)
//????????Group?group?=?identityService.createGroupQuery().groupMember(userName).singleResult();
//????????List<Task>?list?=?taskService.createTaskQuery().taskCandidateGroup(group.getId()).list();
//????????taskList.addAll(list);
????????List<VacTask>?vacTaskList?=?new?ArrayList<>();
????????for?(Task?task?:?taskList)?{
????????????VacTask?vacTask?=?new?VacTask();
????????????vacTask.setId(task.getId());
????????????vacTask.setName(task.getName());
????????????vacTask.setCreateTime(task.getCreateTime());
????????????String?instanceId?=?task.getProcessInstanceId();
????????????ProcessInstance?instance?=?runtimeService.createProcessInstanceQuery().processInstanceId(instanceId).singleResult();
????????????Vacation?vac?=?getVac(instance);
????????????vacTask.setVac(vac);
????????????vacTaskList.add(vacTask);
????????}
????????return?vacTaskList;
????}

????private?Vacation?getVac(ProcessInstance?instance)?{
????????Integer?days?=?runtimeService.getVariable(instance.getId(),?"days",?Integer.class);
????????String?reason?=?runtimeService.getVariable(instance.getId(),?"reason",?String.class);
????????Vacation?vac?=?new?Vacation();
????????vac.setApplyUser(instance.getStartUserId());
????????vac.setDays(days);
????????vac.setReason(reason);
????????Date?startTime?=?instance.getStartTime();?//?activiti?6?才有
????????vac.setApplyTime(startTime);
????????vac.setApplyStatus(instance.isEnded()???"申请结束"?:?"等待审批");
????????return?vac;
????}


package?com.yawn.entity;

import?java.util.Date;

/**
?*?@author?Created?by?yawn?on?2018-01-09?14:31
?*/
public?class?VacTask?{

????private?String?id;
????private?String?name;
????private?Vacation?vac;
????private?Date?createTime;

????//?getter?setter?...
}

老板查询自己当前需要审批的任务,并且将任务和参数设置到一个VacTask对象,用于页面的展示。

(2)审批请假

????public?Object?passAudit(String?userName,?VacTask?vacTask)?{
????????String?taskId?=?vacTask.getId();
????????String?result?=?vacTask.getVac().getResult();
????????Map<String,?Object>?vars?=?new?HashMap<>();
????????vars.put("result",?result);
????????vars.put("auditor",?userName);
????????vars.put("auditTime",?new?Date());
????????taskService.claim(taskId,?userName);
????????taskService.complete(taskId,?vars);
????????return?true;
????}

同理,result是审批的结果,也是在完成审批任务时需要传入的参数;taskId是刚才老板查询到的当前需要自己完成的审批任务ID。(如果流程在这里设置分支,可以通过判断result的值来跳转到不同的任务)

3. 查询记录

由于已完成的请假在数据库runtime表中查不到(runtime表只保存正在进行的流程示例信息),所以需要在history表中查询。

(1) 查询请假记录

????public?Object?myVacRecord(String?userName)?{
????????List<HistoricProcessInstance>?hisProInstance?=?historyService.createHistoricProcessInstanceQuery()
????????????????.processDefinitionKey(PROCESS_DEFINE_KEY).startedBy(userName).finished()
????????????????.orderByProcessInstanceEndTime().desc().list();

????????List<Vacation>?vacList?=?new?ArrayList<>();
????????for?(HistoricProcessInstance?hisInstance?:?hisProInstance)?{
????????????Vacation?vacation?=?new?Vacation();
????????????vacation.setApplyUser(hisInstance.getStartUserId());
????????????vacation.setApplyTime(hisInstance.getStartTime());
????????????vacation.setApplyStatus("申请结束");
????????????List<HistoricVariableInstance>?varInstanceList?=?historyService.createHistoricVariableInstanceQuery()
????????????????????.processInstanceId(hisInstance.getId()).list();
????????????ActivitiUtil.setVars(vacation,?varInstanceList);
????????????vacList.add(vacation);
????????}
????????return?vacList;
????}

请假记录即查出历史流程实例,再查出关联的历史参数,将历史流程实例和历史参数设置到Vcation对象(VO对象)中去,即可返回,用来展示。

package?com.yawn.util;

import?org.activiti.engine.history.HistoricVariableInstance;

import?java.lang.reflect.Field;
import?java.util.List;

/**
?*?activiti中使用得到的工具方法
?*?@author?Created?by?yawn?on?2018-01-10?16:32
?*/
public?class?ActivitiUtil?{

????/**
?????*?将历史参数列表设置到实体中去
?????*?@param?entity?实体
?????*?@param?varInstanceList?历史参数列表
?????*/
????public?static?<T>?void?setVars(T?entity,?List<HistoricVariableInstance>?varInstanceList)?{
????????Class<?>?tClass?=?entity.getClass();
????????try?{
????????????for?(HistoricVariableInstance?varInstance?:?varInstanceList)?{
????????????????Field?field?=?tClass.getDeclaredField(varInstance.getVariableName());
????????????????if?(field?==?null)?{
????????????????????continue;
????????????????}
????????????????field.setAccessible(true);
????????????????field.set(entity,?varInstance.getValue());
????????????}
????????}?catch?(Exception?e)?{
????????????e.printStackTrace();
????????}
????}
}

此外,以上是查询历史流程实例和历史参数后,设置VO对象的通用方法:可以根据参数列表中的参数,将与VO对象属性同名的参数设置到VO对象中去。

4. 前端展示和操作

(1)审批列表和审批操作示例

????<div?ng-controller="myAudit">
????????<h2?ng-init="myAudit()">待我审核的请假</h2>
????????<table?border="0">
????????????<tr>
????????????????<td>任务名称</td>
????????????????<td>任务时间</td>
????????????????<td>申请人</td>
????????????????<td>申请时间</td>
????????????????<td>天数</td>
????????????????<td>事由</td>
????????????????<td>操作</td>
????????????</tr>
????????????<tr?ng-repeat="vacTask?in?vacTaskList">
????????????????<td>{{vacTask.name}}</td>
????????????????<td>{{vacTask.createTime?|?date:'yyyy-MM-dd?HH:mm:ss'}}</td>
????????????????<td>{{vacTask.vac.applyUser}}</td>
????????????????<td>{{vacTask.vac.applyTime?|?date:'yyyy-MM-dd?HH:mm:ss'}}</td>
????????????????<td>{{vacTask.vac.days}}</td>
????????????????<td>{{vacTask.vac.reason}}</td>
????????????????<td>
????????????????????<button?type="button"?ng-click="passAudit(vacTask.id,?1)">审核通过</button>
????????????????????<button?type="button"?ng-click="passAudit(vacTask.id,?0)">审核拒绝</button>
????????????????</td>
????????????</tr>
????????</table>
????</div>


app.controller("myAudit",?function?($scope,?$http,?$window)?{
????$scope.vacTaskList?=?[];

????$scope.myAudit?=?function?()?{
????????$http.get(
????????????"/myAudit"
????????).then(function?(response)?{
????????????$scope.vacTaskList?=?response.data;
????????})
????};

????$scope.passAudit?=?function?(taskId,?result)?{
????????$http.post(
????????????"/passAudit",
????????????{
????????????????"id":?taskId,
????????????????"vac":?{
????????????????????"result":?result?>=?1???"审核通过"?:?"审核拒绝"
????????????????}
????????????}
????????).then(function?(response)?{
????????????if?(response.data?===?true)?{
????????????????alert("操作成功!");
????????????????$window.location.reload();
????????????}?else?{
????????????????alert("操作失败!");
????????????}
????????})
????}
});


完整的项目代码:https://gitee.com/yawensilence/activiti-demo6-springboot


原文:my.oschina.net/silenceyawen/blog/1609603

作者:yawn-silence

来源:微信公众号

相关推荐

Spring WebFlux vs. Spring MVC(springboot是什么)

背景随着异步I/O和Netty等框架的流行,响应式编程逐渐走入大众的视野。但是,响应式编程本身并不是太新的概念,这个术语最早出现在1985年DavidHarel和AmirPnue...

深度解析微服务高并发:适配SpringMVC框架适配模块及实现原理

适配主流框架如果不借助Sentinel提供的适配主流框架的模块,则在使用Sentinel时需要借助try-catchfinally将要保护的资源(方法或代码块)包起来,在目标方法或代码块执行之前,调...

Spring MVC 底层原理深度解析:从请求到响应的全链路拆解

一、Servlet容器与DispatcherServlet的启动博弈1.Tomcat初始化阶段java//Tomcat初始化流程StandardContext#startInterna...

改造总结之传统SpringMVC架构转换为SpringBoot再到集群

改造出发点,是基于现在服务都在向上云的目标前进,传统SpringMVC难以满足项目持续构建、服务节点任意扩展的需求,所以开始了历史项目的改造。项目改造考虑的主要是兼容以前的业务代码,以及session...

SpringBoot3 整合 Spring MVC 全解析:开启高效 Web 开发之旅

在当今的JavaWeb开发领域,Spring框架家族无疑占据着重要的地位。其中,SpringBoot3和SpringMVC更是开发者们构建强大、高效Web应用的得力工具。今天,...

一文读懂SpringMVC(一文读懂!残疾人低保边缘家庭能领的超实用福利政策)

1.SpringMVC定义1.1.MVC定义Model(模型):是应用程序中用于处理应用程序数据逻辑的部分。通常模型对象负责在数据库中存取数据View(视图):是应用程序中处理数据显示的部分。通常...

69 个Spring mvc 全部注解:真实业务使用案例说明(必须收藏)

SpringMVC框架的注解为Web开发提供了一种简洁而强大的声明式方法。从控制器的定义、请求映射、参数绑定到异常处理和响应构建,这些注解涵盖了Web应用程序开发的各个方面。它们不仅简化了编码工作,...

Spring MVC工作原理:像拼积木一样构建Web应用

SpringMVC工作原理:像拼积木一样构建Web应用在Java的Web开发领域,SpringMVC无疑是一个让人又爱又恨的存在。它像一位神通广大的积木搭建大师,将一个个分散的功能模块巧妙地拼接在...

5千字的SpringMVC总结,我觉得你会需要

思维导图文章已收录到我的Github精选,欢迎Star:https://github.com/yehongzhi/learningSummary概述SpringMVC再熟悉不过的框架了,因为现在最火的...

SpringMVC工作原理与优化指南(springmvc工作原理和工作流程)

SpringMVC工作原理与优化指南在现代Java开发中,SpringMVC无疑是构建Web应用程序的首选框架之一。它以其优雅的设计和强大的功能吸引了无数开发者。那么,SpringMVC究竟是如何工作...

Spring MVC框架源码深度剖析:从入门到精通

SpringMVC框架源码深度剖析:从入门到精通SpringMVC框架简介SpringMVC作为Spring框架的一部分,为构建Web应用程序提供了强大且灵活的支持。它遵循MVC(Model-V...

3000字搞明白SpringMVC工作流程、DispatcherServlet类、拦截器!

SpringMVC基础虽然SpringBoot近几年发展迅猛,但是SpringMVC在Web开发领域仍然占有重要的地位。本章主要讲解SpringMVC的核心:DispatcherServlet类...

多年经验大佬用2000字透彻解析SpringMVC的常用注解及相关示例

SpringMVC注解SpringMVC框架提供了大量的注解,如请求注解、参数注解、响应注解及跨域注解等。这些注解提供了解决HTTP请求的方案。本节主要讲解SpringMVC的常用注解及相关示例...

知乎热议:如何成为前端架构师,赚百万年薪?

作者|慕课网精英讲师双越最近有一条知乎热议:从一个前端工程师,如何根据目标,制定计划,才能快速进阶成为前端架构师?不久之前我参与了一次直播,讲到了自己对于Web前端架构师的理解。架构师这个角色...

学习笔记-前端开发架构设计(前端架构设计方案)

前端开发的技术选项主要包含以下几点,下面对一些名词概念的解释做了笔记:1、分层架构:把功能相似,抽象级别相近的实现进行分层隔离优势:松散耦合(易维护,易复用,易扩展)常见分层方式:MVC,MVVM2、...

取消回复欢迎 发表评论: