yujian
2020-01-03 c9cbdfa41d645d42eeaa7e06d550d4ef8ac328e7
fanli/src/main/java/com/yeshi/fanli/util/RedisManager.java
@@ -31,6 +31,7 @@
import net.sf.json.JSONArray;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.params.SetParams;
//抢红包采用的redis
@Component
@@ -56,10 +57,12 @@
    */
   private void setString(String key, String value) {
      Jedis jedis = jedisPool.getResource();
      SetParams params=new SetParams().nx().ex(60);
      jedis.set(key, value, params);
      try {
         jedis.set(key, value);
      } finally {
         jedisPool.returnResource(jedis);
         jedis.close();
      }
   }
@@ -75,7 +78,7 @@
      try {
         jedis.del(key);
      } finally {
         jedisPool.returnResource(jedis);
         jedis.close();
      }
   }
@@ -93,7 +96,7 @@
      try {
         jedis.setex(key, seconds, value);
      } finally {
         jedisPool.returnResource(jedis);
         jedis.close();
      }
   }
@@ -102,7 +105,7 @@
      try {
         return jedis.get(key);
      } finally {
         jedisPool.returnResource(jedis);
         jedis.close();
      }
   }
@@ -111,7 +114,7 @@
      try {
         jedis.incr(key);
      } finally {
         jedisPool.returnResource(jedis);
         jedis.close();
      }
   }
@@ -120,7 +123,7 @@
      try {
         jedis.expire(key, seconds);
      } finally {
         jedisPool.returnResource(jedis);
         jedis.close();
      }
   }
@@ -148,7 +151,7 @@
   public void saveTaoBaoGoodsBriefTemp(TaoBaoGoodsBrief goods) {
      if (goods == null)
         return;
      String key = "taobao-goods-temp-" + goods.getAuctionId();
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoGoodsTemp, goods.getAuctionId() + "");
      if (Constant.IS_OUTNET) {
         // 暂存4个小时的分享
         cacheCommonString(key, JsonUtil.getSimpleGson().toJson(goods), 60 * 60 * 4);
@@ -156,7 +159,7 @@
   }
   public TaoBaoGoodsBrief getTaoBaoGoodsTemp(Long auctionId) {
      String key = "taobao-goods-temp-" + auctionId;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoGoodsTemp, auctionId + "");
      String value = getCommonString(key);
      if (!StringUtil.isNullOrEmpty(value)) {
         return JsonUtil.getSimpleGson().fromJson(value, TaoBaoGoodsBrief.class);
@@ -170,14 +173,14 @@
    * @param auctionId
    */
   public void deleteTaoBaoGoodsBrief(Long auctionId) {
      String key = "taobao-goods-" + auctionId;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoGoods, auctionId + "");
      if (Constant.IS_OUTNET)
         removeKey(key);
   }
   public TaoBaoGoodsBrief getTaoBaoGoodsBrief(long auctionId) throws TaobaoGoodsDownException {
      long startTime = System.currentTimeMillis();
      String key = "taobao-goods-" + auctionId;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoGoods, auctionId + "");
      String value = "";
      if (Constant.IS_OUTNET)
         value = getCommonString(key);
@@ -199,7 +202,7 @@
   }
   public List<ImageInfo> getTaoBaoGoodsDetailImgs(long auctionId) {
      String key = "taobao-goods-detailimgs-size-" + auctionId;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoGoodsDetailimgs, auctionId + "");
      String value = "";
      if (Constant.IS_OUTNET)
         value = getCommonString(key);
@@ -228,7 +231,7 @@
   public String getXCXCouponToken(TaoBaoGoodsBrief tb) {
      List<TaoBaoUnionConfig> configList = taoBaoUnionConfigService.getConfigByTypeCache(PidUser.TYPE_FANLI_ANDROID);
      String key = "taobao-couple-xcx-" + tb.getAuctionId();
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoCoupleXCX, tb.getAuctionId() + "");
      String value = "";
      if (Constant.IS_OUTNET)
         value = getCommonString(key);
@@ -251,7 +254,7 @@
    * @param ip
    */
   public boolean ipFrequencyLimit(String ip, String apiName) {
      String key = ip + "-" + StringUtil.Md5(apiName);
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.emptyKey, ip + "-" + StringUtil.Md5(apiName));
      Jedis jedis = jedisPool.getResource();
      try {
         long count = jedis.incr(key);
@@ -262,12 +265,12 @@
         else
            return false;
      } finally {
         jedisPool.returnResource(jedis);
         jedis.close();
      }
   }
   public boolean frequencyLimit(String key, int timeS, int num) {
      key = "frequency-" + key;
      key = RedisKeyEnum.getRedisKey(RedisKeyEnum.frequencyLimit, key);
      Jedis jedis = jedisPool.getResource();
      try {
         long count = jedis.incr(key);
@@ -278,7 +281,7 @@
         else
            return false;
      } finally {
         jedisPool.returnResource(jedis);
         jedis.close();
      }
   }
@@ -289,7 +292,7 @@
    * @return
    */
   public List<String> getTBImg(Long auctionId) {
      String key = "taobao-img-" + auctionId;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoImgs, auctionId + "");
      String value = "";
      if (Constant.IS_OUTNET)
         value = getCommonString(key);
