<?php
/**
 * Copyright © Magento, Inc. All rights reserved.
 * See COPYING.txt for license details.
 */
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;

/**
 * Cron job for removing outdated prices.
 *
 * Cron operation is responsible for deleting all product prices on WEBSITE level
 * in case 'Catalog Price Scope' configuration parameter is set to GLOBAL.
 */
class DeleteOutdatedPriceValues
{
    /**
     * @var ResourceConnection
     */
    private $resource;

    /**
     * @var AttributeRepository
     */
    private $attributeRepository;

    /**
     * @var ScopeConfig
     */
    private $scopeConfig;

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

    /**
     * Delete all price values for non-admin stores if PRICE_SCOPE is set to global.
     *
     * @return void
     */
    public function execute()
    {
        if (!$this->isPriceScopeSetToGlobal()) {
            return;
        }

        /** @var \Magento\Catalog\Model\ResourceModel\Eav\Attribute $priceAttribute */
        $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
        );
    }

    /**
     * Checks if price scope config option explicitly equal to global value.
     *
     * Such strict comparison is required to prevent price deleting when
     * price scope config option is null for some reason.
     *
     * @return bool
     */
    private function isPriceScopeSetToGlobal()
    {
        $priceScope = $this->scopeConfig->getValue(Store::XML_PATH_PRICE_SCOPE);
        if ($priceScope === null) {
            return false;
        }

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