@Data
public class OperateLog {
    private Long id; //主鍵
    private Long userId; //操作人id
    private Date createTime; //創(chuàng)建時(shí)間
    private String description; //請求描述
    private String method; //請求方法 如：post、get
    private String ip; //操作人ip
    private String param; //請求參數(shù)：json格式
    private String result; //請求結(jié)果：json格式
    private Integer success; //操作是否成功
    private String errorMsg; //錯(cuò)誤信息
}

create table operate_log(
	id BIGINT PRIMARY key AUTO_INCREMENT COMMENT '主鍵',
	user_id BIGINT DEFAULT 100 COMMENT '操作人id',
	create_time datetime DEFAULT CURRENT_TIMESTAMP COMMENT '創(chuàng)建時(shí)間',
	description VARCHAR(200) COMMENT '請求描述',
	method VARCHAR(20) COMMENT '請求方法 如：post、get',
	ip VARCHAR(32) COMMENT '操作人ip',
	param VARCHAR(2000) COMMENT '請求參數(shù)：json格式',
	result VARCHAR(2000) COMMENT '請求結(jié)果：json格式',
	success TINYINT DEFAULT 0 COMMENT '操作是否成功：1是、0否',
	error_msg VARCHAR(2000) COMMENT '錯(cuò)誤消息'
) COMMENT '操作日志記錄表';

//mapper接口
public interface OperateLogMapper extends BaseMapper<OperateLog> {}

//service接口
public interface OperateLogService extends IService<OperateLog> {}

//service實(shí)現(xiàn)類
@Service
public class OperateLogServiceImpl extends ServiceImpl<OperateLogMapper, OperateLog> implements OperateLogService {}

@Target({ ElementType.PARAMETER, ElementType.METHOD })
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface Log {
    /**
     * 請求描述
     */
    String title() default "";
}

@Aspect
@Component
public class LogAspect {
    private static final Logger log = LoggerFactory.getLogger(LogAspect.class);
    @Autowired
    private OperateLogService logService;

    private final ExecutorService executor = Executors.newSingleThreadExecutor();

    /**
     * 請求前執(zhí)行
     * @param aspLog
     */
    @Before(value = "@annotation(aspLog)")
    public void doBefore(Log aspLog){
        log.info("請求日志記錄start");
    }

    /**
     * 請求后執(zhí)行
     * @param aspLog
     * @param result
     */
    @AfterReturning(pointcut = "@annotation(aspLog)",returning = "result")
    public void doAfterReturning(JoinPoint joinPoint, Log aspLog, Object result){
        handleLog(joinPoint,aspLog,null,result);
    }

    /**
     * 請求異常執(zhí)行
     * @param aspLog
     * @param e
     */
    @AfterThrowing(value = "@annotation(aspLog)", throwing = "e")
    public void doAfterThrowing(JoinPoint joinPoint,Log aspLog,Exception e){
        handleLog(joinPoint,aspLog,e,null);
    }

    /**
     * 日志處理器-記錄日志
     * @param aspLog
     * @param e
     * @param result
     */
    private void handleLog(JoinPoint joinPoint,Log aspLog,Exception e,Object result){
        ServletRequestAttributes attributes = (ServletRequestAttributes)RequestContextHolder.getRequestAttributes();
        OperateLog operateLog = new OperateLog();
        operateLog.setIp(attributes.getRequest().getRemoteAddr());
        operateLog.setMethod(attributes.getRequest().getMethod());
        String param = JSON.toJSONString(joinPoint.getArgs());
        operateLog.setParam(param);
        if(e != null){
            operateLog.setErrorMsg(e.getLocalizedMessage());
        }else{
            operateLog.setSuccess(1);
            operateLog.setResult(JSON.toJSONString(result));
        }
        operateLog.setDescription(aspLog.title());
        executor.submit(() -> logService.save(operateLog));
    }
}

@RestController
public class TestController {
    @Log(title = "測試操作")
    @GetMapping("/test")
    public String test(){
        return "沒毛病";
    }

    @Log(title = "測試參數(shù)操作")
    @PostMapping("/testParam")
    public String testParam(@RequestBody String data){
        return data;
    }

    @Log(title = "測試異常操作")
    @GetMapping("/testExecption")
    public String testExecption(){
        return (1/0)+"";
    }
}