ProductAbstractPropelDataSetWriter::getProductAbstractLocalizedTransfers() - Code Metrics - spryker-shop/b2b-demo-shop - Measure and Improve Code Quality continuously with Scrutinizer

getProductAbstractLocalizedTransfers() A
last analyzed 2025-09-16 15:05 UTC

↳ Parent: ProductAbstractPropelDataSetWriter

Complexity

Conditions	1
Paths	1

Size

Total Lines	3
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	1
dl	0
loc	3
c	0
b	0
f	0
rs	10
cc	1
nc	1
nop	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\ProductAbstract\Writer;

use Generated\Shared\Transfer\SpyProductAbstractEntityTransfer;
filter:
    dependency_paths: ["lib/*"]
use Orm\Zed\Product\Persistence\SpyProductAbstract;
use Orm\Zed\Product\Persistence\SpyProductAbstractLocalizedAttributesQuery;
use Orm\Zed\Product\Persistence\SpyProductAbstractQuery;
use Orm\Zed\ProductCategory\Persistence\SpyProductCategoryQuery;
use Orm\Zed\Url\Persistence\SpyUrlQuery;
use Propel\Runtime\ActiveQuery\Criteria;
use Pyz\Zed\DataImport\Business\Model\Product\Repository\ProductRepository;
use Pyz\Zed\DataImport\Business\Model\ProductAbstract\ProductAbstractHydratorStep;
use Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface;
use Spryker\Zed\DataImport\Business\Model\DataSet\DataSetWriterInterface;
use Spryker\Zed\DataImport\Business\Model\Publisher\DataImporterPublisher;
use Spryker\Zed\Product\Dependency\ProductEvents;
use Spryker\Zed\ProductCategory\Dependency\ProductCategoryEvents;
use Spryker\Zed\Url\Dependency\UrlEvents;

class ProductAbstractPropelDataSetWriter implements DataSetWriterInterface
{
    /**
     * @var \Pyz\Zed\DataImport\Business\Model\Product\Repository\ProductRepository
     */
    protected $productRepository;

    /**
     * @param \Pyz\Zed\DataImport\Business\Model\Product\Repository\ProductRepository $productRepository
     */
    public function __construct(ProductRepository $productRepository)
    {
        $this->productRepository = $productRepository;
    }

    /**
     * @param \Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface $dataSet
     *
     * @return void
     */
    public function write(DataSetInterface $dataSet): void
    {
        $productAbstractEntity = $this->createOrUpdateProductAbstract($dataSet);

        $this->productRepository->addProductAbstract($productAbstractEntity);

        $this->createOrUpdateProductAbstractLocalizedAbstract($dataSet, $productAbstractEntity->getIdProductAbstract());
        $this->createOrUpdateProductCategories($dataSet, $productAbstractEntity->getIdProductAbstract());
        $this->createOrUpdateProductUrls($dataSet, $productAbstractEntity->getIdProductAbstract());

        DataImporterPublisher::addEvent(ProductEvents::PRODUCT_ABSTRACT_PUBLISH, $productAbstractEntity->getIdProductAbstract());
    }

    /**
     * @param \Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface $dataSet
     *
     * @return \Orm\Zed\Product\Persistence\SpyProductAbstract
     */
    protected function createOrUpdateProductAbstract(DataSetInterface $dataSet): SpyProductAbstract
    {
        $productAbstractEntityTransfer = $this->getProductAbstractTransfer($dataSet);

        $productAbstractEntity = SpyProductAbstractQuery::create()
            ->filterBySku($productAbstractEntityTransfer->getSku())
            ->findOneOrCreate();

        $productAbstractEntity->fromArray($productAbstractEntityTransfer->modifiedToArray());

        if ($productAbstractEntity->isNew() || $productAbstractEntity->isModified()) {
            $productAbstractEntity->save();

            DataImporterPublisher::addEvent(ProductEvents::PRODUCT_ABSTRACT_PUBLISH, $productAbstractEntity->getIdProductAbstract());
        }

        return $productAbstractEntity;
    }

