src/AppBundle/EventListener/PromotionsEventListener.php line 27

Open in your IDE?
  1. <?php
  3. namespace AppBundle\EventListener;
  5. use AppBundle\EventListener\Validator\PromotionsEventListenerValidator;
  6. use AppBundle\Service\TrimSpacesService;
  7. use Pimcore\Event\Model\ElementEventInterface;
  8. use Pimcore\Model\DataObject\Promotions;
  9. use Symfony\Component\Messenger\MessageBusInterface;
  11. class PromotionsEventListener extends DataObjectEventListener
  12. {
  13.     const PIMCORE_DATA_OBJECT_CLASS_PATH = Promotions::class;
  14.     protected $object;
  15.     private $trimSpacesService;
  17.     public function __construct(MessageBusInterface $messageBus){
  18.         parent::__construct($messageBus);
  19.         $this->trimSpacesService = new TrimSpacesService();
  20.     }
  22.     /**
  23.      * @param ElementEventInterface $event
  24.      * @return void
  25.      * @throws \Doctrine\DBAL\DBALException
  26.      */
  27.     public function onObjectPreAdd(ElementEventInterface $event): void {
  28.         // Not Promotions DataObject?
  29.         if(!$this->eventBelongsToThisClass($event)){
  30.             return;
  31.         }
  32.         $validator = new PromotionsEventListenerValidator();
  33.         $validator->validatePreAdd($this->object);
  35.         $this->onObjectPrePersist($event);
  36.     }
  38.     /**
  39.      * @param ElementEventInterface $event
  40.      * @return void
  41.      * @throws \Doctrine\DBAL\DBALException
  42.      */
  43.     public function onObjectPreUpdate(ElementEventInterface $event): void {
  44.         // Not Promotions DataObject?
  45.         if(!$this->eventBelongsToThisClass($event)){
  46.             return;
  47.         }
  48.         $validator = new PromotionsEventListenerValidator();
  49.         $validator->validatePreUpdate($this->object);
  51.         $this->onObjectPrePersist($event);
  52.         $this->forceUpdateCategoryAndBrandTimestamps();
  53.     }
  55.     /**
  56.      * @param ElementEventInterface $event
  57.      * @return void
  58.      */
  59.     public function onObjectPrePersist(ElementEventInterface $event): void {
  60.         $promotion = $this->trimSpacesService->trimSpaces($this->object->getPromotion());
  61.         $this->object->setPromotion($promotion);
  62.     }
  64.     /**
  65.      * @return void
  66.      * @throws \Doctrine\DBAL\DBALException
  67.      */
  68.     private function forceUpdateCategoryAndBrandTimestamps(): void {
  69.         $db = \Pimcore\Db::get();
  71.         // Get list of all Marken assigned to this object:
  72.         $marken = $this->object->getMarken();
  73.         $markenIdsArr = [];
  74.         // Iterate through them and fetch the ids
  75.         foreach($marken as $marke){
  76.             $markenIdsArr[] = $marke->getObjectId();
  77.         }
  78.         $markenIdsStr = implode(",", $markenIdsArr);
  79.         // Update it in the DB
  80.         $markenQuery = "UPDATE objects
  81.                     SET o_modificationDate = UNIX_TIMESTAMP()
  82.                     WHERE o_id IN ({$markenIdsStr})";
  84.         $kategorien = $this->object->getKategorien();
  85.         $kategorienIdsArr = [];
  86.         // Iterate through them and fetch the ids
  87.         foreach($kategorien as $category){
  88.             $kategorienIdsArr[] = $category->getObjectId();
  89.         }
  90.         $kategorienIdsStr = implode(",", $kategorienIdsArr);
  91.         // Update it in the DB
  92.         $kategorienQuery = "UPDATE objects
  93.                     SET o_modificationDate = UNIX_TIMESTAMP()
  94.                     WHERE o_id IN ({$kategorienIdsStr})";
  96.         try{
  97.             $db->beginTransaction();
  98.             if(count($markenIdsArr) > 0){
  99.                 $db->executeQuery($markenQuery);
  100.             }
  101.             if(count($kategorienIdsArr) > 0){
  102.                 $db->executeQuery($kategorienQuery);
  103.             }
  104.             $db->commit();
  105.         }catch(\Throwable $throwable){
  106.             $db->rollBack();
  107.             throw new \Exception("Failed to update timestamps for Brands and Categories, please try saving again!");
  108.         }
  109.     }
  110. }