From 5a80c35e42ba1ed7340097ea9b156016e52a23f2 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期一, 26 八月 2019 17:05:05 +0800 Subject: [PATCH] 京东订单修改 --- fanli/src/main/java/com/yeshi/fanli/controller/client/v2/SearchControllerV2.java | 271 +++++++++++++++++++++++++++++++++--------------------- 1 files changed, 165 insertions(+), 106 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 d95cde7..c5a53c0 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 @@ -16,6 +16,7 @@ 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; @@ -27,11 +28,13 @@ import com.yeshi.fanli.dto.pdd.PDDGoodsResult; import com.yeshi.fanli.dto.pdd.PDDSearchFilter; import com.yeshi.fanli.entity.accept.AcceptData; +import com.yeshi.fanli.entity.goods.CommonGoods; import com.yeshi.fanli.entity.jd.JDGoods; import com.yeshi.fanli.entity.taobao.SearchFilter; import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief; import com.yeshi.fanli.entity.taobao.TaoBaoSearchResult; import com.yeshi.fanli.entity.taobao.dataoke.DaTaoKeDetail; +import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException; import com.yeshi.fanli.log.LogHelper; import com.yeshi.fanli.service.inter.config.BusinessSystemService; import com.yeshi.fanli.service.inter.config.ConfigService; @@ -49,6 +52,7 @@ import com.yeshi.fanli.util.ThreadUtil; import com.yeshi.fanli.util.Utils; import com.yeshi.fanli.util.cache.TaoBaoGoodsCacheUtil; +import com.yeshi.fanli.util.factory.CommonGoodsFactory; import com.yeshi.fanli.util.factory.goods.GoodsDetailVOFactory; import com.yeshi.fanli.util.jd.JDApiUtil; import com.yeshi.fanli.util.jd.JDUtil; @@ -56,6 +60,7 @@ import com.yeshi.fanli.util.pinduoduo.PinDuoDuoUtil; import com.yeshi.fanli.util.taobao.SearchFilterUtil; import com.yeshi.fanli.util.taobao.TaoBaoUtil; +import com.yeshi.fanli.util.taobao.TaoKeApiUtil; import com.yeshi.fanli.vo.brand.TaoBaoShopVO; import com.yeshi.fanli.vo.goods.GoodsDetailVO; @@ -98,12 +103,10 @@ @Resource private DaTaoKeGoodsDetailService daTaoKeGoodsDetailService; - + @Resource(name = "taskExecutor") private TaskExecutor executor; - - /** * 绮樿创鏉夸俊鎭帹鑽� * @@ -112,17 +115,14 @@ * 鍟嗗搧閾炬帴 * @param out */ - @RequestMapping(value = "getNewGoodsInfo", method = RequestMethod.POST) - public void getNewGoodsInfo(AcceptData acceptData, String text, PrintWriter out) { + @RequestMapping(value = "getRecommendInfo", method = RequestMethod.POST) + public void getRecommendInfo(AcceptData acceptData, String text, PrintWriter out) { if (StringUtil.isNullOrEmpty(text)) { out.print(JsonUtil.loadFalseResult("鍊间负绌�")); return; } - - if (text.length() > 256) { - out.print(JsonUtil.loadFalseResult("鍊艰繃闀�")); - return; - } + // 鍘婚櫎鍓嶅悗绌烘牸 + text = text.trim(); 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\\&%_\\./-~-]*)?"; @@ -130,13 +130,14 @@ Pattern p = Pattern.compile(URL_REGEX); Matcher matcher = p.matcher(text); if (!matcher.find()) {// 涓嶅寘鍚摼鎺� - // 鍟嗗搧璇︽儏 - // 鍙戠幇 - // 娌℃湁閾炬帴锛屾爣棰樿繃闀夸篃涓嶅鐞� - if (text.startsWith("銆�") && text.contains("銆�")) { - int end = text.indexOf("銆�"); - if (end > 2) - text = text.substring(1, end); + if (text.length() > 256) { + out.print(JsonUtil.loadFalseResult("鍊艰繃闀�")); + return; + } + String pattern = "^[A-Za-z0-9-]+$"; + if (Pattern.matches(pattern, text.replace(" ", ""))) {// 鍒犻櫎绌烘牸 + out.println(JsonUtil.loadFalseResult("涓嶆敮鎸佹帹鑽�")); + return; } LogHelper.test("鏍规嵁绮樿创鏉挎帹鑽�:" + text); @@ -146,41 +147,30 @@ return; } - SearchFilter sf = new SearchFilter(); - sf.setKey(text); - JSONObject root = new JSONObject(); - - TaoBaoSearchResult result = TaoBaoUtil.search(sf); - if (result != null && result.getTaoBaoGoodsBriefs() != null && result.getTaoBaoGoodsBriefs().size() > 0) - for (TaoBaoGoodsBrief goods : result.getTaoBaoGoodsBriefs()) { - // 鏄睘浜庢窐瀹濊仈鐩熷晢鍝� - if (goods.getTitle().equalsIgnoreCase(text)) { - root.put("type", 2); - JSONObject data = new JSONObject(); - data.put("title", goods.getTitle()); - root.put("data", data); - out.print(JsonUtil.loadTrueResult(root)); - return; - } - } - - // 鏌ヨ澶ф窐瀹㈡爣棰� - List<DaTaoKeDetail> list = daTaoKeGoodsDetailService.listByDtitle(text); - if (list != null && list.size() > 0) { - root.put("type", 2); - JSONObject data = new JSONObject(); - data.put("title", list.get(0).getdTitle()); - root.put("data", data); - out.print(JsonUtil.loadTrueResult(root)); + if (analysisTaoToken(text, out)) { return; } - out.print(JsonUtil.loadFalseResult("鏆備笉鏀寔璇ョ被鍨嬶紒")); + JSONObject root = new JSONObject(); + + root.put("type", 2); + JSONObject data = new JSONObject(); + data.put("title", text); + root.put("data", data); + out.print(JsonUtil.loadTrueResult(root)); return; } + 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("鏆傛湭鎵惧埌璇ュ晢鍝侊紝璇风◢鍚庡啀璇曪紒")); @@ -211,34 +201,100 @@ } } else { tb = TaoBaoUtil.parsePhoneShareUrlByTB(text); + if (tb == null)// 娣樺疂鏄┖鍊� + { + String jdId = JDUtil.getJDGoodsId(text); + if (!StringUtil.isNullOrEmpty(jdId)) { + JDGoods goods = JDApiUtil.getGoodsDetail(Long.parseLong(jdId)); + if (goods != null) + commonGoods = CommonGoodsFactory.create(goods); + } else { + String pddId = PinDuoDuoUtil.getPDDGoodsId(text); + if (!StringUtil.isNullOrEmpty(pddId)) { + PDDGoodsDetail goods = PinDuoDuoApiUtil.getGoodsDetail(Long.parseLong(pddId)); + if (goods != null) + commonGoods = CommonGoodsFactory.create(goods); + } + } + } } - if (tb == null) { + if (tb == null && commonGoods == null) { out.println(JsonUtil.loadFalseResult("鏆傛湭鎵惧埌璇ュ晢鍝侊紝璇风◢鍚庡啀璇曪紒")); return; } + + if (tb != null) { + commonGoods = new CommonGoods(); + commonGoods.setPrice(tb.getZkPrice()); + commonGoods.setTitle(tb.getTitle()); + commonGoods.setGoodsId(tb.getAuctionId()); + commonGoods.setGoodsType(Constant.SOURCE_TYPE_TAOBAO); + commonGoods.setPicture(tb.getPictUrl()); + } + JSONObject data = new JSONObject(); JSONObject taoBaoGoodsJSON = new JSONObject(); - taoBaoGoodsJSON.put("title", tb.getTitle()); - taoBaoGoodsJSON.put("zkPrice", tb.getZkPrice()); - taoBaoGoodsJSON.put("auctionId", tb.getAuctionId()); - taoBaoGoodsJSON.put("url", "http://item.taobao.com/item.htm?id=" + tb.getAuctionId()); - data.put("taoBaoGoodsBrief", taoBaoGoodsJSON); - if (!StringUtil.isNullOrEmpty(tb.getPictUrl())) { - if (tb.getImgList() == null) - tb.setImgList(new ArrayList<>()); - tb.getImgList().add(0, TbImgUtil.getTBSize220Img(tb.getPictUrl())); + taoBaoGoodsJSON.put("title", commonGoods.getTitle()); + taoBaoGoodsJSON.put("zkPrice", commonGoods.getPrice() + ""); + taoBaoGoodsJSON.put("id", commonGoods.getGoodsId()); + taoBaoGoodsJSON.put("goodsType", commonGoods.getGoodsType()); + if (commonGoods.getGoodsType() == Constant.SOURCE_TYPE_TAOBAO) { + taoBaoGoodsJSON.put("url", "http://item.taobao.com/item.htm?id=" + commonGoods.getGoodsId()); + } else if (commonGoods.getGoodsType() == Constant.SOURCE_TYPE_JD) { + taoBaoGoodsJSON.put("url", String.format("https://item.jd.com/%s.html", commonGoods.getGoodsId() + "")); + } else if (commonGoods.getGoodsType() == Constant.SOURCE_TYPE_PDD) { + taoBaoGoodsJSON.put("url", "http://yangkeduo.com/goods.html?goods_id=" + commonGoods.getGoodsId()); } - data.put("tbImgs", tb.getImgList()); + data.put("goods", taoBaoGoodsJSON); + List<String> picList = new ArrayList<>(); + picList.add(commonGoods.getPicture()); + data.put("imgs", picList); JSONObject root = new JSONObject(); root.put("type", 1); root.put("data", data); out.print(JsonUtil.loadTrueResult(root)); } - - - + + private boolean analysisTaoToken(String text, PrintWriter out) { + String token = StringUtil.picUpTaoToken(text); + if (!StringUtil.isNullOrEmpty(token)) { + Long auctionId = TaoKeApiUtil.tokenConvertAuctionId(token); + if (auctionId != null) { + TaoBaoGoodsBrief tb = null; + try { + tb = TaoKeApiUtil.getSimpleGoodsInfo(auctionId); + } catch (TaobaoGoodsDownException e) { + e.printStackTrace(); + } + + if (tb != null) { + JSONObject data = new JSONObject(); + JSONObject taoBaoGoodsJSON = new JSONObject(); + taoBaoGoodsJSON.put("title", tb.getTitle()); + taoBaoGoodsJSON.put("zkPrice", tb.getZkPrice()); + taoBaoGoodsJSON.put("id", tb.getAuctionId()); + taoBaoGoodsJSON.put("goodsType", Constant.SOURCE_TYPE_TAOBAO); + taoBaoGoodsJSON.put("url", "http://item.taobao.com/item.htm?id=" + tb.getAuctionId()); + data.put("goods", taoBaoGoodsJSON); + if (!StringUtil.isNullOrEmpty(tb.getPictUrl())) { + if (tb.getImgList() == null) + tb.setImgList(new ArrayList<>()); + tb.getImgList().add(0, TbImgUtil.getTBSize220Img(tb.getPictUrl())); + } + data.put("imgs", tb.getImgList()); + JSONObject root = new JSONObject(); + root.put("type", 1); + root.put("data", data); + out.print(JsonUtil.loadTrueResult(root)); + return true; + } + } + } + return false; + } + /** * 鎼滅储鍊欓�夎瘝 * @@ -281,32 +337,33 @@ * @param kw * @param page * @param filter - * @param order 閿�閲忕敱楂樺埌浣�:1 銆� 浠锋牸浠庨珮鍒颁綆:2 銆� 浠锋牸浠庝綆鍒伴珮:3 銆� 鎺ㄥ箍閲忛珮鍒颁綆:4锛堢患鍚堥粯璁わ級銆佽繑鍒╂瘮楂樺埌浣�:5 - * 銆佽繑鍒╂瘮浣庡埌楂�:6 銆佹帹鑽�20 + * @param order + * 閿�閲忕敱楂樺埌浣�:1 銆� 浠锋牸浠庨珮鍒颁綆:2 銆� 浠锋牸浠庝綆鍒伴珮:3 銆� 鎺ㄥ箍閲忛珮鍒颁綆:4锛堢患鍚堥粯璁わ級銆佽繑鍒╂瘮楂樺埌浣�:5 + * 銆佽繑鍒╂瘮浣庡埌楂�:6 銆佹帹鑽�20 * @param startprice * @param endprice * @param fastFilter * @param out */ @RequestMapping(value = "searchGoods") - public void searchGoods(AcceptData acceptData, Integer goodsType, String key, Integer page, String filter, Integer order, - PrintWriter out) { - if (goodsType == null || goodsType < 1 || goodsType >3) { + public void searchGoods(AcceptData acceptData, Integer goodsType, String key, Integer page, String filter, + Integer order, PrintWriter out) { + if (goodsType == null || goodsType < 1 || goodsType > 3) { out.print(JsonUtil.loadFalseResult(1, "璇蜂紶閫掓纭钩鍙板弬鏁�")); return; } - + if (page == null || page < 1) { out.print(JsonUtil.loadFalseResult(1, "椤电爜涓嶈兘灏忎簬1")); return; } - + if (StringUtil.isNullOrEmpty(key)) { out.print(JsonUtil.loadFalseResult(1, "璇疯緭鍏ユ悳绱㈠唴瀹�")); return; } final String searchkey = key.trim(); - + executor.execute(new Runnable() { @Override public void run() { @@ -317,12 +374,11 @@ String device = acceptData.getDevice(); sb.append(platform).append(link).append(packages).append(link).append(device); String bid = StringUtil.Md5(sb.toString()); - + // 鍔犲叆鎼滅储鍘嗗彶璁板綍 historySearchService.addHistorySearch(searchkey, bid); } }); - if (searchkey.startsWith("http://") || searchkey.startsWith("https://")) { JSONObject data = new JSONObject(); @@ -332,19 +388,19 @@ return; } - /*--------- 浜笢鍟嗗搧 -------*/ + /*--------- 浜笢鍟嗗搧 -------*/ if (goodsType.intValue() == Constant.SOURCE_TYPE_JD) { searchJDGoods(searchkey, page, filter, order, out); return; } - /*-------- 鎷煎澶氬晢鍝� -------*/ + /*-------- 鎷煎澶氬晢鍝� -------*/ if (goodsType.intValue() == Constant.SOURCE_TYPE_PDD) { searchPDDGoods(searchkey, page, filter, order, out); return; } - /*-------- 娣樺疂鍟嗗搧 -------*/ + /*-------- 娣樺疂鍟嗗搧 -------*/ searchTaoBaoGoods(searchkey, page, filter, order, out); } @@ -375,25 +431,25 @@ } else if (order == 4) { // 杩斿埄姣旈珮鍒颁綆 sf.setSort(TaoBaoUtil.SORT_TKRATE_HIGH_TO_LOW); } - } - + } + if (!StringUtil.isNullOrEmpty(filter)) { JSONObject jsonfilter = JSONObject.fromObject(filter); Boolean coupon = jsonfilter.optBoolean("coupon"); if (coupon != null && coupon) { sf.setQuan(1); // 鏈夊埜 } - + Boolean tmall = jsonfilter.optBoolean("tmall"); if (tmall != null && tmall) { sf.setTmall(true); // 澶╃尗 } - + String minPrice = jsonfilter.optString("minPrice"); if (!StringUtil.isNullOrEmpty(minPrice)) { sf.setStartPrice(new BigDecimal(minPrice)); } - + String maxPrice = jsonfilter.optString("maxPrice"); if (!StringUtil.isNullOrEmpty(maxPrice)) { sf.setEndPrice(new BigDecimal(maxPrice)); @@ -405,10 +461,10 @@ if (page == 1) { daTaoKeList = daTaoKeGoodsDetailService.listByDtitle(key); } - + // 娣樺疂api鎼滅储鍟嗗搧 TaoBaoSearchResult result = TaoBaoUtil.search(sf); - + // 鎼滅储鏄惁鍦ㄨ惀閿�涓诲晢鍝佸簱 if (result != null && result.getTaoBaoGoodsBriefs() != null && result.getTaoBaoGoodsBriefs().size() > 0) { ThreadUtil.run(new Runnable() { @@ -420,7 +476,7 @@ } }); } - + List<TaoBaoGoodsBrief> taoBaoGoodsBriefs = null; if (result != null) { taoBaoGoodsBriefs = result.getTaoBaoGoodsBriefs(); @@ -428,7 +484,7 @@ if (taoBaoGoodsBriefs == null) { taoBaoGoodsBriefs = new ArrayList<>(); } - + if (daTaoKeList != null && daTaoKeList.size() > 0) { try { Collections.reverse(daTaoKeList); @@ -438,7 +494,7 @@ } catch (Exception e) { } } - + List<GoodsDetailVO> list = new ArrayList<GoodsDetailVO>(); BigDecimal fanLiRate = hongBaoManageService.getFanLiRate(); BigDecimal shareRate = hongBaoManageService.getShareRate(); @@ -448,7 +504,7 @@ Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()) .excludeFieldsWithoutExposeAnnotation().create(); - + JSONObject data = new JSONObject(); data.put("result", gson.toJson(list)); data.put("count", result.getTaoBaoHead().getDocsfound()); @@ -464,7 +520,6 @@ out.print(JsonUtil.loadTrueResult(data)); } - /** * 浜笢 * @@ -477,7 +532,7 @@ * @return */ private void searchJDGoods(String key, Integer page, String filter, Integer order, PrintWriter out) { - + JDSearchResult result = null; String way = configService.get("jd_api_search_key"); if ("1".equals(way)) { @@ -510,31 +565,29 @@ } } - if (!StringUtil.isNullOrEmpty(filter)) { JSONObject jsonfilter = JSONObject.fromObject(filter); Boolean coupon = jsonfilter.optBoolean("coupon"); if (coupon != null && coupon) { filterAPI.setIsCoupon(1); // 鏈夊埜 } - + Boolean zy = jsonfilter.optBoolean("zy"); if (zy != null && zy) { filterAPI.setOwner("g"); // 鑷惀 } - - + String minPrice = jsonfilter.optString("minPrice"); if (!StringUtil.isNullOrEmpty(minPrice)) { filterAPI.setPricefrom(Double.parseDouble(minPrice)); } - + String maxPrice = jsonfilter.optString("maxPrice"); if (!StringUtil.isNullOrEmpty(maxPrice)) { filterAPI.setPriceto(Double.parseDouble(maxPrice)); } } - + result = JDApiUtil.queryByKey(filterAPI); } else { // 缃戦〉鐖彇 @@ -573,31 +626,39 @@ if (coupon != null && coupon) { jdfilter.setHasCoupon(1); // 鏈夊埜 } - + Boolean zy = jsonfilter.optBoolean("zy"); if (zy != null && zy) { jdfilter.setIsZY(1); // 鑷惀 } - + Boolean delivery = jsonfilter.optBoolean("delivery"); if (delivery != null && delivery) { jdfilter.setDeliveryType(1); // 浜笢閰嶉�� } - + String minPrice = jsonfilter.optString("minPrice"); if (!StringUtil.isNullOrEmpty(minPrice)) { + if (minPrice.contains(".")) { + minPrice = minPrice.replace(".", "-"); + minPrice = minPrice.split("-")[0]; + } jdfilter.setFromPrice(Integer.parseInt(minPrice)); } - + String maxPrice = jsonfilter.optString("maxPrice"); if (!StringUtil.isNullOrEmpty(maxPrice)) { + if (maxPrice.contains(".")) { + maxPrice = maxPrice.replace(".", "-"); + maxPrice = maxPrice.split("-")[0]; + } jdfilter.setToPrice(Integer.parseInt(maxPrice)); } } result = JDUtil.searchByKey(jdfilter); - + } - + long count = 0; JSONObject data = new JSONObject(); JSONArray array = new JSONArray(); @@ -614,8 +675,7 @@ Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()) .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); for (JDGoods goods : goodsList) { - GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertJDGoods(goods, null, fanLiRate, - shareRate); + GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertJDGoods(goods, fanLiRate, shareRate); array.add(gson.toJson(goodsDetailVO)); } } @@ -627,7 +687,7 @@ } /** - * 浜笢 + * 鎷煎澶� * * @param kw * @param page @@ -663,14 +723,14 @@ break; } } - + if (!StringUtil.isNullOrEmpty(filter)) { JSONObject jsonfilter = JSONObject.fromObject(filter); Boolean coupon = jsonfilter.optBoolean("coupon"); if (coupon != null && coupon) { pddfilter.setHasCoupon(true); // 鏈夊埜 } - + Boolean brand = jsonfilter.optBoolean("brand"); if (brand != null && brand) { pddfilter.setIsBrand(true); // 鏄惁鏄搧鐗� @@ -684,15 +744,14 @@ PDDGoodsResult result = PinDuoDuoApiUtil.searchGoods(pddfilter); if (result != null) { count = result.getTotalCount(); + Gson gson = JsonUtil.getApiCommonGson(); List<PDDGoodsDetail> goodsList = result.getGoodsList(); if (goodsList != null && goodsList.size() > 0) { BigDecimal fanLiRate = hongBaoManageService.getFanLiRate(); BigDecimal shareRate = hongBaoManageService.getShareRate(); - Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()) - .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); + for (PDDGoodsDetail goods : goodsList) { - GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertPDDGoods(goods, null, fanLiRate, - shareRate); + GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertPDDGoods(goods, fanLiRate, shareRate); array.add(gson.toJson(goodsDetailVO)); } } -- Gitblit v1.8.0