Laravel集成Elasticsearch实现嵌套库存字段多条件筛选

直接在你现有布尔查询的filter数组里追加数组成员匹配规则就行，这里要避开ES处理对象数组的经典坑，不然查出来的结果会完全不准。

必须先明确的索引规则 #

ES对普通object类型的数组，默认会做扁平化索引：比如你给的示例产品数据，实际索引时会把数组内的字段拆成独立的列表存储，最终存的内容相当于：

stocks.country: ["EN", "IN"]
stocks.stock: [0, 1]

如果直接在filter里写两个独立的term/range条件，会把不同数组元素的字段值错配匹配——比如把IN国家的库存值1，当成EN国家的库存匹配，根本保证不了“同一个stocks条目同时满足country=EN、stock>1”的要求。
推荐把stocks字段的mapping调整为nested类型，这种类型会把数组里的每个对象当成独立的隐藏文档存储，能精确匹配同一个数组成员的多条件组合，也是这类场景的标准配置。

具体的代码改动 #

1. 筛选规则改动 #

在现有filter数组里追加下面的嵌套查询块，专门匹配stocks数组里符合要求的条目：

{
    "nested": {
        "path": "stocks",
        "query": {
            "bool": {
                "must": [
                    // 匹配同一条stocks记录的国家为EN
                    { "term": { "stocks.country": "EN" } },
                    // 匹配同一条stocks记录的库存值大于1
                    { "range": { "stocks.stock": { "gt": 1 } } }
                ]
            }
        }
    }
}

2. 排序逻辑修正 #

你原来的sort配置里引用了顶层的stock字段，这个字段在实际数据结构里根本不存在，排序会失效。如果要按EN国家的库存值倒序排，要把sort部分改成支持nested字段的结构：

"sort": [
    {
        "stocks.stock": {
            "order": "desc",
            "nested": {
                "path": "stocks",
                "filter": {
                    "term": { "stocks.country": "EN" }
                }
            }
        }
    }
]

整合后的完整可运行查询 #

把上面的改动和你原有查询逻辑合并后，完整结构如下：

{
    "index": "products",
    "body": {
        "size": 15,
        "from": 1,
        "sort": [
            {
                "stocks.stock": {
                    "order": "desc",
                    "nested": {
                        "path": "stocks",
                        "filter": {
                            "term": { "stocks.country": "EN" }
                        }
                    }
                }
            }
        ],
        "query": {
            "bool": {
                "must": [
                    {
                        "query_string": {
                            "query": "**",
                            "type": "best_fields",
                            "fields": [
                                "erp_id",
                                "title_en^2",
                                "translations.title^2",
                                "erp.title_en",
                                "erp.title",
                                "erp.options.title",
                                "erp.options.title_en"
                            ],
                            "analyze_wildcard": true,
                            "allow_leading_wildcard": true
                        }
                    }
                ],
                "filter": [
                    {
                        "term": {
                            "is_active": 1
                        }
                    },
                    {
                        "term": {
                            "shops.shop_id": 1
                        }
                    },
                    // 新增的库存匹配规则
                    {
                        "nested": {
                            "path": "stocks",
                            "query": {
                                "bool": {
                                    "must": [
                                        { "term": { "stocks.country": "EN" } },
                                        { "range": { "stocks.stock": { "gt": 1 } } }
                                    ]
                                }
                            }
                        }
                    }
                ]
            }
        },
        "aggs": {
            "max_price": {
                "filter": {
                    "term": {
                        "erp.price_lists.currency.abbr": "tmn"
                    }
                },
                "aggs": {
                    "result": {
                        "max": {
                            "field": "erp.price_lists.pivot.price_tt"
                        }
                    }
                }
            },
            "min_price": {
                "filter": {
                    "term": {
                        "erp.price_lists.currency.abbr": "tmn"
                    }
                },
                "aggs": {
                    "result": {
                        "min": {
                            "field": "erp.price_lists.pivot.price_tt"
                        }
                    }
                }
            }
        }
    }
}

常见踩坑提示 #

• 如果你的stocks.country被配置成了text类型（带分词器），term查询会因为分词不一致匹配不到结果，要换成对应的keyword字段，比如stocks.country.keyword
• 新增的匹配条件放在filter层级即可，不用挪到must里，因为不需要计算相关性得分，查询性能和原有逻辑保持一致
• 如果暂时没有权限调整mapping把stocks改成nested类型，普通object结构下根本做不到严格的同数组元素多条件匹配，长期维护建议一定要调整mapping配置

内容的提问来源于stack exchange，提问作者S.M_Emamian