package com.yeshi.fanli.controller.client.v2;
|
|
import java.io.PrintWriter;
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.Collections;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.regex.Matcher;
|
import java.util.regex.Pattern;
|
|
import javax.annotation.Resource;
|
|
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;
|
import com.google.gson.GsonBuilder;
|
import com.yeshi.fanli.dto.jd.JDFilter;
|
import com.yeshi.fanli.dto.jd.JDSearchFilter;
|
import com.yeshi.fanli.dto.jd.JDSearchResult;
|
import com.yeshi.fanli.dto.pdd.PDDGoodsDetail;
|
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.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.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.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.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.cache.TaoBaoGoodsCacheUtil;
|
import com.yeshi.fanli.util.factory.goods.GoodsDetailVOFactory;
|
import com.yeshi.fanli.util.jd.JDApiUtil;
|
import com.yeshi.fanli.util.jd.JDUtil;
|
import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil;
|
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.vo.brand.TaoBaoShopVO;
|
import com.yeshi.fanli.vo.goods.GoodsDetailVO;
|
|
import net.sf.json.JSONArray;
|
import net.sf.json.JSONObject;
|
|
@Controller
|
@RequestMapping("api/v2/search")
|
public class SearchControllerV2 {
|
|
@Resource
|
private BusinessSystemService businessSystemService;
|
|
@Resource
|
private ConfigService configService;
|
|
@Resource
|
private SuperHotSearchService superHotSearchSerivce;
|
|
@Resource
|
private HistorySearchService historySearchService;
|
|
@Resource
|
private HongBaoManageService hongBaoManageService;
|
|
@Resource
|
private TaoBaoUnionConfigService taoBaoUnionConfigService;
|
|
@Resource
|
private TaoKeGoodsService taoKeGoodsService;
|
|
@Resource
|
private QualityGoodsService qualityGoodsService;
|
|
@Resource
|
private TaoBaoGoodsCacheUtil taoBaoGoodsCacheUtil;
|
|
@Resource
|
private TaoBaoShopService taoBaoShopService;
|
|
@Resource
|
private DaTaoKeGoodsDetailService daTaoKeGoodsDetailService;
|
|
@Resource(name = "taskExecutor")
|
private TaskExecutor executor;
|
|
/**
|
* 粘贴板信息推荐
|
*
|
* @param acceptData
|
* @param url
|
* 商品链接
|
* @param 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;
|
}
|
|
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\\&%_\\./-~-]*)?";
|
|
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 (NumberUtil.isNumeric(text)) {
|
out.println(JsonUtil.loadFalseResult("不支持纯数字"));
|
return;
|
}
|
|
LogHelper.test("根据粘贴板推荐:" + text);
|
|
if (text.length() > 80) {
|
out.print(JsonUtil.loadFalseResult("值过长"));
|
return;
|
}
|
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;
|
}
|
|
text = matcher.group();
|
if (text.contains("ju.taobao.com") || text.contains(".juhuasuan.com")) {// 聚划算
|
int index = text.indexOf("item_id");
|
if (index < 0) {
|
out.println(JsonUtil.loadFalseResult("暂未找到该商品，请稍后再试！"));
|
return;
|
}
|
text = text.substring(index);
|
int last = text.indexOf("&");
|
String id = "";
|
if (last > 0)
|
id = text.substring(text.indexOf("=") + 1, text.indexOf("&"));
|
else {
|
id = text.substring(text.indexOf("=" + 1));
|
}
|
tb = TaoBaoUtil.isAlimama(id);
|
if (tb == null) {
|
tb = TaoBaoUtil.parsePhoneTmAndTb(id);
|
}
|
} else if (text.contains("http://zmnxbc.com")) { // 手机端天猫APP分享
|
tb = TaoBaoUtil.parsePhoneShareUrlByTM(text);
|
} else if (text.contains("h5.m.taobao") || text.contains("detail.m.tmall") || text.contains("item.taobao")
|
|| text.contains("detail.tmall")) { // 手机页面和电脑页面
|
Map<String, String> map = Utils.parseURL(text);
|
String id = "";
|
id = map.get("id").replace("}", "");
|
tb = TaoBaoUtil.isAlimama(id);
|
if (tb == null) {
|
tb = TaoBaoUtil.parsePhoneTmAndTb(id);
|
}
|
} else {
|
tb = TaoBaoUtil.parsePhoneShareUrlByTB(text);
|
}
|
|
if (tb == null) {
|
out.println(JsonUtil.loadFalseResult("暂未找到该商品，请稍后再试！"));
|
return;
|
}
|
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));
|
}
|
|
/**
|
* 搜索候选词
|
*
|
* @param acceptData
|
* @param kw
|
* @param out
|
*/
|
@RequestMapping(value = "suggestSearch", method = RequestMethod.POST)
|
public void getSugguestSearch(AcceptData acceptData, String kw, Integer goodsType, PrintWriter out) {
|
if (goodsType == null) {
|
out.print(JsonUtil.loadFalseResult("平台类型不能为空"));
|
return;
|
}
|
|
List<String> list = null;
|
if (goodsType == Constant.SOURCE_TYPE_TAOBAO) {
|
list = TaoBaoUtil.getSuguestSearch(kw);
|
} else if (goodsType == Constant.SOURCE_TYPE_JD) {
|
list = JDUtil.suggestSearch(kw);
|
} else if (goodsType == Constant.SOURCE_TYPE_PDD) {
|
list = PinDuoDuoUtil.suggestSearch(kw);
|
}
|
|
if (list == null || list.size() == 0) {
|
out.print(JsonUtil.loadFalseResult("暂无建议内容"));
|
return;
|
}
|
|
JSONArray array = new JSONArray();
|
for (String words : list) {
|
array.add(words);
|
}
|
out.print(JsonUtil.loadTrueResult(array));
|
}
|
|
/**
|
* 搜索-新版
|
*
|
* @param acceptData
|
* @param kw
|
* @param page
|
* @param filter
|
* @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) {
|
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() {
|
StringBuffer sb = new StringBuffer();
|
String link = "#$$$#";
|
String platform = acceptData.getPlatform();
|
String packages = acceptData.getPackages();
|
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();
|
data.put("result", new JSONArray());
|
data.put("count", 0);
|
out.print(JsonUtil.loadTrueResult(data));
|
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);
|
}
|
|
/**
|
* 执行搜索-新版
|
*
|
* @param kw
|
* @param page
|
* @param filter
|
* @param order
|
* @param startprice
|
* @param endprice
|
* @return
|
*/
|
private void searchTaoBaoGoods(String key, Integer page, String filter, Integer order, PrintWriter out) {
|
SearchFilter sf = new SearchFilter();
|
sf.setKey(SearchFilterUtil.filterSearchContent(key));
|
sf.setPage(page);
|
sf.setPageSize(Constant.PAGE_SIZE);
|
|
if (order != null) {
|
if (order == 1) { // 销量高到低
|
sf.setSort(TaoBaoUtil.SORT_SALE_HIGH_TO_LOW);
|
} else if (order == 2) { // 价格高到低
|
sf.setSort(TaoBaoUtil.SORT_PRICE_HIGH_TO_LOW);
|
} else if (order == 3) { // 价格低到高
|
sf.setSort(TaoBaoUtil.SORT_PRICE_LOW_TO_HIGH);
|
} 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));
|
}
|
}
|
|
// 搜索大淘客
|
List<DaTaoKeDetail> daTaoKeList = null;
|
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() {
|
@Override
|
public void run() {
|
// 更新到緩存
|
for (TaoBaoGoodsBrief goods : result.getTaoBaoGoodsBriefs())
|
taoBaoGoodsCacheUtil.saveCommonTaoBaoGoodsInfo(goods);
|
}
|
});
|
}
|
|
List<TaoBaoGoodsBrief> taoBaoGoodsBriefs = null;
|
if (result != null) {
|
taoBaoGoodsBriefs = result.getTaoBaoGoodsBriefs();
|
}
|
if (taoBaoGoodsBriefs == null) {
|
taoBaoGoodsBriefs = new ArrayList<>();
|
}
|
|
if (daTaoKeList != null && daTaoKeList.size() > 0) {
|
try {
|
Collections.reverse(daTaoKeList);
|
for (DaTaoKeDetail detail : daTaoKeList) {
|
taoBaoGoodsBriefs.add(0, TaoBaoUtil.convert(detail));
|
}
|
} catch (Exception e) {
|
}
|
}
|
|
List<GoodsDetailVO> list = new ArrayList<GoodsDetailVO>();
|
BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();
|
BigDecimal shareRate = hongBaoManageService.getShareRate();
|
for (TaoBaoGoodsBrief goods : taoBaoGoodsBriefs) {
|
list.add(GoodsDetailVOFactory.convertTaoBao(goods, null, fanLiRate, shareRate));
|
}
|
|
Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
|
.excludeFieldsWithoutExposeAnnotation().create();
|
|
JSONObject data = new JSONObject();
|
data.put("result", gson.toJson(list));
|
data.put("count", result.getTaoBaoHead().getDocsfound());
|
|
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)));
|
}
|
}
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
|
/**
|
* 京东
|
*
|
* @param kw
|
* @param page
|
* @param filter
|
* @param order
|
* @param startprice
|
* @param endprice
|
* @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)) {
|
JDFilter filterAPI = new JDFilter();
|
filterAPI.setKeyword(SearchFilterUtil.filterSearchContent(key));
|
filterAPI.setPageIndex(page);
|
filterAPI.setPageSize(Constant.PAGE_SIZE);
|
|
if (order != null) {
|
int sort = order.intValue();
|
switch (sort) {
|
case 1: // 销量 desc
|
filterAPI.setSort(JDFilter.SORT_DESC);
|
filterAPI.setSortName(JDFilter.SORTNAME_ORDER_COUNT_30DAYS);
|
break;
|
case 2: // 价格—desc
|
filterAPI.setSort(JDFilter.SORT_DESC);
|
filterAPI.setSortName(JDFilter.SORTNAME_PRICE);
|
break;
|
case 3: // 价格—asc
|
filterAPI.setSort(JDFilter.SORT_ASC);
|
filterAPI.setSortName(JDFilter.SORTNAME_PRICE);
|
break;
|
case 4: // 返利比—DESC
|
filterAPI.setSort(JDFilter.SORT_DESC);
|
filterAPI.setSortName(JDFilter.SORTNAME_COMMISSION_SHARE);
|
break;
|
default:
|
break;
|
}
|
}
|
|
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 {
|
// 网页爬取
|
JDSearchFilter jdfilter = new JDSearchFilter();
|
jdfilter.setKey(SearchFilterUtil.filterSearchContent(key));
|
jdfilter.setPageNo(page);
|
jdfilter.setPageSize(Constant.PAGE_SIZE);
|
|
if (order != null) {
|
int sort = order.intValue();
|
switch (sort) {
|
case 1: // 销量 desc
|
jdfilter.setSort(JDSearchFilter.SORT_DESC);
|
jdfilter.setSortName(JDSearchFilter.SORTNAME_ORDER_COUNT_30DAYS);
|
break;
|
case 2: // 价格—desc
|
jdfilter.setSort(JDSearchFilter.SORT_DESC);
|
jdfilter.setSortName(JDSearchFilter.SORTNAME_PRICE);
|
break;
|
case 3: // 价格—asc
|
jdfilter.setSort(JDSearchFilter.SORT_ASC);
|
jdfilter.setSortName(JDSearchFilter.SORTNAME_PRICE);
|
break;
|
case 4: // 返利比—DESC
|
jdfilter.setSort(JDSearchFilter.SORT_DESC);
|
jdfilter.setSortName(JDSearchFilter.SORTNAME_COMMISSION_SHARE);
|
break;
|
default:
|
break;
|
}
|
}
|
|
if (!StringUtil.isNullOrEmpty(filter)) {
|
JSONObject jsonfilter = JSONObject.fromObject(filter);
|
Boolean coupon = jsonfilter.optBoolean("coupon");
|
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();
|
if (result != null) {
|
PageEntity pageEntity = result.getPageEntity();
|
if (pageEntity != null) {
|
count = pageEntity.getTotalCount();
|
}
|
|
List<JDGoods> 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 (JDGoods goods : goodsList) {
|
GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertJDGoods(goods, fanLiRate, shareRate);
|
array.add(gson.toJson(goodsDetailVO));
|
}
|
}
|
}
|
|
data.put("result", array);
|
data.put("count", count);
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
|
/**
|
* 拼多多
|
*
|
* @param kw
|
* @param page
|
* @param filter
|
* @param order
|
* @param startprice
|
* @param endprice
|
* @return
|
*/
|
private void searchPDDGoods(String key, Integer page, String filter, Integer order, PrintWriter out) {
|
PDDSearchFilter pddfilter = new PDDSearchFilter();
|
pddfilter.setKw(SearchFilterUtil.filterSearchContent(key));
|
pddfilter.setPage(page);
|
pddfilter.setPageSize(Constant.PAGE_SIZE);
|
|
if (order != null) {
|
int sort = order.intValue();
|
switch (sort) {
|
case 1: // 销量 desc
|
pddfilter.setSortType(6);
|
break;
|
case 2: // 价格—desc
|
pddfilter.setSortType(4);
|
break;
|
case 3: // 价格—asc
|
pddfilter.setSortType(3);
|
break;
|
case 4: // 返利比—desc
|
pddfilter.setSortType(2);
|
break;
|
default: // 综合排序
|
pddfilter.setSortType(0);
|
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); // 是否是品牌
|
}
|
}
|
|
int count = 0;
|
JSONObject data = new JSONObject();
|
JSONArray array = new JSONArray();
|
|
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();
|
|
for (PDDGoodsDetail goods : goodsList) {
|
GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertPDDGoods(goods, fanLiRate, shareRate);
|
array.add(gson.toJson(goodsDetailVO));
|
}
|
}
|
}
|
|
data.put("result", array);
|
data.put("count", count);
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
}
|
