opensource/RuoYi-Vue-Plus
2
0
Fork 1
mirror of https://gitee.com/dromara/RuoYi-Vue-Plus.git synced 2026-09-20 18:15:56 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

update 调整注释

Browse Source
This commit is contained in:
songgaoshuai 2023-12-28 12:42:21 +08:00
parent ed66fbf38e
commit 5bb3f65bae
3 changed files with 18 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/annotation/FlowListenerAnnotation.java
View File

@ -16,12 +16,12 @@ import java.lang.annotation.*;
public @interface FlowListenerAnnotation {
/**
* 流程定义
* 流程定义key
*/
String processDefinitionKey();
/**
* 节点定义
* 节点id
*/
String taskDefId() default "";
}

4
ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/flowable/config/GlobalFlowableListener.java
View File

@ -107,8 +107,8 @@ public class GlobalFlowableListener implements FlowableEventListener {
ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().processDefinitionId(entity.getProcessDefinitionId()).singleResult();
String processDefinitionKey = processDefinition.getKey();
String taskDefinitionKey = entity.getTaskDefinitionKey();
String beanName = processDefinitionKey + "_" + taskDefinitionKey;
FlowTaskEventHandler handler = flowEventStrategy.getTaskHandler(beanName);
String key = processDefinitionKey + "_" + taskDefinitionKey;
FlowTaskEventHandler handler = flowEventStrategy.getTaskHandler(key);
if (handler != null) {
handler.handleTask(entity);
}

23
ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/flowable/strategy/FlowEventStrategy.java
View File

@ -23,7 +23,7 @@ public class FlowEventStrategy implements BeanPostProcessor {
@Override
public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {
if (bean instanceof FlowTaskEventHandler || bean instanceof FlowProcessEventHandler) {
if (bean instanceof FlowTaskEventHandler) {
FlowListenerAnnotation annotation = bean.getClass().getAnnotation(FlowListenerAnnotation.class);
if (null != annotation) {
if (StringUtils.isNotBlank(annotation.processDefinitionKey()) && StringUtils.isNotBlank(annotation.taskDefId())) {
@ -32,6 +32,11 @@ public class FlowEventStrategy implements BeanPostProcessor {
flowTaskEventHandlers.put(id, (FlowTaskEventHandler) bean);
}
}
}
}
if (bean instanceof FlowProcessEventHandler) {
FlowListenerAnnotation annotation = bean.getClass().getAnnotation(FlowListenerAnnotation.class);
if (null != annotation) {
if (StringUtils.isNotBlank(annotation.processDefinitionKey()) && StringUtils.isBlank(annotation.taskDefId())) {
if (!flowProcessEventHandlers.containsKey(annotation.processDefinitionKey())) {
flowProcessEventHandlers.put(annotation.processDefinitionKey(), (FlowProcessEventHandler) bean);
@ -45,24 +50,24 @@ public class FlowEventStrategy implements BeanPostProcessor {
/**
* 获取可执行bean
*
* @param beanName beanName
* @param key key
*/
public FlowTaskEventHandler getTaskHandler(String beanName) {
if (!flowTaskEventHandlers.containsKey(beanName)) {
public FlowTaskEventHandler getTaskHandler(String key) {
if (!flowTaskEventHandlers.containsKey(key)) {
return null;
}
return flowTaskEventHandlers.get(beanName);
return flowTaskEventHandlers.get(key);
}
/**
* 获取可执行bean
*
* @param beanName beanName
* @param key key
*/
public FlowProcessEventHandler getProcessHandler(String beanName) {
if (!flowProcessEventHandlers.containsKey(beanName)) {
public FlowProcessEventHandler getProcessHandler(String key) {
if (!flowProcessEventHandlers.containsKey(key)) {
return null;
}
return flowProcessEventHandlers.get(beanName);
return flowProcessEventHandlers.get(key);
}
}