src/Modules/Notification/Event/Subscriber/SendPlaneApprovedNotification.php line 58

Open in your IDE?
  1. <?php
  3. namespace App\Modules\Notification\Event\Subscriber;
  6. use App\Modules\Contract\ValueObject\Asset;
  7. use App\Modules\Notification\Entity\NotificationEntity;
  8. use App\Modules\Notification\Message\System\AssetApprovedNotification;
  9. use App\Modules\Notification\Service\NotificationService;
  10. use App\Modules\TangibleAsset\Event\AssetApproved;
  11. use App\Modules\TangibleAsset\Service\AssetOwnerRepresentativesService;
  12. use App\Service\WebRoutes;
  13. use Psr\Log\LoggerInterface;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class SendPlaneApprovedNotification implements EventSubscriberInterface
  17. {
  18.     private $notificationService;
  19.     private $logger;
  20.     private $representativesService;
  22.     public function __construct(
  23.         NotificationService $notificationService,
  24.         AssetOwnerRepresentativesService $representativesService,
  25.         LoggerInterface $logger
  26.     )
  27.     {
  28.         $this->notificationService = $notificationService;
  29.         $this->logger = $logger;
  30.         $this->representativesService = $representativesService;
  31.     }
  33.     /**
  34.      * Returns an array of event names this subscriber wants to listen to.
  35.      *
  36.      * The array keys are event names and the value can be:
  37.      *
  38.      *  * The method name to call (priority defaults to 0)
  39.      *  * An array composed of the method name to call and the priority
  40.      *  * An array of arrays composed of the method names to call and respective
  41.      *    priorities, or 0 if unset
  42.      *
  43.      * For instance:
  44.      *
  45.      *  * ['eventName' => 'methodName']
  46.      *  * ['eventName' => ['methodName', $priority]]
  47.      *  * ['eventName' => [['methodName1', $priority], ['methodName2']]]
  48.      *
  49.      * @return array The event names to listen to
  50.      */
  51.     public static function getSubscribedEvents()
  52.     {
  53.         return [
  54.             AssetApproved::class => ['sendNotification']
  55.         ];
  56.     }
  58.     public function sendNotification(AssetApproved $event)
  59.     {
  60.         try {
  61.             $asset = $event->getAsset();
  62.             $assetOwner = $asset->getOwnerID();
  63.             $assetTypeTitle = Asset::getTypeTitle($asset->getType());
  64.             $assetLink = [
  65.                 'entity' => NotificationEntity::$assetEntities[$asset->getType()],
  66.                 'id' => $asset->getId()
  67.             ];
  69.             $receivers = $this->representativesService->get($assetOwner->getId(), $assetOwner->getOwnerType());
  71.             $notification = new AssetApprovedNotification($asset->getTitle(), $assetTypeTitle, $assetLink, $receivers);
  72.             $this->notificationService->sendSystem($notification);
  74.         } catch (\Exception $e) {
  75.             $this->logger->error($e->getMessage());
  76.         }
  77.     }
  78. }