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

Complexity

Conditions	7
Paths	29

Size

Total Lines	63
Code Lines	36

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
        ], null, $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'])) {
                    $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'])) {
                        $label->markAsError($labelRes['error']);
                    } else {
                        $labelFileFactory = $this->getContainer()->get('loevgaard_pakkelabels.label_file_factory');
                        $labelFile = $labelFileFactory->create($label);
                        $labelFile->fwrite(base64_decode($labelRes['base64']));
                        $label->markAsSuccess();

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

            $manager->flush();
        }
    }
}