[PW-4149] add processing time to notifications

Components/Builder/NotificationBuilder.php

@@ -94,6 +94,35 @@ public function fromParams($params)
             $notification->setErrorDetails($params['reason']);
         }
 
+        if (isset($params['eventCode']) && isset($params['success'])) {
+            $notification->setProcessedAt($this->getProcessingTime($notification));
+        }
+
         return $notification;
     }
+
+    /**
+     * Set delay in processing time for certain notifications.
+     *
+     * @param Notification $notification
+     * @return \DateTime
+     */
+    private function getProcessingTime(Notification $notification): \DateTime
+    {
+        $processedAt = new \DateTime();
+        switch ($notification->getEventCode()) {
+            case 'AUTHORISATION':
+                if (!$notification->isSuccess()) {
+                    $processedAt = $processedAt->add(new \DateInterval('PT30M'));
+                }
+                break;
+            case 'OFFER_CLOSED':
+                $processedAt = $processedAt->add(new \DateInterval('PT30M'));
+                break;
+            default:
+                break;
+        }
+
+        return $processedAt;
+    }
 }

Components/NotificationManager.php

@@ -49,9 +49,11 @@ public function getNextNotificationToHandle()
     {
         $builder = $this->notificationRepository->createQueryBuilder('n');
         $builder->where("n.status = :statusReceived OR n.status = :statusRetry")
+            ->where('(n.processedAt <= :processingTime OR n.processedAt IS NULL)')
             ->orderBy('n.updatedAt', 'ASC')
             ->setParameter('statusReceived', NotificationStatus::STATUS_RECEIVED)
             ->setParameter('statusRetry', NotificationStatus::STATUS_RETRY)
+            ->setParameter('processingTime', new \DateTime())
             ->setMaxResults(1);
 
         return $builder->getQuery()->getSingleResult();

Models/Notification.php

@@ -52,6 +52,12 @@ class Notification extends ModelEntity implements \JsonSerializable
      */
     private $updatedAt;
 
+    /**
+     * @var \DateTime
+     * @ORM\Column(name="processed_at", type="datetime", nullable=true)
+     */
+    private $processedAt;
+
     /**
      * @var string
      * @ORM\Column(name="status", type="text")
@@ -217,6 +223,24 @@ public function setUpdatedAt(\DateTime $updatedAt): Notification
         return $this;
     }
 
+    /**
+     * @return \DateTime
+     */
+    public function getProcessedAt(): \DateTime
+    {
+        return $this->processedAt;
+    }
+
+    /**
+     * @param \DateTime $processedAt
+     * @return Notification
+     */
+    public function setProcessedAt(\DateTime $processedAt): Notification
+    {
+        $this->processedAt = $processedAt;
+        return $this;
+    }
+
     /**
      * @return string
      */