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