ProductAbstractPagePublisher::pairRemainingProductAbstractPageSearchEntities() - Code Metrics - spryker/spryker-core - Measure and Improve Code Quality continuously with Scrutinizer

pairRemainingProductAbstractPageSearchEntities() A
last analyzed 2025-09-26 11:00 UTC

↳ Parent: ProductAbstractPagePublisher
Complexity

Conditions	1
Paths	1
Size

Total Lines	12
Code Lines	7
Duplication

Lines	0
Ratio	0 %
Importance

Changes
Metric	Value
cc	1
eloc	7
nc	1
nop	2
dl	0
loc	12
rs	10
c	0
b	0
f	0
<?php

/**
 * Copyright © 2016-present Spryker Systems GmbH. All rights reserved.
 * Use of this software requires acceptance of the Evaluation License Agreement. See LICENSE file.
 */

namespace Spryker\Zed\ProductPageSearch\Business\Publisher;

use Generated\Shared\Transfer\ProductPageLoadTransfer;
use Generated\Shared\Transfer\ProductPageSearchTransfer;
use Generated\Shared\Transfer\ProductPayloadTransfer;
use Orm\Zed\ProductPageSearch\Persistence\SpyProductAbstractPageSearch;
use Spryker\Shared\ProductPageSearch\ProductPageSearchConfig as SharedProductPageSearchConfig;
use Spryker\Zed\Kernel\Persistence\EntityManager\InstancePoolingTrait;
use Spryker\Zed\ProductPageSearch\Business\Exception\PluginNotFoundException;
use Spryker\Zed\ProductPageSearch\Business\Mapper\ProductPageSearchMapperInterface;
use Spryker\Zed\ProductPageSearch\Business\Model\ProductPageSearchWriterInterface;
use Spryker\Zed\ProductPageSearch\Business\Reader\AddToCartSkuReaderInterface;
use Spryker\Zed\ProductPageSearch\Dependency\Facade\ProductPageSearchToStoreFacadeInterface;
use Spryker\Zed\ProductPageSearch\Persistence\ProductPageSearchQueryContainerInterface;
use Spryker\Zed\ProductPageSearch\Persistence\ProductPageSearchRepositoryInterface;
use Spryker\Zed\ProductPageSearch\ProductPageSearchConfig;

class ProductAbstractPagePublisher implements ProductAbstractPagePublisherInterface
{
    use InstancePoolingTrait;

    /**
     * @var array<int>
     */
    protected static array $publishedProductAbstractIds = [];

    /**
     * @var array<int>
     */
    protected static array $unpublishedProductAbstractIds = [];

    /**
     * @var string
     */
    public const PRODUCT_ABSTRACT_LOCALIZED_ENTITY = 'PRODUCT_ABSTRACT_LOCALIZED_ENTITY';

    /**
     * @var string
     */
    public const PRODUCT_ABSTRACT_PAGE_SEARCH_ENTITY = 'PRODUCT_ABSTRACT_PAGE_SEARCH_ENTITY';

    /**
     * @var string
     */
    public const STORE_NAME = 'STORE_NAME';

    /**
     * @var string
     */
    public const LOCALE_NAME = 'LOCALE_NAME';

    /**
     * @var array<int, array<string>>
     */
    protected static $localesByIdStoreMap;

    /**
     * @var array<int, int>
     */
    protected array $productAbstractIdTimestampMapToSave = [];

    /**
     * @param \Spryker\Zed\ProductPageSearch\Persistence\ProductPageSearchRepositoryInterface $repository
     * @param \Spryker\Zed\ProductPageSearch\Persistence\ProductPageSearchQueryContainerInterface $queryContainer
     * @param array<\Spryker\Zed\ProductPageSearch\Dependency\Plugin\ProductPageDataExpanderInterface> $pageDataExpanderPlugins
     * @param array<\Spryker\Zed\ProductPageSearchExtension\Dependency\Plugin\ProductPageDataLoaderPluginInterface> $productPageDataLoaderPlugins
     * @param array<\Spryker\Zed\ProductPageSearchExtension\Dependency\Plugin\ProductPageSearchCollectionFilterPluginInterface> $productPageSearchCollectionFilterPlugins
     * @param \Spryker\Zed\ProductPageSearch\Business\Mapper\ProductPageSearchMapperInterface $productPageSearchMapper
     * @param \Spryker\Zed\ProductPageSearch\Business\Model\ProductPageSearchWriterInterface $productPageSearchWriter
     * @param \Spryker\Zed\ProductPageSearch\ProductPageSearchConfig $productPageSearchConfig
     * @param \Spryker\Zed\ProductPageSearch\Dependency\Facade\ProductPageSearchToStoreFacadeInterface $storeFacade
     * @param \Spryker\Zed\ProductPageSearch\Business\Reader\AddToCartSkuReaderInterface $addToCartSkuReader
     */
    public function __construct(
        protected ProductPageSearchRepositoryInterface $repository,
        protected ProductPageSearchQueryContainerInterface $queryContainer,
        protected array $pageDataExpanderPlugins,
        protected array $productPageDataLoaderPlugins,
        protected array $productPageSearchCollectionFilterPlugins,
        protected ProductPageSearchMapperInterface $productPageSearchMapper,
        protected ProductPageSearchWriterInterface $productPageSearchWriter,
        protected ProductPageSearchConfig $productPageSearchConfig,
        protected ProductPageSearchToStoreFacadeInterface $storeFacade,
        protected AddToCartSkuReaderInterface $addToCartSkuReader
    ) {
    }

