StockItemImporter.php

Go to the documentation of this file.

<?php
declare(strict_types=1);

namespace Magento\CatalogImportExport\Model;

use Magento\CatalogInventory\Model\ResourceModel\Stock\Item;
use Magento\CatalogInventory\Model\ResourceModel\Stock\ItemFactory;
use Magento\Framework\Exception\CouldNotSaveException;
use Psr\Log\LoggerInterface;

class StockItemImporter implements StockItemImporterInterface
{
    private $stockResourceItemFactory;

    private $logger;

    public function __construct(
        ItemFactory $stockResourceItemFactory,
        LoggerInterface $logger
    ) {
        $this->stockResourceItemFactory = $stockResourceItemFactory;
        $this->logger = $logger;
    }

    public function import(array $stockData)
    {
        $stockItemResource = $this->stockResourceItemFactory->create();
        $entityTable = $stockItemResource->getMainTable();
        try {
            $stockImportData = array_map(
                function ($stockItemData) {
                    unset($stockItemData['sku']);
                    return $stockItemData;
                },
                array_values($stockData)
            );
            $stockItemResource->getConnection()->insertOnDuplicate($entityTable, $stockImportData);
        } catch (\Exception $e) {
            $this->logger->error($e->getMessage());
            throw new CouldNotSaveException(__('Invalid Stock data for insert'), $e);
        }
    }
}