package com.app.aspect;

import com.alibaba.fastjson.JSON;
import com.auth0.jwt.JWT;
import com.system.log.entity.SysLog;
import com.system.log.service.SysLogService;
import com.system.user.entity.SysUser;

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.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.context.request.RequestAttributes;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;

import javax.servlet.http.HttpServletRequest;

import java.io.UnsupportedEncodingException;
import java.lang.reflect.Method;
import java.util.Date;

/**
 * 系统日志：切面处理类
 */
@Aspect
@Component
public class SysLogAspect {

    @Autowired
    private SysLogService sysLogService;

    //定义切点 @Pointcut
    //在注解的位置切入代码
   // @Pointcut("@annotation( com.app.aspect.MyLog)")
    @Pointcut("execution(public * com.*.*.controller..*.*(..))")
    public void logPoinCut() {
    }

    //切面 配置通知
    @AfterReturning("logPoinCut()")
    public void saveSysLog(JoinPoint joinPoint) {
        System.out.println("访问日志。。。。。。" + new Date());
        //保存日志
        SysLog sysLog = new SysLog();

        //从切面织入点处通过反射机制获取织入点处的方法
        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
        //获取切入点所在的方法
        Method method = signature.getMethod();

        //获取操作
      /*  MyLog myLog = method.getAnnotation(MyLog.class);
        if (myLog != null) {
            String value = myLog.value();
            sysLog.setOperation(value);//保存获取的操作
        }*/

        //获取请求的类名
        String className = joinPoint.getTarget().getClass().getName();
        //获取请求的方法名
        String methodName = method.getName();
        sysLog.setMethod(className + "." + methodName);

        //请求的参数
        Object[] args = joinPoint.getArgs();
        //将参数所在的数组转换成json
        String params = JSON.toJSONString(args);
        
        //System.out.println("String length: " + params.length());
        //System.out.println("Byte array length: " + params.getBytes().length);
        
        //20181225-fyx-参数过大(一般是文件)
        if(params.length()>=255){
        	params = params.substring(0, 254);
        }
        System.out.println("String: " + params);
     
        try {
			params = new String(params.getBytes("ISO8859-1"), "GBK");
		} catch (UnsupportedEncodingException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		}
        //System.out.println(params);
        
       
        sysLog.setParams(params);

        sysLog.setCreatedTime(new Date());
        
        RequestAttributes ra = RequestContextHolder.getRequestAttributes();
        ServletRequestAttributes sra = (ServletRequestAttributes) ra;
        HttpServletRequest request = sra.getRequest();
        
        String token = request.getHeader("X-Token");// 从 http 请求头中取出 token
        if(token != null){
        	String userCode = JWT.decode(token).getAudience().get(0);
            //获取用户名
            sysLog.setUsername(userCode);
        }
        
        //获取用户ip地址
        sysLog.setIp(IpUtil.getIpAddr(request));

        //调用service保存SysLog实体类到数据库
        try {
			//sysLogService.add(sysLog);
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			System.out.println(e.toString());
		}
    }

}