Loevgaard\PakkelabelsBundle\Command\GenerateLabelsCommand::execute()

Complexity

Conditions	7
Paths	33

Size

Total Lines	68
Code Lines	40

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    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();
        }
    }
}