AnimeDb\Bundle\AppBundle\Repository\Task

Complexity

Total Complexity

4

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	4

Test Coverage

Coverage

0%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	getNextTask()	0	17	1
B	getWaitingTime()	0	29	3

<?php
/**
 * AnimeDb package.
 *
 * @author    Peter Gribanov <info@peter-gribanov.ru>
 * @copyright Copyright (c) 2011, Peter Gribanov
 * @license   http://opensource.org/licenses/GPL-3.0 GPL v3
 */
namespace AnimeDb\Bundle\AppBundle\Repository;

use Doctrine\ORM\EntityRepository;
use AnimeDb\Bundle\AppBundle\Entity\Task as TaskEntity;

class Task extends EntityRepository
{
    /**
     * Maximum standby time.
     *
     * Between scans tasks can interpose new task.
     * If no limit standby scheduler can not handle the new task before
     * the arrival of the start time of the next task.
     * For example the scheduler can expect a few days before the execution of the tasks
     * that must be performed every hour.
     *
     * @var int
     */
    const MAX_STANDBY_TIME = 3600;

    /**
     * @return TaskEntity|null
     */
    public function getNextTask()
    {
        return $this->getEntityManager()->createQuery('
            SELECT
                t
            FROM
                AnimeDbAppBundle:Task t
            WHERE
                t.status = :status AND t.next_run <= :time
            ORDER BY
                t.next_run ASC
        ')
            ->setMaxResults(1)
            ->setParameter('status', TaskEntity::STATUS_ENABLED)
            ->setParameter('time', date('Y-m-d H:i:s'))
            ->getOneOrNullResult();
    }

    /**
     * @return int
     */
    public function getWaitingTime()
    {
        // get next task
        $task = $this->getEntityManager()->createQuery('
            SELECT
                t
            FROM
                AnimeDbAppBundle:Task t
            WHERE
                t.status = :status
            ORDER BY
                t.next_run ASC
        ')
            ->setMaxResults(1)
            ->setParameter('status', TaskEntity::STATUS_ENABLED)
            ->getOneOrNullResult();

        // task is exists
        if ($task instanceof TaskEntity) {
            $task_time = $task->getNextRun()->getTimestamp() - time();
            if ($task_time > 0) {
                return min($task_time, self::MAX_STANDBY_TIME);
            } else {
                return 0; // need run now
            }
        }

        return self::MAX_STANDBY_TIME;
    }
}