devbox
凡人多烦事01
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Java+springboot+elasticsearch7.6.2实现分组查询（平级+层级）并实现script多字段拼接查询以及大于小于等条件关系查询的实现_elasticsearch java 条件添加 数据小于等于

作者：凡人多烦事01 | 2024-04-13 09:36:12

赞

踩

elasticsearch java 条件添加 数据小于等于

Java+springboot+elasticsearch7.6.2实现分组查询（平级+层级）并实现script多字段拼接查询

简介：关于elasticsearch的“层级”聚合，百度一下有一大堆文章。这里不再啰嗦了，由于百度了三个小时，也没找到我想要的"平级"查询的方法，最后还是自己研究源码整除来的，其实就是那么那么简单，只是没有例子，就不好整。上干货。

注：对es里的专业用语不熟，所以这里用的"平级"，"层级"两个测只是形象词语，不是es专业叫法。。。知道叫法的请留言告知。

 

目录

Java+springboot+elasticsearch7.6.2实现分组查询（平级+层级）并实现script多字段拼接查询

第一步、 实现平级搜索。

第二部、实现平级+层级分组聚合

第三部、script实现多字段查询

四、分词的字段做聚合

五、实践代码

 

第一步、 实现平级搜索。

先看一下，测试数据的数据结构：

kibana：

  1. GET ermsftrv1/_search
  2. {
  3.   "query": {
  4.     "match_all": {}
  5.   }
  6. }

结果：

  1. {
  2.   "took" : 0,
  3.   "timed_out" : false,
  4.   "_shards" : {
  5.     "total" : 1,
  6.     "successful" : 1,
  7.     "skipped" : 0,
  8.     "failed" : 0
  9.   },
  10.   "hits" : {
  11.     "total" : {
  12.       "value" : 6,
  13.       "relation" : "eq"
  14.     },
  15.     "max_score" : 1.0,
  16.     "hits" : [
  17.       {
  18.         "_index" : "ermsftrv1",
  19.         "_type" : "_doc",
  20.         "_id" : "6502586031240448",
  21.         "_score" : 1.0,
  22.         "_source" : {
  23.           "annual" : "",
  24.           "archName" : "新建文本文档",
  25.           "archNo" : "0022-SB0000.TODO-TODO-001",
  26.           "archTypeCode" : "SB0000",
  27.           "archTypeId" : "6485930821313792",
  28.           "archTypeName" : "设备仪器",
  29.           "archivedDate" : 1587545484000,
  30.           "archivedDep" : "1753-11-11 00:00:00",
  31.           "archivedOperator" : "",
  32.           "documentPage" : 0,
  33.           "entityTypeId" : 1,
  34.           "expDate" : -6820704000000,
  35.           "fileNo" : "",
  36.           "handlerId" : 6502586302145792,
  37.           "id" : "6502586031240448",
  38.           "pageNum" : "0",
  39.           "picPage" : 0,
  40.           "responsibleDept" : "",
  41.           "responsibleOper" : "hanfeixian",
  42.           "savePeriod" : "永久",
  43.           "savePeriodId" : "1",
  44.           "secret" : "普通商密",
  45.           "secretExpDate" : 1650556800000,
  46.           "secretId" : "2",
  47.           "secretPeriodId" : 1,
  48.           "sectId" : "6480640146142464",
  49.           "sectName" : "新奥集团档案局",
  50.           "sectNo" : "A0022",
  51.           "thridId" : "A0022-2020-0000000722",
  52.           "writingDate" : 1650556800000,
  53.           "year" : "2020"
  54.         }
  55.       },
  56.       {
  57.         "_index" : "ermsftrv1",
  58.         "_type" : "_doc",
  59.         "_id" : "6500384144856320",
  60.         "_score" : 1.0,
  61.         "_source" : {
  62.           "annual" : "",
  63.           "archName" : "问题",
  64.           "archNo" : "0022-JS0000-TODO.-TODO-027",
  65.           "archTypeCode" : "JS0000",
  66.           "archTypeId" : "6485924961527040",
  67.           "archTypeName" : "建设项目",
  68.           "archivedDate" : 1587548214000,
  69.           "archivedDep" : "1753-11-11 00:00:00",
  70.           "archivedOperator" : "",
  71.           "documentPage" : 0,
  72.           "entityTypeId" : 1,
  73.           "expDate" : -6820704000000,
  74.           "fileNo" : "",
  75.           "handlerId" : 6502597485647104,
  76.           "id" : "6500384144856320",
  77.           "pageNum" : "1",
  78.           "picPage" : 0,
  79.           "responsibleDept" : "",
  80.           "responsibleOper" : "hanfeixian",
  81.           "savePeriod" : "永久",
  82.           "savePeriodId" : "1",
  83.           "secret" : "普通商密",
  84.           "secretExpDate" : 1650038400000,
  85.           "secretId" : "2",
  86.           "secretPeriodId" : 9,
  87.           "sectId" : "6480640146142464",
  88.           "sectName" : "新奥集团档案局",
  89.           "sectNo" : "A0022",
  90.           "thridId" : "A0022-2020-0000000723",
  91.           "writingDate" : 1650038400000,
  92.           "year" : "2020"
  93.         }
  94.       },
  95.       {
  96.         "_index" : "ermsftrv1",
  97.         "_type" : "_doc",
  98.         "_id" : "6503214760639744",
  99.         "_score" : 1.0,
  100.         "_source" : {
  101.           "annual" : "2020",
  102.           "archName" : "曹操出行-2行程单",
  103.           "archNo" : "0022-ZZ0100.TODO-03-006",
  104.           "archTypeCode" : "ZZ0100",
  105.           "archTypeId" : "6489894262050048",
  106.           "archTypeName" : "01 企业证照",
  107.           "archivedDate" : 1587699428000,
  108.           "archivedDep" : "1753-11-11 00:00:00",
  109.           "archivedOperator" : "",
  110.           "documentPage" : 0,
  111.           "entityTypeId" : 1,
  112.           "expDate" : -6820704000000,
  113.           "fileNo" : "",
  114.           "handlerId" : 6503216857251072,
  115.           "id" : "6503214760639744",
  116.           "pageNum" : "0",
  117.           "picPage" : 0,
  118.           "responsibleDept" : "",
  119.           "responsibleOper" : "zhangjunk",
  120.           "savePeriod" : "30年",
  121.           "savePeriodId" : "3",
  122.           "secret" : "核心商密",
  123.           "secretExpDate" : 1638633600000,
  124.           "secretId" : "3",
  125.           "secretPeriodId" : 1,
  126.           "sectId" : "6480626827621632",
  127.           "sectName" : "新奥集团股份有限公司",
  128.           "sectNo" : "A0022",
  129.           "thridId" : "A0022-2020-0000000187",
  130.           "writingDate" : 1638633600000,
  131.           "year" : "2020"
  132.         }
  133.       },
  134.       {
  135.         "_index" : "ermsftrv1",
  136.         "_type" : "_doc",
  137.         "_id" : "6503218290695424",
  138.         "_score" : 1.0,
  139.         "_source" : {
  140.           "annual" : "",
  141.           "archName" : "消息接入规范",
  142.           "archNo" : "0022-ZZ0200.TODO-K093-002",
  143.           "archTypeCode" : "ZZ0200",
  144.           "archTypeId" : "6495573858862336",
  145.           "archTypeName" : "02 领导证照",
  146.           "archivedDate" : 1587709784000,
  147.           "archivedDep" : "1753-11-11 00:00:00",
  148.           "archivedOperator" : "",
  149.           "documentPage" : 0,
  150.           "entityTypeId" : 2,
  151.           "expDate" : 1619258366000,
  152.           "fileNo" : "",
  153.           "handlerId" : 6503218290752768,
  154.           "id" : "6503218290695424",
  155.           "pageNum" : "0",
  156.           "picPage" : 0,
  157.           "responsibleDept" : "",
  158.           "responsibleOper" : "zhangjunk",
  159.           "savePeriod" : "永久",
  160.           "savePeriodId" : "1",
  161.           "secret" : "核心商密",
  162.           "secretExpDate" : 1808560781000,
  163.           "secretId" : "3",
  164.           "secretPeriodId" : 7,
  165.           "sectId" : "6480626827621632",
  166.           "sectName" : "新奥集团股份有限公司",
  167.           "sectNo" : "A0022",
  168.           "thridId" : "A0022-2020-0000000318",
  169.           "writingDate" : 1584547200000,
  170.           "year" : "2020"
  171.         }
  172.       },
  173.       {
  174.         "_index" : "ermsftrv1",
  175.         "_type" : "_doc",
  176.         "_id" : "6503265140862208",
  177.         "_score" : 1.0,
  178.         "_source" : {
  179.           "annual" : "",
  180.           "archName" : "新奥档案系统-项目进度计划-20200408",
  181.           "archNo" : "0022-ZZ0200.TODO-null-010",
  182.           "archTypeCode" : "ZZ0200",
  183.           "archTypeId" : "6495573858862336",
  184.           "archTypeName" : "02 领导证照",
  185.           "archivedDate" : 1587711282000,
  186.           "archivedDep" : "1753-11-11 00:00:00",
  187.           "archivedOperator" : "",
  188.           "documentPage" : 0,
  189.           "entityTypeId" : 1,
  190.           "expDate" : -6820704000000,
  191.           "fileNo" : "",
  192.           "handlerId" : 6503265140927744,
  193.           "id" : "6503265140862208",
  194.           "pageNum" : "0",
  195.           "picPage" : 0,
  196.           "responsibleDept" : "",
  197.           "responsibleOper" : "zhangjunk",
  198.           "savePeriod" : "永久",
  199.           "savePeriodId" : "1",
  200.           "secret" : "核心商密",
  201.           "secretExpDate" : 1649347200000,
  202.           "secretId" : "3",
  203.           "secretPeriodId" : 1,
  204.           "sectId" : "6480640146142464",
  205.           "sectName" : "新奥集团档案局",
  206.           "sectNo" : "A0022",
  207.           "thridId" : "A0022-2020-0000000768",
  208.           "writingDate" : 1649347200000,
  209.           "year" : "2020"
  210.         }
  211.       },
  212.       {
  213.         "_index" : "ermsftrv1",
  214.         "_type" : "_doc",
  215.         "_id" : "6503265140526336",
  216.         "_score" : 1.0,
  217.         "_source" : {
  218.           "annual" : "",
  219.           "archName" : "新奥档案系统-项目进度计划-20200415",
  220.           "archNo" : "0022-ZZ0200.TODO-null-011",
  221.           "archTypeCode" : "ZZ0200",
  222.           "archTypeId" : "6495573858862336",
  223.           "archTypeName" : "02 领导证照",
  224.           "archivedDate" : 1587711282000,
  225.           "archivedDep" : "1753-11-11 00:00:00",
  226.           "archivedOperator" : "",
  227.           "documentPage" : 0,
  228.           "entityTypeId" : 1,
  229.           "expDate" : -6820704000000,
  230.           "fileNo" : "",
  231.           "handlerId" : 6503265411443968,
  232.           "id" : "6503265140526336",
  233.           "pageNum" : "0",
  234.           "picPage" : 0,
  235.           "responsibleDept" : "",
  236.           "responsibleOper" : "zhangjunk",
  237.           "savePeriod" : "永久",
  238.           "savePeriodId" : "1",
  239.           "secret" : "普通商密",
  240.           "secretExpDate" : 1650384000000,
  241.           "secretId" : "2",
  242.           "secretPeriodId" : 1,
  243.           "sectId" : "6480640146142464",
  244.           "sectName" : "新奥集团档案局",
  245.           "sectNo" : "A0022",
  246.           "thridId" : "A0022-2020-0000000769",
  247.           "writingDate" : 1650384000000,
  248.           "year" : "2020"
  249.         }
  250.       }
  251.     ]
  252.   }
  253. }

