默认日期格式的支持

yzg-util-cloud/src/main/java/com/yanzuoguang/cloud/aop/MqAspect.java

@@ -2,13 +2,18 @@ package com.yanzuoguang.cloud.aop;
 
 import com.yanzuoguang.util.exception.ExceptionHelper;
 import com.yanzuoguang.util.helper.StringHelper;
+import com.yanzuoguang.util.log.Log;
 import org.aspectj.lang.ProceedingJoinPoint;
 import org.aspectj.lang.annotation.Around;
 import org.aspectj.lang.annotation.Aspect;
 import org.aspectj.lang.annotation.Pointcut;
+import org.aspectj.lang.reflect.MethodSignature;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 
+import java.lang.annotation.Annotation;
+import java.lang.reflect.Method;
+
 /**
  * LogsAspect（接口请求日志切面）
  *
@@ -39,7 +44,12 @@ public class MqAspect extends BaseRequestAspect {
      */
     @Around(value = "mqAspect()")
     public Object requestWebAround(ProceedingJoinPoint joinPoint) throws Throwable {
-        boolean clear = requestLogInit();
+        boolean clear = isRabbit(joinPoint);
+        if (clear) {
+            Log.threadBegin();
+        } else {
+            clear = requestLogInit();
+        }
         long start = requestLog(TAG, joinPoint);
         Object result = null;
         Exception ex = null;
@@ -58,6 +68,20 @@ public class MqAspect extends BaseRequestAspect {
         }
     }
 
+    private boolean isRabbit(ProceedingJoinPoint joinPoint) {
+        if (joinPoint.getSignature() instanceof MethodSignature) {
+            MethodSignature methodSignature = (MethodSignature) joinPoint.getSignature();
+            Method targetMethod = methodSignature.getMethod();
+            Annotation[] annotations = targetMethod.getAnnotations();
+            for (Annotation annotation : annotations) {
+                if (annotation.getClass().getSimpleName().indexOf("RabbitListener") >= 0) {
+                    return true;
+                }
+            }
+        }
+        return false;
+    }
+
     private Object executeMethod(ProceedingJoinPoint joinPoint) throws Throwable {
         return joinPoint.proceed();
     }