SprykerEco\Zed\FirstData\Business\CommandExecutor\CaptureCommandExecutor

Complexity

Total Complexity

6

Size/Duplication

Total Lines	88
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	10	1
A	executeOmsCommand()	0	28	3
A	executeTransactionUpdatePaymentFirstDataItems()	0	6	2

<?php

/**
 * MIT License
 * For full license information, please view the LICENSE file that was distributed with this source code.
 */

namespace SprykerEco\Zed\FirstData\Business\CommandExecutor;

use Generated\Shared\Transfer\FirstDataApiRequestTransfer;

The type Generated\Shared\Transfer\FirstDataApiRequestTransfer was not found. Maybe you did not declare it correctly or list all dependencies?

use Generated\Shared\Transfer\FirstDataOmsCommandRequestTransfer;

The type Generated\Shared\Transfer\FirstDataOmsCommandRequestTransfer was not found. Maybe you did not declare it correctly or list all dependencies?

use Spryker\Zed\Kernel\Persistence\EntityManager\TransactionTrait;
use SprykerEco\Zed\FirstData\Business\Api\ApiClient\FirstDataApiClientInterface;
use SprykerEco\Zed\FirstData\FirstDataConfig;
use SprykerEco\Zed\FirstData\Persistence\FirstDataEntityManagerInterface;
use SprykerEco\Zed\FirstData\Persistence\FirstDataRepositoryInterface;

class CaptureCommandExecutor implements FirstDataCommandExecutorInterface
{
    use TransactionTrait;

    /**
     * @var \SprykerEco\Zed\FirstData\Persistence\FirstDataEntityManagerInterface
     */
    protected $entityManager;

    /**
     * @var \SprykerEco\Zed\FirstData\Persistence\FirstDataRepositoryInterface
     */
    protected $firstDataRepository;

    /**
     * @var \SprykerEco\Zed\FirstData\FirstDataConfig
     */
    protected $firstDataConfig;

    /**
     * @var \SprykerEco\Zed\FirstData\Business\Api\ApiClient\FirstDataApiClientInterface
     */
    protected $firstDataApiClient;

    /**
     * @param \SprykerEco\Zed\FirstData\Business\Api\ApiClient\FirstDataApiClientInterface $firstDataApiClient
     * @param \SprykerEco\Zed\FirstData\Persistence\FirstDataEntityManagerInterface $entityManager
     * @param \SprykerEco\Zed\FirstData\Persistence\FirstDataRepositoryInterface $firstDataRepository
     * @param \SprykerEco\Zed\FirstData\FirstDataConfig $firstDataConfig
     */
    public function __construct(
        FirstDataApiClientInterface $firstDataApiClient,
        FirstDataEntityManagerInterface $entityManager,
        FirstDataRepositoryInterface $firstDataRepository,
        FirstDataConfig $firstDataConfig
    ) {
        $this->firstDataApiClient = $firstDataApiClient;
        $this->entityManager = $entityManager;
        $this->firstDataRepository = $firstDataRepository;
        $this->firstDataConfig = $firstDataConfig;
    }

    /**
     * @param \Generated\Shared\Transfer\FirstDataOmsCommandRequestTransfer $firstDataOmsCommandRequestTransfer
     *
     * @return void
     */
    public function executeOmsCommand(FirstDataOmsCommandRequestTransfer $firstDataOmsCommandRequestTransfer): void
    {
        $paymentFirstDataTransfer = $this->firstDataRepository
            ->findPaymentFirstDataByIdSalesOrder($firstDataOmsCommandRequestTransfer->getOrderOrFail()->getIdSalesOrderOrFail());

        if (!$paymentFirstDataTransfer) {
            return;
        }

        $firstDataApiRequestTransfer = (new FirstDataApiRequestTransfer())
            ->setRequestType(FirstDataConfig::FIRST_DATA_CAPTURE_REQUEST_TYPE)
            ->setOrder($firstDataOmsCommandRequestTransfer->getOrder())
            ->setOrderItemIds($firstDataOmsCommandRequestTransfer->getSalesOrderItemIds())
            ->setTransactionId($paymentFirstDataTransfer->getOid());

        $firstDataApiResponseTransfer = $this->firstDataApiClient->performApiRequest($firstDataApiRequestTransfer);

        if (!$firstDataApiResponseTransfer->getIsSuccess()) {
            return;
        }

        $paymentFirstDataItemTransfers = $this->firstDataRepository
            ->getPaymentFirstDataItemCollection(
                $paymentFirstDataTransfer,
                $firstDataOmsCommandRequestTransfer->getSalesOrderItemIds()
            );

        $this->executeTransactionUpdatePaymentFirstDataItems($paymentFirstDataItemTransfers);
    }

    /**
     * @param \Generated\Shared\Transfer\PaymentFirstDataItemTransfer[] $paymentFirstDataItemTransfers
     *
     * @return void
     */
    protected function executeTransactionUpdatePaymentFirstDataItems(array $paymentFirstDataItemTransfers): void
    {
        $this->getTransactionHandler()->handleTransaction(function () use ($paymentFirstDataItemTransfers): void {
            foreach ($paymentFirstDataItemTransfers as $paymentFirstDataItemTransfer) {
                $paymentFirstDataItemTransfer->setStatus($this->firstDataConfig->getOmsStatusCaptured());
                $this->entityManager->savePaymentFirstDataItem($paymentFirstDataItemTransfer);
            }
        });
    }
}