【无标题】

  
            com.fasterxml.jackson.core
            jackson-databind
            2.11.4
        
        
            org.aspectj
            aspectjrt
            runtime
        

        
            org.aspectj
            aspectjweaver
        

        
        
            eu.bitwalker
            UserAgentUtils
            ${user.agent.version}
        

        
        
            cn.hutool
            hutool-all
            ${hutool.version}
        
        
        
            com.google.guava
            guava
            ${guava.version}
        
        
            org.springframework.boot
            spring-boot-starter-web
        

        
            org.springframework.boot
            spring-boot-starter-test
            test
        

        
        
            org.projectlombok
            lombok
        

        
        
            mysql
            mysql-connector-java
        

        
        
        
            com.baomidou
            mybatis-plus-boot-starter
            3.0.5
        

@Aspect
@Component
@Slf4j
public class AopLog  {


    @Autowired
    private LogUserMapper logUserMapper;


    
    private static final ThreadLocal DATE_THREAD_LOCAL = new ThreadLocal<>();

    
    @Pointcut("execution(public * com.demo.controller.*Controller.*(..))")
    public void log() {

    }

    
    @Around("log()")
    public Object aroundLog(ProceedingJoinPoint point) throws Throwable {

        DATE_THREAD_LOCAL.set (new Date ());

        // 开始打印请求日志
        ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
        HttpServletRequest request = Objects.requireNonNull(attributes).getRequest();

        // 打印请求相关参数
        long startTime = System.currentTimeMillis();
        Object result = point.proceed();
        String header = request.getHeader("User-Agent");
        UserAgent userAgent = UserAgent.parseUserAgentString(header);
        final LogUser l =   LogUser.builder()
            .threadId(Long.toString(Thread.currentThread().getId()))
            .threadName(Thread.currentThread().getName())
            .ip(getIp(request))
            .url(request.getRequestURL().toString())
            .beginTime(DATE_THREAD_LOCAL.get ())
            .endTime(new Date ())
            .classMethod(String.format("%s.%s", point.getSignature().getDeclaringTypeName(),
                point.getSignature().getName()))
            .httpMethod(request.getMethod())
            .requestParams(new ObjectMapper ().writevalueAsString (getNameAndValue(point)))
            .result(new ObjectMapper ().writevalueAsString (result))
            .timeCost(System.currentTimeMillis() - startTime)
            .userAgent(header)
            .browser(userAgent.getBrowser().toString())
            .os(userAgent.getOperatingSystem().toString()).build();

        addUser(l);
        log.info ("0-----------------------0",DATE_THREAD_LOCAL.get ());
        //打印日志
        log.info("Request LogUser Info : {}", JSONUtil.toJsonStr(l));

        return result;
    }

    
    @Transactional(value = "Exception.class")
    void addUser(LogUser logUser){
        logUserMapper.insert (logUser);
    }

    
    private Map getNameAndValue(ProceedingJoinPoint joinPoint) {

        final Signature signature = joinPoint.getSignature();
        MethodSignature methodSignature = (MethodSignature) signature;
        final String[] names = methodSignature.getParameterNames();
        final Object[] args = joinPoint.getArgs();

        if (ArrayUtil.isEmpty(names) || ArrayUtil.isEmpty(args)) {
            return Collections.emptyMap();
        }
        if (names.length != args.length) {
            log.warn("{}方法参数名和参数值数量不一致", methodSignature.getName());
            return Collections.emptyMap();
        }
        Map map = Maps.newHashMap();
        for (int i = 0; i < names.length; i++) {
            map.put(names[i], args[i]);
        }
        return map;
    }

    private static final String UNKNOWN = "unknown";

    
    public static String getIp(HttpServletRequest request) {
        String ip = request.getHeader("x-forwarded-for");
        if (ip == null || ip.length() == 0 || UNKNOWN.equalsIgnoreCase(ip)) {
            ip = request.getHeader("Proxy-Client-IP");
        }
        if (ip == null || ip.length() == 0 || UNKNOWN.equalsIgnoreCase(ip)) {
            ip = request.getHeader("WL-Proxy-Client-IP");
        }
        if (ip == null || ip.length() == 0 || UNKNOWN.equalsIgnoreCase(ip)) {
            ip = request.getRemoteAddr();
        }
        String comma = ",";
        String localhost = "127.0.0.1";
        if (ip.contains(comma)) {
            ip = ip.split(",")[0];
        }
        if (localhost.equals(ip)) {
            // 获取本机真正的ip地址
            try {
                ip = InetAddress.getLocalHost().getHostAddress();
            } catch (UnknownHostException e) {
                log.error(e.getMessage(), e);
            }
        }
        return ip;
    }

}

@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@TableName(value = "logUser")
public class LogUser implements Serializable {

//        @TableId(type = IdType.AUTO)
        // 线程id
        private String threadId;
        // 线程名称
        private String threadName;
        // ip
        private String ip;
        // url
        private String url;
        // http方法 GET POST PUT DELETE PATCH
        private String httpMethod;
        // 类方法
        private String classMethod;
        // 请求参数
        private String requestParams;
        // 返回参数
        private String result;
        // 接口耗时
        private Long timeCost;
        // 操作系统
        private String os;
        // 浏览器
        private String browser;
        // user-agent
        private String userAgent;
        //开始时间
        private Date beginTime;
        //结束时间
        private Date  endTime;

}

@Slf4j
@RestController
public class TestController {

    @GetMapping("/demo")
    public String testDemo() {
        return "demo";
    }

    
    @GetMapping("/test")
    public Dict test(String who) {
        return Dict.create().set("who", StrUtil.isBlank(who) ? "URL" : who);
    }

    
    @PostMapping("/testJson")
    public Dict testJson(@RequestBody Map map) {

        final String jsonStr = JSONUtil.toJsonStr(map);
        log.info(jsonStr);
        return Dict.create().set("json", map);
    }
}