GetAssignedStockIds.php 1.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354
  1. <?php
  2. /**
  3. * Copyright © Magento, Inc. All rights reserved.
  4. * See COPYING.txt for license details.
  5. */
  6. declare(strict_types=1);
  7. namespace Magento\InventoryIndexer\Indexer\Source;
  8. use Magento\Framework\App\ResourceConnection;
  9. use Magento\Inventory\Model\ResourceModel\StockSourceLink as StockSourceLinkResourceModel;
  10. use Magento\Inventory\Model\StockSourceLink;
  11. /**
  12. * Returns assigned Stock ids by given Source ids
  13. */
  14. class GetAssignedStockIds
  15. {
  16. /**
  17. * @var ResourceConnection
  18. */
  19. private $resourceConnection;
  20. /**
  21. * @param ResourceConnection $resourceConnection
  22. */
  23. public function __construct(
  24. ResourceConnection $resourceConnection
  25. ) {
  26. $this->resourceConnection = $resourceConnection;
  27. }
  28. /**
  29. * @param string[] $sourceCodes
  30. * @return int[]
  31. */
  32. public function execute(array $sourceCodes): array
  33. {
  34. $connection = $this->resourceConnection->getConnection();
  35. $sourceStockLinkTable = $this->resourceConnection->getTableName(
  36. StockSourceLinkResourceModel::TABLE_NAME_STOCK_SOURCE_LINK
  37. );
  38. $select = $connection
  39. ->select()
  40. ->from($sourceStockLinkTable, StockSourceLink::STOCK_ID)
  41. ->where(StockSourceLink::SOURCE_CODE . ' IN (?)', $sourceCodes)
  42. ->group(StockSourceLink::STOCK_ID);
  43. $stockIds = $connection->fetchCol($select);
  44. $stockIds = array_map('intval', $stockIds);
  45. return $stockIds;
  46. }
  47. }