尚品汇-ES（三十一）

目录：

（1）封装搜索相关实体对象

（2）搜索接口封装

（3）在service-list-client模块添加远程接口

（1）封装搜索相关实体对象

搜索参数实体：SearchParam

搜索参数实体：SearchParam
package com.atguigu.gmall.model.list;
/*** 商品搜索参数* 参数说明：*      1，商标品牌：trademark=2:华为  *              2：为品牌id，搜索字段*              华为：品牌名称，页面回显属性*      2，平台属性：props=23:4G:运行内存*              23：平台属性id，搜索字段*              运行内存：平台属性名称，页面回显属性*              4G：平台属性值，搜索字段与页面回显属性* </p>**/
@Data
public class SearchParam {// ?category3Id=61&trademark=2:华为&props=23:4G:运行内存&order=1:desc//category3Id=61private Long category1Id;;//三级分类idprivate Long category2Id;private Long category3Id;//trademark=2:华为private String trademark;//品牌idprivate String keyword;//检索的关键字// order=1:asc  排序规则   0:ascprivate String order = "";// 1：综合排序/热点  2：价格//props=23:4G:运行内存private String[] props;//页面提交的数组private Integer pageNo = 1;//分页信息private Integer pageSize = 12;
}

 搜索结果集实体：SearchResponseVo

