=> {
+ await recalculateSubscribersScore();
+ notices.info({t('recalculateSubscribersScoreNotice')}
, { scroll: true });
+ };
+ return (
+ <>
+
+
+
+
+ >
+ );
+}
diff --git a/assets/js/src/settings/store/actions/index.ts b/assets/js/src/settings/store/actions/index.ts
index 3637b04ad1..04322cd8de 100644
--- a/assets/js/src/settings/store/actions/index.ts
+++ b/assets/js/src/settings/store/actions/index.ts
@@ -1,5 +1,6 @@
export * from './settings';
export * from './mss_and_premium';
export { default as reinstall } from './reinstall';
+export { recalculateSubscribersScore } from './recalculate_subscribers_score';
export { default as sendTestEmail } from './send_test_email';
export { default as openWoocommerceCustomizer } from './open_woocommerce_customizer';
diff --git a/assets/js/src/settings/store/actions/recalculate_subscribers_score.ts b/assets/js/src/settings/store/actions/recalculate_subscribers_score.ts
new file mode 100644
index 0000000000..69d0d8e3aa
--- /dev/null
+++ b/assets/js/src/settings/store/actions/recalculate_subscribers_score.ts
@@ -0,0 +1,16 @@
+import MailPoet from 'mailpoet';
+
+export function* recalculateSubscribersScore(): Generator<{
+ type: string;
+ endpoint: string;
+ action: string;
+}> {
+ MailPoet.Modal.loading(true);
+ yield {
+ type: 'CALL_API',
+ endpoint: 'settings',
+ action: 'recalculateSubscribersScore',
+ };
+ MailPoet.Modal.loading(false);
+ return { type: 'SAVE_DONE' };
+}
diff --git a/lib/API/JSON/v1/Settings.php b/lib/API/JSON/v1/Settings.php
index e58a08370e..143355e7a9 100644
--- a/lib/API/JSON/v1/Settings.php
+++ b/lib/API/JSON/v1/Settings.php
@@ -6,12 +6,17 @@ use MailPoet\API\JSON\Endpoint as APIEndpoint;
use MailPoet\API\JSON\Error as APIError;
use MailPoet\Config\AccessControl;
use MailPoet\Config\ServicesChecker;
+use MailPoet\Cron\Workers\SubscribersEngagementScore;
+use MailPoet\Entities\ScheduledTaskEntity;
use MailPoet\Mailer\MailerLog;
use MailPoet\Services\AuthorizedEmailsController;
use MailPoet\Services\Bridge;
use MailPoet\Settings\SettingsController;
+use MailPoet\Statistics\StatisticsOpensRepository;
use MailPoet\WooCommerce\TransactionalEmails;
use MailPoet\WP\Functions as WPFunctions;
+use MailPoetVendor\Carbon\Carbon;
+use MailPoetVendor\Doctrine\ORM\EntityManager;
class Settings extends APIEndpoint {
@@ -30,15 +35,31 @@ class Settings extends APIEndpoint {
/** @var ServicesChecker */
private $servicesChecker;
+ /** @var WPFunctions */
+ private $wp;
+
public $permissions = [
'global' => AccessControl::PERMISSION_MANAGE_SETTINGS,
];
+ /**
+ * @var EntityManager
+ */
+ private $entityManager;
+
+ /**
+ * @var StatisticsOpensRepository
+ */
+ private $statisticsOpensRepository;
+
public function __construct(
SettingsController $settings,
Bridge $bridge,
AuthorizedEmailsController $authorizedEmailsController,
TransactionalEmails $wcTransactionalEmails,
+ WPFunctions $wp,
+ EntityManager $entityManager,
+ StatisticsOpensRepository $statisticsOpensRepository,
ServicesChecker $servicesChecker
) {
$this->settings = $settings;
@@ -46,6 +67,9 @@ class Settings extends APIEndpoint {
$this->authorizedEmailsController = $authorizedEmailsController;
$this->wcTransactionalEmails = $wcTransactionalEmails;
$this->servicesChecker = $servicesChecker;
+ $this->wp = $wp;
+ $this->entityManager = $entityManager;
+ $this->statisticsOpensRepository = $statisticsOpensRepository;
}
public function get() {
@@ -81,6 +105,17 @@ class Settings extends APIEndpoint {
}
}
+ public function recalculateSubscribersScore() {
+ $this->statisticsOpensRepository->resetSubscribersScoreCalculation();
+ $task = new ScheduledTaskEntity();
+ $task->setType(SubscribersEngagementScore::TASK_TYPE);
+ $task->setScheduledAt(Carbon::createFromTimestamp($this->wp->currentTime('timestamp')));
+ $task->setStatus(ScheduledTaskEntity::STATUS_SCHEDULED);
+ $this->entityManager->persist($task);
+ $this->entityManager->flush();
+ return $this->successResponse();
+ }
+
public function setAuthorizedFromAddress($data = []) {
$address = $data['address'] ?? null;
if (!$address) {
diff --git a/lib/Statistics/StatisticsOpensRepository.php b/lib/Statistics/StatisticsOpensRepository.php
index b6c7c6eee9..946fc3863c 100644
--- a/lib/Statistics/StatisticsOpensRepository.php
+++ b/lib/Statistics/StatisticsOpensRepository.php
@@ -47,4 +47,11 @@ class StatisticsOpensRepository extends Repository {
$subscriber->setEngagementScore($score);
$this->entityManager->flush();
}
+
+ public function resetSubscribersScoreCalculation() {
+ $this->entityManager->createQueryBuilder()->update(SubscriberEntity::class, 's')
+ ->set('s.engagementScoreUpdatedAt', ':verified')
+ ->setParameter('verified', null)
+ ->getQuery()->execute();
+ }
}
diff --git a/views/settings.html b/views/settings.html
index 5954645228..f2c1f7a354 100644
--- a/views/settings.html
+++ b/views/settings.html
@@ -150,6 +150,10 @@
'yourReCaptchaSecret': __('Your reCAPTCHA Secret Key'),
'fillReCaptchaKeys': __('Please fill the reCAPTCHA keys.'),
'disable': __('Disable'),
+ 'recalculateSubscribersScoreTitle': __('Recalculate Subscriber Scores'),
+ 'recalculateSubscribersScoreDescription': __('MailPoet will recalculate subscriber engagement scores for all subscribers. This may take some time to complete.'),
+ 'recalculateSubscribersScoreNow': __('Update now…'),
+ 'recalculateSubscribersScoreNotice': __('Subscriber score recalculation has been scheduled and will start soon. It may take some time to complete.'),
'reinstallTitle': __('Reinstall from scratch'),
'reinstallDescription': __('Want to start from the beginning? This will completely delete MailPoet and reinstall it from scratch. Remember: you will lose all of your data!'),
'reinstallNow': __('Reinstall now...'),