ES练习项目-酒店搜索

news2025/4/5 14:28:31

目录

  • 1 需求分析
  • 2 酒店搜索和分页
    • 2.1 请求和响应分析
    • 2.2 定义实体类，接收请求参数的JSON对象
    • 2.3 编写controller，接收页面的请求
    • 2.4 编写业务实现，利用RestHighLevelClient实现搜索、分页
  • 3. 酒店结果过滤
    • 3.1 请求和响应分析
    • 3.2 修改请求参数的对象RequestParams
    • 3.2 修改业务逻辑，在搜索条件之外，添加一些过滤条件
  • 4.实现 我周边的酒店
    • 4.1 请求和响应分析
    • 4.2 修改RequestParams参数，接收location字段
    • 4.3 修改search方法，完成距离排序
    • 4.4 排序距离显示
  • 5 酒店竞价排名
    • 5.1 请求和响应分析
    • 5.2 修改Hoteldoc实体类 以及 es添加doc属性
    • 5.3 修改业务层代码
  • 6 实现品牌城市星级价格的聚合
    • 6.1 什么意思
    • 6.2 请求和响应分析
    • 6.3 Controller层实现
    • 6.4 业务层实现

代码请见： https://gitee.com/lhwebsite/es_practice_hotels

1 需求分析

实现四部分功能：

  • 酒店搜索和分页
  • 酒店结果过滤
  • 我周边的酒店
  • 酒店竞价排名
  • 实现品牌城市星级价格的聚合
    在这里插入图片描述

2 酒店搜索和分页

2.1 请求和响应分析

在这里插入图片描述
在这里插入图片描述
由上我们可知：

  • 请求方式：POST
  • 请求路径：/hotel/list
  • 请求参数：JSON对象，包含4个字段：
    • key：搜索关键字
    • page：页码
    • size：每页大小
    • sortBy：排序，目前暂不实现
      再分析下响应信息：
      在这里插入图片描述
      返回值：分页查询，需要返回分页结果PageResult，包含两个属性：
  • total：总条数
  • hotels：当前页的数据

因此，我们实现业务的流程如下：

  • 步骤一：定义实体类，接收请求参数的JSON对象
  • 步骤二：编写controller，接收页面的请求
  • 步骤三：编写业务实现，利用RestHighLevelClient实现搜索、分页

2.2 定义实体类，接收请求参数的JSON对象

request请求pojo类：

@Data
public class requestParams {
    private String key;
    private Integer page;
    private Integer size;
    private String sortBy;
}

reponse响应pojo类：

@Data
@NoArgsConstructor
@AllArgsConstructor
public class PageResult {
    private Long total;
    private List<HotelDoc> hotels;
}

2.3 编写controller，接收页面的请求

@RestController
@RequestMapping("hotel")
public class HotelController {

    @Autowired
    private IHotelService hotelService;

    @PostMapping("list")
    public PageResult search(@RequestBody RequestParams params) {
        return hotelService.search(params);
    }
}

2.4 编写业务实现，利用RestHighLevelClient实现搜索、分页

@Service
public class HotelService extends ServiceImpl<HotelMapper, Hotel> implements IHotelService {

    @Autowired
    private RestHighLevelClient restHighLevelClient;

    @Override
    public PageResult searchPageInfo(RequestParams params) throws IOException {
        //1 构建搜索请求对象
        SearchRequest request = new SearchRequest("hotel");
        //2 构建查询条件
        if(params.getKey() == null){
            //如果关键字为空 则无条件查询
            request.source().query(QueryBuilders.matchAllQuery());
        }else{
            request.source().query(QueryBuilders.matchQuery("all",params.getKey()));
        }
        // 3 构建分页
        Integer page = params.getPage()==null?1:params.getPage();
        Integer pageSize = params.getSize()==null?1:params.getSize();
        request.source().from((page - 1)*pageSize).size(pageSize);
        //4 发起请求
        SearchResponse response = restHighLevelClient.search(request, RequestOptions.DEFAULT);
        //5 解析response
        return handerResult(response);
    }

