Alpixel\Bundle\CronBundle\Command\CronStatusCommand::execute()

Complexity

Conditions	11
Paths	63

Size

Total Lines	58
Code Lines	44

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $em = $this->getContainer()->get('doctrine.orm.entity_manager');
        $jobRepo = $em->getRepository(CronJob::class);
        
        $output->writeln('Cron job statuses:');

        $cronJobs = [];
        if ($jobName = $input->getArgument('job')) {
            try {
                $cronJobs = [$jobRepo->findOneByCommand($jobName)];
            } catch (\Exception $e) {
                $output->writeln("Couldn't find a job by the name of $jobName");

                return CronJobResult::FAILED;
            }
        } else {
            $cronJobs = $em->getRepository('CronBundle:CronJob')->findAll();
        }

        foreach ($cronJobs as $cronJob) {
            $output->write(' - '.$cronJob->getCommand());
            if (!$cronJob->getEnabled()) {
                $output->write(' (disabled)');
            }
            $output->writeln('');
            $output->writeln('   Description: '.$cronJob->getDescription());
            if (!$cronJob->getEnabled()) {
                $output->writeln('   Not scheduled');
            } else {
                $output->write('   Scheduled for: ');
                $now = new \DateTime();
                if ($cronJob->getNextRun() <= $now) {
                    $output->writeln('Next run');
                } else {
                    $output->writeln(strftime('%c', $cronJob->getNextRun()->getTimestamp()));
                }
            }
            if ($cronJob->getMostRecentRun()) {
                $status = 'Unknown';
                switch ($cronJob->getMostRecentRun()->getResult()) {
                    case CronJobResult::SUCCEEDED:
                        $status = 'Successful';
                        break;
                    case CronJobResult::SKIPPED:
                        $status = 'Skipped';
                        break;
                    case CronJobResult::FAILED:
                        $status = 'Failed';
                        break;
                }
                $output->writeln("   Last run was: $status");
            } else {
                $output->writeln('   This job has not yet been run');
            }
            $output->writeln('');
        }
    }
}