From 9eac5df983c89eac94864e3b90b979473863381c Mon Sep 17 00:00:00 2001 From: beeajax <1105173470@qq.com> Date: Sun, 4 Jun 2023 22:20:03 +0800 Subject: [PATCH] trackHelper --- .../server/visitor/VisitorProcessor.java | 13 +++++++++-- .../docus/server/ws/convert/IConverter.java | 5 ++++ .../impl/TaskOriginalMessageServiceImpl.java | 2 +- .../log/processor/AbstractProcessor.java | 23 ++----------------- 4 files changed, 19 insertions(+), 24 deletions(-) diff --git a/common-collect/src/main/java/com/docus/server/visitor/VisitorProcessor.java b/common-collect/src/main/java/com/docus/server/visitor/VisitorProcessor.java index b231f8f..903157f 100644 --- a/common-collect/src/main/java/com/docus/server/visitor/VisitorProcessor.java +++ b/common-collect/src/main/java/com/docus/server/visitor/VisitorProcessor.java @@ -43,10 +43,20 @@ public class VisitorProcessor extends AbstractProcessor { return null; } + @Override + public Object doProcess(TrackContext context) { + if (context.isError()) { + log.debug("=== AOP 异常通知 ==="); + return afterThrowingProcess(context); + } else { + log.debug("=== AOP 后置通知 ==="); + return afterReturnProcess(context); + } + } + /** * 后置通知 */ - @Override public Object afterReturnProcess(TrackContext context) { Map params = context.getParams(); Long taskId = (Long) params.get("taskId"); @@ -60,7 +70,6 @@ public class VisitorProcessor extends AbstractProcessor { /** * 异常通知 */ - @Override public Object afterThrowingProcess(TrackContext context) { log.error(context.getExMessageResult()); Map params = context.getParams(); diff --git a/common-collect/src/main/java/com/docus/server/ws/convert/IConverter.java b/common-collect/src/main/java/com/docus/server/ws/convert/IConverter.java index 677d2fa..30a661b 100644 --- a/common-collect/src/main/java/com/docus/server/ws/convert/IConverter.java +++ b/common-collect/src/main/java/com/docus/server/ws/convert/IConverter.java @@ -2,6 +2,11 @@ package com.docus.server.ws.convert; public interface IConverter { + /** + * @param message 原始报文 + * @param methodName 目标方法 + * @return T + */ T convert(String message, String methodName); } diff --git a/common-collect/src/main/java/com/docus/server/ws/impl/TaskOriginalMessageServiceImpl.java b/common-collect/src/main/java/com/docus/server/ws/impl/TaskOriginalMessageServiceImpl.java index b1daf37..aa09305 100644 --- a/common-collect/src/main/java/com/docus/server/ws/impl/TaskOriginalMessageServiceImpl.java +++ b/common-collect/src/main/java/com/docus/server/ws/impl/TaskOriginalMessageServiceImpl.java @@ -20,7 +20,7 @@ public class TaskOriginalMessageServiceImpl extends ServiceImpl