    /**
     * @param array<int, int> $productAbstractIdTimestampMap
     *
     * @return void
     */
    public function publishWithTimestamps(array $productAbstractIdTimestampMap): void
    {
        // Filters IDs if it had been processed in the current process
        $productAbstractIds = array_values(array_unique(array_diff(array_keys($productAbstractIdTimestampMap), static::$publishedProductAbstractIds)));
        // Exclude IDs if they were processed in current process
        $productAbstractIdTimestampMap = array_intersect_key($productAbstractIdTimestampMap, array_flip($productAbstractIds));
        // Filters IDs if it had been processed in parallel processes
        $this->productAbstractIdTimestampMapToSave = $this->repository->getRelevantProductAbstractIdsToUpdate($productAbstractIdTimestampMap);

        if ($this->productAbstractIdTimestampMapToSave) {
            $this->publish(array_keys($this->productAbstractIdTimestampMapToSave));
        }

        static::$publishedProductAbstractIds = array_merge(static::$publishedProductAbstractIds, $productAbstractIds);
    }

    /**
     * @param array<int> $productAbstractIds
     *
     * @return void
     */
    public function publish(array $productAbstractIds)
    {
        $productAbstractIdsChunks = array_chunk(
            $productAbstractIds,
            $this->productPageSearchConfig->getProductAbstractPagePublishChunkSize(),
        );

        foreach ($productAbstractIdsChunks as $productAbstractIdsChunk) {
            $this->publishEntities($productAbstractIdsChunk, [], false);
        }
    }

    /**
     * @param array<int> $productAbstractIds
     * @param array<string> $pageDataExpanderPluginNames
     *
     * @return void
     */
    public function refresh(array $productAbstractIds, array $pageDataExpanderPluginNames = [])
    {
        $isPoolingStateChanged = $this->disableInstancePooling();

        $productAbstractIdsChunks = array_chunk(
            array_unique($productAbstractIds),
            $this->productPageSearchConfig->getProductAbstractPagePublishChunkSize(),
        );

        foreach ($productAbstractIdsChunks as $productAbstractIdsChunk) {
            $this->publishEntities($productAbstractIdsChunk, $pageDataExpanderPluginNames, true);
        }

        if ($isPoolingStateChanged) {
            $this->enableInstancePooling();
        }
    }

    /**
     * @param array<int, int> $productAbstractIdTimestampMap
     *
     * @return void
     */
    public function unpublishWithTimestamps(array $productAbstractIdTimestampMap)
    {
        $productAbstractIds = array_values(array_unique(array_diff(array_keys($productAbstractIdTimestampMap), static::$unpublishedProductAbstractIds)));
        if ($productAbstractIds) {
            $this->unpublish($productAbstractIds);
        }
        static::$unpublishedProductAbstractIds = array_merge(static::$unpublishedProductAbstractIds, $productAbstractIds);
    }

    /**
     * @param array<int> $productAbstractIds
     *
     * @return void
     */
    public function unpublish(array $productAbstractIds)
    {
        $productAbstractPageSearchEntities = $this->findProductAbstractPageSearchEntities($productAbstractIds);
        $this->productPageSearchWriter->deleteProductAbstractPageSearchEntities($productAbstractPageSearchEntities);
        $this->productPageSearchWriter->commitRemaining();
    }

