BitBag\SyliusQuadPayPlugin\Command\UpdatePaymentStateCommand

Complexity

Total Complexity

6

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	10	1
A	configure()	0	6	1
A	execute()	0	33	4

<?php

/*
 * This file has been created by developers from BitBag.
 * Feel free to contact us once you face any issues or want to start
 * another great project.
 * You can find more information about us on https://bitbag.shop and write us
 * an email on mikolaj.krol@bitbag.pl.
 */

declare(strict_types=1);

namespace BitBag\SyliusQuadPayPlugin\Command;

use BitBag\SyliusQuadPayPlugin\QuadPayGatewayFactory;
use BitBag\SyliusQuadPayPlugin\Repository\PaymentRepositoryInterface;
use BitBag\SyliusQuadPayPlugin\Resolver\PaymentStateResolverInterface;
use Psr\Log\LoggerInterface;
use Sylius\Component\Core\Model\PaymentInterface;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

final class UpdatePaymentStateCommand extends Command
{
    /** @var PaymentRepositoryInterface */
    private $paymentRepository;

    /** @var PaymentStateResolverInterface */
    private $paymentStateResolver;

    /** @var LoggerInterface */
    private $logger;

    public function __construct(
        PaymentRepositoryInterface $paymentRepository,
        PaymentStateResolverInterface $paymentStateResolver,
        LoggerInterface $logger
    ) {
        parent::__construct();

        $this->paymentRepository = $paymentRepository;
        $this->paymentStateResolver = $paymentStateResolver;
        $this->logger = $logger;
    }

    protected function configure(): void
    {
        $this
            ->setName('bitbag:quadpay:update-payment-state')
            ->setDescription('Updates the payments state.')
            ->setHelp('This command allows you to update the payments state for QuadPay gateway.')
        ;
    }

    protected function execute(InputInterface $input, OutputInterface $output): void
    {
        /** @var PaymentInterface[] $payments */
        $payments = $this->paymentRepository->findAllActiveByGatewayFactoryName(QuadPayGatewayFactory::FACTORY_NAME);

        $updatesCount = 0;

        foreach ($payments as $payment) {
            $oldState = $payment->getState();

            $orderNumber = $payment->getOrder()->getNumber();

            try {
                $this->paymentStateResolver->resolve($payment);
            } catch (\Exception $exception) {
                $message = sprintf('An error occurred for the order #%s: %s', $orderNumber, $exception->getMessage());

                $this->logger->error($message);

                $output->writeln($message);

                continue;
            }

            if ($oldState !== $payment->getState()) {
                ++$updatesCount;

                $output->writeln(sprintf('Update payment state for order #%s: %s -> %s', $orderNumber, $oldState, $payment->getState()));
            }
        }

        $output->writeln('');
        $output->writeln(sprintf('Updated: %d', $updatesCount));
    }
}