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

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

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

来源:微信公众号

相关推荐

用Deepseek扩写土木工程毕业论文实操指南

用Deepseek扩写毕业论文实操指南一、前期准备整理现有论文初稿/提纲列清楚论文核心框架(背景、现状、意义、方法、数据、结论等)梳理好关键文献,明确核心技术路线二、Deepseek扩写核心思路...

985学霸亲授,DeepSeek也能绘6大科研图表,5分钟就出图

在实验数据处理中,高效可视化是每个科研人的必修课。传统绘图软件操作复杂、耗时费力,而智能工具DeepSeek的出现彻底改变了这一现状。本文将详解如何用DeepSeek一键生成六大科研常用图表,从思维导...

AI写论文刷屏?大学生正在丢掉的思考力

一、宿舍深夜:当论文变成"Ctrl+C+V"凌晨两点的大学宿舍,小王对着电脑屏幕叹气。本该三天前开始写的近代史论文,此刻还一片空白。他熟练打开某AI写作网站,输入"论五四运动的...

Grok在辅助论文写作上能不能既“聪明”又“可怕”?!

AcademicIdeas-学境思源AI初稿写作随着人工智能技术的飞速发展,论文写作这一学术任务正迎来新的助力。2025年2月18日,美国xAI公司推出了备受瞩目的Grok3模型,其创始人埃隆·...

大四论文沟通场景!音频转文字难题听脑AI来化解

大四学生都知道,写论文时和导师沟通修改意见,简直是“过关斩将”。电话、语音沟通完,想把导师说的修改方向、重点要求记下来,麻烦事儿可不少。手写记不全,用普通录音转文字工具,转完还得自己慢慢找重点,稍不注...

论文写作 | 技术路线图怎么画?(提供经典优秀模板参考)

技术路线图是一种图表或文字说明,用于描述研究目标、方法和实施计划。它展示了研究的整体框架和步骤,有助于读者理解研究的逻辑和进展。在课题及论文中,技术路线图是常见的一部分,甚至是一个类似心脏一样的中枢器...

25年信息系统项目管理师考试第2批论文题目写作建议思路框架

25年信息系统项目管理师考试第2批论文题目写作建议思路框架--马军老师

微信购物应尽快纳入法律框架(微信购物管辖)

符向军近日,甘肃省工商行政管理局发布《2016年上半年信息分析报告》。报告显示,微信网购纠纷迅猛增长,网络购物投诉呈上升趋势。投诉的主要问题有出售的商品质量不过关、消费者通过微信付款后对方不发货、购买...

泛珠三角区域网络媒体与腾讯微信签署《战略合作框架协议》

新海南客户端、南海网7月14日消息(记者任桐)7月14日上午,参加第四届泛珠三角区域合作网络媒体论坛的区域网络媒体负责人及嘉宾一行到腾讯微信总部座谈交流,并签署《战略合作框架协议》(以下简称《框架协...

离线使用、植入微信-看乐心Mambo手环如何打破框架

从2014年开始智能手环就成功进入人们的生活,至今已经演变出数据监测、信息推送、心率监测等诸多五花八门的功能,人们选择智能手环并不指望其能够改变身体健康情况,更多的是通过数据来正视自身运动情况和身体健...

微信私域电商运营策略与框架(微信私域怎么做)

...

华专网络:如何零基础制作一个网站出来?

#如何零基础制作一个网站出来?#你是不是觉得网站建设很复杂,觉得自己是小白,需求不明确、流程搞不懂、怕被外包公司坑……这些问题我都懂!今天华专网络就用大白话给你捋清楚建站的全流程,让你轻松get网站制...

WAIC2024丨明日上午9点,不见不散!共同探讨智能社会与全球治理框架

大咖云集,硕果闪耀WAIC2024世界人工智能大会智能社会论坛将于7月5日9:00-12:00与你相约直播间WAIC2024上海杨浦同济大学哔哩哔哩多平台同步直播探讨智能社会与全球治理框架WAIC...

约基奇:森林狼换来戈贝尔时大家都在嘲笑 他们的阵容框架很不错

直播吧5月4日讯西部季后赛半决赛,掘金将迎战森林狼,约基奇赛前接受采访。约基奇说道:“当蒂姆-康纳利(森林狼总经理、前掘金总经理&曾选中约基奇)做了那笔交易(换来戈贝尔)时,每个人都在嘲笑他...

视频号带货为什么一个流量都没有?顶级分析框架送给你

视频号带货为什么一个流量都没有?遇到问题,一定是步步来分析内容,视频号带货一个流量都没有,用另外一个意思来讲,就可以说是零播放。为什么视频号带货一个流量都没有?跟你说再多,都不如来个分析框架。1、是否...

取消回复欢迎 发表评论: