| | |
| | | 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;
|
| | |
| | | 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
|
| | |
| | | private TaoBaoShopService taoBaoShopService;
|
| | |
|
| | | @Resource
|
| | | private TaoBaoUnionConfigService taoBaoUnionConfigService; |
| | | private TaoBaoUnionConfigService taoBaoUnionConfigService;
|
| | |
|
| | | @Resource
|
| | | private ConfigService configService;
|
| | |
| | | */
|
| | | 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();
|
| | | }
|
| | |
|
| | | }
|
| | |
| | | try {
|
| | | jedis.del(key);
|
| | | } finally {
|
| | | jedisPool.returnResource(jedis);
|
| | | jedis.close();
|
| | | }
|
| | |
|
| | | }
|
| | |
| | | try {
|
| | | jedis.setex(key, seconds, value);
|
| | | } finally {
|
| | | jedisPool.returnResource(jedis);
|
| | | jedis.close();
|
| | | }
|
| | | }
|
| | |
|
| | |
| | | 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();
|
| | | }
|
| | | }
|
| | |
|
| | |
| | | }
|
| | |
|
| | | /**
|
| | | * 将信息永久保存到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;
|
| | | }
|
| | |
|
| | | /**
|
| | |
| | | * @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);
|
| | |
| | | }
|
| | |
|
| | | 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);
|
| | |
| | |
|
| | | 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);
|
| | |
| | | * @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();
|
| | | }
|
| | | }
|
| | |
|
| | |
| | | * @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);
|
| | |
| | | * @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;
|
| | | }
|
| | | }
|
| | |
|
| | |
| | | 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;
|
| | |
| | | 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);
|
| | | }
|
| | |
|
| | |
| | | */
|
| | |
|
| | | 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);
|
| | | }
|
| | |
| | | * @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);
|
| | | }
|
| | |
| | | * @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);
|
| | | }
|
| | |
|
| | |
| | | * 保存绑定支付宝短信验证码的正确性
|
| | | */
|
| | | public void saveBindAlipayAccountSMSState(String phone) {
|
| | | String key = "smsstate-alipay-" + phone;
|
| | |
|
| | | String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMSStateAlipay, phone + "" );
|
| | | // 验证后十分钟有效
|
| | | setString(key, "1", 10 * 60);
|
| | | }
|
| | |
| | | * @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);
|
| | | }
|
| | | }
|
| | |
|
| | | }
|