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

Fix setting processed at when finishing sending within resume

Browse Source 
[MAILPOET-3962]
This commit is contained in:
Rostislav Wolny
2021-11-19 15:15:38 +01:00
committed by Veljko V
parent 8e5d7dd917
commit c8111a7a85
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
lib/Newsletter/Sending/SendingQueuesRepository.php
View File

@@ -8,6 +8,7 @@ use MailPoet\Entities\ScheduledTaskEntity;
use MailPoet\Entities\SendingQueueEntity; use MailPoet\Entities\SendingQueueEntity;
use MailPoet\Entities\SubscriberEntity; use MailPoet\Entities\SubscriberEntity;
use MailPoet\WP\Functions as WPFunctions; use MailPoet\WP\Functions as WPFunctions;
use MailPoetVendor\Carbon\Carbon;
use MailPoetVendor\Doctrine\ORM\EntityManager; use MailPoetVendor\Doctrine\ORM\EntityManager;
/** /**
@@ -99,7 +100,8 @@ class SendingQueuesRepository extends Repository {
if (!$task instanceof ScheduledTaskEntity) return; if (!$task instanceof ScheduledTaskEntity) return;
if ($queue->getCountProcessed() === $queue->getCountTotal()) { if ($queue->getCountProcessed() === $queue->getCountTotal()) {
$task->setProcessedAt($this->wp->currentTime('mysql')); $processedAt = Carbon::createFromTimestamp($this->wp->currentTime('mysql'));
$task->setProcessedAt($processedAt);
$task->setStatus(ScheduledTaskEntity::STATUS_COMPLETED); $task->setStatus(ScheduledTaskEntity::STATUS_COMPLETED);
$this->flush(); $this->flush();
} else { } else {