Task\TaskBundle\Entity\TaskExecutionRepository

Complexity

Total Complexity

5

Size/Duplication

Total Lines	40
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	2
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	findByStartTime()	0	11	1
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 Task\Execution\TaskExecutionInterface;
use Task\Storage\TaskExecutionRepositoryInterface;
use Task\TaskInterface;
use Task\TaskStatus;

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

    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)
    {
        $this->_em->flush();
    }

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