RuleProductPricesPersistor.php

Go to the documentation of this file.

<?php
namespace Magento\CatalogRule\Model\Indexer;

use Magento\CatalogRule\Model\Indexer\IndexerTableSwapperInterface as TableSwapper;
use Magento\Catalog\Model\ResourceModel\Indexer\ActiveTableSwitcher;
use Magento\Framework\App\ObjectManager;

class RuleProductPricesPersistor
{
    private $resource;

    private $dateFormat;

    private $activeTableSwitcher;

    private $tableSwapper;

    public function __construct(
        \Magento\Framework\Stdlib\DateTime $dateFormat,
        \Magento\Framework\App\ResourceConnection $resource,
        ActiveTableSwitcher $activeTableSwitcher,
        TableSwapper $tableSwapper = null
    ) {
        $this->dateFormat = $dateFormat;
        $this->resource = $resource;
        $this->activeTableSwitcher = $activeTableSwitcher;
        $this->tableSwapper = $tableSwapper ??
            ObjectManager::getInstance()->get(TableSwapper::class);
    }

    public function execute(array $priceData, $useAdditionalTable = false)
    {
        if (empty($priceData)) {
            return false;
        }

        $connection = $this->resource->getConnection();
        $indexTable = $this->resource->getTableName('catalogrule_product_price');
        if ($useAdditionalTable) {
            $indexTable = $this->resource->getTableName(
                $this->tableSwapper->getWorkingTableName('catalogrule_product_price')
            );
        }

        $productIds = [];

        try {
            foreach ($priceData as $key => $data) {
                $productIds['product_id'] = $data['product_id'];
                $priceData[$key]['rule_date'] = $this->dateFormat->formatDate($data['rule_date'], false);
                $priceData[$key]['latest_start_date'] = $this->dateFormat->formatDate(
                    $data['latest_start_date'],
                    false
                );
                $priceData[$key]['earliest_end_date'] = $this->dateFormat->formatDate(
                    $data['earliest_end_date'],
                    false
                );
            }
            $connection->insertOnDuplicate($indexTable, $priceData);
        } catch (\Exception $e) {
            throw $e;
        }
        return true;
    }
}