@@ -318,7 +321,7 @@
    * @return
    */
   public TaoBaoShopInfo getTBShopInfo(String shopTitle, Long sellerId, Long auctionId) {
      String key = "taobao-shop-" + sellerId;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoShop, sellerId +"");
      String value = "";
      if (Constant.IS_OUTNET)
         value = getCommonString(key);
@@ -367,7 +370,7 @@
   public boolean isSmsFrequencyLimit(String phone, int type) {
      if (!Constant.IS_OUTNET)
         return false;
      String key = "sms-" + phone + "-" + type;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMS,  phone + "-" + type);
      String value = getCommonString(key);
      if (StringUtil.isNullOrEmpty(value))
         return false;
@@ -384,14 +387,14 @@
   public void sendSms(String phone, int type) {
      if (!Constant.IS_OUTNET)
         return;
      String key = "sms-" + phone + "-" + type;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMS,  phone + "-" + type);
      setString(key, "1", 10);
   }
   public void clearSMSFrequencyLimit(String phone, int type) {
      if (!Constant.IS_OUTNET)
         return;
      String key = "sms-" + phone + "-" + type;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMS,  phone + "-" + type);
      removeKey(key);
   }
@@ -404,7 +407,7 @@
    */
   public void saveSMSVCode(String phone, int type, String code) {
      String key = "smscode-" + phone + "-" + type;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMSVCode, phone + "-" + type);
      // 保存2分钟
      setString(key, code, 120);
   }
@@ -418,7 +421,7 @@
   public String getSMSVCode(String phone, int type) {
      // if (!Constant.IS_OUTNET)
      // return "";
      String key = "smscode-" + phone + "-" + type;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMSVCode, phone + "-" + type);
      // 保存2分钟
      return getString(key);
   }
@@ -433,7 +436,7 @@
   public void clearSMSVCode(String phone, int type) {
      // if (!Constant.IS_OUTNET)
      // return;
      String key = "smscode-" + phone + "-" + type;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMSVCode, phone + "-" + type);
      removeKey(key);
   }
@@ -441,8 +444,7 @@
    * 保存绑定支付宝短信验证码的正确性
    */
   public void saveBindAlipayAccountSMSState(String phone) {
      String key = "smsstate-alipay-" + phone;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMSStateAlipay, phone + "" );
      // 验证后十分钟有效
      setString(key, "1", 10 * 60);
   }
@@ -454,7 +456,7 @@
    * @return
    */
   public boolean isBindAlipayAccountSMSStateValid(String phone) {
      String key = "smsstate-alipay-" + phone;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMSStateAlipay, phone + "" );
      return !StringUtil.isNullOrEmpty(getString(key));
   }
@@ -466,8 +468,7 @@
    */
   public void setInviteShortLink(long uid, String shortlink) {
      String value = "";
      String key = "invite-shortlink-" + uid;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.inviteShortLink, uid + "" );
      if (Constant.IS_OUTNET) {
         value = getCommonString(key);
@@ -486,10 +487,8 @@
    * @return
    */
   public String getInviteShortLink(long uid) {
      String value = "";
      String key = "invite-shortlink-" + uid;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.inviteShortLink, uid + "" );
      if (Constant.IS_OUTNET)
         value = getCommonString(key);
@@ -503,7 +502,7 @@
    * @param token
    */
   public void saveCommonTaoToken(Long auctionId, String token) {
      String key = "taobao-common-token-" + auctionId;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoTokenCommon, auctionId + "" );
      if (Constant.IS_OUTNET) {
         if (!StringUtil.isNullOrEmpty(token)) {
            // 口令缓存10天
@@ -519,8 +518,7 @@
    * @return
    */
   public String getCommonTaoToken(Long auctionId) {
      String key = "taobao-common-token-" + auctionId;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoTokenCommon, auctionId + "" );
      if (Constant.IS_OUTNET) {
         return getCommonString(key);
      }
@@ -534,7 +532,7 @@
    * @param token
    */
   public void saveTLJToken(String url, String token) {
      String key = "taobao-tlj-token-" + StringUtil.Md5(url);
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoTokenTLJ, StringUtil.Md5(url));
      if (Constant.IS_OUTNET) {
         if (!StringUtil.isNullOrEmpty(token)) {
            // 口令缓存10天
@@ -550,8 +548,7 @@
    * @return
    */
   public String getTLJToken(String url) {
      String key = "taobao-common-token-" + StringUtil.Md5(url);
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoTokenTLJ, StringUtil.Md5(url));
      if (Constant.IS_OUTNET) {
         return getCommonString(key);
      }
@@ -565,7 +562,7 @@
    * @param key
    * @param seconds
    */
   public void saveObj(Class<?> clazz, String key, Integer seconds) {
   public void saveObj(Object clazz, String key, Integer seconds) {
      if (clazz == null)
         return;
      String value = new Gson().toJson(clazz);
@@ -618,8 +615,7 @@
   }
   public JDGoods getJDGoods(long goodsId) {
      String key = "jingdong-goods-" + goodsId;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.jingDongGoods, goodsId +"");
      String value = getCommonString(key);
      if (StringUtil.isNullOrEmpty(value)) {
         JDGoods jdGoods = JDApiUtil.queryGoodsDetail(goodsId);
@@ -638,7 +634,7 @@
   }
   public PDDGoodsDetail getPDDGoodsDetail(long goodsId) {
      String key = "pinduoduo-goods-" + goodsId;
      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.pinDuoDuoGoods, goodsId +"");
      String value = getCommonString(key);
      if (StringUtil.isNullOrEmpty(value)) {