实现archTypeId和year做聚合实现平级分组。

kibana：

  1. POST ermsftrv1/_search
  2. {
  3.   "aggs": {
  4.     "archTypeGroup": {
  5.       "terms": {
  6.         "field": "archTypeId.keyword",
  7.         "size": 10
  8.       }
  9.     },
  10.     "yearGroup": {
  11.       "terms": {
  12.         "field": "year.keyword",
  13.         "size": 10
  14.       }
  15.     }
  16.   }
  17. }

结果：

  1. {
  2.   "took" : 1,
  3.   "timed_out" : false,
  4.   "_shards" : {
  5.     "total" : 1,
  6.     "successful" : 1,
  7.     "skipped" : 0,
  8.     "failed" : 0
  9.   },
  10.   "hits" : {
  11.     "total" : {
  12.       "value" : 6,
  13.       "relation" : "eq"
  14.     },
  15.     "max_score" : 1.0,
  16.     "hits" : [
  17.       {
  18.         "_index" : "ermsftrv1",
  19.         "_type" : "_doc",
  20.         "_id" : "6502586031240448",
  21.         "_score" : 1.0,
  22.         "_source" : {
  23.           "annual" : "",
  24.           "archName" : "新建文本文档",
  25.           "archNo" : "0022-SB0000.TODO-TODO-001",
  26.           "archTypeCode" : "SB0000",
  27.           "archTypeId" : "6485930821313792",
  28.           "archTypeName" : "设备仪器",
  29.           "archivedDate" : 1587545484000,
  30.           "archivedDep" : "1753-11-11 00:00:00",
  31.           "archivedOperator" : "",
  32.           "documentPage" : 0,
  33.           "entityTypeId" : 1,
  34.           "expDate" : -6820704000000,
  35.           "fileNo" : "",
  36.           "handlerId" : 6502586302145792,
  37.           "id" : "6502586031240448",
  38.           "pageNum" : "0",
  39.           "picPage" : 0,
  40.           "responsibleDept" : "",
  41.           "responsibleOper" : "hanfeixian",
  42.           "savePeriod" : "永久",
  43.           "savePeriodId" : "1",
  44.           "secret" : "普通商密",
  45.           "secretExpDate" : 1650556800000,
  46.           "secretId" : "2",
  47.           "secretPeriodId" : 1,
  48.           "sectId" : "6480640146142464",
  49.           "sectName" : "新奥集团档案局",
  50.           "sectNo" : "A0022",
  51.           "thridId" : "A0022-2020-0000000722",
  52.           "writingDate" : 1650556800000,
  53.           "year" : "2020"
  54.         }
  55.       },
  56.       {
  57.         "_index" : "ermsftrv1",
  58.         "_type" : "_doc",
  59.         "_id" : "6500384144856320",
  60.         "_score" : 1.0,
  61.         "_source" : {
  62.           "annual" : "",
  63.           "archName" : "问题",
  64.           "archNo" : "0022-JS0000-TODO.-TODO-027",
  65.           "archTypeCode" : "JS0000",
  66.           "archTypeId" : "6485924961527040",
  67.           "archTypeName" : "建设项目",
  68.           "archivedDate" : 1587548214000,
  69.           "archivedDep" : "1753-11-11 00:00:00",
  70.           "archivedOperator" : "",
  71.           "documentPage" : 0,
  72.           "entityTypeId" : 1,
  73.           "expDate" : -6820704000000,
  74.           "fileNo" : "",
  75.           "handlerId" : 6502597485647104,
  76.           "id" : "6500384144856320",
  77.           "pageNum" : "1",
  78.           "picPage" : 0,
  79.           "responsibleDept" : "",
  80.           "responsibleOper" : "hanfeixian",
  81.           "savePeriod" : "永久",
  82.           "savePeriodId" : "1",
  83.           "secret" : "普通商密",
  84.           "secretExpDate" : 1650038400000,
  85.           "secretId" : "2",
  86.           "secretPeriodId" : 9,
  87.           "sectId" : "6480640146142464",
  88.           "sectName" : "新奥集团档案局",
  89.           "sectNo" : "A0022",
  90.           "thridId" : "A0022-2020-0000000723",
  91.           "writingDate" : 1650038400000,
  92.           "year" : "2020"
  93.         }
  94.       },
  95.       {
  96.         "_index" : "ermsftrv1",
  97.         "_type" : "_doc",
  98.         "_id" : "6503214760639744",
  99.         "_score" : 1.0,
  100.         "_source" : {
  101.           "annual" : "2020",
  102.           "archName" : "曹操出行-2行程单",
  103.           "archNo" : "0022-ZZ0100.TODO-03-006",
  104.           "archTypeCode" : "ZZ0100",
  105.           "archTypeId" : "6489894262050048",
  106.           "archTypeName" : "01 企业证照",
  107.           "archivedDate" : 1587699428000,
  108.           "archivedDep" : "1753-11-11 00:00:00",
  109.           "archivedOperator" : "",
  110.           "documentPage" : 0,
  111.           "entityTypeId" : 1,
  112.           "expDate" : -6820704000000,
  113.           "fileNo" : "",
  114.           "handlerId" : 6503216857251072,
  115.           "id" : "6503214760639744",
  116.           "pageNum" : "0",
  117.           "picPage" : 0,
  118.           "responsibleDept" : "",
  119.           "responsibleOper" : "zhangjunk",
  120.           "savePeriod" : "30年",
  121.           "savePeriodId" : "3",
  122.           "secret" : "核心商密",
  123.           "secretExpDate" : 1638633600000,
  124.           "secretId" : "3",
  125.           "secretPeriodId" : 1,
  126.           "sectId" : "6480626827621632",
  127.           "sectName" : "新奥集团股份有限公司",
  128.           "sectNo" : "A0022",
  129.           "thridId" : "A0022-2020-0000000187",
  130.           "writingDate" : 1638633600000,
  131.           "year" : "2020"
  132.         }
  133.       },
  134.       {
  135.         "_index" : "ermsftrv1",
  136.         "_type" : "_doc",
  137.         "_id" : "6503218290695424",
  138.         "_score" : 1.0,
  139.         "_source" : {
  140.           "annual" : "",
  141.           "archName" : "消息接入规范",
  142.           "archNo" : "0022-ZZ0200.TODO-K093-002",
  143.           "archTypeCode" : "ZZ0200",
  144.           "archTypeId" : "6495573858862336",
  145.           "archTypeName" : "02 领导证照",
  146.           "archivedDate" : 1587709784000,
  147.           "archivedDep" : "1753-11-11 00:00:00",
  148.           "archivedOperator" : "",
  149.           "documentPage" : 0,
  150.           "entityTypeId" : 2,
  151.           "expDate" : 1619258366000,
  152.           "fileNo" : "",
  153.           "handlerId" : 6503218290752768,
  154.           "id" : "6503218290695424",
  155.           "pageNum" : "0",
  156.           "picPage" : 0,
  157.           "responsibleDept" : "",
  158.           "responsibleOper" : "zhangjunk",
  159.           "savePeriod" : "永久",
  160.           "savePeriodId" : "1",
  161.           "secret" : "核心商密",
  162.           "secretExpDate" : 1808560781000,
  163.           "secretId" : "3",
  164.           "secretPeriodId" : 7,
  165.           "sectId" : "6480626827621632",
  166.           "sectName" : "新奥集团股份有限公司",
  167.           "sectNo" : "A0022",
  168.           "thridId" : "A0022-2020-0000000318",
  169.           "writingDate" : 1584547200000,
  170.           "year" : "2020"
  171.         }
  172.       },
  173.       {
  174.         "_index" : "ermsftrv1",
  175.         "_type" : "_doc",
  176.         "_id" : "6503265140862208",
  177.         "_score" : 1.0,
  178.         "_source" : {
  179.           "annual" : "",
  180.           "archName" : "新奥档案系统-项目进度计划-20200408",
  181.           "archNo" : "0022-ZZ0200.TODO-null-010",
  182.           "archTypeCode" : "ZZ0200",
  183.           "archTypeId" : "6495573858862336",
  184.           "archTypeName" : "02 领导证照",
  185.           "archivedDate" : 1587711282000,
  186.           "archivedDep" : "1753-11-11 00:00:00",
  187.           "archivedOperator" : "",
  188.           "documentPage" : 0,
  189.           "entityTypeId" : 1,
  190.           "expDate" : -6820704000000,
  191.           "fileNo" : "",
  192.           "handlerId" : 6503265140927744,
  193.           "id" : "6503265140862208",
  194.           "pageNum" : "0",
  195.           "picPage" : 0,
  196.           "responsibleDept" : "",
  197.           "responsibleOper" : "zhangjunk",
  198.           "savePeriod" : "永久",
  199.           "savePeriodId" : "1",
  200.           "secret" : "核心商密",
  201.           "secretExpDate" : 1649347200000,
  202.           "secretId" : "3",
  203.           "secretPeriodId" : 1,
  204.           "sectId" : "6480640146142464",
  205.           "sectName" : "新奥集团档案局",
  206.           "sectNo" : "A0022",
  207.           "thridId" : "A0022-2020-0000000768",
  208.           "writingDate" : 1649347200000,
  209.           "year" : "2020"
  210.         }
  211.       },
  212.       {
  213.         "_index" : "ermsftrv1",
  214.         "_type" : "_doc",
  215.         "_id" : "6503265140526336",
  216.         "_score" : 1.0,
  217.         "_source" : {
  218.           "annual" : "",
  219.           "archName" : "新奥档案系统-项目进度计划-20200415",
  220.           "archNo" : "0022-ZZ0200.TODO-null-011",
  221.           "archTypeCode" : "ZZ0200",
  222.           "archTypeId" : "6495573858862336",
  223.           "archTypeName" : "02 领导证照",
  224.           "archivedDate" : 1587711282000,
  225.           "archivedDep" : "1753-11-11 00:00:00",
  226.           "archivedOperator" : "",
  227.           "documentPage" : 0,
  228.           "entityTypeId" : 1,
  229.           "expDate" : -6820704000000,
  230.           "fileNo" : "",
  231.           "handlerId" : 6503265411443968,
  232.           "id" : "6503265140526336",
  233.           "pageNum" : "0",
  234.           "picPage" : 0,
  235.           "responsibleDept" : "",
  236.           "responsibleOper" : "zhangjunk",
  237.           "savePeriod" : "永久",
  238.           "savePeriodId" : "1",
  239.           "secret" : "普通商密",
  240.           "secretExpDate" : 1650384000000,
  241.           "secretId" : "2",
  242.           "secretPeriodId" : 1,
  243.           "sectId" : "6480640146142464",
  244.           "sectName" : "新奥集团档案局",
  245.           "sectNo" : "A0022",
  246.           "thridId" : "A0022-2020-0000000769",
  247.           "writingDate" : 1650384000000,
  248.           "year" : "2020"
  249.         }
  250.       }
  251.     ]
  252.   },
  253.   "aggregations" : {
  254.     "yearGroup" : {
  255.       "doc_count_error_upper_bound" : 0,
  256.       "sum_other_doc_count" : 0,
  257.       "buckets" : [
  258.         {
  259.           "key" : "2020",
  260.           "doc_count" : 6
  261.         }
  262.       ]
  263.     },
  264.     "archTypeGroup" : {
  265.       "doc_count_error_upper_bound" : 0,
  266.       "sum_other_doc_count" : 0,
  267.       "buckets" : [
  268.         {
  269.           "key" : "6495573858862336",
  270.           "doc_count" : 3
  271.         },
  272.         {
  273.           "key" : "6485924961527040",
  274.           "doc_count" : 1
  275.         },
  276.         {
  277.           "key" : "6485930821313792",
  278.           "doc_count" : 1
  279.         },
  280.         {
  281.           "key" : "6489894262050048",
  282.           "doc_count" : 1
  283.         }
  284.       ]
  285.     }
  286.   }
  287. }

