summaryrefslogtreecommitdiffstats
path: root/lib/Db
diff options
context:
space:
mode:
authorMaxence Lange <maxence@artificial-owl.com>2018-11-28 19:21:28 -0100
committerMaxence Lange <maxence@artificial-owl.com>2018-11-28 19:21:28 -0100
commit8b9217292d8c67d64d148a9a13df17de97a9ef24 (patch)
tree246ff05407380d47e0cda875d4e6715c01edc1e5 /lib/Db
parentdf2e2715d08498a6f9324f2ed8f66b1e253d2222 (diff)
to avoid conflict, filters failing instance when processing queue
Signed-off-by: Maxence Lange <maxence@artificial-owl.com>
Diffstat (limited to 'lib/Db')
-rw-r--r--lib/Db/CoreRequestBuilder.php9
-rw-r--r--lib/Db/RequestQueueRequest.php6
2 files changed, 3 insertions, 12 deletions
diff --git a/lib/Db/CoreRequestBuilder.php b/lib/Db/CoreRequestBuilder.php
index efe8b813..a87672d6 100644
--- a/lib/Db/CoreRequestBuilder.php
+++ b/lib/Db/CoreRequestBuilder.php
@@ -363,15 +363,6 @@ class CoreRequestBuilder {
/**
* @param IQueryBuilder $qb
- * @param string $order
- */
- protected function orderByPriority(IQueryBuilder &$qb, string $order = 'desc') {
- $qb->orderBy('priority', $order);
- }
-
-
- /**
- * @param IQueryBuilder $qb
* @param string $field
* @param string $value
* @param bool $cs - case sensitive
diff --git a/lib/Db/RequestQueueRequest.php b/lib/Db/RequestQueueRequest.php
index d358051e..4e07ffba 100644
--- a/lib/Db/RequestQueueRequest.php
+++ b/lib/Db/RequestQueueRequest.php
@@ -86,14 +86,14 @@ class RequestQueueRequest extends RequestQueueRequestBuilder {
/**
- * return Queue from database based on the status != 9
+ * return Queue from database based on the status=0
*
* @return RequestQueue[]
*/
public function getStandby(): array {
$qb = $this->getQueueSelectSql();
$this->limitToStatus($qb, RequestQueue::STATUS_STANDBY);
- $this->orderByPriority($qb, 'desc');
+ $qb->orderBy('id', 'asc');
$requests = [];
$cursor = $qb->execute();
@@ -122,7 +122,7 @@ class RequestQueueRequest extends RequestQueueRequestBuilder {
$this->limitToStatus($qb, $status);
}
- $this->orderByPriority($qb);
+ $qb->orderBy('priority', 'desc');
$requests = [];
$cursor = $qb->execute();