From 4d4013896c936a7541277ccda4a6832b31ffbcd8 Mon Sep 17 00:00:00 2001
From: Daniel Supernault <danielsupernault@gmail.com>
Date: Sun, 4 Feb 2024 07:11:05 -0700
Subject: [PATCH] Update NotificationEpochUpdatePipeline, use more efficient
 query

---
 .../InternalPipeline/NotificationEpochUpdatePipeline.php   | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/app/Jobs/InternalPipeline/NotificationEpochUpdatePipeline.php b/app/Jobs/InternalPipeline/NotificationEpochUpdatePipeline.php
index 477b1f9b3..79df5aa9a 100644
--- a/app/Jobs/InternalPipeline/NotificationEpochUpdatePipeline.php
+++ b/app/Jobs/InternalPipeline/NotificationEpochUpdatePipeline.php
@@ -61,7 +61,12 @@ class NotificationEpochUpdatePipeline implements ShouldQueue, ShouldBeUniqueUnti
      */
     public function handle(): void
     {
-        $rec = Notification::where('created_at', '>', now()->subMonths(6))->first();
+        $pid = Cache::get(NotificationService::EPOCH_CACHE_KEY . '6');
+        if($pid && $pid > 1) {
+            $rec = Notification::where('id', '>', $pid)->whereDate('created_at', now()->subMonths(6)->format('Y-m-d'))->first();
+        } else {
+            $rec = Notification::whereDate('created_at', now()->subMonths(6)->format('Y-m-d'))->first();
+        }
         $id = 1;
         if($rec) {
             $id = $rec->id;