溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章將為大家詳細講解有關Activiti7如何整合Springboot使用記錄，小編覺得挺實用的，因此分享給大家做個參考，希望大家閱讀完這篇文章后可以有所收獲。
通過https://start.spring.io/生成純凈的一個springboot工程
<dependency> <groupId>org.activiti</groupId> <artifactId>activiti-spring-boot-starter</artifactId> <version>7.1.0.M6</version> </dependency>
##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文件夾
使用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張表
啟動一個流程實例表示開始一次業務流程的運行
//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 任務信息
流程啟動后，任務的負責人就可以查詢自己當前需要處理的任務，查詢出來的任務都是該用戶的待辦任務。
//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
//任務名稱：提交申請
} @Test
public void completTask(){
//根據流程key和任務的負責人查詢任務并選擇其中的一個任務處理,這里用的
//是singleResult返回一條，真實環境中是通過步驟5中查詢出所有的任務，然后在頁面上選擇一個任務進行處理.
Task task = taskService.createTaskQuery()
.processDefinitionKey("myProcess_1") //流程Key
.taskAssignee("liuky") //要查詢的負責人
.singleResult();
//完成任務,參數：任務id
taskService.complete(task.getId());
} //流程結束，或流程流轉過程中的歷史信息查詢
@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("");
}
}查詢流程相關信息，包含流程定義，流程部署，流程定義版本
@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());
}
} //刪除流程
@Test
public void deleteDeployment(){
String deploymentId = "125098e1-ffd9-11eb-8847-02004c4f4f50";
//刪除流程定義，如果該流程定義已有流程實例啟動則刪除時出錯
repositoryService.deleteDeployment(deploymentId);
//設置true 級聯刪除流程定義，即使該流程有流程實例啟動也可以刪除，設置為false非級別刪除方式，如果流程
//repositoryService.deleteDeployment(deploymentId, true);
}關于“Activiti7如何整合Springboot使用記錄”這篇文章就分享到這里了，希望以上內容可以對大家有一定的幫助，使各位可以學到更多知識，如果覺得文章不錯，請把它分享出去讓更多的人看到。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
