src/EntityCallback/ProductCallback.php line 85

Open in your IDE?
  1. <?php
  3. /**
  4.  * Copyright (c) 2011-present Qualiteam software Ltd. All rights reserved.
  5.  * See https://www.x-cart.com/license-agreement.html for license details.
  6.  */
  8. namespace XCart\EntityCallback;
  10. use Doctrine\ORM\EntityManagerInterface;
  11. use Doctrine\Persistence\Event\LifecycleEventArgs;
  12. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  13. use XCart\Doctrine\CallbackManager\CallbackManager;
  14. use XCart\Event\Service\DeferrerCallbackRunEvent;
  15. use XLite\Model\Product;
  17. final class ProductCallback
  18. {
  19.     public function __construct(
  20.         private CallbackManager $callbackManager,
  21.         private EntityManagerInterface $entityManager
  22.     ) {
  23.     }
  25.     public function prePersist(Product $product, LifecycleEventArgs $args): void
  26.     {
  27.         $time = \XLite\Core\Converter::time();
  28.         if (!$product->getDate()) {
  29.             $product->setDate($time);
  30.         }
  32.         if (!$product->getArrivalDate()) {
  33.             $product->setArrivalDate(
  34.                 mktime(0, 0, 0, date('m', $time), date('j', $time), date('Y', $time))
  35.             );
  36.         }
  38.         $this->preUpdate($product, $args);
  39.     }
  41.     public function preUpdate(Product $product, LifecycleEventArgs $args): void
  42.     {
  43.         $product->setUpdateDate(\XLite\Core\Converter::time());
  45.         if (\XLite\Core\Converter::isEmptyString($product->getSku())) {
  46.             $product->setSku(null);
  47.         }
  48.     }
  50.     public function postUpdate(Product $product, LifecycleEventArgs $args): void
  51.     {
  52.         if (
  53.             $product->isLowLimitReached()
  54.             && $product->isShouldSend()
  55.             && $product->isInventoryChanged()
  56.         ) {
  57.             $product->sendLowLimitNotification();
  58.         }
  60.         $context = $this->callbackManager->getContextValue();
  61.         if (!in_array($context, ['import', 'load-fixtures', 'remove-data'], true)) {
  62.             $this->callbackManager->addDeferredCallback(
  63.                 'quickDataProductRecalculate',
  64.                 [
  65.                     $product->getProductId()
  66.                 ]
  67.             );
  68.         }
  69.     }
  71.     public function postPersist(Product $product, LifecycleEventArgs $args): void
  72.     {
  73.         $context = $this->callbackManager->getContextValue();
  75.         if (!in_array($context, ['import', 'load-fixtures'], true)) {
  76.             $this->callbackManager->addDeferredCallback(
  77.                 'quickDataProductRecalculate',
  78.                 [
  79.                     $product->getProductId()
  80.                 ]
  81.             );
  82.         }
  83.     }
  85.     public function runQuickData(
  86.         DeferrerCallbackRunEvent $callbackRunEvent,
  87.         string $eventName,
  88.         EventDispatcherInterface $dispatcher
  89.     ): void {
  90.         if ($dtos = $callbackRunEvent->getCallbackDto('quickDataProductRecalculate')) {
  91.             foreach ($dtos as $dto) {
  92.                 if ($productId = $dto->getArgs()[0]) {
  93.                     $this->entityManager
  94.                         ->getRepository(Product::class)
  95.                         ->find($productId)
  96.                         ?->updateQuickData();
  97.                 }
  98.             }
  99.         }
  100.     }
  101. }