package com.mzl.flower.config;
|
|
import com.mzl.flower.config.exception.ValidationException;
|
import com.mzl.flower.utils.IpUtil;
|
import org.apache.commons.lang3.ArrayUtils;
|
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;
|
import java.io.PrintWriter;
|
import java.io.StringWriter;
|
import java.io.Writer;
|
import java.time.Instant;
|
import java.time.ZoneId;
|
import java.time.ZonedDateTime;
|
import java.time.format.DateTimeFormatter;
|
|
|
@Aspect
|
@Component
|
public class LoggingAspect {
|
private static final Logger logger = LoggerFactory.getLogger(LoggingAspect.class);
|
|
@Pointcut("execution(public * com.mzl.flower.web.*.*Controller.*(..))")
|
public void controllerLoggingPointcut() {
|
}
|
|
@Before("controllerLoggingPointcut()")
|
public void logBefore(JoinPoint joinPoint) {
|
}
|
|
@AfterReturning(pointcut = "controllerLoggingPointcut()", returning = "jsonResult")
|
public void logAfter(Object jsonResult) {
|
|
}
|
|
@Around("controllerLoggingPointcut()")
|
public Object logAround(ProceedingJoinPoint joinPoint) throws Throwable {
|
//程序开始的时间
|
long beginTime = System.currentTimeMillis();
|
String result = "success";
|
String errorMsg = "";
|
try {
|
Object o = joinPoint.proceed();
|
return o;
|
} catch (Throwable e) {
|
if(e instanceof ValidationException){
|
result = "validate";
|
errorMsg = ((ValidationException) e).getErrorMessageKey();
|
}else{
|
result = "error";
|
final Writer writer = new StringWriter();
|
final PrintWriter print = new PrintWriter(writer);
|
e.printStackTrace(print);
|
errorMsg = e.getMessage();
|
}
|
throw e;
|
} finally {
|
//程序结束的时间
|
long endTime = System.currentTimeMillis();
|
//程序运行结束的耗时
|
long requestTime = endTime - beginTime;
|
|
// 接收到请求
|
ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
|
HttpServletRequest request = attributes.getRequest();
|
String logReturnMsg = "{\"startTime\":\"{}\",\"endTime\":\"{}\",\"method\":\"{}\",\"api\":\"{}\"" +
|
",\"ip\":\"{}\",\"duration\":\"{}\",\"result\":\"{}\",\"errorMsg\":\"{}\"}";
|
if("success".equals(result) || "validate".equals(result)){
|
logger.info(logReturnMsg, beginTime, endTime, request.getMethod(), request.getRequestURI(), IpUtil.getIpAddress(request), requestTime, result, errorMsg);
|
}else{
|
logger.error(logReturnMsg, beginTime, endTime, request.getMethod(), request.getRequestURI(), IpUtil.getIpAddress(request), requestTime, result, errorMsg);
|
}
|
}
|
}
|
}
|
