Algolia多索引搜索结果的客户端聚合与联合搜索策略

{
  "results": [
    {
      "hits": [
        { "objectID": "p1", "name": "Product A", "_index": "products" }
      ],
      "index": "products",
      // ... 其他元数据
    },
    {
      "hits": [
        { "objectID": "r1", "title": "Resource X", "_index": "resources" },
        { "objectID": "r2", "title": "Resource Y", "_index": "resources" }
      ],
      "index": "resources",
      // ... 其他元数据
    },
    {
      "hits": [
        { "objectID": "n1", "headline": "News Z", "_index": "news" }
      ],
      "index": "news",
      // ... 其他元数据
    }
  ]
}

<?php

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

use Algolia\AlgoliaSearch\SearchClient;

// 替换为你的Algolia应用ID和API密钥
$appId = 'YOUR_APP_ID';
$apiKey = 'YOUR_API_KEY';

$client = SearchClient::create($appId, $apiKey);

// 定义要查询的索引和查询参数
$queries = [
    [
        'indexName' => 'products',
        'query' => 'jimmie paint',
        'params' => [
            'hitsPerPage' => 5,
            'attributesToRetrieve' => ['objectID', 'name', 'price']
        ]
    ],
    [
        'indexName' => 'resources',
        'query' => 'jimmie paint',
        'params' => [
            'hitsPerPage' => 5,
            'attributesToRetrieve' => ['objectID', 'title', 'category']
        ]
    ],
    [
        'indexName' => 'news',
        'query' => 'jimmie paint',
        'params' => [
            'hitsPerPage' => 5,
            'attributesToRetrieve' => ['objectID', 'headline', 'date']
        ]
    ]
];

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

    $aggregatedHits = [];
    $totalNbHits = 0; // 用于记录所有索引的总命中数

    // 遍历每个索引的结果，并聚合hits
    foreach ($response['results'] as $result) {
        foreach ($result['hits'] as $hit) {
            // 可选：为每个hit添加一个'_index'字段，以便在聚合后识别其来源
            $hit['_index'] = $result['index'];
            $aggregatedHits[] = $hit;
        }
        $totalNbHits += $result['nbHits'];
    }

    // 构造期望的单一同源结果格式
    $finalResult = [
        'results' => [
            [
                'hits' => $aggregatedHits,
                'page' => 0, // 聚合后通常需要重新计算或统一处理分页
                'nbHits' => $totalNbHits,
                'nbPages' => ceil($totalNbHits / 20), // 假设每页20个
                'hitsPerPage' => 20, // 聚合后通常需要统一的每页命中数
                'processingTimeMS' => $response['processingTimeMS'], // 可以取所有查询的最大值或总和
                'query' => 'jimmie paint',
                'params' => '...', // 聚合后参数可能需要重新组合
                'index' => 'aggregated_indices' // 指示这是聚合结果
            ]
        ]
    ];

    // 输出聚合后的结果
    echo json_encode($finalResult, JSON_PRETTY_PRINT);

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

?>

// 伪代码示例：使用Autocomplete.js实现联合搜索
autocomplete('#search-input', {}, [
  {
    source: autocomplete.sources.hits(productsIndex, { hitsPerPage: 3 }),
    displayKey: 'name',
    templates: {
      header: '<span>产品</span>',
      suggestion: function(suggestion) {
        return '<div>' + suggestion.name + '</div>';
      }
    }
  },
  {
    source: autocomplete.sources.hits(newsIndex, { hitsPerPage: 3 }),
    displayKey: 'title',
    templates: {
      header: '<span>新闻</span>',
      suggestion: function(suggestion) {
        return '<div>' + suggestion.title + '</div>';
      }
    }
  }
]);