@Retention(RetentionPolicy.RUNTIME)@Target({ ElementType.METHOD })public @interface RedisLogService {       enum CACHE_OPERATION {        FIND, // 查询缓存操作        UPDATE, // 需要执行修改缓存的操作        INSERT; // 需要执行新增缓存的操作    }    /** 存储的分组 */    String[] group();    /** 当前缓存操作类型 */    CACHE_OPERATION cacheOperation() default CACHE_OPERATION.FIND;    /** 存储的Key 默认加入类名跟方法名 */    String key() default "";    /** 是否使用缓存 */    boolean use() default true;    /** 超时时间 */    int expire() default 0;    enum LOG_OPERATION {        ON, // 开启日志记录        OFF, // 关闭日志记录    }    /** 当前缓存操作类型 */    LOG_OPERATION logOperation() default LOG_OPERATION.ON;    /** 操作名称 */    String name() default "";    /** 操作参数 */    String param() default "";    /** 日志参数 操作人操作IP,操作IP归属地 */    String logParam() default "";

@RedisLogService(group = {
            "group.news" }, key = "#record", name = "网站维护-公司新闻管理-分页查询公司新闻", param = "#record", logParam = "#map")

@Aspect@Order(value = 1)@Component("redisLogServiceInterceptor")public class RedisLogServiceInterceptor {    private static final Logger LOGGER = LoggerFactory.getLogger(RedisLogServiceInterceptor.class);    @Autowired    private UserLogRecordService userLogRecordService;    @Autowired    private RedisTemplate<String, Object> redisTemplate;    /**     *      *      * @Title: execute     * @Description: 切入点业务逻辑     * @param proceedingJoinPoint     * @return     */    @Around("@annotation(RedisLogService)")    public Object execute(ProceedingJoinPoint proceedingJoinPoint) throws ServiceException {        Object result = null;        try {            Method method = getMethod(proceedingJoinPoint);            // 获取注解对象            RedisLogService redisLogService = method.getAnnotation(RedisLogService.class);            // 判断是否使用缓存            boolean useRedis = redisLogService.use();            if (useRedis) {                // 使用redis                ValueOperations<String, Object> operations = redisTemplate.opsForValue();                // 判断当前操作                switch (redisLogService.cacheOperation()) {                case FIND:                    result = executeDefault(redisLogService, operations, proceedingJoinPoint, method);                    break;                case UPDATE:                    result = executeUpdate(redisLogService, operations, proceedingJoinPoint);                    break;                case INSERT:                    result = executeInsert(redisLogService, operations, proceedingJoinPoint);                    break;                default:                    result = proceedingJoinPoint.proceed();                    break;                }            } else {                result = proceedingJoinPoint.proceed();            }        } catch (ServiceException e) {            throw e;        } catch (Throwable e) {            throw new ServiceException(new Result<Object>("500", e.getMessage()), e);        }        return result;    }

    /**
     * 
     * @Title: getMethod
     * @Description: 获取被拦截方法对象
     * @param joinPoint
     * @return
     */
    protected Method getMethod(JoinPoint joinPoint) throws Exception {

        MethodSignature methodSignature = (MethodSignature) joinPoint.getSignature();

        Method method = methodSignature.getMethod();

        return method;
    }