fanli-server.git

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

			@@ -116,18 +141,6 @@

			public void removeCommonString(String key) {
			removeKey(key);
			}

			/**
			* 将信息永久保存到Redis
			*
			* @param goods
			*/
			public void saveTaoBaoGoodsBriefForever(TaoBaoGoodsBrief goods) {
			String key = "taobao-goods-" + goods.getAuctionId();
			if (Constant.IS_OUTNET) {
			cacheCommonString(key, JsonUtil.getSimpleGson().toJson(goods));
			}
			}

			/**
			@@ -247,12 +260,28 @@
			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 = "frequency-" + 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();
			}
			}

			@@ -296,19 +325,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;
			}
			}

			@@ -359,8 +407,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);
			@@ -373,8 +419,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);
			@@ -388,8 +434,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);
			}
			@@ -484,4 +530,131 @@
			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);
			}
			}

			}