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