Algolia多索引搜索结果聚合：实现与策略

{
  "results": [
    {
      "hits": [
        { "objectID": "p1", "name": "Product A", "type": "product" }
      ],
      "index": "products",
      "page": 0,
      "nbHits": 1,
      "nbPages": 1,
      "hitsPerPage": 20,
      "query": "search_term"
    },
    {
      "hits": [
        { "objectID": "r1", "title": "Resource X", "type": "resource" },
        { "objectID": "r2", "title": "Resource Y", "type": "resource" }
      ],
      "index": "resources",
      "page": 0,
      "nbHits": 2,
      "nbPages": 1,
      "hitsPerPage": 20,
      "query": "search_term"
    }
    // ... 更多索引的结果
  ]
}

<?php

require __DIR__ . '/vendor/autoload.php';

use Algolia\AlgoliaSearch\SearchClient;

// 初始化Algolia客户端
// 替换为你的应用ID和API密钥
$client = SearchClient::create('YOUR_APP_ID', 'YOUR_SEARCH_API_KEY');

// 定义要查询的索引
$indices = [
    'products',
    'resources',
    'news'
];

$queries = [];
foreach ($indices as $indexName) {
    $queries[] = [
        'indexName' => $indexName,
        'query'     => 'search_term', // 你的搜索关键词
        'params'    => [
            'hitsPerPage' => 10 // 每个索引返回的命中数
        ]
    ];
}

try {
    // 执行多索引查询
    $response = $client->multipleQueries($queries);

    $aggregatedHits = [];
    $totalNbHits = 0;

    // 遍历每个索引的结果并聚合hits
    foreach ($response['results'] as $result) {
        // 可选：为每个命中项添加源索引信息，以便后续区分
        foreach ($result['hits'] as &$hit) {
            $hit['_index'] = $result['index'];
        }
        $aggregatedHits = array_merge($aggregatedHits, $result['hits']);
        $totalNbHits += $result['nbHits'];
    }

    // 此时 $aggregatedHits 包含了所有索引的命中项
    // 可以对 $aggregatedHits 进行进一步的处理，例如统一排序
    // 注意：这里的nbHits只是一个简单的累加，实际分页逻辑会更复杂
    $finalResult = [
        'hits' => $aggregatedHits,
        'nbHits' => $totalNbHits,
        'page' => 0, // 聚合后的分页需要单独处理
        'hitsPerPage' => 20, // 聚合后的每页命中数也需要单独处理
        'query' => 'search_term',
        'processingTimeMS' => $response['results'][0]['processingTimeMS'] ?? 0 // 示例，可能需要更复杂的计算
    ];

    // 打印聚合后的结果
    header('Content-Type: application/json');
    echo json_encode($finalResult, JSON_PRETTY_PRINT);

} catch (Exception $e) {
    echo "Error: " . $e->getMessage();
}

?>