java springboot实现：

  1. SearchRequest searchRequest = new SearchRequest(ermsesProperties.getIndex());
  2. SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();            
  3. //第一个字段进行分组
  4. TermsAggregationBuilder yearGroupAgg = AggregationBuilders.terms("yearGroup").field("year.keyword");
  5. //根据第二个字段进行分组
  6. TermsAggregationBuilder archTypeGroupAgg = AggregationBuilders.terms("archTypeGroup").field("archTypeId.keyword");
  7. //如果存在第三个，以此类推...
  8. //只需要平级添加聚合条件即可
  9. sourceBuilder.aggregation(yearGroupAgg);
  10. sourceBuilder.aggregation(archTypeGroupAgg);
  11. searchRequest.source(sourceBuilder);

第二部、实现平级+层级分组聚合

实现archTypeId和year做聚合实现平级分组，同时实现archTypeId和secret层级聚合分组（也是百度中大篇幅的层级聚合分组）。

kibana：

  1. POST ermsftrv1/_search
  2. {
  3.   "aggs": {
  4.     "archTypeGroup": {
  5.       "terms": {
  6.         "field": "archTypeId.keyword",
  7.         "size": 10
  8.       },
  9.       "aggs": {
  10.         "secretGroup": {
  11.           "terms": {
  12.             "field": "secret.keyword"
  13.           }
  14.         }
  15.       }
  16.     },
  17.     "yearGroup": {
  18.       "terms": {
  19.         "field": "year.keyword",
  20.         "size": 10
  21.       }
  22.     }
  23.   }
  24. }

