Add Beamer Worker

This commit is contained in:
Amine Ben hammou
2019-06-20 15:43:26 +01:00
committed by M. Shull
parent 6ff194e8e5
commit 2fe193d5d9
3 changed files with 40 additions and 0 deletions

View File

@@ -51,6 +51,7 @@ class Daemon {
yield $this->workers_factory->createPremiumKeyCheckWorker($this->timer); yield $this->workers_factory->createPremiumKeyCheckWorker($this->timer);
yield $this->workers_factory->createBounceWorker($this->timer); yield $this->workers_factory->createBounceWorker($this->timer);
yield $this->workers_factory->createExportFilesCleanupWorker($this->timer); yield $this->workers_factory->createExportFilesCleanupWorker($this->timer);
yield $this->workers_factory->createBeamerkWorker($this->timer);
yield $this->workers_factory->createInactiveSubscribersWorker($this->timer); yield $this->workers_factory->createInactiveSubscribersWorker($this->timer);
yield $this->workers_factory->createWooCommerceSyncWorker($this->timer); yield $this->workers_factory->createWooCommerceSyncWorker($this->timer);
yield $this->workers_factory->createAuthorizedSendingEmailsCheckWorker($this->timer); yield $this->workers_factory->createAuthorizedSendingEmailsCheckWorker($this->timer);

View File

@@ -0,0 +1,34 @@
<?php
namespace MailPoet\Cron\Workers;
use Carbon\Carbon;
use MailPoet\Models\ScheduledTask;
use MailPoet\Cron\Workers\SimpleWorker;
use MailPoet\Settings\SettingsController;
use MailPoet\WP\Functions as WPFunctions;
if (!defined('ABSPATH')) exit;
class Beamer extends SimpleWorker {
const TASK_TYPE = 'beamer';
/** @var SettingsController */
private $settings;
function __construct(SettingsController $settings, $timer = false) {
parent::__construct($timer);
$this->settings = $settings;
}
function processTaskStrategy(ScheduledTask $task) {
$this->settings->set('last_announcement_date', 'timestamp');
return true;
}
// static function getNextRunDate() {
// $wp = new WPFunctions();
// $date = Carbon::createFromTimestamp($wp->currentTime('timestamp'));
// return $date->addMinute();
// // return $date->hour(11)->minute(00)->second(00)->addDay();
// }
}

View File

@@ -135,6 +135,11 @@ class WorkersFactory {
return new ExportFilesCleanup($timer); return new ExportFilesCleanup($timer);
} }
/** @return Beamer */
function createBeamerWorker($timer) {
return new Beamer($this->settings, $timer);
}
/** @return InactiveSubscribers */ /** @return InactiveSubscribers */
function createInactiveSubscribersWorker($timer) { function createInactiveSubscribersWorker($timer) {
return new InactiveSubscribers($this->inactive_subscribers_controller, $this->settings, $timer); return new InactiveSubscribers($this->inactive_subscribers_controller, $this->settings, $timer);