Loevgaard\PakkelabelsBundle\Command\GenerateLabelsCommand

Complexity

Total Complexity

8

Size/Duplication

Total Lines	81
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	10

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	7	1
C	execute()	0	68	7

<?php

namespace Loevgaard\PakkelabelsBundle\Command;

use Assert\Assert;
use Doctrine\Common\Persistence\ObjectManager;
use Loevgaard\PakkelabelsBundle\Entity\Label;
use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
use Symfony\Component\Console\Command\LockableTrait;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;

class GenerateLabelsCommand extends ContainerAwareCommand
{
    use LockableTrait;

    protected function configure()
    {
        $this->setName('loevgaard:pakkelabels:generate-labels')
            ->setDescription('Generates labels')
            ->addOption('limit', 'l', InputOption::VALUE_REQUIRED, 'The number of labels to normalize', 20)
        ;
    }

    protected function execute(InputInterface $input, OutputInterface $output)
    {
        if (!$this->lock($this->getName())) {
            $output->writeln('The command is already running in another process.');

            return 0;
        }

        $limit = (int) $input->getOption('limit');
        Assert::that($limit)->integer()->greaterThan(0);

        /** @var ObjectManager $manager */
        $manager = $this->getContainer()->get('doctrine')->getManager();

        $pakkelabels = $this->getContainer()->get('loevgaard_pakkelabels.client');

        /** @var Label[] $labels */
        $labels = $manager->getRepository('LoevgaardPakkelabelsBundle:Label')->findBy([
            'status' => Label::STATUS_PENDING_CREATION,
        ], [
            'id' => 'asc',
        ], $limit);

        if ($output->isVerbose()) {
            $output->writeln('Label count: '.count($labels));
        }

        foreach ($labels as $label) {
            $output->writeln('Creating label id: '.$label->getId().' with order id: '.$label->getOrderId(), OutputInterface::VERBOSITY_VERBOSE);

            try {
                $res = $pakkelabels->doRequest('post', '/shipments', [
                    'json' => $label->arrayForApi(),
                ]);

                if (isset($res['error'])) {
                    $output->writeln($res['error'], OutputInterface::VERBOSITY_VERBOSE);
                    $label->markAsError($res['error']);
                } else {
                    $label->setExternalId($res['id']);

                    // download label
                    $labelRes = $pakkelabels->doRequest('get', '/shipments/'.$res['id'].'/labels', [
                        'query' => [
                            'label_format' => 'png',
                        ],
                    ]);

                    if (isset($labelRes['error'])) {
                        $output->writeln($labelRes['error'], OutputInterface::VERBOSITY_VERBOSE);
                        $label->markAsError($labelRes['error']);
                    } else {
                        $labelFileFactory = $this->getContainer()->get('loevgaard_pakkelabels.label_file_factory');
                        $labelFile = $labelFileFactory->create($label);
                        $labelFile->fwrite(base64_decode($labelRes[0]['base64']));
                        $label->markAsSuccess();

                        $output->writeln('Label was created', OutputInterface::VERBOSITY_VERBOSE);
                    }
                }
            } catch (\Exception $e) {
                $output->writeln($e->getMessage(), OutputInterface::VERBOSITY_VERBOSE);
                $label->markAsError('An error occurred during creation of the label. The error was: '.$e->getMessage());
            }

            $manager->flush();
        }
    }
}