搜索结果集实体：SearchResponseVopackage com.atguigu.gmall.model.list;@Data
public class SearchResponseVo implements Serializable {//品牌 此时vo对象中的id字段保留（不用写） name就是“品牌” value: [{id:100,name:华为,logo:xxx},{id:101,name:小米,log:yyy}]private List<SearchResponseTmVo> trademarkList;//所有商品的顶头显示的筛选属性private List<SearchResponseAttrVo> attrsList = new ArrayList<>();//检索出来的商品信息private List<Goods> goodsList = new ArrayList<>();private Long total;//总记录数private Integer pageSize;//每页显示的内容private Integer pageNo;//当前页面private Long totalPages;}

结果集品牌实体：SearchResponseTmVo

package com.atguigu.gmall.model.list;@Data
public class SearchResponseTmVo implements Serializable {//当前属性值的所有值private Long tmId;//属性名称private String tmName;//网络制式，分类//图片urlprivate String tmLogoUrl;
}

结果集平台属性实体：SearchResponseAttrVo

package com.atguigu.gmall.model.list;@Data
public class SearchResponseAttrVo implements Serializable {private Long attrId;//1//当前属性值的所有值private List<String> attrValueList = new ArrayList<>();//属性名称private String attrName;//网络制式，分类
}

（2）搜索接口封装

SearchService接口

/*** 搜索列表* @param searchParam* @return* @throws IOException*/
SearchResponseVo search(SearchParam searchParam) throws IOException;

接口实现类

api参考文档：

Java REST Client [7.8] | Elastic

Java REST Client [7.8] | Elastic

@Autowired
private RestHighLevelClient restHighLevelClient;
@Override
public SearchResponseVo search(SearchParam searchParam) throws IOException {// 构建dsl语句SearchRequest searchRequest = this.buildQueryDsl(searchParam);SearchResponse response = this.restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);System.out.println(response);SearchResponseVo responseVO = this.parseSearchResult(response);responseVO.setPageSize(searchParam.getPageSize());responseVO.setPageNo(searchParam.getPageNo());long totalPages = (responseVO.getTotal()+searchParam.getPageSize()-1)/searchParam.getPageSize();responseVO.setTotalPages(totalPages);return responseVO;
}//封装查询条件
// 制作dsl 语句  
private SearchRequest buildQueryDsl(SearchParam searchParam) {// 构建查询器SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();// 构建多条件对象boolQueryBuilderBoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();// 判断查询条件是否为空 关键字if (!StringUtils.isEmpty(searchParam.getKeyword())){// 小米手机  小米and手机// MatchQueryBuilder matchQueryBuilder = new MatchQueryBuilder("title",searchParam.getKeyword()).operator(Operator.AND);MatchQueryBuilder title = QueryBuilders.matchQuery("title", searchParam.getKeyword()).operator(Operator.AND);boolQueryBuilder.must(title);}// 构建品牌查询String trademark = searchParam.getTrademark();if (!StringUtils.isEmpty(trademark)){// trademark=2:华为String[] split = StringUtils.split(trademark, ":");if (split != null && split.length == 2) {//构建过滤品牌TermQueryBuilder tmId=QueryBuilders.termQuery("tmId", split[0]);// 根据品牌Id过滤  添加到多条件对象boolQueryBuilder.filter(tmId);}}// 构建分类过滤 用户在点击的时候，只能点击一个值，所以此处使用termif(null!=searchParam.getCategory1Id()){boolQueryBuilder.filter(QueryBuilders.termQuery("category1Id",searchParam.getCategory1Id()));}// 构建分类过滤if(null!=searchParam.getCategory2Id()){boolQueryBuilder.filter(QueryBuilders.termQuery("category2Id",searchParam.getCategory2Id()));}// 构建分类过滤if(null!=searchParam.getCategory3Id()){boolQueryBuilder.filter(QueryBuilders.termQuery("category3Id",searchParam.getCategory3Id()));}// 构建平台属性查询// 23:4G:运行内存String[] props = searchParam.getProps();if (props!=null && props.length>0){// 循环遍历for (String prop : props) {// 23:4G:运行内存  平台属性id：平台属性值名称：平台属性名String[] split = StringUtils.split(prop, ":");if (split!=null && split.length==3){// 构建嵌套查询  创建多条件对象BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();// 嵌套查询子查询BoolQueryBuilder subBoolQuery = QueryBuilders.boolQuery();// 构建子查==询中的过滤条件subBoolQuery.must(QueryBuilders.termQuery("attrs.attrId",split[0]));subBoolQuery.must(QueryBuilders.termQuery("attrs.attrValue",split[1]));// ScoreMode.None ？boolQuery.must(QueryBuilders.nestedQuery("attrs",subBoolQuery, ScoreMode.None));// 添加到整个过滤对象中，外层对象boolQueryBuilder.filter(boolQuery);}}}// 执行查询方法searchSourceBuilder.query(boolQueryBuilder);// 构建分页int from = (searchParam.getPageNo()-1)*searchParam.getPageSize();searchSourceBuilder.from(from);searchSourceBuilder.size(searchParam.getPageSize());// 排序  1：hotScore 2：price   1：综合排序/热度  2：价格//1：ascString order = searchParam.getOrder();if (!StringUtils.isEmpty(order)){// 判断排序规则String[] split = StringUtils.split(order, ":");if (split!=null && split.length==2){// 排序的字段String field = null;// 数组中的第一个参数switch (split[0]){case "1":field="hotScore";break;case "2":field="price";break;}searchSourceBuilder.sort(field,"asc".equals(split[1])? SortOrder.ASC:SortOrder.DESC);}else {// 没有传值的时候给默认值searchSourceBuilder.sort("hotScore",SortOrder.DESC);}}// 构建高亮HighlightBuilder highlightBuilder = new HighlightBuilder();highlightBuilder.field("title");highlightBuilder.postTags("</span>");highlightBuilder.preTags("<span style=color:red>");searchSourceBuilder.highlighter(highlightBuilder);//  设置品牌聚合TermsAggregationBuilder termsAggregationBuilder =        AggregationBuilders.terms("tmIdAgg").field("tmId").subAggregation(AggregationBuilders.terms("tmNameAgg").field("tmName")).subAggregation(AggregationBuilders.terms("tmLogoUrlAgg").field("tmLogoUrl"));searchSourceBuilder.aggregation(termsAggregationBuilder);//  设置平台属性聚合searchSourceBuilder.aggregation(AggregationBuilders.nested("attrAgg", "attrs").subAggregation(AggregationBuilders.terms("attrIdAgg").field("attrs.attrId").subAggregation(AggregationBuilders.terms("attrNameAgg").field("attrs.attrName")).subAggregation(AggregationBuilders.terms("attrValueAgg").field("attrs.attrValue"))));// 结果集过滤searchSourceBuilder.fetchSource(new String[]{"id","defaultImg","title","price"},null);SearchRequest searchRequest = new SearchRequest("goods");//searchRequest.types("_doc");//将构建对象添加到请求中searchRequest.source(searchSourceBuilder);System.out.println("dsl:"+searchSourceBuilder.toString());return searchRequest;
}// 制作返回结果集
private SearchResponseVo parseSearchResult(SearchResponse response) {SearchHits hits = response.getHits();//声明对象SearchResponseVo searchResponseVo = new SearchResponseVo();//获取品牌的集合Map<String, Aggregation> aggregationMap = response.getAggregations().asMap();//ParsedLongTerms ?ParsedLongTerms tmIdAgg = (ParsedLongTerms) aggregationMap.get("tmIdAgg");List<SearchResponseTmVo> trademarkList = tmIdAgg.getBuckets().stream().map(bucket -> {SearchResponseTmVo trademark = new SearchResponseTmVo();//获取品牌Idtrademark.setTmId((Long.parseLong(((Terms.Bucket) bucket).getKeyAsString())));//trademark.setTmId(Long.parseLong(bucket.getKeyAsString()));//获取品牌名称Map<String, Aggregation> tmIdSubMap = ((Terms.Bucket) bucket).getAggregations().asMap();ParsedStringTerms tmNameAgg = (ParsedStringTerms) tmIdSubMap.get("tmNameAgg");String tmName = tmNameAgg.getBuckets().get(0).getKeyAsString();trademark.setTmName(tmName);
ParsedStringTerms tmLogoUrlAgg = (ParsedStringTerms) tmIdSubMap.get("tmLogoUrlAgg");
String tmLogoUrl = tmLogoUrlAgg.getBuckets().get(0).getKeyAsString();
trademark.setTmLogoUrl(tmLogoUrl);return trademark;}).collect(Collectors.toList());searchResponseVo.setTrademarkList(trademarkList);//赋值商品列表SearchHit[] subHits = hits.getHits();List<Goods> goodsList = new ArrayList<>();if (subHits!=null && subHits.length>0){//循环遍历for (SearchHit subHit : subHits) {// 将subHit 转换为对象Goods goods = JSONObject.parseObject(subHit.getSourceAsString(), Goods.class);//获取高亮if (subHit.getHighlightFields().get("title")!=null){Text title = subHit.getHighlightFields().get("title").getFragments()[0];goods.setTitle(title.toString());}goodsList.add(goods);}}searchResponseVo.setGoodsList(goodsList);//获取平台属性数据ParsedNested attrAgg = (ParsedNested) aggregationMap.get("attrAgg");ParsedLongTerms attrIdAgg = attrAgg.getAggregations().get("attrIdAgg");List<? extends Terms.Bucket> buckets = attrIdAgg.getBuckets();if (!CollectionUtils.isEmpty(buckets)){List<SearchResponseAttrVo> searchResponseAttrVOS = buckets.stream().map(bucket -> {//声明平台属性对象SearchResponseAttrVo responseAttrVO = new SearchResponseAttrVo();//设置平台属性值IdresponseAttrVO.setAttrId(((Terms.Bucket) bucket).getKeyAsNumber().longValue());ParsedStringTerms attrNameAgg = bucket.getAggregations().get("attrNameAgg");List<? extends Terms.Bucket> nameBuckets = attrNameAgg.getBuckets();responseAttrVO.setAttrName(nameBuckets.get(0).getKeyAsString());//设置规格参数列表ParsedStringTerms attrValueAgg = ((Terms.Bucket) bucket).getAggregations().get("attrValueAgg");List<? extends Terms.Bucket> valueBuckets = attrValueAgg.getBuckets();List<String> values = valueBuckets.stream().map(Terms.Bucket::getKeyAsString).collect(Collectors.toList());responseAttrVO.setAttrValueList(values);return responseAttrVO;}).collect(Collectors.toList());searchResponseVo.setAttrsList(searchResponseAttrVOS);}// 获取总记录数searchResponseVo.setTotal(hits.getTotalHits().value);return searchResponseVo;
}

 

 

