目录
- 0.springboot项目创建
- 1.引入activiti相关依赖
- 8.其他api测试
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内容请搜索www.887551.com以前的文章或继续浏览下面的相关文章希望大家以后多多支持www.887551.com！
黄山市民网：https://www.huangshanshimin.com/
