FileMaster

Edit File: ReporterCampaignData.php

<?php declare(strict_types = 1);

namespace MailPoet\Analytics;

if (!defined('ABSPATH')) exit;

use MailPoet\Entities\NewsletterEntity;
use MailPoet\Newsletter\Sending\SendingQueuesRepository;
use MailPoet\UnexpectedValueException;

class ReporterCampaignData {

const STANDARD_7_DAYS = 'Number of standard newsletters sent in last 7 days';
  const STANDARD_30_DAYS = 'Number of standard newsletters sent in last 30 days';
  const STANDARD_3_MONTHS = 'Number of standard newsletters sent in last 3 months';
  const STANDARD_SEGMENT_7_DAYS = 'Number of standard newsletters sent to segment in last 7 days';
  const STANDARD_SEGMENT_30_DAYS = 'Number of standard newsletters sent to segment in last 30 days';
  const STANDARD_SEGMENT_3_MONTHS = 'Number of standard newsletters sent to segment in last 3 months';
  const STANDARD_FILTERED_SEGMENT_7_DAYS = 'Number of standard newsletters filtered by segment in last 7 days';
  const STANDARD_FILTERED_SEGMENT_30_DAYS = 'Number of standard newsletters filtered by segment in last 30 days';
  const STANDARD_FILTERED_SEGMENT_3_MONTHS = 'Number of standard newsletters filtered by segment in last 3 months';
  const AUTOMATION_7_DAYS = 'Number of automations campaigns sent in the last 7 days';
  const AUTOMATION_30_DAYS = 'Number of automations campaigns sent in the last 30 days';
  const AUTOMATION_3_MONTHS = 'Number of automations campaigns sent in the last 3 months';
  const RE_ENGAGEMENT_7_DAYS = 'Number of re-engagement campaigns sent in the last 7 days';
  const RE_ENGAGEMENT_30_DAYS = 'Number of re-engagement campaigns sent in the last 30 days';
  const RE_ENGAGEMENT_3_MONTHS = 'Number of re-engagement campaigns sent in the last 3 months';
  const RE_ENGAGEMENT_SEGMENT_7_DAYS = 'Number of re-engagement campaigns sent to segment in the last 7 days';
  const RE_ENGAGEMENT_SEGMENT_30_DAYS = 'Number of re-engagement campaigns sent to segment in the last 30 days';
  const RE_ENGAGEMENT_SEGMENT_3_MONTHS = 'Number of re-engagement campaigns sent to segment in the last 3 months';
  const RE_ENGAGEMENT_FILTERED_SEGMENT_7_DAYS = 'Number of re-engagement campaigns filtered by segment in the last 7 days';
  const RE_ENGAGEMENT_FILTERED_SEGMENT_30_DAYS = 'Number of re-engagement campaigns filtered by segment in the last 30 days';
  const RE_ENGAGEMENT_FILTERED_SEGMENT_3_MONTHS = 'Number of re-engagement campaigns filtered by segment in the last 3 months';
  const POST_NOTIFICATION_7_DAYS = 'Number of post notification campaigns sent in the last 7 days';
  const POST_NOTIFICATION_30_DAYS = 'Number of post notification campaigns sent in the last 30 days';
  const POST_NOTIFICATION_3_MONTHS = 'Number of post notification campaigns sent in the last 3 months';
  const POST_NOTIFICATION_SEGMENT_7_DAYS = 'Number of post notification campaigns sent to segment in the last 7 days';
  const POST_NOTIFICATION_SEGMENT_30_DAYS = 'Number of post notification campaigns sent to segment in the last 30 days';
  const POST_NOTIFICATION_SEGMENT_3_MONTHS = 'Number of post notification campaigns sent to segment in the last 3 months';
  const POST_NOTIFICATION_FILTERED_SEGMENT_7_DAYS = 'Number of post notification campaigns filtered by segment in the last 7 days';
  const POST_NOTIFICATION_FILTERED_SEGMENT_30_DAYS = 'Number of post notification campaigns filtered by segment in the last 30 days';
  const POST_NOTIFICATION_FILTERED_SEGMENT_3_MONTHS = 'Number of post notification campaigns filtered by segment in the last 3 months';

const LEGACY_WELCOME_7_DAYS = 'Number of legacy welcome email campaigns sent in the last 7 days';
  const LEGACY_WELCOME_30_DAYS = 'Number of legacy welcome email campaigns sent in the last 30 days';
  const LEGACY_WELCOME_3_MONTHS = 'Number of legacy welcome email campaigns sent in the last 3 months';

const LEGACY_ABANDONED_CART_7_DAYS = 'Number of legacy abandoned cart campaigns sent in the last 7 days';
  const LEGACY_ABANDONED_CART_30_DAYS = 'Number of legacy abandoned cart campaigns sent in the last 30 days';
  const LEGACY_ABANDONED_CART_3_MONTHS = 'Number of legacy abandoned cart campaigns sent in the last 3 months';

const LEGACY_FIRST_PURCHASE_7_DAYS = 'Number of legacy first purchase campaigns sent in the last 7 days';
  const LEGACY_FIRST_PURCHASE_30_DAYS = 'Number of legacy first purchase campaigns sent in the last 30 days';
  const LEGACY_FIRST_PURCHASE_3_MONTHS = 'Number of legacy first purchase campaigns sent in the last 3 months';

const LEGACY_PURCHASED_IN_CATEGORY_7_DAYS = 'Number of legacy purchased in category campaigns sent in the last 7 days';
  const LEGACY_PURCHASED_IN_CATEGORY_30_DAYS = 'Number of legacy purchased in category campaigns sent in the last 30 days';
  const LEGACY_PURCHASED_IN_CATEGORY_3_MONTHS = 'Number of legacy purchased in category campaigns sent in the last 3 months';

const LEGACY_PURCHASED_PRODUCT_7_DAYS = 'Number of legacy purchased product campaigns sent in the last 7 days';
  const LEGACY_PURCHASED_PRODUCT_30_DAYS = 'Number of legacy purchased product campaigns sent in the last 30 days';
  const LEGACY_PURCHASED_PRODUCT_3_MONTHS = 'Number of legacy purchased product campaigns sent in the last 3 months';

const TOTAL_CAMPAIGNS_7_DAYS = 'Number of campaigns sent in the last 7 days';
  const TOTAL_CAMPAIGNS_30_DAYS = 'Number of campaigns sent in the last 30 days';
  const TOTAL_CAMPAIGNS_3_MONTHS = 'Number of campaigns sent in the last 3 months';

const TOTAL_CAMPAIGNS_SEGMENT_7_DAYS = 'Number of campaigns sent to segment in the last 7 days';
  const TOTAL_CAMPAIGNS_SEGMENT_30_DAYS = 'Number of campaigns sent to segment in the last 30 days';
  const TOTAL_CAMPAIGNS_SEGMENT_3_MONTHS = 'Number of campaigns sent to segment in the last 3 months';

const TOTAL_CAMPAIGNS_FILTERED_SEGMENT_7_DAYS = 'Number of campaigns filtered by segment in the last 7 days';
  const TOTAL_CAMPAIGNS_FILTERED_SEGMENT_30_DAYS = 'Number of campaigns filtered by segment in the last 30 days';
  const TOTAL_CAMPAIGNS_FILTERED_SEGMENT_3_MONTHS = 'Number of campaigns filtered by segment in the last 3 months';

/** @var SendingQueuesRepository */
  private $sendingQueuesRepository;

public function __construct(
    SendingQueuesRepository $sendingQueuesRepository
  ) {
    $this->sendingQueuesRepository = $sendingQueuesRepository;
  }

public function getCampaignAnalyticsProperties(): array {
    $returnData = [
      self::STANDARD_7_DAYS => 0,
      self::STANDARD_30_DAYS => 0,
      self::STANDARD_3_MONTHS => 0,

self::STANDARD_SEGMENT_7_DAYS => 0,
      self::STANDARD_SEGMENT_30_DAYS => 0,
      self::STANDARD_SEGMENT_3_MONTHS => 0,

self::STANDARD_FILTERED_SEGMENT_7_DAYS => 0,
      self::STANDARD_FILTERED_SEGMENT_30_DAYS => 0,
      self::STANDARD_FILTERED_SEGMENT_3_MONTHS => 0,

self::AUTOMATION_7_DAYS => 0,
      self::AUTOMATION_30_DAYS => 0,
      self::AUTOMATION_3_MONTHS => 0,

self::RE_ENGAGEMENT_7_DAYS => 0,
      self::RE_ENGAGEMENT_30_DAYS => 0,
      self::RE_ENGAGEMENT_3_MONTHS => 0,

self::RE_ENGAGEMENT_SEGMENT_7_DAYS => 0,
      self::RE_ENGAGEMENT_SEGMENT_30_DAYS => 0,
      self::RE_ENGAGEMENT_SEGMENT_3_MONTHS => 0,

self::RE_ENGAGEMENT_FILTERED_SEGMENT_7_DAYS => 0,
      self::RE_ENGAGEMENT_FILTERED_SEGMENT_30_DAYS => 0,
      self::RE_ENGAGEMENT_FILTERED_SEGMENT_3_MONTHS => 0,

self::POST_NOTIFICATION_7_DAYS => 0,
      self::POST_NOTIFICATION_30_DAYS => 0,
      self::POST_NOTIFICATION_3_MONTHS => 0,

self::POST_NOTIFICATION_SEGMENT_7_DAYS => 0,
      self::POST_NOTIFICATION_SEGMENT_30_DAYS => 0,
      self::POST_NOTIFICATION_SEGMENT_3_MONTHS => 0,

self::POST_NOTIFICATION_FILTERED_SEGMENT_7_DAYS => 0,
      self::POST_NOTIFICATION_FILTERED_SEGMENT_30_DAYS => 0,
      self::POST_NOTIFICATION_FILTERED_SEGMENT_3_MONTHS => 0,

// Legacy
      self::LEGACY_WELCOME_7_DAYS => 0,
      self::LEGACY_WELCOME_30_DAYS => 0,
      self::LEGACY_WELCOME_3_MONTHS => 0,

self::LEGACY_ABANDONED_CART_7_DAYS => 0,
      self::LEGACY_ABANDONED_CART_30_DAYS => 0,
      self::LEGACY_ABANDONED_CART_3_MONTHS => 0,

self::LEGACY_FIRST_PURCHASE_7_DAYS => 0,
      self::LEGACY_FIRST_PURCHASE_30_DAYS => 0,
      self::LEGACY_FIRST_PURCHASE_3_MONTHS => 0,

self::LEGACY_PURCHASED_IN_CATEGORY_7_DAYS => 0,
      self::LEGACY_PURCHASED_IN_CATEGORY_30_DAYS => 0,
      self::LEGACY_PURCHASED_IN_CATEGORY_3_MONTHS => 0,

self::LEGACY_PURCHASED_PRODUCT_7_DAYS => 0,
      self::LEGACY_PURCHASED_PRODUCT_30_DAYS => 0,
      self::LEGACY_PURCHASED_PRODUCT_3_MONTHS => 0,

// Totals
      self::TOTAL_CAMPAIGNS_7_DAYS => 0,
      self::TOTAL_CAMPAIGNS_30_DAYS => 0,
      self::TOTAL_CAMPAIGNS_3_MONTHS => 0,
      self::TOTAL_CAMPAIGNS_SEGMENT_7_DAYS => 0,
      self::TOTAL_CAMPAIGNS_SEGMENT_30_DAYS => 0,
      self::TOTAL_CAMPAIGNS_SEGMENT_3_MONTHS => 0,
      self::TOTAL_CAMPAIGNS_FILTERED_SEGMENT_7_DAYS => 0,
      self::TOTAL_CAMPAIGNS_FILTERED_SEGMENT_30_DAYS => 0,
      self::TOTAL_CAMPAIGNS_FILTERED_SEGMENT_3_MONTHS => 0,
    ];

$processedResults = $this->getProcessedCampaignAnalytics();

foreach ($processedResults as $campaignId => $processedResult) {
      $isNewerThan7DaysAgo = $processedResult['sentLast7Days'] ?? false;
      $isNewerThan30DaysAgo = $processedResult['sentLast30Days'] ?? false;
      $isNewerThan3MonthsAgo = $processedResult['sentLast3Months'] ?? false;

$newsletterType = $processedResult['newsletterType'];

$wasSentToDynamicSegment = $processedResult['sentToSegment'] ?? false;
      $wasFilteredBySegment = $processedResult['filteredBySegment'] ?? false;

// Totals
      if ($isNewerThan7DaysAgo) {
        $returnData[self::TOTAL_CAMPAIGNS_7_DAYS]++;
        $returnData[self::TOTAL_CAMPAIGNS_30_DAYS]++;
        $returnData[self::TOTAL_CAMPAIGNS_3_MONTHS]++;
        if ($wasSentToDynamicSegment) {
          $returnData[self::TOTAL_CAMPAIGNS_SEGMENT_7_DAYS]++;
          $returnData[self::TOTAL_CAMPAIGNS_SEGMENT_30_DAYS]++;
          $returnData[self::TOTAL_CAMPAIGNS_SEGMENT_3_MONTHS]++;
        }
        if ($wasFilteredBySegment) {
          $returnData[self::TOTAL_CAMPAIGNS_FILTERED_SEGMENT_7_DAYS]++;
          $returnData[self::TOTAL_CAMPAIGNS_FILTERED_SEGMENT_30_DAYS]++;
          $returnData[self::TOTAL_CAMPAIGNS_FILTERED_SEGMENT_3_MONTHS]++;
        }
      } elseif ($isNewerThan30DaysAgo) {
        $returnData[self::TOTAL_CAMPAIGNS_30_DAYS]++;
        $returnData[self::TOTAL_CAMPAIGNS_3_MONTHS]++;
        if ($wasSentToDynamicSegment) {
          $returnData[self::TOTAL_CAMPAIGNS_SEGMENT_30_DAYS]++;
          $returnData[self::TOTAL_CAMPAIGNS_SEGMENT_3_MONTHS]++;
        }
        if ($wasFilteredBySegment) {
          $returnData[self::TOTAL_CAMPAIGNS_FILTERED_SEGMENT_30_DAYS]++;
          $returnData[self::TOTAL_CAMPAIGNS_FILTERED_SEGMENT_3_MONTHS]++;
        }
      } elseif ($isNewerThan3MonthsAgo) {
        $returnData[self::TOTAL_CAMPAIGNS_3_MONTHS]++;
        if ($wasSentToDynamicSegment) {
          $returnData[self::TOTAL_CAMPAIGNS_SEGMENT_3_MONTHS]++;
        }
        if ($wasFilteredBySegment) {
          $returnData[self::TOTAL_CAMPAIGNS_FILTERED_SEGMENT_3_MONTHS]++;
        }
      }

switch ($newsletterType) {
        case NewsletterEntity::TYPE_STANDARD:
          if ($isNewerThan7DaysAgo) {
            $returnData[self::STANDARD_7_DAYS]++;
            $returnData[self::STANDARD_30_DAYS]++;
            $returnData[self::STANDARD_3_MONTHS]++;
            if ($wasFilteredBySegment) {
              $returnData[self::STANDARD_FILTERED_SEGMENT_7_DAYS]++;
              $returnData[self::STANDARD_FILTERED_SEGMENT_30_DAYS]++;
              $returnData[self::STANDARD_FILTERED_SEGMENT_3_MONTHS]++;
            }
            if ($wasSentToDynamicSegment) {
              $returnData[self::STANDARD_SEGMENT_7_DAYS]++;
              $returnData[self::STANDARD_SEGMENT_30_DAYS]++;
              $returnData[self::STANDARD_SEGMENT_3_MONTHS]++;
            }
          } elseif ($isNewerThan30DaysAgo) {
            $returnData[self::STANDARD_30_DAYS]++;
            $returnData[self::STANDARD_3_MONTHS]++;
            if ($wasFilteredBySegment) {
              $returnData[self::STANDARD_FILTERED_SEGMENT_30_DAYS]++;
              $returnData[self::STANDARD_FILTERED_SEGMENT_3_MONTHS]++;
            }
            if ($wasSentToDynamicSegment) {
              $returnData[self::STANDARD_SEGMENT_30_DAYS]++;
              $returnData[self::STANDARD_SEGMENT_3_MONTHS]++;
            }
          } elseif ($isNewerThan3MonthsAgo) {
            $returnData[self::STANDARD_3_MONTHS]++;
            if ($wasFilteredBySegment) {
              $returnData[self::STANDARD_FILTERED_SEGMENT_3_MONTHS]++;
            }
            if ($wasSentToDynamicSegment) {
              $returnData[self::STANDARD_SEGMENT_3_MONTHS]++;
            }
          }
          break;
        case NewsletterEntity::TYPE_NOTIFICATION_HISTORY:
          if ($isNewerThan7DaysAgo) {
            $returnData[self::POST_NOTIFICATION_7_DAYS]++;
            $returnData[self::POST_NOTIFICATION_30_DAYS]++;
            $returnData[self::POST_NOTIFICATION_3_MONTHS]++;
            if ($wasSentToDynamicSegment) {
              $returnData[self::POST_NOTIFICATION_SEGMENT_7_DAYS]++;
              $returnData[self::POST_NOTIFICATION_SEGMENT_30_DAYS]++;
              $returnData[self::POST_NOTIFICATION_SEGMENT_3_MONTHS]++;
            }
            if ($wasFilteredBySegment) {
              $returnData[self::POST_NOTIFICATION_FILTERED_SEGMENT_7_DAYS]++;
              $returnData[self::POST_NOTIFICATION_FILTERED_SEGMENT_30_DAYS]++;
              $returnData[self::POST_NOTIFICATION_FILTERED_SEGMENT_3_MONTHS]++;
            }
          } elseif ($isNewerThan30DaysAgo) {
            $returnData[self::POST_NOTIFICATION_30_DAYS]++;
            $returnData[self::POST_NOTIFICATION_3_MONTHS]++;
            if ($wasSentToDynamicSegment) {
              $returnData[self::POST_NOTIFICATION_SEGMENT_30_DAYS]++;
              $returnData[self::POST_NOTIFICATION_SEGMENT_3_MONTHS]++;
            }
            if ($wasFilteredBySegment) {
              $returnData[self::POST_NOTIFICATION_FILTERED_SEGMENT_30_DAYS]++;
              $returnData[self::POST_NOTIFICATION_FILTERED_SEGMENT_3_MONTHS]++;
            }
          } elseif ($isNewerThan3MonthsAgo) {
            $returnData[self::POST_NOTIFICATION_3_MONTHS]++;
            if ($wasSentToDynamicSegment) {
              $returnData[self::POST_NOTIFICATION_SEGMENT_3_MONTHS]++;
            }
            if ($wasFilteredBySegment) {
              $returnData[self::POST_NOTIFICATION_FILTERED_SEGMENT_3_MONTHS]++;
            }
          }
          break;
        case NewsletterEntity::TYPE_RE_ENGAGEMENT:
          if ($isNewerThan7DaysAgo) {
            $returnData[self::RE_ENGAGEMENT_7_DAYS]++;
            $returnData[self::RE_ENGAGEMENT_30_DAYS]++;
            $returnData[self::RE_ENGAGEMENT_3_MONTHS]++;
            if ($wasSentToDynamicSegment) {
              $returnData[self::RE_ENGAGEMENT_SEGMENT_7_DAYS]++;
              $returnData[self::RE_ENGAGEMENT_SEGMENT_30_DAYS]++;
              $returnData[self::RE_ENGAGEMENT_SEGMENT_3_MONTHS]++;
            }
            if ($wasFilteredBySegment) {
              $returnData[self::RE_ENGAGEMENT_FILTERED_SEGMENT_7_DAYS]++;
              $returnData[self::RE_ENGAGEMENT_FILTERED_SEGMENT_30_DAYS]++;
              $returnData[self::RE_ENGAGEMENT_FILTERED_SEGMENT_3_MONTHS]++;
            }
          } elseif ($isNewerThan30DaysAgo) {
            $returnData[self::RE_ENGAGEMENT_30_DAYS]++;
            $returnData[self::RE_ENGAGEMENT_3_MONTHS]++;
            if ($wasSentToDynamicSegment) {
              $returnData[self::RE_ENGAGEMENT_SEGMENT_30_DAYS]++;
              $returnData[self::RE_ENGAGEMENT_SEGMENT_3_MONTHS]++;
            }
            if ($wasFilteredBySegment) {
              $returnData[self::RE_ENGAGEMENT_FILTERED_SEGMENT_30_DAYS]++;
              $returnData[self::RE_ENGAGEMENT_FILTERED_SEGMENT_3_MONTHS]++;
            }
          } elseif ($isNewerThan3MonthsAgo) {
            $returnData[self::RE_ENGAGEMENT_3_MONTHS]++;
            if ($wasSentToDynamicSegment) {
              $returnData[self::RE_ENGAGEMENT_SEGMENT_3_MONTHS]++;
            }
            if ($wasFilteredBySegment) {
              $returnData[self::RE_ENGAGEMENT_FILTERED_SEGMENT_3_MONTHS]++;
            }
          }
          break;
        case NewsletterEntity::TYPE_WELCOME:
          if ($isNewerThan7DaysAgo) {
            $returnData[self::LEGACY_WELCOME_7_DAYS]++;
            $returnData[self::LEGACY_WELCOME_30_DAYS]++;
            $returnData[self::LEGACY_WELCOME_3_MONTHS]++;
          } elseif ($isNewerThan30DaysAgo) {
            $returnData[self::LEGACY_WELCOME_30_DAYS]++;
            $returnData[self::LEGACY_WELCOME_3_MONTHS]++;
          } elseif ($isNewerThan3MonthsAgo) {
            $returnData[self::LEGACY_WELCOME_3_MONTHS]++;
          }
          break;
        case NewsletterEntity::TYPE_AUTOMATION:
          if ($isNewerThan7DaysAgo) {
            $returnData[self::AUTOMATION_7_DAYS]++;
            $returnData[self::AUTOMATION_30_DAYS]++;
            $returnData[self::AUTOMATION_3_MONTHS]++;
          } elseif ($isNewerThan30DaysAgo) {
            $returnData[self::AUTOMATION_30_DAYS]++;
            $returnData[self::AUTOMATION_3_MONTHS]++;
          } elseif ($isNewerThan3MonthsAgo) {
            $returnData[self::AUTOMATION_3_MONTHS]++;
          }
          break;
        // Legacy automatic emails.
        case 'purchasedProduct':
          if ($isNewerThan7DaysAgo) {
            $returnData[self::LEGACY_PURCHASED_PRODUCT_7_DAYS]++;
            $returnData[self::LEGACY_PURCHASED_PRODUCT_30_DAYS]++;
            $returnData[self::LEGACY_PURCHASED_PRODUCT_3_MONTHS]++;
          } elseif ($isNewerThan30DaysAgo) {
            $returnData[self::LEGACY_PURCHASED_PRODUCT_30_DAYS]++;
            $returnData[self::LEGACY_PURCHASED_PRODUCT_3_MONTHS]++;
          } elseif ($isNewerThan3MonthsAgo) {
            $returnData[self::LEGACY_PURCHASED_PRODUCT_3_MONTHS]++;
          }
          break;
        case 'purchasedInCategory':
          if ($isNewerThan7DaysAgo) {
            $returnData[self::LEGACY_PURCHASED_IN_CATEGORY_7_DAYS]++;
            $returnData[self::LEGACY_PURCHASED_IN_CATEGORY_30_DAYS]++;
            $returnData[self::LEGACY_PURCHASED_IN_CATEGORY_3_MONTHS]++;
          } elseif ($isNewerThan30DaysAgo) {
            $returnData[self::LEGACY_PURCHASED_IN_CATEGORY_30_DAYS]++;
            $returnData[self::LEGACY_PURCHASED_IN_CATEGORY_3_MONTHS]++;
          } elseif ($isNewerThan3MonthsAgo) {
            $returnData[self::LEGACY_PURCHASED_IN_CATEGORY_3_MONTHS]++;
          }
          break;
        case 'abandonedCart':
          if ($isNewerThan7DaysAgo) {
            $returnData[self::LEGACY_ABANDONED_CART_7_DAYS]++;
            $returnData[self::LEGACY_ABANDONED_CART_30_DAYS]++;
            $returnData[self::LEGACY_ABANDONED_CART_3_MONTHS]++;
          } elseif ($isNewerThan30DaysAgo) {
            $returnData[self::LEGACY_ABANDONED_CART_30_DAYS]++;
            $returnData[self::LEGACY_ABANDONED_CART_3_MONTHS]++;
          } elseif ($isNewerThan3MonthsAgo) {
            $returnData[self::LEGACY_ABANDONED_CART_3_MONTHS]++;
          }
          break;
        case 'firstPurchase':
          if ($isNewerThan7DaysAgo) {
            $returnData[self::LEGACY_FIRST_PURCHASE_7_DAYS]++;
            $returnData[self::LEGACY_FIRST_PURCHASE_30_DAYS]++;
            $returnData[self::LEGACY_FIRST_PURCHASE_3_MONTHS]++;
          } elseif ($isNewerThan30DaysAgo) {
            $returnData[self::LEGACY_FIRST_PURCHASE_30_DAYS]++;
            $returnData[self::LEGACY_FIRST_PURCHASE_3_MONTHS]++;
          } elseif ($isNewerThan3MonthsAgo) {
            $returnData[self::LEGACY_FIRST_PURCHASE_3_MONTHS]++;
          }
          break;
      }
    }

return $returnData;
  }

public function getProcessedCampaignAnalytics(): array {
    $rawData = $this->sendingQueuesRepository->getCampaignAnalyticsQuery()->getArrayResult();
    $processedResults = [];

foreach ($rawData as $sendingInfo) {
      $meta = $sendingInfo['sendingQueueMeta'];
      $campaignId = $meta['campaignId'] ?? null;

if (!is_string($campaignId)) {
        continue;
      }

if (!isset($processedResults[$campaignId])) {
        $newsletterType = $sendingInfo['newsletterType'];
        $processedData = [
          'campaignId' => $campaignId,
          'newsletterType' => $newsletterType,
          'automaticSubType' => null,
          'sentToSegment' => (bool)$sendingInfo['sentToSegment'],
          'sentLast7Days' => (bool)$sendingInfo['sentLast7Days'],
          'sentLast30Days' => (bool)$sendingInfo['sentLast30Days'],
          'sentLast3Months' => (bool)$sendingInfo['sentLast3Months'],
          'filteredBySegment' => !!($meta['filterSegment'] ?? null),
        ];
        $processedResults[$campaignId] = $processedData;
        if ($newsletterType === NewsletterEntity::TYPE_AUTOMATIC) {
          try {
            // Although we could determine the subtype by joining the appropriate newsletter option field, using
            // the meta should be just as reliable, and we need the meta anyway, so this keeps our query simpler.
            $subType = $this->getLegacyAutomaticEmailSubtypeFromMeta($meta);
            $processedResults[$campaignId]['newsletterType'] = $subType;
          } catch (UnexpectedValueException $e) {
            // Ignore this error, the `automatic` email type won't be counted
          }
        }
      } else {
        if ($sendingInfo['sentLast7Days']) {
          $processedResults[$campaignId]['sentLast7Days'] = true;
        }
        if ($sendingInfo['sentLast30Days']) {
          $processedResults[$campaignId]['sentLast30Days'] = true;
        }
        if ($sendingInfo['sentLast3Months']) {
          $processedResults[$campaignId]['sentLast3Months'] = true;
        }
        if ($sendingInfo['sentToSegment']) {
          $processedResults[$campaignId]['sentToSegment'] = true;
        }
      }
    }

return $processedResults;
  }

private function getLegacyAutomaticEmailSubtypeFromMeta(array $meta): string {
    if (array_key_exists('orderedProducts', $meta)) {
      return 'purchasedProduct';
    }
    if (array_key_exists('orderedProductCategories', $meta)) {
      return 'purchasedInCategory';
    }
    if (array_key_exists('cart_product_ids', $meta)) {
      return 'abandonedCart';
    }
    if (array_key_exists('order_amount', $meta) && array_key_exists('order_date', $meta) && array_key_exists('order_id', $meta)) {
      return 'firstPurchase';
    }

throw new UnexpectedValueException('Unknown automatic email type based on meta data');
  }
}

Back