• springboot+Elasticsearch进阶

    1. package com.admin.model;
    2.  
    3.  
    4. import com.fasterxml.jackson.annotation.JsonFormat;
    5. import com.admin.common.entity.BaseSJFZEntity;
    6. import lombok.Data;
    7. import org.springframework.data.elasticsearch.annotations.Document;
    8. import org.springframework.data.elasticsearch.annotations.Field;
    9. import org.springframework.data.elasticsearch.annotations.FieldType;
    10.  
    11. import java.util.Date;
    12.  
    13. /**
    14.  * Es 索引库实体
    15.  *
    16.  * @author wangwei
    17.  * @date 2024-04-25
    18.  */
    20. /***
    21.  * esmodel8、 esmodel9 是存储在es中的索引类型
    22.  */
    23. @Document(indexName = "esmodel9")
    24. @Data
    25. public class EsModel extends BaseSJFZEntity {
    26.  
    27.     /*** 索引id*/
    28.     @Field(type = FieldType.Long)
    29.     private String id;
    30.  
    31.     /**** es中对应的数据库业务单据id*/
    32.     @Field(analyzer = "ik_max_word")
    33.     private String ctId;
    34.  
    35.     /**** es中业务数据 对应的业务数据库表名称*/
    36.     @Field(analyzer = "ik_max_word")
    37.     private String ctTableName;
    38.  
    39.     /**** es中业务数据 对应的 业务简称*/
    40.     @Field(analyzer = "ik_max_word")
    41.     private String ctName;
    42.  
    43.  
    44.     /**** es中业务数据 对应的 业务内容详细信息*/
    45.     @Field(analyzer = "ik_max_word")
    46.     private String ctContent;
    47.  
    48. /*    *//** 创建者 *//*
    49.     //@Field(analyzer = "ik_max_word")
    50.     private String createUser;
    51.  
    52.     *//** 创建时间 *//*
    53.     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    54.     //@Field(analyzer = "ik_max_word")
    55.     private Date createTime;
    56.  
    57.     *//** 更新者 *//*
    58.    // @Field(analyzer = "ik_max_word")
    59.     private String updateUser;
    60.  
    61.     *//** 更新时间 *//*
    62.     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    63.    // @Field(analyzer = "ik_max_word")
    64.     private Date updateTime;*/
    65.  
    66.     /** 备注 */
    67.     @Field(analyzer = "ik_max_word")
    68.     private String remark;
    69.  
    70.     /** 备用1 */
    71.     @Field(analyzer = "ik_max_word")
    72.     private String by1;
    73.  
    74.     /** 备用2 */
    75.     @Field(analyzer = "ik_max_word")
    76.     private String by2;
    77.  
    78.     /** 备用3 */
    79.     @Field(analyzer = "ik_max_word")
    80.     private String by3;
    81.  
    82.     /** 备用4 */
    83.     @Field(analyzer = "ik_max_word")
    84.     private String by4;
    85.  
    86.     /** 备用5 */
    87.     @Field(analyzer = "ik_max_word")
    88.     private String by5;
    89.  
    90. }

    2.

    1. package com.admin.controller;
    2. import com.admin.common.annotation.Log;
    3. import com.admin.common.core.controller.BaseController;
    4. import com.admin.common.core.domain.AjaxResult;
    5. import com.admin.common.core.page.TableDataInfo;
    6. import com.admin.common.enums.BusinessType;
    7. import com.admin.model.EsModel;
    8. import com.admin.service.EsService;
    9. import io.swagger.annotations.Api;
    10. import io.swagger.annotations.ApiOperation;
    11. import org.springframework.beans.factory.annotation.Autowired;
    12. import org.springframework.data.domain.Pageable;
    13. import org.springframework.web.bind.annotation.*;
    14.  
    15. import java.util.List;
    16.  
    17. /**
    18.  * es -spi
    19.  *
    20.  * @author wangwei
    21.  * @date 2024-04-25
    22.  */
    23. @Api(tags = "ES-api")
    24. @RestController
    25. @RequestMapping("/es/api")
    26. public class EsController extends BaseController {
    27.  
    28.     @Autowired
    29.     private EsService esService;
    30.  
    31.     /***
    32.      *从es中按指定字段值获取数据
    33.      * @param key
    34.      * @return
    35.      */
    36.     @ApiOperation(value = "查询 从es中按指定字段值获取数据")
    37.     @GetMapping("/list")
    38.     public AjaxResult list(String key, Pageable pageable) {
    39.         AjaxResult ajaxResult = esService.searchES(key, pageable);
    40.         return ajaxResult;
    41.     }
    42.  
    43.     /***
    44.      * 全文检索
    45.      *查询 从es中全文检索所包含的 业务数据信息
    46.      * eg：es中的数据字段有 name, contene,等，接口查询条件key  包含在所有字段中的业务数据信息
    47.      * @param key
    48.      * @return
    49.      */
    50.     @ApiOperation(value = "查询 从es中全文检索所包含的 业务数据信息")
    51.     @GetMapping("/whole")
    52.     public TableDataInfo searchWhole(String key, Pageable pageable) {
    53.         List<EsModel> list = esService.searchWhole(key, pageable);
    54.         return getDataTable(list);
    55.     }
    56.  
    57.     /****
    58.      * es中数据新增
    59.      */
    60.     @ApiOperation(value = "es中数据新增" )
    61.     @Log(title = "es中数据新增" , businessType = BusinessType.INSERT)
    62.     @PostMapping
    63.     public AjaxResult add(@RequestBody EsModel esModel) {
    64.         return toAjax(esService.insertEsModel(esModel));
    65.     }
    66.  
    67.     /****
    68.      * es中数据修改
    69.      */
    70.     @ApiOperation(value = "es中数据修改" )
    71.     @Log(title = "es中数据修改" , businessType = BusinessType.UPDATE)
    72.     @PutMapping
    73.     public AjaxResult put(@RequestBody EsModel esModel) {
    74.         return toAjax(esService.updateEsModel(esModel));
    75.     }
    76.  
    77.     /**
    78.      * 删除es中的数据
    79.      */
    80.     @ApiOperation(value = "删除es中的数据")
    81.     @Log(title = "删除es中的数据", businessType = BusinessType.DELETE)
    82.     @DeleteMapping("/{ctId}")
    83.     public AjaxResult remove(@PathVariable String ctId) {
    84.         return toAjax(esService.deleteById(ctId));
    85.     }
    86.  
    87.  
    88. }

    3.

    1. package com.admin.service.impl;
    2.  
    3. import com.admin.common.core.domain.AjaxResult;
    4. import com.admin.common.exception.CustomException;
    5. import com.admin.common.utils.StringUtils;
    6. import com.admin.constant.EsConstants;
    7. import com.admin.model.EsModel;
    8. import com.admin.repository.EsModelRepository;
    9. import com.admin.service.EsService;
    10. import com.admin.util.HighlightResultMapper;
    11. import com.alibaba.fastjson.JSON;
    12. import org.elasticsearch.action.update.UpdateRequest;
    13. import org.elasticsearch.action.update.UpdateResponse;
    14. import org.elasticsearch.client.RequestOptions;
    15. import org.elasticsearch.client.RestHighLevelClient;
    16. import org.elasticsearch.common.xcontent.XContentType;
    17. import org.elasticsearch.index.query.QueryBuilders;
    18. import org.elasticsearch.search.builder.SearchSourceBuilder;
    19. import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
    20. import org.elasticsearch.search.sort.SortBuilders;
    21. import org.elasticsearch.search.sort.SortOrder;
    22. import org.springframework.beans.factory.annotation.Autowired;
    23. import org.springframework.data.domain.Page;
    24. import org.springframework.data.domain.Pageable;
    25. import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
    26. import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
    27. import org.springframework.data.elasticsearch.core.query.SearchQuery;
    28. import org.springframework.stereotype.Service;
    29. import java.io.IOException;
    30. import java.util.ArrayList;
    31. import java.util.List;
    32. import java.util.UUID;
    33.  
    34. import static org.elasticsearch.index.query.QueryBuilders.matchQuery;
    35.  
    36. @Service
    37. public class EsServiceImpl implements EsService {
    38.  
    39.     @Autowired
    40.     private EsModelRepository esModelRepository;
    41.  
    42.     @Autowired
    43.     private ElasticsearchRestTemplate elasticsearchRestTemplate;
    44.  
    45.     @Autowired
    46.     private RestHighLevelClient client;
    47.  
    48.     @Override
    49.     public AjaxResult searchES(String key, Pageable pageable) {
    50.         Page<EsModel> ctContent = esModelRepository.findEsModelByCtContent(key, pageable);
    51.         return AjaxResult.success(ctContent);
    52.     }
    53.  
    54.     /***
    55.      * 全文检索
    56.      * @param key
    57.      * @return
    58.      */
    59.     @Override
    60.     public  List<EsModel> searchWhole(String key, Pageable pageable) {
    61.         //高亮字段设置
    62.         String ctName = "ctName";
    63.         String ctContent = "ctContent";
    64.         String remark = "remark";
    65.         String preTags = "color:#F56C6C\">";
    66.         String postTags = "";
    67.         HighlightBuilder.Field ctNameField = new HighlightBuilder.Field(ctName).preTags(preTags).postTags(postTags);
    68.         HighlightBuilder.Field ctContentField = new HighlightBuilder.Field(ctContent).preTags(preTags).postTags(postTags);
    69.         HighlightBuilder.Field remarkField = new HighlightBuilder.Field(remark).preTags(preTags).postTags(postTags);
    70.  
    71.         if (StringUtils.isEmpty(key)) {
    72.             //throw new CustomException("请输入搜索内容！");
    73.             List<EsModel> contentList = new ArrayList<>();
    74.             return contentList;
    75.         }
    76.  
    77.         //只要数据中包含就能检索到数据 （类似于模糊查询，有分词器的效果）
    78.         //不同类别检索的进阶示例： https://www.cnblogs.com/jelly12345/p/14765477.html
    79.         SearchQuery searchQuery = new NativeSearchQueryBuilder()
    80.                 .withPageable(pageable)//分页
    81.                 .withQuery(QueryBuilders.multiMatchQuery(key, "ctName", "ctContent", "remark"))
    82.                 .withHighlightFields(ctNameField, ctContentField, remarkField)//设置高亮
    83.                // .withSort(SortBuilders.fieldSort("date").order(SortOrder.DESC))//排序
    84.                 .build();
    85.  
    86.         Page<EsModel> esModels = null;
    87.         try {
    88.             esModels =  elasticsearchRestTemplate.queryForPage(searchQuery, EsModel.class, new HighlightResultMapper());
    89.         }catch (Exception e){
    90.             throw new CustomException("数据检索失败，请联系管理员处理！");
    91.         }
    92.  
    93.         List<EsModel> contentList = esModels.getContent();
    94.         return contentList;
    95.     }
    96.  
    97.  
    98.     /****
    99.      *数据插入es中
    100.      * @param esModel
    101.      * @return
    102.      */
    103.     @Override
    104.     public int insertEsModel(EsModel esModel) {
    105.         try {
    106.             esModel.setCtId(UUID.randomUUID().toString());
    107.             EsModel save = esModelRepository.save(esModel);
    108.         } catch (Exception e) {
    109.             System.out.println("==================================错误信息是："+e.getMessage()+"============================");
    110.             throw new CustomException("ES数据新增失败，请联系管理员处理！");
    111.         }
    112.         return 1;
    113.     }
    114.  
    115.     /***
    116.      *es-update  https://www.jb51.net/article/246798.htm
    117.      * @param esModel
    118.      * @return
    119.      */
    120.     @Override
    121.     public int updateEsModel(EsModel esModel) {
    122.         UpdateRequest updateRequest = new UpdateRequest(EsConstants.ES_INDEX, EsConstants.ES_INDEX_TYPE, String.valueOf(esModel.getCtId()));
    123.         //更新    将对象转换为json
    124.         updateRequest.doc(JSON.toJSONString(esModel), XContentType.JSON);
    125.  
    126.         //客户端发送请求，进行更新
    127.         UpdateResponse update = null;
    128.         try {
    129.             update = client.update(updateRequest, RequestOptions.DEFAULT);
    130.         } catch (IOException e) {
    131.             throw new CustomException("ES数据同步失败可能原因是es中的业务ctId在数据库中不存在，请查看es客户端查询验证，请联系管理员处理！");
    132.         }
    133.  
    134.         if (!"OK".equals(update.status().toString())) {
    135.             throw new CustomException("ES数据修改失败，请联系管理员处理！");
    136.         }
    137.         return 1;
    138.  
    139.     }
    140.  
    141.     /***
    142.      * 删除es中的数据
    143.      * @param ctId
    144.      * @return
    145.      */
    146.     @Override
    147.     public int deleteById(String ctId) {
    148.         try {
    149.             esModelRepository.deleteById(ctId);
    150.         }catch (Exception e){
    151.             throw new CustomException("ES数据删除失败，请联系管理员处理！");
    152.         }
    153.         return 1;
    154.     }
    155.  
    156. }
    157.  
    158.

    4.

    1. package com.admin.repository;
    2. import com.admin.model.EsModel;
    3. import org.springframework.data.domain.Page;
    4. import org.springframework.data.domain.Pageable;
    5. import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
    6. import org.springframework.stereotype.Repository;
    7.  
    8. /**
    9.  * @author wangwei
    10.  * @date 2024-04-25 14:12:36
    11.  */
    12. @Repository
    13. public interface EsModelRepository extends ElasticsearchRepository<EsModel, String> {
    14.  
    15.  
    16.     /*****
    17.      * 这儿查询的  findBy 根据idea 的补全查询（eg:ByCtContent 将查询es中的 字段名称为 ctContent 中的值）
    18.      * @param ket
    19.      * @param pageable
    20.      * @return
    21.      */
    22.     Page<EsModel> findEsModelByCtContent(String ket, Pageable pageable);
    23.  
    24.     /****
    25.      * 删除es操作
    26.      */
    27.     public void deleteById(Long id);
    28.  
    29.  
    30. }

    5.检索结果高亮显示

    1. package com.admin.util;
    2.  
    3. import com.alibaba.fastjson.JSON;
    4. import org.elasticsearch.action.search.SearchResponse;
    5. import org.elasticsearch.search.SearchHit;
    6. import org.elasticsearch.search.SearchHits;
    7. import org.elasticsearch.search.fetch.subphase.highlight.HighlightField;
    8. import org.springframework.data.domain.Pageable;
    9. import org.springframework.data.elasticsearch.core.SearchResultMapper;
    10. import org.springframework.data.elasticsearch.core.aggregation.AggregatedPage;
    11. import org.springframework.data.elasticsearch.core.aggregation.impl.AggregatedPageImpl;
    12. import java.lang.reflect.Field;
    13.  
    14. import java.util.ArrayList;
    15. import java.util.List;
    16. import java.util.Map;
    17.  
    18.  
    19. /***
    20.  * 检索高亮设置
    21.  * @author wangwei
    22.  * @date 2024-04-25 11:55
    23.  */
    24. public class HighlightResultMapper implements SearchResultMapper {
    25.     @Override
    26.     public <T> AggregatedPage<T> mapResults(SearchResponse response, Class<T> clazz, Pageable pageable) {
    27.         long totalHits = response.getHits().getTotalHits();
    28.         List<T> list = new ArrayList<>();
    29.         SearchHits hits = response.getHits();
    30.         if (hits.getHits().length> 0) {
    31.             for (SearchHit searchHit : hits) {
    32.                 Map<String, HighlightField> highlightFields = searchHit.getHighlightFields();
    33.                 T item = JSON.parseObject(searchHit.getSourceAsString(), clazz);
    34.                 Field[] fields = clazz.getDeclaredFields();
    35.                 for (Field field : fields) {
    36.                     field.setAccessible(true);
    37.                     if (highlightFields.containsKey(field.getName())) {
    38.                         try {
    39.                             field.set(item, highlightFields.get(field.getName()).fragments()[0].toString());
    40.                         } catch (IllegalAccessException e) {
    41.                             e.printStackTrace();
    42.                         }
    43.                     }
    44.                 }
    45.                 list.add(item);
    46.             }
    47.         }
    48.         return new AggregatedPageImpl<>(list, pageable, totalHits);
    49.     }
    50.  
    51.     @Override
    52.     public <T> T mapSearchHit(SearchHit searchHit, Class<T> type) {
    53.         return null;
    54.     }
    55. }

    6.vue

    1. <template>
    2.   <div class="app-container">
    3.     <el-row :gutter="20">
    4.  
    5.       <!--用户数据-->
    6.       <el-col :span="20" :xs="24">
    7.         <el-form :model="queryParams" ref="queryForm" :inline="true" v-show="showSearch" label-width="68px" style="text-align: center">
    8.           <el-form-item label="检索内容" prop="key" >
    9.             <el-input
    10.               v-model="queryParams.key"
    11.               placeholder="请输入检索内容"
    12.               clearable
    13.               size="small"
    14.               style="width: 240px"
    15.               @keyup.enter.native="handleQuery"
    16.             />
    17.           </el-form-item>
    18.           <el-form-item>
    19.             <el-button type="primary" icon="el-icon-search" size="mini" @click="handleQuery">搜索</el-button>
    20.             <el-button icon="el-icon-refresh" size="mini" @click="resetQuery">重置</el-button>
    21.           </el-form-item>
    22.         </el-form>
    23.  
    24.  
    25.         <el-table  v-loading="loading" :data="tableList" >
    26.           <el-table-column label="编号" align="center" key="ctId" prop="ctId" v-if="columns[0].visible" />
    27.           <el-table-column label="名称" align="center" key="ctName" prop="ctName" v-if="columns[1].visible" :show-overflow-tooltip="true" />
    28.           <el-table-column label="内容" align="center" key="ctContent" prop="ctContent" v-if="columns[2].visible" :show-overflow-tooltip="true" />
    29.           <el-table-column label="备注" align="center" key="remark" prop="remark" v-if="columns[2].visible" :show-overflow-tooltip="true" />
    30.         </el-table>
    31.  
    32.         <pagination
    33.           v-show="total>0"
    34.           :total="total"
    35.           :page.sync="queryParams.number"
    36.           :limit.sync="queryParams.size"
    37.           @pagination="getList"
    38.         />
    39.       </el-col>
    40.     </el-row>
    41.  
    42.   </div>
    43. </template>
    44.  
    45. <script>
    46.   import { list, getWholeList, addEsModel, editEsModel, removeEsModel} from "@/api/search";
    47.  
    48. import { getToken } from "@/utils/auth";
    49. import { treeselect } from "@/api/system/dept";
    50. import Treeselect from "@riophae/vue-treeselect";
    51. import "@riophae/vue-treeselect/dist/vue-treeselect.css";
    52.  
    53. export default {
    54.   name: "User",
    55.   components: { Treeselect },
    56.   data() {
    57.     return {
    58.       // 遮罩层
    59.       loading: true,
    60.       // 选中数组
    61.       ids: [],
    62.       // 非单个禁用
    63.       single: true,
    64.       // 非多个禁用
    65.       multiple: true,
    66.       // 显示搜索条件
    67.       showSearch: true,
    68.       // 总条数
    69.       total: 0,
    70.       // 表格数据
    71.       tableList: [],
    72.       // 弹出层标题
    73.       title: "",
    74.       // 部门树选项
    75.       deptOptions: undefined,
    76.       // 是否显示弹出层
    77.       open: false,
    78.       // 部门名称
    79.       deptName: undefined,
    80.       // 默认密码
    81.       initPassword: undefined,
    82.       // 日期范围
    83.       dateRange: [],
    84.       // 状态数据字典
    85.       statusOptions: [],
    86.       // 性别状态字典
    87.       sexOptions: [],
    88.       // 岗位选项
    89.       postOptions: [],
    90.       // 角色选项
    91.       roleOptions: [],
    92.       // 表单参数
    93.       form: {},
    94.       defaultProps: {
    95.         children: "children",
    96.         label: "label"
    97.       },
    98.       // 查询参数
    99.       queryParams: {
    100.         number: 1,
    101.         size: 10,
    102.       },
    103.       // 列信息
    104.       columns: [
    105.         { key: 0, label: `编号`, visible: true },
    106.         { key: 1, label: `名称`, visible: true },
    107.         { key: 2, label: `内容`, visible: true },
    108.       ],
    109.       // 表单校验
    110.       rules: {
    111.  
    112.       }
    113.     };
    114.   },
    115.   watch: {
    116.  
    117.   },
    118.   created() {
    119.     this.getList();
    120.   },
    121.   methods: {
    122.     /** 查询用户列表 */
    123.     getList() {
    124.       this.loading = true;
    125.       console.log(this.queryParams)
    126.       getWholeList(this.queryParams).then(response => {
    127.           this.tableList = response.rows;
    128.           this.total = response.total;
    129.           this.loading = false;
    130.         });
    131.     },
    132.  
    133.     // 取消按钮
    134.     cancel() {
    135.       this.open = false;
    136.       this.reset();
    137.     },
    138.     // 表单重置
    139.     reset() {
    140.       this.form = {
    141.         ctId: undefined,
    142.         ctName: undefined,
    143.         ctContent: undefined,
    144.         remark: undefined,
    145.       };
    146.       this.resetForm("form");
    147.     },
    148.     /** 搜索按钮操作 */
    149.     handleQuery() {
    150.       //this.queryParams.page = 1;
    151.       this.getList();
    152.     },
    153.     /** 重置按钮操作 */
    154.     resetQuery() {
    155.       this.dateRange = [];
    156.       this.resetForm("queryForm");
    157.       this.handleQuery();
    158.     },
    159.   }
    160. };
    161. </script>

    7.

  • 相关阅读:
    阿里P8总结的Nacos入门笔记，从安装到进阶小白也能轻松学会
    C专家编程 第6章 运行的诗章：运行时数据结构 6.5 当函数被调用时发生了什么：过程活动记录
    GJB 5000B简介
    微服务环境搭建
    用于胰腺癌自动化综述报告和可切除性分类的大型语言模型| 文献速递-基于深度学习的乳房、前列腺疾病诊断系统
    如何利用curl仿造websocket请求？
    【C语言基础】：操作符详解(二)
    【快应用】如何跳转应用市场app详情页？
    BI业务分析思维：生产制造供应链订单交付优化分析三种方式
    代码随想录第46天|139.单词拆分，了解多重背包，背包总结
  • 原文地址：https://blog.csdn.net/weixin_41037490/article/details/138193246