package com.oying.aspect;
|
|
import com.oying.service.SysLogService;
|
import lombok.extern.slf4j.Slf4j;
|
import com.oying.domain.SysLog;
|
import com.oying.utils.RequestHolder;
|
import com.oying.utils.SecurityUtils;
|
import com.oying.utils.StringUtils;
|
import com.oying.utils.ThrowableUtil;
|
import org.aspectj.lang.JoinPoint;
|
import org.aspectj.lang.ProceedingJoinPoint;
|
import org.aspectj.lang.annotation.AfterThrowing;
|
import org.aspectj.lang.annotation.Around;
|
import org.aspectj.lang.annotation.Aspect;
|
import org.aspectj.lang.annotation.Pointcut;
|
import org.springframework.stereotype.Component;
|
import javax.servlet.http.HttpServletRequest;
|
|
/**
|
* @author Z
|
* @date 2018-11-24
|
*/
|
@Component
|
@Aspect
|
@Slf4j
|
public class LogAspect {
|
|
private final SysLogService sysLogService;
|
|
ThreadLocal<Long> currentTime = new ThreadLocal<>();
|
|
public LogAspect(SysLogService sysLogService) {
|
this.sysLogService = sysLogService;
|
}
|
|
/**
|
* 配置切入点
|
*/
|
@Pointcut("@annotation(com.oying.annotation.Log)")
|
public void logPointcut() {
|
// 该方法无方法体,主要为了让同类中其他方法使用此切入点
|
}
|
|
/**
|
* 配置环绕通知,使用在方法logPointcut()上注册的切入点
|
*
|
* @param joinPoint join point for advice
|
*/
|
@Around("logPointcut()")
|
public Object logAround(ProceedingJoinPoint joinPoint) throws Throwable {
|
Object result;
|
currentTime.set(System.currentTimeMillis());
|
result = joinPoint.proceed();
|
SysLog sysLog = new SysLog("INFO",System.currentTimeMillis() - currentTime.get());
|
currentTime.remove();
|
HttpServletRequest request = RequestHolder.getHttpServletRequest();
|
sysLogService.save(getUsername(), StringUtils.getBrowser(request), StringUtils.getIp(request),joinPoint, sysLog);
|
return result;
|
}
|
|
/**
|
* 配置异常通知
|
*
|
* @param joinPoint join point for advice
|
* @param e exception
|
*/
|
@AfterThrowing(pointcut = "logPointcut()", throwing = "e")
|
public void logAfterThrowing(JoinPoint joinPoint, Throwable e) {
|
SysLog sysLog = new SysLog("ERROR",System.currentTimeMillis() - currentTime.get());
|
currentTime.remove();
|
sysLog.setExceptionDetail(new String(ThrowableUtil.getStackTrace(e).getBytes()));
|
HttpServletRequest request = RequestHolder.getHttpServletRequest();
|
sysLogService.save(getUsername(), StringUtils.getBrowser(request), StringUtils.getIp(request), (ProceedingJoinPoint)joinPoint, sysLog);
|
}
|
|
/**
|
* 获取用户名
|
* @return /
|
*/
|
public String getUsername() {
|
try {
|
return SecurityUtils.getCurrentUsername();
|
}catch (Exception e){
|
return "";
|
}
|
}
|
}
|