src/Service/ProfileTopBoard.php line 125

Open in your IDE?
  1. <?php
  2. namespace App\Service;
  3. use App\Dto\ProfileListSpecification;
  4. use App\Entity\Location\City;
  5. use App\Entity\Profile\Profile;
  6. use App\Entity\Sales\Profile\PlacementCharge;
  7. use App\Entity\Sales\Profile\TopPlacement;
  8. use App\Event\Profile\ProfilesShownEvent;
  9. use App\Event\Profile\ProfileWasPlacedOnTop;
  10. use App\Repository\PaidPlacementPriceRepository;
  11. use App\Repository\ProfileTopPlacementRepository;
  12. use Carbon\CarbonImmutable;
  13. use Doctrine\Persistence\ManagerRegistry;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use Doctrine\Persistence\ObjectManager;
  16. use Happyr\DoctrineSpecification\Filter\Filter;
  17. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  18. class ProfileTopBoard
  19. {
  20.     private ?EntityManagerInterface $entityManager;
  21.     public function __construct(
  22.         private ManagerRegistry $managerRegistry,
  23.         private ProfileChargesCalculator $profileChargesCalculator,
  24.         private PaidPlacementPriceRepository  $paidPlacementPriceRepository,
  25.         private AccountFinances $accountFinances,
  26.         private ProfileTopPlacementRepository $profileTopPlacementRepository,
  27.         private EventDispatcherInterface $eventDispatcher,
  28.         private CurrentCityResolver $cityResolver,
  29.         private ProfileAdBoard $profileAdBoard
  30.     )
  31.     {
  32.         $this->entityManager $this->managerRegistry->getManagerForClass(TopPlacement::class);
  33.     }
  34.     public function doPlaceOnTop(Profile $profile\DateTimeImmutable $placedAt\DateTimeImmutable $placedUntil): void
  35.     {
  36.         $city $profile->getCity();
  37.         $timezone $placedAt->getTimezone();
  38.         $now = new \DateTime('now'$timezone);
  39.         if($placedAt->format("Y-m-d H") == $now->format("Y-m-d H")) {
  40.             throw new \LogicException('Нельзя разместить на текущий час'2);
  41.         }
  42.         $placementPrice $this->paidPlacementPriceRepository->getProfileTopPlacementPrice($profile);
  43. //        $charges = $this->profileChargesCalculator->calculateTopPlacementCharges($profile, $placedAt, $placedUntil);
  44. //        $placementCharge = new PlacementCharge($profile, $charges, CarbonImmutable::now(), $placementPrice, $placedAt, $placedUntil);
  45. //        $placement = new TopPlacement($city, $profile, $placementPrice, $placedAt, $placedUntil);
  46.         $placements = [];
  47.         $intervalStart = clone $placedAt;
  48.         while ($intervalStart $placedUntil) {
  49.             $intervalEnd $intervalStart->modify('+1 hour');
  50.             $placements[] = new TopPlacement($city$profile$placementPrice$intervalStart$intervalEnd);
  51.             $intervalStart $intervalEnd;
  52.         }
  53.         $alreadyTakenBySomeone 0;
  54.         $fails 0;
  55.         foreach ($placements as $placement) {
  56.             /** @var TopPlacement $placement */
  57.             $charges $this->profileChargesCalculator->calculateTopPlacementCharges($profile$placement->getPlacedAt(), $placement->getExpiresAt());
  58.             $placementCharge = new PlacementCharge($profile$chargesCarbonImmutable::now(), $placementPrice$placement->getPlacedAt(), $placement->getExpiresAt());
  59.             if(false === $this->entityManager->isOpen()) {
  60.                 $this->managerRegistry->resetManager();
  61.             }
  62.             try {
  63.                 $this->entityManager->transactional(function (EntityManagerInterface $em) use ($city$placement$placementCharge$profile/*, $placedAt, $placedUntil*/, &$alreadyTakenBySomeone): void {
  64.                     $overlaps $this->profileTopPlacementRepository->getPlacementsByPeriod($city$placement->getPlacedAt(), $placement->getExpiresAt());
  65.                     if(count($overlaps)) {
  66.                         $alreadyTakenBySomeone++;
  67.                         return;
  68.                     }
  69.                     $this->accountFinances->processCharge($placementCharge);
  70.                     $em->persist($placement);
  71.                     $profile->addTopPlacement($placement);
  72.                     $this->eventDispatcher->dispatch(new ProfileWasPlacedOnTop($profile$placement), ProfileWasPlacedOnTop::NAME);
  73.                 });
  74.             } catch(\Throwable $e) {
  75.                 $fails++;
  76.             }
  77.         }
  78.         if($alreadyTakenBySomeone 0) {
  79.             throw new \LogicException('Некоторые из выбранных промежутков уже заняты.'1);
  80.         }
  81.         if($fails 0) {
  82.             throw new \LogicException('Некоторые из выбранных промежутков не разместились.'2);
  83.         }
  84.     }
  85.     /**
  86.      * @deprecated Теперь для показа топ-размещения учитываются фильтры текущего листинга
  87.      * @see topPlacementSatisfiedBy
  88.      */
  89.     public function currentTopPlacement(bool $increaseShows): ?Profile
  90.     {
  91.         $city $this->cityResolver->resolveCurrentCity();
  92.         $currentTime CarbonImmutable::now();
  93.         $profile $this->profileTopPlacementRepository->getCurrentlyPlaced($city$currentTime);
  94.         if($profile) {
  95.             $this->profileAdBoard->deleteProfileHiding($profile);
  96.             if($increaseShows) {
  97.                 $this->eventDispatcher->dispatch(new ProfilesShownEvent([$profile->getId()], 'top'), ProfilesShownEvent::NAME);
  98.             }
  99.         }
  100.         return $profile;
  101.     }
  102.     public function topPlacementSatisfiedBy(City $city, ?Filter $spec null): ?Profile
  103.     {
  104.         $currentTime CarbonImmutable::now();
  105.         return $this->profileTopPlacementRepository->getCurrentlyPlacedAndSatisfiedBy($city$currentTime$spec);
  106.     }
  107. }