custom/plugins/CrswCleverReachOfficial/src/Subscriber/Automation/SalesChannelSubscriber.php line 84

Open in your IDE?
  1. <?php
  3. namespace Crsw\CleverReachOfficial\Subscriber\Automation;
  5. use Crsw\CleverReachOfficial\Components\Utility\Bootstrap;
  6. use Crsw\CleverReachOfficial\Components\Utility\Initializer;
  7. use Crsw\CleverReachOfficial\Core\Infrastructure\Exceptions\BaseException;
  8. use Crsw\CleverReachOfficial\Core\Infrastructure\Logger\Logger;
  9. use Crsw\CleverReachOfficial\Entity\SalesChannel\Repositories\SalesChannelRepository;
  10. use Crsw\CleverReachOfficial\Service\BusinessLogic\Automation\AutomationService;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  13. use Shopware\Core\System\SalesChannel\SalesChannelEvents;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. /**
  17.  * Class SalesChannelSubscriber
  18.  *
  19.  * @package Crsw\CleverReachOfficial\Subscriber\Automation
  20.  */
  21. class SalesChannelSubscriber implements EventSubscriberInterface
  22. {
  23.     /**
  24.      * @var AutomationService
  25.      */
  26.     private $automationService;
  27.     /**
  28.      * @var SalesChannelRepository
  29.      */
  30.     private $salesChannelRepository;
  32.     /**
  33.      * SalesChannelSubscriber constructor.
  34.      *
  35.      * @param Initializer $initializer
  36.      * @param AutomationService $automationService
  37.      * @param SalesChannelRepository $salesChannelRepository
  38.      */
  39.     public function __construct(
  40.         Initializer $initializer,
  41.         AutomationService $automationService,
  42.         SalesChannelRepository $salesChannelRepository
  43.     ) {
  44.         Bootstrap::register();
  45.         $initializer->registerServices();
  46.         $this->automationService = $automationService;
  47.         $this->salesChannelRepository = $salesChannelRepository;
  48.     }
  50.     /**
  51.      * @inheritDoc
  52.      */
  53.     public static function getSubscribedEvents(): array
  54.     {
  55.         return [
  56.             SalesChannelEvents::SALES_CHANNEL_DELETED => 'onSalesChannelDelete',
  57.             SalesChannelEvents::SALES_CHANNEL_WRITTEN => 'onSalesChannelSave'
  58.         ];
  59.     }
  61.     /**
  62.      * Removes cart automation when store has been deleted.
  63.      *
  64.      * @param EntityDeletedEvent $event
  65.      */
  66.     public function onSalesChannelDelete(EntityDeletedEvent $event): void
  67.     {
  68.         $ids = $event->getIds();
  70.         foreach ($ids as $id) {
  71.             try {
  72.                 $this->automationService->delete($id);
  73.             } catch (BaseException $e) {
  74.                 Logger::logError('Failed to remove automation for store: ' . $id, 'Integration');
  75.             }
  76.         }
  77.     }
  79.     /**
  80.      * Removes cart records when store has been deactivated.
  81.      *
  82.      * @param EntityWrittenEvent $event
  83.      */
  84.     public function onSalesChannelSave(EntityWrittenEvent $event): void
  85.     {
  86.         $ids = $event->getIds();
  88.         foreach ($ids as $id) {
  89.             $salesChannel = $this->salesChannelRepository->getSalesChannelById($id, $event->getContext());
  91.             if (!$salesChannel) {
  92.                 return;
  93.             }
  95.             if (!$salesChannel->getActive()) {
  96.                 try {
  97.                     $this->automationService->deleteRecords($id);
  98.                 } catch (BaseException $e) {
  99.                     Logger::logError('Failed to remove automation records for store: ' . $id, 'Integration');
  100.                 }
  101.             }
  102.         }
  103.     }
  104. }