Activiti7整合Springboot使用记录
0.springboot项目创建
通过https://start.spring.io/生成纯净的一个springboot工程
1.引入activiti相关依赖
<dependency> <groupid>org.activiti</groupid> <artifactid>activiti-spring-boot-starter</artifactid> <version>7.1.0.m6</version> </dependency>
2.启动工程并创建activiti数据库
##activiti7中使用spring security,因此启动工程前,需要加入2个文件支持,2个文件的代码如下:
package cn.gzsendi.activitidemotest.config; import java.util.arrays; import java.util.list; import java.util.stream.collectors; import org.slf4j.logger; import org.slf4j.loggerfactory; import org.springframework.context.annotation.bean; import org.springframework.context.annotation.configuration; import org.springframework.security.core.authority.simplegrantedauthority; import org.springframework.security.core.userdetails.user; import org.springframework.security.core.userdetails.userdetailsservice; import org.springframework.security.crypto.bcrypt.bcryptpasswordencoder; import org.springframework.security.crypto.password.passwordencoder; import org.springframework.security.provisioning.inmemoryuserdetailsmanager; @configuration public class activiticonfiguration { private logger logger = loggerfactory.getlogger(activiticonfiguration.class); @bean(name = "userdetailsservice") public userdetailsservice myuserdetailsservice() { inmemoryuserdetailsmanager inmemoryuserdetailsmanager = new inmemoryuserdetailsmanager(); //用户 string[][] usersgroupsandroles = { {"hefy", "123456", "role_activiti_user"}, {"liujh", "123456", "role_activiti_admin"}, {"liuky", "123456", "role_activiti_user"}, {"admin", "123456", "role_activiti_admin"}, }; for (string[] user : usersgroupsandroles) { list<string> authoritiesstrings = arrays.aslist(arrays.copyofrange(user, 2, user.length)); logger.info("> registering new user: " + user[0] + " with the following authorities[" + authoritiesstrings + "]"); inmemoryuserdetailsmanager.createuser(new user(user[0], passwordencoder().encode(user[1]), authoritiesstrings.stream().map(s -> new simplegrantedauthority(s)).collect(collectors.tolist()))); } return inmemoryuserdetailsmanager; } @bean public passwordencoder passwordencoder() { return new bcryptpasswordencoder(); } }
package cn.gzsendi.activitidemotest.utils; import java.util.collection; import org.springframework.beans.factory.annotation.autowired; import org.springframework.beans.factory.annotation.qualifier; import org.springframework.security.core.authentication; import org.springframework.security.core.grantedauthority; import org.springframework.security.core.context.securitycontextholder; import org.springframework.security.core.context.securitycontextimpl; import org.springframework.security.core.userdetails.userdetails; import org.springframework.security.core.userdetails.userdetailsservice; import org.springframework.stereotype.component; import javax.annotation.resource; @component public class securityutil { @autowired @qualifier("userdetailsservice") private userdetailsservice userdetailsservice; public void loginas(string username) { userdetails user = userdetailsservice.loaduserbyusername(username); if (user == null) { throw new illegalstateexception("user " + username + " doesn't exist, please provide a valid user"); } securitycontextholder.setcontext(new securitycontextimpl(new authentication() { @override public collection<? extends grantedauthority> getauthorities() { return user.getauthorities(); } @override public object getcredentials() { return user.getpassword(); } @override public object getdetails() { return user; } @override public object getprincipal() { return user; } @override public boolean isauthenticated() { return true; } @override public void setauthenticated(boolean isauthenticated) throws illegalargumentexception { } @override public string getname() { return user.getusername(); } })); org.activiti.engine.impl.identity.authentication.setauthenticateduserid(username); } }
##加入activiti7的配置
server.port=8080 server.servlet.context-path=/activitidemotest spring.datasource.driver-class-name=com.mysql.cj.jdbc.driver spring.datasource.url=jdbc:mysql://localhost:3306/activitidemo?usessl=false&useunicode=true&characterencoding=utf8&servertimezone=gmt%2b8&allowmultiqueries=true spring.datasource.username=root spring.datasource.password=123456 spring.activiti.database-schema-update=true spring.activiti.db-history-used=true spring.activiti.history-level=full spring.activiti.check-process-definitions=false spring.activiti.deployment-mode=never-fail spring.activiti.process-definition-location-prefix=classpath:/process/
##启动springboot工程,让系统启动时帮我们建好25张表 2.安装activiti插件(设计器) ##idea
file->settings->plugins,然后找actibpm进行安装。
##流程图中乱码问题先提前设置防止:
修改idea64.exe.vmoptions文件,在文件中加上如下,然后重启idea
-dfile.encoding=utf-8
##进行流程设计
file->new->bpmnfile
设计好后,修改process1.bpmn成process1.xml,然后右键export file导出成process1.jpg,再将process1.bpmn修改成process1.bpmn20.xml,最后将2个文件放在process文件夹
3.流程部署
使用activiti提供的api把流程定义内容存储起来,activiti执行把流程定义内容存储在数据库中。
package cn.gzsendi.activitidemotest; /** * created by jxlhl on 2021/8/18. */ import org.activiti.engine.repositoryservice; import org.activiti.engine.repository.deployment; import org.activiti.engine.repository.deploymentbuilder; import org.junit.test; import org.junit.runner.runwith; import org.springframework.beans.factory.annotation.autowired; import org.springframework.boot.test.context.springboottest; import org.springframework.test.context.junit4.springrunner; @runwith(springrunner.class) @springboottest public class springbootjunittest { //得到repositoryservice实例 @autowired private repositoryservice repositoryservice; //0.流程部署,单个文件部署方式 @test public void testdeployment(){ //使用repositoryservice进行部署 deploymentbuilder builder = repositoryservice.createdeployment(); builder.addclasspathresource("process/process1.bpmn20.xml"); builder.addclasspathresource("process/process1.jpg"); builder.name("first_activiti_process"); deployment deployment = builder.deploy(); //输出部署信息 system.out.println("流程部署id:" + deployment.getid()); system.out.println("流程部署名称:" + deployment.getname()); //流程部署id:125098e1-ffd9-11eb-8847-02004c4f4f50 //流程部署名称:first_activiti_process } }
执行此操作后activiti会将上边代码中指定的bpmn20文件和图片文件保存在activiti数据库。
流程定义部署后操作activiti的3张表
4.流程实例启动
启动一个流程实例表示开始一次业务流程的运行
//1.流程实例启动 @test public void teststartprocess(){ //根据流程定义id启动流程 processinstance processinstance = runtimeservice.startprocessinstancebykey("myprocess_1"); //输出实例信息 system.out.println("流程定义id:" + processinstance.getprocessdefinitionid()); system.out.println("流程实例id:" + processinstance.getid()); system.out.println("当前活动id:" + processinstance.getactivityid()); //流程定义id:myprocess_1:1:12702ed4-ffd9-11eb-8847-02004c4f4f50 //流程实例id:a9b162aa-ffda-11eb-bad1-02004c4f4f50 //当前活动id:null }
流程实例启动,将操作以下几个数据库表
act_hi_actinst 流程实例执行历史 act_hi_identitylink 流程的参与用户历史信息 act_hi_procinst 流程实例历史信息 act_hi_taskinst 流程任务历史信息 act_ru_execution 流程执行信息 act_ru_identitylink 流程的参与用户信息 act_ru_task 任务信息
5.任务查询
流程启动后,任务的负责人就可以查询自己当前需要处理的任务,查询出来的任务都是该用户的待办任务。
//2.任务查询 //流程启动后,任务的负责人就可以查询自己当前需要处理的任务,查询出来的任务都是该用户的待办任务。 @test public void testfindpersonaltasklist() { //任务负责人 string assignee = "liuky"; //根据流程key 和 任务负责人 查询任务 list<task> list = taskservice.createtaskquery() .processdefinitionkey("myprocess_1") .taskassignee(assignee) .list(); for (task task : list) { system.out.println("流程实例id:" + task.getprocessinstanceid()); system.out.println("任务id:" + task.getid()); system.out.println("任务负责人:" + task.getassignee()); system.out.println("任务名称:" + task.getname()); } //流程实例id:a9b162aa-ffda-11eb-bad1-02004c4f4f50 //任务id:a9b5815e-ffda-11eb-bad1-02004c4f4f50 //任务负责人:liuky //任务名称:提交申请 }
6. 完成任务
@test public void complettask(){ //根据流程key和任务的负责人查询任务并选择其中的一个任务处理,这里用的 //是singleresult返回一条,真实环境中是通过步骤5中查询出所有的任务,然后在页面上选择一个任务进行处理. task task = taskservice.createtaskquery() .processdefinitionkey("myprocess_1") //流程key .taskassignee("liuky") //要查询的负责人 .singleresult(); //完成任务,参数:任务id taskservice.complete(task.getid()); }
7.流程结束,或流程流转过程中的历史信息查询
//流程结束,或流程流转过程中的历史信息查询 @test public void findhistoryinfo(){ //获取 actinst表的查询对象 historicactivityinstancequery instancequery = historyservice.createhistoricactivityinstancequery(); //查询 actinst表,条件:根据 instanceid 查询 instancequery.processinstanceid("fb5b7674-ffde-11eb-91f8-02004c4f4f50"); //增加排序操作,orderbyhistoricactivityinstancestarttime 根据开始时间排序 asc 升序 instancequery.orderbyhistoricactivityinstancestarttime().asc(); //查询所有内容 list<historicactivityinstance> activityinstancelist = instancequery.list(); //输出结果 for (historicactivityinstance hi : activityinstancelist) { system.out.println(""); system.out.println("===================-==============="); system.out.println(hi.getstarttime()); system.out.println(hi.getassignee()); system.out.println(hi.getactivityid()); system.out.println(hi.getactivityname()); system.out.println(hi.getprocessdefinitionid()); system.out.println(hi.getprocessinstanceid()); system.out.println("===================-==============="); system.out.println(""); } }
8.其他api测试
8.1 流程定义信息查询
查询流程相关信息,包含流程定义,流程部署,流程定义版本
@test public void queryprocessdefinition(){ //得到processdefinitionquery对象 processdefinitionquery processdefinitionquery = repositoryservice.createprocessdefinitionquery(); //查询出当前所有的流程定义 list<processdefinition> definitionlist = processdefinitionquery.processdefinitionkey("myprocess_1") .orderbyprocessdefinitionversion() .desc() .list(); //打印结果 for (processdefinition processdefinition : definitionlist) { system.out.println("流程定义 id="+processdefinition.getid()); system.out.println("流程定义 name="+processdefinition.getname()); system.out.println("流程定义 key="+processdefinition.getkey()); system.out.println("流程定义 version="+processdefinition.getversion()); system.out.println("流程部署id ="+processdefinition.getdeploymentid()); } }
8.2 删除流程
//删除流程 @test public void deletedeployment(){ string deploymentid = "125098e1-ffd9-11eb-8847-02004c4f4f50"; //删除流程定义,如果该流程定义已有流程实例启动则删除时出错 repositoryservice.deletedeployment(deploymentid); //设置true 级联删除流程定义,即使该流程有流程实例启动也可以删除,设置为false非级别删除方式,如果流程 //repositoryservice.deletedeployment(deploymentid, true); }
9.demo源码下载
github:
gitee:
到此这篇关于activiti7整合springboot使用记录的文章就介绍到这了,更多相关springboot整合activiti7内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持!
上一篇: 详细分析Redis集群故障
推荐阅读
-
activemq整合springboot使用方法(个人微信小程序用)
-
在SpringBoot中使用Logback管理记录日志
-
在SpringBoot中使用Logback管理记录日志
-
浅谈Springboot整合RocketMQ使用心得
-
SpringBoot2.x整合Shiro出现cors跨域问题(踩坑记录)
-
SpringBoot整合Netty并使用Protobuf进行数据传输(附工程)
-
每天学点SpringCloud(一):使用SpringBoot2.0.3整合SpringCloud
-
Springboot整合Mybatis使用分页 PageHelper分页插件
-
SpringBoot整合使用tk.mybatis配置及测试
-
SpringBoot RocketMQ docker整合使用