wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

hotfix - 处理 MQ message body size 的问题

Browse Source
This commit is contained in:
wangli 2026-03-05 20:36:26 +08:00
parent 08aea64621
commit a43cce3ed0
4 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEvent_100_Listener.java
View File

@ -181,7 +181,7 @@ public class RocketMqBpmActivityEvent_100_Listener extends AbstractBpmnEventList
runtimeService.createProcessInstanceQuery().processInstanceId(execution.getProcessInstanceId())
.includeProcessVariables().singleResult());
SimpleFormModel formModel = getContext().getFormModel(() -> {
FormInfo formInfo = formRepositoryService.getFormModelByKey(processInstance.getProcessDefinitionKey(), processInstance.getTenantId(), false);
FormInfo formInfo = formRepositoryService.getFormModelByKey(processInstance.getProcessDefinitionKey(), processInstance.getTenantId(), true);
if (Objects.isNull(formInfo)) {
return null;
} else {

2
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java
View File

@ -427,7 +427,7 @@ public class RocketMqMessagePushEventListener extends AbstractBpmnEventListener<
});
}
SimpleFormModel formModel = getContext().getFormModel(() -> {
FormInfo formInfo = formRepositoryService.getFormModelByKey(processInstance.getProcessDefinitionKey(), processInstance.getTenantId(), false);
FormInfo formInfo = formRepositoryService.getFormModelByKey(processInstance.getProcessDefinitionKey(), processInstance.getTenantId(), true);
if (Objects.isNull(formInfo)) {
return null;
} else {

12
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/RocketMqBpmnProcessEventListener.java
View File

@ -79,7 +79,7 @@ public class RocketMqBpmnProcessEventListener extends AbstractBpmnEventListener<
BpmnTaskDelegateAssigner initiator = getContext().getInitiator(() -> BpmnTaskDelegateAssigner.toObjectCompatible(((ExecutionEntityImpl) event.getEntity()).getVariable(INTERNAL_INITIATOR)));
SimpleFormModel formModel = getContext().getFormModel(() -> {
FormInfo formInfo = formRepositoryService.getFormModelByKey(((ExecutionEntityImpl) event.getEntity()).getProcessDefinitionKey(),
((ExecutionEntityImpl) event.getEntity()).getTenantId(), false);
((ExecutionEntityImpl) event.getEntity()).getTenantId(), true);
if (Objects.isNull(formInfo)) {
return null;
} else {
@ -124,7 +124,7 @@ public class RocketMqBpmnProcessEventListener extends AbstractBpmnEventListener<
SimpleFormModel formModel = getContext().getFormModel(() -> {
FormInfo formInfo = formRepositoryService.getFormModelByKey(((ExecutionEntityImpl) event.getEntity()).getProcessDefinitionKey(),
((ExecutionEntityImpl) event.getEntity()).getTenantId(), false);
((ExecutionEntityImpl) event.getEntity()).getTenantId(), true);
if (Objects.isNull(formInfo)) {
return null;
} else {
@ -164,7 +164,7 @@ public class RocketMqBpmnProcessEventListener extends AbstractBpmnEventListener<
.getExecution().getVariable(INTERNAL_INITIATOR)));
SimpleFormModel formModel = getContext().getFormModel(() -> {
FormInfo formInfo = formRepositoryService.getFormModelByKey(((ExecutionEntityImpl) ((FlowableProcessCancelledEventImpl) event).getExecution()).getProcessDefinitionKey(),
((FlowableProcessCancelledEventImpl) event).getExecution().getTenantId(), false);
((FlowableProcessCancelledEventImpl) event).getExecution().getTenantId(), true);
if (Objects.isNull(formInfo)) {
return null;
} else {
@ -215,7 +215,7 @@ public class RocketMqBpmnProcessEventListener extends AbstractBpmnEventListener<
SimpleFormModel formModel = getContext().getFormModel(() -> {
FormInfo formInfo = formRepositoryService.getFormModelByKey(((ExecutionEntityImpl) ((FlowableProcessCancelledEventImpl) event).getExecution()).getProcessDefinitionKey(),
((FlowableProcessCancelledEventImpl) event).getExecution().getTenantId(), false);
((FlowableProcessCancelledEventImpl) event).getExecution().getTenantId(), true);
if (Objects.isNull(formInfo)) {
return null;
} else {
@ -260,7 +260,7 @@ public class RocketMqBpmnProcessEventListener extends AbstractBpmnEventListener<
SimpleFormModel formModel = getContext().getFormModel(() -> {
FormInfo formInfo = formRepositoryService.getFormModelByKey(((ExecutionEntityImpl) ((FlowableProcessCancelledEventImpl) event).getExecution()).getProcessDefinitionKey(),
((FlowableProcessCancelledEventImpl) event).getExecution().getTenantId(), false);
((FlowableProcessCancelledEventImpl) event).getExecution().getTenantId(), true);
if (Objects.isNull(formInfo)) {
return null;
} else {
@ -305,7 +305,7 @@ public class RocketMqBpmnProcessEventListener extends AbstractBpmnEventListener<
SimpleFormModel formModel = getContext().getFormModel(() -> {
FormInfo formInfo = formRepositoryService.getFormModelByKey(((ExecutionEntityImpl) event.getEntity()).getProcessDefinitionKey(),
((ExecutionEntityImpl) event.getEntity()).getTenantId(), false);
((ExecutionEntityImpl) event.getEntity()).getTenantId(), true);
if (Objects.isNull(formInfo)) {
return null;
} else {

2
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEvent_102_Listener.java
View File

@ -149,7 +149,7 @@ public class RocketMqBpmnTaskEvent_102_Listener extends AbstractBpmnEventListene
String category = getDeployment(delegateTask.getProcessInstanceId()).getKey();
SimpleFormModel formModel = getContext().getFormModel(() -> {
FormInfo formInfo = formRepositoryService.getFormModelByKey(processInstance.getProcessDefinitionKey(), processInstance.getTenantId(), false);
FormInfo formInfo = formRepositoryService.getFormModelByKey(processInstance.getProcessDefinitionKey(), processInstance.getTenantId(), true);
if (Objects.isNull(formInfo)) {
return null;
} else {