| | |
| | | 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.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;
|
| | |
| | | }
|
| | | }
|
| | |
|
| | | 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);
|
| | | }
|
| | |
| | | }
|
| | |
|
| | | /**
|
| | | * 将信息永久保存到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;
|
| | | }
|
| | |
|
| | | /**
|
| | |
| | | long count = jedis.incr(key);
|
| | | if (count == 1)
|
| | | jedis.expire(key, 5);
|
| | | if (count >= 100)
|
| | | if (count >= 10)
|
| | | return true;
|
| | | else
|
| | | return false;
|
| | |
| | | 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;
|
| | | }
|
| | | }
|
| | |
|
| | |
| | | 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);
|
| | | }
|
| | |
|
| | | }
|