中山专业外贸网站建设,用wordpress二级导航栏,做个网站怎样做的,wordpress标签重定向一. 版本信息
IntelliJ IDEA 2023.3.6JDK 17Activiti 7
二. IDEA依赖插件安装 安装BPM流程图插件#xff0c;如果IDEA的版本超过2020,则不支持actiBPM插件。我的IDEA是2023版本我装的是 Activiti BPMN visualizer 插件。
在Plugins 搜索 Activiti BPMN visualizer 安装创建…一. 版本信息
IntelliJ IDEA 2023.3.6JDK 17Activiti 7
二. IDEA依赖插件安装 安装BPM流程图插件如果IDEA的版本超过2020,则不支持actiBPM插件。我的IDEA是2023版本我装的是 Activiti BPMN visualizer 插件。
在Plugins 搜索 Activiti BPMN visualizer 安装创建BPMN文件使用视图模式打开bpmn.xml
三. 创建SpringBoot 集成 activiti7
使用 IDEA 创建SpringBoot项目设置项目参数在 pom.xml 依赖配置文件中添加Mysql,Lombokactiviti7依赖 ?xml version1.0 encodingUTF-8?
project xmlnshttp://maven.apache.org/POM/4.0.0 xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersionparentgroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-parent/artifactIdversion3.3.4/versionrelativePath/ !-- lookup parent from repository --/parentgroupIdcom/groupIdartifactIdactiviti-demo/artifactIdversion0.0.1-SNAPSHOT/versionnameactiviti-demo/namedescriptionactiviti-demo/descriptionpropertiesjava.version17/java.version/propertiesdependencies!-- web依赖 --dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependency!-- mysql依赖 --dependencygroupIdcom.mysql/groupIdartifactIdmysql-connector-j/artifactIdversion8.2.0/version/dependency!-- lombok依赖 --dependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdoptionaltrue/optional/dependency!-- mybatis数据访问层 --dependencygroupIdcom.baomidou/groupIdartifactIdmybatis-plus-spring-boot3-starter/artifactIdversion3.5.7/version/dependency!-- activiti7 工作流引擎依赖 --dependencygroupIdorg.activiti/groupIdartifactIdactiviti-spring-boot-starter/artifactIdversion7.1.0.M6/version/dependency!-- 模块测试依赖 --dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependency/dependenciesbuildpluginsplugingroupIdorg.springframework.boot/groupIdartifactIdspring-boot-maven-plugin/artifactIdconfigurationexcludesexcludegroupIdorg.projectlombok/groupIdartifactIdlombok/artifactId/exclude/excludes/configuration/plugin/plugins/build/project创建本地连接的数据库 创建数据库 activiti CREATE DATABASE activiti /*!40100 DEFAULT CHARACTER SET utf8 */; 创建数据库表 user -- activiti.user definitionCREATE TABLE user (ID bigint(20) NOT NULL AUTO_INCREMENT COMMENT 主键,NAME varchar(100) DEFAULT NULL COMMENT 名称,AGE varchar(100) DEFAULT NULL COMMENT 年龄,CREATED_BY varchar(32) DEFAULT NULL COMMENT 创建人名称,CREATED_TIME datetime DEFAULT NULL COMMENT 创建时间,CREATED_ID varchar(32) DEFAULT NULL COMMENT 创建人ID,UPDATED_BY varchar(32) DEFAULT NULL COMMENT 更新人名称,UPDATED_TIME datetime DEFAULT NULL COMMENT 更新时间,UPDATED_ID varchar(32) DEFAULT NULL COMMENT 更新人ID,PRIMARY KEY (ID)
) ENGINEInnoDB AUTO_INCREMENT2 DEFAULT CHARSETutf8mb4 COMMENT用户信息表; 添加一条测试数据 INSERT INTO activiti.user
(ID, NAME, AGE, CREATED_BY, CREATED_TIME, CREATED_ID, UPDATED_BY, UPDATED_TIME, UPDATED_ID)
VALUES(1, 小王, 24, NULL, NULL, NULL, NULL, NULL, NULL); 添加 application.yml 配置文件 spring:application:name: activiti-demodatasource:#url切换数据库之后如果对应数据库名称和路径有变动需要修改urlurl: jdbc:mysql://localhost:3306/activiti?useUnicodetruecharacterEncodingutf-8useSSLfalseusername: rootpassword: rootdriver-class-name: com.mysql.cj.jdbc.Driver添加 activiti.cfg.xml 配置文件(文件名不能随便改) ?xml version1.0 encodingUTF-8?
!DOCTYPE beans [!ELEMENT beans (bean)*!ATTLIST beansxmlns CDATA #REQUIREDxmlns:xsi CDATA #REQUIREDxsi:schemaLocation CDATA #REQUIRED!ELEMENT bean (property)*!ATTLIST beanid CDATA #REQUIREDclass CDATA #REQUIRED!ELEMENT property (#PCDATA)!ATTLIST propertyname CDATA #REQUIREDvalue CDATA #REQUIRED]
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsd!-- processEnqine Activiti 的流程引擎 --bean idprocessEngineConfigurationclassorg.activiti.engine.impl.cfg.StandaloneProcessEngineConfigurationproperty namejdbcDriver valuecom.mysql.cj.jdbc.Driver/property namejdbcUrlvaluejdbc:mysql://localhost:3306/activiti?useUnicodetrueamp;characterEncodingUTF-8amp;serverTimezoneAsia/Shanghaiamp;useSSLfalseamp;nullCatalogMeansCurrenttrue/property namejdbcUsername valueroot/property namejdbcPassword valueroot/!-- activiti 数据库表处理策略 --!-- databaseSchemaUpdate 属性的值可以设置为以下几种 --!-- none这是默认值表示不对数据库模式做任何变更应用程序启动时不会检查数据库表结构是否与实体类匹配--!-- true设置为 true 时Spring会在应用程序启动时检查数据库表结构并在发现不匹配时自动创建或修改表结构以匹配实体类定义。这相当于执行了数据库迁移--!-- create与 true 类似但 create 会在每次启动时删除并重新创建表这可能会导致数据丢失因此使用时需要谨慎--!-- create-drop在每次启动应用程序时创建表在关闭应用程序时删除表。这通常用于测试环境--!-- validate在启动时验证数据库表结构是否与实体类定义匹配如果不匹配则抛出异常但不会自动进行任何更改--property namedatabaseSchemaUpdate valuetrue//bean
/beans启动SpringBoot项目成功开始添加一个查询数据测试接口ControllerServiceMapperEntity Controller类 package com.activitidemo.act.controller;import com.activitidemo.act.entity.UserEntity;
import com.activitidemo.act.service.impl.UserServiceImp;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import jakarta.annotation.Resource;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;/*** p* 前端控制器* /p** author ningbeibei* since 2024-09-26*/
RestController
RequestMapping(/user-entity)
public class UserController {Resourceprivate UserServiceImp userService;PostMapping(/user)public Object getUser(RequestBody UserEntity user){QueryWrapperUserEntity queryWrapper new QueryWrapper();queryWrapper.eq(id,user.getId());return userService.getBaseMapper().selectList(queryWrapper);}} Service 类 package com.activitidemo.act.service;import com.activitidemo.act.entity.UserEntity;
import com.baomidou.mybatisplus.extension.service.IService;/*** author ningbeibei* since 2024-09-26*/
public interface UserService extends IServiceUserEntity {}package com.activitidemo.act.service.impl;import com.activitidemo.act.mapper.UserMapper;
import com.activitidemo.act.service.UserService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
import com.activitidemo.act.entity.UserEntity;/*** p* 服务实现类* /p** author ningbeibei* since 2024-09-26*/
Service
public class UserServiceImp extends ServiceImplUserMapper, UserEntity implements UserService {
}Mapper 类 package com.activitidemo.act.mapper;import com.activitidemo.act.entity.UserEntity;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;/*** p* Mapper 接口* /p** author ningbeibei* since 2024-09-26*/
Mapper
public interface UserMapper extends BaseMapperUserEntity {}?xml version1.0 encodingUTF-8?
!DOCTYPE mapper PUBLIC -//mybatis.org//DTD Mapper 3.0//EN http://mybatis.org/dtd/mybatis-3-mapper.dtd
mapper namespacecom.activitidemo.act.entity.UserEntity/mapperEntity 类 package com.activitidemo.act.entity;import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Getter;
import lombok.Setter;import java.io.Serializable;
import java.time.LocalDateTime;/*** author ningbeibei* since 2024-09-26*/
Getter
Setter
TableName(user)
public class UserEntity implements Serializable {private static final long serialVersionUID 1L;TableField(ID)private Integer id;TableField(NAME)private String name;TableField(AGE)private int age;TableField(CREATED_BY)private String createdBy;TableField(CREATED_TIME)private LocalDateTime createdTime;TableField(CREATED_ID)private String createdId;TableField(UPDATED_BY)private String updatedBy;TableField(UPDATED_TIME)private LocalDateTime updatedTime;TableField(UPDATED_ID)private String updatedId;}目录结构使用Postman接口测试工具测试接口是否正常
四. Activiti 使用步骤 Activiti 主要流程操作步骤: 定义流程按照BPMN的规范使用流程定义工具用流程符号把整个流程描述出来。部署流程把画好的流程定义文件加载到数据库中生成表的数据。启动流程使用 java 代码来操作数据库表中的内容。处理任务操作流程当中的各个任务。 1. 定义流程 2. 初始库表、定义、部署、操作任务代码
创建测试类 测试代码
package com.activitidemo;import org.activiti.engine.HistoryService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.RuntimeService;
import org.activiti.engine.TaskService;
import org.activiti.engine.history.HistoricActivityInstance;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.repository.ProcessDefinition;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Comment;
import org.activiti.engine.task.Task;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.util.FileCopyUtils;import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.List;SpringBootTest
class ActivitiDemoApplicationTests {// 创建 ProcessEngine 对象
// private ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();// /**
// * 初始化数据库表第一种方式
// */
// Test
// public void testInitOne() {
// ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();
// System.err.println(processEngine processEngine);
// }/*** 初始化数据库表* 通过读取 activiti.cfg.xml 配置文件*/Testpublic void testInitTwo() {ProcessEngineConfiguration configuration ProcessEngineConfiguration.createProcessEngineConfigurationFromResource(activiti.cfg.xml);ProcessEngine processEngine configuration.buildProcessEngine();System.err.println(processEngine processEngine);}/*** 流程部署*/Testpublic void testDeploy() {// 创建 ProcessEngine 对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();// 获取 repositoryService 对象RepositoryService repositoryService processEngine.getRepositoryService();// 进行部署Deployment deployment repositoryService.createDeployment().addClasspathResource(process/leave.bpmn20.xml).addClasspathResource(process/leave.bpmn20.png).name(请假流程).deploy();// 输出部署的一些信息System.out.println(流程部署ID deployment.getId());System.out.println(流程部署名称 deployment.getName());System.out.println(流程部署成功);}/*** 启动流程实例*/Testpublic void testStartProcess() {// 创建 ProcessEngine 对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();// 获取 runtimeService 对象RuntimeService runtimeService processEngine.getRuntimeService();// 1.根据流程定义的key启动流程实例这个key是在定义bpmn的时候设置的ProcessInstance instance runtimeService.startProcessInstanceByKey(leave);// 2.根据流程定义id启动流程实例
// ProcessInstance instance runtimeService.startProcessInstanceById(leave:1:4);// 获取流程实例的相关信息System.out.println(流程定义的id instance.getProcessDefinitionId());System.out.println(流程实例的id instance.getId());System.out.println(启动流程成功 );}/*** 查询待办任务*/Testpublic void testSelectTodoTaskList() {String assignee 李四;// 创建 ProcessEngine 对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();// 获取指定用户审核任务TaskService taskService processEngine.getTaskService();// 使用面对对象方式查询数据库ListTask tasks taskService.createTaskQuery().processDefinitionKey(leave).taskAssignee(assignee)// 返回多个结果.list();// 只返回一个结果// .singleResult();// 自定义 sql 查询// taskService.createNativeTaskQuery();// 获取流程实例的相关信息for (Task task : tasks) {System.out.println(流程定义的id task.getProcessDefinitionId());System.out.println(流程实例的id task.getProcessInstanceId());System.out.println(任务id task.getId());System.out.println(任务名称 task.getName());}}/*** 指定用户去完成任务待办多人审批在这操作改变审核人名称就行了*/Testpublic void testCompleteTask() {String assignee 李四;// 创建 ProcessEngine 对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();// 获取指定用户审核任务TaskService taskService processEngine.getTaskService();ListTask tasks taskService.createTaskQuery().processDefinitionKey(leave).taskAssignee(assignee).list();if (tasks ! null !tasks.isEmpty()){// 当前流程图所限制只能做审核同意的动作for (Task task : tasks) {taskService.complete(task.getId());}}}/*** 审批添加备注*/Testpublic void testAddComment() {String assignee 张三;// 创建 ProcessEngine 对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();// 获取指定用户审核任务TaskService taskService processEngine.getTaskService();ListTask tasks taskService.createTaskQuery().processDefinitionKey(leave).taskAssignee(assignee).list();if (tasks ! null !tasks.isEmpty()) {// 当前流程图所限制只能做审核同意的动作for (Task task : tasks) {// 添加备注taskService.addComment(task.getId(), task.getProcessInstanceId(), assignee 表示同意);taskService.complete(task.getId());}}}/*** 查询审批历史*/Testpublic void testSelectHistoryTask() {String processInstanceId 2501;String assignee 张三;// 创建 ProcessEngine 对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();// 查看历史信息HistoryService historyService processEngine.getHistoryService();// 获取指定用户审核任务TaskService taskService processEngine.getTaskService();// 获取历史审核信息ListHistoricActivityInstance userTask historyService.createHistoricActivityInstanceQuery().activityType(userTask)// 指定实例的id.processInstanceId(processInstanceId).taskAssignee(assignee).finished().list();for (HistoricActivityInstance instance : userTask) {System.out.println(任务名称 instance.getActivityName());System.out.println(任务开始时间 instance.getStartTime());System.out.println(任务结束时间 instance.getEndTime());System.out.println(任务耗时 instance.getDurationInMillis());// 获取审批批注信息ListComment taskComments taskService.getTaskComments(instance.getTaskId());if (!taskComments.isEmpty()){System.out.println(审批批注 taskComments.get(0).getFullMessage());}}}/*** 查询流程相关信息*/Testpublic void testDefinitionQuery() {// 创建 ProcessEngine 对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();// 获取仓库服务RepositoryService repositoryService processEngine.getRepositoryService();// 获取流程定义集合ListProcessDefinition processDefinitionList repositoryService.createProcessDefinitionQuery().processDefinitionKey(leave)// 最新的一个版本.latestVersion().list();// 遍历集合for (ProcessDefinition definition : processDefinitionList) {System.out.println(流程定义id definition.getId());System.out.println(流程定义名称 definition.getName());System.out.println(流程定义key definition.getKey());System.out.println(流程定义版本 definition.getVersion());System.out.println(流程部署id definition.getDeploymentId());System.out.println();}}/*** 资源文件下载*/Testpublic void testDownloadResource() throws IOException {// 创建 ProcessEngine 对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();// 获取仓库服务RepositoryService repositoryService processEngine.getRepositoryService();// 获取流程定义集合ListProcessDefinition list repositoryService.createProcessDefinitionQuery().processDefinitionKey(leave)// 按照版本降序.orderByProcessDefinitionVersion()// 降序.desc().list();// 获取最新那个ProcessDefinition definition list.get(0);// 获取部署idString deploymentId definition.getDeploymentId();// 获取bpmn的输入流InputStream bpmnInputStream repositoryService.getResourceAsStream(deploymentId, definition.getResourceName());// 获取png的输入流
// InputStream pngInputStream repositoryService.getResourceAsStream(deploymentId, definition.getDiagramResourceName());String resourcePath C:/Users/ASUS/Desktop/ File.separator definition.getResourceName();File file new File(resourcePath);if (!file.exists()) {file.getParentFile().mkdirs();}String diagramResourcePath C:/Users/ASUS/Desktop/ File.separator definition.getDiagramResourceName();file new File(diagramResourcePath);if (!file.exists()) {file.getParentFile().mkdirs();}//复制文件FileCopyUtils.copy(bpmnInputStream, Files.newOutputStream(Paths.get(resourcePath)));
// FileCopyUtils.copy(pngInputStream, Files.newOutputStream(Paths.get(diagramResourcePath)));}/*** 删除已经部署的流程定义*/Testpublic void testDeleteDeploy() {// 删除已经部署的流程定义String deploymentId 45001;// 创建 ProcessEngine 对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();// 获取仓库服务RepositoryService repositoryService processEngine.getRepositoryService();// 删除流程定义如果改流程定义已有流程实例启动则会报错
// repositoryService.deleteDeployment(deploymentId);// 设置 true级联删除流程定义即使有启动的实例也可以删除repositoryService.deleteDeployment(deploymentId, true);}/*** 启动流程需要进行 BusinessKey 绑定流程实例*/Testpublic void testStartBindBusinessKey() {String businessKey 1;// 创建 ProcessEngine 对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RuntimeService runtimeService processEngine.getRuntimeService();// 根据流程定义的key启动流程实例这个key是在定义bpmn的时候设置的// 在启动流程的时候将业务key加进去ProcessInstance instance runtimeService.startProcessInstanceByKey(leave, businessKey);// 获取流程实例的相关信息System.out.println(流程定义id instance.getProcessDefinitionId());System.out.println(流程实例id instance.getId());System.out.println(业务标识 instance.getBusinessKey());}/*** 跑到下一个节点需要进行审批了此时需要获取 BusinessKey 进而获取请假单信息*/Testpublic void testGetBusinessKey() {// 1、获取李四的待办信息ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();TaskService taskService processEngine.getTaskService();ListTask task taskService.createTaskQuery().taskAssignee(李四).processDefinitionKey(leave).list();// 2、获取 businessKey// 获取流程实例idString processInstanceId task.get(1).getProcessInstanceId();RuntimeService runtimeService processEngine.getRuntimeService();ProcessInstance processInstance runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();String businessKey processInstance.getBusinessKey();System.out.println(业务标识 businessKey);}/*** 流程定义挂起与激活*/Testpublic void testSuspendAllProcessInstance() {// 创建 ProcessEngine 对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();// 获取仓库服务RepositoryService repositoryService processEngine.getRepositoryService();// 获取流程定义对象ProcessDefinition processDefinition repositoryService.createProcessDefinitionQuery().processDefinitionKey(leave).singleResult();boolean suspended processDefinition.isSuspended();// 输出流程定义状态System.out.println(流程定义状态 (suspended ? 已挂起 : 已激活));String processDefinitionId processDefinition.getId();if (suspended) {repositoryService.activateProcessDefinitionById(processDefinitionId, true, null);System.out.println(流程id processDefinitionId 已激活);} else {repositoryService.suspendProcessDefinitionById(processDefinitionId, true, null);System.out.println(流程id processDefinitionId 已挂起);}}/*** 流程实例挂起与激活*/Testpublic void testProcessInstance() {// 创建 ProcessEngine 对象ProcessEngine processEngine ProcessEngines.getDefaultProcessEngine();RuntimeService runtimeService processEngine.getRuntimeService();// 获取流程定义对象ListProcessInstance processInstanceList runtimeService.createProcessInstanceQuery().processDefinitionKey(leave).list();// 遍历集合for (ProcessInstance processInstance : processInstanceList) {boolean suspended processInstance.isSuspended();// 输出流程定义状态System.out.println(流程实例状态 processInstance , (suspended ? 已挂起 : 已激活));String processDefinitionId processInstance.getId();if (suspended) {runtimeService.activateProcessInstanceById(processDefinitionId);System.out.println(流程实例id processDefinitionId 已激活);} else {runtimeService.suspendProcessInstanceById(processDefinitionId);System.out.println(流程实例id processDefinitionId 已挂起);}}}
}
