Server IP : 172.67.158.161 / Your IP : 18.220.203.200 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/thread-self/root/home/giankuin/thietke365.net/wp-content/plugins/mailpoet/lib/Segments/ |
Upload File : |
<?php declare(strict_types = 1); namespace MailPoet\Segments; if (!defined('ABSPATH')) exit; use MailPoet\Entities\SegmentEntity; use MailPoet\Entities\SubscriberEntity; use MailPoet\Segments\DynamicSegments\FilterHandler; use MailPoetVendor\Doctrine\DBAL\Result; use MailPoetVendor\Doctrine\ORM\EntityManager; class SegmentsFinder { /** @var EntityManager */ private $entityManager; /** @var FilterHandler */ private $filterHandler; /** @var SegmentsRepository */ private $segmentsRepository; public function __construct( EntityManager $entityManager, FilterHandler $filterHandler, SegmentsRepository $segmentsRepository ) { $this->entityManager = $entityManager; $this->filterHandler = $filterHandler; $this->segmentsRepository = $segmentsRepository; } /** @return SegmentEntity[] */ public function findSegments(SubscriberEntity $subscriber): array { return array_merge( $this->findStaticSegments($subscriber), $this->findDynamicSegments($subscriber) ); } /** @return SegmentEntity[] */ public function findStaticSegments(SubscriberEntity $subscriber): array { return $subscriber->getSegments()->toArray(); } /** @return SegmentEntity[] */ public function findDynamicSegments(SubscriberEntity $subscriber): array { $segments = $this->segmentsRepository->findBy([ 'type' => SegmentEntity::TYPE_DYNAMIC, ]); $subscribersTable = $this->entityManager->getClassMetadata(SubscriberEntity::class)->getTableName(); $queryBuilder = $this->entityManager->getConnection()->createQueryBuilder() ->select('id') ->from($subscribersTable) ->where('id = :subscriberId') ->setParameter('subscriberId', $subscriber->getId()); $matchingSegments = []; foreach ($segments as $segment) { $result = $this->filterHandler->apply(clone $queryBuilder, $segment)->execute(); if ($result instanceof Result && $result->fetchOne()) { $matchingSegments[] = $segment; } } return $matchingSegments; } }