package com.panzhihua.serviceapi.aop;
|
|
import java.io.BufferedReader;
|
import java.io.IOException;
|
import java.lang.reflect.Method;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
|
import org.aspectj.lang.JoinPoint;
|
import org.aspectj.lang.annotation.AfterReturning;
|
import org.aspectj.lang.annotation.Aspect;
|
import org.aspectj.lang.annotation.Pointcut;
|
import org.aspectj.lang.reflect.MethodSignature;
|
import org.springframework.stereotype.Component;
|
import org.springframework.util.ObjectUtils;
|
import org.springframework.web.context.request.RequestAttributes;
|
import org.springframework.web.context.request.RequestContextHolder;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.panzhihua.common.constants.Constants;
|
import com.panzhihua.common.constants.TokenConstant;
|
import com.panzhihua.common.interfaces.OperLog;
|
import com.panzhihua.common.model.vos.LoginUserInfoVO;
|
import com.panzhihua.common.model.vos.user.SysOperLogVO;
|
import com.panzhihua.common.service.user.UserService;
|
import com.panzhihua.common.utlis.AES;
|
import com.panzhihua.common.utlis.IPUtil;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
/**
|
* 切面处理类，操作日志异常日志记录处理
|
*
|
* @author wu
|
* @date 2019/03/21
|
*/
|
@Slf4j
|
@Aspect
|
@Component
|
public class OperLogAspect {
|
|
@Resource
|
private UserService userService;
|
|
/**
|
* 设置操作日志切入点 记录操作日志 在注解的位置切入代码
|
*/
|
@Pointcut("@annotation(com.panzhihua.common.interfaces.OperLog)")
|
public void operLogPoinCut() {}
|
|
/**
|
* 正常返回通知，拦截用户操作日志，连接点正常执行完成后执行， 如果连接点抛出异常，则不会执行
|
*
|
* @param joinPoint
|
* 切入点
|
* @param keys
|
* 返回结果
|
*/
|
@AfterReturning(value = "operLogPoinCut()", returning = "keys")
|
public void saveOperLog(JoinPoint joinPoint, Object keys) {
|
log.info("进入切面");
|
// 获取RequestAttributes
|
RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
|
// 从获取RequestAttributes中获取HttpServletRequest的信息
|
HttpServletRequest request =
|
(HttpServletRequest)requestAttributes.resolveReference(RequestAttributes.REFERENCE_REQUEST);
|
// 登录对象信息
|
String userInfo = request.getHeader(TokenConstant.TOKEN_USERINFO);
|
boolean empty = ObjectUtils.isEmpty(userInfo);
|
if (empty) {
|
log.error("操作日志获取登录用户信息失败【{}】", joinPoint);
|
return;
|
}
|
byte[] bytes = AES.parseHexStr2Byte(userInfo);
|
byte[] decrypt = AES.decrypt(bytes, Constants.AES_KEY);
|
userInfo = new String(decrypt);
|
LoginUserInfoVO loginUserInfoVO = JSONObject.parseObject(userInfo, LoginUserInfoVO.class);
|
|
SysOperLogVO operlog = new SysOperLogVO();
|
try {
|
|
// 从切面织入点处通过反射机制获取织入点处的方法
|
MethodSignature signature = (MethodSignature)joinPoint.getSignature();
|
// 获取切入点所在的方法
|
Method method = signature.getMethod();
|
// 获取操作
|
OperLog opLog = method.getAnnotation(OperLog.class);
|
if (opLog != null) {
|
String operModul = opLog.operModul();
|
int operType = opLog.operType();
|
operlog.setTitle(operModul);
|
// 操作模块
|
operlog.setBusinessType(operType);
|
// 操作类型
|
}
|
// 获取请求的类名
|
String className = joinPoint.getTarget().getClass().getName();
|
// 获取请求的方法名
|
String methodName = method.getName();
|
methodName = className + "." + methodName;
|
|
operlog.setMethod(methodName);
|
// 请求方法
|
|
if (joinPoint.getArgs().length > 0) {
|
for (Object o : joinPoint.getArgs()) {
|
if (o instanceof HttpServletRequest || o instanceof HttpServletResponse) {
|
continue;
|
}
|
operlog.setOperParam(JSONObject.toJSONString(o));
|
// 请求参数
|
}
|
}
|
|
operlog.setJsonResult(JSONObject.toJSONString(keys));
|
// 返回结果
|
operlog.setAccount(loginUserInfoVO.getAccount());
|
operlog.setOperName(loginUserInfoVO.getName());
|
// 请求用户名称
|
operlog.setOperIp(IPUtil.getIpAddress(request));
|
// 请求IP
|
operlog.setOperUrl(request.getRequestURI());
|
// 请求URI
|
operlog.setRequestMethod(request.getMethod());
|
operlog.setOperLocation(IPUtil.getIpBelongAddress(request));
|
operlog.setOperTime(new Date());
|
// 创建时间
|
operlog.setAccount(loginUserInfoVO.getAccount());
|
Long communityId = loginUserInfoVO.getCommunityId();
|
operlog.setCommunityId(null == communityId ? 0 : communityId);
|
userService.addOperLog(operlog);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 转换request 请求参数
|
*
|
* @param paramMap
|
* request获取的参数数组
|
*/
|
public Map<String, String> converMap(Map<String, String[]> paramMap) {
|
Map<String, String> rtnMap = new HashMap<>(6);
|
for (String key : paramMap.keySet()) {
|
rtnMap.put(key, paramMap.get(key)[0]);
|
}
|
return rtnMap;
|
}
|
|
private String getPostData(HttpServletRequest request) {
|
StringBuffer data = new StringBuffer();
|
String line = null;
|
BufferedReader reader = null;
|
try {
|
reader = request.getReader();
|
while (null != (line = reader.readLine())) {
|
data.append(line);
|
}
|
} catch (IOException e) {
|
} finally {
|
}
|
return data.toString();
|
}
|
|
/**
|
* 转换异常信息为字符串
|
*
|
* @param exceptionName
|
* 异常名称
|
* @param exceptionMessage
|
* 异常信息
|
* @param elements
|
* 堆栈信息
|
*/
|
public String stackTraceToString(String exceptionName, String exceptionMessage, StackTraceElement[] elements) {
|
StringBuffer strbuff = new StringBuffer();
|
for (StackTraceElement stet : elements) {
|
strbuff.append(stet + "\n");
|
}
|
String message = exceptionName + ":" + exceptionMessage + "\n\t" + strbuff.toString();
|
return message;
|
}
|
}
|