    private PageResult handerResult(SearchResponse response) {
        //1 判断是不是null
        if(response == null){
            return null;
        }
        //2 解析数据
        SearchHits hits = response.getHits();
        //3 获取命中的文档数
        long total = hits.getTotalHits().value;
        //4 获取命中查询的内容
        SearchHit[] hitsArray = hits.getHits();
        List<HotelDoc> docs = new ArrayList<>();
        if(hitsArray.length > 0){
            for (SearchHit hit : hitsArray) {
                String jsonData = hit.getSourceAsString();
                HotelDoc hotelDoc = JSON.parseObject(jsonData, HotelDoc.class);
                docs.add(hotelDoc);
            }
        }
        //5 组装pageResult
        return new PageResult(total, docs);
    }

}

3. 酒店结果过滤

3.1 请求和响应分析

需求：添加品牌、城市、星级、价格等过滤功能
在页面搜索框下面，会有一些过滤项：
在这里插入图片描述
前端进入f12查看request和response
在这里插入图片描述
包含的过滤条件有：

  • brand：品牌值
  • city：城市
  • minPrice~maxPrice：价格范围
  • starName：星级

我们需要做两件事情：

  • 修改请求参数的对象RequestParams，接收上述参数
  • 修改业务逻辑，在搜索条件之外，添加一些过滤条件

3.2 修改请求参数的对象RequestParams

在这里插入图片描述

3.2 修改业务逻辑，在搜索条件之外，添加一些过滤条件

对业务层进行修改，使用bool查询进行组合查询条件：

  • 品牌过滤：是keyword类型，用term查询
  • 星级过滤：是keyword类型，用term查询
  • 价格过滤：是数值类型，用range查询
  • 城市过滤：是keyword类型，用term查询
  • 关键字搜索放到must中，参与算分
  • 其它过滤条件放到filter中，不参与算分

为了提高代码可阅读性，我把bool过滤查询封装到了一个函数：

    /**
     * bool多条件过滤查询构建方法
     * @param request
     * @param params
     */
    private void buildBasicSearch(SearchRequest request, RequestParams params) {
        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
        //1 设置must全文过滤条件
        if(params.getKey() == null){
            //如果关键字为空 则无条件查询
            boolQueryBuilder.must(QueryBuilders.matchAllQuery());
        }else{
            boolQueryBuilder.must(QueryBuilders.matchQuery("all",params.getKey()));
        }
        //2 设置filter过滤条件
        if(params.getBrand() != null){
            boolQueryBuilder.filter(QueryBuilders.termQuery("brand",params.getBrand()));
        }
        if(params.getCity() != null){
            boolQueryBuilder.filter(QueryBuilders.termQuery("city",params.getCity()));
        }
        if(params.getStarName() != null){
            boolQueryBuilder.filter(QueryBuilders.termQuery("starName",params.getStarName()));
        }
        if(params.getMinPrice() != null && params.getMaxPrice() != null){
            boolQueryBuilder.filter(QueryBuilders.rangeQuery("price").gte(params.getMinPrice()).lte(params.getMaxPrice()));
        }
        request.source().query(boolQueryBuilder);
    }

4.实现 我周边的酒店

4.1 请求和响应分析

在酒店列表页的右侧，有一个小地图，点击地图的定位按钮，地图会找到你所在的位置：
在这里插入图片描述
并且，在前端会发起查询请求，将你的坐标发送到服务端：
在这里插入图片描述
所以需求就是基于这个location坐标，然后按照距离对周围酒店排序。实现思路如下：

  • 修改RequestParams参数，接收location字段
  • 修改search方法业务逻辑，如果location有值，添加根据geo_distance排序的功能

4.2 修改RequestParams参数，接收location字段

@Data
public class RequestParams {
    private String key;
    private Integer page;
    private Integer size;
    private String sortBy;
    // 下面是新增的过滤条件参数
    private String city;
    private String brand;
    private String starName;
    private Integer minPrice;
    private Integer maxPrice;
    // 我当前的地理坐标
    private String location;
}

4.3 修改search方法，完成距离排序

