В предишна статия Описах процеса на импортиране на продукти в Magento 2 по обичайния начин - чрез модели и хранилища. Обичайният метод има много ниска скорост на обработка на данни. Моят лаптоп произвеждаше около един продукт в секунда. В това продължение разглеждам алтернативен начин за импортиране на продукт - чрез директно влизане в базата данни, заобикаляйки стандартните механизми на Magento 2 (модели, фабрики, хранилища). Последователността от стъпки за импортиране на продукти може да бъде адаптирана към всеки език за програмиране, който може да работи с MySQL.

Отказ от отговорност: Magento има готова функционалност за импортиране на данни и най-вероятно ще ви е достатъчно. Ако обаче се нуждаете от по-пълен контрол върху процеса на импортиране, без да се ограничавате до подготовката на CSV файл за това, което имате, добре дошли в cat.

Кодът, получен след написването на двете статии, може да се види в модула на Magento "flancer32/mage2_ext_demo_import". Ето някои ограничения, които следвах, за да опростя кода на демо модула:

• Продуктите само се създават, не се актуализират.
• Един склад
• Импортират се само имена на категории, без тяхната структура
• Структурите на данните отговарят на версия 2.3

JSON за импортиране на един продукт:

{
  "sku": "MVA20D-UBV-3",
  "name": "Заглушка для пломбировки ВА47-29 IEK",
  "desc": "Обеспечение доступа к устройствам ...",
  "desc_short": "Заглушка для пломбировки ВА47-29 IEK предназначена для ...",
  "price": 5.00,
  "qty": 25,
  "categories": ["Категория 1", "Категория 2"],
  "image_path": "mva20d_ubv_3.png"
}

Преглед на основните етапи на вноса

• регистрация на самия продукт
• връзка между продукт и уебсайт
• основни атрибути на продукта (EAV)
• данни за инвентара (количество продукт на склад)
• медии (снимки)
• връзка с каталожни категории

Регистрация на продукта

Основна информация за продукта можете да намерите в catalog_product_entity:

CREATE TABLE `catalog_product_entity` (
  `entity_id` int(10) unsigned NOT NULL AUTO_INCREMENT COMMENT 'Entity Id',
  `attribute_set_id` smallint(5) unsigned NOT NULL DEFAULT '0' COMMENT 'Attribute Set ID',
  `type_id` varchar(32) NOT NULL DEFAULT 'simple' COMMENT 'Type ID',
  `sku` varchar(64) DEFAULT NULL COMMENT 'SKU',
  `has_options` smallint(6) NOT NULL DEFAULT '0' COMMENT 'Has Options',
  `required_options` smallint(5) unsigned NOT NULL DEFAULT '0' COMMENT 'Required Options',
  `created_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT 'Creation Time',
  `updated_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT 'Update Time',
  PRIMARY KEY (`entity_id`),
  KEY `CATALOG_PRODUCT_ENTITY_ATTRIBUTE_SET_ID` (`attribute_set_id`),
  KEY `CATALOG_PRODUCT_ENTITY_SKU` (`sku`)
)

Минималната информация, необходима за създаване на запис в продуктовия регистър, е:

• attribute_set_id
• sku

допълнителен:

• type_id — ако не го посочим, тогава ще се използва „просто“.

За да пиша директно в базата данни, използвам DB адаптера на самия Magento:

function create($sku, $typeId, $attrSetId)
{
    /** @var MagentoFrameworkAppResourceConnection $this->resource */
    /** @var MagentoFrameworkDBAdapterPdoMysql $conn */
    $conn = $this->resource->getConnection();
    $table = $this->resource->getTableName('catalog_product_entity');
    $bind = [
        'sku' => $sku,
        'type_id' => $typeId,
        'attribute_set_id' => $attrSetId
    ];
    $conn->insert($table, $bind);
    $result = $conn->lastInsertId($table);
    return $result;
}

След регистрация на продукта с catalog_product_entity става видима в админ панела, в продуктовата мрежа (Каталог/Продукти).

Връзка между продукт и уебсайт

Асоциацията на продукта със сайта определя в кои магазини и дисплеи продуктът ще бъде наличен отпред.

function linkToWebsite($prodId, $websiteId)
{
    /** @var MagentoFrameworkAppResourceConnection $this->resource */
    /** @var MagentoFrameworkDBAdapterPdoMysql $conn */
    $conn = $this->resource->getConnection();
    $table = $this->resource->getTableName('catalog_product_website');
    $bind = [
        'product_id' => $prodId,
        'website_id' => $websiteId
    ];
    $conn->insert($table, $bind);
}

Основни характеристики на продукта