    /**
     * @param array<int> $productAbstractIds
     * @param array<string> $pageDataExpanderPluginNames
     * @param bool $isRefresh
     *
     * @return void
     */
    protected function publishEntities(array $productAbstractIds, array $pageDataExpanderPluginNames, $isRefresh = false)
    {
        $pageDataExpanderPlugins = $this->getPageDataExpanderPlugins($pageDataExpanderPluginNames);

        $payloadTransfers = [];
        foreach ($productAbstractIds as $productAbstractId) {
            $payloadTransfers[$productAbstractId] = (new ProductPayloadTransfer())->setIdProductAbstract($productAbstractId);
        }

        $productPageLoadTransfer = (new ProductPageLoadTransfer())
            ->setProductAbstractIds($productAbstractIds)
            ->setPayloadTransfers($payloadTransfers);

        foreach ($this->productPageDataLoaderPlugins as $productPageDataLoaderPlugin) {
            $productPageLoadTransfer = $productPageDataLoaderPlugin->expandProductPageDataTransfer($productPageLoadTransfer);
        }

        $productAbstractLocalizedEntities = $this->findProductAbstractLocalizedEntities($productAbstractIds);
        $productCategories = $this->getProductCategoriesByProductAbstractIds($productAbstractIds);
        $productAbstractLocalizedEntities = $this->hydrateProductAbstractLocalizedEntitiesWithProductCategories($productCategories, $productAbstractLocalizedEntities);

        $productAbstractPageSearchEntities = $this->findProductAbstractPageSearchEntities($productAbstractIds);
        if (!$productAbstractLocalizedEntities) {
            $this->productPageSearchWriter->deleteProductAbstractPageSearchEntities($productAbstractPageSearchEntities);
            $this->productPageSearchWriter->commitRemaining();

            return;
        }

        if ($this->productPageSearchConfig->isProductAbstractAddToCartEnabled()) {
            $productAbstractLocalizedEntities = $this->hydrateProductAbstractLocalizedEntitiesWithProductAbstractAddToCartSku(
                $productAbstractLocalizedEntities,
                $productAbstractIds,
            );
        }

        $this->storeData(
            $productAbstractLocalizedEntities,
            $productAbstractPageSearchEntities,
            $pageDataExpanderPlugins,
            $productPageLoadTransfer,
            $isRefresh,
        );

        $this->productPageSearchWriter->commitRemaining();
    }

    /**
     * @param array<array<string, mixed>> $productAbstractLocalizedEntities
     * @param array<\Orm\Zed\ProductPageSearch\Persistence\SpyProductAbstractPageSearch> $productAbstractPageSearchEntities
     * @param array<\Spryker\Zed\ProductPageSearch\Dependency\Plugin\ProductPageDataExpanderInterface> $pageDataExpanderPlugins
     * @param \Generated\Shared\Transfer\ProductPageLoadTransfer $productPageLoadTransfer
     * @param bool $isRefresh
     *
     * @return void
     */
    protected function storeData(
        array $productAbstractLocalizedEntities,
        array $productAbstractPageSearchEntities,
        array $pageDataExpanderPlugins,
        ProductPageLoadTransfer $productPageLoadTransfer,
        $isRefresh = false
    ) {
        $pairedEntities = $this->pairProductAbstractLocalizedEntitiesWithProductAbstractPageSearchEntities(
            $productAbstractLocalizedEntities,
            $productAbstractPageSearchEntities,
            $productPageLoadTransfer,
        );

        $productPageSearchTransfers = $this->mapPairedEntitiesToProductPageSearchTransfers(
            $pairedEntities,
            $isRefresh,
        );
        $productPageSearchTransfers = $this->executeProductPageSearchCollectionFilterPlugins($productPageSearchTransfers);
        $productPageSearchTransfersIndexedByLocaleAndIdProductAbstract = $this->getProductPageSearchTransfersIndexedByLocaleAndIdProductAbstract(
            $productPageSearchTransfers,
        );

        foreach ($pairedEntities as $pairedEntity) {
            /** @var array|null $productAbstractLocalizedEntity */
            $productAbstractLocalizedEntity = $pairedEntity[static::PRODUCT_ABSTRACT_LOCALIZED_ENTITY];
            /** @var \Orm\Zed\ProductPageSearch\Persistence\SpyProductAbstractPageSearch $productAbstractPageSearchEntity */
            $productAbstractPageSearchEntity = $pairedEntity[static::PRODUCT_ABSTRACT_PAGE_SEARCH_ENTITY];
            $store = $pairedEntity[static::STORE_NAME];
            $locale = $pairedEntity[static::LOCALE_NAME];

            if ($productAbstractLocalizedEntity === null || !$this->isActual($productAbstractLocalizedEntity)) {
                $this->deleteProductAbstractPageSearchEntity($productAbstractPageSearchEntity);

                continue;
            }

            $idProductAbstract = $productAbstractLocalizedEntity['fk_product_abstract'];
            $productPageSearchTransfer = $this->findProductPageSearchTransferFromIndexedList(
                $productPageSearchTransfersIndexedByLocaleAndIdProductAbstract,
                $idProductAbstract,
                $locale,
                $store,
            );

            if ($productPageSearchTransfer === null) {
                $this->deleteProductAbstractPageSearchEntity($productAbstractPageSearchEntity);

                continue;
            }

            $this->storeProductAbstractPageSearchEntity(
                $productAbstractLocalizedEntity,
                $productAbstractPageSearchEntity,
                $productPageSearchTransfer,
                $store,
                $locale,
                $pageDataExpanderPlugins,
            );
        }
    }

