你要的Elasticsearch ORM框架终于来了！！！

{  "settings": {    "number_of_replicas": 0,    "number_of_shards": 1  },  "mappings": {    "properties": {      "cargoId": {        "type": "long"      },      "driverUserName": {        "type": "keyword"      },      "loadAddress": {        "type": "text"      },      "searchable": {        "type": "boolean"      },      "companyId": {        "type": "long"      }    }  }}

{"index":{}}{"cargoId": 1, "driverUserName":"张三", "loadAddress": "南京市玄武区", "searchable": true,"companyId": 666}{"index":{}}{"cargoId": 2, "driverUserName":"李四", "loadAddress": "南京市秦淮区", "searchable": false,"companyId": 667}{"index":{}}{"cargoId": 3, "driverUserName":"王五", "loadAddress": "南京市六合区", "searchable": true,"companyId": 668}{"index":{}}{"cargoId": 4, "driverUserName":"赵六", "loadAddress": "南京市建邺区", "searchable": true,"companyId": 669}{"index":{}}{"cargoId": 5, "driverUserName":"钱七", "loadAddress": "南京市鼓楼区", "searchable": true,"companyId": 665

<dependency>     <groupId>io.manbang</groupId>     <artifactId>ebatis-core</artifactId>     <version>7.5.1.3.RELEASE</version></dependency>

@AutoService(ClusterRouterProvider.class)public class SampleClusterRouterProvider implements ClusterRouterProvider {    public static final String SAMPLE_CLUSTER_NAME = "sampleCluster";    @Override    public ClusterRouter getClusterRouter(String name) {        if (SAMPLE_CLUSTER_NAME.equalsIgnoreCase(name)) {            Cluster cluster = Cluster.simple("127.0.0.1", 9200, Credentials.basic("admin", "123456"));            ClusterRouter clusterRouter = ClusterRouter.single(cluster);            return clusterRouter;        } else {            return null;        }    }}

@Datapublic class RecentOrder {    private Long cargoId    private String driverUserName;    private String loadAddress;    private Boolean searchable;    private Integer companyId;}@Datapublic class RecentOrderCondition {    private Boolean searchable;    private String driverUserName;}

@Mapper(indices = "recent_order_index")public interface RecentOrderRepository {    @Search    List<RecentOrder> search(RecentOrderCondition condition);}

@Slf4jpublic class OrderRepositoryTest {    @Test    public void search() {        // 组装查询条件        RecentOrderCondition condition = new RecentOrderCondition();        condition.setSearchable(Boolean.TRUE);        condition.setDriverUserName("张三");        // 映射接口        RecentOrderRepository repository = MapperProxyFactory.getMapperProxy(RecentOrderRepository.class, SampleClusterRouterProvider.SAMPLE_CLUSTER_NAME);        // 搜索货源        List<RecentOrder> orders = repository.search(condition);        // 断言        Assert.assertEquals(3, orders.size());        // 打印输出        orders.forEach(order -> log.info("{}", order));    }}

{  "query": {    "bool": {      "must": [        {          "bool": {            "must": [              {                "bool": {                  "should": [                    {                      "terms": {                        "startDistrictId": [                          684214,                          981362                        ],                        "boost": 1.0                      }                    },                    {                      "terms": {                        "startCityId": [                          320705,                          931125                        ],                        "boost": 1.0                      }                    }                  ],                  "adjust_pure_negative": true,                  "boost": 1.0                }              },              {                "bool": {                  "should": [                    {                      "terms": {                        "endDistrictId": [                          95312,                          931125                        ],                        "boost": 1.0                      }                    },                    {                      "terms": {                        "endCityId": [                          589421,                          953652                        ],                        "boost": 1.0                      }                    }                  ],                  "adjust_pure_negative": true,                  "boost": 1.0                }              }            ],            "adjust_pure_negative": true,            "boost": 1.0          }        },        {          "range": {            "updateTime": {              "from": 1608285822239,              "to": null,              "include_lower": true,              "include_upper": true,              "boost": 1.0            }          }        },        {          "terms": {            "cargoLabels": [              "水果",              "生鲜"            ],            "boost": 1.0          }        }      ],      "must_not": [        {          "terms": {            "cargoCategory": [              "A",              "B"            ],            "boost": 1.0          }        },        {          "term": {            "featureSort": {              "value": "好货",              "boost": 1.0            }          }        }      ],      "should": [        {          "bool": {            "must_not": [              {                "terms": {                  "cargoChannel": [                    "长途货源",                    "一口价货源"                  ],                  "boost": 1.0                }              }            ],            "should": [              {                "bool": {                  "must": [                    {                      "term": {                        "searchableSources": {                          "value": "ALL",                          "boost": 1.0                        }                      }                    },                    {                      "bool": {                        "must": [                          {                            "terms": {                              "cargoChannel": [                                "No.1",                                "No.2",                                "No.3"                              ],                              "boost": 1.0                            }                          },                          {                            "term": {                              "securityTran": {                                "value": "平台保证",                                "boost": 1.0                              }                            }                          }                        ],                        "adjust_pure_negative": true,                        "boost": 1.0                      }                    }                  ],                  "adjust_pure_negative": true,                  "boost": 1.0                }              }            ],            "adjust_pure_negative": true,            "boost": 1.0          }        }      ],      "adjust_pure_negative": true,      "boost": 1.0    }  },  "_source": {    "includes": [      "cargoId",      "startDistrictId",      "startCityId",      "endDistrictId",      "endCityId",      "updateTime",      "cargoLabels",      "cargoCategory",      "featureSort",      "cargoChannel",      "searchableSources",      "securityTran"    ],    "excludes": []  },  "sort": [    {      "duplicate": {        "order": "asc"      }    },    {      "_script": {        "script": {          "source": "searchCargo-script",          "lang": "painless",          "params": {            "searchColdCargoTop": 0          }        },        "type": "string",        "order": "asc"      }    }  ]}

final BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();final TermsQueryBuilder startCityId = QueryBuilders.termsQuery("startCityId", Lists.newArrayList(320705L, 931125L));final TermsQueryBuilder startDistrictId = QueryBuilders.termsQuery("startDistrictId", Lists.newArrayList(684214L, 981362L));final TermsQueryBuilder endCityId = QueryBuilders.termsQuery("endCityId", Lists.newArrayList(589421L, 953652L));final TermsQueryBuilder endDistrictId = QueryBuilders.termsQuery("endDistrictId", Lists.newArrayList(95312L, 931125L));final BoolQueryBuilder startBuilder = QueryBuilders.boolQuery();startBuilder.should(startCityId).should(startDistrictId);final BoolQueryBuilder endBuilder = QueryBuilders.boolQuery();endBuilder.should(endCityId).should(endDistrictId);final BoolQueryBuilder cityBuilder = QueryBuilders.boolQuery();cityBuilder.must(startBuilder);cityBuilder.must(endBuilder);queryBuilder.must(cityBuilder);final RangeQueryBuilder rangeBuilder = QueryBuilders.rangeQuery("updateTime");queryBuilder.must(rangeBuilder.from(1608285822239L));final TermsQueryBuilder cargoLabelsBuilder = QueryBuilders.termsQuery("cargoLabels", Lists.newArrayList("水果", "生鲜"));queryBuilder.must(cargoLabelsBuilder);final TermsQueryBuilder cargoCategoryBuilder = QueryBuilders.termsQuery("cargoCategory", Lists.newArrayList("A", "B"));final TermQueryBuilder featureSortBuilder = QueryBuilders.termQuery("featureSort", "好货");queryBuilder.mustNot(cargoCategoryBuilder);queryBuilder.mustNot(featureSortBuilder);final BoolQueryBuilder cargoChannelBuilder = QueryBuilders.boolQuery();queryBuilder.should(cargoChannelBuilder);final TermsQueryBuilder channelBuilder = QueryBuilders.termsQuery("cargoChannel", Lists.newArrayList("长途货源", "一口价货源"));cargoChannelBuilder.mustNot(channelBuilder);final BoolQueryBuilder searchableSourcesBuilder = QueryBuilders.boolQuery();cargoChannelBuilder.should(searchableSourcesBuilder);final TermQueryBuilder sourceBuilder = QueryBuilders.termQuery("searchableSources", "ALL");searchableSourcesBuilder.must(sourceBuilder);final BoolQueryBuilder securityTranBuilder = QueryBuilders.boolQuery();searchableSourcesBuilder.must(securityTranBuilder);securityTranBuilder.must(QueryBuilders.termsQuery("cargoChannel", "No.1", "No.2", "No.3"));securityTranBuilder.must(QueryBuilders.termQuery("securityTran", "平台保证"));SearchSourceBuilder searchSource = new SearchSourceBuilder();searchSource.query(queryBuilder);searchSource.fetchSource(new String[]{"cargoId", "startDistrictId", "startCityId", "endDistrictId", "endCityId", "updateTime", "cargoLabels",                "cargoCategory", "featureSort", "cargoChannel", "searchableSources", "securityTran"},        new String[0]);searchSource.sort("duplicate", SortOrder.ASC);ScriptSortBuilder sortBuilder = SortBuilders.scriptSort(new org.elasticsearch.script.Script(ScriptType.INLINE,        "painless", "searchCargo-script", Collections.emptyMap(), Collections.singletonMap("searchColdCargoTop", 0)),        ScriptSortBuilder.ScriptSortType.STRING).order(SortOrder.ASC);searchSource.sort(sortBuilder);

@Repositoryinterface CargoRepository extends ElasticsearchRepository<Cargo, String> {    @Query("{\"match\": {\"name\": {\"query\": \"?0\.............."}}}")    List<Cargo> findByCargoCondition(List<String> startCity, List<String> StartDistrictId /*,...*/);}final List<Cargo> cargos=cargoRepository.findByCargoCondition(Lists.newArrayList(320705L, 931125L),Lists.newArrayList(684214L, 981362L).........);

// 1. 创建搜货条件POJO对象@Datapublic class CargoCondition implements SortProvider {    @Must    private City city;    @Must    private Range<Long> updateTime;    @Must(queryType = QueryType.TERMS)    private List<String> cargoLabels;    @Must    private Boolean searchable;    @Must    private CargoLines cargoLines;    @Should    private CargoChannel cargoChannel;    @MustNot(queryType = QueryType.TERMS)    private List<String> cargoCategory;    @MustNot    private String featureSort;    private static final Sort[] SORTS = new Sort[]{Sort.fieldAsc("duplicate"),            Sort.scriptStringAsc(Script.inline("searchCargo-script", Collections.singletonMap("searchColdCargoTop", 0)))};    @Override    public Sort[] getSorts() {        return SORTS;    }    @Data    public static class City {        @Must        private StartCity startCity;        @Must        private EndCity endCity;    }    @Data    public static class StartCity {        @Should(queryType = QueryType.TERMS)        private List<Long> startDistrictId;        @Should(queryType = QueryType.TERMS)        private List<Long> startCityId;    }    @Data    public static class EndCity {        @Should(queryType = QueryType.TERMS)        private List<Long> endDistrictId;        @Should(queryType = QueryType.TERMS)        private List<Long> endCityId;    }    @Data    public static class CargoChannel {        @MustNot(queryType = QueryType.TERMS)        private List<String> cargoChannel;        @Should        private Security security;    }    @Data    public static class Security {        @Must        private String searchableSources;        @Must        private SecurityChannel securityChannel;    }    @Data    public static class SecurityChannel {        @Must(queryType = QueryType.TERMS)        private List<String> cargoChannel;        @Must        private String securityTran;    }    @Data    public static class CargoLines {        @Must(queryType = QueryType.TERMS)        private List<String> cargoLines;        @Must        private CargoLabel cargoLabel;    }    @Data    public static class CargoLabel {        @Must(queryType = QueryType.TERMS)        private List<String> cargoLines;        @Must(queryType = QueryType.TERMS)        private List<String> cargoLabels;    }}
// 2. 创建搜索接口@Mapper(indices = "cargo")public interface CargoMapper {    @Search    List<Cargo> searchCargo(CargoCondition condition);}
 // 3. 拼装搜获条件final CargoCondition cargo = new CargoCondition();CargoCondition cargo = new CargoCondition();final CargoCondition.City city = new CargoCondition.City();cargo.setCity(city);final CargoCondition.StartCity startCity = new CargoCondition.StartCity();city.setStartCity(startCity);startCity.setStartCityId(Lists.newArrayList(320705L,931125L));startCity.setStartDistrictId(Lists.newArrayList(684214L,981362L));final CargoCondition.EndCity endCity = new CargoCondition.EndCity();city.setEndCity(endCity);endCity.setEndCityId(Lists.newArrayList(589421L,953652L));endCity.setEndDistrictId(Lists.newArrayList(95312L,931125L));cargo.setUpdateTime(Range.ge(System.currentTimeMillis()));cargo.setCargoLabels(Lists.newArrayList("水果","生鲜"));final CargoCondition.CargoChannel cargoChannel = new CargoCondition.CargoChannel();cargo.setCargoChannel(cargoChannel);cargoChannel.setCargoChannel(Lists.newArrayList("长途货源","一口价货源"));final CargoCondition.Security security = new CargoCondition.Security();cargoChannel.setSecurity(security);security.setSearchableSources("ALL");final CargoCondition.SecurityChannel securityChannel = new CargoCondition.SecurityChannel();security.setSecurityChannel(securityChannel);securityChannel.setCargoChannel(Lists.newArrayList("No.1","No.2","No.3"));securityChannel.setSecurityTran("平台保证");cargo.setCargoCategory(Lists.newArrayList("A","B"));cargo.setFeatureSort("好货");
// 4. 执行搜索final List<Cargo> cargos = cargoMapper.searchCargo(condition）；

@Slf4j@AutoService(Interceptor.class)public class TestInterceptor implements Interceptor {@Overridepublic int getOrder() {return 0;    }@Overridepublic void handleException(Throwable throwable) {        log.error("Exception", throwable);    }@Overridepublic void preRequest(Object[] args) {       ...//通过ContextHolder可以跨上下文获取绑定的值       String userId = ContextHolder.getString("userId");    }@Overridepublic <T extends ActionRequest> void postRequest(RequestInfo<T> requestInfo) {        ...    }@Overridepublic <T extends ActionRequest> void preResponse(PreResponseInfo<T> preResponseInfo) {        ...    }@Overridepublic <T extends ActionRequest, R extends ActionResponse> void postResponse(PostResponseInfo<T, R> postResponseInfo) {        ...    }}

<dependency><groupId>io.manbang</groupId><artifactId>ebatis-spring</artifactId><version>7.5.1.3.RELEASE</version></dependency>

@Configuration@EnableEasyMapper(basePackages = "io.manbang.ebatis.sample.mapper")public class EbatisConfig {@Bean(destroyMethod = "close")public ClusterRouter clusterRouter() {        Cluster cluster = Cluster.simple("127.0.0.1", 9200, Credentials.basic("admin", "123456"));        ClusterRouter clusterRouter = ClusterRouter.single(cluster);return clusterRouter;    }}