Activiti7整合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;@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(); }}
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的配置
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/
##啟動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文件夾
使用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)@SpringBootTestpublic 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張表
啟動一個流程實例表示開始一次業務流程的運行
//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();//完成任務,參數：任務idtaskService.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: https://github.com/jxlhljh/activitidemotest.gitgitee: https://gitee.com/jxlhljh/activitidemotest.git
到此這篇關于Activiti7整合Springboot使用記錄的文章就介紹到這了,更多相關Springboot整合Activiti7內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網！
相關文章：
網公網安備