From 6b75391e97aa770e12965ec6e542856df79e6de0 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 27 九月 2019 15:14:02 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/div' into div
---
fanli/src/main/java/com/yeshi/fanli/controller/client/v2/SearchControllerV2.java | 247 ++++++++++++++++++++++++++++++++++++++++++++-----
1 files changed, 220 insertions(+), 27 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 cfe3891..67d202c 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;
@@ -34,22 +36,28 @@
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.exception.user.TokenRecordException;
import com.yeshi.fanli.log.LogHelper;
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;
@@ -60,8 +68,10 @@
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.BrandInfoVO;
import com.yeshi.fanli.vo.brand.TaoBaoShopVO;
import com.yeshi.fanli.vo.goods.GoodsDetailVO;
+import com.yeshi.fanli.vo.msg.TokenVO;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
@@ -106,6 +116,15 @@
@Resource(name = "taskExecutor")
private TaskExecutor executor;
+ @Resource
+ private TokenRecordService tokenRecordService;
+
+ @Resource
+ private IntegralGetService integralGetService;
+
+ @Resource
+ private IntegralGetCacheManager integralGetCacheManager;
+
/**
* 绮樿创鏉夸俊鎭帹鑽�
*
@@ -115,7 +134,7 @@
* @param out
*/
@RequestMapping(value = "getRecommendInfo", method = RequestMethod.POST)
- public void getRecommendInfo(AcceptData acceptData, String text, PrintWriter out) {
+ public void getRecommendInfo(AcceptData acceptData, String text, Long uid, PrintWriter out) {
if (StringUtil.isNullOrEmpty(text)) {
out.print(JsonUtil.loadFalseResult("鍊间负绌�"));
return;
@@ -123,9 +142,15 @@
// 鍘婚櫎鍓嶅悗绌烘牸
text = text.trim();
- if (text.length() > 256) {
- out.print(JsonUtil.loadFalseResult("鍊艰繃闀�"));
+ try {
+ TokenVO tokenVO = tokenRecordService.discernToken(text, uid);
+ out.print(JsonUtil.loadTrueResult(tokenVO));
return;
+ } catch (TokenRecordException e) {
+ if (e.getCode() == 1001) { // 闇�瑕佺敤鎴风櫥褰�
+ out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));
+ return;
+ }
}
TaoBaoGoodsBrief tb = null;
@@ -134,8 +159,12 @@
Pattern p = Pattern.compile(URL_REGEX);
Matcher matcher = p.matcher(text);
if (!matcher.find()) {// 涓嶅寘鍚摼鎺�
+ if (text.length() > 256) {
+ out.print(JsonUtil.loadFalseResult("鍊艰繃闀�"));
+ return;
+ }
String pattern = "^[A-Za-z0-9-]+$";
- if (Pattern.matches(pattern, text)) {
+ if (Pattern.matches(pattern, text.replace(" ", ""))) {// 鍒犻櫎绌烘牸
out.println(JsonUtil.loadFalseResult("涓嶆敮鎸佹帹鑽�"));
return;
}
@@ -147,12 +176,11 @@
return;
}
- if (analysisTaoToken(text, out)) {
+ if (analysisTaoToken(acceptData, text, out)) {
return;
}
JSONObject root = new JSONObject();
-
root.put("type", 2);
JSONObject data = new JSONObject();
data.put("title", text);
@@ -161,9 +189,17 @@
return;
}
+ int type = 3;
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("鏆傛湭鎵惧埌璇ュ晢鍝侊紝璇风◢鍚庡啀璇曪紒"));
@@ -179,7 +215,8 @@
}
tb = TaoBaoUtil.isAlimama(id);
if (tb == null) {
- tb = TaoBaoUtil.parsePhoneTmAndTb(id);
+ type = 4;
+ tb = TaoBaoUtil.getTmallGoodsInfo(id);
}
} else if (text.contains("http://zmnxbc.com")) { // 鎵嬫満绔ぉ鐚獳PP鍒嗕韩
tb = TaoBaoUtil.parsePhoneShareUrlByTM(text);
@@ -190,7 +227,8 @@
id = map.get("id").replace("}", "");
tb = TaoBaoUtil.isAlimama(id);
if (tb == null) {
- tb = TaoBaoUtil.parsePhoneTmAndTb(id);
+ type = 4;
+ tb = TaoBaoUtil.getTmallGoodsInfo(id);
}
} else {
tb = TaoBaoUtil.parsePhoneShareUrlByTB(text);
@@ -199,21 +237,94 @@
String jdId = JDUtil.getJDGoodsId(text);
if (!StringUtil.isNullOrEmpty(jdId)) {
JDGoods goods = JDApiUtil.getGoodsDetail(Long.parseLong(jdId));
- if (goods != null)
+ if (goods != null) {
commonGoods = CommonGoodsFactory.create(goods);
+ } else {
+ type = 4;
+ goods = JDUtil.getSimpleGoodsInfo(jdId);
+ if (goods != null) {
+ commonGoods = new CommonGoods();
+ commonGoods.setTitle(goods.getSkuName());
+ commonGoods.setPicture(goods.getPicUrl());
+ }
+ }
} else {
String pddId = PinDuoDuoUtil.getPDDGoodsId(text);
if (!StringUtil.isNullOrEmpty(pddId)) {
PDDGoodsDetail goods = PinDuoDuoApiUtil.getGoodsDetail(Long.parseLong(pddId));
- if (goods != null)
+ if (goods != null) {
commonGoods = CommonGoodsFactory.create(goods);
+ } else {
+ type = 4;
+ goods = PinDuoDuoUtil.getPDDGoodsInfo("26478646158");
+ commonGoods = new CommonGoods();
+ commonGoods.setTitle(goods.getGoodsName());
+ commonGoods.setPicture(goods.getGoodsThumbnailUrl());
+ }
}
}
}
}
-
+
if (tb == null && commonGoods == null) {
out.println(JsonUtil.loadFalseResult("鏆傛湭鎵惧埌璇ュ晢鍝侊紝璇风◢鍚庡啀璇曪紒"));
+ return;
+ }
+
+ if (type == 4) {
+ if (!VersionUtil.greaterThan_2_0_1(acceptData.getPlatform(), acceptData.getVersion())) {
+ out.println(JsonUtil.loadFalseResult("鏆傛湭鎵惧埌璇ュ晢鍝侊紝璇风◢鍚庡啀璇曪紒"));
+ return;
+ }
+
+ JSONObject data = new JSONObject();
+ if (tb != null) {
+ commonGoods = new CommonGoods();
+ commonGoods.setTitle(tb.getTitle());
+ commonGoods.setPicture(tb.getPictUrl());
+ }
+
+ if (StringUtil.isNullOrEmpty(commonGoods.getTitle()) || StringUtil.isNullOrEmpty(commonGoods.getPicture())) {
+ out.println(JsonUtil.loadFalseResult("鏆傛湭鎵惧埌璇ュ晢鍝侊紝璇风◢鍚庡啀璇曪紒"));
+ return;
+ }
+
+ JSONObject goodsJSON = new JSONObject();
+ goodsJSON.put("title", commonGoods.getTitle());
+ goodsJSON.put("pictUrl", commonGoods.getPicture());
+
+ data.put("type", type);
+ data.put("desc", "璇ュ晢鍝佹棤鎺ㄥ箍淇℃伅");
+ data.put("goods", goodsJSON);
+ out.print(JsonUtil.loadTrueResult(data));
+ return;
+ }
+
+
+ JSONObject data = new JSONObject();
+ if (VersionUtil.greaterThan_1_6_5(acceptData.getPlatform(), acceptData.getVersion())) {
+ if (tb != null) {
+ TaoBaoGoodsBrief goodsBrief = null;
+ try {
+ goodsBrief = TaoKeApiUtil.searchGoodsDetail(tb.getAuctionId());
+ } catch (TaobaoGoodsDownException e) {
+ e.printStackTrace();
+ }
+ if (goodsBrief == null) {
+ out.println(JsonUtil.loadFalseResult("鏆傛湭鎵惧埌璇ュ晢鍝侊紝璇风◢鍚庡啀璇曪紒"));
+ return;
+ }
+ commonGoods = CommonGoodsFactory.create(goodsBrief);
+ }
+
+ BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();
+ BigDecimal shareRate = hongBaoManageService.getShareRate();
+ Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
+ .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();
+ data.put("type", type);
+ data.put("goods",
+ gson.toJson(GoodsDetailVOFactory.convertCommonGoods(commonGoods, null, fanLiRate, shareRate)));
+ out.print(JsonUtil.loadTrueResult(data));
return;
}
@@ -226,7 +337,6 @@
commonGoods.setPicture(tb.getPictUrl());
}
- JSONObject data = new JSONObject();
JSONObject taoBaoGoodsJSON = new JSONObject();
taoBaoGoodsJSON.put("title", commonGoods.getTitle());
taoBaoGoodsJSON.put("zkPrice", commonGoods.getPrice() + "");
@@ -246,11 +356,10 @@
JSONObject root = new JSONObject();
root.put("type", 1);
root.put("data", data);
-
out.print(JsonUtil.loadTrueResult(root));
}
- private boolean analysisTaoToken(String text, PrintWriter out) {
+ private boolean analysisTaoToken(AcceptData acceptData, String text, PrintWriter out) {
String token = StringUtil.picUpTaoToken(text);
if (!StringUtil.isNullOrEmpty(token)) {
Long auctionId = TaoKeApiUtil.tokenConvertAuctionId(token);
@@ -263,6 +372,32 @@
}
if (tb != null) {
+ if (VersionUtil.greaterThan_1_6_5(acceptData.getPlatform(), acceptData.getVersion())) {
+ TaoBaoGoodsBrief goodsBrief = null;
+ try {
+ goodsBrief = TaoKeApiUtil.searchGoodsDetail(tb.getAuctionId());
+ } catch (TaobaoGoodsDownException e) {
+ e.printStackTrace();
+ }
+
+ if (goodsBrief == null) {
+ out.println(JsonUtil.loadFalseResult("鏆傛湭鎵惧埌璇ュ晢鍝侊紝璇风◢鍚庡啀璇曪紒"));
+ return false;
+ }
+
+ BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();
+ BigDecimal shareRate = hongBaoManageService.getShareRate();
+ Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
+ .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();
+
+ JSONObject data = new JSONObject();
+ data.put("type", 3);
+ data.put("goods", gson.toJson(GoodsDetailVOFactory.convertTaoBao(goodsBrief, null, fanLiRate, shareRate)));
+ out.print(JsonUtil.loadTrueResult(data));
+ return true;
+ }
+
+
JSONObject data = new JSONObject();
JSONObject taoBaoGoodsJSON = new JSONObject();
taoBaoGoodsJSON.put("title", tb.getTitle());
@@ -286,6 +421,25 @@
}
}
return false;
+ }
+
+ /**
+ * 鍙ｄ护棰嗗彇
+ *
+ * @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 {
+ String msg = tokenRecordService.receiveToken(token, uid);
+ out.print(JsonUtil.loadTrueResult(msg));
+ } catch (TokenRecordException e) {
+ out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));
+ }
}
/**
@@ -340,7 +494,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;
@@ -356,6 +511,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
@@ -383,18 +556,18 @@
/*--------- 浜笢鍟嗗搧 -------*/
if (goodsType.intValue() == Constant.SOURCE_TYPE_JD) {
- searchJDGoods(searchkey, page, filter, order, out);
+ searchJDGoods(acceptData, searchkey, page, filter, order, out);
return;
}
/*-------- 鎷煎澶氬晢鍝� -------*/
if (goodsType.intValue() == Constant.SOURCE_TYPE_PDD) {
- searchPDDGoods(searchkey, page, filter, order, out);
+ searchPDDGoods(acceptData, searchkey, page, filter, order, out);
return;
}
/*-------- 娣樺疂鍟嗗搧 -------*/
- searchTaoBaoGoods(searchkey, page, filter, order, out);
+ searchTaoBaoGoods(acceptData, searchkey, page, filter, order, out);
}
/**
@@ -408,7 +581,7 @@
* @param endprice
* @return
*/
- private void searchTaoBaoGoods(String key, Integer page, String filter, Integer order, PrintWriter out) {
+ private void searchTaoBaoGoods(AcceptData acceptData, String key, Integer page, String filter, Integer order, PrintWriter out) {
SearchFilter sf = new SearchFilter();
sf.setKey(SearchFilterUtil.filterSearchContent(key));
sf.setPage(page);
@@ -502,12 +675,23 @@
data.put("result", gson.toJson(list));
data.put("count", result.getTaoBaoHead().getDocsfound());
- if (page == 1) {
- // 绗竴椤佃繑鍥炲簵閾轰俊鎭�
+ if (page == 1) { // 绗竴椤佃繑鍥炲簵閾轰俊鎭�
List<TaoBaoShopVO> listShop = taoBaoShopService.getShopByKeyV2(key);
if (listShop != null && listShop.size() > 0 && listShop.get(0).getListGoodsVO() != null
&& listShop.get(0).getListGoodsVO().size() > 2) {
- data.put("shop", JsonUtil.getApiCommonGson().toJson(listShop.get(0)));
+ String platform = acceptData.getPlatform();
+ TaoBaoShopVO taoBaoShop = listShop.get(0);
+ if (("ios".equalsIgnoreCase(platform) && VersionUtil.greaterThan_2_0(platform, acceptData.getVersion()))
+ || ("android".equalsIgnoreCase(platform) && VersionUtil.greaterThan_2_0_1(platform, acceptData.getVersion()))) {
+ BrandInfoVO brandInfoVO = new BrandInfoVO();
+ brandInfoVO.setId(taoBaoShop.getId());
+ brandInfoVO.setName(taoBaoShop.getShopName());
+ brandInfoVO.setIcon(taoBaoShop.getShopIcon());
+ brandInfoVO.setListGoods(taoBaoShop.getListGoodsVO());
+ data.put("shop", JsonUtil.getApiCommonGson().toJson(brandInfoVO));
+ } else {
+ data.put("shop", JsonUtil.getApiCommonGson().toJson(taoBaoShop));
+ }
}
}
out.print(JsonUtil.loadTrueResult(data));
@@ -524,9 +708,10 @@
* @param endprice
* @return
*/
- private void searchJDGoods(String key, Integer page, String filter, Integer order, PrintWriter out) {
+ private void searchJDGoods(AcceptData acceptData, 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();
@@ -562,6 +747,7 @@
JSONObject jsonfilter = JSONObject.fromObject(filter);
Boolean coupon = jsonfilter.optBoolean("coupon");
if (coupon != null && coupon) {
+ hasCoupon = true;
filterAPI.setIsCoupon(1); // 鏈夊埜
}
@@ -617,6 +803,7 @@
JSONObject jsonfilter = JSONObject.fromObject(filter);
Boolean coupon = jsonfilter.optBoolean("coupon");
if (coupon != null && coupon) {
+ hasCoupon = true;
jdfilter.setHasCoupon(1); // 鏈夊埜
}
@@ -669,7 +856,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));
+ }
}
}
}
@@ -690,7 +883,7 @@
* @param endprice
* @return
*/
- private void searchPDDGoods(String key, Integer page, String filter, Integer order, PrintWriter out) {
+ private void searchPDDGoods(AcceptData acceptData, String key, Integer page, String filter, Integer order, PrintWriter out) {
PDDSearchFilter pddfilter = new PDDSearchFilter();
pddfilter.setKw(SearchFilterUtil.filterSearchContent(key));
pddfilter.setPage(page);
--
Gitblit v1.8.0