业务层修改代码：距离排序规则 由近到远排序

        if(params.getLocation() != null){
            //距离排序规则 由近到远排序
            request.source().sort(SortBuilders.geoDistanceSort("location",new GeoPoint(params.getLocation()))
                    .order(SortOrder.ASC).unit(DistanceUnit.KILOMETERS));
        }

4.4 排序距离显示

实现以下功能：
在这里插入图片描述
这个实现也很简单，之前学习es时，在es终端输入这个距离排序，得到的结果是：
在这里插入图片描述
因此，我们在结果解析阶段，除了解析source部分以外，还要得到sort部分，也就是排序的距离，然后放到响应结果中。

我们要做两件事：

  • 修改HotelDoc，添加排序距离字段，用于页面显示
  • 修改HotelService类中的handleResponse方法，添加对sort值的获取

首先查看前端页面：
在这里插入图片描述
这里前端接受的是一个叫做distance的值（且保留两位小数），因此，HotelDoc实体类中应该添加一个distance成员变量
在这里插入图片描述
之后修改业务层代码：

                //获取距离
                Object[] sortValues = hit.getSortValues();
                if(sortValues.length > 0){
                    hotelDoc.setDistance(sortValues[0]);
                }

5 酒店竞价排名

5.1 请求和响应分析

充钱了就是牛逼
要让指定酒店在搜索结果中排名置顶，并且像淘宝一样有个“广告”标识

那怎样才能让指定的酒店排名置顶呢？
的function_score查询可以影响算分，算分高了，自然排名也就高了。而function_score包含3个要素：

  • 过滤条件：哪些文档要加分
  • 算分函数：如何计算function score
  • 加权方式：function score 与 query score如何运算

这里的需求是：让指定酒店排名靠前。因此我们需要给这些酒店添加一个标记，这样在过滤条件中就可以根据这个标记来判断，是否要提高算分。

比如，我们给酒店添加一个字段：isAD，Boolean类型：

  • true：是广告
  • false：不是广告

关于这一点，前端以及实现了：
在这里插入图片描述

这样function_score包含3个要素就很好确定了：

  • 过滤条件：判断isAD 是否为true
  • 算分函数：我们可以用最简单暴力的weight，固定加权值
  • 加权方式：可以用默认的相乘，大大提高算分

因此，实现以上功能的步骤如下：

  1. 给HotelDoc类添加isAD字段，Boolean类型
  2. 挑选几个你喜欢的酒店，给它的文档数据添加isAD字段，值为true
  3. 修改search方法，添加function score功能，给isAD值为true的酒店增加权重

5.2 修改Hoteldoc实体类 以及 es添加doc属性

修改实体类：
在这里插入图片描述
给几个酒店的doc添加isAD标签
首先，我们es原来索引的mapping中没有isAD，那么怎么进行添加？
其实不用改动mapping，es相对于mysql这中关系型数据库有个很强大的特性：我们只需要给某个索引doc添加isAD属性，那么hotel的索引mapping自动会检测到并添加isAD的mapping属性。如下所示：

POST /hotel/_update/2359697
{
  "doc": {
    "isAD":true
  }
}

之后查一下hotel的mapping
在这里插入图片描述

5.3 修改业务层代码

首先我们回一下算分查询的语法把：
在这里插入图片描述
那么根据es的语法，修改代码：

        FunctionScoreQueryBuilder functionScoreQueryBuilder = QueryBuilders.functionScoreQuery(boolQueryBuilder,
                new FunctionScoreQueryBuilder.FilterFunctionBuilder[]{
                        new FunctionScoreQueryBuilder.FilterFunctionBuilder(
                                QueryBuilders.termQuery("isAD","true"),
                                ScoreFunctionBuilders.weightFactorFunction(20f)
                        )
                });

最终达到这种效果：
在这里插入图片描述

6 实现品牌城市星级价格的聚合

6.1 什么意思

在这里插入图片描述
搜索页面的品牌、城市等信息不应该是在页面写死，而是通过聚合索引库中的酒店数据得来的
那么如何解决这个问题呢？

