src/AppBundle/EventListeners/MongoUpdater.php line 28

Open in your IDE?
  1. <?php
  3. namespace AppBundle\EventListeners;
  5. use Pimcore;
  6. use Pimcore\Config;
  7. use Pimcore\Event\Model\ElementEventInterface;
  8. use Pimcore\Model\DataObject\Product;
  9. use Pimcore\Model\DataObject\Supplier;
  10. use Website\Helpers\MongoExportHelper;
  12. class MongoUpdater
  13. {
  14.     /** @var MongoExportHelper */
  15.     protected $exportHelper;
  17.     protected $mongoConfig;
  19.     public function __construct($mongoConfig)
  20.     {
  21.         $this->mongoConfig = $mongoConfig;
  22.     }
  24.     /**
  25.      * @param ElementEventInterface $e
  26.      * @throws \Exception
  27.      */
  28.     public function handleEvent(ElementEventInterface $e)
  29.     {
  30.         if (!$e instanceof Pimcore\Event\Model\DataObjectEvent) {
  31.             return;
  32.         }
  33.         $object = $e->getObject();
  34.         if (env('DISABLE_MONGO_EXPORT', false)) {
  35.             return;
  36.         }
  38.         if ($object instanceof Product) {
  39.             return $this->handleProduct($object);
  40.         }
  42.         if ($object instanceof Supplier) {
  43.             return $this->handleSupplier($object);
  44.         }
  46.     }
  48.     /**
  49.      * @param Product $product
  50.      * @throws \Exception
  51.      */
  52.     protected function handleProduct(Product $product)
  53.     {
  54.         $productId = $product->getId();
  55.         Product::setGetInheritedValues(true);
  57.         $this->connectToMongo();
  58.         $this->exportHelper()->updateProduct($productId);
  60.     }
  62.     /**
  63.      * @throws \Exception
  64.      */
  65.     protected function connectToMongo()
  66.     {
  67.         $this->exportHelper()->connectToMongo(
  68.             $this->mongoConfig['hosts'],
  69.             $this->mongoConfig['username'],
  70.             $this->mongoConfig['password'],
  71.             $this->mongoConfig['database']);
  72.     }
  74.     /**
  75.      * @return MongoExportHelper
  76.      */
  77.     protected function exportHelper()
  78.     {
  79.         if (!$this->exportHelper) {
  80.             $this->exportHelper = new MongoExportHelper();
  81.         }
  83.         return $this->exportHelper;
  84.     }
  86.     /**
  87.      * @param Supplier $supplier
  88.      * @throws \Exception
  89.      */
  90.     protected function handleSupplier(Supplier $supplier)
  91.     {
  92.         $this->connectToMongo();
  93.         $this->exportHelper()->updateSupplier($supplier);
  94.     }
  97. }