    /**
     * @param \Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface $dataSet
     * @param int $idProductAbstract
     *
     * @return void
     */
    protected function createOrUpdateProductAbstractLocalizedAbstract(
        DataSetInterface $dataSet,
        int $idProductAbstract,
    ): void {
        $productAbstractLocalizedTransfers = $this->getProductAbstractLocalizedTransfers($dataSet);

        foreach ($productAbstractLocalizedTransfers as $productAbstractLocalizedArray) {
            $productAbstractLocalizedTransfer = $productAbstractLocalizedArray[ProductAbstractHydratorStep::KEY_PRODUCT_ABSTRACT_LOCALIZED_TRANSFER];

            $idLocale = $productAbstractLocalizedTransfer->getFkLocale();

            $productAbstractLocalizedAttributesEntity = SpyProductAbstractLocalizedAttributesQuery::create()
                ->filterByFkProductAbstract($idProductAbstract)
                ->filterByFkLocale($idLocale)
                ->findOneOrCreate();

            $productAbstractLocalizedAttributesEntity->fromArray($productAbstractLocalizedTransfer->modifiedToArray());

            if (!$productAbstractLocalizedAttributesEntity->isNew() && !$productAbstractLocalizedAttributesEntity->isModified()) {
                continue;
            }

            $productAbstractLocalizedAttributesEntity->save();
        }
    }

    /**
     * @param \Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface $dataSet
     * @param int $idProductAbstract
     *
     * @return void
     */
    protected function createOrUpdateProductCategories(DataSetInterface $dataSet, int $idProductAbstract): void
    {
        $productCategoryTransfers = $this->getProductCategoryTransfers($dataSet);

        foreach ($productCategoryTransfers as $productCategoryArray) {
            $productCategoryTransfer = $productCategoryArray[ProductAbstractHydratorStep::KEY_PRODUCT_CATEGORY_TRANSFER];

            $productCategoryEntity = SpyProductCategoryQuery::create()
                ->filterByFkProductAbstract($idProductAbstract)
                ->filterByFkCategory($productCategoryTransfer->getFkCategory())
                ->findOneOrCreate();

            $productCategoryEntity->fromArray($productCategoryTransfer->modifiedToArray());

            if (!$productCategoryEntity->isNew() && !$productCategoryEntity->isModified()) {
                continue;
            }

            $productCategoryEntity->save();

            DataImporterPublisher::addEvent(ProductCategoryEvents::PRODUCT_CATEGORY_PUBLISH, $idProductAbstract);
            DataImporterPublisher::addEvent(ProductEvents::PRODUCT_ABSTRACT_PUBLISH, $idProductAbstract);
        }
    }

    /**
     * @param \Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface $dataSet
     * @param int $idProductAbstract
     *
     * @return void
     */
    protected function createOrUpdateProductUrls(DataSetInterface $dataSet, int $idProductAbstract): void
    {
        $productUrlTransfers = $this->getProductUrlTransfers($dataSet);

        foreach ($productUrlTransfers as $productUrlArray) {
            $productUrlTransfer = $productUrlArray[ProductAbstractHydratorStep::KEY_PRODUCT_URL_TRASNFER];

            $productUrl = $productUrlTransfer->getUrl();
            $idLocale = $productUrlTransfer->getFkLocale();

            $this->cleanupRedirectUrls($productUrl);

            $urlEntity = SpyUrlQuery::create()
                ->filterByFkLocale($idLocale)
                ->filterByFkResourceProductAbstract($idProductAbstract)
                ->findOneOrCreate();

            $urlEntity->fromArray($productUrlTransfer->modifiedToArray());

            if (!$urlEntity->isNew() && !$urlEntity->isModified()) {
                continue;
            }

            $urlEntity->save();

            DataImporterPublisher::addEvent(UrlEvents::URL_PUBLISH, $urlEntity->getIdUrl());
        }
    }

    /**
     * @param string $abstractProductUrl
     *
     * @return void
     */
    protected function cleanupRedirectUrls(string $abstractProductUrl): void
    {
        SpyUrlQuery::create()
            ->filterByUrl($abstractProductUrl)
            ->filterByFkResourceRedirect(null, Criteria::ISNOTNULL)
            ->delete();
    }