使用聚合功能，利用Bucket聚合，对搜索结果中的文档基于品牌分组、基于城市分组，就能得知包含哪些品牌、哪些城市了，之后在选项中显示包含的结果。
因为是对搜索结果聚合，因此聚合是限定范围的聚合，也就是说聚合的限定条件跟搜索文档的条件一致。

6.2 请求和响应分析

首先，这个功能是通过filters接口实现的：
在这里插入图片描述
那么，我们从前端页面看一下这个request和response的参数：
其中request和上面是一样的
在这里插入图片描述
response大概的样子：
在这里插入图片描述

6.3 Controller层实现

要求：

  • 请求方式：POST
  • 请求路径：/hotel/filters
  • 请求参数：RequestParams，与搜索文档的参数一致
  • 返回值类型：Map<String, List<String>>
    @PostMapping("/filters")
    public Map<String, List<String>> getFilters(@RequestBody RequestParams params){
        return hotelService.getFilters(params);
    }

6.4 业务层实现

service代码如下：

    /**
     * 根据传入的条件 动态过滤出品牌星级城市价格等信息
     * @param params
     * @return
     */
    @Override
    public Map<String, List<String>> getFilters(RequestParams params) throws IOException {
        SearchRequest request = new SearchRequest("hotel");
        request.source().size(0);
        buildBasicSearch(request,params);
        //在上面条件的基础上构建聚合:brand city starName
        buildAggs(request);
        //发起请求
        SearchResponse response = restHighLevelClient.search(request, RequestOptions.DEFAULT);
        //解析聚合数据
        List<String> cities = getBuckNames(response,"brandAggs");
        List<String> brands = getBuckNames(response,"cityAggs");
        List<String> starNames = getBuckNames(response,"starNameAggs");
        //组装为响应结果
        Map<String,List<String>> info = new HashMap<>();
        info.put("city",cities);
        info.put("brand",brands);
        info.put("starName",starNames);
        return info;
    }

封装了两个函数
buildAggs：

    /**
     * 构建brand city starName的聚合
     * @param request
     */
    private void buildAggs(SearchRequest request) {
        request.source().aggregation(AggregationBuilders
                .terms("cityAggs").field("city").size(20));
        request.source().aggregation(AggregationBuilders
                .terms("brandAggs").field("brand").size(20));
        request.source().aggregation(AggregationBuilders
                .terms("starNameAggs").field("starName").size(20));
    }

getBuckNames：

    /**
     * 根据response和聚合名称获取桶的数据
     * @param response
     * @param aggName
     * @return
     */
    private List<String> getBuckNames(SearchResponse response, String aggName) {
        List<String> result = new ArrayList<>();
        Aggregations aggregations = response.getAggregations();
        Terms aggregation = aggregations.get(aggName);
        if(aggregation == null || aggregation.getBuckets().size() == 0){
            return result;
        }
        List<? extends Terms.Bucket> buckets = aggregation.getBuckets();
        for (Terms.Bucket bucket : buckets) {
            String key = bucket.getKeyAsString();
            result.add(key);
        }
        return result;
    }

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

上位机图像处理和嵌入式模块部署（树莓派4b设置ftp下载）

上位机图像处理和嵌入式模块部署（树莓派4b设置ftp下载）

【 声明&#xff1a;版权所有&#xff0c;欢迎转载&#xff0c;请勿用于商业用途。 联系信箱&#xff1a;feixiaoxing 163.com】 作为一个开发板&#xff0c;最好支持ftp下载&#xff0c;这样文件的上传和下载都会比较方便。虽然目前为止&#xff0c;利用mobaxterm和ssh也能实现…
阅读更多...
算法学习(5)-图的遍历

算法学习(5)-图的遍历

目录 什么是深度和广度优先 图的深度优先遍历-城市地图 图的广度优先遍历-最少转机 什么是深度和广度优先 使用深度优先搜索来遍历这个图的过程具体是&#xff1a; 首先从一个未走到过的顶点作为起始顶点&#xff0c; 比如以1号顶点作为起点。沿1号顶点的边去尝试访问其它未…
阅读更多...
用Jenkins实现cherry-pick多个未入库的gerrit编译Android固件

用Jenkins实现cherry-pick多个未入库的gerrit编译Android固件

