Gtt\Bundle\WorkflowExtensionsBundle\Entity\Repository\ScheduledJobRepository

Complexity

Total Complexity

1

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
B	findScheduledJobToReschedule()	0	32	1

<?php
/**
 * This file is part of the Global Trading Technologies Ltd workflow-extension-bundle package.
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 *
 * (c) fduch <alex.medwedew@gmail.com>
 * @date 01.08.16
 */

namespace Gtt\Bundle\WorkflowExtensionsBundle\Entity\Repository;

use Doctrine\ORM\EntityRepository;
use Gtt\Bundle\WorkflowExtensionsBundle\Entity\ScheduledJob;
use JMS\JobQueueBundle\Entity\Job;

/**
 * ScheduledJobRepository
 */
class ScheduledJobRepository extends EntityRepository
{
    /**
     * Finds ScheduledJob by subject identity and workflow transition that can be rescheduled (is able to be started now)
     *
     * @param string $workflowName   workflow name
     * @param string $transitionName transition name
     * @param string $subjectClass   subject class
     * @param string $subjectId      subject id
     *
     * @return ScheduledJob|null
     */
    public function findScheduledJobToReschedule($workflowName, $transitionName, $subjectClass, $subjectId)
    {
        // fetching scheduled job that was not started before - it can be rescheduled
        $queryString = <<<'QUERY'
            SELECT sj FROM WorkflowExtensionsBundle:ScheduledJob sj
            JOIN sj.job j
            WHERE
                sj.workflow = :workflow AND
                sj.transition = :transition AND
                sj.subjectClass = :subjectClass AND
                sj.subjectId = :subjectId AND
                j.state in (:stateNew, :statePending)
QUERY;

        $scheduledJobToReschedule =
        $this->_em
            ->createQuery($queryString)
            ->setParameters([
                'workflow'     => $workflowName,
                'transition'   => $transitionName,
                'subjectClass' => $subjectClass,
                'subjectId'    => $subjectId,
                'stateNew'     => Job::STATE_NEW,
                'statePending' => Job::STATE_PENDING
            ])
            // since there is unique index on transition, workflow, subjectClass, subjectId fields we can select here
            // 0 or 1 job entity
            ->getOneOrNullResult()
        ;

        return $scheduledJobToReschedule;
    }
}