src/Modules/Notification/Event/Subscriber/SendFormPriceUpdatedNotification.php line 73

Open in your IDE?
  1. <?php
  3. namespace App\Modules\Notification\Event\Subscriber;
  6. use App\Modules\Contract\Event\ContractCreated;
  7. use App\Modules\Contract\Event\FormAccepted;
  8. use App\Modules\Contract\Event\FormFinalized;
  9. use App\Modules\Contract\Event\FormUpdated;
  10. use App\Modules\Notification\Entity\NotificationEntity;
  11. use App\Modules\Notification\Message\System\FormCreatedNotification;
  12. use App\Modules\Notification\Message\System\FormRequestAcceptedNotification;
  13. use App\Modules\Notification\Message\System\FormRequestFinalizedNotification;
  14. use App\Modules\Notification\Message\System\FormRequestPriceChangedNotification;
  15. use App\Modules\Notification\Service\NotificationService;
  16. use App\Modules\Contract\Service\ParticipantDetailsService;
  17. use App\Modules\User\Service\RepresentativesService;
  18. use App\Service\WebRoutes;
  19. use Psr\Log\LoggerInterface;
  20. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  22. class SendFormPriceUpdatedNotification implements EventSubscriberInterface
  23. {
  24.     private $notificationService;
  25.     private $logger;
  26.     /**
  27.      * @var ParticipantDetailsService
  28.      */
  29.     private $participantDetailsService;
  30.     /**
  31.      * @var RepresentativesService
  32.      */
  33.     private $representativesService;
  35.     public function __construct(
  36.         NotificationService $notificationService,
  37.         ParticipantDetailsService $participantDetailsService,
  38.         RepresentativesService $representativesService,
  39.         LoggerInterface $logger
  40.     )
  41.     {
  42.         $this->notificationService = $notificationService;
  43.         $this->logger = $logger;
  44.         $this->participantDetailsService = $participantDetailsService;
  45.         $this->representativesService = $representativesService;
  46.     }
  48.     /**
  49.      * Returns an array of event names this subscriber wants to listen to.
  50.      *
  51.      * The array keys are event names and the value can be:
  52.      *
  53.      *  * The method name to call (priority defaults to 0)
  54.      *  * An array composed of the method name to call and the priority
  55.      *  * An array of arrays composed of the method names to call and respective
  56.      *    priorities, or 0 if unset
  57.      *
  58.      * For instance:
  59.      *
  60.      *  * ['eventName' => 'methodName']
  61.      *  * ['eventName' => ['methodName', $priority]]
  62.      *  * ['eventName' => [['methodName1', $priority], ['methodName2']]]
  63.      *
  64.      * @return array The event names to listen to
  65.      */
  66.     public static function getSubscribedEvents()
  67.     {
  68.         return [
  69.             FormUpdated::class => ['sendNotification']
  70.         ];
  71.     }
  73.     public function sendNotification(FormUpdated $event)
  74.     {
  75.         try {
  76.             if (is_null($event->getValue())) {
  77.                 return;
  78.             }
  80.             $form = $event->getForm();
  82.             $contract = $form->getContract();
  83.             $initiator = $contract->getInitiator();
  84.             $executor = $contract->getExecutor();
  85.             $sender = $this->participantDetailsService->get($executor->getId(), $executor->getType());
  87.             is_null($sender) ? $senderName = '' : $senderName = $sender->getName();
  89.             $refNumber  = $contract->getRef();
  90.             $link = [
  91.                 'id' => $form->getId(),
  92.                 'entity' => NotificationEntity::CONTRACT_FORM,
  93.                 'form_type' => $form->getType()
  94.             ];
  95.             $receivers = $this->representativesService->get($initiator->getId(), $initiator->getType());
  97.             $notification = new FormRequestPriceChangedNotification($refNumber, $link, $senderName, $receivers);
  98.             $this->notificationService->sendSystem($notification);
  99.         } catch (\Exception $e) {
  100.             $this->logger->error($e->getMessage());
  101.         }
  102.     }
  103. }