src/EventListener/CancellationInFoListener.php line 27

Open in your IDE?
  1. <?php
  3. namespace App\EventListener;
  5. use App\Entity\Gos\CancellationFoResponse;
  6. use App\Entity\Gos\OrderPart;
  7. use App\Event\CancellationInFoEvent;
  8. use Doctrine\ORM\EntityManagerInterface;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. class CancellationInFoListener implements EventSubscriberInterface
  12. {
  13.     private $em;
  15.     public function __construct(EntityManagerInterface $em)
  16.     {
  17.         $this->em = $em;
  18.     }
  20.     public static function getSubscribedEvents(): array
  21.     {
  22.         return [
  23.             CancellationInFoEvent::CANCELLATION_SENT => 'onCancellationSent'
  24.         ];
  25.     }
  27.     public function onCancellationSent(CancellationInFoEvent $event): void
  28.     {
  29.         $orderPart = $event->getOrderPart();
  30.         $response = $event->getResponse();
  31.         $decodedResponse = json_decode($response, true);
  33.         if (!$orderPart->getCancellationFoResponses()->isEmpty())
  34.         {
  35.             /** @var CancellationFoResponse $cancellationResponse */
  36.             $cancellationFoResponse = $orderPart->getCancellationFoResponses()->first();
  37.         }
  39.         $cancellationFoResponse = $cancellationFoResponse ?? new CancellationFoResponse();
  40.         $cancellationFoResponse->setOrderPart($orderPart);
  41.         $cancellationFoResponse->setUser($orderPart->getOrders()->getUser());
  42.         $cancellationFoResponse->setBody($response);
  43.         $cancellationFoResponse->setIsSuccessfully(true);
  45.         if (empty($decodedResponse) || array_key_exists('error', $decodedResponse))
  46.         {
  47.             $this->handleCancellationFailure($event, $orderPart, $response, $cancellationFoResponse);
  48.         }
  49.         else
  50.         {
  51.             $cancellationFoResponse->setFailureNumber(null);
  52.         }
  54.         $this->em->persist($cancellationFoResponse);
  55.         $this->em->flush();
  56.     }
  58.     private function handleCancellationFailure(
  59.         CancellationInFoEvent $event,
  60.         OrderPart $orderPart,
  61.         string $response,
  62.         CancellationFoResponse $cancellationFoResponse
  63.     ): void
  64.     {
  65.         $failureNumber = $cancellationFoResponse->getFailureNumber();
  67.         if (++$failureNumber >= 5)
  68.         {
  69.             $event->setEmailMessage($orderPart->getOrdTran() . ' - ' . $failureNumber . ' nieudana rezygnacja w FO');
  70.         }
  72.         $cancellationFoResponse->setFailureNumber($failureNumber);
  73.         $cancellationFoResponse->setIsSuccessfully(false);
  74.     }
  75. }