aop 记录用户操作（一）

转载： http://www.cnblogs.com/guokai870510826/p/5981015.html

使用标签来设置需要的记录

实例：@ISystemLog()

@Controller

@RequestMapping("test")

public class TestController {

    @RequestMapping(value = "test.do", method = RequestMethod.GET)

    @ISystemLog(module = "TestController",methods = "test")

    public ModelAndView test(HttpServletRequest request, HttpServletResponse response) throws Exception {

        HttpServletRequest request1 = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();

        return new ModelAndView("/login");

    }

}

创建ISystemLog

package com.helka.cmis.common.utils.log;

import java.lang.annotation.*;

@Target({ElementType.PARAMETER, ElementType.METHOD})

@Retention(RetentionPolicy.RUNTIME)

@Documented

public @interface ISystemLog {

    String module()  default "";

    String methods()  default "";

}

创建LogAopAction

package com.helka.cmis.common.utils.log;

import com.helka.cmis.common.utils.LogEntity;

import org.aspectj.lang.ProceedingJoinPoint;

import org.aspectj.lang.Signature;

import org.aspectj.lang.annotation.After;

import org.aspectj.lang.annotation.AfterReturning;

import org.aspectj.lang.annotation.AfterThrowing;

import org.aspectj.lang.annotation.Around;

import org.aspectj.lang.annotation.Aspect;

import org.aspectj.lang.annotation.Before;

import org.aspectj.lang.annotation.Pointcut;

import org.aspectj.lang.reflect.MethodSignature;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.context.request.RequestContextHolder;

import org.springframework.web.context.request.ServletRequestAttributes;

import org.springframework.web.context.request.ServletWebRequest;

import javax.annotation.Resource;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import java.lang.reflect.Method;

import java.text.SimpleDateFormat;

import java.util.Date;

@Aspect

public class LogAopAction {

//    @Resource(name="logService")

//    private LogServiceImpl logservice;

    //配置接入点,如果不知道怎么配置,可以百度一下规则

    @Pointcut("execution(* com.kintech.*.controller..*.*(..))")

    private void controllerAspect(){}

//    @Autowired

//    private  HttpServletRequest request;

    //@Around("execution(* org.springframework.web.servlet.mvc.annotation.AnnotationMethodHandlerAdapter.handle(..))")

    @Around("controllerAspect()")

    public Object around(ProceedingJoinPoint pjp) throws Throwable {

        //常见日志实体对象

        LogEntity log = new LogEntity();

        //获取登录用户账户

        HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();

        ServletWebRequest servletWebRequest=new ServletWebRequest(request);

        HttpServletResponse response=servletWebRequest.getResponse();

        String name = (String) request.getSession().getAttribute("USER_ID");

        log.setAccount(name);

        //获取系统时间

        String time = new SimpleDateFormat("YYYY-MM-dd HH:mm:ss").format(new Date());

        log.setCreatetime(time);

        String ip = request.getHeader("X-Real-IP");

        log.setIp(ip);

        long start = System.currentTimeMillis();

        // 拦截的实体类，就是当前正在执行的controller

        Object target = pjp.getTarget();

        // 拦截的方法名称。当前正在执行的方法

        String methodName = pjp.getSignature().getName();

        // 拦截的方法参数

        Object[] args = pjp.getArgs();

        // 拦截的放参数类型

        Signature sig = pjp.getSignature();

        MethodSignature msig = null;

        if (!(sig instanceof MethodSignature)) {

            throw new IllegalArgumentException("该注解只能用于方法");

        }

        msig = (MethodSignature) sig;

        Class[] parameterTypes = msig.getMethod().getParameterTypes();

        Object object = null;

        // 获得被拦截的方法

        Method method = null;

        try {

            method = target.getClass().getMethod(methodName, parameterTypes);

        } catch (NoSuchMethodException e1) {

            // TODO Auto-generated catch block

            e1.printStackTrace();

        } catch (SecurityException e1) {

            // TODO Auto-generated catch block

            e1.printStackTrace();

        }

        if (null != method) {

            // 判断是否包含自定义的注解，说明一下这里的SystemLog就是我自己自定义的注解

            if (method.isAnnotationPresent(ISystemLog.class)) {

                ISystemLog systemlog = method.getAnnotation(ISystemLog.class);

                log.setModule(systemlog.module());

                log.setMethod(systemlog.methods());

                try {

                    object = pjp.proceed();

                    long end = System.currentTimeMillis();

                    //将计算好的时间保存在实体中

                    log.setUsedtime(end-start);

                    log.setCommit("Success！");

                    //保存进数据库

                    //logservice.saveLog(log);

                } catch (Throwable e) {

                    // TODO Auto-generated catch block

                    long end = System.currentTimeMillis();

                    log.setUsedtime(end-start);

                    log.setCommit("Failed");

                    //logservice.saveLog(log);

                }

            } else {//没有包含注解

                object = pjp.proceed();

            }

        } else { //不需要拦截直接执行

            object = pjp.proceed();

        }

        return object;

    }

}

创建数据库的映射实体

public class LogEntity {

    private int id;

    private String account;

    private String module;

    private String method;

    private long usedtime;

    private String ip;

    private String createtime;

    private String commit;

    public int getId() {

        return id;

    }

    public void setId(int id) {

        this.id = id;

    }

    public String getAccount() {

        return account;

    }

    public void setAccount(String account) {

        this.account = account;

    }

    public String getModule() {

        return module;

    }

    public void setModule(String module) {

        this.module = module;

    }

    public String getMethod() {

        return method;

    }

    public void setMethod(String method) {

        this.method = method;

    }

    public long getUsedtime() {

        return usedtime;

    }

    public void setUsedtime(long usedtime) {

        this.usedtime = usedtime;

    }

    public String getIp() {

        return ip;

    }

    public void setIp(String ip) {

        this.ip = ip;

    }

    public String getCreatetime() {

        return createtime;

    }

    public void setCreatetime(String createtime) {

        this.createtime = createtime;

    }

    public String getCommit() {

        return commit;

    }

    public void setCommit(String commit) {

        this.commit = commit;

    }

}

配置文件：

springmvc-servlet.xml

<aop:aspectj-autoproxy proxy-target-class="true" />

    <bean id="logAopAction" class="com.helka.cmis.common.utils.log.LogAopAction" />

巴特西

aop 记录用户操作（一）

最新文章

热门文章