    /**
     * @param \Orm\Zed\ProductPageSearch\Persistence\SpyProductAbstractPageSearch $productAbstractPageSearchEntity
     *
     * @return void
     */
    protected function deleteProductAbstractPageSearchEntity(SpyProductAbstractPageSearch $productAbstractPageSearchEntity)
    {
        if (!$productAbstractPageSearchEntity->isNew()) {
            $productAbstractPageSearchEntity->delete();
        }
    }

    /**
     * @param array $productAbstractLocalizedEntity
     * @param \Orm\Zed\ProductPageSearch\Persistence\SpyProductAbstractPageSearch $productAbstractPageSearchEntity
     * @param \Generated\Shared\Transfer\ProductPageSearchTransfer $productPageSearchTransfer
     * @param string $storeName
     * @param string $localeName
     * @param array<\Spryker\Zed\ProductPageSearch\Dependency\Plugin\ProductPageDataExpanderInterface> $pageDataExpanderPlugins
     *
     * @return void
     */
    protected function storeProductAbstractPageSearchEntity(
        array $productAbstractLocalizedEntity,
        SpyProductAbstractPageSearch $productAbstractPageSearchEntity,
        ProductPageSearchTransfer $productPageSearchTransfer,
        string $storeName,
        string $localeName,
        array $pageDataExpanderPlugins
    ) {
        if (!empty($this->productAbstractIdTimestampMapToSave[$productAbstractPageSearchEntity->getFkProductAbstract()])) {
            $productPageSearchTransfer->setTimestamp($this->productAbstractIdTimestampMapToSave[$productAbstractPageSearchEntity->getFkProductAbstract()]);
        }
        $productPageSearchTransfer->setStore($storeName);
        $productPageSearchTransfer->setLocale($localeName);

        $this->expandPageSearchTransferWithPlugins($pageDataExpanderPlugins, $productAbstractLocalizedEntity, $productPageSearchTransfer);

        $searchDocument = $this->productPageSearchMapper->mapToSearchData($productPageSearchTransfer);

        $this->productPageSearchWriter->save($productPageSearchTransfer, $searchDocument, $productAbstractPageSearchEntity);
    }

    /**
     * @param array $productAbstractLocalizedEntity
     *
     * @return bool
     */
    protected function isActual(array $productAbstractLocalizedEntity): bool
    {
        foreach ($productAbstractLocalizedEntity['SpyProductAbstract']['SpyProducts'] as $spyProduct) {
            if ($spyProduct['is_active'] && $this->isSearchable($spyProduct, $productAbstractLocalizedEntity['fk_locale'])) {
                return true;
            }
        }

        return false;
    }

    /**
     * @param array $spyProduct
     * @param int $idLocale
     *
     * @return bool
     */
    protected function isSearchable(array $spyProduct, int $idLocale): bool
    {
        foreach ($spyProduct['SpyProductSearches'] as $spyProductSearch) {
            if ($spyProductSearch['fk_locale'] === $idLocale && $spyProductSearch['is_searchable'] === true) {
                return true;
            }
        }

        return false;
    }

    /**
     * Retrieves the ProductPageSearchTransfer from the storage entity (if it existed already) or populates it from the localized entity.
     *
     * @param array $productAbstractLocalizedEntity
     * @param \Orm\Zed\ProductPageSearch\Persistence\SpyProductAbstractPageSearch $productAbstractPageSearchEntity
     * @param bool $isRefresh
     *
     * @return \Generated\Shared\Transfer\ProductPageSearchTransfer
     */
    protected function getProductPageSearchTransfer(
        array $productAbstractLocalizedEntity,
        SpyProductAbstractPageSearch $productAbstractPageSearchEntity,
        $isRefresh = false
    ): ProductPageSearchTransfer {
        if ($isRefresh && !$productAbstractPageSearchEntity->isNew()) {
            return $this->refreshProductPageSearchTransfer($productAbstractPageSearchEntity);
        }

        return $this->productPageSearchMapper->mapToProductPageSearchTransfer($productAbstractLocalizedEntity);
    }

    /**
     * @param \Orm\Zed\ProductPageSearch\Persistence\SpyProductAbstractPageSearch $productAbstractPageSearchEntity
     *
     * @return \Generated\Shared\Transfer\ProductPageSearchTransfer
     */
    protected function refreshProductPageSearchTransfer(
        SpyProductAbstractPageSearch $productAbstractPageSearchEntity
    ): ProductPageSearchTransfer {
        return $this->productPageSearchMapper->mapToProductPageSearchTransferFromJson($productAbstractPageSearchEntity->getStructuredData());
    }

    /**
     * @param array<string> $pageDataExpanderPluginNames
     *
     * @return array<\Spryker\Zed\ProductPageSearch\Dependency\Plugin\ProductPageDataExpanderInterface>
     */
    protected function getPageDataExpanderPlugins(array $pageDataExpanderPluginNames)
    {
        if (!$pageDataExpanderPluginNames) {
            return $this->pageDataExpanderPlugins;
        }

        $selectedExpanderPlugins = [];
        foreach ($pageDataExpanderPluginNames as $pageDataExpanderPluginName) {
            $this->assertPageDataExpanderPluginName($pageDataExpanderPluginName);

            $selectedExpanderPlugins[] = $this->pageDataExpanderPlugins[$pageDataExpanderPluginName];
        }

        return $selectedExpanderPlugins;
    }

    /**
     * @param string $pageDataExpanderPluginName
     *
     * @throws \Spryker\Zed\ProductPageSearch\Business\Exception\PluginNotFoundException
     *
     * @return void
     */
    protected function assertPageDataExpanderPluginName($pageDataExpanderPluginName)
    {
        if (!isset($this->pageDataExpanderPlugins[$pageDataExpanderPluginName])) {
            throw new PluginNotFoundException(sprintf('The plugin with this name: %s is not found', $pageDataExpanderPluginName));
        }
    }

    /**
     * @param array<\Spryker\Zed\ProductPageSearch\Dependency\Plugin\ProductPageDataExpanderInterface> $pageDataExpanderPlugins
     * @param array<string, mixed> $productAbstractLocalizedEntity
     * @param \Generated\Shared\Transfer\ProductPageSearchTransfer $productPageSearchTransfer
     *
     * @return void
     */
    protected function expandPageSearchTransferWithPlugins(
        array $pageDataExpanderPlugins,
        array $productAbstractLocalizedEntity,
        ProductPageSearchTransfer $productPageSearchTransfer
    ) {
        foreach ($pageDataExpanderPlugins as $pageDataExpanderPlugin) {
            $pageDataExpanderPlugin->expandProductPageData($productAbstractLocalizedEntity, $productPageSearchTransfer);
        }
    }

    /**
     * - Returns a paired array with all provided entities.
     * - ProductAbstractLocalizedEntities without ProductAbstractPageSearchEntity are paired with a newly created ProductAbstractPageSearchEntity.
     * - ProductAbstractPageSearchEntity without ProductAbstractLocalizedEntities (left outs) are paired with NULL.
     * - ProductAbstractLocalizedEntities are paired multiple times per store.
     *
     * @param array<array<string, mixed>> $productAbstractLocalizedEntities
     * @param array<\Orm\Zed\ProductPageSearch\Persistence\SpyProductAbstractPageSearch> $productAbstractPageSearchEntities
     * @param \Generated\Shared\Transfer\ProductPageLoadTransfer $productPageLoadTransfer
     *
     * @return array
     */
    protected function pairProductAbstractLocalizedEntitiesWithProductAbstractPageSearchEntities(
        array $productAbstractLocalizedEntities,
        array $productAbstractPageSearchEntities,
        ProductPageLoadTransfer $productPageLoadTransfer
    ) {
        $mappedProductAbstractPageSearchEntities = $this->mapProductAbstractPageSearchEntities($productAbstractPageSearchEntities);

        $pairs = [];
        $productPayloadTransfers = $productPageLoadTransfer->getPayloadTransfers();
        foreach ($productAbstractLocalizedEntities as $productAbstractLocalizedEntity) {
            [$pairs, $mappedProductAbstractPageSearchEntities] = $this->pairProductAbstractLocalizedEntityWithProductAbstractPageSearchEntityByStoresAndLocale(
                $productAbstractLocalizedEntity['fk_product_abstract'],
                $productAbstractLocalizedEntity['Locale']['locale_name'],
                $productPayloadTransfers[$productAbstractLocalizedEntity['fk_product_abstract']],
                $productAbstractLocalizedEntity['SpyProductAbstract']['SpyProductAbstractStores'],
                $productAbstractLocalizedEntity,
                $mappedProductAbstractPageSearchEntities,
                $pairs,
            );
        }

        $pairs = $this->pairRemainingProductAbstractPageSearchEntities($mappedProductAbstractPageSearchEntities, $pairs);

        return $pairs;
    }

