custom/plugins/ZeobvGetNotified/src/Storefront/Subscriber/NotificationSubscriber.php line 65

Open in your IDE?
  1. <?php declare(strict_types = 1);
  3. namespace Zeobv\GetNotified\Storefront\Subscriber;
  5. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Psr\Log\LoggerInterface;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  11. use Shopware\Core\Framework\Api\Context\SalesChannelApiSource;
  13. use Zeobv\GetNotified\Service\MailService;
  14. use Zeobv\GetNotified\Service\ConfigService;
  16. /**
  17.  * Class NotificationSubscriber
  18.  *
  19.  * @package Zeobv\GetNotified\Storefront\Subscriber
  20.  */
  21. class NotificationSubscriber implements EventSubscriberInterface
  22. {
  23.     /**
  24.      * @var ConfigService
  25.      */
  26.     protected $configService;
  28.     /**
  29.      * @var MailService
  30.      */
  31.     protected $mailService;
  33.     /**
  34.      * @var LoggerInterface
  35.      */
  36.     protected $logger;
  38.     /**
  39.      * NotificationSubscriber constructor.
  40.      *
  41.      * @param ConfigService   $configService
  42.      * @param MailService     $mailService
  43.      * @param LoggerInterface $logger
  44.      */
  45.     public function __construct(
  46.         ConfigService $configService,
  47.         MailService $mailService,
  48.         LoggerInterface $logger
  49.     ) {
  50.         $this->configService = $configService;
  51.         $this->mailService = $mailService;
  52.         $this->logger = $logger;
  53.     }
  55.     /**
  56.      * @return array
  57.      */
  58.     public static function getSubscribedEvents(): array
  59.     {
  60.         return [
  61.             'zeo_stock_subscriber_product.written' => 'onNewStockSubscriber',
  62.         ];
  63.     }
  65.     public function onNewStockSubscriber(EntityWrittenEvent $event): void
  66.     {
  67.         /** @var SalesChannelApiSource|mixed $source */
  68.         $source = $event->getContext()->getSource();
  70.         if (!$event->getContext()->getSource() instanceof SalesChannelApiSource) {
  71.             return;
  72.         }
  74.         $scId = $source->getSalesChannelId();
  76.         if (!$this->configService->getReceiveNotificationEmailOnNewSubscription($scId)) {
  77.             return;
  78.         }
  80.         $notificationEmail = $this->configService->getNotificationEmail($scId);
  81.         if (empty($notificationEmail)) {
  82.             return;
  83.         }
  85.         /** @var EntityWriteResult $writeResult */
  86.         foreach ($event->getWriteResults() as $writeResult) {
  87.             if ($writeResult->getOperation() !== EntityWriteResult::OPERATION_INSERT) {
  88.                 continue;
  89.             }
  91.             $payload = $writeResult->getPayload();
  92.             if (!is_array($payload) || !key_exists('stockSubscriberId', $payload)) {
  93.                 continue;
  94.             }
  96.             try {
  97.                 $this->mailService->sendNewSubscriptionMail($notificationEmail, $payload, $event->getContext());
  98.             } catch (\Throwable $e) {
  99.                 $this->logger->critical($e->getMessage(), ['trace' => $e->getTrace()]);
  100.             }
  101.         }
  102.     }
  103. }