结果：

  1. {
  2.   "took" : 2,
  3.   "timed_out" : false,
  4.   "_shards" : {
  5.     "total" : 1,
  6.     "successful" : 1,
  7.     "skipped" : 0,
  8.     "failed" : 0
  9.   },
  10.   "hits" : {
  11.     "total" : {
  12.       "value" : 6,
  13.       "relation" : "eq"
  14.     },
  15.     "max_score" : 1.0,
  16.     "hits" : [
  17.       {
  18.         "_index" : "ermsftrv1",
  19.         "_type" : "_doc",
  20.         "_id" : "6502586031240448",
  21.         "_score" : 1.0,
  22.         "_source" : {
  23.           "annual" : "",
  24.           "archName" : "新建文本文档",
  25.           "archNo" : "0022-SB0000.TODO-TODO-001",
  26.           "archTypeCode" : "SB0000",
  27.           "archTypeId" : "6485930821313792",
  28.           "archTypeName" : "设备仪器",
  29.           "archivedDate" : 1587545484000,
  30.           "archivedDep" : "1753-11-11 00:00:00",
  31.           "archivedOperator" : "",
  32.           "documentPage" : 0,
  33.           "entityTypeId" : 1,
  34.           "expDate" : -6820704000000,
  35.           "fileNo" : "",
  36.           "handlerId" : 6502586302145792,
  37.           "id" : "6502586031240448",
  38.           "pageNum" : "0",
  39.           "picPage" : 0,
  40.           "responsibleDept" : "",
  41.           "responsibleOper" : "hanfeixian",
  42.           "savePeriod" : "永久",
  43.           "savePeriodId" : "1",
  44.           "secret" : "普通商密",
  45.           "secretExpDate" : 1650556800000,
  46.           "secretId" : "2",
  47.           "secretPeriodId" : 1,
  48.           "sectId" : "6480640146142464",
  49.           "sectName" : "新奥集团档案局",
  50.           "sectNo" : "A0022",
  51.           "thridId" : "A0022-2020-0000000722",
  52.           "writingDate" : 1650556800000,
  53.           "year" : "2020"
  54.         }
  55.       },
  56.       {
  57.         "_index" : "ermsftrv1",
  58.         "_type" : "_doc",
  59.         "_id" : "6500384144856320",
  60.         "_score" : 1.0,
  61.         "_source" : {
  62.           "annual" : "",
  63.           "archName" : "问题",
  64.           "archNo" : "0022-JS0000-TODO.-TODO-027",
  65.           "archTypeCode" : "JS0000",
  66.           "archTypeId" : "6485924961527040",
  67.           "archTypeName" : "建设项目",
  68.           "archivedDate" : 1587548214000,
  69.           "archivedDep" : "1753-11-11 00:00:00",
  70.           "archivedOperator" : "",
  71.           "documentPage" : 0,
  72.           "entityTypeId" : 1,
  73.           "expDate" : -6820704000000,
  74.           "fileNo" : "",
  75.           "handlerId" : 6502597485647104,
  76.           "id" : "6500384144856320",
  77.           "pageNum" : "1",
  78.           "picPage" : 0,
  79.           "responsibleDept" : "",
  80.           "responsibleOper" : "hanfeixian",
  81.           "savePeriod" : "永久",
  82.           "savePeriodId" : "1",
  83.           "secret" : "普通商密",
  84.           "secretExpDate" : 1650038400000,
  85.           "secretId" : "2",
  86.           "secretPeriodId" : 9,
  87.           "sectId" : "6480640146142464",
  88.           "sectName" : "新奥集团档案局",
  89.           "sectNo" : "A0022",
  90.           "thridId" : "A0022-2020-0000000723",
  91.           "writingDate" : 1650038400000,
  92.           "year" : "2020"
  93.         }
  94.       },
  95.       {
  96.         "_index" : "ermsftrv1",
  97.         "_type" : "_doc",
  98.         "_id" : "6503214760639744",
  99.         "_score" : 1.0,
  100.         "_source" : {
  101.           "annual" : "2020",
  102.           "archName" : "曹操出行-2行程单",
  103.           "archNo" : "0022-ZZ0100.TODO-03-006",
  104.           "archTypeCode" : "ZZ0100",
  105.           "archTypeId" : "6489894262050048",
  106.           "archTypeName" : "01 企业证照",
  107.           "archivedDate" : 1587699428000,
  108.           "archivedDep" : "1753-11-11 00:00:00",
  109.           "archivedOperator" : "",
  110.           "documentPage" : 0,
  111.           "entityTypeId" : 1,
  112.           "expDate" : -6820704000000,
  113.           "fileNo" : "",
  114.           "handlerId" : 6503216857251072,
  115.           "id" : "6503214760639744",
  116.           "pageNum" : "0",
  117.           "picPage" : 0,
  118.           "responsibleDept" : "",
  119.           "responsibleOper" : "zhangjunk",
  120.           "savePeriod" : "30年",
  121.           "savePeriodId" : "3",
  122.           "secret" : "核心商密",
  123.           "secretExpDate" : 1638633600000,
  124.           "secretId" : "3",
  125.           "secretPeriodId" : 1,
  126.           "sectId" : "6480626827621632",
  127.           "sectName" : "新奥集团股份有限公司",
  128.           "sectNo" : "A0022",
  129.           "thridId" : "A0022-2020-0000000187",
  130.           "writingDate" : 1638633600000,
  131.           "year" : "2020"
  132.         }
  133.       },
  134.       {
  135.         "_index" : "ermsftrv1",
  136.         "_type" : "_doc",
  137.         "_id" : "6503218290695424",
  138.         "_score" : 1.0,
  139.         "_source" : {
  140.           "annual" : "",
  141.           "archName" : "消息接入规范",
  142.           "archNo" : "0022-ZZ0200.TODO-K093-002",
  143.           "archTypeCode" : "ZZ0200",
  144.           "archTypeId" : "6495573858862336",
  145.           "archTypeName" : "02 领导证照",
  146.           "archivedDate" : 1587709784000,
  147.           "archivedDep" : "1753-11-11 00:00:00",
  148.           "archivedOperator" : "",
  149.           "documentPage" : 0,
  150.           "entityTypeId" : 2,
  151.           "expDate" : 1619258366000,
  152.           "fileNo" : "",
  153.           "handlerId" : 6503218290752768,
  154.           "id" : "6503218290695424",
  155.           "pageNum" : "0",
  156.           "picPage" : 0,
  157.           "responsibleDept" : "",
  158.           "responsibleOper" : "zhangjunk",
  159.           "savePeriod" : "永久",
  160.           "savePeriodId" : "1",
  161.           "secret" : "核心商密",
  162.           "secretExpDate" : 1808560781000,
  163.           "secretId" : "3",
  164.           "secretPeriodId" : 7,
  165.           "sectId" : "6480626827621632",
  166.           "sectName" : "新奥集团股份有限公司",
  167.           "sectNo" : "A0022",
  168.           "thridId" : "A0022-2020-0000000318",
  169.           "writingDate" : 1584547200000,
  170.           "year" : "2020"
  171.         }
  172.       },
  173.       {
  174.         "_index" : "ermsftrv1",
  175.         "_type" : "_doc",
  176.         "_id" : "6503265140862208",
  177.         "_score" : 1.0,
  178.         "_source" : {
  179.           "annual" : "",
  180.           "archName" : "新奥档案系统-项目进度计划-20200408",
  181.           "archNo" : "0022-ZZ0200.TODO-null-010",
  182.           "archTypeCode" : "ZZ0200",
  183.           "archTypeId" : "6495573858862336",
  184.           "archTypeName" : "02 领导证照",
  185.           "archivedDate" : 1587711282000,
  186.           "archivedDep" : "1753-11-11 00:00:00",
  187.           "archivedOperator" : "",
  188.           "documentPage" : 0,
  189.           "entityTypeId" : 1,
  190.           "expDate" : -6820704000000,
  191.           "fileNo" : "",
  192.           "handlerId" : 6503265140927744,
  193.           "id" : "6503265140862208",
  194.           "pageNum" : "0",
  195.           "picPage" : 0,
  196.           "responsibleDept" : "",
  197.           "responsibleOper" : "zhangjunk",
  198.           "savePeriod" : "永久",
  199.           "savePeriodId" : "1",
  200.           "secret" : "核心商密",
  201.           "secretExpDate" : 1649347200000,
  202.           "secretId" : "3",
  203.           "secretPeriodId" : 1,
  204.           "sectId" : "6480640146142464",
  205.           "sectName" : "新奥集团档案局",
  206.           "sectNo" : "A0022",
  207.           "thridId" : "A0022-2020-0000000768",
  208.           "writingDate" : 1649347200000,
  209.           "year" : "2020"
  210.         }
  211.       },
  212.       {
  213.         "_index" : "ermsftrv1",
  214.         "_type" : "_doc",
  215.         "_id" : "6503265140526336",
  216.         "_score" : 1.0,
  217.         "_source" : {
  218.           "annual" : "",
  219.           "archName" : "新奥档案系统-项目进度计划-20200415",
  220.           "archNo" : "0022-ZZ0200.TODO-null-011",
  221.           "archTypeCode" : "ZZ0200",
  222.           "archTypeId" : "6495573858862336",
  223.           "archTypeName" : "02 领导证照",
  224.           "archivedDate" : 1587711282000,
  225.           "archivedDep" : "1753-11-11 00:00:00",
  226.           "archivedOperator" : "",
  227.           "documentPage" : 0,
  228.           "entityTypeId" : 1,
  229.           "expDate" : -6820704000000,
  230.           "fileNo" : "",
  231.           "handlerId" : 6503265411443968,
  232.           "id" : "6503265140526336",
  233.           "pageNum" : "0",
  234.           "picPage" : 0,
  235.           "responsibleDept" : "",
  236.           "responsibleOper" : "zhangjunk",
  237.           "savePeriod" : "永久",
  238.           "savePeriodId" : "1",
  239.           "secret" : "普通商密",
  240.           "secretExpDate" : 1650384000000,
  241.           "secretId" : "2",
  242.           "secretPeriodId" : 1,
  243.           "sectId" : "6480640146142464",
  244.           "sectName" : "新奥集团档案局",
  245.           "sectNo" : "A0022",
  246.           "thridId" : "A0022-2020-0000000769",
  247.           "writingDate" : 1650384000000,
  248.           "year" : "2020"
  249.         }
  250.       }
  251.     ]
  252.   },
  253.   "aggregations" : {
  254.     "yearGroup" : {
  255.       "doc_count_error_upper_bound" : 0,
  256.       "sum_other_doc_count" : 0,
  257.       "buckets" : [
  258.         {
  259.           "key" : "2020",
  260.           "doc_count" : 6
  261.         }
  262.       ]
  263.     },
  264.     "archTypeGroup" : {
  265.       "doc_count_error_upper_bound" : 0,
  266.       "sum_other_doc_count" : 0,
  267.       "buckets" : [
  268.         {
  269.           "key" : "6495573858862336",
  270.           "doc_count" : 3,
  271.           "secretGroup" : {
  272.             "doc_count_error_upper_bound" : 0,
  273.             "sum_other_doc_count" : 0,
  274.             "buckets" : [
  275.               {
  276.                 "key" : "核心商密",
  277.                 "doc_count" : 2
  278.               },
  279.               {
  280.                 "key" : "普通商密",
  281.                 "doc_count" : 1
  282.               }
  283.             ]
  284.           }
  285.         },
  286.         {
  287.           "key" : "6485924961527040",
  288.           "doc_count" : 1,
  289.           "secretGroup" : {
  290.             "doc_count_error_upper_bound" : 0,
  291.             "sum_other_doc_count" : 0,
  292.             "buckets" : [
  293.               {
  294.                 "key" : "普通商密",
  295.                 "doc_count" : 1
  296.               }
  297.             ]
  298.           }
  299.         },
  300.         {
  301.           "key" : "6485930821313792",
  302.           "doc_count" : 1,
  303.           "secretGroup" : {
  304.             "doc_count_error_upper_bound" : 0,
  305.             "sum_other_doc_count" : 0,
  306.             "buckets" : [
  307.               {
  308.                 "key" : "普通商密",
  309.                 "doc_count" : 1
  310.               }
  311.             ]
  312.           }
  313.         },
  314.         {
  315.           "key" : "6489894262050048",
  316.           "doc_count" : 1,
  317.           "secretGroup" : {
  318.             "doc_count_error_upper_bound" : 0,
  319.             "sum_other_doc_count" : 0,
  320.             "buckets" : [
  321.               {
  322.                 "key" : "核心商密",
  323.                 "doc_count" : 1
  324.               }
  325.             ]
  326.           }
  327.         }
  328.       ]
  329.     }
  330.   }
  331. }

java实现：

  1. SearchRequest searchRequest = new SearchRequest(ermsesProperties.getIndex());
  2. SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();            
  3. //第一个字段进行分组
  4. TermsAggregationBuilder yearGroupAgg = AggregationBuilders.terms("yearGroup").field("year.keyword");
  5. //根据第二个字段进行分组
  6. TermsAggregationBuilder archTypeGroupAgg = AggregationBuilders.terms("archTypeGroup").field("archTypeId.keyword");
  7. //自己聚合分组，生命方式一样
  8. TermsAggregationBuilder secretGroup = AggregationBuilders.terms("secretGroup").field("secret.keyword");
  9. //只需要平级添加聚合条件即可
  10. sourceBuilder.aggregation(yearGroupAgg);
  11. //设置聚合分组时，同事设置子分组（子层级）
  12. sourceBuilder.aggregation(archTypeGroupAgg.subAggregation(secretGroup));
  13. searchRequest.source(sourceBuilder);

