饿了么绘图，添加口碑

admin

2020-05-19 744594ef1a2f530fc3e86ea9dc48b62247f79420

 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,14 +22,16 @@
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;

import redis.clients.jedis.JedisPool;

import redis.clients.jedis.params.SetParams;



//抢红包采用的redis

@Component

@@ -39,7 +44,7 @@
   private TaoBaoShopService taoBaoShopService;



   @Resource

   private TaoBaoUnionConfigService taoBaoUnionConfigService;
   private TaoBaoUnionConfigService taoBaoUnionConfigService;



   @Resource

   private ConfigService configService;

@@ -52,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();

      }



   }

@@ -71,7 +78,7 @@
      try {

         jedis.del(key);

      } finally {

         jedisPool.returnResource(jedis);

         jedis.close();

      }



   }

@@ -89,7 +96,7 @@
      try {

         jedis.setex(key, seconds, value);

      } finally {

         jedisPool.returnResource(jedis);

         jedis.close();

      }

   }



@@ -98,7 +105,25 @@
      try {

         return jedis.get(key);

      } finally {

         jedisPool.returnResource(jedis);

         jedis.close();

      }

   }



   public void increase(String key) {

      Jedis jedis = jedisPool.getResource();

      try {

         jedis.incr(key);

      } finally {

         jedis.close();

      }

   }



   public void expire(String key, int seconds) {

      Jedis jedis = jedisPool.getResource();

      try {

         jedis.expire(key, seconds);

      } finally {

         jedis.close();

      }

   }



@@ -119,15 +144,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 = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoGoodsTemp, 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 = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoGoodsTemp, auctionId + "");

      String value = getCommonString(key);

      if (!StringUtil.isNullOrEmpty(value)) {

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

      }

      return null;

   }



   /**

@@ -136,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);

@@ -165,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);

@@ -194,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);

@@ -217,18 +254,34 @@
    * @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);

         if (count == 1)

            jedis.expire(key, 5);

         if (count >= 100)

         if (count >= 10)

            return true;

         else

            return false;

      } finally {

         jedisPool.returnResource(jedis);

         jedis.close();

      }

   }



   public boolean frequencyLimit(String key, int timeS, int num) {

      key = RedisKeyEnum.getRedisKey(RedisKeyEnum.frequencyLimit, key);

      Jedis jedis = jedisPool.getResource();

      try {

         long count = jedis.incr(key);

         if (count == 1)

            jedis.expire(key, timeS);

         if (count >= num)

            return true;

         else

            return false;

      } finally {

         jedis.close();

      }

   }



@@ -239,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);

@@ -268,23 +321,42 @@
    * @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);



      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;

      }

   }



@@ -298,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;

@@ -315,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);

   }



@@ -335,9 +407,7 @@
    */



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

      if (!Constant.IS_OUTNET)

         return;

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

      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMSVCode, phone + "-" + type);

      // 保存2分钟

      setString(key, code, 120);

   }

@@ -349,9 +419,9 @@
    * @return

    */

   public String getSMSVCode(String phone, int type) {

      if (!Constant.IS_OUTNET)

         return "";

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

      // if (!Constant.IS_OUTNET)

      // return "";

      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMSVCode, phone + "-" + type);

      // 保存2分钟

      return getString(key);

   }

@@ -364,9 +434,9 @@
    * @param code

    */

   public void clearSMSVCode(String phone, int type) {

      if (!Constant.IS_OUTNET)

         return;

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

      // if (!Constant.IS_OUTNET)

      // return;

      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMSVCode, phone + "-" + type);

      removeKey(key);

   }



@@ -374,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);

   }

@@ -387,8 +456,198 @@
    * @return

    */

   public boolean isBindAlipayAccountSMSStateValid(String phone) {

      String key = "smsstate-alipay-" + phone;

      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMSStateAlipay, phone + "" );

      return !StringUtil.isNullOrEmpty(getString(key));

   }



   /**

    * 缓存短连接1分钟

    * 
    * @param uid

    * @param shortlink

    */

   public void setInviteShortLink(long uid, String shortlink) {

      String value = "";

      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.inviteShortLink, 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 = RedisKeyEnum.getRedisKey(RedisKeyEnum.inviteShortLink, uid + "" );

      if (Constant.IS_OUTNET)

         value = getCommonString(key);



      return value;

   }



   /**

    * 保存淘口令

    * 
    * @param auctionId

    * @param token

    */

   public void saveCommonTaoToken(Long auctionId, String token) {

      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoTokenCommon, 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 = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoTokenCommon, auctionId + "" );

      if (Constant.IS_OUTNET) {

         return getCommonString(key);

      }

      return null;

   }



   /**

    * 保存淘礼金的口令

    * 
    * @param url

    * @param token

    */

   public void saveTLJToken(String url, String token) {

      String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoTokenTLJ, 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 = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoTokenTLJ, StringUtil.Md5(url));

      if (Constant.IS_OUTNET) {

         return getCommonString(key);

      }

      return null;

   }



   /**

    * 保存对象

    * 
    * @param T

    * @param key

    * @param seconds

    */

   public void saveObj(Object 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 = RedisKeyEnum.getRedisKey(RedisKeyEnum.jingDongGoods, 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 = RedisKeyEnum.getRedisKey(RedisKeyEnum.pinDuoDuoGoods, 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);

      }

   }



}