package com.yeshi.fanli.service.impl.brand;
|
|
import java.math.BigDecimal;
|
import java.util.Date;
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.stereotype.Service;
|
|
import com.yeshi.fanli.dao.brand.BrandGoodsCaheDao;
|
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.brand.BrandGoodsCahe;
|
import com.yeshi.fanli.entity.brand.BrandInfo;
|
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.service.inter.brand.BrandGoodsCaheService;
|
import com.yeshi.fanli.service.inter.config.ConfigService;
|
import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;
|
import com.yeshi.fanli.tag.PageEntity;
|
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.taobao.SearchFilterUtil;
|
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
|
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
|
|
@Service
|
public class BrandGoodsCaheServiceImpl implements BrandGoodsCaheService {
|
@Resource
|
private HongBaoManageService hongBaoManageService;
|
|
@Resource
|
private ConfigService configService;
|
|
@Resource
|
private BrandGoodsCaheDao brandGoodsCaheDao;
|
|
|
@Override
|
public int addBrandGoods(BrandInfo brandInfo) {
|
int count = 0;
|
// 淘宝
|
count += addBrandGoodsTB(brandInfo);
|
// 京东
|
count += addBrandGoodsJD(brandInfo);
|
// 拼多多
|
count += addBrandGoodsPDD(brandInfo);
|
|
return count;
|
}
|
|
|
/**
|
* 淘宝商品
|
* @param brandInfo
|
* @return
|
*/
|
private int addBrandGoodsTB(BrandInfo brandInfo) {
|
SearchFilter filter = new SearchFilter();
|
filter.setKey(brandInfo.getName());
|
filter.setPage(1);
|
filter.setPageSize(50);
|
filter.setTmall(true);
|
filter.setSort(TaoBaoUtil.SORT_SALE_HIGH_TO_LOW);
|
TaoBaoSearchResult searchResult = TaoKeApiUtil.searchWuLiao(filter);
|
if (searchResult == null || searchResult.getTaoBaoGoodsBriefs() == null
|
|| searchResult.getTaoBaoGoodsBriefs().size() == 0)
|
return 0;
|
|
BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();
|
BigDecimal shareRate = hongBaoManageService.getShareRate();
|
List<TaoBaoGoodsBrief> listGoods = searchResult.getTaoBaoGoodsBriefs();
|
for (TaoBaoGoodsBrief goods: listGoods) {
|
BrandGoodsCahe brandGoods = new BrandGoodsCahe();
|
brandGoods.setBrandId(brandInfo.getId());
|
brandGoods.setWeight((int) (Math.random() * 1000));
|
brandGoods.setGoods(GoodsDetailVOFactory.convertTaoBao(goods, null, fanLiRate, shareRate));
|
brandGoods.setCreateTime(new Date());
|
brandGoods.setUpdateTime(new Date());
|
brandGoodsCaheDao.save(brandGoods);
|
}
|
return listGoods.size();
|
}
|
|
|
/**
|
* 京东商品
|
*
|
* @param brandInfo
|
* @return
|
*/
|
private int addBrandGoodsJD(BrandInfo brandInfo) {
|
JDSearchResult result = null;
|
String way = configService.get("jd_api_search_key");
|
if ("1".equals(way)) {
|
JDFilter filterAPI = new JDFilter();
|
filterAPI.setKeyword(SearchFilterUtil.filterSearchContent(brandInfo.getName()));
|
filterAPI.setPageIndex(1);
|
filterAPI.setPageSize(100);
|
filterAPI.setSort(JDFilter.SORT_DESC);
|
filterAPI.setSortName(JDFilter.SORTNAME_ORDER_COUNT_30DAYS);
|
result = JDApiUtil.queryByKey(filterAPI);
|
} else {
|
// 网页爬取
|
JDSearchFilter jdfilter = new JDSearchFilter();
|
jdfilter.setKey(SearchFilterUtil.filterSearchContent(brandInfo.getName()));
|
jdfilter.setPageNo(1);
|
jdfilter.setPageSize(100);
|
jdfilter.setSort(JDSearchFilter.SORT_DESC);
|
jdfilter.setSortName(JDSearchFilter.SORTNAME_ORDER_COUNT_30DAYS);
|
result = JDUtil.searchByKey(jdfilter);
|
}
|
|
int count = 0;
|
if (result != null) {
|
PageEntity pageEntity = result.getPageEntity();
|
if (pageEntity != null) {
|
count = (int) pageEntity.getTotalCount();
|
}
|
|
List<JDGoods> goodsList = result.getGoodsList();
|
if (goodsList != null && goodsList.size() > 0) {
|
BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();
|
BigDecimal shareRate = hongBaoManageService.getShareRate();
|
for (JDGoods goods : goodsList) {
|
BrandGoodsCahe brandGoods = new BrandGoodsCahe();
|
brandGoods.setBrandId(brandInfo.getId());
|
brandGoods.setWeight((int) (Math.random() * 1000));
|
brandGoods.setGoods(GoodsDetailVOFactory.convertJDGoods(goods, fanLiRate, shareRate));
|
brandGoods.setCreateTime(new Date());
|
brandGoods.setUpdateTime(new Date());
|
brandGoodsCaheDao.save(brandGoods);
|
}
|
}
|
}
|
return count;
|
}
|
|
|
/**
|
* 拼多多商品
|
* @param brandInfo
|
* @return
|
*/
|
private int addBrandGoodsPDD(BrandInfo brandInfo) {
|
PDDSearchFilter pddfilter = new PDDSearchFilter();
|
pddfilter.setKw(brandInfo.getName());
|
pddfilter.setPage(1);
|
pddfilter.setPageSize(50);
|
pddfilter.setSortType(6);
|
|
int count = 0;
|
PDDGoodsResult result = PinDuoDuoApiUtil.searchGoods(pddfilter);
|
if (result != null) {
|
count = result.getTotalCount();
|
List<PDDGoodsDetail> goodsList = result.getGoodsList();
|
if (goodsList != null && goodsList.size() > 0) {
|
BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();
|
BigDecimal shareRate = hongBaoManageService.getShareRate();
|
for (PDDGoodsDetail goods : goodsList) {
|
BrandGoodsCahe brandGoods = new BrandGoodsCahe();
|
brandGoods.setBrandId(brandInfo.getId());
|
brandGoods.setWeight((int) (Math.random() * 1000));
|
brandGoods.setGoods(GoodsDetailVOFactory.convertPDDGoods(goods, fanLiRate, shareRate));
|
brandGoods.setCreateTime(new Date());
|
brandGoods.setUpdateTime(new Date());
|
brandGoodsCaheDao.save(brandGoods);
|
}
|
}
|
}
|
return count;
|
}
|
}
|
