|
@Aspect
@Component
public class WebLogAspect {
private final Logger logger = LoggerFactory.getLogger(WebLogAspect.class);
@RpcConsumer
SysLogService sysLogService;
@Autowired
RedisOperator redis;
@Pointcut("execution(* com.yankuang.*..*Controller.*(..)) && !execution(* com.yankuang.*..*.login*(..))")
public void login() {
}
@Pointcut("execution(* com.yankuang.*..*Controller.*(..))")
public void webLog() {
}
@Pointcut("execution( * com.yankuang.*..*Controller.*(..)) && !execution(* com.yankuang.*..*.create*(..)) && !execution(* com.yankuang.*..*.update*(..)) " +
"&& !execution(* com.yankuang.*..*.delete*(..)) && !execution(* com.yankuang.*..*.find*(..))")
public void sysLog() {
}
/**
* 添加业务逻辑方法切入点
*/
@Pointcut("execution(* com.yankuang.*..*.create*(..)) ")
public void insertCell() {
}
/**
* 修改业务逻辑方法切入点
*/
@Pointcut("execution(* com.yankuang.*..*.update*(..)) ")
public void updateCell() {
}
/**
* 删除业务逻辑方法切入点
*/
@Pointcut("execution(* com.yankuang.*..*.delete*(..)) ")
public void deleteCell() {
}
/**
* 查询业务逻辑方法切入点
*/
@Pointcut("execution(* com.yankuang.*..*.find*(..)) ")
public void findCell() {
}
/**
* 拦截异常处理
*/
@Pointcut("execution(* com.yankuang.*..controller.*Controller(..))") //切点
public void webExceptionLog() {
}
@Before("webLog()")
public void doBefore(JoinPoint joinPoint) throws Throwable {
// 接收到请求，记录请求内容
ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
HttpServletRequest request = attributes.getRequest();
// 记录下请求内容
logger.info("访问地址 : " + request.getRequestURL().toString());// 访问地址
logger.info("请求方式 : " + request.getMethod());// 请求方式
logger.info("访问IP : " + InetAddress.getLocalHost().toString().substring(InetAddress.getLocalHost().toString().lastIndexOf("/") + 1));
logger.info("执行了" + joinPoint.getTarget().getClass().getName() + "类的" + joinPoint.getSignature().getName() + "方法");// 获取哪个类哪个方法
logger.info("传入参数 : " + Arrays.toString(joinPoint.getArgs()));//获取传入目标方法的参数对象
logger.info("请求token : " + request.getHeader("token"));// 请求token
}
/**
* 除增删改查（add,delete,update,find）之外的操作日志(后置通知)
*
* @param joinPoint
* @param object
*/
@AfterReturning(returning = "object", pointcut = "sysLog()")
public void sysLog(JoinPoint joinPoint, Object object) throws Throwable {
// 判断参数
if (joinPoint.getArgs() == null) {// 没有参数
return;
}
SysLog syslog = new SysLog();
syslog.setContent(opContent(joinPoint));
syslog.setIpAddress(InetAddress.getLocalHost().toString().substring(InetAddress.getLocalHost().toString().lastIndexOf("/") + 1));
syslog.setReturnedContent("返回内容为：" + object);
sysLogService.create(syslog);
}
/**
* 添加操作日志(后置通知)
*
* @param joinPoint
* @param object
*/
@AfterReturning(returning = "object", pointcut = "insertCell()")
public void insertLog(JoinPoint joinPoint, Object object) throws Throwable {
// 判断参数
if (joinPoint.getArgs() == null) {// 没有参数
return;
}
SysLog syslog = new SysLog();
syslog.setContent(opContent(joinPoint));
syslog.setOperation("添加");
syslog.setIpAddress(InetAddress.getLocalHost().toString().substring(InetAddress.getLocalHost().toString().lastIndexOf("/") + 1));
syslog.setReturnedContent("返回内容为：" + object);
sysLogService.create(syslog);
}
/**
* 管理员删除操作日志(后置通知)
*
* @param joinPoint
* @param object
* @throws Throwable
*/
@AfterReturning(value = "deleteCell()", returning = "object")
public void deleteLog(JoinPoint joinPoint, Object object) throws Throwable {
// 判断参数
if (joinPoint.getArgs() == null) {// 没有参数
return;
}
// 创建日志对象
SysLog syslog = new SysLog();
syslog.setContent(opContent(joinPoint));
syslog.setOperation("删除");
syslog.setIpAddress(InetAddress.getLocalHost().toString().substring(InetAddress.getLocalHost().toString().lastIndexOf("/") + 1));
syslog.setReturnedContent("返回内容为：" + object);
sysLogService.create(syslog);
}
/**
* 管理员修改操作日志(后置通知)
*
* @param joinPoint
* @param object
* @throws Throwable
*/
@AfterReturning(value = "updateCell()", returning = "object")
public void updateLog(JoinPoint joinPoint, Object object) throws Throwable {
// 判断参数
if (joinPoint.getArgs() == null) {// 没有参数
return;
}
// 创建日志对象
SysLog syslog = new SysLog();
syslog.setContent(opContent(joinPoint));
syslog.setOperation("修改");
syslog.setIpAddress(InetAddress.getLocalHost().toString().substring(InetAddress.getLocalHost().toString().lastIndexOf("/") + 1));
syslog.setReturnedContent("返回内容为：" + object);
sysLogService.create(syslog);
}
/**
* 管理员查找操作日志(后置通知)
*
* @param joinPoint
* @param object
* @throws Throwable
*/
@AfterReturning(value = "findCell()", returning = "object")
public void findLog(JoinPoint joinPoint, Object object) throws Throwable {
// 判断参数
if (joinPoint.getArgs() == null) {// 没有参数
return;
}
// 创建日志对象
SysLog syslog = new SysLog();
syslog.setContent(opContent(joinPoint));
syslog.setOperation("查询");
syslog.setIpAddress(InetAddress.getLocalHost().toString().substring(InetAddress.getLocalHost().toString().lastIndexOf("/") + 1));
syslog.setReturnedContent("返回内容为：" + object);
sysLogService.create(syslog);
}
/**
* 异常通知 用于拦截异常日志
*
* @param joinPoint
* @param e
*/
@AfterThrowing(pointcut = "webExceptionLog()", throwing = "e")
public void doAfterThrowing(JoinPoint joinPoint, Throwable e) {
HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
//获取用户请求方法的参数并序列化为JSON格式字符串
try {
// 创建日志对象
SysLog syslog = new SysLog();
syslog.setContent(opContent(joinPoint));
syslog.setIpAddress(InetAddress.getLocalHost().toString().substring(InetAddress.getLocalHost().toString().lastIndexOf("/") + 1));
syslog.setExceptionName(e.getClass().getName());
syslog.setExceptionMsg(e.getMessage());
//保存数据库
sysLogService.create(syslog);
} catch (Exception ex) {
//记录本地异常日志
e.printStackTrace();
}
}
/**
* 获取执行的操作的信息
*
* @param joinPoint
* @return
*/
public String opContent(JoinPoint joinPoint) {
//获取类名
String className = joinPoint.getTarget().getClass().getName();
//获取方法名
String methodName = joinPoint.getSignature().getName();
String str = "执行了" + className + "类的" + methodName + "方法";
return str;
}
/**
* 接口拦截验证
*
* @param joinPoint
* @throws Throwable
*/
@Around("login()") // CommonResponse
public Object loginVerify(ProceedingJoinPoint joinPoint) throws Throwable {
HttpServletRequest request =
((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
String token = request.getHeader("token");
if (StringUtils.isEmpty(token)) {
return CommonResponse.errorTokenMsg("token不能为空，请登录");
}
String authorityCode = request.getHeader("authorityCode");
if (StringUtils.isEmpty(authorityCode)) {
return CommonResponse.errorTokenMsg("authorityCode不能为空");
}
String userRedis = (String) redis.get(token);
if (StringUtils.isEmpty(userRedis)) {
return CommonResponse.errorTokenMsg("登陆超时，请重新登录！");
}
// 刷新token时长
redis.expire(token, 7200);
// json转对象 todo
//UserDTO userFromRedis = JsonUtils.jsonToPojo(userRedis, UserDTO.class);
// 根据authorityCode鉴权 todo
// 登录跟验证权限通过，接受相应方法返回值（可做相应处理），返回前端 todo
//CommonResponse result = (CommonResponse) joinPoint.proceed();
return joinPoint.proceed();
}
}
|
