|
1
|
|
|
<?php |
|
2
|
|
|
|
|
3
|
|
|
|
|
4
|
|
|
namespace Jarobe\TaskRunnerBundle\Repository; |
|
5
|
|
|
|
|
6
|
|
|
use Doctrine\ORM\EntityRepository; |
|
7
|
|
|
use Jarobe\TaskRunnerBundle\Entity\TaskEvent; |
|
8
|
|
|
|
|
9
|
|
|
class TaskEventRepository extends EntityRepository |
|
10
|
|
|
{ |
|
11
|
|
|
/** |
|
12
|
|
|
* @param \DateTime $dateTime |
|
13
|
|
|
* @param $taskName |
|
14
|
|
|
* @return TaskEvent[] |
|
15
|
|
|
*/ |
|
16
|
|
|
public function getCompletedTaskEvents(\DateTime $dateTime, $taskName) |
|
17
|
|
|
{ |
|
18
|
|
|
$qb = $this->createQueryBuilder('te'); |
|
19
|
|
|
$qb->andWhere('te.taskName = :taskName') |
|
20
|
|
|
->andWhere('te.targetTime = :targetTime') |
|
21
|
|
|
->andWhere('te.completedAt IS NOT NULL') |
|
22
|
|
|
; |
|
23
|
|
|
$qb->setParameter('taskName', $taskName) |
|
24
|
|
|
->setParameter('targetTime', $dateTime) |
|
25
|
|
|
; |
|
26
|
|
|
|
|
27
|
|
|
$query = $qb->getQuery(); |
|
28
|
|
|
return $query->getResult(); |
|
29
|
|
|
} |
|
30
|
|
|
|
|
31
|
|
|
/** |
|
32
|
|
|
* @param \DateTime $dateTime |
|
33
|
|
|
* @param $taskName |
|
34
|
|
|
* @return TaskEvent[] |
|
35
|
|
|
*/ |
|
36
|
|
|
public function getFailedTaskEvents(\DateTime $dateTime, $taskName) |
|
37
|
|
|
{ |
|
38
|
|
|
$qb = $this->createQueryBuilder('te'); |
|
39
|
|
|
$qb->andWhere('te.taskName = :taskName') |
|
40
|
|
|
->andWhere('te.targetTime = :targetTime') |
|
41
|
|
|
->andWhere('te.failedAt IS NOT NULL') |
|
42
|
|
|
; |
|
43
|
|
|
$qb->setParameter('taskName', $taskName) |
|
44
|
|
|
->setParameter('targetTime', $dateTime) |
|
45
|
|
|
; |
|
46
|
|
|
|
|
47
|
|
|
$query = $qb->getQuery(); |
|
48
|
|
|
return $query->getResult(); |
|
49
|
|
|
} |
|
50
|
|
|
|
|
51
|
|
|
/** |
|
52
|
|
|
* @param \DateTime $dateTime |
|
53
|
|
|
* @param $taskName |
|
54
|
|
|
* @return TaskEvent[] |
|
55
|
|
|
*/ |
|
56
|
|
View Code Duplication |
public function getPendingTaskEvents(\DateTime $dateTime, $taskName) |
|
|
|
|
|
|
57
|
|
|
{ |
|
58
|
|
|
$qb = $this->createQueryBuilder('te'); |
|
59
|
|
|
$qb->andWhere('te.taskName = :taskName') |
|
60
|
|
|
->andWhere('te.targetTime = :targetTime') |
|
61
|
|
|
->andWhere('te.completedAt IS NULL') |
|
62
|
|
|
->andWhere('te.failedAt IS NULL') |
|
63
|
|
|
->andWhere('te.initiatedAt IS NOT NULL') |
|
64
|
|
|
; |
|
65
|
|
|
$qb->setParameter('taskName', $taskName) |
|
66
|
|
|
->setParameter('targetTime', $dateTime) |
|
67
|
|
|
; |
|
68
|
|
|
|
|
69
|
|
|
$query = $qb->getQuery(); |
|
70
|
|
|
return $query->getResult(); |
|
71
|
|
|
} |
|
72
|
|
|
|
|
73
|
|
|
/** |
|
74
|
|
|
* @param \DateTime $dateTime |
|
75
|
|
|
* @param $taskName |
|
76
|
|
|
* @return TaskEvent[] |
|
77
|
|
|
*/ |
|
78
|
|
View Code Duplication |
public function getScheduledTaskEvents(\DateTime $dateTime, $taskName) |
|
|
|
|
|
|
79
|
|
|
{ |
|
80
|
|
|
$qb = $this->createQueryBuilder('te'); |
|
81
|
|
|
$qb->andWhere('te.taskName = :taskName') |
|
82
|
|
|
->andWhere('te.targetTime = :targetTime') |
|
83
|
|
|
->andWhere('te.initiatedAt IS NULL') |
|
84
|
|
|
; |
|
85
|
|
|
$qb->setParameter('taskName', $taskName) |
|
86
|
|
|
->setParameter('targetTime', $dateTime) |
|
87
|
|
|
; |
|
88
|
|
|
|
|
89
|
|
|
$qb->addOrderBy('te.id', 'ASC'); |
|
90
|
|
|
|
|
91
|
|
|
$query = $qb->getQuery(); |
|
92
|
|
|
return $query->getResult(); |
|
93
|
|
|
} |
|
94
|
|
|
} |
|
95
|
|
|
|
jarobe42 /
task-runner
Loading history...
Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation.
You can also find more detailed suggestions in the “Code” section of your repository.