src/EventSubscriber/VoucherSubscriber.php line 30

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\Voucher;
  6. use App\Entity\JobQueue;
  7. use App\Service\EsJobQueue;
  8. use App\Event\VoucherPostPersistEvent;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use Symfony\Component\Security\Core\Security;
  11. use App\Service\JobQueueAction\GenerateVoucherCodeAction;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. class VoucherSubscriber implements EventSubscriberInterface
  15. {
  16.     public function __construct(
  17.         private EntityManagerInterface $_em,
  18.         private Security $security,
  19.         private EsJobQueue $esJobQueue
  20.     ) {
  21.     }
  23.     public static function getSubscribedEvents(): array
  24.     {
  25.         return [
  26.             VoucherPostPersistEvent::NAME => 'onPostCreate'
  27.         ];
  28.     }
  30.     public function onPostCreate(VoucherPostPersistEvent $event)
  31.     {
  32.         $object = $event->getObject();
  33.         if ($object->getVoucherType() == Voucher::VOUCHERTYPE_ONE) {
  34.             $payload['voucherId'] = $object->getId();
  35.             $this->esJobQueue->create(
  36.                 GenerateVoucherCodeAction::NAME,
  37.                 json_encode($payload),
  38.                 JobQueue::PRIORITY_LOW,
  39.                 null,
  40.                 1,
  41.                 $this->security->getUser()
  42.             );
  43.         }
  44.     }
  45. }