BulkZeroLegacyStockItem.php 1.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263
  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\InventoryCatalog\Model\ResourceModel;
  8. use Magento\CatalogInventory\Api\Data\StockItemInterface;
  9. use Magento\Framework\App\ResourceConnection;
  10. use Magento\InventoryCatalogApi\Model\GetProductIdsBySkusInterface;
  11. /**
  12. * Set quantity=0 to legacy cataloginventory_stock_item table for a set of skus via plain MySql query
  13. */
  14. class BulkZeroLegacyStockItem
  15. {
  16. /**
  17. * @var ResourceConnection
  18. */
  19. private $resourceConnection;
  20. /**
  21. * @var GetProductIdsBySkusInterface
  22. */
  23. private $getProductIdsBySkus;
  24. /**
  25. * @param ResourceConnection $resourceConnection
  26. * @param GetProductIdsBySkusInterface $getProductIdsBySkus
  27. */
  28. public function __construct(
  29. ResourceConnection $resourceConnection,
  30. GetProductIdsBySkusInterface $getProductIdsBySkus
  31. ) {
  32. $this->resourceConnection = $resourceConnection;
  33. $this->getProductIdsBySkus = $getProductIdsBySkus;
  34. }
  35. /**
  36. * @param array $skus
  37. * @return void
  38. * @throws \Magento\Framework\Exception\NoSuchEntityException
  39. */
  40. public function execute(array $skus)
  41. {
  42. $productIds = array_values($this->getProductIdsBySkus->execute($skus));
  43. $connection = $this->resourceConnection->getConnection();
  44. $connection->update(
  45. $this->resourceConnection->getTableName('cataloginventory_stock_item'),
  46. [
  47. StockItemInterface::QTY => 0,
  48. StockItemInterface::IS_IN_STOCK => 0,
  49. ],
  50. [
  51. StockItemInterface::PRODUCT_ID . ' IN (?)' => $productIds,
  52. 'website_id = ?' => 0,
  53. ]
  54. );
  55. }
  56. }