custom/plugins/WabsMaterialstammSync/src/Subscriber/WabsMaterialstammSyncSubscriber.php line 65

Open in your IDE?
  1. <?php declare(strict_types=1);
  4. namespace WabsMaterialstammSync\Subscriber;
  6. use Exception;
  7. use Psr\Log\LoggerInterface;
  8. use Shopware\Core\Content\Category\CategoryEvents;
  9. use Shopware\Core\Content\Product\ProductEvents;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use WabsMaterialstammSync\Exceptions\WabsMaterialstammSyncException;
  13. use WabsMaterialstammSync\Service\WabsMaterialstammSubsriberService;
  16. class WabsMaterialstammSyncSubscriber implements EventSubscriberInterface
  17. {
  18.     /** @var WabsMaterialstammSubsriberService $WabsMaterialstammSubsriberService */
  19.     private $wabsMaterialstammSubsriberService;
  21.     /** @var LoggerInterface $logger */
  22.     private $logger;
  24.     public function __construct(
  25.         WabsMaterialstammSubsriberService $wabsMaterialstammSubsriberService,
  26.         LoggerInterface $logger
  27.     ) {
  28.         $this->wabsMaterialstammSubsriberService = $wabsMaterialstammSubsriberService;
  29.         $this->logger = $logger;
  30.     }
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             ProductEvents::PRODUCT_WRITTEN_EVENT => "onProductWritten",
  36.             CategoryEvents::CATEGORY_WRITTEN_EVENT => "onCategoryWritten"
  37.         ];
  38.     }
  40.     /**
  41.      * @param EntityWrittenEvent $event
  42.      */
  43.     public function onProductWritten(EntityWrittenEvent $event)
  44.     {
  45.         //only execute if the context source is admin
  46.         if (!$this->isAdminContextSource($event)) {
  47.             return;
  48.         }
  49.         try {
  50.             $this->logger->debug("--- Starting onProductWritten Event - WabsMaterialstammSync\Subscriber");
  51.             $productIds = [];
  52.             foreach ($event->getWriteResults() as $writeResult) {
  53.                 $productIds[] = $writeResult->getPrimaryKey();
  54.             }
  55.             $this->wabsMaterialstammSubsriberService->updateMasterdataIsSync($productIds, false);
  56.             $this->logger->debug("--- onProductWritten found " . count($productIds) . " ids");
  57.         } catch (Exception $exception) {
  58.             $this->logger->error($exception->getMessage());
  59.         }
  60.     }
  62.     /**
  63.      * @param EntityWrittenEvent $event
  64.      */
  65.     public function onCategoryWritten(EntityWrittenEvent $event)
  66.     {
  67.         //only execute if the context source is admin
  68.         if (!$this->isAdminContextSource($event)) {
  69.             return;
  70.         }
  71.         try {
  72.             $this->logger->debug("--- Starting onCategoryWritten Event - WabsMaterialstammSync\Subscriber");
  73.             $categoryIds = [];
  74.             foreach ($event->getWriteResults() as $writeResult) {
  75.                 $categoryIds[] = $writeResult->getPrimaryKey();
  76.             }
  77.             $categoryIds = $this->wabsMaterialstammSubsriberService->getCategoriesIdsByIds($categoryIds);
  78.             $productIds = $this->wabsMaterialstammSubsriberService->getProductIdsByCategoryIds($categoryIds);
  79.             if (empty($productIds)) {
  80.                 throw new WabsMaterialstammSyncException("No Products found");
  81.             }
  82.             $this->wabsMaterialstammSubsriberService->updateMasterdataIsSync($productIds, false);
  83.             $this->logger->debug("--- onCategoryWritten found " . count($productIds), $productIds);
  84.         } catch (Exception $exception) {
  85.             $this->logger->error($exception->getMessage());
  86.         }
  87.     }
  89.     private function isAdminContextSource(EntityWrittenEvent $event): bool
  90.     {
  91.         return is_a($event->getContext()->getSource(), "Shopware\Core\Framework\Api\Context\AdminApiSource");
  92.     }
  93. }