Реализация двусторонней синхронизации каталога товаров с PIM-системой

Реализация двусторонней синхронизации каталога товаров с PIM-системой

PIM (Product Information Management) — централизованное хранилище данных о товарах: Akeneo, Pimcore, Plytix, Syndigo. Основная ценность PIM — один источник правды для всех каналов продаж: сайт, маркетплейсы, печатные каталоги. Интеграция сайта с PIM означает, что сайт всегда показывает актуальные обогащённые данные.

Архитектура интеграции с Akeneo

Akeneo предоставляет REST API версии 1.0+:

GET  /api/rest/v1/products           — список товаров
GET  /api/rest/v1/products/{code}    — конкретный товар
GET  /api/rest/v1/product-models     — модели (для вариативных товаров)
GET  /api/rest/v1/categories         — дерево категорий
GET  /api/rest/v1/attributes         — схема атрибутов
GET  /api/rest/v1/families           — семейства товаров

Аутентификация через OAuth2 с client credentials flow.

Пагинированный импорт

class AkeneoSyncService
{
    private AkeneoClient $client;

    public function syncProducts(): void
    {
        $cursor = null;

        do {
            $response = $this->client->getProducts([
                'limit'       => 100,
                'search'      => json_encode(['enabled' => [['operator' => '=', 'value' => true]]]),
                'search_after'=> $cursor,
            ]);

            foreach ($response['_embedded']['items'] as $item) {
                $this->upsertProduct($item);
            }

            $nextLink = $response['_links']['next']['href'] ?? null;
            $cursor   = $nextLink ? $this->extractCursor($nextLink) : null;

        } while ($cursor !== null);
    }

    private function upsertProduct(array $akeneoProduct): void
    {
        // Извлечение локализованных значений
        $values = $akeneoProduct['values'];
        $name   = $this->getLocaleValue($values, 'name', 'ru_RU');
        $desc   = $this->getLocaleValue($values, 'description', 'ru_RU');
        $price  = $this->getScopedValue($values, 'price', 'ecommerce');

        Product::updateOrCreate(
            ['akeneo_code' => $akeneoProduct['identifier']],
            compact('name', 'desc', 'price') + [
                'family'      => $akeneoProduct['family'],
                'categories'  => $akeneoProduct['categories'],
                'raw_values'  => $values,   // JSONB — полные данные из PIM
                'synced_at'   => now(),
            ]
        );
    }

    private function getLocaleValue(array $values, string $attr, string $locale): ?string
    {
        return collect($values[$attr] ?? [])
            ->firstWhere('locale', $locale)['data'] ?? null;
    }
}

Webhook от Akeneo (изменения в реальном времени)

Akeneo Enterprise поддерживает event subscriptions:

// Обработчик входящих событий от Akeneo
Route::post('/webhooks/akeneo', function (Request $request) {
    $signature = $request->header('X-Akeneo-Request-Signature');

    if (!hash_equals(
        hash_hmac('sha256', $request->getContent(), config('akeneo.webhook_secret')),
        $signature
    )) {
        abort(401);
    }

    foreach ($request->json('events') as $event) {
        match($event['action']) {
            'product.created', 'product.updated' =>
                SyncAkeneoProduct::dispatch($event['resource']['identifier']),
            'product.removed' =>
                Product::where('akeneo_code', $event['resource']['identifier'])
                       ->update(['active' => false]),
        };
    }

    return response('ok');
});

Обратная синхронизация: сайт → PIM

Данные, которые генерирует сайт и имеют ценность для PIM: рейтинги, количество просмотров, данные о конверсии. Пишутся через API Akeneo как custom attributes.

Сроки

Интеграция с Akeneo PIM (односторонняя): 6–10 дней. Двусторонняя с webhook-поддержкой: 10–16 дней.