Новорегистрираният продукт все още няма име или описание. Всичко това става чрез EAV атрибути. Ето списък с основни атрибути на продукта, които са необходими, за да може продуктът да бъде показан правилно отпред:

• name
• price
• description
• short_description
• status
• tax_class_id
• url_key
• visibility

Към продукт като този се добавя отделен атрибут (подробностите за получаване на идентификатора и типа на атрибута от неговия код са пропуснати):

public function create($prodId, $attrCode, $attrValue)
{
    $attrId = /* get attribute ID by attribute code */
    $attrType = /* get attribute type [datetime|decimal|int|text|varchar]) by attribute code */
    if ($attrId) {
        /** @var MagentoFrameworkAppResourceConnection $this->resource */
        /** @var MagentoFrameworkDBAdapterPdoMysql $conn */
        $conn = $this->resource->getConnection();
        $tblName = 'catalog_product_entity_' . $attrType;
        $table = $this->resource->getTableName($tblName);
        $bind = [
            'attribute_id' => $attrId,
            'entity_id' => $prodId,
            /* put all attributes to default store view with id=0 (admin) */
            'store_id' => 0,
            'value' => $attrValue
        ];
        $conn->insert($table, $bind);
    }
}

Използвайки кода на атрибута, ние определяме неговия идентификатор и тип данни (datetime, decimal, int, text, varchar), след което запишете данните за административния прозорец в съответната таблица (store_id = 0).

След като добавите горните атрибути към продукта, получавате следната снимка в админ панела:

Данни за инвентара

Започвайки от версия 2.3 в Magento, има два паралелни набора от таблици, които осигуряват съхранение на информация за инвентара (количество на продукта):

• cataloginventory_*: стара конструкция;
• inventory_*: нова структура (MSI - Multi Source Inventory);

Трябва да добавите данни за инвентара към двете структури, тъй като новата структура все още не е напълно независима от старата (много вероятно е за default склад в новата структура е включена маса cataloginventory_stock_status като inventory_stock_1).

каталог инвентар_

При внедряването на Magneto 2.3 първоначално имаме 2 записа store_website, което отговаря на два сайта - административен и основен клиент:

website_id|code |name        |sort_order|default_group_id|is_default|
----------|-----|------------|----------|----------------|----------|
         0|admin|Admin       |         0|               0|         0|
         1|base |Main Website|         0|               1|         1|

Таблица cataloginventory_stock имаме само един запис:

stock_id|website_id|stock_name|
--------|----------|----------|
       1|         0|Default   |

Тоест в старата ни структура има само един „склад“ (stock) и е свързан към административния уебсайт. Добавяне на нови през админ панела sources/stocks в MSI (нова структура) не води до нови записи в cataloginventory_stock.

Данните за наличностите за продукти в старата структура първоначално се записват в таблици:

• cataloginventory_stock_item
• cataloginventory_stock_status

каталог_инвентар_сток_артикул

function createOldItem($prodId, $qty)
{
    $isQtyDecimal = (((int)$qty) != $qty);
    $isInStock = ($qty > 0);
    /** @var MagentoFrameworkAppResourceConnection $this->resource */
    /** @var MagentoFrameworkDBAdapterPdoMysql $conn */
    $conn = $this->resource->getConnection();
    $table = $this->resource->getTableName('cataloginventory_stock_item');
    $bind = [
        'product_id' => $prodId,
        /* we use one only stock in 'cataloginventory' structure by default */
        'stock_id' => 1,
        'qty' => $qty,
        'is_qty_decimal' => $isQtyDecimal,
        'is_in_stock' => $isInStock,
        /* default stock is bound to admin website (see `cataloginventory_stock`) */
        'website_id' => 0
    ];
    $conn->insert($table, $bind);
}

каталог_състояние_наличност_наличност

function createOldStatus($prodId, $qty)
{
    $isInStock = ($qty > 0);
    /** @var MagentoFrameworkAppResourceConnection $this->resource */
    /** @var MagentoFrameworkDBAdapterPdoMysql $conn */
    $conn = $this->resource->getConnection();
    $table = $this->resource->getTableName('cataloginventory_stock_status');
    $bind = [
        'product_id' => $prodId,
        /* we use one only stock in 'cataloginventory' structure by default */
        'stock_id' => 1, 
        'qty' => $qty,
        'stock_status' => MagentoCatalogInventoryApiDataStockStatusInterface::STATUS_IN_STOCK,
        /* default stock is bound to admin website (see `cataloginventory_stock`) */
        'website_id' => 0 
    ];
    $conn->insert($table, $bind);
}

складова наличност_

Първоначално новата структура за съхранение на данни за инвентара съдържа 1 "източник"(inventory_source):

