Move plugin files to a subfolder
[MAILPOET-3988]
This commit is contained in:
Jan Jakes
Veljko V
210
mailpoet/lib/Subscribers/InactiveSubscribersController.php
Normal file
210
mailpoet/lib/Subscribers/InactiveSubscribersController.php
Normal file
@ -0,0 +1,210 @@
|
||||
<?php declare(strict_types = 1);
|
||||
|
||||
namespace MailPoet\Subscribers;
|
||||
|
||||
use MailPoet\Config\MP2Migrator;
|
||||
use MailPoet\Entities\ScheduledTaskEntity;
|
||||
use MailPoet\Entities\ScheduledTaskSubscriberEntity;
|
||||
use MailPoet\Entities\SendingQueueEntity;
|
||||
use MailPoet\Entities\SubscriberEntity;
|
||||
use MailPoet\Settings\SettingsRepository;
|
||||
use MailPoetVendor\Carbon\Carbon;
|
||||
use MailPoetVendor\Doctrine\DBAL\Connection;
|
||||
use MailPoetVendor\Doctrine\ORM\EntityManager;
|
||||
|
||||
class InactiveSubscribersController {
|
||||
|
||||
private $inactiveTaskIdsTableCreated = false;
|
||||
|
||||
/** @var SettingsRepository */
|
||||
private $settingsRepository;
|
||||
|
||||
/** @var EntityManager */
|
||||
private $entityManager;
|
||||
|
||||
public function __construct(
|
||||
EntityManager $entityManager,
|
||||
SettingsRepository $settingsRepository
|
||||
) {
|
||||
$this->settingsRepository = $settingsRepository;
|
||||
$this->entityManager = $entityManager;
|
||||
}
|
||||
|
||||
public function markInactiveSubscribers(int $daysToInactive, int $batchSize, ?int $startId = null) {
|
||||
$thresholdDate = $this->getThresholdDate($daysToInactive);
|
||||
return $this->deactivateSubscribers($thresholdDate, $batchSize, $startId);
|
||||
}
|
||||
|
||||
public function markActiveSubscribers(int $daysToInactive, int $batchSize): int {
|
||||
$thresholdDate = $this->getThresholdDate($daysToInactive);
|
||||
return $this->activateSubscribers($thresholdDate, $batchSize);
|
||||
}
|
||||
|
||||
public function reactivateInactiveSubscribers(): void {
|
||||
$subscribersTable = $this->entityManager->getClassMetadata(SubscriberEntity::class)->getTableName();
|
||||
$reactivateAllInactiveQuery = "
|
||||
UPDATE {$subscribersTable} SET status = :statusSubscribed WHERE status = :statusInactive
|
||||
";
|
||||
$this->entityManager->getConnection()->executeQuery($reactivateAllInactiveQuery, [
|
||||
'statusSubscribed' => SubscriberEntity::STATUS_SUBSCRIBED,
|
||||
'statusInactive' => SubscriberEntity::STATUS_INACTIVE,
|
||||
]);
|
||||
}
|
||||
|
||||
private function getThresholdDate(int $daysToInactive): Carbon {
|
||||
$now = new Carbon();
|
||||
return $now->subDays($daysToInactive);
|
||||
}
|
||||
|
||||
/**
|
||||
* @return int|bool
|
||||
*/
|
||||
private function deactivateSubscribers(Carbon $thresholdDate, int $batchSize, ?int $startId = null) {
|
||||
$subscribersTable = $this->entityManager->getClassMetadata(SubscriberEntity::class)->getTableName();
|
||||
$scheduledTasksTable = $this->entityManager->getClassMetadata(ScheduledTaskEntity::class)->getTableName();
|
||||
$scheduledTaskSubscribersTable = $this->entityManager->getClassMetadata(ScheduledTaskSubscriberEntity::class)->getTableName();
|
||||
$sendingQueuesTable = $this->entityManager->getClassMetadata(SendingQueueEntity::class)->getTableName();
|
||||
$connection = $this->entityManager->getConnection();
|
||||
|
||||
$thresholdDateIso = $thresholdDate->toDateTimeString();
|
||||
$dayAgo = new Carbon();
|
||||
$dayAgoIso = $dayAgo->subDay()->toDateTimeString();
|
||||
|
||||
// If MP2 migration occurred during detection interval we can't deactivate subscribers
|
||||
// because they are imported with original subscription date but they were not present in a list for whole period
|
||||
$mp2MigrationDate = $this->getMP2MigrationDate();
|
||||
if ($mp2MigrationDate && $mp2MigrationDate > $thresholdDate) {
|
||||
return false;
|
||||
}
|
||||
|
||||
// We take into account only emails which have at least one opening tracked
|
||||
// to ensure that tracking was enabled for the particular email
|
||||
$inactiveTaskIdsTable = 'inactive_task_ids';
|
||||
if (!$this->inactiveTaskIdsTableCreated) {
|
||||
$inactiveTaskIdsTableSql = "
|
||||
CREATE TEMPORARY TABLE IF NOT EXISTS {$inactiveTaskIdsTable}
|
||||
(INDEX task_id_ids (id))
|
||||
SELECT DISTINCT task_id as id FROM {$sendingQueuesTable} as sq
|
||||
JOIN {$scheduledTasksTable} as st ON sq.task_id = st.id
|
||||
WHERE st.processed_at > :thresholdDate
|
||||
AND st.processed_at < :dayAgo
|
||||
";
|
||||
$connection->executeQuery($inactiveTaskIdsTableSql, [
|
||||
'thresholdDate' => $thresholdDateIso,
|
||||
'dayAgo' => $dayAgoIso,
|
||||
]);
|
||||
$this->inactiveTaskIdsTableCreated = true;
|
||||
}
|
||||
|
||||
// Select subscribers who received a recent tracked email but didn't open it
|
||||
$startId = (int)$startId;
|
||||
$endId = $startId + $batchSize;
|
||||
$inactiveSubscriberIdsTmpTable = 'inactive_subscriber_ids';
|
||||
$connection->executeQuery("
|
||||
CREATE TEMPORARY TABLE IF NOT EXISTS {$inactiveSubscriberIdsTmpTable}
|
||||
(UNIQUE subscriber_id (id))
|
||||
SELECT DISTINCT s.id FROM {$subscribersTable} as s
|
||||
JOIN {$scheduledTaskSubscribersTable} as sts USE INDEX (subscriber_id) ON s.id = sts.subscriber_id
|
||||
JOIN {$inactiveTaskIdsTable} task_ids ON task_ids.id = sts.task_id
|
||||
WHERE s.last_subscribed_at < :thresholdDate
|
||||
AND s.status = :status
|
||||
AND s.id >= :startId
|
||||
AND s.id < :endId
|
||||
",
|
||||
[
|
||||
'thresholdDate' => $thresholdDateIso,
|
||||
'status' => SubscriberEntity::STATUS_SUBSCRIBED,
|
||||
'startId' => $startId,
|
||||
'endId' => $endId,
|
||||
]);
|
||||
|
||||
$result = $connection->executeQuery("
|
||||
SELECT isi.id FROM {$inactiveSubscriberIdsTmpTable} isi
|
||||
LEFT OUTER JOIN {$subscribersTable} as s ON isi.id = s.id AND GREATEST(
|
||||
COALESCE(s.last_engagement_at, '0'),
|
||||
COALESCE(s.last_subscribed_at, '0'),
|
||||
COALESCE(s.created_at, '0')
|
||||
) > :thresholdDate
|
||||
WHERE s.id IS NULL
|
||||
", [
|
||||
'thresholdDate' => $thresholdDateIso,
|
||||
]);
|
||||
$idsToDeactivate = $result->fetchAllAssociative();
|
||||
|
||||
$connection->executeQuery("DROP TABLE {$inactiveSubscriberIdsTmpTable}");
|
||||
|
||||
$idsToDeactivate = array_map(
|
||||
function ($id) {
|
||||
return (int)$id['id'];
|
||||
},
|
||||
$idsToDeactivate
|
||||
);
|
||||
if (!count($idsToDeactivate)) {
|
||||
return 0;
|
||||
}
|
||||
$connection->executeQuery("UPDATE {$subscribersTable} SET status = :statusInactive WHERE id IN (:idsToDeactivate)", [
|
||||
'statusInactive' => SubscriberEntity::STATUS_INACTIVE,
|
||||
'idsToDeactivate' => $idsToDeactivate,
|
||||
], ['idsToDeactivate' => Connection::PARAM_INT_ARRAY]);
|
||||
return count($idsToDeactivate);
|
||||
}
|
||||
|
||||
private function activateSubscribers(Carbon $thresholdDate, int $batchSize): int {
|
||||
$subscribersTable = $this->entityManager->getClassMetadata(SubscriberEntity::class)->getTableName();
|
||||
$connection = $this->entityManager->getConnection();
|
||||
|
||||
$mp2MigrationDate = $this->getMP2MigrationDate();
|
||||
if ($mp2MigrationDate && $mp2MigrationDate > $thresholdDate) {
|
||||
// If MP2 migration occurred during detection interval re-activate all subscribers created before migration
|
||||
$idsToActivate = $connection->executeQuery("
|
||||
SELECT id
|
||||
FROM {$subscribersTable}
|
||||
WHERE created_at < :migrationDate
|
||||
AND status = :statusInactive
|
||||
LIMIT :batchSize
|
||||
", [
|
||||
'migrationDate' => $mp2MigrationDate,
|
||||
'statusInactive' => SubscriberEntity::STATUS_INACTIVE,
|
||||
'batchSize' => $batchSize,
|
||||
], ['batchSize' => \PDO::PARAM_INT])->fetchAllAssociative();
|
||||
} else {
|
||||
$idsToActivate = $connection->executeQuery("
|
||||
SELECT s.id
|
||||
FROM {$subscribersTable} s
|
||||
LEFT OUTER JOIN {$subscribersTable} s2 ON s.id = s2.id AND GREATEST(
|
||||
COALESCE(s2.last_engagement_at, '0'),
|
||||
COALESCE(s2.last_subscribed_at, '0'),
|
||||
COALESCE(s2.created_at, '0')
|
||||
) > :thresholdDate
|
||||
WHERE s.last_subscribed_at < :thresholdDate
|
||||
AND s.status = :statusInactive
|
||||
AND s2.id IS NOT NULL
|
||||
GROUP BY s.id
|
||||
LIMIT :batchSize
|
||||
", [
|
||||
'thresholdDate' => $thresholdDate,
|
||||
'statusInactive' => SubscriberEntity::STATUS_INACTIVE,
|
||||
'batchSize' => $batchSize,
|
||||
], ['batchSize' => \PDO::PARAM_INT])->fetchAllAssociative();
|
||||
}
|
||||
|
||||
$idsToActivate = array_map(
|
||||
function($id) {
|
||||
return (int)$id['id'];
|
||||
}, $idsToActivate
|
||||
);
|
||||
if (!count($idsToActivate)) {
|
||||
return 0;
|
||||
}
|
||||
$connection->executeQuery("UPDATE {$subscribersTable} SET status = :statusSubscribed WHERE id IN (:idsToActivate)", [
|
||||
'statusSubscribed' => SubscriberEntity::STATUS_SUBSCRIBED,
|
||||
'idsToActivate' => $idsToActivate,
|
||||
], ['idsToActivate' => Connection::PARAM_INT_ARRAY]);
|
||||
return count($idsToActivate);
|
||||
}
|
||||
|
||||
private function getMP2MigrationDate() {
|
||||
$setting = $this->settingsRepository->findOneByName(MP2Migrator::MIGRATION_COMPLETE_SETTING_KEY);
|
||||
return $setting ? Carbon::instance($setting->getCreatedAt()) : null;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user