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

update - 调整日志打印

Browse Source
This commit is contained in:
wangli 2023-12-06 14:20:09 +08:00
parent 97e91cbfdf
commit f40bd07fad
8 changed files with 63 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineExecutionStartListener.java
View File

@ -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)) {

4
workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineProcessInstanceEventListener.java
View File

@ -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());
}

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

@ -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);
}

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

@ -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);
}

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

@ -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

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

@ -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);
}

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

@ -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());
});
});

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

@ -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);
}