src/Controller/Api/SearchController.php line 47

Open in your IDE?
  1. <?php
  3. namespace App\Controller\Api;
  5. use App\Enum\OrganizationStatusEnum;
  6. use App\Service\ElasticSearchService;
  7. use Evo\Infrastructure\MappingORM\Organization;
  8. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  9. use Symfony\Component\HttpFoundation\Request;
  10. use Symfony\Component\HttpKernel\Exception\NotAcceptableHttpException;
  11. use Symfony\Component\Routing\Annotation\Route;
  12. use Symfony\Component\Serializer\SerializerInterface;
  13. use Symfony\Contracts\Translation\TranslatorInterface;
  15. /**
  16.  * @Route("/search")
  17.  */
  18. final class SearchController extends AbstractController
  19. {
  20.     private ElasticSearchService $elasticSearchService;
  21.     private SerializerInterface $serializer;
  22.     private TranslatorInterface $translator;
  24.     public function __construct(
  25.         ElasticSearchService $elasticSearchService,
  26.         SerializerInterface $serializer,
  27.         TranslatorInterface $translator
  28.     ) {
  29.         $this->elasticSearchService = $elasticSearchService;
  30.         $this->serializer = $serializer;
  31.         $this->translator = $translator;
  32.     }
  34.     /**
  35.      * @Route("/mailbox", name="app_search_mailbox", methods={"POST"})
  36.      */
  37.     public function searchFromMailbox(Request $request)
  38.     {
  39.         $content = json_decode($request->getContent(), true, 512, JSON_THROW_ON_ERROR);
  40.         if (!isset($content['search_phrase']) || empty($content['search_phrase'])) {
  41.             throw new \InvalidArgumentException('Not valid search input!');
  42.         }
  44.         $results = $this->elasticSearchService->search(
  45.             ElasticSearchService::CONTEXT_MAILBOX,
  46.             $content['search_phrase'],
  47.             $content['postal_code'] ?? null
  48.         );
  50.         $normalized = $this->serializer->normalize($results, $this->extractFormat($request), [
  51.             'groups' => ['read_search', 'read_search_signature'],
  52.             'callbacks' => $this->getSerializerCallbacks(),
  53.         ]);
  55.         return $this->json($normalized);
  56.     }
  58.     /**
  59.      * @Route("/admin", name="app_search_admin", methods={"POST"})
  60.      */
  61.     public function searchFromAdmin(Request $request)
  62.     {
  63.         $content = json_decode($request->getContent(), true, 512, JSON_THROW_ON_ERROR);
  65.         if (!isset($content['search_phrase']) || empty($content['search_phrase'])) {
  66.             throw new \InvalidArgumentException('Not valid search input!');
  67.         }
  69.         $results = $this->elasticSearchService->search(
  70.             ElasticSearchService::CONTEXT_ADMIN,
  71.             $content['search_phrase'],
  72.             null
  73.         );
  75.         $normalized = $this->serializer->normalize($results, $this->extractFormat($request), [
  76.             'groups' => ['read_search'],
  77.             'callbacks' => $this->getSerializerCallbacks(),
  78.         ]);
  80.         return $this->json($normalized);
  81.     }
  83.     private function extractFormat(Request $request): string
  84.     {
  85.         $acceptable = ['application/ld+json', 'application/json'];
  86.         $header = $request->getAcceptableContentTypes()[0] ?? '*/*';
  88.         // Use json by default if */* is accepted
  89.         $accept = ('*/*' !== $header) ? $header : $acceptable[0];
  90.         if (!in_array($accept, $acceptable, true)) {
  91.             throw new NotAcceptableHttpException();
  92.         }
  94.         return $request->getFormat($accept);
  95.     }
  97.     private function getSerializerCallbacks(): array
  98.     {
  99.         $translator = $this->translator;
  101.         return [
  102.             // For organizations only, translate status
  103.             'statusTranslated' => function ($innerObject, $outerObject, string $attributeName, string $format = null, array $context = []) use ($translator) {
  104.                 if (!$outerObject instanceof Organization) {
  105.                     return '';
  106.                 }
  107.                 if (null === $innerObject) {
  108.                     return '';
  109.                 }
  111.                 if (!OrganizationStatusEnum::isValueExist($innerObject)) {
  112.                     return '';
  113.                 }
  115.                 return $translator->trans(OrganizationStatusEnum::getReadableValue($innerObject));
  116.             },
  117.             'numberOfLetterParcel' => function ($innerObject, $outerObject, string $attributeName, string $format = null, array $context = []) {
  118.                 if ($outerObject instanceof Organization) {
  119.                     $numberOfLetterParcel = $this->getOrganizationNumberOfLetterParcel($outerObject, 'LETTER,LETTER_WITH_AR,NOTICE,BAILIFF_NOTICE,BAILIFF_DEED');
  121.                     return $numberOfLetterParcel + $this->getOrganizationNumberOfLetterParcel($outerObject, 'PARCEL');
  122.                 }
  124.                 return 0;
  125.             },
  126.         ];
  127.     }
  129.     private function getOrganizationNumberOfLetterParcel(Organization $organization, string $type): int
  130.     {
  131.         $letterParcel = $this->forward(LetterController::class.'::letterParcel', [
  132.             'type' => $type,
  133.             'orgaId' => $organization->getId(),
  134.         ]);
  136.         return json_decode($letterParcel->getContent(), null, 512, JSON_THROW_ON_ERROR)->result;
  137.     }
  138. }