vendor/pimcore/portal-engine/src/Service/StatisticsTracker/Elasticsearch/AssetUpdateTracker.php line 98

Open in your IDE?
  1. <?php
  3. /**
  4.  * Pimcore
  5.  *
  6.  * This source file is available under following license:
  7.  * - Pimcore Commercial License (PCL)
  8.  *
  9.  *  @copyright  Copyright (c) Pimcore GmbH (http://www.pimcore.org)
  10.  *  @license    http://www.pimcore.org/license     PCL
  11.  */
  13. namespace Pimcore\Bundle\PortalEngineBundle\Service\StatisticsTracker\Elasticsearch;
  15. use Pimcore\Bundle\PortalEngineBundle\Enum\ElasticSearchFields;
  16. use Pimcore\Bundle\PortalEngineBundle\Model\DataObject\PortalUserInterface;
  17. use Pimcore\Bundle\PortalEngineBundle\Service\Security\SecurityService;
  18. use Pimcore\Bundle\StatisticsExplorerBundle\StatisticsTracker\Elasticsearch\AbstractElasticsearchTracker;
  19. use Pimcore\Model\User;
  21. /**
  22.  * Class AssetUpdateTracker
  23.  *
  24.  * @package Pimcore\Bundle\PortalEngineBundle\Service\StatisticsTracker\Elasticsearch
  25.  */
  26. class AssetUpdateTracker extends AbstractElasticsearchTracker
  27. {
  28.     /**
  29.      * @var string
  30.      */
  31.     protected $indexName;
  33.     /** @var SecurityService */
  34.     protected $securityService;
  36.     /**
  37.      * @param SecurityService $securityService
  38.      * @required
  39.      */
  40.     public function setSecurityService(SecurityService $securityService)
  41.     {
  42.         $this->securityService = $securityService;
  43.     }
  45.     /**
  46.      * @return array
  47.      */
  48.     protected function buildMappingArray(): array
  49.     {
  50.         return [
  51.             'timestamp' => ['type' => 'date'],
  52.             'pimcoreUserId' => ['type' => 'long'],
  53.             'userId' => ['type' => 'long'],
  54.             'path' => ['type' => 'keyword'],
  55.             ElasticSearchFields::SYSTEM_FIELDS => [
  56.                 'type' => 'object',
  57.                 'properties' => [
  58.                     ElasticSearchFields::SYSTEM_FIELDS_FULL_PATH => [
  59.                         'type' => 'text',
  60.                         'analyzer' => 'portal_engine_path_analyzer',
  61.                     ],
  62.                     ElasticSearchFields::SYSTEM_FIELDS_ID => [
  63.                         'type' => 'long',
  64.                     ],
  65.                     ElasticSearchFields::SYSTEM_FIELDS_KEY => [
  66.                         'type' => 'keyword',
  67.                     ],
  68.                 ],
  70.             ]
  71.         ];
  72.     }
  74.     /**
  75.      * @return string
  76.      */
  77.     protected function getIndexName(): string
  78.     {
  79.         return $this->indexName;
  80.     }
  82.     /**
  83.      * @param string $indexName
  84.      */
  85.     public function setIndexName(string $indexName): void
  86.     {
  87.         $this->indexName = $indexName;
  88.     }
  90.     /**
  91.      * @param array $parameters
  92.      *
  93.      * @throws \Exception
  94.      */
  95.     public function trackEvent(array $parameters): void
  96.     {
  97.         /** @var User|null $pimcoreUser */
  98.         $pimcoreUser = $this->securityService->getPimcoreUser();
  99.         /** @var PortalUserInterface|null $portalUser */
  100.         $portalUser = $this->securityService->getPortalUser();
  102.         if ($pimcoreUser || $portalUser) {
  103.             /** @var array $values */
  104.             $values = [
  105.                 'timestamp' => (new \DateTime())->format(\DateTime::ISO8601),
  106.                 'pimcoreUserId' => $pimcoreUser ? $pimcoreUser->getId() : null,
  107.                 'userId' => $portalUser ? $portalUser->getId() : null,
  108.                 'path' => $parameters['asset']->getRealFullPath(),
  109.                 ElasticSearchFields::SYSTEM_FIELDS => [
  110.                     ElasticSearchFields::SYSTEM_FIELDS_FULL_PATH => $parameters['asset']->getRealFullPath(),
  111.                     ElasticSearchFields::SYSTEM_FIELDS_ID => $parameters['asset']->getId(),
  112.                     ElasticSearchFields::SYSTEM_FIELDS_KEY => $parameters['asset']->getKey(),
  113.                 ]
  114.             ];
  115.             $this->doTrackEvent($values);
  116.         }
  117.     }
  119.     /**
  120.      * @return array
  121.      */
  122.     protected function createIndexSettings()
  123.     {
  124.         return [
  125.             'analysis' => [
  126.                 'tokenizer' => [
  127.                     'portal_engine_path_tokenizer' => [
  128.                         'type' => 'path_hierarchy',
  129.                     ],
  130.                 ],
  131.                 'analyzer' => [
  132.                     'portal_engine_path_analyzer' => [
  133.                         'tokenizer' => 'portal_engine_path_tokenizer',
  134.                     ],
  135.                 ],
  136.             ],
  137.         ];
  138.     }
  139. }