From a43cce3ed05f3745a83e6edd861c18288878b237 Mon Sep 17 00:00:00 2001 From: wangli <274027703@qq.com> Date: Thu, 5 Mar 2026 20:36:26 +0800 Subject: [PATCH] =?UTF-8?q?hotfix=20-=20=E5=A4=84=E7=90=86=20MQ=20message?= =?UTF-8?q?=20body=20size=20=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../RocketMqBpmActivityEvent_100_Listener.java | 2 +- .../notice/RocketMqMessagePushEventListener.java | 2 +- .../process/RocketMqBpmnProcessEventListener.java | 12 ++++++------ .../task/RocketMqBpmnTaskEvent_102_Listener.java | 2 +- 4 files changed, 9 insertions(+), 9 deletions(-) diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEvent_100_Listener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEvent_100_Listener.java index c351517b0..45c9313ef 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEvent_100_Listener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEvent_100_Listener.java @@ -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 { diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java index c6a8e63cc..878802e1c 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java @@ -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 { diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/RocketMqBpmnProcessEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/RocketMqBpmnProcessEventListener.java index 5e945fc39..940119d24 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/RocketMqBpmnProcessEventListener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/RocketMqBpmnProcessEventListener.java @@ -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 { diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEvent_102_Listener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEvent_102_Listener.java index dfb2a0792..2c6b3f193 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEvent_102_Listener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEvent_102_Listener.java @@ -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 {