From 27579a01111c6d8652c8b7c86dc84a15f10affe3 Mon Sep 17 00:00:00 2001
From: yuri <yurikuzn@users.noreply.github.com>
Date: Wed, 25 Sep 2019 16:27:44 +0300
Subject: [PATCH] fix webhook

---
 application/Espo/Core/Webhook/Queue.php | 22 +++++++++++++++-------
 1 file changed, 15 insertions(+), 7 deletions(-)

diff --git a/application/Espo/Core/Webhook/Queue.php b/application/Espo/Core/Webhook/Queue.php
index 2b0e49c1d4..26acec8b2d 100644
--- a/application/Espo/Core/Webhook/Queue.php
+++ b/application/Espo/Core/Webhook/Queue.php
@@ -112,17 +112,25 @@ class Queue
         $batchSize = $this->config->get('webhookBatchSize', self::BATCH_SIZE);
 
         $groupedItemList = $this->entityManager->getRepository('WebhookQueueItem')
-            ->select(['webhookId'])
+            ->select(['webhookId', 'number'])
             ->where([
-                'status' => 'Pending',
-                'OR' => [
-                    ['processAt' => null],
-                    ['processAt<=' => DateTime::getSystemNowString()],
+                'number=s' => [
+                    'entityType' => 'WebhookQueueItem',
+                    'selectParams' => [
+                        'select' => ['MIN:number'],
+                        'whereClause' => [
+                            'status' => 'Pending',
+                            'OR' => [
+                                ['processAt' => null],
+                                ['processAt<=' => DateTime::getSystemNowString()],
+                            ],
+                        ],
+                        'groupBy' => ['webhookId'],
+                    ]
                 ],
             ])
-            ->order('number')
             ->limit(0, $portionSize)
-            ->groupBy(['webhookId'])
+            ->order('number')
             ->find();
 
         foreach ($groupedItemList as $group) {