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

Use newsletter entity constants in scheduler worker

Browse Source 
[MAILPOET-3782]
This commit is contained in:
Rostislav Wolny
2021-10-06 14:57:39 +02:00
committed by Veljko V
parent 59031237fe
commit 550077800e
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
lib/Cron/Workers/Scheduler.php
View File

@@ -3,6 +3,7 @@
namespace MailPoet\Cron\Workers; namespace MailPoet\Cron\Workers;
use MailPoet\Cron\CronHelper; use MailPoet\Cron\CronHelper;
use MailPoet\Entities\NewsletterEntity;
use MailPoet\Logging\LoggerFactory; use MailPoet\Logging\LoggerFactory;
use MailPoet\Models\Newsletter; use MailPoet\Models\Newsletter;
use MailPoet\Models\ScheduledTask; use MailPoet\Models\ScheduledTask;
@@ -50,15 +51,15 @@ class Scheduler {
$newsletter = Newsletter::findOneWithOptions($queue->newsletterId); $newsletter = Newsletter::findOneWithOptions($queue->newsletterId);
if (!$newsletter || $newsletter->deletedAt !== null) { if (!$newsletter || $newsletter->deletedAt !== null) {
$queue->delete(); $queue->delete();
} elseif ($newsletter->status !== Newsletter::STATUS_ACTIVE && $newsletter->status !== Newsletter::STATUS_SCHEDULED) { } elseif ($newsletter->status !== NewsletterEntity::STATUS_ACTIVE && $newsletter->status !== NewsletterEntity::STATUS_SCHEDULED) {
continue; continue;
} elseif ($newsletter->type === Newsletter::TYPE_WELCOME) { } elseif ($newsletter->type === NewsletterEntity::TYPE_WELCOME) {
$this->processWelcomeNewsletter($newsletter, $queue); $this->processWelcomeNewsletter($newsletter, $queue);
} elseif ($newsletter->type === Newsletter::TYPE_NOTIFICATION) { } elseif ($newsletter->type === NewsletterEntity::TYPE_NOTIFICATION) {
$this->processPostNotificationNewsletter($newsletter, $queue); $this->processPostNotificationNewsletter($newsletter, $queue);
} elseif ($newsletter->type === Newsletter::TYPE_STANDARD) { } elseif ($newsletter->type === NewsletterEntity::TYPE_STANDARD) {
$this->processScheduledStandardNewsletter($newsletter, $queue); $this->processScheduledStandardNewsletter($newsletter, $queue);
} elseif ($newsletter->type === Newsletter::TYPE_AUTOMATIC) { } elseif ($newsletter->type === NewsletterEntity::TYPE_AUTOMATIC) {
$this->processScheduledAutomaticEmail($newsletter, $queue); $this->processScheduledAutomaticEmail($newsletter, $queue);
} }
$this->cronHelper->enforceExecutionLimit($timer); $this->cronHelper->enforceExecutionLimit($timer);