libraries/OutputBundle/EventListener/AlgoliaListener.php line 45

Open in your IDE?
  1. <?php
  3. namespace OutputBundle\EventListener;
  5. use Pimcore\Event\Model\ElementEventInterface;
  6. use Pimcore\Event\Model\DataObjectEvent;
  7. use Pimcore\Model\DataObject\Folder;
  8. use Pimcore\Model\DataObject\Product;
  10. class AlgoliaListener
  11. {
  13.     private $clientId = ''; // Comes from WebsiteSetting: algoliaClientId
  14.     private $apiKey = ''; // Comes from WebsiteSetting: algoliaApiKeyAdmin
  15.     private $client = false;
  17.     public function __construct()
  18.     {
  20.         $this->clientId = "";
  21.         try {
  22.             $clientIdSetting = \Pimcore\Model\WebsiteSetting::getByName('algoliaClientId');
  23.             if ($clientIdSetting) {
  24.                 $this->clientId = $clientIdSetting->getData();
  25.             }
  26.         } catch (\Exception $e) {
  27.             return;
  28.         }
  30.         $this->apiKey = "";
  31.         try {
  32.             $apiKeySetting = \Pimcore\Model\WebsiteSetting::getByName('algoliaApiKeyAdmin');
  33.             if ($apiKeySetting) {
  34.                 $this->apiKey = $apiKeySetting->getData();
  35.             }
  36.         } catch (\Exception $e) {
  37.             return;
  38.         }
  40.         if ($this->apiKey && $this->clientId) {
  41.             $this->client = new \AlgoliaSearch\Client($this->clientId, $this->apiKey);
  42.         }
  43.     }
  45.     public function onPostUpdate(ElementEventInterface $e)
  46.     {
  48.         if (!$this->client) {
  49.             return;
  50.         }
  52.         if ($e instanceof DataObjectEvent) {
  54.             $data = $e->getObject();
  56.             if ($data instanceof Product) {
  57.                 /* Ist bei Mefa entstanden */
  58.                 if (method_exists($data, "getAritkelnummer")) {
  59.                     if ($data->getAritkelnummer()) {
  60.                         $success = true;
  61.                     }
  62.                 }
  63.                 /* nach Möglichkeit immer nur über diese Methode gehen */
  64.                 if (method_exists($data, "getOSDoIndexProduct")) {
  65.                     if ($data->getOSDoIndexProduct()) {
  66.                         $success = true;
  67.                     }
  68.                 }
  69.             }
  71.             if($success){
  72.                 $bulkProcess = new \OutputBundle\Model\Algolia\BulkProcess($this->client);
  73.                 $bulkProcess->update([$data]);
  74.             }
  76.         }
  77.         return;
  78.     }
  80.     public function onPostDelete(ElementEventInterface $e)
  81.     {
  83.         if (!$this->client) {
  84.             return;
  85.         }
  87.         if ($e instanceof DataObjectEvent) {
  89.             $algoliaSync = false;
  90.             try {
  91.                 $algolyaSyncSetting = \Pimcore\Model\WebsiteSetting::getByName('algoliaSync');
  92.                 if ($algolyaSyncSetting) {
  93.                     $algoliaSync = $algolyaSyncSetting->getData();
  94.                 }
  95.             } catch (\Exception $e) {
  96.                 return;
  97.             }
  99.             try {
  100.                 $algoliaSkipVariantsSetting = \Pimcore\Model\WebsiteSetting::getByName('algoliaSkipVariants');
  101.                 if ($algoliaSkipVariantsSetting) {
  102.                     $algoliaSkipVariants = $algoliaSkipVariantsSetting->getData();
  103.                 }
  104.             } catch (\Exception $e) {
  105.                 //
  106.                 $algoliaSkipVariants = false;
  107.             }
  109.             $data = $e->getObject();
  110.             $data->setGetInheritedValues(1);
  112.             $type = $data->getType();
  113.             if ($type === "variant" && $algoliaSkipVariants) {
  114.                 return;
  115.             }
  117.             $indexName = $data->getProperty('algoliaIndexName');
  118.             if ($indexName) {
  119.                 $index = $this->client->initIndex($indexName);
  120.             }
  122.             if ($algoliaSync && $indexName && !$data instanceof Folder) {
  124.                // $index->deleteObject($data->getId());
  126.             }
  128.         }
  129.     }
  130. }