custom/plugins/SelfdelveCms/src/Subscriber/CustomerRegisterSubscriber.php line 70

Open in your IDE?
  1. <?php
  2.     namespace Selfdelve\Cms\Subscriber;
  4.     use Psr\Log\LoggerInterface;
  5.     use Shopware\Core\Checkout\Customer\Aggregate\CustomerGroup\CustomerGroupEntity;
  6.     use Shopware\Core\Checkout\Customer\CustomerEntity;
  7.     use Shopware\Core\Checkout\Customer\Event\CustomerRegisterEvent;
  8.     use Shopware\Core\Content\Mail\Service\AbstractMailService;
  9.     use Shopware\Core\Content\MailTemplate\MailTemplateEntity;
  10.     use Shopware\Core\Framework\Context;
  11.     use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  12.     use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  13.     use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  14.     use Shopware\Core\Framework\Validation\DataBag\DataBag;
  15.     use Shopware\Core\System\SalesChannel\SalesChannelContext;
  16.     use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17.     use Shopware\Core\System\SystemConfig\SystemConfigService;
  19.     class CustomerRegisterSubscriber implements EventSubscriberInterface
  20.     {
  21.         private LoggerInterface $logger;
  23.         private EntityRepositoryInterface $customerGroupRepository;
  25.         private EntityRepositoryInterface $mailTemplateRepository;
  27.         private AbstractMailService $mailService;
  29.         private SystemConfigService $systemConfigService;
  31.         /**
  32.          * CustomerRegisterSubscriber constructor.
  33.          * @param LoggerInterface $logger
  34.          * @param EntityRepositoryInterface $customerGroupRepository
  35.          * @param EntityRepositoryInterface $mailTemplateRepository
  36.          * @param AbstractMailService $mailService
  37.          * @param SystemConfigService $systemConfigService
  38.          */
  39.         public function __construct(
  40.             LoggerInterface $logger,
  41.             EntityRepositoryInterface $customerGroupRepository,
  42.             EntityRepositoryInterface $mailTemplateRepository,
  43.             AbstractMailService $mailService,
  44.             SystemConfigService $systemConfigService
  45.         ) {
  46.             $this->logger = $logger;
  47.             $this->customerGroupRepository = $customerGroupRepository;
  48.             $this->mailTemplateRepository = $mailTemplateRepository;
  49.             $this->mailService = $mailService;
  50.             $this->systemConfigService = $systemConfigService;
  51.         }
  53.         /**
  54.          * @return array
  55.          */
  56.         public static function getSubscribedEvents(): array
  57.         {
  58.             return [
  59.                 CustomerRegisterEvent::class => 'onCustomerRegister'
  60.             ];
  61.         }
  63.         /**
  64.          * Email the admin, if a customer requested a closed customer group (e.g., reseller).
  65.          * This event is triggered after the initial opt-in of the customer.
  66.          *
  67.          * @param CustomerRegisterEvent $event
  68.          * @return bool
  69.          */
  70.         public function onCustomerRegister(CustomerRegisterEvent $event): bool
  71.         {
  72.             /** @var CustomerEntity $customer */
  73.             $customer = $event->getCustomer();
  74.             if ((string) $customer->getRequestedGroupId() === '') {
  75.                 return false;
  76.             }
  78.             /** @var CustomerGroupEntity $customerGroup */
  79.             $customerGroup = $this->customerGroupRepository->search(
  80.                 new Criteria([$customer->getRequestedGroupId()]),
  81.                 $event->getContext()
  82.             )->first();
  84.             if (!$customerGroup instanceof CustomerGroupEntity) {
  85.                 return false;
  86.             }
  88.             if ($customerGroup->getRegistrationOnlyCompanyRegistration() === false) {
  89.                 return false;
  90.             }
  92.             $mailTemplateId = $this->systemConfigService->get('SelfdelveCms.config.registrationTemplateId');
  94.             /** @var MailTemplateEntity $mailTemplate */
  95.             $mailTemplate = $this->mailTemplateRepository->search(
  96.                 new Criteria([$mailTemplateId]),
  97.                 $event->getContext()
  98.             )->first();
  100.             if (!$mailTemplate) {
  101.                 $this->logger->error('Could not find email template for id ' . $mailTemplateId);
  102.                 return false;
  103.             }
  105.             $data = new DataBag();
  107.             $data->set('salesChannelId', $event->getSalesChannelId());
  108.             $data->set('templateId', $mailTemplate->getId());
  110.             $data->set('recipients', [
  111.                 $this->systemConfigService->get('SelfdelveCms.config.adminEmail') => $this->systemConfigService->get('SelfdelveCms.config.adminName')
  112.             ]);
  113.             $data->set('senderName', $mailTemplate->getTranslation('senderName'));
  114.             $data->set('subject', $mailTemplate->getTranslation('subject'));
  116.             $data->set('contentHtml', $mailTemplate->getTranslation('contentHtml'));
  117.             $data->set('contentPlain', $mailTemplate->getTranslation('contentPlain'));
  119.             if (!$this->mailService->send(
  120.                 $data->all(),
  121.                 $event->getContext(),
  122.                 ['customer' => $customer]
  123.             )) {
  124.                 $this->logger->error('Customer registration admin email not sent.');
  125.                 return false;
  126.             }
  128.             return true;
  129.         }
  130.     }