jarobe42 / task-runner

     * @param $taskName

     * @return TaskEvent[]

     */

    public function getPendingTaskEvents(\DateTime $dateTime, $taskName)

    {

        $qb = $this->createQueryBuilder('te');

        $qb->andWhere('te.taskName = :taskName')

            ->andWhere('te.targetTime = :targetTime')

            ->andWhere('te.completed IS NULL')

            ->andWhere('te.failedAt IS NULL')

            ->andWhere('te.initiatedAt IS NOT NULL')

        ;

        $qb->setParameter('taskName', $taskName)

            ->setParameter('targetTime', $dateTime)

        ;

        $query = $qb->getQuery();

        return $query->getResult();

    }

    /**

     * @param \DateTime $dateTime

     * @param $taskName

     * @return TaskEvent[]

     */

    public function getScheduledTaskEvents(\DateTime $dateTime, $taskName)

    {

        $qb = $this->createQueryBuilder('te');

        $qb->andWhere('te.taskName = :taskName')

            ->andWhere('te.targetTime = :targetTime')

            ->andWhere('te.initiatedAt IS NULL')

        ;

        $qb->setParameter('taskName', $taskName)

            ->setParameter('targetTime', $dateTime)

        ;

        $qb->addOrderBy('te.id', 'ASC');

        $query = $qb->getQuery();

        return $query->getResult();

    }

}