    /**
     * @return void
     */
    public function flush(): void
    {
        DataImporterPublisher::triggerEvents();
    }

    /**
     * @param \Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface $dataSet
     *
     * @return \Generated\Shared\Transfer\SpyProductAbstractEntityTransfer
     */
    protected function getProductAbstractTransfer(DataSetInterface $dataSet): SpyProductAbstractEntityTransfer
    {
        return $dataSet[ProductAbstractHydratorStep::DATA_PRODUCT_ABSTRACT_TRANSFER];
    }

    /**
     * @param \Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface $dataSet
     *
     * @return array<string, mixed>
     */
    protected function getProductAbstractLocalizedTransfers(DataSetInterface $dataSet): array
    {
        return $dataSet[ProductAbstractHydratorStep::DATA_PRODUCT_ABSTRACT_LOCALIZED_TRANSFER];
    }

    /**
     * @param \Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface $dataSet
     *
     * @return array<string, mixed>
     */
    protected function getProductCategoryTransfers(DataSetInterface $dataSet): array
    {
        return $dataSet[ProductAbstractHydratorStep::DATA_PRODUCT_CATEGORY_TRANSFER];
    }

    /**
     * @param \Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface $dataSet
     *
     * @return array<string, mixed>
     */
    protected function getProductUrlTransfers(DataSetInterface $dataSet): array
    {
        return $dataSet[ProductAbstractHydratorStep::DATA_PRODUCT_URL_TRANSFER];
    }
}


1			<?php
2
3			/**
4			* This file is part of the Spryker Commerce OS.
5			* For full license information, please view the LICENSE file that was distributed with this source code.
6			*/
7
8			declare(strict_types = 1);
9
10			namespace Pyz\Zed\DataImport\Business\Model\ProductAbstract\Writer;
11
12			use Generated\Shared\Transfer\SpyProductAbstractEntityTransfer;
			0 ignored issues – show Bug introduced 2020-09-01 10:20 UTC by Report Bug Copy Issue Report The type `Generated\Shared\Transfe...tAbstractEntityTransfer` was not found. Maybe you did not declare it correctly or list all dependencies? The issue could also be caused by a filter entry in the build configuration. If the path has been excluded in your configuration, e.g. `excluded_paths: ["lib/"]`, you can move it to the dependency path list as follows: filter: dependency_paths: ["lib/"] For further information see https://scrutinizer-ci.com/docs/tools/php/php-scrutinizer/#list-dependency-paths Loading history...
