src/EventSubscriber/ESProfilePostTransformSubscriber.php line 33

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