Track
4 days ago
GATracking.php
6 months ago
StatisticsBouncesRepository.php
3 years ago
StatisticsClicksRepository.php
2 years ago
StatisticsFormsRepository.php
3 years ago
StatisticsNewslettersRepository.php
1 year ago
StatisticsOpensRepository.php
3 days ago
StatisticsUnsubscribesRepository.php
2 months ago
StatisticsWooCommercePurchasesRepository.php
1 year ago
UnsubscribeReasonTracker.php
2 months ago
UserAgentsRepository.php
1 year ago
index.php
3 years ago
StatisticsOpensRepository.php
167 lines
| 1 | <?php declare(strict_types = 1); |
| 2 | |
| 3 | namespace MailPoet\Statistics; |
| 4 | |
| 5 | if (!defined('ABSPATH')) exit; |
| 6 | |
| 7 | |
| 8 | use MailPoet\Doctrine\Repository; |
| 9 | use MailPoet\Entities\SegmentEntity; |
| 10 | use MailPoet\Entities\StatisticsNewsletterEntity; |
| 11 | use MailPoet\Entities\StatisticsOpenEntity; |
| 12 | use MailPoet\Entities\SubscriberEntity; |
| 13 | use MailPoet\Entities\UserAgentEntity; |
| 14 | use MailPoet\Settings\TrackingConfig; |
| 15 | use MailPoet\Subscribers\Statistics\SubscriberStatisticsRepository; |
| 16 | use MailPoetVendor\Doctrine\DBAL\ArrayParameterType; |
| 17 | use MailPoetVendor\Doctrine\ORM\EntityManager; |
| 18 | use MailPoetVendor\Doctrine\ORM\QueryBuilder; |
| 19 | |
| 20 | /** |
| 21 | * @extends Repository<StatisticsOpenEntity> |
| 22 | */ |
| 23 | class StatisticsOpensRepository extends Repository { |
| 24 | /** @var TrackingConfig */ |
| 25 | private $trackingConfig; |
| 26 | |
| 27 | public function __construct( |
| 28 | EntityManager $entityManager, |
| 29 | TrackingConfig $trackingConfig |
| 30 | ) { |
| 31 | parent::__construct($entityManager); |
| 32 | $this->entityManager = $entityManager; |
| 33 | $this->trackingConfig = $trackingConfig; |
| 34 | } |
| 35 | |
| 36 | protected function getEntityClassName(): string { |
| 37 | return StatisticsOpenEntity::class; |
| 38 | } |
| 39 | |
| 40 | public function recalculateSubscriberScore(SubscriberEntity $subscriber): void { |
| 41 | $subscriberId = $subscriber->getId(); |
| 42 | if (!$subscriberId) { |
| 43 | return; |
| 44 | } |
| 45 | $this->recalculateSubscribersScore([$subscriberId]); |
| 46 | } |
| 47 | |
| 48 | /** |
| 49 | * Recalculates and persists engagement scores in a single bulk UPDATE. Runs entirely |
| 50 | * in SQL so large batches avoid entity hydration, validation, and per-entity flushes. |
| 51 | * In-memory SubscriberEntity instances are not refreshed and keep stale score fields. |
| 52 | * |
| 53 | * @param int[] $subscriberIds |
| 54 | */ |
| 55 | public function recalculateSubscribersScore(array $subscriberIds): void { |
| 56 | if (!$subscriberIds) { |
| 57 | return; |
| 58 | } |
| 59 | $subscribersTable = $this->entityManager->getClassMetadata(SubscriberEntity::class)->getTableName(); |
| 60 | $sentStatsTable = $this->entityManager->getClassMetadata(StatisticsNewsletterEntity::class)->getTableName(); |
| 61 | $openStatsTable = $this->entityManager->getClassMetadata(StatisticsOpenEntity::class)->getTableName(); |
| 62 | $humanOpensCondition = $this->trackingConfig->areOpensSeparated() ? ' AND so.user_agent_type = :userAgentType' : ''; |
| 63 | |
| 64 | $sql = " |
| 65 | UPDATE {$subscribersTable} s |
| 66 | LEFT JOIN ( |
| 67 | SELECT subscriber_id, COUNT(DISTINCT newsletter_id) AS sent_count |
| 68 | FROM {$sentStatsTable} |
| 69 | WHERE subscriber_id IN (:ids) AND sent_at >= :yearAgo |
| 70 | GROUP BY subscriber_id |
| 71 | ) sent ON sent.subscriber_id = s.id |
| 72 | LEFT JOIN ( |
| 73 | SELECT so.subscriber_id, COUNT(DISTINCT so.newsletter_id) AS open_count |
| 74 | FROM {$openStatsTable} so |
| 75 | JOIN {$sentStatsTable} sn |
| 76 | ON sn.newsletter_id = so.newsletter_id |
| 77 | AND sn.subscriber_id = so.subscriber_id |
| 78 | AND sn.sent_at >= :yearAgo |
| 79 | WHERE so.subscriber_id IN (:ids){$humanOpensCondition} |
| 80 | GROUP BY so.subscriber_id |
| 81 | ) opens ON opens.subscriber_id = s.id |
| 82 | SET s.engagement_score = CASE |
| 83 | WHEN COALESCE(sent.sent_count, 0) < :minSentCount THEN NULL |
| 84 | ELSE COALESCE(opens.open_count, 0) / sent.sent_count * 100 |
| 85 | END, |
| 86 | s.engagement_score_updated_at = :now |
| 87 | WHERE s.id IN (:ids) |
| 88 | "; |
| 89 | |
| 90 | $parameters = [ |
| 91 | 'ids' => array_map('intval', $subscriberIds), |
| 92 | 'yearAgo' => (new \DateTimeImmutable('-1 year'))->format('Y-m-d H:i:s'), |
| 93 | 'minSentCount' => SubscriberStatisticsRepository::MIN_SENT_EMAILS_FOR_ENGAGEMENT_SCORE, |
| 94 | 'now' => (new \DateTimeImmutable())->format('Y-m-d H:i:s'), |
| 95 | ]; |
| 96 | if ($humanOpensCondition) { |
| 97 | $parameters['userAgentType'] = UserAgentEntity::USER_AGENT_TYPE_HUMAN; |
| 98 | } |
| 99 | $this->entityManager->getConnection()->executeStatement( |
| 100 | $sql, |
| 101 | $parameters, |
| 102 | ['ids' => ArrayParameterType::INTEGER] |
| 103 | ); |
| 104 | } |
| 105 | |
| 106 | public function resetSubscribersScoreCalculation() { |
| 107 | $this->entityManager->createQueryBuilder()->update(SubscriberEntity::class, 's') |
| 108 | ->set('s.engagementScoreUpdatedAt', ':updatedAt') |
| 109 | ->setParameter('updatedAt', null) |
| 110 | ->getQuery()->execute(); |
| 111 | } |
| 112 | |
| 113 | public function recalculateSegmentScore(SegmentEntity $segment): void { |
| 114 | $segment->setAverageEngagementScoreUpdatedAt(new \DateTimeImmutable()); |
| 115 | $avgScore = $this |
| 116 | ->entityManager |
| 117 | ->createQueryBuilder() |
| 118 | ->select('avg(subscriber.engagementScore)') |
| 119 | ->from(SubscriberEntity::class, 'subscriber') |
| 120 | ->join('subscriber.subscriberSegments', 'subscriberSegments') |
| 121 | ->where('subscriberSegments.segment = :segment') |
| 122 | ->andWhere('subscriber.status = :subscribed') |
| 123 | ->andWhere('subscriber.deletedAt IS NULL') |
| 124 | ->andWhere('subscriberSegments.status = :subscribed') |
| 125 | ->setParameter('segment', $segment) |
| 126 | ->setParameter('subscribed', SubscriberEntity::STATUS_SUBSCRIBED) |
| 127 | ->getQuery() |
| 128 | ->getSingleScalarResult(); |
| 129 | $segment->setAverageEngagementScore($avgScore === null ? $avgScore : (float)$avgScore); |
| 130 | $this->entityManager->flush(); |
| 131 | } |
| 132 | |
| 133 | public function resetSegmentsScoreCalculation(): void { |
| 134 | $this->entityManager->createQueryBuilder()->update(SegmentEntity::class, 's') |
| 135 | ->set('s.averageEngagementScoreUpdatedAt', ':updatedAt') |
| 136 | ->setParameter('updatedAt', null) |
| 137 | ->getQuery()->execute(); |
| 138 | } |
| 139 | |
| 140 | public function getAllForSubscriber(SubscriberEntity $subscriber): QueryBuilder { |
| 141 | return $this->entityManager->createQueryBuilder() |
| 142 | ->select('opens.id id, queue.newsletterRenderedSubject, opens.createdAt, userAgent.userAgent') |
| 143 | ->from(StatisticsOpenEntity::class, 'opens') |
| 144 | ->join('opens.queue', 'queue') |
| 145 | ->leftJoin('opens.userAgent', 'userAgent') |
| 146 | ->where('opens.subscriber = :subscriber') |
| 147 | ->orderBy('queue.newsletterRenderedSubject') |
| 148 | ->setParameter('subscriber', $subscriber->getId()); |
| 149 | } |
| 150 | |
| 151 | /** @param int[] $ids */ |
| 152 | public function deleteByNewsletterIds(array $ids): void { |
| 153 | $this->entityManager->createQueryBuilder() |
| 154 | ->delete(StatisticsOpenEntity::class, 's') |
| 155 | ->where('s.newsletter IN (:ids)') |
| 156 | ->setParameter('ids', $ids) |
| 157 | ->getQuery() |
| 158 | ->execute(); |
| 159 | |
| 160 | // delete was done via DQL, make sure the entities are also detached from the entity manager |
| 161 | $this->detachAll(function (StatisticsOpenEntity $entity) use ($ids) { |
| 162 | $newsletter = $entity->getNewsletter(); |
| 163 | return $newsletter && in_array($newsletter->getId(), $ids, true); |
| 164 | }); |
| 165 | } |
| 166 | } |
| 167 |