Refactor CreateStackableUserNotification to optimize notification updates and support chunked processing

Author: Cyperghost

wcfsetup/install/files/lib/command/user/notification/CreateStackableUserNotification.class.php

@@ -7,6 +7,7 @@
 use wcf\data\user\notification\UserNotificationList;
 use wcf\data\user\User;
 use wcf\data\user\UserProfile;
+use wcf\system\database\util\PreparedStatementConditionBuilder;
 use wcf\system\WCF;
 
 /**
@@ -90,33 +91,38 @@ private function createUserNotifications(UserProfile $author, array $notificatio
                                     (notificationID, authorID, time)
                 VALUES              (?, ?, ?)";
         $authorStatement = WCF::getDB()->prepare($sql);
-        $sql = "UPDATE  wcf1_user_notification
-                SET     timesTriggered = timesTriggered + ?,
-                        guestTimesTriggered = guestTimesTriggered + ?
-                WHERE   notificationID = ?";
-        $triggerStatement = WCF::getDB()->prepare($sql);
 
         $authorId = $author->userID;
         $isGuestTrigger = $authorId ? 0 : 1;
         $now = TIME_NOW;
-        $notificationIDs = [];
+        $notificationIDs = \array_map(static function ($notificationData) {
+            return $notificationData['object']->notificationID;
+        }, $notifications);
 
         WCF::getDB()->beginTransaction();
-        foreach ($notifications as $notificationData) {
-            $notificationID = $notificationData['object']->notificationID;
-            $notificationIDs[] = $notificationID;
-
+        foreach ($notificationIDs as $notificationID) {
             $authorStatement->execute([
                 $notificationID,
                 $authorId,
                 $now,
             ]);
+        }
+
+        $chunks = \array_chunk($notificationIDs, 1_000);
+        foreach ($chunks as $chunk) {
+            $conditionBuilder = new PreparedStatementConditionBuilder();
+            $conditionBuilder->add('notificationID IN (?)', [$chunk]);
 
-            $triggerStatement->execute([
+            $sql = "UPDATE  wcf1_user_notification
+                    SET     timesTriggered = timesTriggered + ?,
+                            guestTimesTriggered = guestTimesTriggered + ?
+                    " . $conditionBuilder;
+            $triggerStatement = WCF::getDB()->prepare($sql);
+
+            $triggerStatement->execute(\array_merge([
                 1,
                 $isGuestTrigger,
-                $notificationID,
-            ]);
+            ], $conditionBuilder->getParameters()));
         }
         WCF::getDB()->commitTransaction();