Реалізація двосторонньої синхронізації каталогу товарів з 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 днів.