custom/plugins/RhiemRentalProducts/src/Subscriber/RentalProduct.php line 46

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Rhiem\RhiemRentalProducts\Subscriber;
  7. use League\Period\Exception;
  8. use Rhiem\RhiemRentalProducts\Components\RentalProduct\DAL\RentalCheapestPriceContainer;
  9. use Rhiem\RhiemRentalProducts\Components\RentalProduct\RentalProductModeInterface;
  10. use Rhiem\RhiemRentalProducts\Components\RentalTime\RentalTime;
  11. use Rhiem\RhiemRentalProducts\Entities\RentalProduct\RentalProductEntity;
  12. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItem\OrderLineItemEntity;
  13. use Shopware\Core\Content\Product\DataAbstractionLayer\CheapestPrice\CheapestPriceContainer;
  14. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. class RentalProduct implements EventSubscriberInterface, RentalProductModeInterface
  20. {
  21.     /**
  22.      * @var EntityRepositoryInterface
  23.      */
  24.     private $rentalProductRepository;
  26.     public function __construct(EntityRepositoryInterface $rentalProductRepository)
  27.     {
  28.         $this->rentalProductRepository = $rentalProductRepository;
  29.     }
  31.     /**
  32.      * @return array
  33.      */
  34.     public static function getSubscribedEvents()
  35.     {
  36.         return [
  37.             'rental_product.written' => 'onRentalProductWritten',
  38.             'order_line_item.loaded' => 'onOrderLineItemLoaded',
  39.             'rental_product.loaded' => 'loaded',
  40.         ];
  41.     }
  43.     /**
  44.      * @throws Exception
  45.      */
  46.     public function onRentalProductWritten(EntityWrittenEvent $event): void
  47.     {
  48.         $writeResults = $event->getWriteResults();
  49.         foreach ($writeResults as $writeResult) {
  50.             $payload = $writeResult->getPayload();
  51.             $rentalTimes = [];
  52.             if (!empty($payload['blockedPeriods'])) {
  53.                 foreach ($payload['blockedPeriods'] as $blockedPeriod) {
  54.                     $rentalTime = RentalTime::createRentalTime(
  55.                         $payload['productId'],
  56.                         $blockedPeriod['blocked_quantity'],
  57.                         $blockedPeriod['rhiem_rental_products_rent_start'],
  58.                         $blockedPeriod['rhiem_rental_products_rent_end'],
  59.                         'blocked',
  60.                         self::DAYRENT,
  61.                         'UTC'
  62.                     );
  63.                     $rentalTimes[] = serialize($rentalTime);
  64.                 }
  65.                 $this->rentalProductRepository->upsert(
  66.                     [
  67.                         [
  68.                             'id' => $payload['id'],
  69.                             'rentalTimes' => $rentalTimes,
  70.                         ],
  71.                     ],
  72.                     $event->getContext()
  73.                 );
  74.             }
  75.         }
  76.     }
  78.     public function onOrderLineItemLoaded(EntityLoadedEvent $event): void
  79.     {
  80.         /** @var OrderLineItemEntity $entity */
  81.         foreach ($event->getEntities() as $entity) {
  82.             $payload = $entity->getPayload();
  83.             if (!empty($payload['rentalProduct']) && !empty($payload['rentalProduct']['rentalTime'])) {
  84.                 $rentalTime = unserialize($payload['rentalProduct']['rentalTime']);
  85.                 $payload['rentalProduct']['rentalTime'] = $rentalTime;
  86.                 $entity->setPayload($payload);
  87.             }
  88.         }
  89.     }
  91.     public function loaded(EntityLoadedEvent $event): void
  92.     {
  93.         /** @var RentalProductEntity $rentalProduct */
  94.         foreach ($event->getEntities() as $rentalProduct) {
  95.             $price = $rentalProduct->getCheapestPrice();
  96.             if ($price instanceof CheapestPriceContainer) {
  97.                 $rentalPrice = new RentalCheapestPriceContainer($price);
  98.                 $resolved = $rentalPrice->resolve($event->getContext());
  99.                 $rentalProduct->setCheapestPriceContainer($price);
  100.                 $rentalProduct->setCheapestPrice($resolved);
  101.             }
  102.         }
  103.     }
  104. }