custom/plugins/SwagSocialShopping/src/EventListener/DataFeedEventListener.php line 41

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /*
  3.  * (c) shopware AG <info@shopware.com>
  4.  *
  5.  * For the full copyright and license information, please view the LICENSE
  6.  * file that was distributed with this source code.
  7.  */
  9. namespace SwagSocialShopping\EventListener;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Shopware\Core\System\SalesChannel\SalesChannelEntity;
  16. use Shopware\Core\System\SalesChannel\SalesChannelEvents;
  17. use SwagSocialShopping\Component\DataFeed\DataFeedHandler;
  18. use SwagSocialShopping\SwagSocialShopping;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. class DataFeedEventListener implements EventSubscriberInterface
  22. {
  23.     private DataFeedHandler $dataFeedHandler;
  25.     private EntityRepositoryInterface $salesChannelRepository;
  27.     public function __construct(DataFeedHandler $dataFeedHandler, EntityRepositoryInterface $salesChannelRepository)
  28.     {
  29.         $this->dataFeedHandler = $dataFeedHandler;
  30.         $this->salesChannelRepository = $salesChannelRepository;
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             SwagSocialShopping::SOCIAL_SHOPPING_SALES_CHANNEL_WRITTEN_EVENT => 'afterWrite',
  37.             SalesChannelEvents::SALES_CHANNEL_WRITTEN => 'afterWriteSalesChannel',
  38.         ];
  39.     }
  41.     public function afterWrite(EntityWrittenEvent $event): void
  42.     {
  43.         foreach ($event->getWriteResults() as $writeResult) {
  44.             if (!$this->needsDataFeed($writeResult)) {
  45.                 continue;
  46.             }
  48.             $this->dataFeedHandler->createDataFeedForWriteResult($writeResult, $event);
  49.         }
  50.     }
  52.     public function afterWriteSalesChannel(EntityWrittenEvent $event): void
  53.     {
  54.         foreach ($event->getWriteResults() as $writeResult) {
  55.             if ($writeResult->getOperation() === EntityWriteResult::OPERATION_DELETE
  56.                 || $writeResult->getOperation() === EntityWriteResult::OPERATION_INSERT) {
  57.                 continue;
  58.             }
  60.             $payload = $writeResult->getPayload();
  62.             if (!empty($payload['typeId']) && $payload['typeId'] !== SwagSocialShopping::SALES_CHANNEL_TYPE_SOCIAL_SHOPPING) {
  63.                 continue;
  64.             }
  66.             if (empty($payload['id'])) {
  67.                 continue;
  68.             }
  70.             if (empty($payload['typeId'])) {
  71.                 /** @var SalesChannelEntity|null $salesChannel */
  72.                 $salesChannel = $this->salesChannelRepository->search(new Criteria([$payload['id']]), $event->getContext())->first();
  74.                 if ($salesChannel === null || $salesChannel->getTypeId() !== SwagSocialShopping::SALES_CHANNEL_TYPE_SOCIAL_SHOPPING) {
  75.                     continue;
  76.                 }
  77.             }
  79.             $this->dataFeedHandler->updateActiveStatus($writeResult, $event->getContext());
  80.         }
  81.     }
  83.     private function needsDataFeed(EntityWriteResult $writeResult): bool
  84.     {
  85.         if ($writeResult->getEntityName() !== 'swag_social_shopping_sales_channel') {
  86.             return false;
  87.         }
  89.         if (\in_array($writeResult->getOperation(), [
  90.             EntityWriteResult::OPERATION_DELETE,
  91.             EntityWriteResult::OPERATION_UPDATE,
  92.         ], true)) {
  93.             return false;
  94.         }
  96.         if (isset($writeResult->getPayload()['network'])
  97.             && \in_array($writeResult->getPayload()['network'], DataFeedHandler::RELEVANT_NETWORKS, true)) {
  98.             return true;
  99.         }
  101.         return !empty($writeResult->getPayload()['id']);
  102.     }
  103. }