基于springcould所写的电商项目，使用了rabbitmq，es等等技术

package com.youke.service; import com.fasterxml.jackson.core.type.TypeReference; import com.youke.clients.BrandClient; import com.youke.clients.CategoryClient; import com.youke.clients.GoodsClient; import com.youke.clients.SpecificationClient; import com.youke.enums.ExceptionEnum; import com.youke.exceptions.YkException; import com.youke.pojo.*; import com.youke.repositorys.GoodsRepository; import com.youke.utils.JsonUtils; import com.youke.vo.SearchRequest; import com.youke.vo.SearchResult; import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.math.NumberUtils; import org.elasticsearch.index.query.BoolQueryBuilder; import org.elasticsearch.index.query.MatchQueryBuilder; import org.elasticsearch.index.query.QueryBuilder; import org.elasticsearch.index.query.QueryBuilders; import org.elasticsearch.search.aggregations.Aggregation; import org.elasticsearch.search.aggregations.AggregationBuilders; import org.elasticsearch.search.aggregations.Aggregations; import org.elasticsearch.search.aggregations.bucket.MultiBucketsAggregation; import org.elasticsearch.search.aggregations.bucket.terms.Terms; import org.elasticsearch.search.sort.SortBuilders; import org.elasticsearch.search.sort.SortOrder; import org.springframework.data.domain.PageRequest; import org.springframework.data.elasticsearch.core.*; import org.springframework.data.elasticsearch.core.query.FetchSourceFilter; import org.springframework.data.elasticsearch.core.query.NativeSearchQuery; import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder; import org.springframework.stereotype.Service; import javax.annotation.Resource; import javax.xml.crypto.Data; import java.time.ZoneId; import java.util.*; import java.util.stream.Collectors; @Service public class SearchService { @Resource private BrandClient brandClient; @Resource private CategoryClient categoryClient; @Resource private GoodsClient goodsClient; @Resource private SpecificationClient specificationClient; @Resource private ElasticsearchRestTemplate elasticsearchRestTemplate; @Resource private GoodsRepository goodsRepository; /** * 将数据库商品数据，转换为索引库数据 * * @param spu * @return */ public Goods buildGoods(Spu spu) { //1.处理all，标题+分类+品牌 Brand brand = brandClient.queryBrandByid(spu.getBrandId()); List<Category> categories = categoryClient.queryCategoryByIds(Arrays.asList(spu.getCid1(), spu.getCid2(), spu.getCid3())); String cnames = categories.stream().map(Category::getName).collect(Collectors.joining(" ")); String all=spu.getTitle()+" "+brand.getName()+" "+cnames; //2.处理Sku List<Map<String,Object>> skus=new ArrayList<>(); List<Sku> skuList = goodsClient.querySkus(spu.getId()); Set<Long> price = new HashSet<>(); skuList.forEach(sku ->{ //转换剔除不需要的属性 Map<String,Object> map = new HashMap<>(); map.put("id",sku.getId()); map.put("title",sku.getTitle()); map.put("price",sku.getPrice()); map.put("images", StringUtils.substringBefore(sku.getImages(),",")); skus.add(map); //处理价格 price.add(sku.getPrice()); }); //转换成json String skuStr= JsonUtils.toString(skus); //3.处理Spec Map<String,Object> specs=new HashMap<>(); //3.1拆线呢对应分类允许被搜索的数据 List<SpecParam> specParams = specificationClient.querySpecParamByList(null, spu.getCid3(), true); //3.2查询商品详情获取通用规格参数和特有规格参数 SpuDetail spuDetail = goodsClient.querySpuDetail(spu.getId()); //3.3转换Json Map<Long, String> genericSpecMap = JsonUtils.toMap(spuDetail.getGenericSpec(),Long.class,String.class); Map<Long, List<String>> specialSpecMap = JsonUtils.nativeRead(spuDetail.getSpecialSpec(), new TypeReference<Map<Long, List<String>>>() {}); //3.4查找出该商品所有可搜索的通过和特有的规格参数（key=value） specParams.forEach(param -> { String key=param.getName(); Object value=""; //1.判断是否是通用规格参数 if (param.getGeneric()){ value=genericSpecMap.get(param.getId()); if (param.getNumeric()){ //处理成段 value=chooseSegment(value.toString(),param); } }else { value=specialSpecMap.get(param.getId()); } specs.put(key,value); }); Goods goods = new Goods(); goods.setId(spu.getId()); goods.setAll(all); goods.setSubTitle(spu.getSubTitle()); goods.setBrandId(spu.getBrandId()); goods.setCid1(spu.getCid1()); goods.setCid2(spu.getCid2()); goods.setCid3(spu.getCid3()); goods.setCreateTime(Date.from(spu.getCreateTime().atZone(ZoneId.systemDefault()).toInstant())); goods.setPrice(price); goods.setSkus(skuStr); goods.setSpecs(specs); return goods; } /** * 处理分段操作 * @param value * @param p * @return */ private String chooseSegment(String value,SpecParam p){ double val = NumberUtils.toDouble(value); String result = "其它"; //保存数值段 for (String segment : p.getSegments().split(",")){ String[] segs = segment.split("-"); //获取数值范围 double begin = NumberUtils.toDouble(segs[0]); double end = Double.MAX_VALUE; if (segs.length == 2){ end = NumberUtils.toDouble(segs[1]); } // 判断是否在范围内 if (val >= begin && val < end){ if (segs.length == 1){ result = segs[0] + p.getUnit() + "以上"; }else if (begin == 0){ result = segs[1] + p.getUnit() + "以下"; }else { result = segment + p.getUnit(); } break; } } return result; } /** * 页面搜索 * @param request * @return */ public SearchResult querySearchPage(SearchRequest request) { //0.不允许全部查询 String key = request.getKey(); if (StringUtils.isEmpty(key)){ throw new YkException(ExceptionEnum.SEARCH_GOODS_QUERY_ALL_ERROR); } //1.查询构造器 NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder(); //过滤不需要的数据 queryBuilder.withSourceFilter(new FetchSourceFilter(new String[]{"id","subTitle","skus"},null)); //2.添加基本分词查询 QueryBuilder allMatchQuery = bulidBasicQuery(request); queryBuilder.withQuery(allMatchQuery); //3.处理分页 int page=request.getPage()-1; int size=request.getSize(); queryBuilder.withPageable(PageRequest.of(page,size)); //4.排序 String sortBy=request.getSortBy(); Boolean desc=request.getDescending(); if (StringUtils.isNotBlank(sortBy)){ //如果不为空,则进行排序 queryBuilder.withSort(SortBuilders.fieldSort(sortBy).order(desc ? SortOrder.DESC : SortOrder.ASC)); } //.聚合分类和品牌 String categoryAggName ="category_agg"; queryBuilder.addAggregation(AggregationBuilders.terms(categoryAggName).field("cid3")); String brand_aggAggName ="brand_agg"; queryBuilder.addAggregation(AggregationBuilders.terms(brand_aggAggName).field("brandId")); //.查询数据 SearchHits<Goods> searchHits = elasticsearchRestTemplate.search(queryBuilder.build(