vendor/bluue/prestashop-connector-bundle/src/EventSubscriber/StockProductEditSubscriber.php line 58

Open in your IDE?
  1. <?php
  3. /**
  4.  * @author Thomas HERISSON (contact@scaledev.fr)
  5.  * @copyright 2021 - ScaleDEV SAS, 12 RUE CHARLES MORET, 10120 ST ANDRE LES VERGERS
  6.  * @license commercial
  7.  */
  9. declare(strict_types=1);
  11. namespace Bluue\PrestashopConnectorBundle\EventSubscriber;
  13. use App\Services\CheckBundleInstall;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use ReflectionClass;
  16. use Symfony\Component\Messenger\MessageBusInterface;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Bluue\PrestashopConnectorBundle\Message\UpdateStockProductToPrestaMessage;
  20. class StockProductEditSubscriber implements EventSubscriberInterface
  21. {
  22.     /**
  23.      * @var MessageBusInterface
  24.      */
  25.     protected MessageBusInterface $messageBus;
  27.     /**
  28.      * @var EntityManagerInterface
  29.      */
  30.     protected EntityManagerInterface $em;
  32.     public function __construct(
  33.         MessageBusInterface $messageBus,
  34.         EntityManagerInterface $em
  35.     ) {
  36.         $this->messageBus = $messageBus;
  37.         $this->em = $em;
  38.     }
  40.     /**
  41.      * @return string[]
  42.      */
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         if (CheckBundleInstall::exist('stocks-bundle')) {
  46.             $reflectionClass = new ReflectionClass('Bluue\StocksBundle\Event\StockProductEditEvent');
  47.             return [
  48.                 $reflectionClass->getConstant('NAME') => 'onChange'
  49.             ];
  50.         }
  51.         return [];
  52.     }
  54.     /**
  55.      * @param object $event
  56.      * @return void
  57.      */
  58.     public function onChange(object $event): void
  59.     {
  60.         $entityId = $event->getId();
  61.         $entity = $this->em->find('StocksBundle:StockProduct', $entityId);
  62.         if ($entity) {
  63.             $this->messageBus->dispatch(new UpdateStockProductToPrestaMessage($entityId->toRfc4122()));
  64.         }
  65.     }
  66. }