AppBundle\Command\RunCronsCommand::execute()

Complexity

Conditions	4
Paths	4

Size

Total Lines	36
Code Lines	22

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	6
CRAP Score	9.8312

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