operationCollectionFactory = $operationCollection; $this->bulkStatus = $bulkStatus; $this->bulkDetailedFactory = $bulkDetailedFactory; $this->bulkShortFactory = $bulkShortFactory; $this->entityManager = $entityManager; } /** * @inheritDoc */ public function getFailedOperationsByBulkId($bulkUuid, $failureType = null) { return $this->bulkStatus->getFailedOperationsByBulkId($bulkUuid, $failureType); } /** * @inheritDoc */ public function getOperationsCountByBulkIdAndStatus($bulkUuid, $status) { return $this->bulkStatus->getOperationsCountByBulkIdAndStatus($bulkUuid, $status); } /** * @inheritDoc */ public function getBulksByUser($userId) { return $this->bulkStatus->getBulksByUser($userId); } /** * @inheritDoc */ public function getBulkStatus($bulkUuid) { return $this->bulkStatus->getBulkStatus($bulkUuid); } /** * @inheritDoc */ public function getBulkDetailedStatus($bulkUuid) { $bulkSummary = $this->bulkDetailedFactory->create(); /** @var \Magento\AsynchronousOperations\Api\Data\DetailedBulkOperationsStatusInterface $bulk */ $bulk = $this->entityManager->load($bulkSummary, $bulkUuid); if ($bulk->getBulkId() === null) { throw new NoSuchEntityException( __( 'Bulk uuid %bulkUuid not exist', ['bulkUuid' => $bulkUuid] ) ); } $operations = $this->operationCollectionFactory->create()->addFieldToFilter('bulk_uuid', $bulkUuid)->getItems(); $bulk->setOperationsList($operations); return $bulk; } /** * @inheritDoc */ public function getBulkShortStatus($bulkUuid) { $bulkSummary = $this->bulkShortFactory->create(); /** @var \Magento\AsynchronousOperations\Api\Data\BulkOperationsStatusInterface $bulk */ $bulk = $this->entityManager->load($bulkSummary, $bulkUuid); if ($bulk->getBulkId() === null) { throw new NoSuchEntityException( __( 'Bulk uuid %bulkUuid not exist', ['bulkUuid' => $bulkUuid] ) ); } $operations = $this->operationCollectionFactory->create()->addFieldToFilter('bulk_uuid', $bulkUuid)->getItems(); $bulk->setOperationsList($operations); return $bulk; } }