如何通过Elasticsearch API获取全状态Liferay Commerce商品

核心原因 #

Liferay Commerce的SearchContext或CommerceProductIndexer会自动注入默认状态过滤条件（仅筛选已批准状态0），即使手动添加全状态的TermsQuery，也会被默认的布尔查询覆盖或组合，导致仅返回已批准商品。

解决方案 #

1. 清除SearchContext的默认状态过滤 #

Liferay的SearchContext会自动添加针对商品状态的过滤，需要手动移除：

SearchContext searchContext = SearchContextFactory.getInstance(
    request.getPortletRequest());

// 移除默认的状态过滤查询
List<Query> postFilters = searchContext.getPostFilterQueries();
if (postFilters != null) {
    postFilters.removeIf(query -> 
        query instanceof TermQuery && 
        ((TermQuery)query).getFieldName().equals("status"));
}

// 禁用默认的AND查询强制组合
searchContext.setAndSearch(false);

2. 构造完整的全状态查询并覆盖默认查询 #

直接构建包含所有必要条件的布尔查询，替换SearchContext的默认查询，避免叠加冲突：

// 构造全状态条件
TermsQuery statusQuery = QueryBuilders.termsQuery("status", 0, 1, 2, 3);

// 目录、类型、供应商条件
TermQuery categoryQuery = QueryBuilders.termQuery("categoryId", YOUR_CATEGORY_ID);
TermQuery typeQuery = QueryBuilders.termQuery("productTypeId", YOUR_PRODUCT_TYPE_ID);
TermQuery supplierQuery = QueryBuilders.termQuery("supplierId", YOUR_SUPPLIER_ID);

// 组合所有查询
BoolQueryBuilder finalQuery = QueryBuilders.boolQuery()
    .must(categoryQuery)
    .must(typeQuery)
    .must(supplierQuery)
    .must(statusQuery);

// 设置到SearchContext，覆盖默认查询
searchContext.setQuery(finalQuery);

3. 排查额外布尔查询的来源 #

开启Liferay Elasticsearch模块的DEBUG日志（日志类com.liferay.portal.search.elasticsearch7），查看实际发送的DSL请求：

• 如果额外查询来自CommerceProductIndexer，则需要在创建SearchContext时跳过索引器的默认过滤逻辑
• 如果是自定义代码中误加的过滤，检查是否有其他地方设置了status的TermQuery

4. 直接使用原生Elasticsearch客户端绕过Liferay默认过滤 #

如果上述方法无效，直接调用Liferay内置的RestHighLevelClient发起原生请求，完全避免Liferay的默认过滤：

// 获取Liferay内置的Elasticsearch客户端
RestHighLevelClient esClient = com.liferay.portal.search.elasticsearch7.internal.ElasticsearchClientManager.getInstance()
    .getRestHighLevelClient();

// 构造搜索请求
SearchRequest searchRequest = new SearchRequest("liferay-commerce-product"); // 替换为实际商品索引名
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();

sourceBuilder.query(QueryBuilders.boolQuery()
    .must(QueryBuilders.termQuery("categoryId", YOUR_CATEGORY_ID))
    .must(QueryBuilders.termQuery("productTypeId", YOUR_PRODUCT_TYPE_ID))
    .must(QueryBuilders.termQuery("supplierId", YOUR_SUPPLIER_ID))
    .must(QueryBuilders.termsQuery("status", 0, 1, 2, 3)));

searchRequest.source(sourceBuilder);

// 执行查询并处理结果
SearchResponse response = esClient.search(searchRequest, RequestOptions.DEFAULT);
for (SearchHit hit : response.getHits().getHits()) {
    // 解析商品数据，示例：
    Map<String, Object> source = hit.getSourceAsMap();
    long productId = Long.parseLong(source.get("productId").toString());
    // 其他字段解析...
}

内容的提问来源于stack exchange，提问作者Anubhav Kalra iDigi