Alpixel\Bundle\CronBundle\Entity\Repository\CronJobRepository

Complexity

Total Complexity

3

Size/Duplication

Total Lines	25
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	3

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	getKnownJobs()	0	12	2
A	findDueTasks()	0	9	1

<?php

namespace Alpixel\Bundle\CronBundle\Entity\Repository;

use Doctrine\ORM\EntityRepository;

class CronJobRepository extends EntityRepository
{
    public function getKnownJobs()
    {
        $data = $this->getEntityManager()
                     ->createQuery('SELECT job.command FROM CronBundle:CronJob job')
                     ->getScalarResult();
        $toRet = [];
        foreach ($data as $datum) {
            $toRet[] = $datum['command'];
        }

        return $toRet;
    }

    public function findDueTasks()
    {
        return $this->getEntityManager()
                    ->createQuery('SELECT job FROM CronBundle:CronJob job
                                   WHERE job.nextRun <= :curTime
                                   AND job.enabled = 1')
                    ->setParameter('curTime', new \DateTime())
                    ->getResult();
    }
}