[Projekt: xRM-Marketing][TicketNr.: 1086209][Verwendung von SqlBuilder.IN +...

[Projekt: xRM-Marketing][TicketNr.: 1086209][Verwendung von SqlBuilder.IN + idArray beim Mailversand.]

process/Bulkmail_lib/process.js

@@ -277,30 +277,47 @@ BulkMailUtils.sendBulkMail = function (pBulkMailId, pIsTestRun, pUser)
                 ActivityUtils.insertNewActivity(activityData, bulkMailLink.concat(contactLink));
             }
         });
-
-        newWhereIfSet("BULKMAILRECIPIENT.BULKMAILRECIPIENTID", successIds, SqlBuilder.IN())
-            .updateFields({
-                "STATUS": $KeywordRegistry.bulkMailRecipientStatus$sent(),
-                "SENTDATE": sentDate
-            });
-
-        newWhereIfSet("BULKMAILRECIPIENT.BULKMAILRECIPIENTID", failedIds, SqlBuilder.IN())
-            .updateFields({
-                "STATUS": $KeywordRegistry.bulkMailRecipientStatus$failed(),
-                "SENTDATE": sentDate
-            });
-
-        newWhereIfSet("BULKMAILRECIPIENT.BULKMAILRECIPIENTID", bouncedSoftIds, SqlBuilder.IN())
-            .updateFields({
-                "STATUS": $KeywordRegistry.bulkMailRecipientStatus$softBounce(),
-                "SENTDATE": sentDate
-            });
         
-        newWhereIfSet("BULKMAILRECIPIENT.BULKMAILRECIPIENTID", bouncedHardIds, SqlBuilder.IN())
-            .updateFields({
-                "STATUS": $KeywordRegistry.bulkMailRecipientStatus$hardBounce(),
-                "SENTDATE": sentDate
-            });
+        var updates = [];
+             
+        updates = updates.concat(successIds.map(function (sucessId)
+        {
+            return  newWhere("BULKMAILRECIPIENT.BULKMAILRECIPIENTID",successId)
+                    .buildUpdateStatement({
+                        "STATUS": $KeywordRegistry.bulkMailRecipientStatus$sent(),
+                        "SENTDATE": sentDate
+                    });
+        }));
+        
+        updates = updates.concat(failedIds.map(function (failedId)
+        {
+            return  newWhere("BULKMAILRECIPIENT.BULKMAILRECIPIENTID",failedId)
+                    .buildUpdateStatement({
+                        "STATUS": $KeywordRegistry.bulkMailRecipientStatus$failed(),
+                        "SENTDATE": sentDate
+                    });
+        }));
+        
+        updates = updates.concat(bouncedSoftIds.map(function (bouncedSoftId)
+        {
+            return  newWhere("BULKMAILRECIPIENT.BULKMAILRECIPIENTID",bouncedSoftId)
+                    .buildUpdateStatement({
+                        "STATUS": $KeywordRegistry.bulkMailRecipientStatus$softBounce(),
+                        "SENTDATE": sentDate
+                    });
+        }));
+        
+        updates = updates.concat(bouncedHardIds.map(function (bouncedHardId)
+        {
+            return  newWhere("BULKMAILRECIPIENT.BULKMAILRECIPIENTID",bouncedHardId)
+                    .buildUpdateStatement({
+                        "STATUS": $KeywordRegistry.bulkMailRecipientStatus$hardBounce(),
+                        "SENTDATE": sentDate
+                    });
+        }));
+
+        db.updates(updates);
+            
             
         newWhere("MAIL_RUN.MAIL_RUNID", mailrunId)
             .updateFields({