Server IP : 104.21.14.103 / Your IP : 3.144.86.233 Web Server : LiteSpeed System : Linux business53.web-hosting.com 4.18.0-553.lve.el8.x86_64 #1 SMP Mon May 27 15:27:34 UTC 2024 x86_64 User : giankuin ( 1871) PHP Version : 7.4.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /proc/self/root/home/giankuin/thietke365.net/wp-content/plugins/mailpoet/lib/Cron/Workers/ |
Upload File : |
<?php declare(strict_types = 1); namespace MailPoet\Cron\Workers; if (!defined('ABSPATH')) exit; use MailPoet\Entities\ScheduledTaskEntity; use MailPoet\Subscribers\EngagementDataBackfiller; use MailPoet\WP\Functions as WPFunctions; class BackfillEngagementData extends SimpleWorker { const TASK_TYPE = 'backfill_engagement_data'; const BATCH_SIZE = 100; const AUTOMATIC_SCHEDULING = false; const SUPPORT_MULTIPLE_INSTANCES = false; /** @var EngagementDataBackfiller */ private $engagementDataBackfiller; public function __construct( EngagementDataBackfiller $engagementDataBackfiller, WPFunctions $wp ) { parent::__construct($wp); $this->engagementDataBackfiller = $engagementDataBackfiller; } public function processTaskStrategy(ScheduledTaskEntity $task, $timer) { $meta = $task->getMeta(); $lastSubscriberId = $meta['last_subscriber_id'] ?? 0; do { $this->cronHelper->enforceExecutionLimit($timer); $batch = $this->engagementDataBackfiller->getBatch($lastSubscriberId, self::BATCH_SIZE); if (empty($batch)) { break; } $this->engagementDataBackfiller->updateBatch($batch); $lastSubscriberId = $this->engagementDataBackfiller->getLastProcessedSubscriberId(); $meta['last_subscriber_id'] = $lastSubscriberId; $task->setMeta($meta); $this->scheduledTasksRepository->persist($task); $this->scheduledTasksRepository->flush(); } while (count($batch) === self::BATCH_SIZE); return true; } }