第三部、script实现多字段查询

实现archTypeId和year平级聚合分组，同事查询出archTypeId对应的中文名称archTypeName。其中#split#是自定义的。

kibana：

  1. POST ermsftrv1/_search
  2. {
  3.   "aggs": {
  4.     "archTypeGroup": {
  5.       "terms": {
  6.         "script": "doc['archTypeId.keyword'].value +'#split#'+ doc['archTypeName.keyword'].value",
  7.         "size": 10
  8.       }
  9.     },
  10.     "yearGroup": {
  11.       "terms": {
  12.         "field": "year.keyword",
  13.         "size": 10
  14.       }
  15.     }
  16.   }
  17. }

结果：

  1. {
  2.   "took" : 1,
  3.   "timed_out" : false,
  4.   "_shards" : {
  5.     "total" : 1,
  6.     "successful" : 1,
  7.     "skipped" : 0,
  8.     "failed" : 0
  9.   },
  10.   "hits" : {
  11.     "total" : {
  12.       "value" : 6,
  13.       "relation" : "eq"
  14.     },
  15.     "max_score" : 1.0,
  16.     "hits" : [
  17.       {
  18.         "_index" : "ermsftrv1",
  19.         "_type" : "_doc",
  20.         "_id" : "6502586031240448",
  21.         "_score" : 1.0,
  22.         "_source" : {
  23.           "annual" : "",
  24.           "archName" : "新建文本文档",
  25.           "archNo" : "0022-SB0000.TODO-TODO-001",
  26.           "archTypeCode" : "SB0000",
  27.           "archTypeId" : "6485930821313792",
  28.           "archTypeName" : "设备仪器",
  29.           "archivedDate" : 1587545484000,
  30.           "archivedDep" : "1753-11-11 00:00:00",
  31.           "archivedOperator" : "",
  32.           "documentPage" : 0,
  33.           "entityTypeId" : 1,
  34.           "expDate" : -6820704000000,
  35.           "fileNo" : "",
  36.           "handlerId" : 6502586302145792,
  37.           "id" : "6502586031240448",
  38.           "pageNum" : "0",
  39.           "picPage" : 0,
  40.           "responsibleDept" : "",
  41.           "responsibleOper" : "hanfeixian",
  42.           "savePeriod" : "永久",
  43.           "savePeriodId" : "1",
  44.           "secret" : "普通商密",
  45.           "secretExpDate" : 1650556800000,
  46.           "secretId" : "2",
  47.           "secretPeriodId" : 1,
  48.           "sectId" : "6480640146142464",
  49.           "sectName" : "新奥集团档案局",
  50.           "sectNo" : "A0022",
  51.           "thridId" : "A0022-2020-0000000722",
  52.           "writingDate" : 1650556800000,
  53.           "year" : "2020"
  54.         }
  55.       },
  56.       {
  57.         "_index" : "ermsftrv1",
  58.         "_type" : "_doc",
  59.         "_id" : "6500384144856320",
  60.         "_score" : 1.0,
  61.         "_source" : {
  62.           "annual" : "",
  63.           "archName" : "问题",
  64.           "archNo" : "0022-JS0000-TODO.-TODO-027",
  65.           "archTypeCode" : "JS0000",
  66.           "archTypeId" : "6485924961527040",
  67.           "archTypeName" : "建设项目",
  68.           "archivedDate" : 1587548214000,
  69.           "archivedDep" : "1753-11-11 00:00:00",
  70.           "archivedOperator" : "",
  71.           "documentPage" : 0,
  72.           "entityTypeId" : 1,
  73.           "expDate" : -6820704000000,
  74.           "fileNo" : "",
  75.           "handlerId" : 6502597485647104,
  76.           "id" : "6500384144856320",
  77.           "pageNum" : "1",
  78.           "picPage" : 0,
  79.           "responsibleDept" : "",
  80.           "responsibleOper" : "hanfeixian",
  81.           "savePeriod" : "永久",
  82.           "savePeriodId" : "1",
  83.           "secret" : "普通商密",
  84.           "secretExpDate" : 1650038400000,
  85.           "secretId" : "2",
  86.           "secretPeriodId" : 9,
  87.           "sectId" : "6480640146142464",
  88.           "sectName" : "新奥集团档案局",
  89.           "sectNo" : "A0022",
  90.           "thridId" : "A0022-2020-0000000723",
  91.           "writingDate" : 1650038400000,
  92.           "year" : "2020"
  93.         }
  94.       },
  95.       {
  96.         "_index" : "ermsftrv1",
  97.         "_type" : "_doc",
  98.         "_id" : "6503214760639744",
  99.         "_score" : 1.0,
  100.         "_source" : {
  101.           "annual" : "2020",
  102.           "archName" : "曹操出行-2行程单",
  103.           "archNo" : "0022-ZZ0100.TODO-03-006",
  104.           "archTypeCode" : "ZZ0100",
  105.           "archTypeId" : "6489894262050048",
  106.           "archTypeName" : "01 企业证照",
  107.           "archivedDate" : 1587699428000,
  108.           "archivedDep" : "1753-11-11 00:00:00",
  109.           "archivedOperator" : "",
  110.           "documentPage" : 0,
  111.           "entityTypeId" : 1,
  112.           "expDate" : -6820704000000,
  113.           "fileNo" : "",
  114.           "handlerId" : 6503216857251072,
  115.           "id" : "6503214760639744",
  116.           "pageNum" : "0",
  117.           "picPage" : 0,
  118.           "responsibleDept" : "",
  119.           "responsibleOper" : "zhangjunk",
  120.           "savePeriod" : "30年",
  121.           "savePeriodId" : "3",
  122.           "secret" : "核心商密",
  123.           "secretExpDate" : 1638633600000,
  124.           "secretId" : "3",
  125.           "secretPeriodId" : 1,
  126.           "sectId" : "6480626827621632",
  127.           "sectName" : "新奥集团股份有限公司",
  128.           "sectNo" : "A0022",
  129.           "thridId" : "A0022-2020-0000000187",
  130.           "writingDate" : 1638633600000,
  131.           "year" : "2020"
  132.         }
  133.       },
  134.       {
  135.         "_index" : "ermsftrv1",
  136.         "_type" : "_doc",
  137.         "_id" : "6503218290695424",
  138.         "_score" : 1.0,
  139.         "_source" : {
  140.           "annual" : "",
  141.           "archName" : "消息接入规范",
  142.           "archNo" : "0022-ZZ0200.TODO-K093-002",
  143.           "archTypeCode" : "ZZ0200",
  144.           "archTypeId" : "6495573858862336",
  145.           "archTypeName" : "02 领导证照",
  146.           "archivedDate" : 1587709784000,
  147.           "archivedDep" : "1753-11-11 00:00:00",
  148.           "archivedOperator" : "",
  149.           "documentPage" : 0,
  150.           "entityTypeId" : 2,
  151.           "expDate" : 1619258366000,
  152.           "fileNo" : "",
  153.           "handlerId" : 6503218290752768,
  154.           "id" : "6503218290695424",
  155.           "pageNum" : "0",
  156.           "picPage" : 0,
  157.           "responsibleDept" : "",
  158.           "responsibleOper" : "zhangjunk",
  159.           "savePeriod" : "永久",
  160.           "savePeriodId" : "1",
  161.           "secret" : "核心商密",
  162.           "secretExpDate" : 1808560781000,
  163.           "secretId" : "3",
  164.           "secretPeriodId" : 7,
  165.           "sectId" : "6480626827621632",
  166.           "sectName" : "新奥集团股份有限公司",
  167.           "sectNo" : "A0022",
  168.           "thridId" : "A0022-2020-0000000318",
  169.           "writingDate" : 1584547200000,
  170.           "year" : "2020"
  171.         }
  172.       },
  173.       {
  174.         "_index" : "ermsftrv1",
  175.         "_type" : "_doc",
  176.         "_id" : "6503265140862208",
  177.         "_score" : 1.0,
  178.         "_source" : {
  179.           "annual" : "",
  180.           "archName" : "新奥档案系统-项目进度计划-20200408",
  181.           "archNo" : "0022-ZZ0200.TODO-null-010",
  182.           "archTypeCode" : "ZZ0200",
  183.           "archTypeId" : "6495573858862336",
  184.           "archTypeName" : "02 领导证照",
  185.           "archivedDate" : 1587711282000,
  186.           "archivedDep" : "1753-11-11 00:00:00",
  187.           "archivedOperator" : "",
  188.           "documentPage" : 0,
  189.           "entityTypeId" : 1,
  190.           "expDate" : -6820704000000,
  191.           "fileNo" : "",
  192.           "handlerId" : 6503265140927744,
  193.           "id" : "6503265140862208",
  194.           "pageNum" : "0",
  195.           "picPage" : 0,
  196.           "responsibleDept" : "",
  197.           "responsibleOper" : "zhangjunk",
  198.           "savePeriod" : "永久",
  199.           "savePeriodId" : "1",
  200.           "secret" : "核心商密",
  201.           "secretExpDate" : 1649347200000,
  202.           "secretId" : "3",
  203.           "secretPeriodId" : 1,
  204.           "sectId" : "6480640146142464",
  205.           "sectName" : "新奥集团档案局",
  206.           "sectNo" : "A0022",
  207.           "thridId" : "A0022-2020-0000000768",
  208.           "writingDate" : 1649347200000,
  209.           "year" : "2020"
  210.         }
  211.       },
  212.       {
  213.         "_index" : "ermsftrv1",
  214.         "_type" : "_doc",
  215.         "_id" : "6503265140526336",
  216.         "_score" : 1.0,
  217.         "_source" : {
  218.           "annual" : "",
  219.           "archName" : "新奥档案系统-项目进度计划-20200415",
  220.           "archNo" : "0022-ZZ0200.TODO-null-011",
  221.           "archTypeCode" : "ZZ0200",
  222.           "archTypeId" : "6495573858862336",
  223.           "archTypeName" : "02 领导证照",
  224.           "archivedDate" : 1587711282000,
  225.           "archivedDep" : "1753-11-11 00:00:00",
  226.           "archivedOperator" : "",
  227.           "documentPage" : 0,
  228.           "entityTypeId" : 1,
  229.           "expDate" : -6820704000000,
  230.           "fileNo" : "",
  231.           "handlerId" : 6503265411443968,
  232.           "id" : "6503265140526336",
  233.           "pageNum" : "0",
  234.           "picPage" : 0,
  235.           "responsibleDept" : "",
  236.           "responsibleOper" : "zhangjunk",
  237.           "savePeriod" : "永久",
  238.           "savePeriodId" : "1",
  239.           "secret" : "普通商密",
  240.           "secretExpDate" : 1650384000000,
  241.           "secretId" : "2",
  242.           "secretPeriodId" : 1,
  243.           "sectId" : "6480640146142464",
  244.           "sectName" : "新奥集团档案局",
  245.           "sectNo" : "A0022",
  246.           "thridId" : "A0022-2020-0000000769",
  247.           "writingDate" : 1650384000000,
  248.           "year" : "2020"
  249.         }
  250.       }
  251.     ]
  252.   },
  253.   "aggregations" : {
  254.     "yearGroup" : {
  255.       "doc_count_error_upper_bound" : 0,
  256.       "sum_other_doc_count" : 0,
  257.       "buckets" : [
  258.         {
  259.           "key" : "2020",
  260.           "doc_count" : 6
  261.         }
  262.       ]
  263.     },
  264.     "archTypeGroup" : {
  265.       "doc_count_error_upper_bound" : 0,
  266.       "sum_other_doc_count" : 0,
  267.       "buckets" : [
  268.         {
  269.           "key" : "6495573858862336#split#02 领导证照",
  270.           "doc_count" : 3
  271.         },
  272.         {
  273.           "key" : "6485924961527040#split#建设项目",
  274.           "doc_count" : 1
  275.         },
  276.         {
  277.           "key" : "6485930821313792#split#设备仪器",
  278.           "doc_count" : 1
  279.         },
  280.         {
  281.           "key" : "6489894262050048#split#01 企业证照",
  282.           "doc_count" : 1
  283.         }
  284.       ]
  285.     }
  286.   }
  287. }

