src/App/EventListener/Custom/Labas/PostListener.php line 94

Open in your IDE?
  1. <?php
  3. namespace App\EventListener\Custom\Labas;
  5. use App\Entity\Central\Client\Client;
  6. use App\Entity\Client\PointOfSale\PointOfSaleMove;
  7. use App\Entity\Client\Store\StoreHeader;
  8. use App\EventListener\GenericEvent;
  9. use App\Exception\ValidationException;
  10. use App\Model\ShellExec;
  11. use App\Service\AppManager;
  12. use App\Service\ShellExecManager;
  13. use App\Utils\ClientUtils;
  14. use Eshop\Entity\Customer\CustomerOrder;
  15. use Symfony\Contracts\Translation\TranslatorInterface;
  17. class PostListener
  18. {
  20.     private ShellExecManager $shellExecManager;
  21.     private AppManager $appManager;
  23.     private TranslatorInterface $translator;
  25.     public function __construct(ShellExecManager $shellExecManager, AppManager $appManager, TranslatorInterface $translator)
  26.     {
  27.         $this->translator = $translator;
  28.         $this->appManager = $appManager;
  29.         $this->shellExecManager = $shellExecManager;
  30.     }
  32.     public function postStoreHeaderCreate(GenericEvent $genericEvent)
  33.     {
  34.         /** @var StoreHeader $entity */
  35.         $entity = $genericEvent->getSubject();
  36.         $this->isClient($genericEvent->getAppManager()->getClient());
  38.         if (!$entity instanceof StoreHeader || $entity->getType() !== StoreHeader::STORE_HEADER_CUSTOMER_RECEIPT) {
  39.             return;
  40.         }
  41.         $this->runCommand('export_paragon', $entity->getId());
  42.     }
  44.     public function postPointOfSaleMoveCreate(GenericEvent $genericEvent)
  45.     {
  46.         /** @var PointOfSaleMove $entity */
  47.         $entity = $genericEvent->getSubject();
  48.         $this->isClient($genericEvent->getAppManager()->getClient());
  50.         if (!$entity instanceof PointOfSaleMove) {
  51.             return;
  52.         }
  53.         $this->runCommand('export_point_of_sale_move', $entity->getId());
  54.     }
  56.     public function postEshopCustomerOrder(GenericEvent $genericEvent)
  57.     {
  58.         /** @var CustomerOrder $entity */
  59.         $entity = $genericEvent->getSubject();
  60.         $this->isClient($genericEvent->getAppManager()->getClient());
  62.         if (!$entity instanceof CustomerOrder) {
  63.             return;
  64.         }
  65.         if ($entity->getState() !== CustomerOrder::STATE_CONFIRMED || $entity->getFinishedAt() === null) {
  66.             return;
  67.         }
  69.         $invalidCoupons = [];
  70.         foreach ($entity->getDiscountCoupons() as $discountCoupon) {
  71.             if($discountCoupon->isValid() === false) {
  72.                 $invalidCoupons[] = $this->translator->trans('discount_coupon.can_not_be_used', ['%code%' => $discountCoupon->getCode()], 'validators');
  73.                 continue;
  74.             }
  75.             $discountCoupon->setAlreadyUsed($discountCoupon->getAlreadyUsed() + 1);
  76.             $this->appManager->persist($discountCoupon);
  77.         }
  79.         if (count($invalidCoupons) > 0) {
  80.             throw new ValidationException(['discountCoupons' => $invalidCoupons]);
  81.         }
  83.         if ($entity->getDiscountCoupons()->count() > 0) {
  84.             $this->appManager->flush();
  85.         }
  87.         $this->runCommand('export_eshop_order', $entity->getId());
  88.         $this->runCommand('eshop:email_customer_order', $entity->getId());
  90.         sleep(10);
  91.         $this->changeCustomerOrderState($genericEvent);
  92.     }
  94.     public function changeCustomerOrderState(GenericEvent $genericEvent)
  95.     {
  96.         $entity = $genericEvent->getSubject();
  97.         $this->isClient($genericEvent->getAppManager()->getClient());
  99.         if (!$entity instanceof CustomerOrder) {
  100.             return;
  101.         }
  103.         $this->runCommand('eshop:firebase_customer_order', $entity->getId());
  104.     }
  106.     private function isClient($client)
  107.     {
  108.         if (!$client instanceof Client || $client->getCode() !== ClientUtils::LABAS) {
  109.             throw new \Exception('Bad client');
  110.         }
  112.     }
  114.     private function runCommand(string $labasCommand, int $entityId, bool $onBackground = true)
  115.     {
  116.         $shellExec = new ShellExec('labas:' . $labasCommand, $entityId . ' --kernel=labas');
  117.         $this->shellExecManager->runShellExec($shellExec, $onBackground);
  118.     }
  120. }