淘礼金创建异常处理

admin

2019-08-26 d28bed1a1275131a5ca37f7da37961e2b518ac07

 fanli/src/main/java/com/yeshi/fanli/util/RedisManager.java

@@ -6,10 +6,13 @@
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;

import com.yeshi.fanli.dto.pdd.PDDGoodsDetail;

import com.yeshi.fanli.entity.common.ImageInfo;

import com.yeshi.fanli.entity.jd.JDGoods;

import com.yeshi.fanli.entity.taobao.PidUser;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

import com.yeshi.fanli.entity.taobao.TaoBaoShopInfo;

@@ -19,10 +22,11 @@
import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.taobao.TaoBaoShopService;

import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService;

import com.yeshi.fanli.util.jd.JDApiUtil;

import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil;

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;

@@ -111,7 +115,7 @@
      }

   }



   public void expire(String key,int seconds) {

   public void expire(String key, int seconds) {

      Jedis jedis = jedisPool.getResource();

      try {

         jedis.expire(key, seconds);

@@ -253,7 +257,7 @@
         long count = jedis.incr(key);

         if (count == 1)

            jedis.expire(key, 5);

         if (count >= 100)

         if (count >= 10)

            return true;

         else

            return false;

@@ -384,8 +388,6 @@
    */



   public void saveSMSVCode(String phone, int type, String code) {

      if (!Constant.IS_OUTNET)

         return;

      String key = "smscode-" + phone + "-" + type;

      // 保存2分钟

      setString(key, code, 120);

@@ -398,8 +400,8 @@
    * @return

    */

   public String getSMSVCode(String phone, int type) {

      if (!Constant.IS_OUTNET)

         return "";

//      if (!Constant.IS_OUTNET)

//         return "";

      String key = "smscode-" + phone + "-" + type;

      // 保存2分钟

      return getString(key);

@@ -413,8 +415,8 @@
    * @param code

    */

   public void clearSMSVCode(String phone, int type) {

      if (!Constant.IS_OUTNET)

         return;

//      if (!Constant.IS_OUTNET)

//         return;

      String key = "smscode-" + phone + "-" + type;

      removeKey(key);

   }

@@ -509,4 +511,133 @@
      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);

   }

	
	
   public JDGoods getJDGoods(long goodsId) {

      String key = "jingdong-goods-" + goodsId;

		
      String value = getCommonString(key);

      if (StringUtil.isNullOrEmpty(value)) {

         JDGoods jdGoods = JDApiUtil.queryGoodsDetail(goodsId);

         if (jdGoods == null) {

            jdGoods = JDApiUtil.getGoodsDetail(goodsId);

         }



         // 缓存20分钟

         if (jdGoods != null)

            cacheCommonString(key, JsonUtil.getSimpleGson().toJson(jdGoods), 60 * 20);

			
         return jdGoods;

      } else {// 直接取缓存

         return JsonUtil.getSimpleGson().fromJson(value, JDGoods.class);

      }

   }

	
	
   public PDDGoodsDetail getPDDGoodsDetail(long goodsId) {

      String key = "pinduoduo-goods-" + goodsId;

		
      String value = getCommonString(key);

      if (StringUtil.isNullOrEmpty(value)) {

         PDDGoodsDetail pddGoods = PinDuoDuoApiUtil.getGoodsDetail(goodsId);



         // 缓存20分钟

         if (pddGoods != null)

            cacheCommonString(key, JsonUtil.getSimpleGson().toJson(pddGoods), 60 * 20);

			
         return pddGoods;

      } else {// 直接取缓存

         return JsonUtil.getSimpleGson().fromJson(value, PDDGoodsDetail.class);

      }

   }



}