Реализация автоматического обновления описаний и характеристик товаров

Реализация автоматического обновления описаний и характеристик товаров

Описания и характеристики товаров — контент, который поставщики регулярно расширяют и уточняют. Новый ГОСТ, исправленные технические параметры, добавленные сертификаты — всё это должно попадать в каталог без ручной работы редакторов. При этом если контент-менеджер вручную переписал описание — автоматика не должна его затирать.

Структура данных для управляемого обновления

Ключевой принцип: разделять источник данных (поставщик) и финальный контент (что показывается на сайте), с флагом «вручную отредактировано».

CREATE TABLE product_content (
    product_id          int        REFERENCES products(id),
    source              varchar(30),          -- supplier_id или 'manual'
    field               varchar(50),          -- description | spec_weight | spec_color ...
    value               text,
    is_manual_override  boolean DEFAULT false,
    supplier_value      text,                 -- последнее значение от поставщика
    updated_at          timestamptz,
    PRIMARY KEY (product_id, field)
);

При автообновлении: если is_manual_override = true — обновлять только supplier_value, но не value. Контент-менеджер видит расхождение в интерфейсе и решает, принять ли изменение поставщика.

Источники описаний

XML-фид поставщика

Большинство производственных компаний предоставляют XML с расширенными атрибутами:

<product article="ABC-123">
  <description lang="ru"><![CDATA[Подробное описание...]]></description>
  <attributes>
    <attribute name="weight" unit="kg">2.5</attribute>
    <attribute name="color">Чёрный</attribute>
    <attribute name="material">Нержавеющая сталь</attribute>
  </attributes>
</product>

Парсер на PHP:

class XmlDescriptionSource implements DescriptionSourceInterface
{
    public function fetch(): iterable
    {
        $xml = new \XMLReader();
        $xml->open($this->url);

        while ($xml->read()) {
            if ($xml->nodeType === \XMLReader::ELEMENT && $xml->name === 'product') {
                $node = new \SimpleXMLElement($xml->readOuterXml());
                yield $this->parseProduct($node);
            }
        }
        $xml->close();
    }

    private function parseProduct(\SimpleXMLElement $node): array
    {
        $data = [
            'sku'         => (string) $node['article'],
            'description' => (string) $node->description,
            'attributes'  => [],
        ];
        foreach ($node->attributes->attribute as $attr) {
            $data['attributes'][(string) $attr['name']] = (string) $attr;
        }
        return $data;
    }
}

XMLReader читает файл потоково — не загружает весь XML в память, что критично при каталогах от 100 000 позиций.

API с частичным обновлением

Если поставщик предоставляет endpoint изменений:

GET /products/updates?fields=description,attributes&since=2024-01-15T10:00:00Z

Возвращает только товары, у которых изменилось хотя бы одно из указанных полей — существенно сокращает объём обработки.

Обновление характеристик с нормализацией

Поставщик присылает характеристики в собственном формате — нужно привести к внутренней схеме сайта:

class AttributeNormalizer
{
    // Маппинг имён атрибутов поставщика → внутренние ключи
    private array $nameMap = [
        'weight'       => 'spec_weight_kg',
        'масса'        => 'spec_weight_kg',
        'вес нетто'    => 'spec_weight_kg',
        'color'        => 'spec_color',
        'цвет'         => 'spec_color',
    ];

    public function normalize(string $supplierName, mixed $value): ?array
    {
        $key = $this->nameMap[mb_strtolower(trim($supplierName))] ?? null;
        if (!$key) return null;

        return ['key' => $key, 'value' => $this->castValue($key, $value)];
    }

    private function castValue(string $key, mixed $raw): mixed
    {
        return match(true) {
            str_starts_with($key, 'spec_weight') => (float) str_replace(',', '.', $raw),
            default => (string) $raw,
        };
    }
}

Job-цепочка для обновления контента

Обновление описаний тяжелее обновления цен — контент большой, нужно нормализовать атрибуты, сравнивать с override-флагами. Оптимальная схема: отдельная очередь с низким параллелизмом.

class UpdateProductDescriptionsJob implements ShouldQueue
{
    public int $tries = 3;
    public int $backoff = 60; // секунды между повторами

    public function handle(
        DescriptionSourceInterface $source,
        AttributeNormalizer        $normalizer,
        ContentUpdater             $updater,
    ): void {
        foreach ($source->fetch() as $item) {
            $productId = Product::where('sku', $item['sku'])->value('id');
            if (!$productId) continue;

            // Описание
            $updater->updateField($productId, 'description', $item['description']);

            // Характеристики
            foreach ($item['attributes'] as $name => $value) {
                $normalized = $normalizer->normalize($name, $value);
                if ($normalized) {
                    $updater->updateField($productId, $normalized['key'], $normalized['value']);
                }
            }
        }
    }
}

Логика ContentUpdater

class ContentUpdater
{
    public function updateField(int $productId, string $field, mixed $newValue): void
    {
        $existing = ProductContent::where([
            'product_id' => $productId,
            'field'      => $field,
        ])->first();

        if (!$existing) {
            ProductContent::create([
                'product_id'     => $productId,
                'field'          => $field,
                'value'          => $newValue,
                'supplier_value' => $newValue,
            ]);
            return;
        }

        // Всегда обновляем supplier_value для отображения расхождения
        $existing->supplier_value = $newValue;

        // Перезаписываем только если нет ручного оверрайда
        if (!$existing->is_manual_override) {
            $existing->value = $newValue;
        }

        $existing->updated_at = now();
        $existing->save();
    }
}

Расписание и приоритеты

Интерфейс расхождений в админке

Если value != supplier_value AND is_manual_override = true, показывать в интерфейсе товара предупреждение: «Поставщик изменил значение. Текущее: X, новое от поставщика: Y. Принять?» с кнопками «Принять» и «Оставить».

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

• Один XML-источник, обновление описания и атрибутов без оверрайдов — 2–3 дня
• Нормализатор атрибутов с маппинг-таблицей + оверрайд-механизм — +2 дня
• Дашборд расхождений в админке — +1–2 дня