custom/plugins/LinkMobilityShopwareSmsApiPlugin/src/Subscriber/ProductPageSubscriber.php line 54

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace LinkMobility\ShopwareSmsApiPlugin\Subscriber;
  7. use LinkMobility\ShopwareSmsApiPlugin\Core\Content\Entity\BackInStockReminder\BackInStockReminderEntity;
  8. use LinkMobility\ShopwareSmsApiPlugin\Factory\SmsConfigFactoryInterface;
  9. use LinkMobility\ShopwareSmsApiPlugin\Service\SmsSenderInterface;
  10. use Shopware\Core\Content\Product\ProductDefinition;
  11. use Shopware\Core\Content\Product\ProductEvents;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\ChangeSetAware;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Write\Validation\PreWriteValidationEvent;
  19. use Shopware\Core\Framework\Struct\ArrayEntity;
  20. use Shopware\Core\System\SystemConfig\SystemConfigService;
  21. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  22. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  24. class ProductPageSubscriber implements EventSubscriberInterface
  25. {
  26.     public function __construct(
  27.         private SystemConfigService $configService,
  28.         private EntityRepository $backInStockRemindRepository,
  29.         private SmsSenderInterface $smsSender,
  30.         private SmsConfigFactoryInterface $smsConfigFactory,
  31.         ) {
  32.     }
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             ProductEvents::PRODUCT_WRITTEN_EVENT => 'notifyCustomers',
  38.             PreWriteValidationEvent::class => 'triggerChangeSet',
  39.             ProductPageLoadedEvent::class => 'onProductPageLoaded',
  40.         ];
  41.     }
  43.     public function onProductPageLoaded(ProductPageLoadedEvent $event): void
  44.     {
  45.         $context = $event->getPage();
  46.         $config = $this->configService->get('LinkMobilityShopwareSmsApiPlugin.productAware');
  48.         $restockNotifier = $config['restockNotifier'] ?? false;
  49.         if ($restockNotifier) {
  50.             $context->addExtension('smsNotifier', new ArrayEntity(['on' => true]));
  51.         }
  52.     }
  54.     public function notifyCustomers(EntityWrittenEvent $event): void
  55.     {
  56.         $productsWritten = $event->getWriteResults();
  58.         $restockNotifier = $this->smsConfigFactory->createRestockNotifierConfig();
  60.         if (!$restockNotifier->isActive()) {
  61.             return;
  62.         }
  64.         foreach ($productsWritten as $productWritten) {
  65.             if (!$this->isBackInStock($productWritten)) {
  66.                 continue;
  67.             }
  68.             $payload = $productWritten->getPayload();
  70.             $criteria = new Criteria();
  71.             $criteria->addFilter(new EqualsFilter('productId', $payload['id']));
  72.             $criteria->addAssociation('product');
  73.             $context = $event->getContext();
  75.             $reminderEntities = $this->backInStockRemindRepository->search($criteria, $context)->getEntities();
  77.             /** @var BackInStockReminderEntity $reminderEntity */
  78.             foreach ($reminderEntities as $reminderEntity) {
  79.                 $product = $reminderEntity->getProduct();
  80.                 if (null === $product) {
  81.                     continue;
  82.                 }
  84.                 $this->smsSender->sendProductAware($product, $reminderEntity->getPhoneNumber(), $restockNotifier->getMessage());
  86.                 $this->backInStockRemindRepository->delete([[
  87.                     'id' => $reminderEntity->getId(),
  88.                 ]], $context);
  89.             }
  90.         }
  91.     }
  93.     public function triggerChangeSet(PreWriteValidationEvent $event): void
  94.     {
  95.         foreach ($event->getCommands() as $command) {
  96.             if (!$command instanceof ChangeSetAware ||
  97.                 ProductDefinition::ENTITY_NAME !== $command->getDefinition()->getEntityName()) {
  98.                 continue;
  99.             }
  101.             $payload = $command->getPayload();
  102.             if (!isset($payload['is_closeout']) &&
  103.                 !isset($payload['stock'])) {
  104.                 continue;
  105.             }
  107.             $command->requestChangeSet();
  108.         }
  109.     }
  111.     private function isBackInStock(EntityWriteResult $productWritten): bool
  112.     {
  113.         $payload = $productWritten->getPayload();
  115.         if ((!isset($payload['isCloseout']) && !isset($payload['stock'])) ||
  116.             '0' !== $productWritten->getChangeSet()?->getBefore('available')) {
  117.             return false;
  118.         }
  120.         $stockPayload = $payload['stock'] ?? null;
  121.         $isCloseOutPayload = $payload['isCloseout'] ?? false;
  123.         if (0 < $stockPayload && $isCloseOutPayload) {
  124.             return false;
  125.         }
  127.         return true;
  128.     }
  129. }