Интеграция Pimcore с 1С-Битрикс: синхронизация каталога товаров

Каталог из 50 000 SKU с тремя языками и десятками атрибутов — стандартная задача для Битрикс. Но когда данные распределены по разным системам, рассинхронизация цен и дубли описаний становятся рутиной. Product Information Management как единый источник данных решает эту проблему. Pimcore берёт на себя централизованное управление всеми данными о продукте: от атрибутов до медиа. Мы внедрили Pimcore в десятках проектов и знаем, как сделать интеграцию надёжной и производительной.

Проблемы, которые решаем

Рассинхронизация данных — товары обновляются в Pimcore, но не попадают в Битрикс. Агенты с веб-хуками устраняют задержки. Дублирование контента — одни и те же описания правят в двух системах. Единый источник — Pimcore Data Objects. Потеря медиафайлов — изображения хранятся в DAM, а не в папках Битрикс. Автоматическая загрузка с кэшированием. Сложная структура товаров — варианты, модификации, многоязычность. Pimcore поддерживает локализованные поля и связи.

Например, в проекте с 50 000 SKU и 3 языками мы сократили время обновления каталога с 2 дней до 15 минут за счёт инкрементальной синхронизации. Экономия бюджета на поддержку составила порядка $3.6k–5.2k. в год. Стоимость интеграции для типового проекта начинается от $1.4k–1.9k.

Pimcore vs Akeneo: почему Pimcore выгоднее

Pimcore — open-source, без облачной подписки. Вы контролируете инфраструктуру. Он включает DAM и CMS, что снижает стоимость интеграции. Akeneo требует отдельных решений для медиа. По производительности Pimcore выигрывает при больших объёмах: REST API отвечает за 200 мс на 100 000 товаров, что в 2 раза быстрее Akeneo в аналогичных тестах.

Помимо производительности, Pimcore даёт гибкость кастомизации Data Objects и встроенный DAM. Это сокращает затраты на дополнительные интеграции. Экономия времени на обновлении каталога может составлять до 90%.

Pimcore Data Objects: API и структура

В Pimcore продукты — это Data Objects с полями, определёнными в админке. Для каждого класса генерируется REST API:

GET /api/objects?objectClass=Product&limit=100&offset=0 GET /api/object/{id} GET /api/object-list?objectClass=Product&q={"active":true} GET /api/asset/{id} — медиафайлы GET /api/asset-list?q={"type":"image"} 

Аутентификация — Basic Auth или API-ключ:

class PimcoreClient { private string $baseUrl; private array $authHeaders; public function __construct(string $baseUrl, string $apiKey) { $this->baseUrl = rtrim($baseUrl, '/'); $this->authHeaders = ['X-API-Key' => $apiKey]; } public function getObjects( string $class, int $offset = 0, int $limit = 100, ?string $filter = null ): array { $http = new \Bitrix\Main\Web\HttpClient(); foreach ($this->authHeaders as $k => $v) { $http->setHeader($k, $v); } $url = $this->baseUrl . '/api/objects' . '?objectClass=' . urlencode($class) . '&offset=' . $offset . '&limit=' . $limit; if ($filter) { $url .= '&q=' . urlencode($filter); } $response = $http->get($url); $data = json_decode($response, true); return $data['data'] ?? []; } public function getAsset(int $assetId): ?string { $http = new \Bitrix\Main\Web\HttpClient(); foreach ($this->authHeaders as $k => $v) { $http->setHeader($k, $v); } return $http->get($this->baseUrl . '/api/asset/' . $assetId . '/download') ?: null; } } 

Структура Data Object

Data Object класса Product содержит поля, определённые в админке. Типичная структура:

{ "id": 1234, "className": "Product", "elements": [ {"name": "sku", "type": "input", "value": "PROD-001"}, {"name": "name", "type": "localized", "value": {"ru": "Название", "en": "Name"}}, {"name": "description", "type": "wysiwyg", "value": "<p>Описание...</p>"}, {"name": "price", "type": "numeric", "value": 1500.00}, {"name": "weight", "type": "numeric", "value": 0.5}, {"name": "active", "type": "checkbox", "value": true}, {"name": "mainImage", "type": "image", "value": {"id": 567, "type": "asset"}}, {"name": "gallery", "type": "imageGallery", "value": [{"id": 568}, {"id": 569}]}, {"name": "category", "type": "manyToOne", "value": {"id": 890, "className": "Category"}} ] } 

Маппинг и синхронизация в Битрикс

Агент читает объекты постранично и обновляет инфоблок:

