src/Service/Top100ProfilesService.php line 114

Open in your IDE?
  1. <?php
  3. namespace App\Service;
  5. use App\Dto\Top100\Top100ProfileQueryByIdsDTO;
  6. use App\Dto\Top100\Top100ProfileQueryRandomDTO;
  7. use App\Entity\Location\City;
  8. use App\Entity\Profile\Genders;
  9. use App\Repository\ProfileCtrRepository;
  10. use App\Service\Top100\Top100ProfileQueryService;
  11. use App\Specification\Profile\ProfileIdNotIn;
  12. use App\Specification\Profile\ProfileIsApproved;
  13. use Psr\Cache\CacheItemPoolInterface;
  15. class Top100ProfilesService
  16. {
  18.     public const LIMIT = 100;
  20.     public const GENDERS_DEFAULT = [Genders::FEMALE];
  22.     public function __construct(
  23.         private ProfileCtrRepository $profileCtrRepository,
  24.         private Top100ProfileQueryService $profileQueryService,
  25.         private CacheItemPoolInterface $cache,
  26.     ) {}
  29.     public function getCachedProfileIds(City $city): array
  30.     {
  31.         $cacheKey = $this->getCacheKey($city);
  33.         $cacheItem = $this->cache->getItem($cacheKey);
  34.         if (!$cacheItem->isHit()) {
  35.             return [];
  36.         }
  38.         $profileIds = $cacheItem->get();
  40.         return is_array($profileIds) ? $profileIds : [];
  41.     }
  44.     public function refreshProfileIdsCache(City $city): array
  45.     {
  46.         $cacheKey = $this->getCacheKey($city);
  47.         $profileIds = $this->buildProfileIds($city);
  49.         $cacheItem = $this->cache->getItem($cacheKey);
  50.         $cacheItem->set($profileIds);
  51.         $this->cache->save($cacheItem);
  53.         return $profileIds;
  54.     }
  57.     private function buildProfileIds(City $city): array
  58.     {
  59.         $dateStart = new \DateTimeImmutable('-30 days');
  60.         $rankedIds = $this->profileCtrRepository->topVisitedApprovedProfileIdsInCity($city, $dateStart, self::LIMIT);
  62.        
  63.         $rankedProfiles = empty($rankedIds)
  64.             ? []
  65.             : $this->profileQueryService->getActiveProfilesByIds(
  66.                 new Top100ProfileQueryByIdsDTO(
  67.                     city: $city,
  68.                     ids: $rankedIds,
  69.                     filters: [new ProfileIsApproved()],
  70.                     genders: self::GENDERS_DEFAULT,
  71.                     limit: self::LIMIT,
  72.                 )
  73.             );
  75.         
  76.         $ranked = array_map(static fn($profile) => $profile->id, $rankedProfiles);
  78.         if (count($ranked) >= self::LIMIT) {
  79.             return array_slice($ranked, 0, self::LIMIT);
  80.         }
  82.         $toFill = self::LIMIT - count($ranked);
  84.         $randomFilters = [new ProfileIsApproved()];
  85.         if (!empty($ranked)) {
  86.             $randomFilters[] = new ProfileIdNotIn($ranked);
  87.         }
  89.         $randomDto = new Top100ProfileQueryRandomDTO(
  90.             city: $city,
  91.             filters: $randomFilters,
  92.             genders: self::GENDERS_DEFAULT,
  93.             limit: $toFill,
  94.         );
  95.        
  96.         $randomApproved = $this->profileQueryService->getRandomProfiles($randomDto);
  98.         
  99.         $randomIds = array_map(static fn($profile) => $profile->id, $randomApproved);
  100.         return array_merge($ranked, $randomIds);
  101.     }
  103.     private function getCacheKey(City $city): string
  104.     {
  105.         return sprintf('listing.top_100.profile_ids.city.%d', $city->getId());
  106.     }
  107.     
  110.     public function getSortedProfilesByVisits(City $city): \Porpaginas\Page
  111.     {
  112.         $rankedIds = $this->getCachedProfileIds($city);
  113.         
  114.         $rankedProfiles = $this->profileQueryService->getActiveProfilesByIds(
  115.             new Top100ProfileQueryByIdsDTO(
  116.                 city: $city,
  117.                 ids: $rankedIds,
  118.                 filters: [new ProfileIsApproved()],
  119.                 genders: self::GENDERS_DEFAULT,
  120.                 limit: self::LIMIT,
  121.             )
  122.         );
  124.         return $this->profileQueryService->createFakePageFromProfiles(count($rankedProfiles), $rankedProfiles);
  125.     }
  126. }