ProcessInventoryDataObserver.php

Go to the documentation of this file.

<?php
namespace Magento\CatalogInventory\Observer;

use Magento\Catalog\Model\Product;
use Magento\CatalogInventory\Api\Data\StockItemInterface;
use Magento\CatalogInventory\Model\Stock\Item;
use Magento\Framework\Event\ObserverInterface;
use Magento\Framework\Event\Observer as EventObserver;

class ProcessInventoryDataObserver implements ObserverInterface
{
    private $stockRegistry;

    public function __construct(
        \Magento\CatalogInventory\Api\StockRegistryInterface $stockRegistry
    ) {
        $this->stockRegistry = $stockRegistry;
    }

    public function execute(EventObserver $observer)
    {
        $product = $observer->getEvent()->getProduct();
        $this->processStockData($product);
    }

    private function processStockData(Product $product)
    {
        $quantityAndStockStatus = $product->getData('quantity_and_stock_status');
        if (is_array($quantityAndStockStatus)) {
            $stockItem = $this->stockRegistry->getStockItem($product->getId(), $product->getStore()->getWebsiteId());

            $quantityAndStockStatus = $this->prepareQuantityAndStockStatus($stockItem, $quantityAndStockStatus);

            if ($quantityAndStockStatus) {
                $this->setStockDataToProduct($product, $stockItem, $quantityAndStockStatus);
            }
        }
    }

    private function prepareQuantityAndStockStatus(StockItemInterface $stockItem, array $quantityAndStockStatus)
    {
        $stockItemId = $stockItem->getItemId();

        if (null !== $stockItemId) {
            if (isset($quantityAndStockStatus['is_in_stock'])
                && $stockItem->getIsInStock() == $quantityAndStockStatus['is_in_stock']
            ) {
                unset($quantityAndStockStatus['is_in_stock']);
            }
            if (array_key_exists('qty', $quantityAndStockStatus)
                && $stockItem->getQty() == $quantityAndStockStatus['qty']
            ) {
                unset($quantityAndStockStatus['qty']);
            }
        }

        if (array_key_exists('qty', $quantityAndStockStatus) && $quantityAndStockStatus['qty'] === '') {
            $quantityAndStockStatus['qty'] = null;
        }
        return $quantityAndStockStatus;
    }

    private function setStockDataToProduct(Product $product, Item $stockItem, array $quantityAndStockStatus)
    {
        $stockData = array_replace((array)$product->getData('stock_data'), $quantityAndStockStatus);
        if ($stockItem->hasDataChanges()) {
            $stockData = array_replace($stockData, $stockItem->getData());
        }
        $product->setData('stock_data', $stockData);
    }
}