RevertQuoteInventoryObserver.php 2.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576
  1. <?php
  2. /**
  3. * Copyright © Magento, Inc. All rights reserved.
  4. * See COPYING.txt for license details.
  5. */
  6. namespace Magento\CatalogInventory\Observer;
  7. use Magento\Framework\Event\ObserverInterface;
  8. use Magento\CatalogInventory\Api\StockManagementInterface;
  9. use Magento\Framework\Event\Observer as EventObserver;
  10. /**
  11. * Catalog inventory module observer
  12. */
  13. class RevertQuoteInventoryObserver implements ObserverInterface
  14. {
  15. /**
  16. * @var ProductQty
  17. */
  18. protected $productQty;
  19. /**
  20. * @var StockManagementInterface
  21. */
  22. protected $stockManagement;
  23. /**
  24. * @var \Magento\CatalogInventory\Model\Indexer\Stock\Processor
  25. */
  26. protected $stockIndexerProcessor;
  27. /**
  28. * @var \Magento\Catalog\Model\Indexer\Product\Price\Processor
  29. */
  30. protected $priceIndexer;
  31. /**
  32. * RevertQuoteInventory constructor.
  33. * @param ProductQty $productQty
  34. * @param StockManagementInterface $stockManagement
  35. * @param \Magento\CatalogInventory\Model\Indexer\Stock\Processor $stockIndexerProcessor
  36. * @param \Magento\Catalog\Model\Indexer\Product\Price\Processor $priceIndexer
  37. */
  38. public function __construct(
  39. ProductQty $productQty,
  40. StockManagementInterface $stockManagement,
  41. \Magento\CatalogInventory\Model\Indexer\Stock\Processor $stockIndexerProcessor,
  42. \Magento\Catalog\Model\Indexer\Product\Price\Processor $priceIndexer
  43. ) {
  44. $this->productQty = $productQty;
  45. $this->stockManagement = $stockManagement;
  46. $this->stockIndexerProcessor = $stockIndexerProcessor;
  47. $this->priceIndexer = $priceIndexer;
  48. }
  49. /**
  50. * Revert quote items inventory data (cover not success order place case)
  51. *
  52. * @param EventObserver $observer
  53. * @return void
  54. */
  55. public function execute(EventObserver $observer)
  56. {
  57. $quote = $observer->getEvent()->getQuote();
  58. $items = $this->productQty->getProductQty($quote->getAllItems());
  59. $revertedItems = $this->stockManagement->revertProductsSale($items, $quote->getStore()->getWebsiteId());
  60. $productIds = array_keys($revertedItems);
  61. if (!empty($productIds)) {
  62. $this->stockIndexerProcessor->reindexList($productIds);
  63. $this->priceIndexer->reindexList($productIds);
  64. }
  65. // Clear flag, so if order placement retried again with success - it will be processed
  66. $quote->setInventoryProcessed(false);
  67. }
  68. }