package com.yeshi.fanli.aspect.integral;
|
|
import java.lang.reflect.Method;
|
|
import javax.annotation.Resource;
|
|
import org.aspectj.lang.ProceedingJoinPoint;
|
import org.aspectj.lang.Signature;
|
import org.aspectj.lang.annotation.Around;
|
import org.aspectj.lang.annotation.Aspect;
|
import org.aspectj.lang.reflect.MethodSignature;
|
import org.springframework.core.DefaultParameterNameDiscoverer;
|
import org.springframework.expression.EvaluationContext;
|
import org.springframework.expression.Expression;
|
import org.springframework.expression.ExpressionParser;
|
import org.springframework.expression.spel.standard.SpelExpressionParser;
|
import org.springframework.expression.spel.support.StandardEvaluationContext;
|
import org.springframework.stereotype.Component;
|
import org.yeshi.utils.NumberUtil;
|
|
import com.yeshi.fanli.entity.bus.user.UserActiveLog;
|
import com.yeshi.fanli.service.inter.user.UserActiveLogService;
|
import com.yeshi.fanli.util.RedisManager;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.VersionUtil;
|
import com.yeshi.fanli.util.annotation.integral.IntegralGetFrequencyLimit;
|
import com.yeshi.fanli.util.annotation.integral.IntegralGetVersionLimit;
|
|
@Component
|
@Aspect
|
public class IntegralGetFrequencyLimitAspect {
|
|
@Resource
|
private RedisManager redisManager;
|
|
private ExpressionParser parser = new SpelExpressionParser();
|
|
private DefaultParameterNameDiscoverer nameDiscoverer = new DefaultParameterNameDiscoverer();
|
|
public String generateKeyBySpEL(String spELString, ProceedingJoinPoint joinPoint) {
|
MethodSignature methodSignature = (MethodSignature) joinPoint.getSignature();
|
String[] paramNames = nameDiscoverer.getParameterNames(methodSignature.getMethod());
|
Expression expression = parser.parseExpression(spELString);
|
EvaluationContext context = new StandardEvaluationContext();
|
Object[] args = joinPoint.getArgs();
|
for (int i = 0; i < args.length; i++) {
|
context.setVariable(paramNames[i], args[i]);
|
}
|
return expression.getValue(context).toString();
|
}
|
|
@Around("execution(public * com.yeshi.fanli.service.impl.integral.*.*(..))")
|
public Object requestSerializable(ProceedingJoinPoint joinPoint) throws Throwable {
|
Signature signature = joinPoint.getSignature();
|
MethodSignature methodSignature = (MethodSignature) signature;
|
Method targetMethod = methodSignature.getMethod();
|
try {
|
Method realMethod = joinPoint.getTarget().getClass().getDeclaredMethod(joinPoint.getSignature().getName(),
|
targetMethod.getParameterTypes());
|
if (realMethod.isAnnotationPresent(IntegralGetFrequencyLimit.class)) {
|
IntegralGetFrequencyLimit rs = realMethod.getAnnotation(IntegralGetFrequencyLimit.class);
|
String key = rs.key();
|
String catchKey = StringUtil.Md5("integral-get-frequency-" + generateKeyBySpEL(key, joinPoint));
|
|
if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(catchKey))) {
|
return null;
|
}
|
|
try {
|
return joinPoint.proceed();
|
} finally {
|
// 30分钟内不允许操作
|
redisManager.cacheCommonString(catchKey, "1", 60 * 30);
|
}
|
}
|
} catch (NoSuchMethodException e) {
|
e.printStackTrace();
|
} catch (SecurityException e) {
|
e.printStackTrace();
|
}
|
|
return joinPoint.proceed();
|
|
}
|
|
}
|
