admin
2019-06-24 480fa41fa7ee8b3b3a38f46f28c2b8403299b44d
fanli/src/main/java/com/yeshi/fanli/util/RedisManager.java
@@ -6,6 +6,7 @@
import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import org.yeshi.utils.JsonUtil;
import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;
@@ -22,7 +23,6 @@
import com.yeshi.fanli.util.taobao.TaoBaoCouponUtil;
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
import org.yeshi.utils.JsonUtil;
import net.sf.json.JSONArray;
import redis.clients.jedis.Jedis;
@@ -39,7 +39,7 @@
   private TaoBaoShopService taoBaoShopService;
   @Resource
   private TaoBaoUnionConfigService taoBaoUnionConfigService;
   private TaoBaoUnionConfigService taoBaoUnionConfigService;
   @Resource
   private ConfigService configService;
@@ -102,6 +102,24 @@
      }
   }
   public void increase(String key) {
      Jedis jedis = jedisPool.getResource();
      try {
         jedis.incr(key);
      } finally {
         jedisPool.returnResource(jedis);
      }
   }
   public void expire(String key, int seconds) {
      Jedis jedis = jedisPool.getResource();
      try {
         jedis.expire(key, seconds);
      } finally {
         jedisPool.returnResource(jedis);
      }
   }
   public void cacheCommonString(String key, String value, int seconds) {
      setString(key, value, seconds);
   }
