uniqueByMessageId

Author: tatevikg1

src/Domain/Analytics/Repository/UserMessageViewRepository.php

@@ -23,6 +23,16 @@ public function countByMessageId(int $messageId): int
             ->getSingleScalarResult();
     }
 
+    public function uniqueByMessageId(int $messageId): int
+    {
+        return (int) $this->createQueryBuilder('umv')
+            ->select('COUNT(DISTINCT umv.ip)')
+            ->where('umv.messageId = :messageId')
+            ->setParameter('messageId', $messageId)
+            ->getQuery()
+            ->getSingleScalarResult();
+    }
+
     /**
      * Counts views between two dates.
      *

src/Domain/Analytics/Service/AnalyticsService.php

@@ -56,6 +56,7 @@ public function getCampaignStatistics(int $limit = 50, int $lastId = 0): array
         $campaignStats = [];
         foreach ($messages as $message) {
             $views = $this->userMessageViewManager->countViewsByMessageId($message->getId());
+            $uniqueViews = $this->userMessageViewManager->countUniqueViewsByMessageId($message->getId());
             $linkTracks = $this->linkTrackManager->getLinkTracksByMessageId($message->getId());
 
             $totalClicks = 0;
@@ -79,7 +80,7 @@ public function getCampaignStatistics(int $limit = 50, int $lastId = 0): array
                 'sent' => $sentCount,
                 'bounces' => $bounces,
                 'forwards' => $forwards,
-                'uniqueViews' => $views,
+                'uniqueViews' => $uniqueViews,
                 'totalClicks' => $totalClicks,
                 'uniqueClicks' => $uniqueClicks,
             ];

src/Domain/Analytics/Service/Manager/UserMessageViewManager.php

@@ -25,6 +25,11 @@ public function countViewsByMessageId(int $messageId): int
         return $this->userMessageViewRepository->countByMessageId($messageId);
     }
 
+    public function countUniqueViewsByMessageId(int $messageId): int
+    {
+        return $this->userMessageViewRepository->uniqueByMessageId($messageId);
+    }
+
     public function countViewsBetween(DateTimeInterface $start, DateTimeInterface $end): int
     {
         return $this->userMessageViewRepository->countBetween($start, $end);

tests/Unit/Domain/Analytics/Service/AnalyticsServiceTest.php

@@ -98,6 +98,11 @@ public function testGetCampaignStatistics(): void
             ->with($messageId)
             ->willReturn(10);
 
+        $this->userMessageViewManager->expects(self::once())
+            ->method('countUniqueViewsByMessageId')
+            ->with($messageId)
+            ->willReturn(3);
+
         $this->linkTrackManager->expects(self::once())
             ->method('getLinkTracksByMessageId')
             ->with($messageId)
@@ -128,7 +133,7 @@ public function testGetCampaignStatistics(): void
         self::assertSame(15, $campaign['sent']);
         self::assertSame(3, $campaign['bounces']);
         self::assertSame(2, $campaign['forwards']);
-        self::assertSame(10, $campaign['uniqueViews']);
+        self::assertSame(3, $campaign['uniqueViews']);
         self::assertSame(5, $campaign['totalClicks']);
         self::assertSame(2, $campaign['uniqueClicks']);
     }