DeleteOutdatedPriceValues.php

Go to the documentation of this file.

<?php
namespace Magento\Catalog\Cron;

use Magento\Framework\App\ResourceConnection;
use Magento\Eav\Api\AttributeRepositoryInterface as AttributeRepository;
use Magento\Framework\App\Config\MutableScopeConfigInterface as ScopeConfig;
use Magento\Catalog\Api\Data\ProductAttributeInterface;
use Magento\Store\Model\Store;

class DeleteOutdatedPriceValues
{
    private $resource;

    private $attributeRepository;

    private $scopeConfig;

    public function __construct(
        ResourceConnection $resource,
        AttributeRepository $attributeRepository,
        ScopeConfig $scopeConfig
    ) {
        $this->resource = $resource;
        $this->attributeRepository = $attributeRepository;
        $this->scopeConfig = $scopeConfig;
    }

    public function execute()
    {
        if (!$this->isPriceScopeSetToGlobal()) {
            return;
        }

        $priceAttribute = $this->attributeRepository
            ->get(ProductAttributeInterface::ENTITY_TYPE_CODE, ProductAttributeInterface::CODE_PRICE);
        $connection = $this->resource->getConnection();
        $conditions = [
            $connection->quoteInto('attribute_id = ?', $priceAttribute->getId()),
            $connection->quoteInto('store_id != ?', Store::DEFAULT_STORE_ID),
        ];

        $connection->delete(
            $priceAttribute->getBackend()->getTable(),
            $conditions
        );
    }

    private function isPriceScopeSetToGlobal()
    {
        $priceScope = $this->scopeConfig->getValue(Store::XML_PATH_PRICE_SCOPE);
        if ($priceScope === null) {
            return false;
        }

        return (int)$priceScope === Store::PRICE_SCOPE_GLOBAL;
    }
}