13			use Orm\Zed\Product\Persistence\SpyProductAbstract;
14			use Orm\Zed\Product\Persistence\SpyProductAbstractLocalizedAttributesQuery;
15			use Orm\Zed\Product\Persistence\SpyProductAbstractQuery;
16			use Orm\Zed\ProductCategory\Persistence\SpyProductCategoryQuery;
17			use Orm\Zed\Url\Persistence\SpyUrlQuery;
18			use Propel\Runtime\ActiveQuery\Criteria;
19			use Pyz\Zed\DataImport\Business\Model\Product\Repository\ProductRepository;
20			use Pyz\Zed\DataImport\Business\Model\ProductAbstract\ProductAbstractHydratorStep;
21			use Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface;
22			use Spryker\Zed\DataImport\Business\Model\DataSet\DataSetWriterInterface;
23			use Spryker\Zed\DataImport\Business\Model\Publisher\DataImporterPublisher;
24			use Spryker\Zed\Product\Dependency\ProductEvents;
25			use Spryker\Zed\ProductCategory\Dependency\ProductCategoryEvents;
26			use Spryker\Zed\Url\Dependency\UrlEvents;
27
28			class ProductAbstractPropelDataSetWriter implements DataSetWriterInterface
29			{
30			/**
31			* @var \Pyz\Zed\DataImport\Business\Model\Product\Repository\ProductRepository
32			*/
33			protected $productRepository;
34
35			/**
36			* @param \Pyz\Zed\DataImport\Business\Model\Product\Repository\ProductRepository $productRepository
37			*/
38			public function __construct(ProductRepository $productRepository)
39			{
40			$this->productRepository = $productRepository;
41			}
42
43			/**
44			* @param \Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface $dataSet
45			*
46			* @return void
47			*/
48			public function write(DataSetInterface $dataSet): void
49			{
50			$productAbstractEntity = $this->createOrUpdateProductAbstract($dataSet);
51
52			$this->productRepository->addProductAbstract($productAbstractEntity);
53
54			$this->createOrUpdateProductAbstractLocalizedAbstract($dataSet, $productAbstractEntity->getIdProductAbstract());
55			$this->createOrUpdateProductCategories($dataSet, $productAbstractEntity->getIdProductAbstract());
56			$this->createOrUpdateProductUrls($dataSet, $productAbstractEntity->getIdProductAbstract());
57
58			DataImporterPublisher::addEvent(ProductEvents::PRODUCT_ABSTRACT_PUBLISH, $productAbstractEntity->getIdProductAbstract());
59			}
60
61			/**
62			* @param \Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface $dataSet
63			*
64			* @return \Orm\Zed\Product\Persistence\SpyProductAbstract
65			*/
66			protected function createOrUpdateProductAbstract(DataSetInterface $dataSet): SpyProductAbstract
67			{
68			$productAbstractEntityTransfer = $this->getProductAbstractTransfer($dataSet);
69
70			$productAbstractEntity = SpyProductAbstractQuery::create()
71			->filterBySku($productAbstractEntityTransfer->getSku())
72			->findOneOrCreate();
73
74			$productAbstractEntity->fromArray($productAbstractEntityTransfer->modifiedToArray());
75
76			if ($productAbstractEntity->isNew() \|\| $productAbstractEntity->isModified()) {
77			$productAbstractEntity->save();
78
79			DataImporterPublisher::addEvent(ProductEvents::PRODUCT_ABSTRACT_PUBLISH, $productAbstractEntity->getIdProductAbstract());
80			}
81
82			return $productAbstractEntity;
83			}
84
85			/**
86			* @param \Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface $dataSet
87			* @param int $idProductAbstract
88			*
89			* @return void
90			*/
91			protected function createOrUpdateProductAbstractLocalizedAbstract(
92			DataSetInterface $dataSet,
93			int $idProductAbstract,
94			): void {
95			$productAbstractLocalizedTransfers = $this->getProductAbstractLocalizedTransfers($dataSet);
96
97			foreach ($productAbstractLocalizedTransfers as $productAbstractLocalizedArray) {
98			$productAbstractLocalizedTransfer = $productAbstractLocalizedArray[ProductAbstractHydratorStep::KEY_PRODUCT_ABSTRACT_LOCALIZED_TRANSFER];
99
100			$idLocale = $productAbstractLocalizedTransfer->getFkLocale();
101
102			$productAbstractLocalizedAttributesEntity = SpyProductAbstractLocalizedAttributesQuery::create()
103			->filterByFkProductAbstract($idProductAbstract)
104			->filterByFkLocale($idLocale)
105			->findOneOrCreate();
106
107			$productAbstractLocalizedAttributesEntity->fromArray($productAbstractLocalizedTransfer->modifiedToArray());
108
109			if (!$productAbstractLocalizedAttributesEntity->isNew() && !$productAbstractLocalizedAttributesEntity->isModified()) {
110			continue;
111			}
112
113			$productAbstractLocalizedAttributesEntity->save();
114			}
115			}
116
117			/**
118			* @param \Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface $dataSet
119			* @param int $idProductAbstract
120			*
121			* @return void
122			*/
123			protected function createOrUpdateProductCategories(DataSetInterface $dataSet, int $idProductAbstract): void
124			{
125			$productCategoryTransfers = $this->getProductCategoryTransfers($dataSet);
126
127			foreach ($productCategoryTransfers as $productCategoryArray) {
128			$productCategoryTransfer = $productCategoryArray[ProductAbstractHydratorStep::KEY_PRODUCT_CATEGORY_TRANSFER];
129
130			$productCategoryEntity = SpyProductCategoryQuery::create()
131			->filterByFkProductAbstract($idProductAbstract)
132			->filterByFkCategory($productCategoryTransfer->getFkCategory())
133			->findOneOrCreate();
134
135			$productCategoryEntity->fromArray($productCategoryTransfer->modifiedToArray());
136
137			if (!$productCategoryEntity->isNew() && !$productCategoryEntity->isModified()) {
138			continue;
139			}
140
141			$productCategoryEntity->save();
142
143			DataImporterPublisher::addEvent(ProductCategoryEvents::PRODUCT_CATEGORY_PUBLISH, $idProductAbstract);
144			DataImporterPublisher::addEvent(ProductEvents::PRODUCT_ABSTRACT_PUBLISH, $idProductAbstract);
145			}
146			}
147
148			/**
149			* @param \Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface $dataSet
150			* @param int $idProductAbstract
151			*
152			* @return void
153			*/
154			protected function createOrUpdateProductUrls(DataSetInterface $dataSet, int $idProductAbstract): void
155			{
156			$productUrlTransfers = $this->getProductUrlTransfers($dataSet);
157
158			foreach ($productUrlTransfers as $productUrlArray) {
159			$productUrlTransfer = $productUrlArray[ProductAbstractHydratorStep::KEY_PRODUCT_URL_TRASNFER];
160
161			$productUrl = $productUrlTransfer->getUrl();
162			$idLocale = $productUrlTransfer->getFkLocale();
163
164			$this->cleanupRedirectUrls($productUrl);
165
166			$urlEntity = SpyUrlQuery::create()
167			->filterByFkLocale($idLocale)
168			->filterByFkResourceProductAbstract($idProductAbstract)
169			->findOneOrCreate();
170
171			$urlEntity->fromArray($productUrlTransfer->modifiedToArray());
172
173			if (!$urlEntity->isNew() && !$urlEntity->isModified()) {
174			continue;
175			}
176
177			$urlEntity->save();
178
179			DataImporterPublisher::addEvent(UrlEvents::URL_PUBLISH, $urlEntity->getIdUrl());
180			}
181			}
182
183			/**
184			* @param string $abstractProductUrl
185			*
186			* @return void
187			*/
188			protected function cleanupRedirectUrls(string $abstractProductUrl): void
189			{
190			SpyUrlQuery::create()
191			->filterByUrl($abstractProductUrl)
192			->filterByFkResourceRedirect(null, Criteria::ISNOTNULL)
193			->delete();
194			}
195
196			/**
197			* @return void
198			*/
199			public function flush(): void
200			{
201			DataImporterPublisher::triggerEvents();
202			}
203
204			/**
205			* @param \Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface $dataSet
206			*
207			* @return \Generated\Shared\Transfer\SpyProductAbstractEntityTransfer
208			*/
209			protected function getProductAbstractTransfer(DataSetInterface $dataSet): SpyProductAbstractEntityTransfer
210			{
211			return $dataSet[ProductAbstractHydratorStep::DATA_PRODUCT_ABSTRACT_TRANSFER];
212			}
213
214			/**
215			* @param \Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface $dataSet
216			*
217			* @return array<string, mixed>
218			*/
219			protected function getProductAbstractLocalizedTransfers(DataSetInterface $dataSet): array
220			{
221			return $dataSet[ProductAbstractHydratorStep::DATA_PRODUCT_ABSTRACT_LOCALIZED_TRANSFER];
222			}
223
224			/**
225			* @param \Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface $dataSet
226			*
227			* @return array<string, mixed>
228			*/
229			protected function getProductCategoryTransfers(DataSetInterface $dataSet): array
230			{
231			return $dataSet[ProductAbstractHydratorStep::DATA_PRODUCT_CATEGORY_TRANSFER];
232			}
233
234			/**
235			* @param \Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface $dataSet
236			*
237			* @return array<string, mixed>
238			*/
239			protected function getProductUrlTransfers(DataSetInterface $dataSet): array
240			{
241			return $dataSet[ProductAbstractHydratorStep::DATA_PRODUCT_URL_TRANSFER];
242			}
243			}
244

spryker-shop / b2b-demo-shop

getProductAbstractLocalizedTransfers() A last analyzed 2025-09-16 15:05 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

getProductAbstractLocalizedTransfers() A
last analyzed 2025-09-16 15:05 UTC