背景： 在做Android固件开发的时候，通常我们可以利用gerrit-trigger插件，开发者提交一笔的时候自动触发jenkins编译，如果提交的这一笔的编译依赖其他gerrit才能编译过，我们可以在commit message中加入特殊字段，让jenkins在编译此笔patch的时候同时抓取依赖的gerrit代码下…
阅读更多...
selenium在Pycharm中结合python的基本使用、交互、无界面访问

selenium在Pycharm中结合python的基本使用、交互、无界面访问

下载 下载与浏览器匹配的浏览器驱动文件&#xff0c;这里一定注意的是&#xff0c;要选择和浏览器版本号相同的驱动程序&#xff0c;否则后面会有很多问题。 &#xff08;1&#xff09;浏览器&#xff08;以google为例&#xff09;版本号的查询&#xff1a; 我这里的版本号是1…
阅读更多...
RT-Thread V5.2.0版本尝鲜

RT-Thread V5.2.0版本尝鲜

文章目录 配置界面的更新新旧内核生成的二进制文件大小差异旧版本V5.1.0内核旧版本V5.2.0内核 配置界面的更新 尝试将手头RT-Thread工程的OS部分源码进行了更新&#xff0c;发现不少新的变化 配置界面变得更醒目&#xff1a; 配置变更保存提醒界面更新&#xff1a; 新旧内核…
阅读更多...
Android Widget开发代码示例详细说明

Android Widget开发代码示例详细说明

因为AppWidgetProvider扩展自BroadcastReceiver, 所以你不能保证回调函数完成调用后&#xff0c;AppWidgetProvider还在继续运行。 a. AppWidgetProvider 的实现 /*** Copyright(C):教育电子有限公司 * Project Name: NineSync* Filename: SynWidgetProvider.java * Author(S…
阅读更多...
【Node.js工程师养成计划】之原生node开发web服务器

【Node.js工程师养成计划】之原生node开发web服务器

一、使用node创建http服务器 var http require(http);// 获取到服务器实例对象 var server http.createServer() server.listen(8080, function() {console.log(http://127.0.0.1:8080); })server.on(request, function(req, res){console.log(request);res.write(6666666688…
阅读更多...
VitePress 构建的博客如何部署到 github 平台？

VitePress 构建的博客如何部署到 github 平台？

VitePress 构建的博客如何部署到 github 平台&#xff1f; 1. 新建 github 项目 2. 构建 VitePress 项目 2.1. 设置 config 中的 base 由于我们的项目名称为 vite-press-demo&#xff0c;所以我们把 base 设置为 /vite-press-demo/&#xff0c;需注意前后 / export default…
阅读更多...
【数据结构与算法(C语言)】1. 线性表的顺序存储

【数据结构与算法(C语言)】1. 线性表的顺序存储

文章目录 前言一. 线性表插入和删除1. 元素的插入2. 元素的删除 二. 代码三. 优缺点 前言 线性表的顺序存储结构&#xff0c;指的是用一段地址连续的存储单元依次存储线性表的数据结构 一. 线性表插入和删除 1. 元素的插入 插入位置之后的数据都向后移一位&#xff0c;上图中元…
阅读更多...
chrome 安装devtools

chrome 安装devtools

chrome 安装devtools 下载安装 链接&#xff1a;https://github.com/vuejs/devtools 选择对应版本&#xff1a; 安装yarn 下载 npm install -g yarn --registryhttps://registry.npmmirror.com进入下载的目录安装依赖 yarn install --registryhttps://registry.npmmirror.…
阅读更多...
ASP.NET汽车销售管理系统的设计与开发

ASP.NET汽车销售管理系统的设计与开发

摘 要 随着人们生活水平的不断提高&#xff0c;人们对汽车的消费和需求也越来越旺盛。很多汽车销售公司的业务环节仍然运用人工记账的传统方法&#xff0c;既容易出错又会导致账目混乱&#xff0c;查询和统计起来也非常不方便&#xff0c;费时又费力&#xff0c;严重时会给公…
阅读更多...
stm32单片机开发二、定时器-内部时钟中断和外部时钟中断、编码器

