在Algolia中合并多索引搜索结果：从分散到统一的策略

{
  "results": [
    {
      "hits": [
        { "objectID": "product1", "name": "Paint A", "type": "product" }
      ],
      "page": 0,
      "nbHits": 1,
      "index": "products"
    },
    {
      "hits": [
        { "objectID": "resource1", "title": "Painting Guide", "type": "resource" },
        { "objectID": "resource2", "title": "Brush Care", "type": "resource" }
      ],
      "page": 0,
      "nbHits": 2,
      "index": "resources"
    },
    {
      "hits": [
        { "objectID": "news1", "headline": "New Paint Line", "type": "news" }
      ],
      "page": 0,
      "nbHits": 1,
      "index": "news"
    }
  ]
}

{
  "results": [
    {
      "hits": [
        { "objectID": "product1", "name": "Paint A", "type": "product" },
        { "objectID": "resource1", "title": "Painting Guide", "type": "resource" },
        { "objectID": "resource2", "title": "Brush Care", "type": "resource" },
        { "objectID": "news1", "headline": "New Paint Line", "type": "news" }
      ],
      "page": 0,
      "nbHits": 4,
      "index": "combined_indices"
    }
  ]
}

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

use Algolia\AlgoliaSearch\SearchClient;

// 初始化Algolia客户端
$client = SearchClient::create(
    'YOUR_APPLICATION_ID', // 替换为您的应用ID
    'YOUR_SEARCH_API_KEY'  // 替换为您的搜索API Key
);

// 定义多索引查询
$queries = [
    [
        'indexName' => 'products',
        'query'     => 'jimmie paint',
        'params'    => ['hitsPerPage' => 5, 'attributesToRetrieve' => ['objectID', 'name', 'price', 'created_at']],
    ],
    [
        'indexName' => 'resources',
        'query'     => 'jimmie paint',
        'params'    => ['hitsPerPage' => 5, 'attributesToRetrieve' => ['objectID', 'title', 'url', 'created_at']],
    ],
    [
        'indexName' => 'news',
        'query'     => 'jimmie paint',
        'params'    => ['hitsPerPage' => 5, 'attributesToRetrieve' => ['objectID', 'headline', 'date', 'created_at']],
    ],
];

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

    $allHits = [];
    $totalNbHits = 0;
    $maxProcessingTimeMS = 0;
    $combinedQuery = $queries[0]['query']; // 假设所有查询的搜索词相同

    // 聚合所有索引的命中记录
    foreach ($response['results'] as $result) {
        // 为每个命中记录添加 'source_index' 标识
        foreach ($result['hits'] as &$hit) {
            $hit['source_index'] = $result['indexName']; // 使用 indexName 标识
            // 统一时间戳字段，方便排序
            if (isset($hit['date'])) {
                $hit['created_at'] = $hit['date']; // 统一为 created_at
                unset($hit['date']);
            }
        }
        $allHits = array_merge($allHits, $result['hits']);
        $totalNbHits += $result['nbHits'];
        $maxProcessingTimeMS = max($maxProcessingTimeMS, $result['processingTimeMS']);
    }

    // 可选：对聚合后的命中记录进行排序
    // 示例：按 'created_at' 字段降序排列（最新在前）
    usort($allHits, function($a, $b) {
        $a_time = isset($a['created_at']) ? (is_numeric($a['created_at']) ? $a['created_at'] : strtotime($a['created_at'])) : 0;
        $b_time = isset($b['created_at']) ? (is_numeric($b['created_at']) ? $b['created_at'] : strtotime($b['created_at'])) : 0;
        return $b_time <=> $a_time; // 降序
    });

    // 假设每页显示20条结果
    $hitsPerPage = 20;
    $nbPages = ceil($totalNbHits / $hitsPerPage);

    // 构建符合期望的单一命中记录格式
    $aggregatedResponse = [
        'results' => [
            [
                'hits'               => $allHits,
                'page'               => 0, // 客户端聚合后，此值通常重置
                'nbHits'             => $totalNbHits,
                'nbPages'            => $nbPages,
                'hitsPerPage'        => $hitsPerPage,
                'processingTimeMS'   => $maxProcessingTimeMS,
                'query'              => $combinedQuery,
                'params'             => 'custom_combined_params', // 自定义参数标识
                'index'              => 'combined_indices', // 标识为组合索引
            ],
        ],
    ];

    header('Content-Type: application/json');
    echo json_encode($aggregatedResponse, JSON_PRETTY_PRINT);

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

<!-- 假设使用 InstantSearch.js 或 Autocomplete.js -->
<div id="searchbox"></div>
<div id="hits-products"></div>
<div id="hits-resources"></div>
<div id="hits-news"></div>

<script>
  // 伪代码，展示概念
  // const search = instantsearch({ ... });
  // search.addWidgets([
  //   instantsearch.widgets.searchBox({ container: '#searchbox' }),
  //   instantsearch.widgets.hits({ container: '#hits-products', index: 'products' }),
  //   instantsearch.widgets.hits({ container: '#hits-resources', index: 'resources' }),
  //   instantsearch.widgets.hits({ container: '#hits-news', index: 'news' }),
  // ]);
  // search.start();
</script>