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

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

ccwgpt 2024-11-01 11:31 27 浏览 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

来源:微信公众号

相关推荐

盲盒小程序背后的技术揭秘:如何打造个性化购物体验

在2025年的今天,盲盒小程序作为一种新兴的购物方式,正以其独特的魅力和个性化体验吸引着越来越多的消费者。这种将线上购物与盲盒概念相结合的应用,不仅为消费者带来了未知的惊喜,还通过一系列技术手段实现了...

小程序·云开发已支持单日亿级调用量,接口可用率高达99.99%

2019-10-1914:1210月19日,由腾讯云与微信小程序团队联合举办的“小程序·云开发”技术峰会在北京召开。会上,微信小程序团队相关负责人表示“小程序·云开发”系统架构已经支持每天亿级别的...

程序员副业开启模式:8个GitHub上可以赚钱的小程序

前言开源项目作者:JackonYang今天推荐的这个项目是「list-of-wechat-mini-program-list」,开源微信小程序列表的列表、有赚钱能力的小程序开源代码。这个项目分为两部分...

深度科普:盲盒小程序开发的底层逻辑

在当下的数字化浪潮中,盲盒小程序以其独特的趣味性和互动性,吸引着众多消费者的目光。无论是热衷于收集玩偶的年轻人,还是享受拆盒惊喜的上班族,都对盲盒小程序情有独钟。那么,这种备受欢迎的盲盒小程序,其开发...

微信小程序的制作步骤

SaaS小程序制作平台,作为数字化转型时代下的创新产物,不仅将易用性置于设计的核心位置,让非技术背景的用户也能轻松上手,快速制作出功能丰富、界面精美的小程序,更在性能和稳定性方面投入了大量精力,以确保...

携程开源--小程序构建工具,三分钟搞定

前言今天推荐的这个项目是「wean」,一个小程序构建打包工具。在wean之前,大量小程序工具使用webpack进行打包,各种loader、plugin导致整个开发链路变长。wean旨在解...

校园小程序的搭建以及营收模式校园外卖程序校园跑腿校园圈子系统

校园小程序的架构设计主要包括云端架构和本地架构两部分。云端架构方面,采用Serverless架构可以降低技术门槛,通过阿里云、腾讯云等平台提供的云服务,可以实现弹性扩容和快速部署。例如,使用云数据库、...

盲盒小程序开发揭秘:技术架构与实现原理全解析

在2025年的今天,盲盒小程序作为一种结合了线上购物与趣味性的创新应用,正受到越来越多用户的喜爱。其背后的技术架构与实现原理,对于想要了解或涉足这一领域的人来说,无疑充满了神秘与吸引力。本文将为大家科...

月活百万的小程序架构设计:流量暴增秘籍

从小程序到"大"程序的蜕变之路当你的小程序用户量从几千跃升至百万级别时,原有的架构就像一件不合身的衣服,处处紧绷。这个阶段最常遇到的噩梦就是服务器崩溃、接口超时、数据丢失。想象一下,在...

认知智能如何与产业结合?专家学者共探理论框架与落地实践

当前,以大模型为代表的生成式人工智能等前沿技术加速迭代,如何将认知智能与产业结合,成为摆在各行各业面前的一个问题。论坛现场。主办方供图7月4日,2024世界人工智能大会暨人工智能全球治理高级别会议在...

现代中医理论框架

...

认知行为(CBT)中的ABC情绪理论

情绪ABC理论是由美国心理学家阿尔伯特·艾利斯(AlbertEllis1913-2007)创建的理论,A表示诱发性事件(Activatingevent),B表示个体针对此诱发性事件产生的一些信...

说说卡伦霍妮的理论框架,对你调整性格和人际关系,价值很大

01自在今天我主要想说下霍妮的理论框架。主要说三本书,第一本是《我们时代的神经症人格》,第二本是《我们内心的冲突》,第三本是《神经症与人的成长》。根据我的经验,三本书价值巨大,但并不是每个人都能读进去...

供应链管理-理论框架

一个最佳价值的供应链,应该是一个具有敏捷性、适应性和联盟功能(3A)的供应链,其基本要素包括战略资源、物流管理、关系管理以及信息系统,目标是实现速度、质量、成本、柔性的竞争优势。篇幅有...

微信WeUI设计规范文件下载及使用方法

来人人都是产品经理【起点学院】,BAT实战派产品总监手把手系统带你学产品、学运营。WeUI是一套同微信原生视觉体验一致的基础样式库,由微信官方设计团队为微信Web开发量身设计,可以令用户的使用感知...

取消回复欢迎 发表评论: