GetProductIdsByStockIds.php

Go to the documentation of this file.

<?php
declare(strict_types=1);

namespace Magento\InventoryCache\Model\ResourceModel;

use Magento\Framework\App\ResourceConnection;
use Magento\InventoryCatalogApi\Api\DefaultStockProviderInterface;
use Magento\InventoryIndexer\Indexer\IndexStructure;
use Magento\InventoryIndexer\Model\StockIndexTableNameResolverInterface;

class GetProductIdsByStockIds
{
    private $resource;

    private $stockIndexTableNameResolver;

    private $defaultStockProvider;

    private $productTableName;

    public function __construct(
        ResourceConnection $resource,
        StockIndexTableNameResolverInterface $stockIndexTableNameResolver,
        DefaultStockProviderInterface $defaultStockProvider,
        string $productTableName
    ) {
        $this->resource = $resource;
        $this->defaultStockProvider = $defaultStockProvider;
        $this->stockIndexTableNameResolver = $stockIndexTableNameResolver;
        $this->productTableName = $productTableName;
    }

    public function execute(array $stockIds): array
    {
        $productIds = [[]];
        foreach ($stockIds as $stockId) {
            if ($this->defaultStockProvider->getId() === (int)$stockId) {
                continue;
            }
            $stockIndexTableName = $this->stockIndexTableNameResolver->execute($stockId);
            $connection = $this->resource->getConnection();

            if ($connection->isTableExists($stockIndexTableName)) {
                $sql = $connection->select()
                    ->from(['stock_index' => $stockIndexTableName], [])
                    ->join(
                        ['product' => $this->resource->getTableName($this->productTableName)],
                        'product.sku = stock_index.' . IndexStructure::SKU,
                        ['product.entity_id']
                    );
                $productIds[] = $connection->fetchCol($sql);
            }
        }
        $productIds = array_merge(...$productIds);

        return array_unique($productIds);
    }
}