From 413ca3af06d6fb1b6c78fb13d0ca221b37585ac5 Mon Sep 17 00:00:00 2001
From: Alan Knowles <alan@roojs.com>
Date: Sun, 20 Aug 2023 15:39:31 +0800
Subject: [PATCH] fix

---
 Notify.php | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git a/Notify.php b/Notify.php
index b5026e89..f4335e87 100644
--- a/Notify.php
+++ b/Notify.php
@@ -281,7 +281,7 @@ class Pman_Core_Notify extends Pman
             $black = $this->isBlacklisted($email);
             if ($black !== false) {
                 $this->logecho("DOMAIN blacklisted - {$email} - moving to another pool");
-                $this->updateServer($p, $black);
+                $this->updateServer(clone($p), $black);
                 continue;
             }
              
@@ -353,9 +353,12 @@ class Pman_Core_Notify extends Pman
     }
     
     // this sequentially distributes requeued emails.. - to other servers. (can exclude current one if we have that flagged.)
-    function updateServer($w, $exclude = -1)
+    function updateServer($ww, $exclude = -1)
     {
-        $ff = HTML_FlexyFramework::get();
+$w = DB_DataObject::factory($ww->tableName());
+$w->get($ww->id);
+
+$ff = HTML_FlexyFramework::get();
         static $num = 0;
         if (empty($ff->Core_Notify['servers'])) {
             return;
@@ -368,7 +371,7 @@ class Pman_Core_Notify extends Pman
         $pp = clone($w);
         $w->server_id = $num;
                     
-        $w->act_when = $w->sqlValue('NOW + INTERVAL 1 MINUTE');
+        $w->act_when = $w->sqlValue('NOW() + INTERVAL 1 MINUTE');
         $w->update($pp);
         
          
@@ -683,4 +686,4 @@ class Pman_Core_Notify extends Pman
     {
         echo date("Y-m-d H:i:s - ") . $str . "\n";
     }
-}
\ No newline at end of file
+}
-- 
2.39.2