Server IP : 172.67.158.161 / Your IP : 3.144.102.138 Web Server : LiteSpeed System : Linux business53.web-hosting.com 4.18.0-553.lve.el8.x86_64 #1 SMP Mon May 27 15:27:34 UTC 2024 x86_64 User : giankuin ( 1871) PHP Version : 7.4.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /proc/self/root/proc/thread-self/root/proc/self/root/proc/self/root/proc/thread-self/root/home/giankuin/thietke365.net/wp-content/plugins/mailpoet/lib/Newsletter/Segment/ |
Upload File : |
<?php // phpcs:ignore SlevomatCodingStandard.TypeHints.DeclareStrictTypes.DeclareStrictTypesMissing namespace MailPoet\Newsletter\Segment; if (!defined('ABSPATH')) exit; use MailPoet\Doctrine\Repository; use MailPoet\Entities\NewsletterEntity; use MailPoet\Entities\NewsletterSegmentEntity; use MailPoet\Newsletter\Options\NewsletterOptionsRepository; use MailPoetVendor\Doctrine\ORM\EntityManager; /** * @extends Repository<NewsletterSegmentEntity> */ class NewsletterSegmentRepository extends Repository { /** @var NewsletterOptionsRepository */ private $newsletterOptionsRepository; public function __construct( NewsletterOptionsRepository $newsletterOptionsRepository, EntityManager $entityManager ) { parent::__construct($entityManager); $this->newsletterOptionsRepository = $newsletterOptionsRepository; } protected function getEntityClassName() { return NewsletterSegmentEntity::class; } public function getSubjectsOfActivelyUsedEmailsForSegments(array $segmentIds): array { $nameMap = []; // Welcome emails foreach ($this->newsletterOptionsRepository->findWelcomeNotificationsForSegments($segmentIds) as $option) { $newsletter = $option->getNewsletter(); if (!$newsletter instanceof NewsletterEntity) continue; $nameMap[(string)$option->getValue()][] = $newsletter->getSubject(); } // Automatic emails foreach ($this->newsletterOptionsRepository->findAutomaticEmailsForSegments($segmentIds) as $option) { $newsletter = $option->getNewsletter(); if (!$newsletter instanceof NewsletterEntity) continue; $nameMap[(string)$option->getValue()][] = $newsletter->getSubject(); } $otherNewsletters = $this->doctrineRepository->createQueryBuilder('ns') ->join('ns.newsletter', 'n') ->leftJoin('n.queues', 'q') ->leftJoin('q.task', 't') ->select('IDENTITY(ns.segment) AS segment_id, n.subject') ->where('(n.type = (:postNotification) OR n.status = :scheduled OR (t.id IS NOT NULL AND t.status IS NULL))') ->andWhere('ns.segment IN (:segmentIds)') ->setParameter('postNotification', NewsletterEntity::TYPE_NOTIFICATION) ->setParameter('segmentIds', $segmentIds) ->setParameter('scheduled', NewsletterEntity::STATUS_SCHEDULED) ->addGroupBy('ns.segment, q.id, t.id') ->getQuery() ->getResult(); foreach ($otherNewsletters as $result) { if (isset($nameMap[(string)$result['segment_id']]) && in_array($result['subject'], $nameMap[(string)$result['segment_id']])) { continue; } $nameMap[(string)$result['segment_id']][] = $result['subject']; } return $nameMap; } }