0.springboot項(xiàng)目創(chuàng)建
通過https://start.spring.io/生成純凈的一個(gè)springboot工程
1.引入activiti相關(guān)依賴
|
1
2
3
4
5
|
<dependency> <groupid>org.activiti</groupid> <artifactid>activiti-spring-boot-starter</artifactid> <version>7.1.0.m6</version></dependency> |
2.啟動(dòng)工程并創(chuàng)建activiti數(shù)據(jù)庫
##activiti7中使用spring security，因此啟動(dòng)工程前，需要加入2個(gè)文件支持，2個(gè)文件的代碼如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
|
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;@configurationpublic 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(); }} |
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
|
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;@componentpublic 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的配置
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
server.port=8080server.servlet.context-path=/activitidemotestspring.datasource.driver-class-name=com.mysql.cj.jdbc.driverspring.datasource.url=jdbc:mysql://localhost:3306/activitidemo?usessl=false&useunicode=true&characterencoding=utf8&servertimezone=gmt%2b8&allowmultiqueries=truespring.datasource.username=rootspring.datasource.password=123456spring.activiti.database-schema-update=truespring.activiti.db-history-used=truespring.activiti.history-level=fullspring.activiti.check-process-definitions=falsespring.activiti.deployment-mode=never-failspring.activiti.process-definition-location-prefix=classpath:/process/ |
##啟動(dòng)springboot工程，讓系統(tǒng)啟動(dòng)時(shí)幫我們建好25張表 2.安裝activiti插件（設(shè)計(jì)器） ##idea
file->settings->plugins，然后找actibpm進(jìn)行安裝。
##流程圖中亂碼問題先提前設(shè)置防止：
修改idea64.exe.vmoptions文件，在文件中加上如下，然后重啟idea
-dfile.encoding=utf-8
##進(jìn)行流程設(shè)計(jì)
file->new->bpmnfile
設(shè)計(jì)好后，修改process1.bpmn成process1.xml,然后右鍵export file導(dǎo)出成process1.jpg，再將process1.bpmn修改成process1.bpmn20.xml，最后將2個(gè)文件放在process文件夾
3.流程部署
使用activiti提供的api把流程定義內(nèi)容存儲(chǔ)起來，activiti執(zhí)行把流程定義內(nèi)容存儲(chǔ)在數(shù)據(jù)庫中。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
|
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)@springboottestpublic class springbootjunittest { //得到repositoryservice實(shí)例 @autowired private repositoryservice repositoryservice; //0.流程部署，單個(gè)文件部署方式 @test public void testdeployment(){ //使用repositoryservice進(jìn)行部署 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 }} |
執(zhí)行此操作后activiti會(huì)將上邊代碼中指定的bpmn20文件和圖片文件保存在activiti數(shù)據(jù)庫。
流程定義部署后操作activiti的3張表
4.流程實(shí)例啟動(dòng)
啟動(dòng)一個(gè)流程實(shí)例表示開始一次業(yè)務(wù)流程的運(yùn)行
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
//1.流程實(shí)例啟動(dòng) @test public void teststartprocess(){ //根據(jù)流程定義id啟動(dòng)流程 processinstance processinstance = runtimeservice.startprocessinstancebykey("myprocess_1"); //輸出實(shí)例信息 system.out.println("流程定義id：" + processinstance.getprocessdefinitionid()); system.out.println("流程實(shí)例id：" + processinstance.getid()); system.out.println("當(dāng)前活動(dòng)id：" + processinstance.getactivityid()); //流程定義id：myprocess_1:1:12702ed4-ffd9-11eb-8847-02004c4f4f50 //流程實(shí)例id：a9b162aa-ffda-11eb-bad1-02004c4f4f50 //當(dāng)前活動(dòng)id：null } |
流程實(shí)例啟動(dòng)，將操作以下幾個(gè)數(shù)據(jù)庫表
|
1
2
3
4
5
6
7
|
act_hi_actinst 流程實(shí)例執(zhí)行歷史act_hi_identitylink 流程的參與用戶歷史信息act_hi_procinst 流程實(shí)例歷史信息act_hi_taskinst 流程任務(wù)歷史信息act_ru_execution 流程執(zhí)行信息act_ru_identitylink 流程的參與用戶信息act_ru_task 任務(wù)信息 |
5.任務(wù)查詢
流程啟動(dòng)后，任務(wù)的負(fù)責(zé)人就可以查詢自己當(dāng)前需要處理的任務(wù)，查詢出來的任務(wù)都是該用戶的待辦任務(wù)。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
|
//2.任務(wù)查詢 //流程啟動(dòng)后，任務(wù)的負(fù)責(zé)人就可以查詢自己當(dāng)前需要處理的任務(wù)，查詢出來的任務(wù)都是該用戶的待辦任務(wù)。 @test public void testfindpersonaltasklist() { //任務(wù)負(fù)責(zé)人 string assignee = "liuky"; //根據(jù)流程key 和 任務(wù)負(fù)責(zé)人 查詢?nèi)蝿?wù) list<task> list = taskservice.createtaskquery() .processdefinitionkey("myprocess_1") .taskassignee(assignee) .list(); for (task task : list) { system.out.println("流程實(shí)例id：" + task.getprocessinstanceid()); system.out.println("任務(wù)id：" + task.getid()); system.out.println("任務(wù)負(fù)責(zé)人：" + task.getassignee()); system.out.println("任務(wù)名稱：" + task.getname()); } //流程實(shí)例id：a9b162aa-ffda-11eb-bad1-02004c4f4f50 //任務(wù)id：a9b5815e-ffda-11eb-bad1-02004c4f4f50 //任務(wù)負(fù)責(zé)人：liuky //任務(wù)名稱：提交申請(qǐng) } |
6. 完成任務(wù)
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
@test public void complettask(){ //根據(jù)流程key和任務(wù)的負(fù)責(zé)人查詢?nèi)蝿?wù)并選擇其中的一個(gè)任務(wù)處理,這里用的 //是singleresult返回一條，真實(shí)環(huán)境中是通過步驟5中查詢出所有的任務(wù)，然后在頁面上選擇一個(gè)任務(wù)進(jìn)行處理. task task = taskservice.createtaskquery() .processdefinitionkey("myprocess_1") //流程key .taskassignee("liuky") //要查詢的負(fù)責(zé)人 .singleresult(); //完成任務(wù),參數(shù)：任務(wù)id taskservice.complete(task.getid()); } |
7.流程結(jié)束，或流程流轉(zhuǎn)過程中的歷史信息查詢
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
|
//流程結(jié)束，或流程流轉(zhuǎn)過程中的歷史信息查詢 @test public void findhistoryinfo(){ //獲取 actinst表的查詢對(duì)象 historicactivityinstancequery instancequery = historyservice.createhistoricactivityinstancequery(); //查詢 actinst表，條件：根據(jù) instanceid 查詢 instancequery.processinstanceid("fb5b7674-ffde-11eb-91f8-02004c4f4f50"); //增加排序操作,orderbyhistoricactivityinstancestarttime 根據(jù)開始時(shí)間排序 asc 升序 instancequery.orderbyhistoricactivityinstancestarttime().asc(); //查詢所有內(nèi)容 list<historicactivityinstance> activityinstancelist = instancequery.list(); //輸出結(jié)果 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 流程定義信息查詢
查詢流程相關(guān)信息，包含流程定義，流程部署，流程定義版本
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
@test public void queryprocessdefinition(){ //得到processdefinitionquery對(duì)象 processdefinitionquery processdefinitionquery = repositoryservice.createprocessdefinitionquery(); //查詢出當(dāng)前所有的流程定義 list<processdefinition> definitionlist = processdefinitionquery.processdefinitionkey("myprocess_1") .orderbyprocessdefinitionversion() .desc() .list(); //打印結(jié)果 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 刪除流程
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
//刪除流程 @test public void deletedeployment(){ string deploymentid = "125098e1-ffd9-11eb-8847-02004c4f4f50"; //刪除流程定義，如果該流程定義已有流程實(shí)例啟動(dòng)則刪除時(shí)出錯(cuò) repositoryservice.deletedeployment(deploymentid); //設(shè)置true 級(jí)聯(lián)刪除流程定義，即使該流程有流程實(shí)例啟動(dòng)也可以刪除，設(shè)置為false非級(jí)別刪除方式，如果流程 //repositoryservice.deletedeployment(deploymentid, true); } |
9.demo源碼下載
github: https://github.com/jxlhljh/activitidemotest.git
gitee: https://gitee.com/jxlhljh/activitidemotest.git
到此這篇關(guān)于activiti7整合springboot使用記錄的文章就介紹到這了,更多相關(guān)springboot整合activiti7內(nèi)容請(qǐng)搜索服務(wù)器之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持服務(wù)器之家！
原文鏈接：https://blog.csdn.net/jxlhljh/article/details/119775872