source_code|name          |enabled|description   |latitude|longitude|country_id|...|
-----------|--------------|-------|--------------|--------|---------|----------|...|
default    |Default Source|      1|Default Source|0.000000| 0.000000|US        |...|

и едно "склад"(inventory_stock):

stock_id|name         |
--------|-------------|
       1|Default Stock|

«източник» представлява физическото хранилище за продукти (записът съдържа физически координати и пощенски адрес). "Наличност"е логично обединение на няколко "източника" (inventory_source_stock_link)

link_id|stock_id|source_code|priority|
-------|--------|-----------|--------|
      1|       1|default    |       1|

на нивото, на което се осъществява връзката с канала за продажба (inventory_stock_sales_channel)

type   |code|stock_id|
-------|----|--------|
website|base|       1|

Съдейки по структурата на данните, се приемат различни видове канали за продажба, но по подразбиране само връзката „наличност"-"уебсайт"(връзката към уебсайта следва кода на уебсайта - base).

един "склад"може да бъде свързан с няколко"източници"и едно "източник"- до няколко"складове"(връзка много към много). Изключенията са по подразбиране "източник"И"склад". Те не са повторно свързани с други обекти (ограничение на ниво код - грешката „Не може да се запази връзка, свързана с източник по подразбиране или запас по подразбиране"). Повече подробности за структурата на MSI в Magento 2 можете да намерите в статията “Система за управление на склад, използваща CQRS и Event Sourcing. Дизайн".

Ще използвам конфигурацията по подразбиране и ще добавя цялата информация за инвентара към източника default, който участва в канала за продажба, свързан с уебсайта с кода base (съответства на предния край на магазина - вижте store_website):

function createNewItem($sku, $qty)
{
    /** @var MagentoFrameworkAppResourceConnection $this->resource */
    /** @var MagentoFrameworkDBAdapterPdoMysql $conn */
    $conn = $this->resource->getConnection();
    $table = $this->resource->getTableName('inventory_source_item');
    $bind = [
        'source_code' => 'default',
        'sku' => $sku,
        'quantity' => $qty,
        'status' => MagentoInventoryApiApiDataSourceItemInterface::STATUS_IN_STOCK
    ];
    $conn->insert($table, $bind);
}

След като добавите данни за инвентара към продукта в административния панел, получавате следната картина:

Средства

При „ръчно“ добавяне на изображение към продукт през админ панела, съответната информация се записва в следните таблици:

• catalog_product_entity_media_gallery: регистър на медиите (изображения и видео файлове);
• catalog_product_entity_media_gallery_value: свързване на медии с продукти и витрини (локализация);
• catalog_product_entity_media_gallery_value_to_entity: свързване на медии само с продукти (вероятно медийно съдържание по подразбиране за продукта);
• catalog_product_entity_varchar: Тук се съхраняват ролите, в които се използва изображението;

и самите изображения се записват в директорията ./pub/media/catalog/product/x/y/Където x и y — първата и втората буква от името на файла с изображение. Например файл image.png трябва да се запише като ./pub/media/catalog/product/i/m/image.png, за да може платформата да го използва като изображение при описание на продукти от каталога.

catalog_product_entity_media_gallery

Регистърът е публикуван в ./pub/media/catalog/product/ медиен файл (процесът на поставяне на самия файл не се обсъжда в тази статия):

function createMediaGallery($imgPathPrefixed)
{
    $attrId = /* get attribute ID by attribute code 'media_gallery' */
    /** @var MagentoFrameworkAppResourceConnection $this->resource */
    /** @var MagentoFrameworkDBAdapterPdoMysql $conn */
    $conn = $this->resource->getConnection();
    $table = $this->resource->getTableName('catalog_product_entity_media_gallery');
    $bind = [
        'attribute_id' => $attrId,
        'value' => $imgPathPrefixed,
        /* 'image' or 'video' */
        'media_type' => 'image',
        'disabled' => false
    ];
    $conn->insert($table, $bind);
    $result = $conn->lastInsertId($table);
    return $result;
}

Когато се регистрира, на нов медиен файл се присвоява идентификатор.

catalog_product_entity_media_gallery_value

Ние свързваме регистрирания медиен файл със съответния продукт за витрината по подразбиране:

function createGalleryValue($mediaId, $prodId)
{
    /** @var MagentoFrameworkAppResourceConnection $this->resource */
    /** @var MagentoFrameworkDBAdapterPdoMysql $conn */
    $conn = $this->resource->getConnection();
    $table = $this->resource->getTableName('catalog_product_entity_media_gallery_value');
    $bind = [
        'value_id' => $mediaId,
        /* use admin store view by default */
        'store_id' => 0,
        'entity_id' => $prodId,
        'label' => null,
        /* we have one only image */
        'position' => 1,
        'disabled' => false
    ];
    $conn->insert($table, $bind);
}

catalog_product_entity_media_gallery_value_to_entity

Ние свързваме регистрирания медиен файл със съответния продукт, без да сме обвързани с витрина. Не е ясно къде точно се използват тези данни и защо е невъзможен достъп до данните от предишната таблица, но тази таблица съществува и данните се записват в нея, когато се добави снимка към продукта. Значи това е.

function createGalleryValueToEntity($mediaId, $prodId)
{
    /** @var MagentoFrameworkAppResourceConnection $this->resource */
    /** @var MagentoFrameworkDBAdapterPdoMysql $conn */
    $conn = $this->resource->getConnection();
    $table = $this->resource->getTableName('catalog_product_entity_media_gallery_value_to_entity');
    $bind = [
        'value_id' => $mediaId,
        'entity_id' => $prodId
    ];
    $conn->insert($table, $bind);
}

catalog_product_entity_varchar

Медиен файл може да се използва с различни роли (съответният код на атрибута е посочен в скоби):

• Основа (image)
• Малко изображение (small_image)
• Миниатюра (thumbnail)
• Мостра изображение (swatch_image)

Свързването на роли към медиен файл е точно това, което се случва в catalog_product_entity_varchar. Кодът за обвързване е подобен на кода в "Основни характеристики на продукта".

След добавяне на изображение към продукта в админ панела изглежда така:

Категории

Основни таблици, съдържащи данни по категории:

• catalog_category_entity: регистър на категориите;
• catalog_category_product: връзка между продукти и категории;
• catalog_category_entity_*: стойности на EAV атрибут;

Първоначално в празно приложение на Magento регистърът на категориите съдържа 2 категории (съкратих имената на колоните: crt - created_at, upd - updated_at):

entity_id|attribute_set_id|parent_id|crt|upd|path|position|level|children_count|
---------|----------------|---------|---|---|----|--------|-----|--------------|
        1|               3|        0|...|...|1   |       0|    0|             1|
        2|               3|        1|...|...|1/2 |       1|    1|             0|

Категорията с id=1 е основата на целия каталог на Magento и не е достъпна нито в админ панела, нито на заглавната страница. Категория с id=2 (По подразбиране Категория) е основната категория за основния магазин на основния сайт (Основен магазин на уебсайта), създадени при внедряване на приложението (вижте. Администратор / Магазини / Всички магазини). Освен това основната категория на самия магазин също не е налична отпред, а само нейните подкатегории.

Тъй като темата на тази статия все още е импортиране на данни за продукти, няма да използвам директно влизане в базата данни при създаване на категории, а ще използвам класовете, предоставени от самия Magento (модели и хранилища). Директното влизане в базата данни се използва само за свързване на импортирания продукт с категория (категорията се съпоставя с нейното име и идентификаторът на категорията се извлича по време на съпоставяне):

function create($prodId, $catId)
{
    /** @var MagentoFrameworkAppResourceConnection $this->resource */
    /** @var MagentoFrameworkDBAdapterPdoMysql $conn */
    $conn = $this->resource->getConnection();
    $table = $this->resource->getTableName('catalog_category_product');
    $bind = [
        'category_id' => $catId,
        'product_id' => $prodId,
    ];
    $conn->insert($table, $bind);
}

След добавяне на продуктова връзка към категориите „Категория 1“ и „Категория 2“, подробностите за продукта в админ панела изглеждат по следния начин:

Допълнителни действия

След като импортирането на данни приключи, трябва да изпълните следните допълнителни стъпки:

• индексиране на данни: извикване в конзолата ./bin/magento indexer:reindex;
• повторно генериране на URL адреси за продукти/категории: можете да използвате разширението „elgentos/regenerate-catalog-urls«

Продукти в админ панела след извършване на допълнителни действия:

и отпред:

Обобщение

Същият набор от продукти (10 броя), както в предишната статия, се внася поне с порядък по-бързо (1 секунда срещу 10). За да оцените по-точно скоростта, имате нужда от по-голям брой продукти - няколкостотин или още по-добре хиляди. Въпреки това, дори и с такъв малък размер на входните данни, можем да заключим, че използването на инструментите, предоставени от Magento (модели и хранилища), е значително (подчертавам - много!) ускорява развитието на необходимата функционалност, но в същото време значително (подчертавам - много!) намаляване на скоростта, с която данните влизат в базата данни.

В резултат на това водата се оказа мокра и това не е откровение. Сега обаче имам кода, с който да си поиграя и може би да стигна до някои по-интересни заключения.

Източник: www.habr.com