    /**
     * @param array<int> $productAbstractIds
     *
     * @return array
     */
    protected function findProductAbstractLocalizedEntities(array $productAbstractIds)
    {
        $localesByIdStoreMap = $this->getLocalesByIdStoreMap();
        /** @var array<int> $allStoreIds */
        $allStoreIds = array_keys($localesByIdStoreMap);
        $allLocaleIsoCodes = array_merge(...array_values($localesByIdStoreMap));

        $productAbstractLocalizedAttributeDataCollection = $this
            ->queryContainer
            ->queryProductAbstractLocalizedAttributesByProductAbstractIdsAndStoreIdsAndLocaleIds(
                $productAbstractIds,
                $allStoreIds,
                $allLocaleIsoCodes,
            )
            ->find()
            ->getData();

        $productConcreteEntities = $this->queryContainer
            ->queryProductConcretesByAbstractProductIdsAndLocaleIsoCodes($productAbstractIds, $allLocaleIsoCodes)
            ->find()
            ->getData();

        $productConcreteIds = array_column($productConcreteEntities, 'id_product');

        $productSearchEntities = $this->queryContainer
            ->queryProductSearchByProductConcreteIdsAndLocaleIsoCodes($productConcreteIds, $allLocaleIsoCodes)
            ->find()
            ->getData();

        $productConcreteEntities = $this->hydrateProductConcreteEntitiesWithProductSearchEntities(
            $productSearchEntities,
            $productConcreteEntities,
        );

        return $this->hydrateProductAbstractLocalizedEntitiesWithProductConcreteEntities(
            $productConcreteEntities,
            $productAbstractLocalizedAttributeDataCollection,
        );
    }

    /**
     * @param array $productSearchEntities
     * @param array $productConcreteEntities
     *
     * @return array
     */
    protected function hydrateProductConcreteEntitiesWithProductSearchEntities(array $productSearchEntities, array $productConcreteEntities): array
    {
        $productSearchByProductConcreteId = [];

        foreach ($productSearchEntities as $productSearch) {
            $productSearchByProductConcreteId[$productSearch['fk_product']][] = $productSearch;
        }

        foreach ($productConcreteEntities as $key => $productConcreteEntity) {
            $productConcreteId = (int)$productConcreteEntity['id_product'];
            $productConcreteEntities[$key]['SpyProductSearches'] = $productSearchByProductConcreteId[$productConcreteId] ?? [];
        }

        return $productConcreteEntities;
    }

    /**
     * @param array $productCategories
     * @param array $productAbstractLocalizedEntities
     *
     * @return array
     */
    protected function hydrateProductAbstractLocalizedEntitiesWithProductCategories(array $productCategories, array $productAbstractLocalizedEntities)
    {
        $productCategoriesByProductAbstractId = [];

        foreach ($productCategories as $productCategory) {
            $productCategoriesByProductAbstractId[$productCategory['fk_product_abstract']][] = $productCategory;
        }

        foreach ($productAbstractLocalizedEntities as $key => $productAbstractLocalizedEntity) {
            $productAbstractId = (int)$productAbstractLocalizedEntity['fk_product_abstract'];
            $productAbstractLocalizedEntities[$key]['SpyProductAbstract']['SpyProductCategories']
                = $productCategoriesByProductAbstractId[$productAbstractId] ?? [];
        }

        return $productAbstractLocalizedEntities;
    }

    /**
     * @param array $productConcreteData
     * @param array $productAbstractLocalizedEntities
     *
     * @return array
     */
    protected function hydrateProductAbstractLocalizedEntitiesWithProductConcreteEntities(
        array $productConcreteData,
        array $productAbstractLocalizedEntities
    ): array {
        $productConcretesByProductAbstractId = [];
        foreach ($productConcreteData as $productConcrete) {
            $productConcretesByProductAbstractId[$productConcrete['fk_product_abstract']][] = $productConcrete;
        }

        foreach ($productAbstractLocalizedEntities as $key => $productAbstractLocalizedEntity) {
            $productAbstractId = (int)$productAbstractLocalizedEntity['fk_product_abstract'];
            $productAbstractLocalizedEntities[$key]['SpyProductAbstract']['SpyProducts'] = $productConcretesByProductAbstractId[$productAbstractId] ?? [];
        }

        return $productAbstractLocalizedEntities;
    }

    /**
     * @param array<int> $productAbstractIds
     *
     * @return array
     */
    protected function getProductCategoriesByProductAbstractIds(array $productAbstractIds)
    {
        return $this->queryContainer->queryAllProductCategories($productAbstractIds)->find()->getData();
    }

    /**
     * @param array<int> $productAbstractIds
     *
     * @return array<\Orm\Zed\ProductPageSearch\Persistence\SpyProductAbstractPageSearch>
     */
    protected function findProductAbstractPageSearchEntities(array $productAbstractIds)
    {
        return $this->queryContainer->queryProductAbstractSearchPageByIds($productAbstractIds)->find()->getArrayCopy();
    }

