绿满筐商城java服务
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
peng
6 天以前 d4d9ea89dd109cb975eaa3412a15c5ff6e8d11dd 
 framework/src/main/java/cn/lili/modules/search/serviceimpl/EsGoodsSearchServiceImpl.java


@@ -3,12 +3,15 @@


import cn.hutool.core.convert.Convert;


import cn.hutool.core.text.CharSequenceUtil;


import cn.hutool.core.util.ArrayUtil;


import cn.lili.base.Result;


import cn.lili.cache.Cache;


import cn.lili.cache.CachePrefix;


import cn.lili.common.exception.ServiceException;


import cn.lili.common.security.context.UserContext;


import cn.lili.common.vo.PageVO;


import cn.lili.modules.goods.entity.enums.GoodsAuthEnum;


import cn.lili.modules.goods.entity.enums.GoodsStatusEnum;


import cn.lili.modules.lmk.domain.query.VideoGoodsEsQuery;


import cn.lili.modules.search.entity.dos.EsGoodsIndex;


import cn.lili.modules.search.entity.dos.EsGoodsRelatedInfo;


import cn.lili.modules.search.entity.dto.EsGoodsSearchDTO;


@@ -29,6 +32,7 @@


import org.elasticsearch.index.query.functionscore.FieldValueFactorFunctionBuilder;


import org.elasticsearch.index.query.functionscore.FunctionScoreQueryBuilder;


import org.elasticsearch.index.query.functionscore.ScoreFunctionBuilders;


import org.elasticsearch.index.search.MultiMatchQuery;


import org.elasticsearch.search.aggregations.*;


import org.elasticsearch.search.aggregations.bucket.nested.ParsedNested;


import org.elasticsearch.search.aggregations.bucket.terms.ParsedStringTerms;


@@ -38,11 +42,16 @@


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.data.domain.PageRequest;


import org.springframework.data.domain.Pageable;


import org.springframework.data.domain.Sort;


import org.springframework.data.elasticsearch.core.*;


import org.springframework.data.elasticsearch.core.query.NativeSearchQuery;


import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;


import org.springframework.stereotype.Service;




import java.text.SimpleDateFormat;


import java.time.LocalDate;


import java.time.ZoneId;


import java.time.format.DateTimeFormatter;


import java.util.*;


import java.util.stream.Collectors;




@@ -88,7 +97,9 @@


            cache.incrementScore(CachePrefix.HOT_WORD.getPrefix(), searchDTO.getKeyword());


        }


        NativeSearchQueryBuilder searchQueryBuilder = createSearchQueryBuilder(searchDTO, pageVo);


//        searchQueryBuilder.withCollapseField("goodsId.keyword");


        if (Objects.nonNull(searchDTO.getCanFilter()) && searchDTO.getCanFilter()) {


            searchQueryBuilder.withCollapseField("goodsId.keyword");


        }


        NativeSearchQuery searchQuery = searchQueryBuilder.build();


        searchQuery.setTrackTotalHits(true);


        log.debug("searchGoods DSL:{}", searchQuery.getQuery());


@@ -174,6 +185,38 @@


    @Override


    public EsGoodsIndex getEsGoodsById(String id) {


        return this.restTemplate.get(id, EsGoodsIndex.class);


    }




    @Override


    public Result videoGoodsEsPage(VideoGoodsEsQuery q) {


        // 判断商品索引是否存在


        if (!restTemplate.indexOps(EsGoodsIndex.class).exists()) {


            return Result.ok();


        }


        // 根据销量倒序排列


        Pageable pageable = PageRequest.of(q.getPageNumber(), q.getPageSize(), Sort.by("buyCount").descending());




        NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();


        queryBuilder.withPageable(pageable);




        BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();




        // 关键词匹配商品名称、商品编号


        if (!StringUtils.isEmpty(q.getKeyword())) {


            boolQuery.must(QueryBuilders.multiMatchQuery(q.getKeyword(), "goodsName", "sn"));


        }




        if (q.getSearchFromSelfStore()) {


            // 如果只查自家店铺商品


            boolQuery.must(QueryBuilders.termQuery("storeId", UserContext.getCurrentUser().getStoreId()));


        }




        queryBuilder.withQuery(boolQuery);




        NativeSearchQuery query = queryBuilder.build();


        SearchHits<EsGoodsIndex> searchHits = restTemplate.search(query, EsGoodsIndex.class);


        List<EsGoodsIndex> data = searchHits.stream().map(hit -> hit.getContent()).collect(Collectors.toList());


        return Result.ok().data(data).total(searchHits.getTotalHits());


    }




    /**


@@ -518,6 +561,23 @@


        if (CharSequenceUtil.isNotEmpty(searchDTO.getPromotionsId()) && CharSequenceUtil.isNotEmpty(searchDTO.getPromotionType())) {


            filterBuilder.must(QueryBuilders.wildcardQuery("promotionMapJson", "*" + searchDTO.getPromotionType() + "-" + searchDTO.getPromotionsId() + "*"));


        }




        if (Objects.nonNull(searchDTO.getNeedFilterPre()) && searchDTO.getNeedFilterPre()) {


            // 转换为当天 00:00:00 的时间戳（毫秒）


            long time = LocalDate.now().atStartOfDay(ZoneId.systemDefault())


                    .toInstant()


                    .toEpochMilli();


            // 条件2：预售结束时间 >= 当前时间 OR 结束时间为空


            filterBuilder.must(QueryBuilders.boolQuery()


                    .should(QueryBuilders.rangeQuery("preSaleEndDate").gte(time))


                    .should(QueryBuilders.boolQuery()


                            .mustNot(QueryBuilders.existsQuery("preSaleEndDate"))));


            // 条件1：预售开始时间 <= 当前时间 OR 开始时间为空


            filterBuilder.must(QueryBuilders.boolQuery()


                    .should(QueryBuilders.rangeQuery("preSaleBeginDate").lte(time))


                    .should(QueryBuilders.boolQuery()


                            .mustNot(QueryBuilders.existsQuery("preSaleBeginDate"))));


        }


        //价格区间判定


        if (CharSequenceUtil.isNotEmpty(searchDTO.getPrice())) {


            String[] prices = searchDTO.getPrice().split("_");