Реализация агрегации товаров от нескольких поставщиков на сайте

Реализация агрегации товаров от нескольких поставщиков на сайте

Агрегация — это не просто слияние списков. Это создание единой карточки товара на основе данных от нескольких поставщиков с сохранением связи с каждым источником. Цель: покупатель видит одну карточку, но за ней стоит актуальный выбор из нескольких предложений с разными ценами, сроками и наличием.

Разница между импортом и агрегацией

Импорт — сохранение «как есть». Агрегация — построение витрины над сырыми данными нескольких поставщиков.

При агрегации нужно решить три задачи:

1. Распознавание — понять, что SKU-447 у поставщика A и ART-10023 у поставщика B — один и тот же товар
2. Слияние — выбрать, чьи атрибуты (название, фото, описание) считать основными
3. Витрина цен — показать покупателю лучшее предложение или дать выбор

Схема данных для агрегации

-- Мастер-карточка (агрегированная)
CREATE TABLE products (
    id              BIGSERIAL PRIMARY KEY,
    master_sku      VARCHAR(255) UNIQUE NOT NULL,
    name            TEXT NOT NULL,        -- из "главного" поставщика
    description     TEXT,
    attributes      JSONB DEFAULT '{}',
    category_id     INT REFERENCES categories(id),
    created_at      TIMESTAMP DEFAULT NOW(),
    updated_at      TIMESTAMP DEFAULT NOW()
);

-- Предложения поставщиков к мастер-карточке
CREATE TABLE product_offers (
    id              BIGSERIAL PRIMARY KEY,
    product_id      BIGINT NOT NULL REFERENCES products(id),
    supplier_id     INT NOT NULL REFERENCES suppliers(id),
    supplier_sku    VARCHAR(255) NOT NULL,
    price           NUMERIC(12,2) NOT NULL,
    stock           INT NOT NULL DEFAULT 0,
    lead_time_days  SMALLINT,             -- срок поставки
    is_primary      BOOLEAN DEFAULT FALSE, -- источник контента для карточки
    last_synced_at  TIMESTAMP,
    UNIQUE(supplier_id, supplier_sku)
);

-- Индексы для быстрого поиска лучшего предложения
CREATE INDEX idx_offers_product_price ON product_offers(product_id, price)
    WHERE stock > 0;

Логика выбора "лучшего предложения"

Лучшее предложение определяется по настраиваемым правилам. Типовой вариант: минимальная цена среди поставщиков с наличием.

class BestOfferResolver
{
    public function resolve(int $productId): ?ProductOffer
    {
        return ProductOffer::where('product_id', $productId)
            ->where('stock', '>', 0)
            ->orderByRaw('
                price * (1 + COALESCE(
                    (SELECT markup FROM suppliers WHERE id = supplier_id), 0
                ) / 100)
            ')
            ->orderBy('lead_time_days')
            ->first();
    }
}

Более гибкий подход — скоринг через взвешенные критерии:

class WeightedOfferScorer
{
    // Настройки весов из конфигурации магазина
    private float $priceWeight      = 0.60;
    private float $stockWeight      = 0.25;
    private float $leadTimeWeight   = 0.15;

    public function score(ProductOffer $offer, array $stats): float
    {
        // Нормализация: лучший получает 1.0
        $priceScore    = $stats['min_price'] / max($offer->price, 0.01);
        $stockScore    = min($offer->stock / 100, 1.0);
        $leadScore     = $stats['max_lead'] > 0
            ? 1 - ($offer->lead_time_days / $stats['max_lead'])
            : 1.0;

        return $this->priceWeight    * $priceScore
             + $this->stockWeight    * $stockScore
             + $this->leadTimeWeight * $leadScore;
    }
}

Агрегатная витрина в API

Ответ API для карточки товара должен включать агрегированные данные:

class ProductResource extends JsonResource
{
    public function toArray($request): array
    {
        $bestOffer = $this->bestOffer;

        return [
            'id'           => $this->id,
            'name'         => $this->name,
            'description'  => $this->description,
            'attributes'   => $this->attributes,

            // Агрегированные цены
            'price'        => $bestOffer?->price,
            'price_min'    => $this->offers->where('stock', '>', 0)->min('price'),
            'price_max'    => $this->offers->where('stock', '>', 0)->max('price'),
            'in_stock'     => $this->offers->where('stock', '>', 0)->count() > 0,
            'total_stock'  => $this->offers->sum('stock'),

            // Список предложений (если магазин показывает их явно)
            'offers'       => OfferResource::collection(
                $this->offers->where('stock', '>', 0)->sortBy('price')
            ),
        ];
    }
}

Обновление агрегации при изменении предложений

Агрегированные показатели должны обновляться при каждом изменении предложения поставщика. Через Observer:

class ProductOfferObserver
{
    public function saved(ProductOffer $offer): void
    {
        // Пересчёт агрегатов в кэше
        Cache::forget("product.{$offer->product_id}.best_offer");
        Cache::forget("product.{$offer->product_id}.price_range");

        // Обновление денормализованных полей в products
        $this->recalculate($offer->product_id);
    }

    private function recalculate(int $productId): void
    {
        $agg = ProductOffer::where('product_id', $productId)
            ->where('stock', '>', 0)
            ->selectRaw('MIN(price) as min_price, MAX(price) as max_price, SUM(stock) as total_stock')
            ->first();

        Product::where('id', $productId)->update([
            'price_min'    => $agg->min_price,
            'price_max'    => $agg->max_price,
            'total_stock'  => $agg->total_stock,
            'updated_at'   => now(),
        ]);
    }
}

Отображение нескольких предложений на карточке

Если бизнес-логика предусматривает выбор поставщика покупателем (как у Яндекс.Маркета):

// React-компонент списка предложений
const OfferList: React.FC<{ offers: Offer[] }> = ({ offers }) => {
  const sorted = [...offers].sort((a, b) => a.price - b.price);

  return (
    <div className="space-y-2">
      {sorted.map(offer => (
        <div key={offer.id} className="flex items-center justify-between border rounded p-3">
          <div>
            <span className="font-semibold">{formatPrice(offer.price)}</span>
            <span className="text-sm text-gray-500 ml-2">
              {offer.supplier.name}
            </span>
          </div>
          <div className="text-sm text-gray-500">
            {offer.stock > 0
              ? `в наличии ${offer.stock} шт.`
              : 'нет в наличии'}
            {offer.lead_time_days && ` · доставка ${offer.lead_time_days} дн.`}
          </div>
          <button
            onClick={() => addToCart(offer)}
            disabled={offer.stock === 0}
            className="btn-primary"
          >
            Купить
          </button>
        </div>
      ))}
    </div>
  );
};

Инвалидация кэша и Elasticsearch

При большом каталоге (50 000+ товаров) агрегаты часто хранятся в Elasticsearch — это ускоряет фильтрацию по цене, наличию, поставщику. При изменении предложения нужно переиндексировать документ:

ProductOffer::saved(function ($offer) {
    ReindexProductJob::dispatch($offer->product_id);
});

В маппинге Elasticsearch предложения хранятся как nested объекты, что позволяет фильтровать по конкретным комбинациям атрибутов поставщика.

Сроки реализации

• Схема данных + логика слияния + BestOfferResolver: 2 дня
• Observer + денормализация агрегатов: 1 день
• API-ресурс с предложениями + фронтенд компонент: 1–2 дня
• Интеграция с Elasticsearch: +2 дня
• Настройка весовых коэффициентов через админку: +1 день

Базовая агрегация без поиска: 4–5 рабочих дней.