Task\TaskBundle\Entity\TaskExecutionRepository

Complexity

Total Complexity

6

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	3
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	findByStartTime()	0	15	2
A	findScheduled()	0	14	2
A	save()	0	4	1
A	add()	0	5	1

<?php

namespace Task\TaskBundle\Entity;

use Doctrine\ORM\EntityRepository;
use Doctrine\ORM\NoResultException;
use Task\Execution\TaskExecutionInterface;
use Task\TaskInterface;
use Task\TaskStatus;

class TaskExecutionRepository extends EntityRepository
{
    public function findByStartTime(TaskInterface $task, \DateTime $scheduleTime)
    {
        try {
            return $this->createQueryBuilder('e')
                ->innerJoin('e.task', 't')
                ->where('t.uuid = :uuid')
                ->andWhere('e.scheduleTime = :scheduleTime')
                ->setParameter('uuid', $task->getUuid())
                ->setParameter('scheduleTime', $scheduleTime)
                ->getQuery()
                ->getSingleResult();
        } catch (NoResultException $e) {
            return;
        }
    }

    public function findScheduled(\DateTime $dateTime = null)
    {
        if ($dateTime === null) {
            $dateTime = new \DateTime();
        }

        return $this->createQueryBuilder('e')
            ->innerJoin('e.task', 't')
            ->where('e.status = :status AND e.scheduleTime < :dateTime')
            ->setParameter('status', TaskStatus::PLANNED)
            ->setParameter('dateTime', $dateTime)
            ->getQuery()
            ->getResult();
    }

    public function save(TaskExecutionInterface $execution)

The parameter $execution is not used and could be removed.

    {
        $this->_em->flush();
    }

    public function add(TaskExecutionInterface $execution)
    {
        $this->_em->persist($execution);
        $this->_em->flush();
    }
}