From b9f8ef2c4737b6e6be4b12fc8f7bafb033bfcfe5 Mon Sep 17 00:00:00 2001
From: admin <2780501319@qq.com>
Date: 星期日, 22 九月 2019 16:47:33 +0800
Subject: [PATCH] 金币BUG修改

---
 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/SearchControllerV2.java |   84 ++++++++++++++++++++++++++++++++----------
 1 files changed, 64 insertions(+), 20 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/SearchControllerV2.java b/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/SearchControllerV2.java
index 030f0bb..cc30a88 100644
--- a/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/SearchControllerV2.java
+++ b/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/SearchControllerV2.java
@@ -10,12 +10,14 @@
 import java.util.regex.Pattern;
 
 import javax.annotation.Resource;
+import javax.servlet.http.HttpSession;
 
 import org.springframework.core.task.TaskExecutor;
 import org.springframework.stereotype.Controller;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.yeshi.utils.JsonUtil;
+import org.yeshi.utils.NumberUtil;
 import org.yeshi.utils.taobao.TbImgUtil;
 
 import com.google.gson.Gson;
@@ -39,20 +41,23 @@
 import com.yeshi.fanli.service.inter.config.BusinessSystemService;
 import com.yeshi.fanli.service.inter.config.ConfigService;
 import com.yeshi.fanli.service.inter.config.SuperHotSearchService;
-import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;
 import com.yeshi.fanli.service.inter.lable.QualityGoodsService;
 import com.yeshi.fanli.service.inter.lable.TaoKeGoodsService;
+import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;
 import com.yeshi.fanli.service.inter.taobao.TaoBaoShopService;
 import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService;
 import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsDetailService;
 import com.yeshi.fanli.service.inter.user.HistorySearchService;
 import com.yeshi.fanli.service.inter.user.TokenRecordService;
+import com.yeshi.fanli.service.inter.user.integral.IntegralGetService;
 import com.yeshi.fanli.tag.PageEntity;
 import com.yeshi.fanli.util.Constant;
 import com.yeshi.fanli.util.StringUtil;
 import com.yeshi.fanli.util.ThreadUtil;
 import com.yeshi.fanli.util.Utils;
 import com.yeshi.fanli.util.VersionUtil;
+import com.yeshi.fanli.util.annotation.RequestSerializableByKey;
+import com.yeshi.fanli.util.cache.IntegralGetCacheManager;
 import com.yeshi.fanli.util.cache.TaoBaoGoodsCacheUtil;
 import com.yeshi.fanli.util.factory.CommonGoodsFactory;
 import com.yeshi.fanli.util.factory.goods.GoodsDetailVOFactory;
@@ -109,9 +114,15 @@
 
 	@Resource(name = "taskExecutor")
 	private TaskExecutor executor;
-	
+
 	@Resource
 	private TokenRecordService tokenRecordService;
+
+	@Resource
+	private IntegralGetService integralGetService;
+
+	@Resource
+	private IntegralGetCacheManager integralGetCacheManager;
 
 	/**
 	 * 绮樿创鏉夸俊鎭帹鑽�
@@ -129,7 +140,7 @@
 		}
 		// 鍘婚櫎鍓嶅悗绌烘牸
 		text = text.trim();
-		
+
 		try {
 			TokenVO tokenVO = tokenRecordService.discernToken(text, uid);
 			out.print(JsonUtil.loadTrueResult(tokenVO));
@@ -140,7 +151,6 @@
 				return;
 			}
 		}
-
 
 		TaoBaoGoodsBrief tb = null;
 		String URL_REGEX = "(((http|https)://)|(www\\.))[a-zA-Z0-9\\._-]+\\.[a-zA-Z]{2,6}(:[0-9]{1,4})?(/[a-zA-Z0-9\\&%_\\./-~-]*)?";
@@ -153,7 +163,7 @@
 				return;
 			}
 			String pattern = "^[A-Za-z0-9-]+$";
-			if (Pattern.matches(pattern, text.replace(" ", ""))) {//鍒犻櫎绌烘牸
+			if (Pattern.matches(pattern, text.replace(" ", ""))) {// 鍒犻櫎绌烘牸
 				out.println(JsonUtil.loadFalseResult("涓嶆敮鎸佹帹鑽�"));
 				return;
 			}
@@ -181,7 +191,14 @@
 
 		CommonGoods commonGoods = null;
 		text = matcher.group();
-		if (text.contains("ju.taobao.com") || text.contains(".juhuasuan.com")) {// 鑱氬垝绠�
+
+		if (text.startsWith("https://a.m.taobao.com/i"))// 娣樺疂璐﹀彿鏈櫥褰曠姸鎬�
+		{
+			text = text.substring("https://a.m.taobao.com/i".length(), text.indexOf(".htm"));
+			if (NumberUtil.isNumeric(text)) {
+				tb = TaoBaoUtil.isAlimama(text);
+			}
+		} else if (text.contains("ju.taobao.com") || text.contains(".juhuasuan.com")) {// 鑱氬垝绠�
 			int index = text.indexOf("item_id");
 			if (index < 0) {
 				out.println(JsonUtil.loadFalseResult("鏆傛湭鎵惧埌璇ュ晢鍝侊紝璇风◢鍚庡啀璇曪紒"));
@@ -235,10 +252,9 @@
 			return;
 		}
 
-
 		JSONObject data = new JSONObject();
-		
-		if(VersionUtil.greaterThan_1_6_5(acceptData.getPlatform(), acceptData.getVersion())) {
+
+		if (VersionUtil.greaterThan_1_6_5(acceptData.getPlatform(), acceptData.getVersion())) {
 			if (tb != null) {
 				TaoBaoGoodsBrief goodsBrief = null;
 				try {
@@ -257,11 +273,12 @@
 			Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
 					.excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();
 			data.put("type", 3);
-			data.put("goods", gson.toJson(GoodsDetailVOFactory.convertCommonGoods(commonGoods, null, fanLiRate, shareRate)));
+			data.put("goods",
+					gson.toJson(GoodsDetailVOFactory.convertCommonGoods(commonGoods, null, fanLiRate, shareRate)));
 			out.print(JsonUtil.loadTrueResult(data));
 			return;
 		}
-		
+
 		if (tb != null) {
 			commonGoods = new CommonGoods();
 			commonGoods.setPrice(tb.getZkPrice());
@@ -270,7 +287,7 @@
 			commonGoods.setGoodsType(Constant.SOURCE_TYPE_TAOBAO);
 			commonGoods.setPicture(tb.getPictUrl());
 		}
-		
+
 		JSONObject taoBaoGoodsJSON = new JSONObject();
 		taoBaoGoodsJSON.put("title", commonGoods.getTitle());
 		taoBaoGoodsJSON.put("zkPrice", commonGoods.getPrice() + "");
@@ -331,26 +348,25 @@
 		return false;
 	}
 
-	
 	/**
+	 * 鍙d护棰嗗彇
 	 * 
 	 * @param acceptData
 	 * @param kw
 	 * @param goodsType
 	 * @param out
 	 */
