src/Entity/Sales/PaidPlacementPrice.php line 28

Open in your IDE?
  1. <?php
  2. /**
  3.  * Created by simpson <simpsonwork@gmail.com>
  4.  * Date: 2019-06-26
  5.  * Time: 18:00
  6.  */
  8. namespace App\Entity\Sales;
  10. use App\Entity\Location\City;
  11. use App\Repository\PaidPlacementPriceRepository;
  12. use Doctrine\ORM\Mapping as ORM;
  13. use Money\Currency;
  14. use Money\Money;
  16. #[ORM\Table(name: 'paid_service_prices')]
  17. #[ORM\Entity(repositoryClass: PaidPlacementPriceRepository::class)]
  18. #[ORM\InheritanceType('SINGLE_TABLE')]
  19. #[ORM\DiscriminatorColumn(name: 'placement_type', type: 'string', length: 32)]
  20. #[ORM\DiscriminatorMap([
  21.     'standard_saloon' => Saloon\StandardPlacementPrice::class, 'vip_saloon' => Saloon\VipPlacementPrice::class,
  22.     'ultra_vip_saloon' => Saloon\UltraVipPlacementPrice::class, 'standard_masseur' => Profile\MasseurPlacementPrice::class,
  23.     'vip_masseur' => Profile\MasseurVipPlacementPrice::class, 'ultra_vip_masseur' => Profile\MasseurUltraVipPlacementPrice::class,
  24.     'standard_profile' => Profile\StandardPlacementPrice::class, 'vip_profile' => Profile\VipPlacementPrice::class,
  25.     'ultra_vip_profile' => Profile\UltraVipPlacementPrice::class, 'top_profile' => Profile\TopPlacementPrice::class,
  26.     'placement_hiding' => PlacementHidingPrice::class
  27. ])]
  28. abstract class PaidPlacementPrice
  29. {
  30.     const SECONDS_IN_HOUR = 3600;
  31.     const SECONDS_IN_DAY = 86400;
  32.     public const WEEKDAY_GROUP_MON_THU = 1;
  33.     public const WEEKDAY_GROUP_FRI = 2;
  34.     public const WEEKDAY_GROUP_SAT_SUN = 3;
  35.     public const TIME_GROUP_NIGHT = 1; // 00:00-02:59
  36.     public const TIME_GROUP_MORNING = 2; // 03:00-09:59
  37.     public const TIME_GROUP_DAY = 3; // 10:00-16:59
  38.     public const TIME_GROUP_EVENING = 4; // 17:00-23:59
  40.     #[ORM\Id]
  41.     #[ORM\Column(name: 'id', type: 'integer')]
  42.     #[ORM\GeneratedValue(strategy: 'AUTO')]
  43.     protected int $id;
  45.     #[ORM\JoinColumn(name: 'city_id', referencedColumnName: 'id')]
  46.     #[ORM\ManyToOne(targetEntity: City::class)]
  47.     protected ?City $city;
  49.     #[ORM\Column(name: 'price_amount', type: 'integer', nullable: true)]
  50.     protected ?int $priceAmount;
  52.     #[ORM\Column(name: 'currency', type: 'string', length: 3)]
  53.     protected string $currency;
  55.     /**
  56.      * Кол-во оплаченного времени по ценнику
  57.      *
  58.      * 3600 - цена в час
  59.      * 86400 - цена в сутки
  60.      */
  61.     #[ORM\Column(name: 'duration', type: 'integer')]
  62.     protected int $duration;
  64.     #[ORM\Column(name: 'enabled', type: 'boolean')]
  65.     protected bool $enabled = false;
  67.     #[ORM\Column(name: 'city_price_category', type: 'smallint', nullable: true)]
  68.     protected ?int $cityPriceCategory = null;
  70.     #[ORM\Column(name: 'dynamic_price_matrix', type: 'json', nullable: true)]
  71.     protected ?array $dynamicPriceMatrix = null;
  73.     public static function createHourlyPrice(?City $city, Money $price): self
  74.     {
  75.         return new static($city, $price, self::SECONDS_IN_HOUR);
  76.     }
  78.     public static function createDailyPrice(?City $city, Money $price): self
  79.     {
  80.         return new static($city, $price, self::SECONDS_IN_DAY);
  81.     }
  83.     protected function __construct(?City $city, Money $basePrice, int $duration)
  84.     {
  85.         $this->city = $city;
  86.         $this->priceAmount = (int)$basePrice->getAmount();
  87.         $this->currency = $basePrice->getCurrency()->getCode();
  88.         $this->duration = $duration;
  89.     }
  91.     public function getId(): int
  92.     {
  93.         return $this->id;
  94.     }
  96.     public function getCity(): ?City
  97.     {
  98.         return $this->city;
  99.     }
  101.     protected function getBasePrice(): Money
  102.     {
  103.         if (null === $this->priceAmount) {
  104.             throw new \LogicException('Base price is not available for dynamic matrix price.');
  105.         }
  107.         return new Money($this->priceAmount, new Currency($this->currency));
  108.     }
  110.     public function getHourlyPrice(): Money
  111.     {
  112.         if ($this->isDynamicPrice()) {
  113.             return $this->resolveDynamicHourlyPriceAt(new \DateTimeImmutable('now'));
  114.         }
  116.         $basePrice = $this->getBasePrice();
  118.         return new Money(+$basePrice->getAmount() * self::SECONDS_IN_HOUR / $this->duration, $basePrice->getCurrency());
  119.     }
  121.     public function getDailyPrice(): Money
  122.     {
  123.         if ($this->isDynamicPrice()) {
  124.             $hourlyAmount = (int)$this->resolveDynamicHourlyPriceAt(new \DateTimeImmutable('now'))->getAmount();
  126.             return new Money($hourlyAmount * 24, new Currency($this->currency));
  127.         }
  129.         $basePrice = $this->getBasePrice();
  131.         return new Money(+$basePrice->getAmount() * self::SECONDS_IN_DAY / $this->duration, $basePrice->getCurrency());
  132.     }
  134.     public function calculatePriceByTimeRange(\DateTimeInterface $from, \DateTimeInterface $till, ?\DateTimeZone $timezone = null): Money
  135.     {
  136.         if ($this->isDynamicPrice()) {
  137.             return $this->calculateDynamicPriceByTimeRange($from, $till, $timezone);
  138.         }
  140.         $diffInSeconds = abs($till->getTimestamp() - $from->getTimestamp());
  141.         $basePrice = $this->getBasePrice();
  143.         return new Money(+$basePrice->getAmount() * $diffInSeconds / $this->duration, $basePrice->getCurrency());
  144.     }
  146.     public function isEnabled(): bool
  147.     {
  148.         return $this->enabled;
  149.     }
  151.     public function setEnabled(bool $enabled): void
  152.     {
  153.         $this->enabled = $enabled;
  154.     }
  156.     public function getCityPriceCategory(): ?int
  157.     {
  158.         return $this->cityPriceCategory;
  159.     }
  161.     public function setDynamicPriceMatrix(int $cityPriceCategory, array $matrix): void
  162.     {
  163.         if ($cityPriceCategory < City::PRICE_CATEGORY_1 || $cityPriceCategory > City::PRICE_CATEGORY_5) {
  164.             throw new \InvalidArgumentException(sprintf('Unexpected city price category %d.', $cityPriceCategory));
  165.         }
  167.         $normalizedMatrix = [];
  168.         foreach ([self::WEEKDAY_GROUP_MON_THU, self::WEEKDAY_GROUP_FRI, self::WEEKDAY_GROUP_SAT_SUN] as $weekdayGroup) {
  169.             if (!isset($matrix[$weekdayGroup]) || !is_array($matrix[$weekdayGroup])) {
  170.                 throw new \InvalidArgumentException(sprintf('Dynamic matrix weekday group %d is missing.', $weekdayGroup));
  171.             }
  173.             $normalizedMatrix[(string)$weekdayGroup] = [];
  174.             foreach ([self::TIME_GROUP_NIGHT, self::TIME_GROUP_MORNING, self::TIME_GROUP_DAY, self::TIME_GROUP_EVENING] as $timeGroup) {
  175.                 if (!array_key_exists($timeGroup, $matrix[$weekdayGroup])) {
  176.                     throw new \InvalidArgumentException(sprintf('Dynamic matrix slot %d/%d is missing.', $weekdayGroup, $timeGroup));
  177.                 }
  179.                 $amount = (int)$matrix[$weekdayGroup][$timeGroup];
  180.                 if ($amount < 0) {
  181.                     throw new \InvalidArgumentException(sprintf('Dynamic matrix slot %d/%d should not be negative.', $weekdayGroup, $timeGroup));
  182.                 }
  184.                 $normalizedMatrix[(string)$weekdayGroup][(string)$timeGroup] = $amount;
  185.             }
  186.         }
  188.         $this->city = null;
  189.         $this->cityPriceCategory = $cityPriceCategory;
  190.         $this->dynamicPriceMatrix = $normalizedMatrix;
  191.         $this->priceAmount = null;
  192.         $this->duration = self::SECONDS_IN_DAY;
  193.     }
  195.     public function isDynamicPrice(): bool
  196.     {
  197.         return null !== $this->dynamicPriceMatrix;
  198.     }
  200.     public function getDynamicPriceMatrix(): ?array
  201.     {
  202.         return $this->dynamicPriceMatrix;
  203.     }
  205.     public function resolveDynamicHourlyPriceAt(\DateTimeInterface $dateTime, ?\DateTimeZone $timezone = null): Money
  206.     {
  207.         if (!$this->isDynamicPrice()) {
  208.             return $this->getHourlyPrice();
  209.         }
  211.         $matrix = $this->dynamicPriceMatrix;
  212.         if (null === $matrix) {
  213.             throw new \LogicException('Dynamic price matrix is not set.');
  214.         }
  216.         $dateTimeInTimezone = \DateTimeImmutable::createFromInterface($dateTime)->setTimezone($this->resolveTimezone($timezone));
  217.         $weekdayGroup = self::resolveWeekdayGroup($dateTimeInTimezone);
  218.         $timeGroup = self::resolveTimeGroup($dateTimeInTimezone);
  219.         $amount = (int)($matrix[(string)$weekdayGroup][(string)$timeGroup] ?? 0);
  221.         return new Money($amount, new Currency($this->currency));
  222.     }
  224.     abstract static public function getType(): string;
  226.     public static function resolveWeekdayGroup(\DateTimeInterface $dateTime): int
  227.     {
  228.         $weekDay = (int)$dateTime->format('N');
  229.         if ($weekDay === 5) {
  230.             return self::WEEKDAY_GROUP_FRI;
  231.         }
  232.         if ($weekDay >= 6) {
  233.             return self::WEEKDAY_GROUP_SAT_SUN;
  234.         }
  236.         return self::WEEKDAY_GROUP_MON_THU;
  237.     }
  239.     public static function resolveTimeGroup(\DateTimeInterface $dateTime): int
  240.     {
  241.         $hour = (int)$dateTime->format('G');
  242.         if ($hour <= 2) {
  243.             return self::TIME_GROUP_NIGHT;
  244.         }
  245.         if ($hour <= 9) {
  246.             return self::TIME_GROUP_MORNING;
  247.         }
  248.         if ($hour <= 16) {
  249.             return self::TIME_GROUP_DAY;
  250.         }
  252.         return self::TIME_GROUP_EVENING;
  253.     }
  255.     private function calculateDynamicPriceByTimeRange(\DateTimeInterface $from, \DateTimeInterface $till, ?\DateTimeZone $timezone = null): Money
  256.     {
  257.         $fromDate = \DateTimeImmutable::createFromInterface($from);
  258.         $tillDate = \DateTimeImmutable::createFromInterface($till);
  259.         if ($tillDate <= $fromDate) {
  260.             return new Money(0, new Currency($this->currency));
  261.         }
  263.         $slotTimezone = $this->resolveTimezone($timezone);
  264.         $amountNumerator = 0;
  265.         $cursor = $fromDate;
  266.         while ($cursor < $tillDate) {
  267.             $nextHour = $cursor->modify('+1 hour');
  268.             if ($nextHour > $tillDate) {
  269.                 $nextHour = $tillDate;
  270.             }
  272.             $hourlyPrice = $this->resolveDynamicHourlyPriceAt($cursor, $slotTimezone);
  273.             $seconds = $nextHour->getTimestamp() - $cursor->getTimestamp();
  274.             $amountNumerator += ((int)$hourlyPrice->getAmount() * $seconds);
  275.             $cursor = $nextHour;
  276.         }
  278.         return new Money((string)intdiv($amountNumerator, self::SECONDS_IN_HOUR), new Currency($this->currency));
  279.     }
  281.     private function resolveTimezone(?\DateTimeZone $timezone): \DateTimeZone
  282.     {
  283.         if (null !== $timezone) {
  284.             return $timezone;
  285.         }
  287.         if (null !== $this->city && null !== $this->city->getTimezone()) {
  288.             return new \DateTimeZone($this->city->getTimezone());
  289.         }
  291.         return new \DateTimeZone('UTC');
  292.     }
  293. }