stm32单片机开发二、定时器-内部时钟中断和外部时钟中断、编码器

定时器本质就是一个计数器 案例&#xff1a;定时器定时中断 内部时钟中断 Timer_Init(); //定时中断初始化 /*** 函 数&#xff1a;定时中断初始化* 参 数&#xff1a;无* 返 回 值&#xff1a;无*/ void Timer_Init(void) {/*开启时钟*/RCC_APB1PeriphClockCmd(RCC…
阅读更多...
CSS-复合选择器

CSS-复合选择器

作用&#xff1a; 后代选择器&#xff1a; 子代选择器 并集选择器 用逗号隔开&#xff0c;在style里面写的时候&#xff0c;每一个标签空一行。 <title>Document</title><style>p,div,span{color: aqua;}</style> </head> <body><p>…
阅读更多...
在Linux操作系统中关于磁盘（硬盘）管理的操作

在Linux操作系统中关于磁盘（硬盘）管理的操作

电脑中数据存储设备&#xff1a;硬盘&#xff08;实现数据的持久化存储&#xff09;&#xff0c;内存 在Linux操作系统中一切皆文件的思想&#xff0c;所有的设备在Linux操作系统中都是通过文件来标识的&#xff0c;所以每一个硬盘都对应一个块设备文件。 在Linux操作系统中所…
阅读更多...
Golang | Leetcode Golang题解之第55题跳跃游戏

Golang | Leetcode Golang题解之第55题跳跃游戏

题目&#xff1a; 题解&#xff1a; // 贪心算法 func canJump(nums []int) bool {cover : 0n : len(nums)-1for i : 0; i < cover; i { // 每次与覆盖值比较cover max(inums[i], cover) //每走一步都将 cover 更新为最大值if cover > n {return true}}return false } …
阅读更多...
YOLov5 + Gradio搭建简单的Web GUI

YOLov5 + Gradio搭建简单的Web GUI

写在前面&#xff1a;当我们将模型训练出来了&#xff0c;此时就需要做UI界面给别人展示了。python提供的Gradio可以快速的搭建web页面。生成本地网址和公网网址&#xff0c;方面自己测试和用户测试。 一、安装 Gradio介绍 Gradio是一个开源的python库&#xff0c;用于构建机…
阅读更多...
深度学习模型Deep Learning Model

深度学习模型Deep Learning Model

什么是深度学习&#xff1f;&#xff1f; 深度学习模型是一种基于人工神经网络&#xff08;Artificial Neural Networks, ANN&#xff09;的机器学习模型&#xff0c;其核心思想是通过多层次的神经网络结构来学习数据的特征表示和模式。这些模型通常由多个层次&#xff08;深度…
阅读更多...
WPS的JS宏如何设置Word文档的表格的单元格文字重新编号

WPS的JS宏如何设置Word文档的表格的单元格文字重新编号

希望对Word文档中的表格进行统一处理&#xff0c;表格内的编号&#xff0c;有时候会出现紊乱&#xff0c;下一个表格的编号承接了上一个表格的编号&#xff0c;实际需要重新编号。 当表格比较多时&#xff0c;手动更改非常麻烦&#xff0c;而且更改一遍并不能完成&#xff0c;…
阅读更多...
测算sample gpt

测算sample gpt

测算代码 import pandas as pd import matplotlib.pyplot as pltlosspd.read_pickle("loss_8.pkl") plt.plot(loss) losspd.read_pickle("loss_16.pkl") plt.plot(loss) losspd.read_pickle("loss_4_8.pkl") plt.plot(loss) losspd.read_pickle(…
阅读更多...
第5篇：创建Nios II工程之Hello_World＜四＞

第5篇：创建Nios II工程之Hello_World＜四＞

Q&#xff1a;最后我们在DE2-115开发板上演示运行Hello_World程序。 A&#xff1a;先烧录编译Quartus硬件工程时生成的.sof文件&#xff0c;在FPGA上成功配置Nios II系统&#xff1b;然后在Nios II Eclipse窗口右键点击工程名hello_world&#xff0c;选择Run As-->Nios II …
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023