TierPricePersistence.php

Go to the documentation of this file.

<?php
namespace Magento\Catalog\Model\Product\Price;

class TierPricePersistence
{
    private $itemsPerOperation = 500;

    private $tierpriceResource;

    private $metadataPool;

    public function __construct(
        \Magento\Catalog\Model\ResourceModel\Product\Attribute\Backend\Tierprice $tierpriceResource,
        \Magento\Framework\EntityManager\MetadataPool $metadataPool
    ) {
        $this->tierpriceResource = $tierpriceResource;
        $this->metadataPool = $metadataPool;
    }

    public function get(array $ids)
    {
        $select = $this->tierpriceResource->getConnection()->select()->from($this->tierpriceResource->getMainTable());
        return $this->tierpriceResource->getConnection()->fetchAll(
            $select->where($this->getEntityLinkField() . ' IN (?)', $ids)
        );
    }

    public function update(array $prices)
    {
        $connection = $this->tierpriceResource->getConnection();
        $connection->beginTransaction();
        try {
            foreach (array_chunk($prices, $this->itemsPerOperation) as $pricesBunch) {
                $this->tierpriceResource->getConnection()->insertOnDuplicate(
                    $this->tierpriceResource->getMainTable(),
                    $pricesBunch,
                    ['value', 'percentage_value']
                );
            }
            $connection->commit();
        } catch (\Exception $e) {
            $connection->rollBack();
            throw new \Magento\Framework\Exception\CouldNotSaveException(
                __('Could not save Tier Prices'),
                $e
            );
        }
    }

    public function replace(array $prices, array $ids)
    {
        $connection = $this->tierpriceResource->getConnection();
        $connection->beginTransaction();
        try {
            foreach (array_chunk($ids, $this->itemsPerOperation) as $idsBunch) {
                $this->tierpriceResource->getConnection()->delete(
                    $this->tierpriceResource->getMainTable(),
                    [$this->getEntityLinkField() . ' IN (?)' => $idsBunch]
                );
            }

            foreach (array_chunk($prices, $this->itemsPerOperation) as $pricesBunch) {
                $this->tierpriceResource->getConnection()->insertMultiple(
                    $this->tierpriceResource->getMainTable(),
                    $pricesBunch
                );
            }
            $connection->commit();
        } catch (\Exception $e) {
            $connection->rollBack();
            throw new \Magento\Framework\Exception\CouldNotSaveException(
                __('Could not replace Tier Prices'),
                $e
            );
        }
    }

    public function delete(array $ids)
    {
        $connection = $this->tierpriceResource->getConnection();
        $connection->beginTransaction();
        try {
            foreach (array_chunk($ids, $this->itemsPerOperation) as $idsBunch) {
                $this->tierpriceResource->getConnection()->delete(
                    $this->tierpriceResource->getMainTable(),
                    ['value_id IN (?)' => $idsBunch]
                );
            }
            $connection->commit();
        } catch (\Exception $e) {
            $connection->rollBack();
            throw new \Magento\Framework\Exception\CouldNotDeleteException(
                __('Could not delete Tier Prices'),
                $e
            );
        }
    }

    public function getEntityLinkField()
    {
        return $this->metadataPool->getMetadata(\Magento\Catalog\Api\Data\ProductInterface::class)
            ->getLinkField();
    }
}