+	@RequestSerializableByKey(key = "'tokenReceive-'+#uid")
 	@RequestMapping(value = "tokenReceive", method = RequestMethod.POST)
 	public void tokenReceive(AcceptData acceptData, Long uid, String token, PrintWriter out) {
 		try {
-			tokenRecordService.receiveToken(token, uid);
-			out.print(JsonUtil.loadTrueResult("棰嗗彇鎴愬姛"));
+			String msg = tokenRecordService.receiveToken(token, uid);
+			out.print(JsonUtil.loadTrueResult(msg));
 		} catch (TokenRecordException e) {
 			out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));
 		}
 	}
-	
-	
-	
+
 	/**
 	 * 鎼滅储鍊欓�夎瘝
 	 * 
@@ -403,7 +419,8 @@
 	 */
 	@RequestMapping(value = "searchGoods")
 	public void searchGoods(AcceptData acceptData, Integer goodsType, String key, Integer page, String filter,
-			Integer order, PrintWriter out) {
+			Integer order, Long uid, HttpSession session, PrintWriter out) {
+
 		if (goodsType == null || goodsType < 1 || goodsType > 3) {
 			out.print(JsonUtil.loadFalseResult(1, "璇蜂紶閫掓纭钩鍙板弬鏁�"));
 			return;
@@ -419,6 +436,24 @@
 			return;
 		}
 		final String searchkey = key.trim();
+
+		if (uid != null) {
+			if (page == 1) {
+				integralGetCacheManager.cacheSearchGoods(acceptData.getDevice(), System.currentTimeMillis());
+			} else if (page > 1) {
+				Long lastTime = integralGetCacheManager.getLastSearchTime(acceptData.getDevice());
+				if (lastTime != null && System.currentTimeMillis() - lastTime >= 15 * 1000L) {// 瓒呰繃15s娴忚
+					integralGetCacheManager.clearSearchTime(acceptData.getDevice());
+					ThreadUtil.run(new Runnable() {
+						@Override
+						public void run() {
+							// 澧炲姞閲戝竵
+							integralGetService.addSearchResultScan(uid, key);
+						}
+					});
+				}
+			}
+		}
 
 		executor.execute(new Runnable() {
 			@Override
@@ -590,6 +625,7 @@
 	private void searchJDGoods(String key, Integer page, String filter, Integer order, PrintWriter out) {
 
 		JDSearchResult result = null;
+		boolean hasCoupon = false;
 		String way = configService.get("jd_api_search_key");
 		if ("1".equals(way)) {
 			JDFilter filterAPI = new JDFilter();
@@ -625,6 +661,7 @@
 				JSONObject jsonfilter = JSONObject.fromObject(filter);
 				Boolean coupon = jsonfilter.optBoolean("coupon");
 				if (coupon != null && coupon) {
+					hasCoupon = true;
 					filterAPI.setIsCoupon(1); // 鏈夊埜
 				}
 
@@ -680,6 +717,7 @@
 				JSONObject jsonfilter = JSONObject.fromObject(filter);
 				Boolean coupon = jsonfilter.optBoolean("coupon");
 				if (coupon != null && coupon) {
+					hasCoupon = true;
 					jdfilter.setHasCoupon(1); // 鏈夊埜
 				}
 
@@ -732,7 +770,13 @@
 						.excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();
 				for (JDGoods goods : goodsList) {
 					GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertJDGoods(goods, fanLiRate, shareRate);
-					array.add(gson.toJson(goodsDetailVO));
+					if (hasCoupon) {
+						if (goodsDetailVO.isHasCoupon()) {
+							array.add(gson.toJson(goodsDetailVO));
+						}
+					} else {
+						array.add(gson.toJson(goodsDetailVO));
+					}
 				}
 			}
 		}

--
Gitblit v1.8.0