|
@@ -0,0 +1,229 @@
|
|
|
+package com.jd.brume.common.aspect;
|
|
|
+
|
|
|
+import java.lang.reflect.Method;
|
|
|
+import java.util.Map;
|
|
|
+import javax.annotation.Resource;
|
|
|
+import javax.servlet.http.HttpServletRequest;
|
|
|
+import javax.servlet.http.HttpServletResponse;
|
|
|
+
|
|
|
+
|
|
|
+import cn.hutool.core.date.DateUtil;
|
|
|
+import cn.hutool.json.JSONObject;
|
|
|
+import com.jd.brume.common.annotation.Log;
|
|
|
+import com.jd.brume.common.enums.OpertateStatus;
|
|
|
+import com.jd.brume.entity.LogEntity;
|
|
|
+import com.jd.brume.service.LogService;
|
|
|
+import com.jd.brume.util.TokenUtil;
|
|
|
+import com.jd.brume.util.IpUtils;
|
|
|
+import io.spring.gradle.dependencymanagement.org.codehaus.plexus.util.StringUtils;
|
|
|
+import org.aspectj.lang.JoinPoint;
|
|
|
+import org.aspectj.lang.Signature;
|
|
|
+import org.aspectj.lang.annotation.AfterReturning;
|
|
|
+import org.aspectj.lang.annotation.AfterThrowing;
|
|
|
+import org.aspectj.lang.annotation.Aspect;
|
|
|
+import org.aspectj.lang.annotation.Pointcut;
|
|
|
+import org.aspectj.lang.reflect.MethodSignature;
|
|
|
+import org.slf4j.Logger;
|
|
|
+import org.slf4j.LoggerFactory;
|
|
|
+import org.springframework.http.HttpMethod;
|
|
|
+import org.springframework.stereotype.Component;
|
|
|
+import org.springframework.web.multipart.MultipartFile;
|
|
|
+import org.springframework.web.servlet.HandlerMapping;
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
|
+
|
|
|
+/**
|
|
|
+ * 操作日志记录处理
|
|
|
+ *
|
|
|
+ */
|
|
|
+@Aspect
|
|
|
+@Component
|
|
|
+class LogAspect
|
|
|
+{
|
|
|
+ private static final Logger log = LoggerFactory.getLogger(LogAspect.class);
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private LogService logService;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private HttpServletRequest request;
|
|
|
+
|
|
|
+ // 配置织入点
|
|
|
+ @Pointcut("@annotation(com.jd.brume.common.annotation.Log)")
|
|
|
+ public void logPointCut()
|
|
|
+ {
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 处理完请求后执行
|
|
|
+ *
|
|
|
+ * @param joinPoint 切点
|
|
|
+ */
|
|
|
+ @AfterReturning(pointcut = "logPointCut()", returning = "jsonResult")
|
|
|
+ public void doAfterReturning(JoinPoint joinPoint, Object jsonResult)
|
|
|
+ {
|
|
|
+ handleLog(joinPoint, null, jsonResult);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 拦截异常操作
|
|
|
+ *
|
|
|
+ * @param joinPoint 切点
|
|
|
+ * @param e 异常
|
|
|
+ */
|
|
|
+ @AfterThrowing(value = "logPointCut()", throwing = "e")
|
|
|
+ public void doAfterThrowing(JoinPoint joinPoint, Exception e)
|
|
|
+ {
|
|
|
+ handleLog(joinPoint, e, null);
|
|
|
+ }
|
|
|
+
|
|
|
+ protected void handleLog(final JoinPoint joinPoint, final Exception e, Object jsonResult)
|
|
|
+ {
|
|
|
+ try
|
|
|
+ {
|
|
|
+ // 获得注解
|
|
|
+ Log controllerLog = getAnnotationLog(joinPoint);
|
|
|
+ if (controllerLog == null)
|
|
|
+ {
|
|
|
+ // 未配置注解
|
|
|
+ return;
|
|
|
+ }
|
|
|
+
|
|
|
+ JSONObject jsonObj = (JSONObject)TokenUtil.getParamStr(new String[] { "userId", "userName"}, request);
|
|
|
+ if(jsonObj == null){
|
|
|
+ // token为空
|
|
|
+ return;
|
|
|
+ }
|
|
|
+
|
|
|
+ LogEntity log = new LogEntity();
|
|
|
+ // 操作人id
|
|
|
+ Integer userId = jsonObj.getInt("userId", 0);
|
|
|
+ log.setOpertateId(userId);
|
|
|
+
|
|
|
+ // 操作ip
|
|
|
+ String ip = IpUtils.getIpAddr(request);
|
|
|
+ log.setOpertateIp(ip);
|
|
|
+
|
|
|
+ // 操作类型
|
|
|
+ // 获取注解中对方法的描述信息 用于Controller层注解
|
|
|
+ log.setOpertateType(controllerLog.opertateType().getValue());
|
|
|
+
|
|
|
+ // 操作人
|
|
|
+ String userName = jsonObj.getStr("userName", "");
|
|
|
+ log.setOpertateName(userName);
|
|
|
+
|
|
|
+ // 操作时间
|
|
|
+ log.setOpertateTime(DateUtil.date());
|
|
|
+
|
|
|
+ // 模块
|
|
|
+ // 获取注解中对方法的描述信息 用于Controller层注解
|
|
|
+ log.setOpertateModule(controllerLog.title().getValue());
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ if (e != null)
|
|
|
+ {
|
|
|
+ // 操作状态:失败、成功
|
|
|
+ log.setOpertateStatus(OpertateStatus.FAIL.getValue());
|
|
|
+
|
|
|
+ // 描述
|
|
|
+ log.setOpertateDesc(StringUtils.substring(e.getMessage(), 0, 1000));
|
|
|
+ }else{
|
|
|
+
|
|
|
+ // 操作状态:失败、成功
|
|
|
+ log.setOpertateStatus(OpertateStatus.SUCCESS.getValue());
|
|
|
+
|
|
|
+ // 描述, 成功无描述
|
|
|
+ log.setOpertateDesc("");
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ // 创建时间
|
|
|
+ log.setCreateTime(DateUtil.date());
|
|
|
+
|
|
|
+ // 操作参数
|
|
|
+ setRequestValue(joinPoint, request, log);
|
|
|
+
|
|
|
+ // 返回参数
|
|
|
+ log.setNewMsg(StringUtils.substring(JSON.toJSONString(jsonResult), 0, 1000));
|
|
|
+ //log.setNewMsg("");
|
|
|
+
|
|
|
+ // 保存日志
|
|
|
+ logService.save(log);
|
|
|
+ }
|
|
|
+ catch (Exception exp)
|
|
|
+ {
|
|
|
+ // 记录本地异常日志
|
|
|
+ log.error("==前置通知异常==");
|
|
|
+ log.error("异常信息:{}", exp.getMessage());
|
|
|
+ exp.printStackTrace();
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取请求的参数,放到log中
|
|
|
+ *
|
|
|
+ * @param log 操作日志
|
|
|
+ * @throws Exception 异常
|
|
|
+ */
|
|
|
+ private void setRequestValue(JoinPoint joinPoint, HttpServletRequest request, LogEntity log) throws Exception
|
|
|
+ {
|
|
|
+ String requestMethod = request.getMethod();
|
|
|
+ if (HttpMethod.PUT.name().equals(requestMethod) || HttpMethod.POST.name().equals(requestMethod))
|
|
|
+ {
|
|
|
+ String params = argsArrayToString(joinPoint.getArgs());
|
|
|
+ log.setOldMsg(StringUtils.substring(params, 0, 1000));
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ Map<?, ?> paramsMap = (Map<?, ?>) request.getAttribute(HandlerMapping.URI_TEMPLATE_VARIABLES_ATTRIBUTE);
|
|
|
+ log.setOldMsg(StringUtils.substring(paramsMap.toString(), 0, 1000));
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 是否存在注解,如果存在就获取
|
|
|
+ */
|
|
|
+ private Log getAnnotationLog(JoinPoint joinPoint) throws Exception
|
|
|
+ {
|
|
|
+ Signature signature = joinPoint.getSignature();
|
|
|
+ MethodSignature methodSignature = (MethodSignature) signature;
|
|
|
+ Method method = methodSignature.getMethod();
|
|
|
+
|
|
|
+ if (method != null)
|
|
|
+ {
|
|
|
+ return method.getAnnotation(Log.class);
|
|
|
+ }
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 参数拼装
|
|
|
+ */
|
|
|
+ private String argsArrayToString(Object[] paramsArray)
|
|
|
+ {
|
|
|
+ String params = "";
|
|
|
+ if (paramsArray != null && paramsArray.length > 0)
|
|
|
+ {
|
|
|
+ for (int i = 0; i < paramsArray.length; i++)
|
|
|
+ {
|
|
|
+ if (!isFilterObject(paramsArray[i]))
|
|
|
+ {
|
|
|
+ Object jsonObj = JSON.toJSON(paramsArray[i]);
|
|
|
+ params += jsonObj.toString() + " ";
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return params.trim();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 判断是否需要过滤的对象。
|
|
|
+ *
|
|
|
+ * @param o 对象信息。
|
|
|
+ * @return 如果是需要过滤的对象,则返回true;否则返回false。
|
|
|
+ */
|
|
|
+ public boolean isFilterObject(final Object o)
|
|
|
+ {
|
|
|
+ return o instanceof MultipartFile || o instanceof HttpServletRequest || o instanceof HttpServletResponse;
|
|
|
+ }
|
|
|
+}
|