java实现：

  1. SearchRequest searchRequest = new SearchRequest(ermsesProperties.getIndex());
  2. SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();            
  3. //第一个字段进行分组
  4. TermsAggregationBuilder yearGroupAgg = AggregationBuilders.terms("yearGroup").field("year.keyword");
  5. //第二个字段进行分组，使用script方式拼接返回值，但是要保证archTypeId和archTypeName是一对一的
  6. Script script = new Script("doc['archTypeId.keyword'].value +'#split#'+ doc['archTypeName.keyword'].value");
  7. TermsAggregationBuilder archTypeGroupAgg = AggregationBuilders.terms("archTypeGroup").script(script);
  8. //添加aggregation
  9. sourceBuilder.aggregation(yearGroupAgg);
  10. sourceBuilder.aggregation(archTypeGroupAgg);
  11. searchRequest.source(sourceBuilder);

刚接触es，不熟悉，最新版本的教程也不多。实际上基本是通过kibana敲命令琢磨出来的。建议装一个kibana或者head来辅助自己熟悉es。

四、分词的字段做聚合

这种情况，先看常规做法。这里以archTypeCode2和archTypeName做平级聚合，但是archTypeName字段是分词字段。往下看：

kibana：

  1.  
  2. POST ermsftrv1/_search
  3. {
  4.   "aggs": {
  5.     "archTypeGroup": {
  6.       "terms": {
  7.         "field": "archTypeCode2",
  8.         "size": 10
  9.       }
  10.     },
  11.     "yearGroup": {
  12.       "terms": {
  13.         "field": "archTypeName",
  14.         "size": 10
  15.       }
  16.     }
  17.   }
  18. }

聚合结果：

  1. "aggregations" : {
  2.     "yearGroup" : {
  3.       "doc_count_error_upper_bound" : 0,
  4.       "sum_other_doc_count" : 4,
  5.       "buckets" : [
  6.         {
  7.           "key" : "证照",
  8.           "doc_count" : 20
  9.         },
  10.         {
  11.           "key" : "01",
  12.           "doc_count" : 10
  13.         },
  14.         {
  15.           "key" : "企业",
  16.           "doc_count" : 10
  17.         },
  18.         {
  19.           "key" : "02",
  20.           "doc_count" : 9
  21.         },
  22.         {
  23.           "key" : "领导",
  24.           "doc_count" : 9
  25.         },
  26.         {
  27.           "key" : "仪器",
  28.           "doc_count" : 3
  29.         },
  30.         {
  31.           "key" : "类型",
  32.           "doc_count" : 3
  33.         },
  34.         {
  35.           "key" : "设备",
  36.           "doc_count" : 3
  37.         },
  38.         {
  39.           "key" : "声像",
  40.           "doc_count" : 2
  41.         },
  42.         {
  43.           "key" : "建设",
  44.           "doc_count" : 2
  45.         }
  46.       ]
  47.     },
  48.     "archTypeGroup" : {
  49.       "doc_count_error_upper_bound" : 0,
  50.       "sum_other_doc_count" : 0,
  51.       "buckets" : [
  52.         {
  53.           "key" : "ZZ",
  54.           "doc_count" : 20
  55.         },
  56.         {
  57.           "key" : "SB",
  58.           "doc_count" : 3
  59.         },
  60.         {
  61.           "key" : "JS",
  62.           "doc_count" : 2
  63.         },
  64.         {
  65.           "key" : "SX",
  66.           "doc_count" : 2
  67.         }
  68.       ]
  69.     }
  70.   }

archTypeName这个聚合出现了：证照、01....等，这些是被分词后的。所以结果并不理想，我们这样解决。

在设置mapping时，archTypeName字段这么设置即可，

  1.         "archTypeName" : {
  2.           "type" : "text",
  3.           "fields" : {
  4.             "raw" : {
  5.               "type" : "keyword" #如果不设置keyword索引在聚合时将会使用已分解后的词
  6.             }
  7.           },
  8.           "analyzer" : "ik_max_word",
  9.           "fielddata" : true
  10.         }

这样正常使用archTypeName还是分词搜索即可，当我们需要使用archTypeName.keyword时只需要写archTypeName.raw.keyword即可，

修改后的kibana：

  1. POST ermsftrv1/_search
  2. {
  3.   "aggs": {
  4.     "archTypeGroup": {
  5.       "terms": {
  6.         "field": "archTypeCode2",
  7.         "size": 10
  8.       }
  9.     },
  10.     "yearGroup": {
  11.       "terms": {
  12.         "field": "archTypeName.raw",
  13.         "size": 10
  14.       }
  15.     }
  16.   }
  17. }

聚合结果：01 企业证照、设备仪器等既可以当做完整的词来聚合展示了。

  1. "aggregations" : {
  2.     "yearGroup" : {
  3.       "doc_count_error_upper_bound" : 0,
  4.       "sum_other_doc_count" : 0,
  5.       "buckets" : [
  6.         {
  7.           "key" : "01 企业证照",
  8.           "doc_count" : 10
  9.         },
  10.         {
  11.           "key" : "02 领导证照",
  12.           "doc_count" : 9
  13.         },
  14.         {
  15.           "key" : "设备仪器",
  16.           "doc_count" : 3
  17.         },
  18.         {
  19.           "key" : "声像类型",
  20.           "doc_count" : 2
  21.         },
  22.         {
  23.           "key" : "建设项目",
  24.           "doc_count" : 2
  25.         },
  26.         {
  27.           "key" : "证照类型",
  28.           "doc_count" : 1
  29.         }
  30.       ]
  31.     },
  32.     "archTypeGroup" : {
  33.       "doc_count_error_upper_bound" : 0,
  34.       "sum_other_doc_count" : 0,
  35.       "buckets" : [
  36.         {
  37.           "key" : "ZZ",
  38.           "doc_count" : 20
  39.         },
  40.         {
  41.           "key" : "SB",
  42.           "doc_count" : 3
  43.         },
  44.         {
  45.           "key" : "JS",
  46.           "doc_count" : 2
  47.         },
  48.         {
  49.           "key" : "SX",
  50.           "doc_count" : 2
  51.         }
  52.       ]
  53.     }
  54.   }

五、实践代码