@@ -119,15 +137,27 @@
   }
   /**
    * 将信息永久保存到Redis
    * 临时存储淘宝的商品详情
    * 
    * @param goods
    */
   public void saveTaoBaoGoodsBriefForever(TaoBaoGoodsBrief goods) {
      String key = "taobao-goods-" + goods.getAuctionId();
   public void saveTaoBaoGoodsBriefTemp(TaoBaoGoodsBrief goods) {
      if (goods == null)
         return;
      String key = "taobao-goods-temp-" + goods.getAuctionId();
      if (Constant.IS_OUTNET) {
         cacheCommonString(key, JsonUtil.getSimpleGson().toJson(goods));
         // 暂存4个小时的分享
         cacheCommonString(key, JsonUtil.getSimpleGson().toJson(goods), 60 * 60 * 4);
      }
   }
   public TaoBaoGoodsBrief getTaoBaoGoodsTemp(Long auctionId) {
      String key = "taobao-goods-temp-" + auctionId;
      String value = getCommonString(key);
      if (!StringUtil.isNullOrEmpty(value)) {
         return JsonUtil.getSimpleGson().fromJson(value, TaoBaoGoodsBrief.class);
      }
      return null;
   }
   /**
@@ -223,7 +253,7 @@
         long count = jedis.incr(key);
         if (count == 1)
            jedis.expire(key, 5);
         if (count >= 100)
         if (count >= 10)
            return true;
         else
            return false;
@@ -272,19 +302,38 @@
      String value = "";
      if (Constant.IS_OUTNET)
         value = getCommonString(key);
      if (StringUtil.isNullOrEmpty(value)) {
         TaoBaoGoodsBrief goods = new TaoBaoGoodsBrief();
         goods.setShopTitle(shopTitle);
         goods.setSellerId(sellerId);
         goods.setAuctionId(auctionId);
         TaoBaoShopInfo info = taoBaoShopService.getTaoBaoShopInfo(goods);
         if (info != null) {
            String shopUrl = info.getShopUrl();
            if (shopUrl != null && shopUrl.contains("tmall://page.tm/shop")) {
               shopUrl = "http://store.taobao.com/shop/view_shop.htm?user_number_id=" + sellerId;
               info.setShopUrl(shopUrl);
            }
         }
         if (Constant.IS_OUTNET && info != null) {
            value = new Gson().toJson(info);
            cacheCommonString(key, value, 60 * 60 * 2);
         }
         return info;
      } else {
         return new Gson().fromJson(value, TaoBaoShopInfo.class);
         TaoBaoShopInfo info = new Gson().fromJson(value, TaoBaoShopInfo.class);
         String shopUrl = info.getShopUrl();
         if (shopUrl != null && shopUrl.contains("tmall://page.tm/shop")) {
            shopUrl = "http://store.taobao.com/shop/view_shop.htm?user_number_id=" + sellerId;
            info.setShopUrl(shopUrl);
         }
         return info;
      }
   }
@@ -391,4 +440,163 @@
      return !StringUtil.isNullOrEmpty(getString(key));
   }
   /**
    * 缓存短连接1分钟
    *
    * @param uid
    * @param shortlink
    */
   public void setInviteShortLink(long uid, String shortlink) {
      String value = "";
      String key = "invite-shortlink-" + uid;
      if (Constant.IS_OUTNET) {
         value = getCommonString(key);
         if (StringUtil.isNullOrEmpty(value)) {
            cacheCommonString(key, shortlink, 60);
         }
      }
   }
   /**
    * 获取用户短连接
    *
    * @param uid
    * @return
    */
   public String getInviteShortLink(long uid) {
      String value = "";
      String key = "invite-shortlink-" + uid;
      if (Constant.IS_OUTNET)
         value = getCommonString(key);
      return value;
   }
   /**
    * 保存淘口令
    *
    * @param auctionId
    * @param token
    */
   public void saveCommonTaoToken(Long auctionId, String token) {
      String key = "taobao-common-token-" + auctionId;
      if (Constant.IS_OUTNET) {
         if (!StringUtil.isNullOrEmpty(token)) {
            // 口令缓存10天
            cacheCommonString(key, token, 60 * 60 * 24 * 10);
         }
      }
   }
   /**
    * 获取用户短连接
    *
    * @param uid
    * @return
    */
   public String getCommonTaoToken(Long auctionId) {
      String key = "taobao-common-token-" + auctionId;
      if (Constant.IS_OUTNET) {
         return getCommonString(key);
      }
      return null;
   }
   /**
    * 保存淘礼金的口令
    *
    * @param url
    * @param token
    */
   public void saveTLJToken(String url, String token) {
      String key = "taobao-tlj-token-" + StringUtil.Md5(url);
      if (Constant.IS_OUTNET) {
         if (!StringUtil.isNullOrEmpty(token)) {
            // 口令缓存10天
            cacheCommonString(key, token, 60 * 60 * 24 * 10);
         }
      }
   }
   /**
    * 获取淘礼金口令
    *
    * @param url
    * @return
    */
   public String getTLJToken(String url) {
      String key = "taobao-common-token-" + StringUtil.Md5(url);
      if (Constant.IS_OUTNET) {
         return getCommonString(key);
      }
      return null;
   }
   /**
    * 保存对象
    *
    * @param T
    * @param key
    * @param seconds
    */
   public void saveObj(Class<?> clazz, String key, Integer seconds) {
      if (clazz == null)
         return;
      String value = new Gson().toJson(clazz);
      if (seconds != null)
         cacheCommonString(key, value, seconds);
      else
         cacheCommonString(key, value);
   }
   /**
    * 保存列表
    *
    * @param clazzList
    * @param key
    * @param seconds
    */
   public <T> T saveObjList(List<T> clazzList, String key, Integer seconds) {
      if (clazzList == null)
         return null;
      String value = new Gson().toJson(clazzList);
      if (seconds != null)
         cacheCommonString(key, value, seconds);
      else
         cacheCommonString(key, value);
      return null;
   }
   /**
    * 获取对象
    *
    * @param clazz
    * @param key
    * @return
    */
   public Class<?> getObj(Class<?> clazz, String key) {
      String value = getCommonString(key);
      return (Class<?>) new Gson().fromJson(value, clazz);
   }
   /**
    * 获取列表
    *
    * @param clazz
    * @param key
    * @return
    */
   public <T> List<T> getObjList(Class<T> clazz, String key) {
      String value = getCommonString(key);
      return JsonUtil.jsonToList(value, clazz);
   }
}