Cavemanon/piratepoet
8
Fork 0
Code Pull Requests Actions Releases 16 Activity

Fix count of tasks on the status page

Browse Source 
[MAILPOET-4664]
This commit is contained in:
Jan Lysý
2022-11-14 19:52:48 +01:00
committed by Aschepikov
parent a7c1d8431d
commit efd3377ecd
1 changed files with 21 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
mailpoet/lib/Newsletter/Sending/ScheduledTasksRepository.php
View File

@@ -218,26 +218,31 @@ class ScheduledTasksRepository extends Repository {
],
$limit = Scheduler::TASK_BATCH_SIZE
) {
$result = [];
foreach ($statuses as $status) {
$tasksQuery = $this->doctrineRepository->createQueryBuilder('st')
->select('st')
->where('st.deletedAt IS NULL')
->where('st.status = :status');
$tasksQuery = $this->doctrineRepository->createQueryBuilder('st')
->select('st')
->where('st.deletedAt IS NULL')
->where('st.status IN (:statuses)');
if (in_array(ScheduledTaskEntity::VIRTUAL_STATUS_RUNNING, $statuses)) {
$tasksQuery = $tasksQuery->orWhere('st.status IS NULL');
}
if (in_array(ScheduledTaskEntity::VIRTUAL_STATUS_RUNNING, $statuses)) {
$tasksQuery = $tasksQuery->orWhere('st.status IS NULL');
if ($type) {
$tasksQuery = $tasksQuery->andWhere('st.type = :type')
->setParameter('type', $type);
}
$tasks = $tasksQuery
->setParameter('status', $status)
->setMaxResults($limit)
->getQuery()
->getResult();
$result = array_merge($result, $tasks);
}
if ($type) {
$tasksQuery = $tasksQuery->andWhere('st.type = :type')
->setParameter('type', $type);
}
return $tasksQuery
->setParameter('statuses', $statuses)
->setMaxResults($limit)
->getQuery()
->getResult();
return $result;
}
/**