src/Hitso/Bundle/CatalogBundle/EventListener/ProductEventListener.php line 132

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Hitso\Bundle\CatalogBundle\EventListener;
  7. use Doctrine\Common\Collections\ArrayCollection;
  8. use Doctrine\ORM\Event\LifecycleEventArgs;
  9. use Hitso\Bundle\CatalogBundle\Entity\Product;
  10. use Hitso\Bundle\CatalogBundle\Entity\TaxRate;
  11. use Hitso\Bundle\CatalogBundle\Service\Tax\Helper\TaxHelperInterface;
  12. use Hitso\Bundle\CommonBundle\Doctrine\Event\EntityEvent;
  13. use Hitso\Bundle\CommonBundle\Doctrine\Manager\ManagerCollection;
  14. use Hitso\Bundle\SearchBundle\Manager\SearchManager;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. /**
  18.  * Class ProductEventListener
  19.  *
  20.  * @package Hitso\Bundle\CatalogBundle\EventListener
  21.  */
  22. class ProductEventListener implements EventSubscriberInterface
  23. {
  24.     /**
  25.      * @var TaxHelperInterface
  26.      */
  27.     private $taxHelper;
  29.     /**
  30.      * @var SearchManager
  31.      */
  32.     private $searchManager;
  34.     /**
  35.      * @var ManagerCollection
  36.      */
  37.     private $managerCollection;
  39.     /**
  40.      * TaxHelperInterface constructor.
  41.      *
  42.      * @param TaxHelperInterface $taxHelper
  43.      * @param SearchManager
  44.      */
  45.     public function __construct(
  46.         TaxHelperInterface $taxHelper,
  47.         SearchManager $searchManager,
  48.         ManagerCollection $managerCollection
  49.     ) {
  50.         $this->taxHelper         = $taxHelper;
  51.         $this->searchManager     = $searchManager;
  52.         $this->managerCollection = $managerCollection;
  53.     }
  55.     /**
  56.      * @return array
  57.      */
  58.     public static function getSubscribedEvents(): array
  59.     {
  60.         return [
  61.             'prePersist',
  62.             'preUpdate',
  63.             'product.post_create' => 'onPostCreate',
  64.             'product.post_update' => 'onPostUpdate',
  65.         ];
  66.     }
  68.     /**
  69.      * @param LifecycleEventArgs $eventArgs
  70.      */
  71.     public function prePersist(LifecycleEventArgs $eventArgs): void
  72.     {
  73.         if (method_exists($eventArgs, 'getEntity')) {
  74.             $product = $eventArgs->getEntity();
  75.             if ($product instanceof Product) {
  76.                 $this->calculateProductPrice($product);
  77.             }
  78.         }
  79.     }
  81.     /**
  82.      * @param LifecycleEventArgs $eventArgs
  83.      */
  84.     public function preUpdate(LifecycleEventArgs $eventArgs): void
  85.     {
  86.         if (method_exists($eventArgs, 'getEntity')) {
  87.             $product = $eventArgs->getEntity();
  88.             if ($product instanceof Product) {
  89.                 $this->calculateProductPrice($product);
  90.             }
  91.         }
  92.     }
  94.     /**
  95.      * @param Product $product
  96.      */
  97.     private function calculateProductPrice(Product $product): void
  98.     {
  99.         if ($product instanceof Product) {
  100.             if ($product->getTaxRate() instanceof TaxRate) {
  101.                 $netAmount   = round($product->getNetAmount(), 2);
  102.                 $grossAmount = $this->taxHelper->calculateGrossAmount($netAmount, $product->getTaxRate()->getValue());
  104.                 $product->setGrossAmount($grossAmount);
  105.                 $product->setNetAmount($netAmount);
  106.                 $product->setTaxAmount($grossAmount - $netAmount);
  107.             }
  108.         }
  109.     }
  111.     /**
  112.      * @param EntityEvent $event
  113.      */
  114.     public function onPostCreate(EntityEvent $event): void
  115.     {
  116.         $entity = $event->getEntity();
  117.         if ($entity instanceof Product) {
  118.             try {
  119.                 $type      = $this->searchManager->getType('product');
  120.                 $documents = new ArrayCollection();
  121.                 $document  = $type->createDocument($entity);
  122.                 $documents->add($document);
  123.                 $this->searchManager->addDocuments($documents, $type->getName());
  124.             } catch (\Exception $e) {
  125.             }
  126.         }
  127.     }
  129.     /**
  130.      * @param EntityEvent $event
  131.      */
  132.     public function onPostUpdate(EntityEvent $event): void
  133.     {
  134.         $entity = $event->getEntity();
  135.         if ($entity instanceof Product) {
  136.             try {
  137.                 $type     = $this->searchManager->getType('product');
  138.                 $document = $type->createDocument($entity);
  139.                 $this->searchManager->updateDocument($document);
  140.             } catch (\Exception $e) {
  141.             }
  142.         }
  143.     }
  144. }