src/Modules/Notification/Event/Subscriber/SendWarrantyFormStatusChangedNotification.php line 74

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