BulkSourceAssign.php 2.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768
  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;
  8. use Magento\Framework\Validation\ValidationException;
  9. use Magento\InventoryCatalogApi\Api\BulkSourceAssignInterface;
  10. use Magento\InventoryCatalogApi\Model\BulkSourceAssignValidatorInterface;
  11. use Magento\InventoryCatalog\Model\ResourceModel\BulkSourceAssign as BulkSourceAssignResource;
  12. use Magento\InventoryIndexer\Indexer\SourceItem\SourceItemIndexer;
  13. /**
  14. * @inheritdoc
  15. */
  16. class BulkSourceAssign implements BulkSourceAssignInterface
  17. {
  18. /**
  19. * @var BulkSourceAssignValidatorInterface
  20. */
  21. private $assignValidator;
  22. /**
  23. * @var BulkSourceAssignResource
  24. */
  25. private $bulkSourceAssign;
  26. /**
  27. * @var SourceItemIndexer
  28. */
  29. private $sourceItemIndexer;
  30. /**
  31. * MassProductSourceAssign constructor.
  32. * @param BulkSourceAssignValidatorInterface $assignValidator
  33. * @param BulkSourceAssignResource $bulkSourceAssign
  34. * @param SourceItemIndexer $sourceItemIndexer
  35. * @SuppressWarnings(PHPMD.LongVariable)
  36. */
  37. public function __construct(
  38. BulkSourceAssignValidatorInterface $assignValidator,
  39. BulkSourceAssignResource $bulkSourceAssign,
  40. SourceItemIndexer $sourceItemIndexer
  41. ) {
  42. $this->assignValidator = $assignValidator;
  43. $this->bulkSourceAssign = $bulkSourceAssign;
  44. $this->sourceItemIndexer = $sourceItemIndexer;
  45. }
  46. /**
  47. * @inheritdoc
  48. */
  49. public function execute(array $skus, array $sourceCodes): int
  50. {
  51. $validationResult = $this->assignValidator->validate($skus, $sourceCodes);
  52. if (!$validationResult->isValid()) {
  53. throw new ValidationException(__('Validation Failed'), null, 0, $validationResult);
  54. }
  55. $res = $this->bulkSourceAssign->execute($skus, $sourceCodes);
  56. $this->sourceItemIndexer->executeList($sourceCodes);
  57. return $res;
  58. }
  59. }