custom/plugins/CioCustomerMailbox/src/Subscriber/ShowUnreadMessagesModalSubscriber.php line 60

Open in your IDE?
  1. <?php
  4. namespace CioCustomerMailbox\Subscriber;
  6. use CioCustomerMailbox\Service\MailboxConfigService;
  7. use CioImports\Event\ImportStockMissingProductNotificationEvent;
  8. use Shopware\Core\Checkout\Cart\Exception\CustomerNotLoggedInException;
  9. use Shopware\Core\Checkout\Customer\CustomerEntity;
  10. use Shopware\Core\Checkout\Customer\Event\CustomerDeletedEvent;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\NotFilter;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\RangeFilter;
  17. use Shopware\Core\Framework\Event\BusinessEvent;
  18. use Shopware\Core\Framework\Event\BusinessEventCollectorEvent;
  19. use Shopware\Core\Framework\Event\BusinessEventDefinition;
  20. use Shopware\Core\System\SystemConfig\SystemConfigService;
  21. use Shopware\Storefront\Controller\AuthController;
  22. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  23. use Symfony\Component\HttpFoundation\RedirectResponse;
  24. use Symfony\Component\HttpKernel\Event\ControllerEvent;
  25. use Symfony\Component\HttpKernel\Event\RequestEvent;
  26. use Symfony\Component\HttpKernel\KernelEvents;
  27. use Shopware\Storefront\Event\StorefrontRenderEvent;
  29. class ShowUnreadMessagesModalSubscriber implements EventSubscriberInterface
  30. {
  32.     CONST WHITELIST_ROUTES = [
  33.         '/account/login',
  34.         '/widgets/checkout/info',
  35.         '/account/recover',
  36.         '/account/recover/password',
  37.         '/checkout/offcanvas',
  38.         '/cookie/offcanvas',
  39.         '/impressum',
  40.         '/account/mailbox'
  41.     ];
  43.     protected EntityRepository $messagesRepository;
  45.     protected MailboxConfigService $mailboxConfigService;
  47.     public function __construct(EntityRepository $messagesRepository, MailboxConfigService $mailboxConfigService)
  48.     {
  49.         $this->messagesRepository = $messagesRepository;
  50.         $this->mailboxConfigService = $mailboxConfigService;
  51.     }
  53.     public static function getSubscribedEvents(): array
  54.     {
  55.         return [
  56.             StorefrontRenderEvent::class => 'onStorefrontRenderEvent'
  57.         ];
  58.     }
  60.     public function onStorefrontRenderEvent(StorefrontRenderEvent $event)
  61.     {
  62.         if($event->getSalesChannelContext()->getSalesChannel()->isMaintenance()) {
  63.             return;
  64.         }
  66.         if ($event->getSalesChannelContext()->getCustomer() instanceof CustomerEntity) {
  68.             $criteria = new Criteria();
  70.             // only messages for the current customer
  71.             $criteria->addFilter(new EqualsFilter('customer_id', $event->getSalesChannelContext()->getCustomer()->getId()));
  73.             // only messages that are not read
  74.             $criteria->addFilter(new EqualsFilter('read_at', null));
  76.             $count = $this->messagesRepository->search($criteria, $event->getSalesChannelContext()->getContext())->count();
  78.             if ($count > 0) {
  79.                 $event->setParameter('unreadMessagesCount', $count);
  80.             }
  82.         }
  84.         if (in_array($event->getRequest()->getPathInfo(), self::WHITELIST_ROUTES)) {
  85.             return;
  86.         }
  88.         if ($event->getSalesChannelContext()->getCustomer() instanceof CustomerEntity) {
  90.             $criteria = new Criteria();
  92.             // only messages for the current customer
  93.             $criteria->addFilter(new EqualsFilter('customer_id', $event->getSalesChannelContext()->getCustomer()->getId()));
  95.             // only messages that are published at the moment and older than x days
  96.             $criteria->addFilter(
  97.                 new RangeFilter(
  98.                     'message_content.visible_from',
  99.                     [
  100.                         'lte' => (new \DateTime())->setTimezone(new \DateTimeZone('Europe/Berlin'))->modify('-' . $this->mailboxConfigService->getShowModalAfterDays() . ' days')->format('Y-m-d H:i:s')
  101.                     ]
  102.                 )
  103.             );
  105.             // only messages that are not read
  106.             $criteria->addFilter(new EqualsFilter('read_at', null));
  108.             // only messages that are important
  109.             $criteria->addFilter(new EqualsFilter('message_content.important', true));
  111.             $count = $this->messagesRepository->search($criteria, $event->getSalesChannelContext()->getContext())->count();
  113.             if ($count > 0) {
  114.                 $event->setParameter('showUnreadMessagesModal', true);
  115.             }
  116.         }
  117.     }
  118. }