Pyz\Zed\DataImport\Business\Model\ProductOption\ProductOptionWriterStep

Complexity

Total Complexity

9

Size/Duplication

Total Lines	96
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	findOrCreateTranslation()	0	18	1
A	execute()	0	46	5
A	isActive()	0	7	3

<?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\ProductOption;

use Orm\Zed\Glossary\Persistence\SpyGlossaryKeyQuery;
use Orm\Zed\Glossary\Persistence\SpyGlossaryTranslationQuery;
use Orm\Zed\Product\Persistence\Map\SpyProductAbstractTableMap;

The type Orm\Zed\Product\Persistence\Map\SpyProductAbstractTableMap was not found. Maybe you did not declare it correctly or list all dependencies?

use Orm\Zed\Product\Persistence\SpyProductAbstractQuery;
use Orm\Zed\ProductOption\Persistence\Base\SpyProductOptionGroup;

The type Orm\Zed\ProductOption\Persistence\Base\SpyProductOptionGroup was not found. Maybe you did not declare it correctly or list all dependencies?

use Orm\Zed\ProductOption\Persistence\SpyProductAbstractProductOptionGroupQuery;
use Orm\Zed\ProductOption\Persistence\SpyProductOptionGroupQuery;
use Orm\Zed\ProductOption\Persistence\SpyProductOptionValueQuery;
use Propel\Runtime\ActiveQuery\Criteria;
use Pyz\Zed\DataImport\Business\Model\Product\ProductLocalizedAttributesExtractorStep;
use Pyz\Zed\DataImport\Business\Model\Tax\TaxSetNameToIdTaxSetStep;
use Spryker\Zed\DataImport\Business\Model\DataImportStep\DataImportStepInterface;
use Spryker\Zed\DataImport\Business\Model\DataImportStep\PublishAwareStep;
use Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface;
use Spryker\Zed\Glossary\Dependency\GlossaryEvents;
use Spryker\Zed\ProductOption\Dependency\ProductOptionEvents;

/**
 * @SuppressWarnings(PHPMD.CouplingBetweenObjects)
 */
class ProductOptionWriterStep extends PublishAwareStep implements DataImportStepInterface
{
    public const BULK_SIZE = 100;

    public const KEY_ABSTRACT_PRODUCT_SKUS = 'abstract_product_skus';

    public const KEY_GROUP_NAME_TRANSLATION_KEY = 'group_name_translation_key';

    public const KEY_IS_ACTIVE = 'is_active';

    public const KEY_SKU = 'sku';

    public const KEY_OPTION_NAME_TRANSLATION_KEY = 'option_name_translation_key';

    public const KEY_OPTION_NAME = 'option_name';

    public const KEY_GROUP_NAME = 'group_name';

    public const KEY_TAX_SET_NAME = 'tax_set_name';

    public function execute(DataSetInterface $dataSet): void
    {
        $productOptionGroupEntity = SpyProductOptionGroupQuery::create()
            ->filterByName($dataSet[self::KEY_GROUP_NAME_TRANSLATION_KEY])
            ->findOneOrCreate();

        $productOptionGroupEntity
            ->setActive($this->isActive($dataSet, $productOptionGroupEntity))
            ->setFkTaxSet($dataSet[TaxSetNameToIdTaxSetStep::KEY_TARGET])
            ->save();

        $productOptionValueEntity = SpyProductOptionValueQuery::create()
            ->filterBySku($dataSet[self::KEY_SKU])
            ->filterByFkProductOptionGroup($productOptionGroupEntity->getIdProductOptionGroup())
            ->findOneOrCreate();

        $productOptionValueEntity
            ->setValue($dataSet[self::KEY_OPTION_NAME_TRANSLATION_KEY])
            ->save();

        if (!empty($dataSet[static::KEY_ABSTRACT_PRODUCT_SKUS])) {
            $abstractProductSkuCollection = explode(',', $dataSet[static::KEY_ABSTRACT_PRODUCT_SKUS]);

            /** @var array<int> $abstractProductIdCollection */
            $abstractProductIdCollection = SpyProductAbstractQuery::create()
                ->select([SpyProductAbstractTableMap::COL_ID_PRODUCT_ABSTRACT])
                ->filterBySku($abstractProductSkuCollection, Criteria::IN)
                ->find();

            foreach ($abstractProductIdCollection as $idProductAbstract) {
                SpyProductAbstractProductOptionGroupQuery::create()
                    ->filterByFkProductOptionGroup($productOptionGroupEntity->getIdProductOptionGroup())
                    ->filterByFkProductAbstract($idProductAbstract)
                    ->findOneOrCreate()
                    ->save();

                $this->addPublishEvents(ProductOptionEvents::PRODUCT_ABSTRACT_PRODUCT_OPTION_PUBLISH, $idProductAbstract);
            }
        }

        foreach ($dataSet[ProductLocalizedAttributesExtractorStep::KEY_LOCALIZED_ATTRIBUTES] as $idLocale => $attributes) {
            if (!isset($attributes[static::KEY_OPTION_NAME])) {
                continue;
            }
            $this->findOrCreateTranslation($dataSet[static::KEY_OPTION_NAME_TRANSLATION_KEY], $attributes[static::KEY_OPTION_NAME], $idLocale);
            $this->findOrCreateTranslation($dataSet[static::KEY_GROUP_NAME_TRANSLATION_KEY], $attributes[static::KEY_GROUP_NAME], $idLocale);
        }
    }

    protected function isActive(DataSetInterface $dataSet, SpyProductOptionGroup $productOptionGroupEntity): bool
    {
        if (isset($dataSet[self::KEY_IS_ACTIVE])) {
            return isset($dataSet[self::KEY_IS_ACTIVE]);
        }

        return ($productOptionGroupEntity->getActive() !== null) ? $productOptionGroupEntity->getActive() : true;
    }

    protected function findOrCreateTranslation(string $key, string $translation, int $idLocale): void
    {
        $glossaryKeyEntity = SpyGlossaryKeyQuery::create()
            ->filterByKey($key)
            ->findOneOrCreate();

        $glossaryKeyEntity->save();

        $glossaryTranslationEntity = SpyGlossaryTranslationQuery::create()
            ->filterByFkLocale($idLocale)
            ->filterByFkGlossaryKey($glossaryKeyEntity->getIdGlossaryKey())
            ->findOneOrCreate();

        $glossaryTranslationEntity
            ->setValue($translation)
            ->save();

        $this->addPublishEvents(GlossaryEvents::GLOSSARY_KEY_PUBLISH, $glossaryTranslationEntity->getFkGlossaryKey());

The constant Spryker\Zed\Glossary\Dependency\GlossaryEvents::GLOSSARY_KEY_PUBLISH has been deprecated: Use {@link \Spryker\Shared\GlossaryStorage\GlossaryStorageConfig::GLOSSARY_KEY_PUBLISH_WRITE} instead.

    }
}