src/ElasticSearch/Worker/AppElasticSearchWorker.php line 19

Open in your IDE?
  1. <?php
  3. namespace App\ElasticSearch\Worker;
  5. use App\ElasticSearch\ProductList\AppElasticSearch;
  6. use Pimcore\Bundle\EcommerceFrameworkBundle\IndexService\ProductList\ProductListInterface;
  7. use Pimcore\Bundle\EcommerceFrameworkBundle\IndexService\Worker\ElasticSearch\DefaultElasticSearch7;
  9. /**
  10.  *  Use this for ES Version >= 6
  11.  */
  12. class AppElasticSearchWorker extends DefaultElasticSearch7
  13. {
  14.     /**
  15.      * returns product list implementation valid and configured for this worker/tenant
  16.      *
  17.      * @return ProductListInterface
  18.      */
  19.     public function getProductList()
  20.     {
  21.         return new AppElasticSearch($this->tenantConfig);
  22.     }
  24.     protected function doUpdateIndex($objectId, $data = null, $metadata = null)
  25.     {
  26.         //This method is overridden because of line 84 and 87
  27.         //Those lines had a param that was throwing errors
  28.         //Param was '_routing' and it was changed for 'routing'.
  29.         //Underscore was not needed
  31. //        $isLocked = $this->checkIndexLock(false);
  32. //
  33. //        if ($isLocked) {
  34. //            return;
  35. //        }
  37.         if (empty($data)) {
  38.             $dataEntry = $this->db->fetchRow('SELECT data, metadata FROM ' . $this->getStoreTableName() . ' WHERE o_id = ? AND tenant = ?', [$objectId, $this->name]);
  39.             if ($dataEntry) {
  40.                 $data = json_decode($dataEntry['data'], true);
  41.                 $metadata = $dataEntry['metadata'];
  43.                 $jsonDecodeError = json_last_error();
  44.                 if ($jsonDecodeError !== JSON_ERROR_NONE) {
  45.                     throw new \Exception("Could not decode store data for updating index - maybe there is invalid json data. Json decode error code was {$jsonDecodeError}, ObjectId was {$objectId}.");
  46.                 }
  47.             }
  48.         }
  50.         if ($data) {
  51.             $systemAttributeKeys = $this->getSystemAttributes(true);
  53.             $indexSystemData = [];
  54.             $indexAttributeData = [];
  55.             $indexRelationData = [];
  57.             $data = $this->doPreIndexDataModification($data);
  59.             //add system and index attributes
  60.             foreach ($data['data'] as $dataKey => $dataEntry) {
  61.                 if (array_key_exists($dataKey, $systemAttributeKeys)) {
  62.                     //add this key to system attributes
  63.                     $indexSystemData[$dataKey] = $dataEntry;
  64.                 } else {
  65.                     //add this key to custom attributes
  66.                     $indexAttributeData[$dataKey] = $dataEntry;
  67.                 }
  68.             }
  70.             //fix categories to array
  71.             $indexSystemData['categoryIds'] = array_values(array_filter(explode(',', $indexSystemData['categoryIds'])));
  72.             $indexSystemData['parentCategoryIds'] = array_values(array_filter(explode(',', $indexSystemData['parentCategoryIds'])));
  74.             //add relation attributes
  75.             foreach ($data['relations'] as $relation) {
  76.                 $indexRelationData[$relation['fieldname']][] = $relation['dest'];
  77.             }
  79.             //check if parent should exist and if so, consider parent relation at indexing
  80.             $routingId = $indexSystemData['o_type'] == ProductListInterface::PRODUCT_TYPE_VARIANT ? $indexSystemData['o_virtualProductId'] : $indexSystemData['o_id'];
  82.             if ($metadata !== null && $routingId != $metadata) {
  83.                 //routing has changed, need to delete old ES entry
  84.                 $this->bulkIndexData[] = ['delete' => ['_index' => $this->getIndexNameVersion(), '_type' => $this->getTenantConfig()->getElasticSearchClientParams()['indexType'], '_id' => $objectId, 'routing' => $metadata]];
  85.             }
  87.             $this->bulkIndexData[] = ['index' => ['_index' => $this->getIndexNameVersion(), '_type' => $this->getTenantConfig()->getElasticSearchClientParams()['indexType'], '_id' => $objectId, 'routing' => $routingId]];
  88.             $bulkIndexData = array_filter(['system' => array_filter($indexSystemData), 'type' => $indexSystemData['o_type'], 'attributes' => array_filter($indexAttributeData, function ($value) {
  89.                 return $value !== null;
  90.             }), 'relations' => $indexRelationData, 'subtenants' => $data['subtenants']]);
  92.             if ($indexSystemData['o_type'] == ProductListInterface::PRODUCT_TYPE_VARIANT) {
  93.                 $bulkIndexData[self::RELATION_FIELD] = ['name' => $indexSystemData['o_type'], 'parent' => $indexSystemData['o_virtualProductId']];
  94.             } else {
  95.                 $bulkIndexData[self::RELATION_FIELD] = ['name' => $indexSystemData['o_type']];
  96.             }
  97.             $this->bulkIndexData[] = $bulkIndexData;
  98.             $this->indexStoreMetaData[$objectId] = $routingId;
  99.         }
  100.     }
  101. }