Alpixel\Bundle\CronBundle\Command\CronStatusCommand

Complexity

Total Complexity

12

Size/Duplication

Total Lines	68
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	6	1
C	execute()	0	58	11

<?php

namespace Alpixel\Bundle\CronBundle\Command;

use Alpixel\Bundle\CronBundle\Entity\CronJob;
use Alpixel\Bundle\CronBundle\Entity\CronJobResult;
use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

class CronStatusCommand extends ContainerAwareCommand
{
    protected function configure()
    {
        $this->setName('cron:status')
             ->setDescription('Displays the current status of cron jobs')
             ->addArgument('job', InputArgument::OPTIONAL, 'Show information for only this job');
    }

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