diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineExecutionStartListener.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineExecutionStartListener.java index eec8d7ce6..324fbab6d 100644 --- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineExecutionStartListener.java +++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineExecutionStartListener.java @@ -70,7 +70,6 @@ public class EngineExecutionStartListener implements ExecutionListener { @Override public void notify(DelegateExecution execution) { - log.info("execution Start: {}", JSON.toJSONString(execution)); String currentActivityId = execution.getCurrentActivityId(); String assigneeListVariableName = INTERNAL_TASK_RELATION_ASSIGNEE_LIST_INFO + currentActivityId; if (execution.hasVariable(assigneeListVariableName)) { diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineProcessInstanceEventListener.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineProcessInstanceEventListener.java index 7ddb54447..c980e509a 100644 --- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineProcessInstanceEventListener.java +++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineProcessInstanceEventListener.java @@ -133,7 +133,9 @@ public class EngineProcessInstanceEventListener extends AbstractFlowableEngineEv MessagePushEventImpl messagePushEvent = MessagePushEventBuilder.createEvent(MessagePushEventType.NOTICE, assigner, noticeConfig.orElse(null), processInstance.getProcessInstanceId(), processInstance.getTenantId(), null); - log.info("发送站内信: {}", com.alibaba.fastjson.JSON.toJSONString(event)); + if (log.isDebugEnabled()) { + log.debug("发送站内信: {}", com.alibaba.fastjson.JSON.toJSONString(event)); + } eventDispatcher.dispatchEvent(messagePushEvent, processEngineConfiguration.getEngineCfgKey()); } diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEventListener.java index 1800292fb..b3d835f04 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEventListener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEventListener.java @@ -62,7 +62,9 @@ public class RocketMqBpmActivityEventListener implements BpmnActivityEventListen if (Objects.nonNull(processInstance)) { dto.setVariables(processInstance.getProcessVariables()); } - log.info("RocketMqBpmActivityEventListener#onStarted MQ.Data: {}", JSON.toJSONString(dto)); + if (log.isDebugEnabled()) { + log.debug("RocketMqBpmActivityEventListener#onStarted MQ.Data: {}", JSON.toJSONString(dto)); + } sendMessageQueue(dto, PROCESS_ACTIVITY_STARTED); } @@ -87,7 +89,9 @@ public class RocketMqBpmActivityEventListener implements BpmnActivityEventListen if (Objects.nonNull(processInstance)) { dto.setVariables(processInstance.getProcessVariables()); } - log.info("RocketMqBpmActivityEventListener#onCompleted MQ.Data: {}", JSON.toJSONString(dto)); + if (log.isDebugEnabled()) { + log.debug("RocketMqBpmActivityEventListener#onCompleted MQ.Data: {}", JSON.toJSONString(dto)); + } sendMessageQueue(dto, PROCESS_ACTIVITY_COMPLETED); } @@ -112,7 +116,9 @@ public class RocketMqBpmActivityEventListener implements BpmnActivityEventListen if (Objects.nonNull(processInstance)) { dto.setVariables(processInstance.getProcessVariables()); } - log.info("RocketMqBpmActivityEventListener#onCancelled MQ.Data: {}", JSON.toJSONString(dto)); + if (log.isDebugEnabled()) { + log.debug("RocketMqBpmActivityEventListener#onCancelled MQ.Data: {}", JSON.toJSONString(dto)); + } sendMessageQueue(dto, PROCESS_ACTIVITY_CANCELLED); } 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 98b0dfd63..c0cf5ec2f 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 @@ -110,7 +110,9 @@ public class RocketMqMessagePushEventListener implements BpmnMessagePushEventLis } MessagePushDTO dto = build(event.getNoticeConfig().getNotice().getNoticeMessageId(), PROCESS_PUSH_NOTICE, event, collectionVariable(event)); - log.info("MessagePushEventListener#onNotice MQ.Data: {}", JSON.toJSONString(dto)); + if (log.isDebugEnabled()) { + log.debug("MessagePushEventListener#onNotice MQ.Data: {}", JSON.toJSONString(dto)); + } sendMessageQueue(dto, PROCESS_PUSH_NOTICE); } @@ -126,7 +128,9 @@ public class RocketMqMessagePushEventListener implements BpmnMessagePushEventLis MessagePushDTO dto = build(event.getNoticeConfig().getPending().getPendingMessageId(), PROCESS_PUSH_PENDING, event, collectionVariable(event)); - log.info("MessagePushEventListener#onPending MQ.Data: {}", JSON.toJSONString(dto)); + if (log.isDebugEnabled()) { + log.debug("MessagePushEventListener#onPending MQ.Data: {}", JSON.toJSONString(dto)); + } sendMessageQueue(dto, PROCESS_PUSH_PENDING); } @@ -140,7 +144,9 @@ public class RocketMqMessagePushEventListener implements BpmnMessagePushEventLis } MessagePushDTO dto = build(event.getNoticeConfig().getSms().getSmsId(), PROCESS_PUSH_SMS, event, collectionVariable(event)); - log.info("MessagePushEventListener#onSms MQ.Data: {}", JSON.toJSONString(dto)); + if (log.isDebugEnabled()) { + log.debug("MessagePushEventListener#onSms MQ.Data: {}", JSON.toJSONString(dto)); + } sendMessageQueue(dto, PROCESS_PUSH_SMS); } diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/CustomBpmnProcessEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/CustomBpmnProcessEventListener.java index 4d822f28f..9cce1784b 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/CustomBpmnProcessEventListener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/CustomBpmnProcessEventListener.java @@ -1,7 +1,6 @@ package cn.axzo.workflow.server.controller.listener.process; import cn.axzo.workflow.core.listener.BpmnProcessEventListener; -import com.alibaba.fastjson.JSON; import lombok.extern.slf4j.Slf4j; import org.flowable.common.engine.api.delegate.event.FlowableEngineEntityEvent; import org.flowable.engine.delegate.event.FlowableCancelledEvent; @@ -21,17 +20,17 @@ import org.springframework.core.Ordered; public class CustomBpmnProcessEventListener implements BpmnProcessEventListener, Ordered { @Override public void onCreated(FlowableEngineEntityEvent event) { - log.info("Process onCreated: ClassName: {}, event: {}", event.getClass().getName(), JSON.toJSONString(event)); + log.info("Process onCreated: ClassName: {}", event.getClass().getName()); } @Override public void onStarted(FlowableProcessStartedEvent event) { - log.info("Process onStarted: ClassName: {}, event: {}", event.getClass().getName(), JSON.toJSONString(event)); + log.info("Process onStarted: ClassName: {}", event.getClass().getName()); } @Override public void onCancelled(FlowableCancelledEvent event) { - log.info("Process onCancelled: ClassName: {}, event: {}", event.getClass().getName(), JSON.toJSONString(event)); + log.info("Process onCancelled: ClassName: {}", event.getClass().getName()); } /** @@ -41,12 +40,12 @@ public class CustomBpmnProcessEventListener implements BpmnProcessEventListener, */ @Override public void onRejected(FlowableCancelledEvent event) { - log.info("Process onRejected: ClassName: {}, event: {}", event.getClass().getName(), JSON.toJSONString(event)); + log.info("Process onRejected: ClassName: {}", event.getClass().getName()); } @Override public void onCompleted(FlowableEngineEntityEvent event) { - log.info("Process onCompleted: ClassName: {}, event: {}", event.getClass().getName(), JSON.toJSONString(event)); + log.info("Process onCompleted: ClassName: {}", event.getClass().getName()); } @Override 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 898737b02..d4cfcc098 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 @@ -69,7 +69,9 @@ public class RocketMqBpmnProcessEventListener implements BpmnProcessEventListene .setTenantId(((ExecutionEntityImpl) event.getEntity()).getTenantId()) .setBusinessKey(((ExecutionEntityImpl) event.getEntity()).getBusinessKey()) .setBusinessProcessInstanceName(((ExecutionEntityImpl) event.getEntity()).getName()); - log.info("RocketMqBpmProcessEventListener#onCreated MQ.Data: {}", JSON.toJSONString(dto)); + if (log.isDebugEnabled()) { + log.debug("RocketMqBpmProcessEventListener#onCreated MQ.Data: {}", JSON.toJSONString(dto)); + } sendMessageQueue(dto, PROCESS_INSTANCE_CREATED); } @@ -97,14 +99,16 @@ public class RocketMqBpmnProcessEventListener implements BpmnProcessEventListene .setTenantId(((ExecutionEntityImpl) event.getEntity()).getTenantId()) .setBusinessKey(((ExecutionEntityImpl) event.getEntity()).getProcessInstance().getBusinessKey()) .setBusinessProcessInstanceName(((ExecutionEntityImpl) event.getEntity()).getProcessInstance().getName()); - log.info("RocketMqBpmProcessEventListener#onStarted MQ.Data: {}", JSON.toJSONString(dto)); + if (log.isDebugEnabled()) { + log.debug("RocketMqBpmProcessEventListener#onStarted MQ.Data: {}", JSON.toJSONString(dto)); + } sendMessageQueue(dto, PROCESS_INSTANCE_STARTED); } @Override public void onCancelled(FlowableCancelledEvent event) { if (log.isDebugEnabled()) { - log.info("RocketMQ onCancelled: ClassName: {}, event: {}", event.getClass().getName(), + log.debug("RocketMQ onCancelled: ClassName: {}, event: {}", event.getClass().getName(), JSON.toJSONString(event)); } Deployment deployment = @@ -125,7 +129,9 @@ public class RocketMqBpmnProcessEventListener implements BpmnProcessEventListene .setBusinessKey(((FlowableProcessCancelledEventImpl) event).getExecution().getProcessInstanceBusinessKey()) .setBusinessProcessInstanceName(((ExecutionEntityImpl) ((FlowableProcessCancelledEventImpl) event).getExecution()).getName()) .setCancelReason(String.valueOf(event.getCause())); - log.info("RocketMqBpmProcessEventListener#onCancelled MQ.Data: {}", JSON.toJSONString(dto)); + if (log.isDebugEnabled()) { + log.debug("RocketMqBpmProcessEventListener#onCancelled MQ.Data: {}", JSON.toJSONString(dto)); + } sendMessageQueue(dto, PROCESS_INSTANCE_CANCELLED); } @@ -137,7 +143,7 @@ public class RocketMqBpmnProcessEventListener implements BpmnProcessEventListene @Override public void onRejected(FlowableCancelledEvent event) { if (log.isDebugEnabled()) { - log.info("RocketMQ onRejected: ClassName: {}, event: {}", event.getClass().getName(), + log.debug("RocketMQ onRejected: ClassName: {}, event: {}", event.getClass().getName(), JSON.toJSONString(event)); } Deployment deployment = @@ -158,14 +164,16 @@ public class RocketMqBpmnProcessEventListener implements BpmnProcessEventListene .setBusinessKey(((FlowableProcessCancelledEventImpl) event).getExecution().getProcessInstanceBusinessKey()) .setBusinessProcessInstanceName(((ExecutionEntityImpl) ((FlowableProcessCancelledEventImpl) event).getExecution()).getName()) .setCancelReason(String.valueOf(event.getCause())); - log.info("RocketMqBpmProcessEventListener#onRejected MQ.Data: {}", JSON.toJSONString(dto)); + if (log.isDebugEnabled()) { + log.debug("RocketMqBpmProcessEventListener#onRejected MQ.Data: {}", JSON.toJSONString(dto)); + } sendMessageQueue(dto, PROCESS_INSTANCE_REJECTED); } @Override public void onCompleted(FlowableEngineEntityEvent event) { if (log.isDebugEnabled()) { - log.info("RocketMQ onCompleted: ClassName: {}, event: {}", event.getClass().getName(), + log.debug("RocketMQ onCompleted: ClassName: {}, event: {}", event.getClass().getName(), JSON.toJSONString(event)); } Deployment deployment = @@ -186,7 +194,9 @@ public class RocketMqBpmnProcessEventListener implements BpmnProcessEventListene .setTenantId(((ExecutionEntityImpl) event.getEntity()).getTenantId()) .setBusinessKey(((ExecutionEntityImpl) event.getEntity()).getProcessInstanceBusinessKey()) .setBusinessProcessInstanceName(((ExecutionEntityImpl) event.getEntity()).getName()); - log.info("RocketMqBpmProcessEventListener#onCompleted MQ.Data: {}", JSON.toJSONString(dto)); + if (log.isDebugEnabled()) { + log.debug("RocketMqBpmProcessEventListener#onCompleted MQ.Data: {}", JSON.toJSONString(dto)); + } sendMessageQueue(dto, PROCESS_INSTANCE_COMPLETED); } diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/PushPendingTaskEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/PushPendingTaskEventListener.java index 9e1933ffb..cc1d8f351 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/PushPendingTaskEventListener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/PushPendingTaskEventListener.java @@ -71,7 +71,9 @@ public class PushPendingTaskEventListener implements BpmnTaskEventListener, Orde MessagePushEventImpl event = MessagePushEventBuilder.createEvent(MessagePushEventType.PENDING, i, noticeConf, processInstance.getProcessInstanceId(), processInstance.getTenantId(), delegateTask.getId()); - log.info("发送待办消息: {}", JSON.toJSONString(event)); + if (log.isDebugEnabled()) { + log.debug("发送待办消息: {}", JSON.toJSONString(event)); + } eventDispatcher.dispatchEvent(event, processEngineConfiguration.getEngineCfgKey()); }); }); diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEventListener.java index 48a9a3389..27e434472 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEventListener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEventListener.java @@ -51,7 +51,10 @@ public class RocketMqBpmnTaskEventListener implements BpmnTaskEventListener, Ord log.debug("task created event"); } ProcessTaskDTO dto = build(delegateTask, PROCESS_TASK_CREATED); - log.info("RocketMqBpmTaskEventListener#onCreated MQ.Data: {}", com.alibaba.fastjson.JSON.toJSONString(dto)); + if (log.isDebugEnabled()) { + log.debug("RocketMqBpmTaskEventListener#onCreated MQ.Data: {}", + com.alibaba.fastjson.JSON.toJSONString(dto)); + } sendMessageQueue(dto, PROCESS_TASK_CREATED); } @@ -61,7 +64,10 @@ public class RocketMqBpmnTaskEventListener implements BpmnTaskEventListener, Ord log.debug("task assigned event"); } ProcessTaskDTO dto = build(delegateTask, PROCESS_TASK_ASSIGNED); - log.info("RocketMqBpmTaskEventListener#onAssigned MQ.Data: {}", com.alibaba.fastjson.JSON.toJSONString(dto)); + if (log.isDebugEnabled()) { + log.debug("RocketMqBpmTaskEventListener#onAssigned MQ.Data: {}", + com.alibaba.fastjson.JSON.toJSONString(dto)); + } sendMessageQueue(dto, PROCESS_TASK_ASSIGNED); } @@ -71,7 +77,10 @@ public class RocketMqBpmnTaskEventListener implements BpmnTaskEventListener, Ord log.debug("task completed event"); } ProcessTaskDTO dto = build(delegateTask, PROCESS_TASK_COMPLETED); - log.info("RocketMqBpmTaskEventListener#onCompleted MQ.Data: {}", com.alibaba.fastjson.JSON.toJSONString(dto)); + if (log.isDebugEnabled()) { + log.debug("RocketMqBpmTaskEventListener#onCompleted MQ.Data: {}", + com.alibaba.fastjson.JSON.toJSONString(dto)); + } sendMessageQueue(dto, PROCESS_TASK_COMPLETED); } @@ -81,7 +90,10 @@ public class RocketMqBpmnTaskEventListener implements BpmnTaskEventListener, Ord log.debug("task deleted event"); } ProcessTaskDTO dto = build(delegateTask, PROCESS_TASK_DELETED); - log.info("RocketMqBpmTaskEventListener#onDeleted MQ.Data: {}", com.alibaba.fastjson.JSON.toJSONString(dto)); + if (log.isDebugEnabled()) { + log.debug("RocketMqBpmTaskEventListener#onDeleted MQ.Data: {}", + com.alibaba.fastjson.JSON.toJSONString(dto)); + } sendMessageQueue(dto, PROCESS_TASK_DELETED); }