    /**
     * @param array<\Orm\Zed\ProductPageSearch\Persistence\SpyProductAbstractPageSearch> $productAbstractPageSearchEntities
     *
     * @return array
     */
    protected function mapProductAbstractPageSearchEntities(array $productAbstractPageSearchEntities)
    {
        $mappedProductAbstractPageSearchEntities = [];
        foreach ($productAbstractPageSearchEntities as $entity) {
            $mappedProductAbstractPageSearchEntities[$entity->getFkProductAbstract()][$entity->getStore()][$entity->getLocale()] = $entity;
        }

        return $mappedProductAbstractPageSearchEntities;
    }

    /**
     * @param array $mappedProductAbstractPageSearchEntities
     * @param array $pairs
     *
     * @return array
     */
    protected function pairRemainingProductAbstractPageSearchEntities(array $mappedProductAbstractPageSearchEntities, array $pairs)
    {
        array_walk_recursive($mappedProductAbstractPageSearchEntities, function (SpyProductAbstractPageSearch $productAbstractPageSearchEntity) use (&$pairs) {
            $pairs[] = [
                static::PRODUCT_ABSTRACT_LOCALIZED_ENTITY => null,
                static::PRODUCT_ABSTRACT_PAGE_SEARCH_ENTITY => $productAbstractPageSearchEntity,
                static::LOCALE_NAME => $productAbstractPageSearchEntity->getLocale(),
                static::STORE_NAME => $productAbstractPageSearchEntity->getStore(),
            ];
        });

        return $pairs;
    }

    /**
     * @param int $idProductAbstract
     * @param string $localeName
     * @param \Generated\Shared\Transfer\ProductPayloadTransfer $productPayloadTransfer
     * @param array $productAbstractStores
     * @param array $productAbstractLocalizedEntity
     * @param array $mappedProductAbstractPageSearchEntities
     * @param array $pairs
     *
     * @return array
     */
    protected function pairProductAbstractLocalizedEntityWithProductAbstractPageSearchEntityByStoresAndLocale(
        $idProductAbstract,
        $localeName,
        ProductPayloadTransfer $productPayloadTransfer,
        array $productAbstractStores,
        array $productAbstractLocalizedEntity,
        array $mappedProductAbstractPageSearchEntities,
        array $pairs
    ) {
        $localesByIdStoreMap = $this->getLocalesByIdStoreMap();

        foreach ($productAbstractStores as $productAbstractStore) {
            $idStore = $productAbstractStore['fk_store'];
            $storeName = $productAbstractStore['SpyStore']['name'];

            if (!in_array($localeName, $localesByIdStoreMap[$idStore])) {
                continue;
            }

            $productAbstractLocalizedEntity[SharedProductPageSearchConfig::PRODUCT_ABSTRACT_PAGE_LOAD_DATA] = $productPayloadTransfer;

            $searchEntity = $mappedProductAbstractPageSearchEntities[$idProductAbstract][$storeName][$localeName] ??
                new SpyProductAbstractPageSearch();

            unset($mappedProductAbstractPageSearchEntities[$idProductAbstract][$storeName][$localeName]);

            $pairs[] = [
                static::PRODUCT_ABSTRACT_LOCALIZED_ENTITY => $productAbstractLocalizedEntity,
                static::PRODUCT_ABSTRACT_PAGE_SEARCH_ENTITY => $searchEntity,
                static::LOCALE_NAME => $localeName,
                static::STORE_NAME => $storeName,
            ];
        }

        return [$pairs, $mappedProductAbstractPageSearchEntities];
    }

    /**
     * @param array $productAbstractLocalizedEntities
     * @param array<int> $productAbstractIds
     *
     * @return array
     */
    protected function hydrateProductAbstractLocalizedEntitiesWithProductAbstractAddToCartSku(
        array $productAbstractLocalizedEntities,
        array $productAbstractIds
    ): array {
        $productAbstractStoreIds = [];
        foreach ($productAbstractLocalizedEntities as $productAbstractLocalizedEntity) {
            $productAbstractId = (int)$productAbstractLocalizedEntity['fk_product_abstract'];
            foreach ($productAbstractLocalizedEntity['SpyProductAbstract']['SpyProductAbstractStores'] as $productAbstractStoreData) {
                $storeId = (int)$productAbstractStoreData['SpyStore']['id_store'];
                $productAbstractStoreIds[$productAbstractId][] = $storeId;
            }
        }

        $productConcreteSkuMapByIdProductAbstract = $this->addToCartSkuReader->getProductAbstractAddToCartSkus($productAbstractIds, $productAbstractStoreIds);

        foreach ($productAbstractLocalizedEntities as &$productAbstractLocalizedEntity) {
            $productAbstractId = (int)$productAbstractLocalizedEntity['fk_product_abstract'];
            $productAbstractLocalizedEntity[ProductPageSearchTransfer::ADD_TO_CART_SKU] = $productConcreteSkuMapByIdProductAbstract[$productAbstractId] ?? null;
        }

        return $productAbstractLocalizedEntities;
    }

