fuhouyin/flowlong
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

注释签名优化

Browse Source
This commit is contained in:
hubin 2024-06-06 12:06:40 +08:00
parent 0559addf58
commit c3612bc41a
69 changed files with 280 additions and 213 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
.gitee/ISSUE_TEMPLATE.zh-CN.md
View File

@ -1,11 +1,7 @@
### 该问题是怎么引起的？
### 重现步骤
### 报错信息

2
.gitee/PULL_REQUEST_TEMPLATE.zh-CN.md
View File

@ -1,7 +1,5 @@
### 内容说明（相关的Issue）
### 变更内容

3
README.md
View File

@ -1,7 +1,7 @@
<img src="https://foruda.gitee.com/images/1693470775312764207/27440c57_12260.png" alt="flowlong" width="100px" height="113px">
# 项目介绍
FlowLong🐉飞龙工作流
- 项目说明 `flowlong` 中文名 `飞龙` 在天美好愿景！
@ -61,7 +61,6 @@ FlowLong🐉飞龙工作流
| 超时审批 | 根据设置的超时审批时间，超时后自动审批【自动通过或拒绝】 | ✅ | | ✅ |
| 自动提醒 | 根据设置的提醒时间，提醒审批人审批【可设定提醒次数】实现接口任意方式提醒【短信，邮件，微信，钉钉等】 | ✅ |
# 贡献力量
- [运行单元测试](https://gitee.com/aizuda/flowlong/wikis/%E8%BF%90%E8%A1%8C%E5%8D%95%E5%85%83%E6%B5%8B%E8%AF%95)

35
build.gradle
View File

@ -31,7 +31,6 @@ allprojects {
}
// 子模块配置
subprojects {
apply plugin: 'java-library'
@ -39,7 +38,8 @@ subprojects {
apply plugin: 'signing'
apply plugin: "io.spring.dependency-management"
tasks.withType(JavaCompile) {
tasks.withType(JavaCompile).configureEach {
options.compilerArgs << "-Xlint:unchecked" << "-Xlint:-serial"
options.encoding = 'UTF-8'
options.warnings = false
}
@ -100,18 +100,19 @@ subprojects {
sourceCompatibility = JavaVersion.VERSION_1_8
targetCompatibility = JavaVersion.VERSION_1_8
tasks.withType(JavaCompile) {
tasks.withType(JavaCompile).configureEach {
options.encoding = 'UTF-8'
options.warnings = false
options.deprecation = true
options.compilerArgs += ["-parameters"]
}
tasks.withType(GenerateModuleMetadata) {
tasks.withType(GenerateModuleMetadata).configureEach {
enabled = false
}
task sourcesJar(type: Jar, dependsOn: classes) {
tasks.register('sourcesJar', Jar) {
dependsOn classes
archiveClassifier = 'sources'
from sourceSets.main.allSource
}
@ -123,22 +124,22 @@ subprojects {
author true
version true
failOnError false
links "http://docs.oracle.com/javase/8/docs/api"
links "https://docs.oracle.com/javase/8/docs/api"
}
}
tasks.withType(MavenPublication) {
tasks.withType(MavenPublication).configureEach {
doFirst {
options.skipCertificateChecks = true
}
}
task javadocJar(type: Jar) {
tasks.register('javadocJar', Jar) {
archiveClassifier = 'javadoc'
from javadoc
}
tasks.whenTaskAdded { task ->
tasks.configureEach { task ->
if (task.name.contains('signMavenJavaPublication')) {
task.enabled = new File(project.property('signing.secretKeyRingFile') as String).isFile()
}
@ -153,8 +154,8 @@ subprojects {
url = version.endsWith('SNAPSHOT') ? snapshotsRepoUrl : releasesRepoUrl
credentials {
username = System.getenv("MAVEN_USERNAME")
password = System.getenv("MAVEN_PASSWORD")
username = "andto"
password = "243194995"
}
}
}
@ -191,18 +192,6 @@ subprojects {
email = 'jobob@qq.com'
}
}
withXml {
def root = asNode()
root.dependencies.'*'.findAll {
def d = it
d.scope.text() == 'runtime' && project.configurations.findByName("implementation").allDependencies.find { dep ->
dep.name == it.artifactId.text()
}.each() {
d.scope*.value = 'compile'
d.appendNode('optional', true)
}
}
}
}
}

8
changelog.md
View File

@ -1,4 +1,3 @@
# 更新日志
## [v0.0.7] 2024.06.05
@ -10,16 +9,17 @@
- 不捕获可能存在得业务异常
- 其它优化完善
## [v0.0.6] 2024.05.20
- 支持并行分支执行节点
- 新增唯一节点 nodeKey 允许节点名称重复
- 调整任务实例表结构优化
```
1，模型新增 nodeKey 替代 nodeName 唯一条件，任务 displayName 修改为 taskKey
2，流程实例 currentNode 分为 currentNodeName currentNodeKey
```
- 增加枚举参与者类型
- 优化换成允许过期时间设置
- 优化任务节点审批人列表
@ -35,7 +35,6 @@
- 新增模型自定义外置表单扩展
- 优化自动审批通过或拒绝
## [v0.0.4] 2024.05.08
- 节点跳转任务支持添加参数
@ -49,7 +48,6 @@
- 新增动态构建执行新任务（不体现在流程图中）
- 优化完善定时自动审批超时等处理逻辑
## [v0.0.3] 2024.04.21
- 执行节点调整父任务节点记录携带优化
@ -59,7 +57,6 @@
- 修复会签节点驳回 Bug
- 其它代码优化
## [v0.0.2] 2024.04.18
- 新增节点条件参数处理器
@ -74,7 +71,6 @@
- 增加 重新部署流程 的测试用例
- 优化初始赋值
## [v0.0.1] 2024.04.01
- 发布创始版

4
flowlong-core/pom.xml
View File

@ -14,10 +14,6 @@
<description>flowlong core</description>
<packaging>jar</packaging>
<properties>
<!-- <spring-boot.version>2.7.0</spring-boot.version>-->
</properties>
<dependencies>
<dependency>
<groupId>org.projectlombok</groupId>

3
flowlong-core/src/main/java/com/aizuda/bpm/engine/FlowDataTransfer.java
View File

@ -62,9 +62,10 @@ public class FlowDataTransfer {
/**
* 获取传递参数
*
* @param param 传递参数
* @param 传递参数
* @return 传递参数 MAP 对象
*/
@SuppressWarnings({"all"})
public static <T> T get(String param) {
Map<String, Object> dataMap = getAll();
if (null != dataMap && !dataMap.isEmpty()) {

2
flowlong-core/src/main/java/com/aizuda/bpm/engine/FlowLongEngine.java
View File

@ -209,7 +209,7 @@ public interface FlowLongEngine {
* @param performType 参与类型
* @param flowCreator 任务创建者
* @param args 任务参数
* @return List<Task> 创建任务集合
* @return 创建任务集合
*/
List<FlwTask> createNewTask(Long taskId, TaskType taskType, PerformType performType, List<FlwTaskActor> taskActors,
FlowCreator flowCreator, Map<String, Object> args);

1
flowlong-core/src/main/java/com/aizuda/bpm/engine/ModelInstance.java
View File

@ -23,6 +23,7 @@ public interface ModelInstance {
*
* @param flowLongContext 流程引擎上下文
* @param execution 执行对象
* @return 执行结果 true 成功 false 失败
*/
boolean execute(FlowLongContext flowLongContext, Execution execution);
}

6
flowlong-core/src/main/java/com/aizuda/bpm/engine/ProcessModelCache.java
View File

@ -21,16 +21,22 @@ public interface ProcessModelCache {
/**
* 流程模型缓存KEY
*
* @return 缓存 KEY
*/
String modelCacheKey();
/**
* 流程模型内容
*
* @return 缓存内容
*/
String getModelContent();
/**
* JSON BPM 模型
*
* @return JSON BPM 模型
*/
default ProcessModel model() {
String modelContent = this.getModelContent();

2
flowlong-core/src/main/java/com/aizuda/bpm/engine/ProcessModelParser.java
View File

@ -37,6 +37,8 @@ public interface ProcessModelParser {
/**
* 流程缓存实现类
*
* @return 流程缓存
*/
FlowCache getFlowCache();
}

9
flowlong-core/src/main/java/com/aizuda/bpm/engine/TaskService.java
View File

@ -82,6 +82,7 @@ public interface TaskService {
* 完成指定实例ID活动任务
*
* @param instanceId 实例ID
* @param flowCreator 处理人员
* @return true 成功 false 失败
*/
boolean completeActiveTasksByInstanceId(Long instanceId, FlowCreator flowCreator);
@ -226,7 +227,7 @@ public interface TaskService {
*
* @param taskModel 任务模型
* @param execution 执行对象
* @return List<Task> 创建任务集合
* @return 创建任务集合
*/
List<FlwTask> createTask(NodeModel taskModel, Execution execution);
@ -242,7 +243,7 @@ public interface TaskService {
* @param performType 参与类型
* @param flowCreator 任务创建者
* @param executionFunction 执行函数
* @return List<Task> 创建任务集合
* @return 创建任务集合
*/
List<FlwTask> createNewTask(Long taskId, TaskType taskType, PerformType performType, List<FlwTaskActor> taskActors,
FlowCreator flowCreator, Function<FlwTask, Execution> executionFunction);
@ -250,7 +251,7 @@ public interface TaskService {
/**
* 获取超时或者提醒的任务
*
* @return List<Task> 任务列表
* @return 任务列表
*/
List<FlwTask> getTimeoutOrRemindTasks();
@ -269,6 +270,7 @@ public interface TaskService {
* @param performType 参与类型 {@link PerformType}
* @param flwTaskActors 参与者列表
* @param flowCreator 执行操作人员
* @return true 成功 false 失败
*/
boolean addTaskActor(Long taskId, PerformType performType, List<FlwTaskActor> flwTaskActors, FlowCreator flowCreator);
@ -282,6 +284,7 @@ public interface TaskService {
* @param taskId 任务ID
* @param actorIds 参与者ID列表
* @param flowCreator 执行操作人员
* @return true 成功 false 失败
*/
boolean removeTaskActor(Long taskId, List<String> actorIds, FlowCreator flowCreator);

1
flowlong-core/src/main/java/com/aizuda/bpm/engine/TaskTrigger.java
View File

@ -23,6 +23,7 @@ public interface TaskTrigger {
*
* @param nodeModel 节点模型
* @param execution 执行对象
* @return 执行结果 true 成功 false 失败
*/
boolean execute(NodeModel nodeModel, Execution execution);
}

5
flowlong-core/src/main/java/com/aizuda/bpm/engine/assist/DateUtils.java
View File

@ -39,6 +39,10 @@ public class DateUtils {
/**
* 日期判断
*
* @param arg0 开始时间
* @param arg1 结束时间
* @return true 开始时间大于结束时间 false 开始时间小于结束时间
*/
public static boolean after(Date arg0, Date arg1) {
return null != arg0 && null != arg1 && arg0.after(arg1);
@ -48,6 +52,7 @@ public class DateUtils {
* 日期 LocalDateTime 转为 Date
*
* @param localDateTime {@link LocalDateTime}
* @return {@link Date}
*/
public static Date toDate(LocalDateTime localDateTime) {
if (null == localDateTime) {

5
flowlong-core/src/main/java/com/aizuda/bpm/engine/assist/ObjectUtils.java
View File

@ -53,6 +53,8 @@ public class ObjectUtils {
/**
* 判断 Map 是否未 Collections$SingletonMap 对象
*
* @return true 是 false 否
*/
public static boolean isSingletonMap(Map<?, ?> mapObj) {
return Objects.equals(mapObj.getClass().getName(), "java.util.Collections$SingletonMap");
@ -60,6 +62,9 @@ public class ObjectUtils {
/**
* 使用反射机制创建类的实例
*
* @param clazz 带创建实例的类
* @return 创建对象
*/
public static Object newInstance(Class<?> clazz) throws ReflectiveOperationException {
Constructor<?> constructor = clazz.getDeclaredConstructor();

2
flowlong-core/src/main/java/com/aizuda/bpm/engine/core/Execution.java
View File

@ -143,6 +143,7 @@ public class Execution implements Serializable {
*
* @param flowLongContext 流程引擎上下文
* @param nodeKey 节点key
* @return 执行节点模型结果 true 成功 false 失败
*/
public boolean executeNodeModel(FlowLongContext flowLongContext, String nodeKey) {
ProcessModel processModel = this.getProcessModel();
@ -175,6 +176,7 @@ public class Execution implements Serializable {
/**
* 执行结束当前流程实例
*
* @param endNode 结束节点
* @return true 执行成功 false 执行失败
*/
public boolean endInstance(NodeModel endNode) {

4
flowlong-core/src/main/java/com/aizuda/bpm/engine/core/FlowLongContext.java
View File

@ -89,6 +89,9 @@ public class FlowLongContext {
/**
* 注入默认流程模型解析器
*
* @param flowCache 流程缓存
* @param processModelParser 流程模型解析器
*/
public FlowLongContext(FlowCache flowCache, ProcessModelParser processModelParser) {
if (null == processModelParser) {
@ -163,6 +166,7 @@ public class FlowLongContext {
/**
* 默认初始化流程引擎上下文
*
* @param configEngine 流程配置引擎
* @return {@link FlowLongEngine}
*/
public FlowLongContext build(FlowLongEngine configEngine) {

6
flowlong-core/src/main/java/com/aizuda/bpm/engine/core/FlowLongEngineImpl.java
View File

@ -213,6 +213,12 @@ public class FlowLongEngineImpl implements FlowLongEngine {
/**
* 根据 任务ID，创建人，参数列表完成任务，并且构造执行对象
*
* @param taskId 任务ID
* @param flowCreator 创建人
* @param args 参数列表
* @param executeNextStep 执行下一步函数方法
* @return 执行结果 true 成功 false 失败
*/
protected boolean execute(Long taskId, FlowCreator flowCreator, Map<String, Object> args, Function<Execution, Boolean> executeNextStep) {
if (args == null) {

2
flowlong-core/src/main/java/com/aizuda/bpm/engine/entity/FlwInstance.java
View File

@ -77,7 +77,7 @@ public class FlwInstance extends FlowEntity {
return flwInstance;
}
@SuppressWarnings("unchecked")
@SuppressWarnings({"all"})
public Map<String, Object> variableToMap() {
Map<String, Object> map = FlowLongContext.fromJson(this.variable, Map.class);
if (map == null) return Collections.emptyMap();

14
flowlong-core/src/main/java/com/aizuda/bpm/engine/entity/FlwProcess.java
View File

@ -111,6 +111,7 @@ public class FlwProcess extends FlowEntity implements ProcessModelCache {
* @param flowLongContext 流程引擎上下文
* @param flowCreator 流程实例任务创建者
* @param function 流程执行对象处理函数
* @return 流程实例
*/
public Optional<FlwInstance> executeStartModel(FlowLongContext flowLongContext, FlowCreator flowCreator, Function<NodeModel, Execution> function) {
FlwInstance flwInstance = null;
@ -131,6 +132,8 @@ public class FlwProcess extends FlowEntity implements ProcessModelCache {
/**
* 流程状态验证
*
* @return 流程定义实体
*/
public FlwProcess checkState() {
if (Objects.equals(0, this.processState)) {
@ -141,11 +144,20 @@ public class FlwProcess extends FlowEntity implements ProcessModelCache {
/**
* 格式化 JSON 模型内容
*
* @param modelContent JSON 模型内容
* @return 流程定义实体
*/
public FlwProcess formatModelContent(String modelContent) {
return setModelContent2Json(FlowLongContext.fromJson(modelContent, ProcessModel.class));
}
/**
* 设置 JSON 模型内容
*
* @param processModel 模型内容
* @return 流程定义实体
*/
public FlwProcess setModelContent2Json(ProcessModel processModel) {
this.modelContent = FlowLongContext.toJson(processModel);
return this;
@ -153,6 +165,8 @@ public class FlwProcess extends FlowEntity implements ProcessModelCache {
/**
* 下一个流程版本
*
* @return 下一个流程版本
*/
public int nextProcessVersion() {
return processVersion + 1;

2
flowlong-core/src/main/java/com/aizuda/bpm/engine/entity/FlwTaskActor.java
View File

@ -67,6 +67,8 @@ public class FlwTaskActor implements Serializable {
/**
* 是否为代理人
*
* @return true 是 false 否
*/
public boolean agentActor() {
return Objects.equals(1, this.weight);

1
flowlong-core/src/main/java/com/aizuda/bpm/engine/listener/FlowLongListener.java
View File

@ -26,6 +26,7 @@ public interface FlowLongListener<T> {
* @param eventType 事件类型
* @param supplier 监听实体提供者
* @param flowCreator 处理人员
* @return 通知结果 true 成功 false 失败
*/
boolean notify(EventType eventType, Supplier<T> supplier, FlowCreator flowCreator);

1
flowlong-core/src/main/java/com/aizuda/bpm/engine/model/ModelHelper.java
View File

@ -26,6 +26,7 @@ public class ModelHelper {
* 递归查找下一个执行节点
*
* @param nodeModel 当前节点
* @param currentTask 当前任务列表
* @return 流程节点模型
*/
public static NodeModel findNextNode(NodeModel nodeModel, List<String> currentTask) {

24
flowlong-core/src/main/java/com/aizuda/bpm/engine/model/NodeModel.java
View File

@ -174,6 +174,13 @@ public class NodeModel implements ModelInstance, Serializable {
*/
private List<NodeModel> parallelNodes;
/**
* 执行节点
*
* @param flowLongContext 流程引擎上下文
* @param execution 执行对象
* @return 执行结果 true 成功 false 失败
*/
@Override
public boolean execute(FlowLongContext flowLongContext, Execution execution) {
if (ObjectUtils.isNotEmpty(parallelNodes)) {
@ -260,7 +267,7 @@ public class NodeModel implements ModelInstance, Serializable {
* 获取process定义的指定节点key的节点模型
*
* @param nodeKey 节点key
* @return {@link NodeModel}
* @return 模型节点
*/
public NodeModel getNode(String nodeKey) {
if (Objects.equals(this.nodeKey, nodeKey)) {
@ -289,7 +296,7 @@ public class NodeModel implements ModelInstance, Serializable {
* 从并行节点获取key
*
* @param nodeKey 节点 key
* @return {@link NodeModel}
* @return 模型节点
*/
private NodeModel getFromParallelNode(String nodeKey) {
for (NodeModel parallelNode : parallelNodes) {
@ -305,7 +312,7 @@ public class NodeModel implements ModelInstance, Serializable {
* 从条件节点中获取节点
*
* @param nodeKey 节点 key
* @return {@link NodeModel}
* @return 模型节点
*/
private NodeModel getFromConditionNodes(String nodeKey) {
for (ConditionNode conditionNode : conditionNodes) {
@ -322,6 +329,8 @@ public class NodeModel implements ModelInstance, Serializable {
/**
* 下一个执行节点
*
* @return 模型节点
*/
public Optional<NodeModel> nextNode() {
return nextNode(null);
@ -329,6 +338,9 @@ public class NodeModel implements ModelInstance, Serializable {
/**
* 下一个执行节点
*
* @param currentTask 当前任务
* @return 模型节点
*/
public Optional<NodeModel> nextNode(List<String> currentTask) {
NodeModel nextNode = this.getChildNode();
@ -341,6 +353,8 @@ public class NodeModel implements ModelInstance, Serializable {
/**
* 判断是否为条件节点
*
* @return true 是 false 否
*/
public boolean conditionNode() {
return TaskType.conditionNode.eq(type) || TaskType.conditionBranch.eq(type);
@ -348,6 +362,8 @@ public class NodeModel implements ModelInstance, Serializable {
/**
* 判断是否为抄送节点
*
* @return true 是 false 否
*/
public boolean ccNode() {
return TaskType.cc.eq(type);
@ -355,6 +371,8 @@ public class NodeModel implements ModelInstance, Serializable {
/**
* 判断是否为并行节点
*
* @return true 是 false 否
*/
public boolean parallelNode() {
return TaskType.parallelBranch.eq(type);

2
flowlong-core/src/main/java/com/aizuda/bpm/engine/model/ProcessModel.java
View File

@ -81,6 +81,8 @@ public class ProcessModel implements Serializable {
/**
* 清理父节点关系
*
* @param rootNode 根节点
*/
public void cleanParentNode(NodeModel rootNode) {
rootNode.setParentNode(null);

2
flowlong-mybatis-plus/src/main/java/com/aizuda/bpm/mybatisplus/mapper/FlwHisTaskActorMapper.java
View File

@ -25,6 +25,7 @@ public interface FlwHisTaskActorMapper extends BaseMapper<FlwHisTaskActor> {
* 通过任务ID获取参与者列表
*
* @param taskId 任务ID
* @return 参与者列表
*/
default List<FlwHisTaskActor> selectListByTaskId(Long taskId) {
return this.selectList(Wrappers.<FlwHisTaskActor>lambdaQuery().eq(FlwHisTaskActor::getTaskId, taskId));
@ -34,6 +35,7 @@ public interface FlwHisTaskActorMapper extends BaseMapper<FlwHisTaskActor> {
* 通过任务ID获取参与者列表
*
* @param taskIds 任务ID列表
* @return 历史任务参与者列表
*/
default List<FlwHisTaskActor> selectListByTaskIds(List<Long> taskIds) {
return this.selectList(Wrappers.<FlwHisTaskActor>lambdaQuery().in(FlwHisTaskActor::getTaskId, taskIds));

5
flowlong-mybatis-plus/src/main/java/com/aizuda/bpm/mybatisplus/mapper/FlwTaskActorMapper.java
View File

@ -25,6 +25,7 @@ public interface FlwTaskActorMapper extends BaseMapper<FlwTaskActor> {
* 通过任务ID获取参与者列表
*
* @param taskId 任务ID
* @return 参与者列表
*/
default List<FlwTaskActor> selectListByTaskId(Long taskId) {
return this.selectList(Wrappers.<FlwTaskActor>lambdaQuery().eq(FlwTaskActor::getTaskId, taskId));
@ -34,6 +35,7 @@ public interface FlwTaskActorMapper extends BaseMapper<FlwTaskActor> {
* 通过任务ID列表获取参与者列表
*
* @param taskIds 任务ID列表
* @return 参与者列表
*/
default List<FlwTaskActor> selectListByTaskIds(List<Long> taskIds) {
return this.selectList(Wrappers.<FlwTaskActor>lambdaQuery().in(FlwTaskActor::getTaskId, taskIds));
@ -43,6 +45,7 @@ public interface FlwTaskActorMapper extends BaseMapper<FlwTaskActor> {
* 通过流程实例ID获取参与者列表
*
* @param instanceId 流程实例ID
* @return 参与者列表
*/
default List<FlwTaskActor> selectListByInstanceId(Long instanceId) {
return this.selectList(Wrappers.<FlwTaskActor>lambdaQuery().eq(FlwTaskActor::getInstanceId, instanceId));
@ -52,6 +55,7 @@ public interface FlwTaskActorMapper extends BaseMapper<FlwTaskActor> {
* 通过任务ID删除参与者
*
* @param taskId 任务ID
* @return true 成功 false 失败
*/
default boolean deleteByTaskId(Long taskId) {
return this.delete(Wrappers.<FlwTaskActor>lambdaQuery().eq(FlwTaskActor::getTaskId, taskId)) > 0;
@ -61,6 +65,7 @@ public interface FlwTaskActorMapper extends BaseMapper<FlwTaskActor> {
* 通过任务ID删除参与者
*
* @param taskIds 任务ID列表
* @return true 成功 false 失败
*/
default boolean deleteByTaskIds(List<Long> taskIds) {
return this.delete(Wrappers.<FlwTaskActor>lambdaQuery().in(FlwTaskActor::getTaskId, taskIds)) > 0;

2
flowlong-mybatis-plus/src/main/java/com/aizuda/bpm/mybatisplus/mapper/FlwTaskMapper.java
View File

@ -38,6 +38,7 @@ public interface FlwTaskMapper extends BaseMapper<FlwTask> {
* 根据流程实例ID获取任务列表
*
* @param instanceId 流程实例ID
* @return 任务列表
*/
default List<FlwTask> selectListByInstanceId(Long instanceId) {
return this.selectList(Wrappers.<FlwTask>lambdaQuery().eq(FlwTask::getInstanceId, instanceId));
@ -47,6 +48,7 @@ public interface FlwTaskMapper extends BaseMapper<FlwTask> {
* 根据父任务ID获取任务列表
*
* @param parentTaskId 父任务ID
* @return 任务列表
*/
default List<FlwTask> selectListByParentTaskId(Long parentTaskId) {
return this.selectList(Wrappers.<FlwTask>lambdaQuery().eq(FlwTask::getParentTaskId, parentTaskId));

8
flowlong-mybatis-plus/src/main/java/com/aizuda/bpm/mybatisplus/service/TaskServiceImpl.java
View File

@ -433,6 +433,7 @@ public class TaskServiceImpl implements TaskService {
*
* @param taskId 任务ID
* @param flowCreator 任务参与者
* @return 任务参与者
*/
protected FlwTaskActor getAllowedFlwTaskActor(Long taskId, FlowCreator flowCreator) {
List<FlwTaskActor> taskActors = taskActorMapper.selectList(Wrappers.<FlwTaskActor>lambdaQuery().eq(FlwTaskActor::getTaskId, taskId)
@ -585,6 +586,7 @@ public class TaskServiceImpl implements TaskService {
* @param hisTaskId 历史任务ID
* @param flowCreator 任务创建者
* @param hisTaskConsumer 历史任务业务处理
* @return 任务参与者
*/
protected Optional<FlwTask> undoHisTask(Long hisTaskId, FlowCreator flowCreator, Consumer<FlwHisTask> hisTaskConsumer) {
FlwHisTask hisTask = hisTaskMapper.getCheckById(hisTaskId);
@ -679,7 +681,7 @@ public class TaskServiceImpl implements TaskService {
/**
* 获取超时或者提醒的任务
*
* @return List<Task> 任务列表
* @return 任务列表
*/
@Override
public List<FlwTask> getTimeoutOrRemindTasks() {
@ -691,7 +693,7 @@ public class TaskServiceImpl implements TaskService {
* 获取任务模型
*
* @param taskId 任务ID
* @return TaskModel
* @return 节点模型
*/
@Override
public NodeModel getTaskModel(Long taskId) {
@ -885,7 +887,9 @@ public class TaskServiceImpl implements TaskService {
* 保存任务及参与者信息
*
* @param flwTask 流程任务对象
* @param performType 参与类型 {@link PerformType}
* @param taskActors 参与者ID集合
* @param execution 流程执行处理类 {@link Execution}
* @return 流程任务列表
*/
protected List<FlwTask> saveTask(FlwTask flwTask, PerformType performType, List<FlwTaskActor> taskActors, Execution execution) {

6
flowlong-spring-boot-example/src/main/resources/process.json
View File

@ -55,10 +55,12 @@
"nodeName": "直接主管审批",
"type": 1,
"setType": 2,
"nodeUserList": [{
"nodeUserList": [
{
"id": "zg0001",
"name": "张三"
}],
}
],
"nodeRoleList": [],
"examineLevel": 1,
"directorLevel": 1,

2
flowlong-spring-boot-starter/src/main/java/com/aizuda/bpm/spring/autoconfigure/FlowLongAutoConfiguration.java
View File

@ -151,6 +151,7 @@ public class FlowLongAutoConfiguration {
* 注入自定义 TaskListener 实现该方法不再生效
*
* @param eventPublisher {@link ApplicationEventPublisher}
* @return {@link EventTaskListener}
*/
@Bean
@ConditionalOnMissingBean
@ -163,6 +164,7 @@ public class FlowLongAutoConfiguration {
* 注入自定义 InstanceListener 实现该方法不再生效
*
* @param eventPublisher {@link ApplicationEventPublisher}
* @return {@link EventInstanceListener}
*/
@Bean
@ConditionalOnMissingBean

6
flowlong-spring-boot-starter/src/test/resources/test/supervisor.json
View File

@ -5,10 +5,12 @@
"nodeName": "发起人",
"nodeKey": "k001",
"type": 0,
"nodeAssigneeList": [{
"nodeAssigneeList": [
{
"id": "360000197302144442",
"name": "何敏"
}],
}
],
"childNode": {
"nodeName": "条件路由",
"nodeKey": "k002",