献上最终版代码，其中有大部搜索情况下的java实现方式，可以参考。

  1. //全文检索字段列表
  2.     private final String[] MULTI_MATCH_FILDS ={
  3.                 "archName","archNo","archTypeCode","archivedDept","archTypeName","archivedYear","createUser","notes",
  4.                 "reorganizeOper","responsibleOper","savePeriod","secret","sectName","sectNo","writingDate","writingYear",
  5.                 "year","signatory"
  6.             };
  7.  
  8.     //全文检索高亮字段列表
  9.     private final String[] MULTI_MATCH_HIGHLIGHT_FILDS ={
  10.             "archName","archNo","archTypeCode","archivedDept","archTypeName","archivedYear","createUser","notes",
  11.             "reorganizeOper","responsibleOper","savePeriod","secret","sectName","sectNo","writingDate","writingYear",
  12.             "year","signatory"
  13.     };
  14.  
  15.     /**
  16.      * 全文mapping中会被分词，并且含有keyword的字段
  17.      */
  18.     private final List<String> MULTI_MATCH_KEYWORD_FIELDS = Arrays.asList(
  19.             "archName", "archNo","archTypeCode","archTypeName","archivedDate","archivedDept",
  20.             "archivedOperator","savePeriod","secretId","sectName", "sectNo","ermsProjectNo",
  21.             "productNo",  "factoryNumber","volumeHao","ERMS_META_DATA_METADATA_EMPLOYEE_NO",
  22.             "ermsProjectName","dossierName", "dossierArchivedDept","equipmentUse",  "ERMS_META_DATA_METADATA_ENTERPRISE_NAME",
  23.             "ERMS_META_DATA_METADATA_FIRST_PARTY","ERMS_META_DATA_METADATA_SECOND_PARTY",
  24.             "ERMS_META_DATA_METADATA_THIRD_PARTY","ERMS_META_DATA_METADATA_CONTRACT_OBJECT","signatory"
  25.     );
  26.  
  27.     /**
  28.      * bool查询的使用
  29.      * Bool查询对应Lucene中的BooleanQuery,它由一个或者多个子句组成,每个子句都有特定的类型
  30.      *
  31.      * must
  32.      * 返回的文档必须满足must子句的条件,并且参与计算分值
  33.      *
  34.      * filter
  35.      * 返回的文档必须满足filter子句的条件,但是不会像must一样,参与计算分值
  36.      *
  37.      * should
  38.      * 返回的文档可能满足should子句的条件.在一个bool查询中,如果没有must或者filter,有一个或者多个should子句,那么只要满足一个就可以返回.minimum_should_match参数定义了至少满足几个子句.
  39.      *
  40.      * must_not
  41.      * 返回的文档必须不满足定义的条件
  42.      *
  43.      * 如果一个查询既有filter又有should,那么至少包含一个should子句.
  44.      *
  45.      * bool查询也支持禁用协同计分选项disable_coord.一般计算分值的因素取决于所有的查询条件.
  46.      *
  47.      * bool查询也是采用more_matches_is_better的机制,因此满足must和should子句的文档将会合并起来计算分值.
  48.      *
  49.      * @param request
  50.      * @return
  51.      */
  52.     @Override
  53.     public Map<String, Object> bindAdvancedQueryGrid(AdvancedQueryParam request) {
  54.         log.info("context:{}", Context.getCurrentUser());
  55.         log.info("查询参数::::{}",request);
  56.         Map resMap = new HashMap();
  57.         //必要参数校验
  58.         if(!request.getAdvanced() && StringUtils.isBlank(request.getKey())&&
  59.                 StringUtils.isBlank(request.getQueryItem())){//不是高级搜索的时候需要穿key
  60.             resMap.put("errMsg","关键字不能为空");
  61.             resMap.put("errCode","-1");
  62.             return resMap;
  63.         }
  64.         SearchRequest searchRequest = new SearchRequest(ermsesProperties.getIndex());
  65.         BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
  66.         SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
  67.  
  68.         // 高级搜索条件
  69.         if (request.getAdvanced()) {//高级搜索参数拼接
  70.             //添加范围
  71.             List<Integer> range = request.getRange();
  72.             if(ObjectUtils.isEmpty(range) || (!range.contains(3) && !range.contains(1)))return resMap;//没选范围返回空
  73.             if(range.size()==1){//档案库和预归档只选了一个库的话
  74.                 if (range.contains(3)){//档案库
  75.                     boolQueryBuilder.must(QueryBuilders.termQuery("archStatus",3));
  76.                 }else if(range.contains(1)){//我要归档
  77.                     boolQueryBuilder.must(QueryBuilders.termQuery("archStatus",1));
  78.                 }
  79.             }
  80.             List<AdvancedCondition> advancedConditions = request.getAdvancedConditions();
  81.             for (AdvancedCondition condition:advancedConditions) {
  82.                 //主要参数为空时跳过
  83.                 if(StringUtils.isBlank(condition.getValue()) ||
  84.                         StringUtils.isBlank(condition.getBelong()) ||
  85.                         (("9".equals(condition.getBelong()) || "10".equals(condition.getBelong()))
  86.                                 && StringUtils.isBlank(condition.getInput())))continue;
  87.                 //如果包含标题内容，添加搜索key以便查询电子文件
  88.                 if("archName".equals(condition.getValue()) && StringUtils.isBlank(request.getKey())){
  89.                     request.setKey(condition.getInput());
  90.                 }
  91.                 //查询条件构建
  92.                 QueryBuilder termQueryBuilder;
  93.                 /**
  94.                  * 条件关系
  95.                  *   { id: 1, label: '包含', value: '1' },
  96.                  *   { id: 2, label: '小于', value: '2' },
  97.                  *   { id: 3, label: '小于等于', value: '3' },
  98.                  *   { id: 4, label: '不等于', value: '4' },
  99.                  *   { id: 5, label: '等于', value: '5' },
  100.                  *   { id: 6, label: '大于', value: '6' },
  101.                  *   { id: 7, label: '大于等于', value: '7' },
  102.                  *   { id: 8, label: '不包含', value: '8' },
  103.                  *   { id: 9, label: '为空', value: '9' },
  104.                  *   { id: 10, label: '不为空', value: '10' },
  105.                  *   { id: 11, label: '以之结尾', value: '11' },
  106.                  *   { id: 12, label: '以之开头', value: '12' }
  107.                  */
  108.                 switch (condition.getBelong()){
  109.                     case "1":
  110.                         termQueryBuilder = QueryBuilders.matchQuery(condition.getValue(), condition.getInput());
  111.                         break;
  112.                     case "2":
  113.                         termQueryBuilder = QueryBuilders.rangeQuery(condition.getValue()).lt(condition.getInput());
  114.                         break;
  115.                     case "3":
  116.                         termQueryBuilder = QueryBuilders.rangeQuery(condition.getValue()).lte(condition.getInput());
  117.                         break;
  118.                     case "4":
  119.                         termQueryBuilder = boolQueryBuilder.mustNot(QueryBuilders.termQuery(condition.getValue(), condition.getInput()));
  120.                         break;
  121.                     case "5":
  122.                         if(MULTI_MATCH_KEYWORD_FIELDS.contains(condition.getValue())){
  123.                             termQueryBuilder = QueryBuilders.termQuery(condition.getValue()+".keyword", condition.getInput());
  124.                         }else {
  125.                             termQueryBuilder = QueryBuilders.termQuery(condition.getValue(), condition.getInput());
  126.                         }
  127.                         break;
  128.                     case "6":
  129.                         termQueryBuilder = QueryBuilders.rangeQuery(condition.getValue()).gt(condition.getInput());
  130.                         break;
  131.                     case "7":
  132.                         termQueryBuilder = QueryBuilders.rangeQuery(condition.getValue()).gte(condition.getInput());
  133.                         break;
  134.                     case "8":
  135.                         termQueryBuilder = boolQueryBuilder.mustNot(QueryBuilders.matchQuery(condition.getValue(), condition.getInput()));
  136.                         break;
  137.                     case "9":
  138.                         termQueryBuilder = boolQueryBuilder.mustNot(QueryBuilders.existsQuery(condition.getValue()));
  139.                         break;
  140.                     case "10":
  141.                         termQueryBuilder = QueryBuilders.existsQuery(condition.getValue());
  142.                         break;
  143.                     case "11"://? 匹配任意字符，* 匹配0个或多个字符
  144.                         termQueryBuilder = QueryBuilders.wildcardQuery(condition.getValue(), "*"+condition.getInput());
  145.                         break;
  146.                     case "12":
  147.                         termQueryBuilder = QueryBuilders.prefixQuery(condition.getValue(), condition.getInput());
  148.                         break;
  149.                     default:
  150.                         continue;
  151.                 }
  152.                 if(StringUtils.isNotBlank(condition.getLogic()) && "2".equals(condition.getLogic())){//或
  153.                     boolQueryBuilder.should(termQueryBuilder);
  154.                 }else {//与
  155.                     boolQueryBuilder.must(termQueryBuilder);
  156.                 }
  157.             }
  158.         }else {
  159.             //全文检索只搜档案库
  160.             boolQueryBuilder.must(QueryBuilders.termQuery("archStatus",3));
  161.             //全文检索--模糊查询条件
  162.             boolQueryBuilder.must(QueryBuilders.multiMatchQuery(request.getKey(),MULTI_MATCH_FILDS));//取消全文检索，改为单属性选择搜索
  163.         }
  164.  
  165.         //检索中--输入条件--档号
  166.         if (!ObjectUtils.isEmpty(request.getArchNo())) {
  167.             boolQueryBuilder.must(QueryBuilders.matchQuery("archNo", request.getArchNo()));
  168.         }
  169.         //检索中--输入条件--档案名称
  170.         if (!ObjectUtils.isEmpty(request.getArchName())) {
  171.             boolQueryBuilder.must(QueryBuilders.matchQuery("archName", request.getArchName()));
  172.         }
  173.         //检索中--输入条件--归档时间
  174.         if (!ObjectUtils.isEmpty(request.getStartDate()) || !ObjectUtils.isEmpty(request.getEndDate())) {
  175.             Object start = request.getStartDate();
  176.             Object end = request.getEndDate();
  177.             boolQueryBuilder.must(QueryBuilders.rangeQuery("archivedDate").from(start+" 00:00:00.000").to(end+" 59:59:59.999"));
  178.         }
  179.  
  180.         //检索中--分类条件--门类
  181.         if (!ObjectUtils.isEmpty(request.getArchTypeCode2())) {
  182.             boolQueryBuilder.must(QueryBuilders.termsQuery("archTypeCode2", request.getArchTypeCode2()));
  183.         }
  184.         //检索中--分类条件--全宗查询条件,非全库且有全宗id时
  185.         if (!ObjectUtils.isEmpty(request.getSectId())) {
  186.             boolQueryBuilder.must(QueryBuilders.termQuery("sectId", request.getSectId()));
  187.         }
  188.         //检索中--分类条件--保管期限查询条件
  189.         if (!ObjectUtils.isEmpty(request.getSavePeriodId())) {
  190.             boolQueryBuilder.must(QueryBuilders.termQuery("savePeriodId", request.getSavePeriodId()));
  191.         }
  192.         //检索中--分类条件--成文日期查询条件
  193.         if (!ObjectUtils.isEmpty(request.getWritingYear())) {
  194.             boolQueryBuilder.must(QueryBuilders.termQuery("writingYear", request.getWritingYear()));
  195.         }
  196.  
  197.         //2.5是否聚合 //TODO
  198.         //加入聚合
  199.         if (request.getAggregation()) {
  200.             //成文年份聚合
  201.             TermsAggregationBuilder yearGroupAgg = AggregationBuilders.terms("writingYearGroup").field("writingYear");
  202.             sourceBuilder.aggregation(yearGroupAgg);
  203.             //门类、档案类型聚合
  204.             TermsAggregationBuilder archTypeCode2Agg = AggregationBuilders.terms("archTypeCode2Group").field("archTypeCode2");
  205.             sourceBuilder.aggregation(archTypeCode2Agg);
  206.             //全宗聚合
  207.             Script script = new Script("doc['sectId'].value +'#split#'+ doc['sectName.keyword'].value");
  208.             TermsAggregationBuilder archTypeGroupAgg = AggregationBuilders.terms("sectGroup").script(script);
  209.             sourceBuilder.aggregation(archTypeGroupAgg);
  210.             //保管期限聚合
  211.             TermsAggregationBuilder savePeriodAgg = AggregationBuilders.terms("savePeriodGroup").field("savePeriodId");
  212.             sourceBuilder.aggregation(savePeriodAgg);
  213.         }
  214.         // 设置分页
  215.         sourceBuilder.query(boolQueryBuilder);
  216.         Integer offSet = 0;
  217.         Integer limit = 10;
  218.         if (!ObjectUtils.isEmpty(request.getPage()) && !ObjectUtils.isEmpty(request.getSize())) {
  219.             Integer page = (Integer) request.getPage();
  220.             limit = (Integer) request.getSize();
  221.             offSet = (page - 1) * limit;
  222.         }
  223.         sourceBuilder.from(offSet);
  224.         sourceBuilder.size(limit);
  225.         sourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));
  226.         //TODO 设置高亮
  227.  
  228.         //添加检索条件
  229.         searchRequest.source(sourceBuilder);
  230.  
  231.         //2.构建查询结果
  232.         try {
  233.             SearchResponse searchResponse = es.searchDocument(searchRequest);
  234.             if(searchResponse.status() != RestStatus.OK){
  235.                 resMap.put("errMsg","查询数据失败");
  236.                 resMap.put("errCode","-1");
  237.                 return resMap;
  238.             }
  239.             SearchHits hits = searchResponse.getHits();
  240.             //2.1构建返回总数
  241.             Long count = hits.getTotalHits().value;
  242.             //2.2构建返回内容
  243.             ES_ARCHIVED_FORM_RESPONSE response = new ES_ARCHIVED_FORM_RESPONSE();
  244.             List<ESArchObject> list = new ArrayList<>();
  245.  
  246.             //字段遮挡 -- 获取可见权限
  247.             final List<ErmsDigitalRights> ermsDigitalRights = digitalRightsService.getErmsDigitalRights();
  248.             Map<String, Set<String>> archTypeIdMap = ermsDigitalRights.stream()
  249.                     .filter(r -> r.getErmsArchTypeId() != null)
  250.                     .collect(Collectors.groupingBy(r -> String.valueOf(r.getErmsSectId()),
  251.                             Collectors.mapping(r -> String.valueOf(r.getErmsArchTypeId()),
  252.                                     Collectors.toSet())));
  253.  
  254.             for (SearchHit hit : hits.getHits()) {
  255.                 ESArchObject esArchObject = JSON.parseObject(hit.getSourceAsString(), ESArchObject.class);
  256.                 //字段遮挡 -- 替换遮挡属性
  257.                 hiddenField(archTypeIdMap.get(esArchObject.getSectId()), esArchObject);
  258.                 list.add(esArchObject);
  259.             }
  260.             response.setForms(list);
  261.  
  262.             if (request.getAggregation()) {//构建聚合
  263.                 Aggregations aggregations = searchResponse.getAggregations();
  264.                 //构建成文年份分组
  265.                 Terms yearGroup = aggregations.get("writingYearGroup");
  266.                 if(!CollectionUtils.isEmpty(yearGroup.getBuckets())){
  267.                     List<Map> years = new ArrayList<>();
  268.                     for (Terms.Bucket bucket : yearGroup.getBuckets()) {
  269.                         Map<String,Object> iterm = new HashMap<>();
  270.                         putGroupIterm(bucket, iterm, bucket.getKeyAsString(), bucket.getKeyAsString());
  271.                         years.add(iterm);
  272.                     }
  273.                     response.setWritingYearGroup(years);
  274.                 }
  275.                 //构建档案类型分组
  276.                 Terms archTypeCode2Group = aggregations.get("archTypeCode2Group");
  277.                 if(!CollectionUtils.isEmpty(archTypeCode2Group.getBuckets())){
  278.                     List<Map> archTypeCode2s = new ArrayList<>();
  279.                     for (Terms.Bucket bucket : archTypeCode2Group.getBuckets()) {
  280.                         Map<String,Object> iterm = new HashMap<>();
  281.                         putGroupIterm(bucket, iterm, bucket.getKeyAsString(), bucket.getKeyAsString());
  282.                         archTypeCode2s.add(iterm);
  283.                     }
  284.                     response.setArchTypeCode2Group(archTypeCode2s);
  285.                 }
  286.                 //构建全宗分组
  287.                 Terms sectGroup = aggregations.get("sectGroup");
  288.                 if(!CollectionUtils.isEmpty(sectGroup.getBuckets())){
  289.                     List<Map> sects = new ArrayList<>();
  290.                     for (Terms.Bucket bucket : sectGroup.getBuckets()) {
  291.                         if(StringUtils.isNotBlank(bucket.getKeyAsString()) && bucket.getKeyAsString().contains("#split#")){
  292.                             String[] split = bucket.getKeyAsString().split("#split#");
  293.                             Map<String,Object> iterm = new HashMap<>();
  294.                             putGroupIterm(bucket, iterm, split[0], split[1]);
  295.                             sects.add(iterm);
  296.                         }
  297.                     }
  298.                     response.setSectGroup(sects);
  299.                 }
  300.                 //构建保管期限分组
  301.                 Terms savePeriodGroup = aggregations.get("savePeriodGroup");
  302.                 if(!CollectionUtils.isEmpty(savePeriodGroup.getBuckets())){
  303.                     List<Map> savePeriods = new ArrayList<>();
  304.                     for (Terms.Bucket bucket : savePeriodGroup.getBuckets()) {
  305.                         Map<String,Object> iterm = new HashMap<>();
  306.                         putGroupIterm(bucket, iterm, bucket.getKeyAsString(), bucket.getKeyAsString());
  307.                         savePeriods.add(iterm);
  308.                     }
  309.                     response.setSavePeriodGroup(savePeriods);
  310.                 }
  311.  
  312.                 //获取电子文件聚合
  313.                 if (!request.getAdvanced() && StringUtils.isNotBlank(request.getKey())){
  314.                     try {
  315.                         ElectronicSearchParam param = new ElectronicSearchParam();
  316.                         BeanUtils.copyProperties(param,request);
  317.                         if(StringUtils.isNotBlank(param.getKey())){
  318.                             response.setElectronicGroup(eleFacetSearchRest(param));//电子文件分类统计
  319.                         }
  320.                     } catch (IllegalAccessException e) {
  321.                         e.printStackTrace();
  322.                     } catch (InvocationTargetException e) {
  323.                         e.printStackTrace();
  324.                     }
  325.                 }
  326.  
  327.             }
  328.             //TODO 查询的同时 往 检索历史表存入检索的
  329.             /*if (!ObjectUtils.isEmpty(request.get("archName"))||!ObjectUtils.isEmpty(request.get("IDes"))||!ObjectUtils.isEmpty(request.get("archNo"))||!ObjectUtils.isEmpty(request.get("name"))|| !ObjectUtils.isEmpty(request.get("end"))||!ObjectUtils.isEmpty(request.get("start"))){
  330.                 ERMSSearchHistory ermsSearchHistory=new ERMSSearchHistory();
  331. //            Context.getERMSSearchHistoryService().createSearchHistory(ermsSearchHistory,request,count);
  332.             }*/
  333.  
  334.  
  335.  
  336.             //3.查询到的值封装并返回
  337.             response.setCount(count);
  338.             resMap.put("data", response);
  339.         } catch (IOException e) {
  340.             e.printStackTrace();
  341.         }
  342.         return resMap;
  343.  
  344.     }

环境搭建可见：

docker swarm集群下部署elasticsearch7.6.2集群+kibana7.6.2+es-head+中文分词

linux Centos7 安裝搭建elasticsearch7.6.2+kibana7.6.2+中文分词7.6.2详解

gogogo！

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/凡人多烦事01/article/detail/415650
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号