package com.tcl.mie.appstore.biz.util;

import java.lang.annotation.Documented;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD})
@Documented
public @interface Cache {
	long expireMinutes() default 10080L;

	int[] pages() default {1};
}

package com.tcl.mie.appstore.biz.util;

import java.lang.reflect.Method;
import java.util.Arrays;
import java.util.concurrent.TimeUnit;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
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.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;

import com.tcl.mie.appstore.persistence.vo.Pagination;

/**
 * 
 * 创建人: xiaolong.hou
 * 
 * 创建时间：Mar 30, 2015 7:07:29 PM
 * 
 * @ClassName: CacheServiceInterceptor
 * @Description: service层的缓存
 */
@Aspect
@Component
public class CacheServiceInterceptor {

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    @Pointcut("execution(* com.tcl.mie.appstore.biz.service..*.*(..))")
    public void pointCut() {}
    @Around("pointCut())")
	    @SuppressWarnings("all")
        public Object cacheAround(ProceedingJoinPoint call) throws Throwable {
   		 Object ret = null;
   		 MethodSignature signature = (MethodSignature) call.getSignature();
   		 Method method = signature.getMethod();
   		 Cache cacheAnno = method.getAnnotation(Cache.class);

   		 // 判断是否注解
   		 if (cacheAnno != null) {
   		     StringBuilder sb =
   		             new StringBuilder(150)
   		                     .append(call.getSignature().getDeclaringTypeName())
   		                     .append(".").append(method.getName());
   		     int pageNow = 0;
   		     // 获得参数
   		     for (Object obj : call.getArgs()) {
   		         sb.append(".").append(obj.getClass().getSimpleName());
   		         // 判断是否有分页
   		         if (obj instanceof Pagination) {
   		             // 获取当前查询页
   		             pageNow = ((Pagination) obj).getPageNo();
   		             sb.append("=").append(pageNow).append(",")
   		                     .append(((Pagination) obj).getPageSize());
   		         } else {
   		             sb.append("=").append(obj);
   		         }
   		     }
   		     String key = sb.toString();
   		     // 判断redis中是否存在key
   		     if ((ret = redisTemplate.opsForValue().get(key)) == null) {
   		         ret = call.proceed();
   		         // 缓存条件： 分页存在且满足指定缓存页；不存在分页
   		         if ((pageNow > 0 && Arrays.binarySearch(cacheAnno.pages(),
   		                 pageNow) >= 0) || pageNow == 0) {
			redisTemplate.opsForValue().set(key, ret);
                		redisTemplate.expire(key, cacheAnno.expireMinutes(),
                        			TimeUnit.MINUTES);
            	 }		
	     }
    	} else {
        		ret = call.proceed();
    	}
    	return ret;
	    }
}