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.             // only messages that are published at the moment
  77.             $criteria->addFilter(new MultiFilter(MultiFilter::CONNECTION_OR, [
  78.                 new EqualsFilter('message_content.visible_from', null),
  79.                 new RangeFilter('message_content.visible_from', [
  80.                     RangeFilter::LTE => (new \DateTime())->setTimezone(new \DateTimeZone('Europe/Berlin'))->format('Y-m-d H:i:s')
  81.                 ])
  82.             ]));
  84.             $count = $this->messagesRepository->search($criteria, $event->getSalesChannelContext()->getContext())->count();
  86.             if ($count > 0) {
  87.                 $event->setParameter('unreadMessagesCount', $count);
  88.             }
  90.         }
  92.         if (in_array($event->getRequest()->getPathInfo(), self::WHITELIST_ROUTES)) {
  93.             return;
  94.         }
  96.         if ($event->getRequest()->getSession()->has('mailbox_remind_later')) {
  97.             $remindLater = $event->getRequest()->getSession()->get('mailbox_remind_later');
  98.             if ($remindLater instanceof \DateTime && $remindLater > new \DateTime()) {
  99.                 return;
  100.             }
  101.         }
  103.         if ($event->getSalesChannelContext()->getCustomer() instanceof CustomerEntity) {
  105.             $criteria = new Criteria();
  107.             // only messages for the current customer
  108.             $criteria->addFilter(new EqualsFilter('customer_id', $event->getSalesChannelContext()->getCustomer()->getId()));
  110.             // only messages that are published at the moment and older than x days
  111.             $criteria->addFilter(
  112.                 new RangeFilter(
  113.                     'message_content.visible_from',
  114.                     [
  115.                         'lte' => (new \DateTime())->setTimezone(new \DateTimeZone('Europe/Berlin'))->modify('-' . $this->mailboxConfigService->getShowModalAfterDays() . ' days')->format('Y-m-d H:i:s')
  116.                     ]
  117.                 )
  118.             );
  120.             // only messages that are not read
  121.             $criteria->addFilter(new EqualsFilter('read_at', null));
  123.             // only messages that are important
  124.             $criteria->addFilter(new EqualsFilter('message_content.important', true));
  126.             $count = $this->messagesRepository->search($criteria, $event->getSalesChannelContext()->getContext())->count();
  128.             if ($count > 0) {
  129.                 $event->setParameter('showUnreadMessagesModal', true);
  130.             }
  131.         }
  132.     }
  133. }