    /**
     * @param array $pairedEntities
     * @param bool $isRefresh
     *
     * @return array
     */
    protected function mapPairedEntitiesToProductPageSearchTransfers(
        array $pairedEntities,
        bool $isRefresh
    ): array {
        $productAbstractPageSearchTransfers = [];

        foreach ($pairedEntities as $pairedEntity) {
            /** @var array|null $productAbstractLocalizedEntity */
            $productAbstractLocalizedEntity = $pairedEntity[static::PRODUCT_ABSTRACT_LOCALIZED_ENTITY] ?? null;
            /** @var \Orm\Zed\ProductPageSearch\Persistence\SpyProductAbstractPageSearch $productAbstractPageSearchEntity */
            $productAbstractPageSearchEntity = $pairedEntity[static::PRODUCT_ABSTRACT_PAGE_SEARCH_ENTITY];

            if (!$productAbstractLocalizedEntity) {
                continue;
            }

            $productAbstractPageSearchTransfers[] = $this->getProductPageSearchTransfer(
                $productAbstractLocalizedEntity,
                $productAbstractPageSearchEntity,
                $isRefresh,
            );
        }

        return $productAbstractPageSearchTransfers;
    }

    /**
     * @param array<\Generated\Shared\Transfer\ProductPageSearchTransfer> $productPageSearchTransfers
     *
     * @return array<\Generated\Shared\Transfer\ProductPageSearchTransfer>
     */
    protected function executeProductPageSearchCollectionFilterPlugins(array $productPageSearchTransfers): array
    {
        foreach ($this->productPageSearchCollectionFilterPlugins as $productPageSearchCollectionFilterPlugin) {
            $productPageSearchTransfers = $productPageSearchCollectionFilterPlugin->filter($productPageSearchTransfers);
        }

        return $productPageSearchTransfers;
    }

    /**
     * @param array<\Generated\Shared\Transfer\ProductPageSearchTransfer> $productPageSearchTransfers
     *
     * @return array<string, array<int, list<\Generated\Shared\Transfer\ProductPageSearchTransfer>>>

     */
    protected function getProductPageSearchTransfersIndexedByLocaleAndIdProductAbstract(array $productPageSearchTransfers): array
    {
        $productPageSearchTransfersIndexedByLocaleAndIdProductAbstract = [];
        foreach ($productPageSearchTransfers as $productPageSearchTransfer) {
            $idProductAbstract = $productPageSearchTransfer->getIdProductAbstractOrFail();
            $locale = $productPageSearchTransfer->getLocaleOrFail();
            $productPageSearchTransfersIndexedByLocaleAndIdProductAbstract[$locale][$idProductAbstract][] = $productPageSearchTransfer;
        }

        return $productPageSearchTransfersIndexedByLocaleAndIdProductAbstract;
    }

    /**
     * @param array<string, array<int, list<\Generated\Shared\Transfer\ProductPageSearchTransfer>>> $productPageSearchTransfersIndexedByLocaleAndIdProductAbstract

     * @param int $idProductAbstract
     * @param string $locale
     * @param string $storeName
     *
     * @return \Generated\Shared\Transfer\ProductPageSearchTransfer|null
     */
    protected function findProductPageSearchTransferFromIndexedList(
        array $productPageSearchTransfersIndexedByLocaleAndIdProductAbstract,
        int $idProductAbstract,
        string $locale,
        string $storeName
    ): ?ProductPageSearchTransfer {
        if (!isset($productPageSearchTransfersIndexedByLocaleAndIdProductAbstract[$locale][$idProductAbstract])) {
            return null;
        }

        $productPageSearchTransfers = $productPageSearchTransfersIndexedByLocaleAndIdProductAbstract[$locale][$idProductAbstract];
        foreach ($productPageSearchTransfers as $productPageSearchTransfer) {
            if ($productPageSearchTransfer->getStore() === $storeName) {
                return $productPageSearchTransfer;
            }
        }

        return $productPageSearchTransfers[0] ?? null;
    }

    /**
     * @return array<int, array<string>>
     */
    protected function getLocalesByIdStoreMap(): array
    {
        if (static::$localesByIdStoreMap === null) {

            static::$localesByIdStoreMap = [];

            foreach ($this->storeFacade->getAllStores() as $storeTransfer) {
                static::$localesByIdStoreMap[(int)$storeTransfer->getIdStore()] = $storeTransfer->getAvailableLocaleIsoCodes();
            }
        }

        return static::$localesByIdStoreMap;
    }
}

spryker / spryker-core

pairRemainingProductAbstractPageSearchEntities() A last analyzed 2025-09-26 11:00 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

pairRemainingProductAbstractPageSearchEntities() A
last analyzed 2025-09-26 11:00 UTC
