src/Modules/Notification/Event/Subscriber/SendChangesRequestApprovedNotification.php line 75

Open in your IDE?
  1. <?php
  3. namespace App\Modules\Notification\Event\Subscriber;
  6. use App\Modules\ChangesRequest\Entity\ChangesRequest;
  7. use App\Modules\ChangesRequest\Event\ChangesRequestApproved;
  8. use App\Modules\ChangesRequest\Event\ChangesRequestCreated;
  9. use App\Modules\ChangesRequest\Factory\CommandFactory;
  10. use App\Modules\Notification\Entity\NotificationEntity;
  11. use App\Modules\Notification\Message\System\ChangesRequest\AddNewPartnerAddressApprovedNotification;
  12. use App\Modules\Notification\Message\System\ChangesRequest\AddNewPartnerServiceApprovedNotification;
  13. use App\Modules\Notification\Message\System\ChangesRequest\ChangePartnerAddressApprovedNotification;
  14. use App\Modules\Notification\Service\NotificationService;
  15. use App\Modules\User\Entity\User;
  16. use App\Modules\User\Repository\UserRepositoryInterface;
  17. use App\Modules\User\Service\PartnerService;
  18. use App\Service\WebRoutes;
  19. use Doctrine\Common\Collections\ArrayCollection;
  20. use Psr\Log\LoggerInterface;
  21. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  23. class SendChangesRequestApprovedNotification implements EventSubscriberInterface
  24. {
  25.     private $notificationService;
  26.     private $logger;
  28.     /**
  29.      * @var UserRepositoryInterface
  30.      */
  31.     private $userRepository;
  32.     /**
  33.      * @var PartnerService
  34.      */
  35.     private $partnerService;
  37.     public function __construct(
  38.         NotificationService $notificationService,
  39.         UserRepositoryInterface $userRepository,
  40.         PartnerService $partnerService,
  41.         LoggerInterface $logger
  42.     )
  43.     {
  44.         $this->notificationService = $notificationService;
  45.         $this->logger = $logger;
  46.         $this->userRepository = $userRepository;
  47.         $this->partnerService = $partnerService;
  48.     }
  50.     /**
  51.      * Returns an array of event names this subscriber wants to listen to.
  52.      *
  53.      * The array keys are event names and the value can be:
  54.      *
  55.      *  * The method name to call (priority defaults to 0)
  56.      *  * An array composed of the method name to call and the priority
  57.      *  * An array of arrays composed of the method names to call and respective
  58.      *    priorities, or 0 if unset
  59.      *
  60.      * For instance:
  61.      *
  62.      *  * ['eventName' => 'methodName']
  63.      *  * ['eventName' => ['methodName', $priority]]
  64.      *  * ['eventName' => [['methodName1', $priority], ['methodName2']]]
  65.      *
  66.      * @return array The event names to listen to
  67.      */
  68.     public static function getSubscribedEvents()
  69.     {
  70.         return [
  71.             ChangesRequestApproved::class => ['sendNotification']
  72.         ];
  73.     }
  75.     public function sendNotification(ChangesRequestApproved $event)
  76.     {
  77.         try {
  78.             $changesRequest = $event->getChangesRequest();
  80.             $recipients = new ArrayCollection();
  81.             $recipients->add($changesRequest->getInitiator());
  83.             $notification = $this->createNotification($changesRequest, $recipients);
  84.             $this->notificationService->sendSystem($notification);
  85.         } catch (\Exception $e) {
  86.             $this->logger->error($e->getMessage());
  87.         }
  88.     }
  90.     private function createNotification(ChangesRequest $changesRequest, $receivers)
  91.     {
  92.         $partnerId = $changesRequest->getEntity()->getId();
  94.         $link = [
  95.             'entity' => NotificationEntity::PARTNER,
  96.             'id' => $partnerId
  97.         ];
  99.         switch ($changesRequest->getOperation()) {
  100.             case CommandFactory::ADD_PARTNER_ADDRESS:
  101.                 return new AddNewPartnerAddressApprovedNotification($link, $receivers);
  102.             case CommandFactory::EDIT_PARTNER_ADDRESS:
  103.                 return new ChangePartnerAddressApprovedNotification($link, $receivers);
  104.             case CommandFactory::ADD_PARTNER_SERVICE:
  105.                 return new AddNewPartnerServiceApprovedNotification($link, $receivers);
  106.             default:
  107.                 throw new \Exception('Unknown operation '. $changesRequest->getOperation());
  108.         }
  109.     }
  110. }