src/EventListener/BulkEmailListener.php line 39

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\EventListener;
  7. use App\Middleware\CustomerMiddleware;
  8. use App\Middleware\ReceivableMiddleware;
  9. use App\Middleware\SaleMiddleware;
  10. use App\Middleware\TransactionFailureMiddleware;
  11. use App\Middleware\BackgroundProcessingMiddleware;
  12. use Symfony\Component\HttpKernel\Event\TerminateEvent;
  13. use Symfony\Component\HttpKernel\KernelInterface;
  15. class BulkEmailListener
  16. {
  17.   private $receivableMiddleware;
  18.   private $saleMiddleware;
  19.   private $transactionFailureMiddleware;
  20.   private $customerMiddleware;
  21.   private $backgroundProcessingMiddleware;
  23.   public function __construct(
  24.     KernelInterface $kernelInterface,
  25.     SaleMiddleware $saleMiddleware,
  26.     ReceivableMiddleware $receivableMiddleware,
  27.     TransactionFailureMiddleware $transactionFailureMiddleware,
  28.     CustomerMiddleware $customerMiddleware,
  29.     BackgroundProcessingMiddleware $backgroundProcessingMiddleware
  30.   ) {
  31.     $this->kernelInterface = $kernelInterface;
  32.     $this->receivableMiddleware = $receivableMiddleware;
  33.     $this->saleMiddleware = $saleMiddleware;
  34.     $this->transactionFailureMiddleware = $transactionFailureMiddleware;
  35.     $this->customerMiddleware = $customerMiddleware;
  36.     $this->backgroundProcessingMiddleware = $backgroundProcessingMiddleware;
  37.   }
  39.   public function onKernelTerminate(TerminateEvent $event): void
  40.   {
  41.     if (!$event->isMasterRequest()) {
  42.       return;
  43.     }
  44.     $request = $event->getRequest();
  45.     if ('api_email_bulk_sale_session' === $request->get('_route')) {
  46.       $parameter = json_decode($request->getContent(), true);
  47.       
  48.       $bgInitiateParameter = array(
  49.         'companyId' => $parameter['companyId'],
  50.         'uniqueKey' => rand(),
  51.         'initiatedData' => json_encode($parameter['selectedId']),
  52.         'processData' => json_encode(array()),
  53.         'module' => 'sale_email',
  54.         'emailsSent' => '0',
  55.         'status' => '1',
  56.         'showAlert' => '0',
  57.         'createdDate' => new \DateTime(),
  58.         'updatedDate' => new \DateTime()
  59.       );
  60.       $this->backgroundProcessingMiddleware->save($bgInitiateParameter);
  62.       $parameter['uniqueKey'] = $bgInitiateParameter['uniqueKey'];
  63.       $parameter['initiatedData'] = $bgInitiateParameter['initiatedData'];
  64.       $this->saleMiddleware->bulkSaleEmailSend($parameter);
  65.       
  66.       return;
  67.     } else if ('api_email_receivable_statement' === $request->get('_route')) {
  68.       $parameter = json_decode($request->getContent(), true);
  69.       $this->receivableMiddleware->sendEmailByCustomer($parameter);
  70.       return;
  71.     } else if ('api_payment_bulk_email_send' === $request->get('_route')) {
  72.       $parameter = json_decode($request->getContent(), true);
  74.       $bgInitiateParameter = array(
  75.         'companyId' => $parameter['companyId'],
  76.         'uniqueKey' => rand(),
  77.         'initiatedData' => isset($parameter['selectedId']) ? json_encode($parameter['selectedId']) : json_encode(array()),
  78.         'processData' => json_encode(array()),
  79.         'module' => isset($parameter['module'])?$parameter['module']:'email',
  80.         'emailsSent' => '0',
  81.         'status' => '1',
  82.         'showAlert' => '0',
  83.         'createdDate' => new \DateTime(),
  84.         'updatedDate' => new \DateTime()
  85.       );
  86.       $this->backgroundProcessingMiddleware->save($bgInitiateParameter);
  88.       if ($parameter['module'] === constant("App\\Constant\\Globals::BULK_PAYMENT_DECLINED")) {
  89.         $this->transactionFailureMiddleware->bulkPaymentDeclineEmailSend($parameter);
  90.       } else if ($parameter['module'] === constant("App\\Constant\\Globals::BULK_EXPIRED_EXPIRING")) {
  91.         $this->customerMiddleware->bulkExpiredExpiringEmailSend($parameter);
  92.       } else if ($parameter['module'] === constant("App\\Constant\\Globals::BULK_UPDATE_CARD")) {
  93.         $this->customerMiddleware->bulkUpdateCardEmailSend($parameter);
  94.       }
  95.       $bgEndParameter = array(
  96.         'companyId' => $parameter['companyId'],
  97.         'uniqueKey' => $bgInitiateParameter['uniqueKey'],
  98.         'initiatedData' => json_encode(array()),
  99.         'processData' => $bgInitiateParameter['initiatedData'],
  100.         'emailsSent' => '1',
  101.         'status' => '0',
  102.         'updatedDate' => new \DateTime()
  103.       );
  104.       $this->backgroundProcessingMiddleware->updateMultiple($bgEndParameter);
  105.       return;
  106.     }
  107.   }
  108. }