From a6a01fc65af3c382cf32d401e2d9ffe0dbcd0929 Mon Sep 17 00:00:00 2001
From: zhaoqifeng <cpyxrjt@163.com>
Date: Fri, 28 Oct 2022 14:13:14 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../modules/item/aspect/RequestLogAspect.java | 90 +++++++++++++++++++
 1 file changed, 90 insertions(+)
 create mode 100644 esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/aspect/RequestLogAspect.java

diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/aspect/RequestLogAspect.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/aspect/RequestLogAspect.java
new file mode 100644
index 000000000..f1c5449ea
--- /dev/null
+++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/aspect/RequestLogAspect.java
@@ -0,0 +1,90 @@
+package com.elink.esua.epdc.modules.item.aspect;
+
+import com.alibaba.fastjson.JSON;
+import org.aspectj.lang.JoinPoint;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.*;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+
+@Component
+@Aspect
+public class RequestLogAspect {
+
+    private static final Logger log = LoggerFactory.getLogger(RequestLogAspect.class);
+
+    /**
+     * 切入点
+     */
+    @Pointcut("execution(* com.elink.esua.epdc.modules.item.controller..*(..)) ")
+    public void entryPoint() {
+        // 无需内容
+    }
+
+    @Before("entryPoint()")
+    public void doBefore(JoinPoint joinPoint) {
+        try {
+            ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
+            HttpServletRequest request = attributes.getRequest();
+
+            String className = joinPoint.getTarget().getClass().getName();
+            String methodName = joinPoint.getSignature().getName();
+            Object[] parameters = joinPoint.getArgs();
+            log.info("==================接口请求日志开始==================");
+            log.info("URL:"+request.getRequestURL().toString()+"\n"
+                    +"IP:"+request.getRemoteAddr()+"\n"
+                    +"HTTP Method:"+request.getMethod()+"\n"
+                    +"类名:" + className+"\n"
+                    + "方法名:" + methodName+"\n"
+                    + "请求参数:" + JSON.toJSONString(parameters));
+            log.info("==================接口请求日志结束==================");
+        } catch (Throwable e) {
+            log.info("around " + joinPoint + " with exception : " + e.getMessage());
+        }
+
+    }
+
+    @Around("entryPoint()")
+    public Object doAround(ProceedingJoinPoint joinPoint) throws Throwable {
+
+        String className = joinPoint.getTarget().getClass().getName();
+        String methodName = joinPoint.getSignature().getName();
+
+        long startTime = System.currentTimeMillis();
+        Object result = joinPoint.proceed();
+        long time = System.currentTimeMillis() - startTime;
+
+        log.info("==================接口返回日志开始==================");
+        log.info(
+                "类名:" + className+"\n"
+                        + "方法名:" + methodName+"\n"
+                        + "返回结果:" + JSON.toJSONString(result)+"\n"
+                        + "方法执行耗时:"+time+"ms"
+        );
+        log.info("==================接口返回日志结束==================");
+
+        return result;
+    }
+
+    @AfterThrowing(pointcut = "entryPoint()", throwing = "e")
+    public void doAfterThrowing(JoinPoint joinPoint, Throwable e) {
+        // 通过request获取登陆用户信息
+        // HttpServletRequest request = ((ServletRequestAttributes)
+        // RequestContextHolder.getRequestAttributes()).getRequest();
+        try {
+            String className = joinPoint.getTarget().getClass().getName();
+            String methodName = joinPoint.getSignature().getName();
+            Object[] parameters = joinPoint.getArgs();
+
+            log.info("异常方法:" + className + "." + methodName + "();参数:" + JSON.toJSONString(parameters));
+            log.info("异常信息:" + e.getMessage());
+        } catch (Exception ex) {
+            log.error("异常信息:{}", ex.getMessage());
+        }
+    }
+}