Cavemanon/piratepoet
8
Fork 0
Code Pull Requests Actions Releases 16 Activity

Simplify fetching subscriber IDs

Browse Source 
[MAILPOET-5737]
This commit is contained in:
Jan Jakes
2024-01-17 15:42:11 +01:00
committed by Aschepikov
parent 895c2ad3e1
commit dbd88f8313
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
mailpoet/lib/Cron/Workers/SendingQueue/SendingQueue.php
View File

@@ -258,12 +258,11 @@ class SendingQueue {
} }
$foundSubscribers = $queryBuilder->getQuery()->getResult(); $foundSubscribers = $queryBuilder->getQuery()->getResult();
$foundSubscribersIds = array_filter( $foundSubscribersIds = array_map(function(SubscriberEntity $subscriber) {
array_map(function(SubscriberEntity $subscriber) { return $subscriber->getId();
return (!empty($subscriber->getId())) ? $subscriber->getId() : false; }, $foundSubscribers);
}, $foundSubscribers)
);
} }
// if some subscribers weren't found, remove them from the processing list // if some subscribers weren't found, remove them from the processing list
if (count($foundSubscribersIds) !== count($subscribersToProcessIds)) { if (count($foundSubscribersIds) !== count($subscribersToProcessIds)) {
$subscribersToRemove = array_diff( $subscribersToRemove = array_diff(