Pyz\Zed\DataImport\Business\Model\DiscountStore\DiscountStoreWriterStep

Complexity

Total Complexity

5

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	getIdStoreByName()	0	8	2
A	getIdDiscountByKey()	0	8	2
A	execute()	0	7	1

<?php

/**
 * This file is part of the Spryker Commerce OS.
 * For full license information, please view the LICENSE file that was distributed with this source code.
 */

declare(strict_types = 1);

namespace Pyz\Zed\DataImport\Business\Model\DiscountStore;

use Orm\Zed\Discount\Persistence\SpyDiscountQuery;
use Orm\Zed\Discount\Persistence\SpyDiscountStoreQuery;
use Orm\Zed\Store\Persistence\SpyStoreQuery;
use Spryker\Zed\DataImport\Business\Model\DataImportStep\DataImportStepInterface;
use Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface;

class DiscountStoreWriterStep implements DataImportStepInterface
{
    public const BULK_SIZE = 100;

    public const KEY_DISCOUNT_KEY = 'discount_key';

    public const KEY_STORE_NAME = 'store_name';

    /**
     * @var array<int> Keys are discount keys, values are discount IDs.
     */
    protected static array $idDiscountBuffer = [];

    /**
     * @var array<int> Keys are store names, values are store ids.
     */
    protected static array $idStoreBuffer = [];

    public function execute(DataSetInterface $dataSet): void
    {
        (new SpyDiscountStoreQuery())
            ->filterByFkDiscount($this->getIdDiscountByKey($dataSet[static::KEY_DISCOUNT_KEY]))
            ->filterByFkStore($this->getIdStoreByName($dataSet[static::KEY_STORE_NAME]))
            ->findOneOrCreate()
            ->save();
    }

    protected function getIdDiscountByKey(string $discountKey): int
    {
        if (!isset(static::$idDiscountBuffer[$discountKey])) {
            static::$idDiscountBuffer[$discountKey] =
                SpyDiscountQuery::create()->findOneByDiscountKey($discountKey)->getIdDiscount();
        }

        return static::$idDiscountBuffer[$discountKey];
    }

    protected function getIdStoreByName(string $storeName): int
    {
        if (!isset(static::$idStoreBuffer[$storeName])) {
            static::$idStoreBuffer[$storeName] =
                SpyStoreQuery::create()->findOneByName($storeName)->getIdStore();
        }

        return static::$idStoreBuffer[$storeName];
    }
}