src/AppBundle/EventListener/WarengruppenEventListener.php line 30

Open in your IDE?
  1. <?php
  3. namespace AppBundle\EventListener;
  5. use AppBundle\Actions\LoggerAction;
  6. use AppBundle\Message\Warengruppen\SyncWarengruppenAttributesToArticlesMessage;
  7. use AppBundle\Service\General\EventListenerJobIdentifierService;
  8. use Pimcore\Db;
  9. use Pimcore\Event\Model\ElementEventInterface;
  10. use Pimcore\Model\DataObject\Warengruppe;
  11. use Symfony\Component\Messenger\MessageBusInterface;
  13. class WarengruppenEventListener extends DataObjectEventListener {
  15.     /**
  16.      * @param MessageBusInterface $messageBus
  17.      */
  18.     public function __construct(MessageBusInterface $messageBus) {
  19.         parent::__construct($messageBus);
  20.     }
  22.     const PIMCORE_DATA_OBJECT_CLASS_PATH = Warengruppe::class;
  23.     protected $object;
  25.     /**
  26.      * @param ElementEventInterface $event
  27.      * @return void
  28.      * @throws \Doctrine\DBAL\DBALException
  29.      */
  30.     public function onObjectPreAdd(ElementEventInterface $event): void {
  31.         // Not Warengruppe DataObject?
  32.         if(!$this->eventBelongsToThisClass($event)){
  33.             return;
  34.         }
  35.         $this->onObjectPrePersist();
  36.     }
  38.     /**
  39.      * @param ElementEventInterface $event
  40.      * @return void
  41.      * @throws \Doctrine\DBAL\DBALException
  42.      * @throws \Doctrine\DBAL\Driver\Exception
  43.      * @throws \Doctrine\DBAL\Exception
  44.      * @throws \Doctrine\DBAL\Exception\DriverException
  45.      */
  46.     public function onObjectPreUpdate(ElementEventInterface $event): void {
  47.         // Not Warengruppe DataObject?
  48.         if(!$this->eventBelongsToThisClass($event)){
  49.             return;
  50.         }
  51.         $this->onObjectPrePersist();
  52.         $this->dispatchAttributesToArticlesAsyncJob($this->object);
  53.     }
  55.     /**
  56.      * @return void
  57.      */
  58.     public function onObjectPrePersist(): void {
  59.         // If datumStillgelegt field has value, remove Aktiv flag from object
  60.         $datumStillgelegt = $this->object->getDatumStillgelegt();
  61.         if($datumStillgelegt && $datumStillgelegt != '0') {
  62.             $this->object->setAktiv(false);
  63.             $this->object->setAktiv_ch(false);
  64.             $this->object->setAktiv_de(false);
  65.         }
  66.     }
  68.     /**
  69.      * @param Warengruppe $object
  70.      * @return void
  71.      * @throws \Doctrine\DBAL\DBALException
  72.      * @throws \Doctrine\DBAL\Driver\Exception
  73.      * @throws \Doctrine\DBAL\Exception
  74.      * @throws \Doctrine\DBAL\Exception\DriverException
  75.      */
  76.     private function dispatchAttributesToArticlesAsyncJob(Warengruppe $object): void {
  78.         // We fetch the necessary variables from this object
  79.         $classId = $object->getClassId();
  80.         $objectId = $object->getId();
  81.         $jobId = EventListenerJobIdentifierService::WARRENGRUPPEN_ATTRIBUTES_TO_ARTICLES_SYNC;
  83.         // We generate a unique message id for this job
  84.         $umid = $this->generateUmid($classId, $objectId, $jobId);
  85.         // If a message with this umid doesn't exist, create it
  86.         if(!$this->messageExistsInQueue("general_messages", $umid, "event_listener")){
  87.             $this->messageBus->dispatch(new SyncWarengruppenAttributesToArticlesMessage($objectId, $umid));
  88.         }
  89.     }
  90. }