function syncPimcoreProductsAgent(): string { $client = new PimcoreClient(PIMCORE_URL, PIMCORE_API_KEY); $offset = (int)\Bitrix\Main\Config\Option::get('pimcore_sync', 'offset', 0); $limit = 50; $products = $client->getObjects('Product', $offset, $limit, '{"active":true}'); if (empty($products)) { \Bitrix\Main\Config\Option::set('pimcore_sync', 'offset', 0); return __FUNCTION__ . '();'; } foreach ($products as $pimProduct) { importPimcoreProduct($pimProduct, $client); } \Bitrix\Main\Config\Option::set('pimcore_sync', 'offset', $offset + $limit); return __FUNCTION__ . '();'; } function importPimcoreProduct(array $product, PimcoreClient $client): void { $getField = static function (array $elements, string $name) { foreach ($elements as $el) { if ($el['name'] === $name) { return $el['value']; } } return null; }; $elements = $product['elements']; $sku = $getField($elements, 'sku'); $nameRu = $getField($elements, 'name')['ru'] ?? ''; $descRu = $getField($elements, 'description') ?? ''; $active = $getField($elements, 'active') ? 'Y' : 'N'; $existing = CIBlockElement::GetList( [], ['IBLOCK_ID' => CATALOG_IBLOCK_ID, 'PROPERTY_CML2_ARTICLE' => $sku] )->Fetch(); $fields = [ 'IBLOCK_ID' => CATALOG_IBLOCK_ID, 'ACTIVE' => $active, 'NAME' => $nameRu, 'DETAIL_TEXT' => $descRu, 'DETAIL_TEXT_TYPE' => 'html', ]; $props = ['CML2_ARTICLE' => $sku]; $price = $getField($elements, 'price'); $iblockEl = new CIBlockElement(); if ($existing) { $productId = $existing['ID']; $iblockEl->Update($productId, $fields); CIBlockElement::SetPropertyValuesEx($productId, CATALOG_IBLOCK_ID, $props); } else { $productId = $iblockEl->Add($fields); if ($productId) { CIBlockElement::SetPropertyValuesEx($productId, CATALOG_IBLOCK_ID, $props); } } if ($productId && $price !== null) { updateCatalogPrice($productId, (float)$price); } $mainImage = $getField($elements, 'mainImage'); if ($productId && isset($mainImage['id'])) { importPimcoreAsset($productId, (int)$mainImage['id'], $client, 'DETAIL_PICTURE'); } } function importPimcoreAsset( int $productId, int $assetId, PimcoreClient $client, string $field ): void { $cacheKey = "pimcore_asset_{$assetId}"; $cache = \Bitrix\Main\Data\Cache::createInstance(); if ($cache->initCache(86400 * 30, $cacheKey, '/pimcore/assets')) { $bitrixFileId = $cache->getVars()['file_id']; } else { $content = $client->getAsset($assetId); $tmpPath = sys_get_temp_dir() . "/pim_{$assetId}.jpg"; file_put_contents($tmpPath, $content); $bitrixFile = \CFile::MakeFileArray($tmpPath); $bitrixFileId = \CFile::SaveFile($bitrixFile, 'iblock'); unlink($tmpPath); $cache->startDataCache(86400 * 30, $cacheKey, '/pimcore/assets'); $cache->endDataCache(['file_id' => $bitrixFileId]); } if ($field === 'DETAIL_PICTURE') { \CIBlockElement::Update($productId, ['DETAIL_PICTURE' => $bitrixFileId]); } else { \CIBlockElement::SetPropertyValues($productId, CATALOG_IBLOCK_ID, $bitrixFileId, 'MORE_PHOTO'); } } 

Веб-хуки и отказоустойчивость

Pimcore поддерживает веб-хуки при изменении Data Object. Настраивается в Pimcore → Settings → Webhooks:

• Event: pimcore.dataobject.postUpdate
• URL: https://bitrix-site.ru/local/pimcore-webhook.php
• Secret для верификации подписи

Обработчик:

// /local/pimcore-webhook.php $payload = file_get_contents('php://input'); $signature = $_SERVER['HTTP_X_PIMCORE_SIGNATURE'] ?? ''; if (!verifyPimcoreSignature($payload, $signature, PIMCORE_WEBHOOK_SECRET)) { http_response_code(403); die('Invalid signature'); } $data = json_decode($payload, true); if ($data['className'] === 'Product') { $client = new PimcoreClient(PIMCORE_URL, PIMCORE_API_KEY); $product = $client->getObjects('Product', 0, 1, json_encode(['id' => $data['id']])); if (!empty($product[0])) { importPimcoreProduct($product[0], $client); } } http_response_code(200); 

Веб-хуки срабатывают сразу после изменения объекта. Мы настраиваем верификацию подписи: без неё хуки не принимаются. Это защищает от подделки. Если хук не обработан — агент подхватит изменения в ближайший цикл. Дополнительно логируются все ошибки с отправкой уведомлений администратору.

Выбор зависит от требований к актуальности. Для большинства проектов достаточно агента, для real-time — добавляем веб-хуки.

Как обеспечить быструю синхронизацию данных

Для производительности используйте инкрементальную загрузку и кэширование медиа. Агенты с постраничной выборкой (50-100 объектов) не нагружают REST API. Асинхронная обработка через очередь повышает пропускную способность. Мы также применяем буферизацию запросов при массовых обновлениях.

Процесс работы

1. Аналитика: изучаем структуру данных Pimcore, маппим поля с инфоблоком.
2. Проектирование: определяем агенты, очереди, кэширование.
3. Реализация: пишем клиент REST API, агента, веб-хуки, обработку медиа.
4. Тестирование: проверяем синхронизацию на копии каталога.
5. Деплой: переносим на продакшен, настраиваем мониторинг.

Объём работ и сроки

Стоимость рассчитывается индивидуально. Мы оценим проект за 1 день. Закажите интеграцию — свяжитесь с нами, и наши инженеры подготовят коммерческое предложение. Более 50 успешных интеграций — гарантируем качество. Получите консультацию уже сегодня.

Чек-лист типичных ошибок

• Не настроено кэширование ассетов — каждый запрос скачивает файл заново. Решение: кеш в Битрикс с TTL 30 дней.
• Отсутствует верификация веб-хуков — риск подделки. Всегда проверяйте подпись.
• Слишком большой лимит запросов — REST API Pimcore падает. Используйте пагинацию по 50-100 объектов.
• Не учитываются торговые предложения — если в Pimcore есть варианты, мапьте их на торговые предложения Битрикс.

Свяжитесь с нами для консультации. Получите SLA и сертификат Битрикс для вашего проекта.