AppBundle\Command\RunCronsCommand::execute()

Complexity

Conditions	4
Paths	4

Size

Total Lines	34
Code Lines	21

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	20

Importance

Changes

0

<?php
    protected function execute(InputInterface $input, OutputInterface $output)
    {

        $doctrine = $this->getContainer()->get('doctrine');

        $crons = $doctrine->getManager()->getRepository('AppBundle:Action')->findBy(['type'=>'cron']);

        /** @var Action $cronAction */
        foreach ($crons as $cronAction) {
            $args = json_decode($cronAction->getArguments(), true);

            if (isset($args['disabled'])) {
                continue;
            }

            if (time() - $args['last'] >= $args['every']) {
                $output->writeln('Running '.$cronAction->getExecutor().' for "'.
                    $cronAction->getDevice()->getName().'" device');
                $this->
                    getContainer()->
                    get('actions')->
                    executeReal(
                        $cronAction,
                        'cron',
                        ['container'=>$this->getContainer()]
                    );
                $args['last'] = time();
                $cronAction->setArguments(json_encode($args));
                $doctrine->getManager()->persist($cronAction);
            }
        }

        $doctrine->getManager()->flush();
    }
}