控制器ListApiController

/*** 搜索商品* @param searchParam* @return* @throws IOException*/
@PostMapping
public Result list(@RequestBody SearchParam searchParam) throws IOException {SearchResponseVo response = searchService.search(searchParam);return Result.ok(response);
}

在service-list 模块中配置logstash

首先在service模块中添加依赖

<dependency>

            <groupId>net.logstash.logback</groupId>

            <artifactId>logstash-logback-encoder</artifactId>

            <version>5.1</version>

        </dependency>

其次，将日志配置文件放入到resources目录下！

（3）在service-list-client模块添加远程接口

package com.atguigu.gmall.list.client;
@FeignClient(value = "service-list", fallback = ListDegradeFeignClient.class)
public interface ListFeignClient {/*** 搜索商品* @param listParam* @return*/@PostMapping("/api/list")Result list(@RequestBody SearchParam listParam);/*** 上架商品* @param skuId* @return*/@GetMapping("/api/list/inner/upperGoods/{skuId}")Result upperGoods(@PathVariable("skuId") Long skuId);/*** 下架商品* @param skuId* @return*/@GetMapping("/api/list/inner/lowerGoods/{skuId}")Result lowerGoods(@PathVariable("skuId") Long skuId);}

package com.atguigu.gmall.list.client.impl;@Component
public class ListDegradeFeignClient implements ListFeignClient {@Overridepublic Result list(SearchParam searchParam) {return Result.fail();}@Overridepublic Result upperGoods(Long skuId) {return null;}@Overridepublic Result lowerGoods(Long skuId) {return null;}
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/398200.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

第七节 流编辑器sed(stream editor)(7.1)

第七节 流编辑器sed(stream editor)(7.1)

一,sed简介 sed是一种流编辑器,处理时,把当前处理的行存储在临时缓冲区中,称为模式空间,接着用sed命令处理缓冲区中的内容,处理完成后,把缓冲区的内容送往屏幕,接着处理下一行,这样不断重复,直到文件末尾,文件内容并没有改变 二,sed的语法 2,1,基本语法 sed options ... […
阅读更多...
AI学习记录 - gpt如何进行token化，理论知识，以GPT2为举例

AI学习记录 - gpt如何进行token化，理论知识，以GPT2为举例

AI学习记录已经发了十几篇&#xff0c;大佬们可以看看&#xff0c;如果有帮助动动小手点赞 token入门版&#xff0c;有空会更新具体代码操作 GPT4当中&#xff0c;我们提问问题是按照token进行扣费的&#xff0c;那到底什么是token&#xff1f; 在不同的语言模型当中&#x…
阅读更多...
gradio之进度条

gradio之进度条

输出控件显示进度&#xff0c;进度结束显示控件结果 import gradio as gr import timedef slowly_reverse(word, progressgr.Progress()):progress(0, desc"Starting")time.sleep(1)progress(0.05)new_string ""for letter in progress.tqdm(word, desc&…
阅读更多...
C++ 特性之vector详解 + 联合opencv使用

C++ 特性之vector详解 + 联合opencv使用

C 特性之vector详解 联合opencv使用 在C中&#xff0c;遍历vector并删除元素需要小心处理迭代器失效的问题。通常推荐的方法是使用迭代器进行遍历&#xff0c;并在需要删除元素时使用erase函数。这里给出一个示例代码&#xff0c;演示如何安全地遍历vector并删除特定条件的元…
阅读更多...
计算机毕业设计 家电销售展示平台 Java+SpringBoot+Vue 前后端分离 文档报告 代码讲解 安装调试

计算机毕业设计 家电销售展示平台 Java+SpringBoot+Vue 前后端分离 文档报告 代码讲解 安装调试

&#x1f34a;作者&#xff1a;计算机编程-吉哥 &#x1f34a;简介&#xff1a;专业从事JavaWeb程序开发&#xff0c;微信小程序开发&#xff0c;定制化项目、 源码、代码讲解、文档撰写、ppt制作。做自己喜欢的事&#xff0c;生活就是快乐的。 &#x1f34a;心愿&#xff1a;点…
阅读更多...
智能识别，2024年SD卡数据恢复软件的智能进化

智能识别，2024年SD卡数据恢复软件的智能进化

除了手机之外现在有不少的设备还是依靠SD卡来存储数据&#xff0c;比如相机、摄像头、无人机等。有的时候会因为一些意外的情况导致数据丢失&#xff0c;那是真的丢失了吗&#xff1f;大部分情况还是可以依靠sd卡数据恢复工具来找回这些“消失”的数据哦。 1.福昕数据恢复 链…
阅读更多...
python正则表达式以及re模块的运用完成文本处理（搜索、匹配、替换等文本操作）

python正则表达式以及re模块的运用完成文本处理（搜索、匹配、替换等文本操作）

1.正则表达式 正则表达式是一种强大的文本处理工具&#xff0c;用于搜索、匹配、替换等文本操作。 2.通过re模块实现正则表达式的操作 Python中的re模块是Python的标准库之一&#xff0c;它提供了对正则表达式的支持。正则表达式是一种强大的文本处理工具&#xff0c;用于搜…
阅读更多...
AI赋能招聘：效率与公平的双重提升

AI赋能招聘：效率与公平的双重提升

一、引言&#xff1a;AI赋能招聘新纪元 在21世纪的数字化浪潮中&#xff0c;人工智能&#xff08;AI&#xff09;技术以前所未有的速度渗透到社会经济的各个领域&#xff0c;深刻地改变着我们的生活方式与工作模式。人力资源管理&#xff0c;作为企业战略的重要组成部分&#…
阅读更多...
[C++][opencv]基于opencv实现photoshop算法色相和饱和度调整

[C++][opencv]基于opencv实现photoshop算法色相和饱和度调整

【测试环境】 vs2019 opencv4.8.0 【效果演示】 【核心实现代码】 HSL.hpp #ifndef OPENCV2_PS_HSL_HPP_ #define OPENCV2_PS_HSL_HPP_#include "opencv2/core.hpp" using namespace cv;namespace cv {enum HSL_COLOR {HSL_ALL,HSL_RED,HSL_YELLOW,HSL_GREEN,HS…
阅读更多...
在IIS上部署ASP.NET Core Web API和Blazor Wasm详细教程

在IIS上部署ASP.NET Core Web API和Blazor Wasm详细教程

前言 前段时间我们完成了七天.NET 8 操作 SQLite 入门到实战的开发系列教程&#xff0c;有不少同学留言问如何将项目发布部署到IIS上面运行。本篇文章我们就一起来讲讲在IIS上部署ASP.NET Core Web API和Blazor Wasm。 前提条件 安装.NET Core SDK https://dotnet.microsoft…
阅读更多...
【学习笔记】Day 10

【学习笔记】Day 10

一、进度概述 1、《地震勘探原理》第三章 二、详情 3.1 野外工作概述 主要介绍地上与海上两种情况下的测量方法&#xff0c;这里不做详解&#xff0c;需要就看书。 其中简况分为&#xff1a;试验工作&#xff0c;生产工作过程&#xff0c;干扰波调查&#xff0c;干扰…
阅读更多...
allegro PCB设计心得笔记(四) -- 显示坐标原点和更改默认产品选项

allegro PCB设计心得笔记(四) -- 显示坐标原点和更改默认产品选项

一、修改坐标原点 Allegro PCB设计过程中&#xff0c;有时需要修改坐标原点&#xff0c;但是PCB文件不显示坐标原点&#xff0c;无法确认已修改的坐标原点是否已经修改好。 显示PCB原点的设置方法如下&#xff1a; Setup -> Design Parameter Editor&#xff0c;如下图所示&…
阅读更多...
[C++][opencv]基于opencv实现photoshop算法图像剪切

[C++][opencv]基于opencv实现photoshop算法图像剪切

【测试环境】 vs2019 opencv4.8.0 【效果演示】 【核心实现代码】 //图像剪切 //参数&#xff1a;src为源图像&#xff0c; dst为结果图像, rect为剪切区域 //返回值&#xff1a;返回0表示成功&#xff0c;否则返回错误代码 int imageCrop(InputArray src, OutputArray dst,…
阅读更多...
8.3.数据库基础技术-关系代数

8.3.数据库基础技术-关系代数

并&#xff1a;结果是两张表中所有记录数合并&#xff0c;相同记录只显示一次。交&#xff1a;结果是两张表中相同的记录。差&#xff1a;S1-S2,结果是S1表中有而S2表中没有的那些记录。 笛卡尔积&#xff1a;S1XS2,产生的结果包括S1和S2的所有属性列&#xff0c;并且S1中每条记…
阅读更多...
大数据知识点

大数据知识点

VMWare 设置网段 虚拟机设置 JDK部署 云平台 创建VPC 找到阿里云控制台里的VPC&#xff0c;点击专有网络 安全组 搁置…有需要再使用&#xff0c;因为每月要花200左右 大数据 数据导论
阅读更多...
merfish数据进行可视化

merfish数据进行可视化

参考博客 https://scanpy.readthedocs.io/en/stable/tutorials/spatial/basic-analysis.html example import scanpy as sc import pandas as pd import matplotlib.pyplot as plt import seaborn as snscoordinates pd.read_excel("./data/pnas.1912459116.sd15.xlsx…
阅读更多...
分布式性能监控之SkyWalking

分布式性能监控之SkyWalking

Apache SkyWalking 是一款开源的分布式应用性能监控和管理工具&#xff0c;旨在为微服务、云原生和容器化环境提供全面的性能分析和监控解决方案。它在分布式系统中起着关键作用&#xff0c;帮助开发者和运维人员实时监控应用程序的性能、定位问题&#xff0c;并优化系统。以下…
阅读更多...
计算机的错误计算（六十）

计算机的错误计算（六十）

摘要 用另一种方法计算计算机的错误计算&#xff08;五十五&#xff09;中案例&#xff1a;先使自变量与 取余&#xff0c;再计算取余后的余弦值&#xff0c;这时&#xff0c;得到了不同的输出。因此&#xff0c;即使不清楚正确结果&#xff0c;Python 与 Visual Studio 也各自…
阅读更多...
加强混合工作时代的组织网络安全态势

加强混合工作时代的组织网络安全态势

随着组织转向采用和实施混合和远程工作模式&#xff0c;网络安全的重要性从未如此重要。虽然工作场所的这种演变提供了灵活性并有望提高生产力&#xff0c;但它也带来了组织无法忽视的无数网络安全挑战。多样化工作环境的整合需要强大的安全措施、创新的保护策略和警惕的文化&a…
阅读更多...
Python | Leetcode Python题解之第332题重新安排行程

Python | Leetcode Python题解之第332题重新安排行程

题目&#xff1a; 题解&#xff1a; class Solution:def findItinerary(self, tickets: List[List[str]]) -> List[str]:def dfs(curr: str):while vec[curr]:tmp heapq.heappop(vec[curr])dfs(tmp)stack.append(curr)vec collections.defaultdict(list)for depart, arri…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023