Elastica实现全量产品查询并按用户收藏优先级排序

要实现返回所有产品且收藏产品排在最前面的需求，你需要放弃原有的Term Query过滤逻辑，改用**函数得分查询（Function Score Query）**通过得分排序区分收藏与非收藏产品，具体步骤如下：

核心思路 #

1. 移除原代码中BoolQuery的must条件（该条件会过滤掉非收藏产品）
2. 使用Function Score Query为当前用户收藏的产品额外增加权重得分
3. 按得分降序排序，让高分的收藏产品排在前列，同时保留所有产品

修改后的代码实现 #

基础版（无其他筛选条件） #

public function applySort(Query $query): void
{
    // 1. 构建匹配所有产品的查询
    $matchAllQuery = new Query\MatchAll();

    // 2. 定义得分规则：当前用户收藏的产品加10分
    $favoriteFilter = new Query\Term([
        'user_ids_who_added_this_product_to_favorite' => $this->getUser()->getId()
    ]);
    $weightFunction = new Query\FunctionScore\Weight(10);
    $filterFunction = new Query\FunctionScore\FilterFunction($favoriteFilter, $weightFunction);

    // 3. 组装Function Score Query
    $functionScoreQuery = new Query\FunctionScore();
    $functionScoreQuery->setQuery($matchAllQuery);
    $functionScoreQuery->addFilterFunction($filterFunction);
    $functionScoreQuery->setBoostMode('sum'); // 原始得分 + 额外权重

    // 4. 设置主查询与排序规则
    $query->setQuery($functionScoreQuery);
    $query->setSort([
        '_score' => ['order' => 'desc'], // 按得分降序，收藏产品在前
        'id' => ['order' => 'asc']       // 备用排序，保证非收藏产品顺序稳定
    ]);
}

进阶版（保留其他筛选条件） #

如果业务中需要保留其他筛选逻辑（比如分类、价格区间等），可以将基础查询替换为原有的BoolQuery：

public function applySort(Query $query, Query\BoolQuery $boolQuery): void
{
    // 移除原有的收藏过滤条件（如果之前添加过）
    // $boolQuery->getMust()->clear();

    // 定义得分规则：给当前用户收藏的产品加10分
    $favoriteFilter = new Query\Term([
        'user_ids_who_added_this_product_to_favorite' => $this->getUser()->getId()
    ]);
    $weightFunction = new Query\FunctionScore\Weight(10);
    $filterFunction = new Query\FunctionScore\FilterFunction($favoriteFilter, $weightFunction);

    // 组装Function Score Query，保留原有筛选条件
    $functionScoreQuery = new Query\FunctionScore();
    $functionScoreQuery->setQuery($boolQuery);
    $functionScoreQuery->addFilterFunction($filterFunction);
    $functionScoreQuery->setBoostMode('sum');

    // 设置查询与排序
    $query->setQuery($functionScoreQuery);
    $query->setSort([
        '_score' => ['order' => 'desc'],
        'id' => ['order' => 'asc']
    ]);
}

关键说明 #

• 为什么不用过滤？：原代码中的must条件会直接排除非收藏产品，而我们需要保留所有产品，仅通过得分排序区分优先级
• 权重值调整：你可以根据需求修改Weight(10)中的数值，数值越大，收藏产品与非收藏产品的得分差距越明显
• 映射兼容性：你当前的user_ids_who_added_this_product_to_favorite字段映射为integer是可行的，Elasticsearch会自动处理多用户ID的存储（多值字段）

内容的提问来源于stack exchange，提问作者Mahmoud