Details.php

Go to the documentation of this file.

<?php
namespace Magento\AsynchronousOperations\Model\Operation;

use Magento\Framework\Bulk\OperationInterface;
use Magento\Framework\Bulk\BulkStatusInterface;

class Details
{
    private $operationCache = [];

    private $bulkStatus;

    private $bulkUuid;

    private $statusMap = [
        OperationInterface::STATUS_TYPE_COMPLETE             => 'operations_successful',
        OperationInterface::STATUS_TYPE_RETRIABLY_FAILED     => 'failed_retriable',
        OperationInterface::STATUS_TYPE_NOT_RETRIABLY_FAILED => 'failed_not_retriable',
        OperationInterface::STATUS_TYPE_OPEN                 => 'open',
        OperationInterface::STATUS_TYPE_REJECTED             => 'rejected',
    ];

    public function __construct(
        BulkStatusInterface $bulkStatus,
        $bulkUuid = null
    ) {
        $this->bulkStatus = $bulkStatus;
        $this->bulkUuid = $bulkUuid;
    }

    public function getDetails($bulkUuid)
    {
        $details = [
            'operations_total'      => 0,
            'operations_successful' => 0,
            'operations_failed'     => 0,
            'failed_retriable'      => 0,
            'failed_not_retriable'  => 0,
            'rejected'              => 0,
        ];

        if (array_key_exists($bulkUuid, $this->operationCache)) {
            return $this->operationCache[$bulkUuid];
        }

        foreach ($this->statusMap as $statusCode => $readableKey) {
            $details[$readableKey] = $this->bulkStatus->getOperationsCountByBulkIdAndStatus(
                $bulkUuid,
                $statusCode
            );
        }

        $details['operations_total'] = array_sum($details);
        $details['operations_failed'] = $details['failed_retriable'] + $details['failed_not_retriable'];
        $this->operationCache[$bulkUuid] = $details;

        return $details;
    }

    public function getOperationsTotal()
    {
        $this->getDetails($this->bulkUuid);

        return $this->operationCache[$this->bulkUuid]['operations_total'];
    }

    public function getOpen()
    {
        $this->getDetails($this->bulkUuid);
        $statusKey = $this->statusMap[OperationInterface::STATUS_TYPE_OPEN];

        return $this->operationCache[$this->bulkUuid][$statusKey];
    }

    public function getOperationsSuccessful()
    {
        $this->getDetails($this->bulkUuid);
        $statusKey = $this->statusMap[OperationInterface::STATUS_TYPE_COMPLETE];

        return $this->operationCache[$this->bulkUuid][$statusKey];
    }

    public function getTotalFailed()
    {
        $this->getDetails($this->bulkUuid);

        return $this->operationCache[$this->bulkUuid]['operations_failed'];
    }

    public function getFailedNotRetriable()
    {
        $statusKey = $this->statusMap[OperationInterface::STATUS_TYPE_NOT_RETRIABLY_FAILED];

        return $this->operationCache[$this->bulkUuid][$statusKey];
    }

    public function getFailedRetriable()
    {
        $this->getDetails($this->bulkUuid);
        $statusKey = $this->statusMap[OperationInterface::STATUS_TYPE_RETRIABLY_FAILED];

        return $this->operationCache[$this->bulkUuid][$statusKey];
    }

    public function getRejected()
    {
        $this->getDetails($this->bulkUuid);
        $statusKey = $this->statusMap[OperationInterface::STATUS_TYPE_REJECTED];

        return $this->operationCache[$this->bulkUuid][$statusKey];
    }
}