src/EventSubscriber/ESProfilePostTransformSubscriber.php line 25

Open in your IDE?
  1. <?php
  2. namespace App\EventSubscriber;
  4. use AngelGamez\TranslatableBundle\Entity\TranslatableValue;
  5. use App\Entity\Location\Station;
  6. use App\Entity\Profile\Profile;
  7. use App\Entity\Profile\ProfileService;
  8. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use FOS\ElasticaBundle\Event\TransformEvent;
  12. class ESProfilePostTransformSubscriber implements EventSubscriberInterface
  13. {
  14.     const INDEX_RECOMMENDATIONS = 'recommendations';
  15.     const INDEX_DESCRIPTION = 'description';
  16.     const INDEX_KEY_SEARCH = 'key_search';
  18.     private $siteLanguages = ['en', 'ru'];
  20.     public function __construct(ParameterBagInterface $parameterBag)
  21.     {
  22.         $this->siteLanguages = $parameterBag->get('app.allowed_locales');
  23.     }
  25.     public function postTransformEntity(TransformEvent $event): void
  26.     {
  27.         $document = $event->getDocument();
  28.         if ($event->getObject() instanceof Profile) {
  30.             /** @var Profile $profile */
  31.             $profile = $event->getObject();
  33.             switch($document->getIndex()) {
  34.                 case self::INDEX_RECOMMENDATIONS:
  36.                     $document->set('selfie', $profile->hasSelfie());
  37.                     $document->set('video', $profile->hasVideo());
  38.                     $document->set('commented', $profile->isCommented());
  39.                     $document->set('primaryStationId', $profile->getStations()->count() ? $profile->getStations()->first()->getId() : null);
  41.                     $stations = [];
  42.                     foreach($profile->getStations()->toArray() as $k => $v) {
  43.                         if($k == 0)
  44.                             continue;
  45.                         $stations[] = $profile->getStations()->get($k)->getId();
  46.                     }
  47.                     $document->set('secondaryStationsIds', $stations);
  49.                     $document->set('description', $this->translatableValueToAllLanguages($profile->getDescription()));
  51.                     break;
  53.                 case self::INDEX_DESCRIPTION:
  55.                     $text = $profile->getDescription()->getTranslation('ru');
  56.                     preg_match_all('/\w+/u', $text, $matches);
  57.                     $words3charsMin = array_filter($matches[0], function($match): bool {
  58.                         return mb_strlen($match) >= 3;
  59.                     });
  61.                     $document->set('descRu', $text);
  62.                     $document->set('descRu3ChrWords', count($words3charsMin));
  63.                     $document->set('descRuWords', count($matches[0]));
  65.                     break;
  67.                 case self::INDEX_KEY_SEARCH:
  69.                     $searchKeysData = ''
  70.                         . $this->getParamString($profile->getPhoneNumber())
  71.                         . $this->getParamString($this->translatableValueToAllLanguages($profile->getName()))
  72.                         . $this->getParamString($profile->getPersonParameters()->getAge())
  73.                         . $this->getParamString($this->translatableValueToAllLanguages($profile->getCity()->getName()))
  74.                         . $this->getParamString(implode(' ', $profile->getStations()->map(function (Station $station): string {
  75.                             $district = $station->getDistrict();
  76.                             return $district ? $this->translatableValueToAllLanguages($district->getName()) : '';
  77.                         })->toArray()))
  78.                         . $this->getParamString(implode(' ', $profile->getStations()->map(function (Station $station): string {
  79.                             $county = $station->getCounty();
  80.                             return $county ? $this->translatableValueToAllLanguages($county->getName()) : '';
  81.                         })->toArray()))
  82.                         . $this->getParamString(implode(' ', $profile->getStations()->map(function (Station $station): string {
  83.                             return $this->translatableValueToAllLanguages($station->getName());
  84.                         })->toArray()))
  85.                         . $this->getParamString(implode(' ', $profile->getProvidedServices()->map(function (ProfileService $profileService): string {
  86.                             return $this->translatableValueToAllLanguages($profileService->getService()->getName());
  87.                         })->toArray()))
  88.                         . $this->getParamString($this->translatableValueToAllLanguages($profile->getDescription()));
  90.                     $searchKeysData = ltrim($searchKeysData, ' ; ');
  92.                     $document->set('searchKeysData', $searchKeysData);
  94.                     break;
  95.             }
  96.         }
  97.     }
  99.     public static function getSubscribedEvents()
  100.     {
  101.         return array(
  102.             TransformEvent::POST_TRANSFORM => 'postTransformEntity',
  103.         );
  104.     }
  106.     protected function getParamString(string $param): string
  107.     {
  108.         return ' ; ' . $param;
  109.     }
  111.     protected function translatableValueToAllLanguages(TranslatableValue $translatableValue): string
  112.     {
  113.         $str = '';
  114.         array_walk($this->siteLanguages, function($language) use (&$str, $translatableValue): void {
  115.             $str .= ' ' . $translatableValue->getTranslation($language);
  116.         });
  118.         return $str;
  119.     }
  120. }