刷单风险规则优化

admin

2020-11-09 2147d023563a7c9d05d97547c00d6b0162c0644c

 fanli/src/main/java/com/yeshi/fanli/aspect/RequestSerializableAspect.java

@@ -7,6 +7,7 @@


import javax.annotation.Resource;



import com.yeshi.fanli.util.RedisManager;

import org.aspectj.lang.ProceedingJoinPoint;

import org.aspectj.lang.Signature;

import org.aspectj.lang.annotation.Around;

@@ -36,7 +37,7 @@
@Order(4)

public class RequestSerializableAspect {

   @Resource

   private JedisPool jedisPool;

   private RedisManager redisManager;



   private ExpressionParser parser = new SpelExpressionParser();



@@ -95,7 +96,7 @@
                  String cacheAlias = cacheKey;

                  cacheKey = "rs-" + StringUtil.Md5(cacheKey);

                  // jiedis原子性做拦截

                  Jedis jedis = jedisPool.getResource();

                  Jedis jedis = redisManager.getJedis();

                  long threadId = Thread.currentThread().getId();

                  try {

                     Constant.waitingThreadSet.add(threadId);

@@ -148,7 +149,10 @@
         return joinPoint.proceed();

      } catch (Throwable e) {

         e.printStackTrace();

         LogHelper.errorDetailInfo(e);

         if (!Constant.IS_TEST)

            LogHelper.errorDetailInfo(e);

         else

            throw e;

      } finally {

      }

      return null;