src/Modules/Notification/Event/Subscriber/SendChangesRequestDeclinedNotification.php line 79

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