SpringBoot Elasticsearch联表查询：门店和商品索引关联查询，带商品名称、分页和距离排序

"在Spring Boot环境下，可以使用Elasticsearch的Java High-Level REST Client来实现两个索引的联表查询，并进行商品名称查询、分页查询和门店距离排序。下面是一个示例代码：\n\n1. 首先，需要创建两个实体类，分别表示门店和商品，包含与tenantId相关的字段和其他需要查询的字段。\n\njava\n@Data\n@Document(indexName = \"store\", type = \"_doc\")\npublic class Store {\n @Id\n private String id;\n private String tenantId;\n private String name;\n private double latitude;\n private double longitude;\n // 其他字段\n}\n\n@Data\n@Document(indexName = \"product\", type = \"_doc\")\npublic class Product {\n @Id\n private String id;\n private String tenantId;\n private String name;\n // 其他字段\n}\n\n\n2. 创建两个Elasticsearch的Repository，用于操作门店和商品索引。\n\njava\n@Repository\npublic interface StoreRepository extends ElasticsearchRepository<Store, String> {\n Page<Store> findByTenantIdAndName(String tenantId, String name, Pageable pageable);\n}\n\n@Repository\npublic interface ProductRepository extends ElasticsearchRepository<Product, String> {\n Page<Product> findByTenantIdAndName(String tenantId, String name, Pageable pageable);\n}\n\n\n3. 创建一个Service类，用于进行联表查询、商品名称查询、分页查询和门店距离排序。\n\njava\n@Service\npublic class SearchService {\n @Autowired\n private StoreRepository storeRepository;\n \n @Autowired\n private ProductRepository productRepository;\n \n @Autowired\n private ElasticsearchRestTemplate elasticsearchRestTemplate;\n\n public Page<Store> searchStoresByTenantIdAndProductName(String tenantId, String productName, double latitude, double longitude, Pageable pageable) {\n // 构建门店索引的查询条件\n QueryBuilder storeQuery = QueryBuilders.boolQuery()\n .must(QueryBuilders.termQuery(\"tenantId\", tenantId))\n .must(QueryBuilders.matchQuery(\"name\", productName));\n \n // 获取门店查询结果\n List<Store> stores = new ArrayList<>();\n SearchHits<Store> searchHits = elasticsearchRestTemplate.search(new NativeSearchQueryBuilder()\n .withQuery(storeQuery)\n .withPageable(pageable)\n .build(), Store.class).getHits();\n\n searchHits.forEach(hit -> stores.add(hit.getContent()));\n\n // 构建商品索引的查询条件\n QueryBuilder productQuery = QueryBuilders.boolQuery()\n .must(QueryBuilders.termQuery(\"tenantId\", tenantId))\n .must(QueryBuilders.matchQuery(\"name\", productName));\n\n // 获取商品查询结果\n List<Product> products = new ArrayList<>();\n SearchHits<Product> productSearchHits = elasticsearchRestTemplate.search(new NativeSearchQueryBuilder()\n .withQuery(productQuery)\n .withPageable(pageable)\n .build(), Product.class).getHits();\n\n productSearchHits.forEach(hit -> products.add(hit.getContent()));\n\n // 进行联表查询，并按照门店距离进行排序\n List<Store> result = new ArrayList<>();\n stores.forEach(store -> {\n products.forEach(product -> {\n if (store.getTenantId().equals(product.getTenantId())) {\n result.add(store);\n }\n });\n });\n result.sort(Comparator.comparingDouble(store -> calculateDistance(store.getLatitude(), store.getLongitude(), latitude, longitude)));\n\n // 分页返回结果\n int start = (int) pageable.getOffset();\n int end = Math.min((start + pageable.getPageSize()), result.size());\n return new PageImpl<>(result.subList(start, end), pageable, result.size());\n }\n\n private double calculateDistance(double lat1, double lon1, double lat2, double lon2) {\n // 计算两个经纬度之间的距离\n // 实现略，可以使用Haversine公式等方法\n }\n}\n\n\n这样，你就可以在Spring Boot环境下使用Elasticsearch的Java High-Level REST Client实现两个索引的联表查询，并进行商品名称查询、分页查询和门店距离排序了。\n