src/EventListener/IdentificationListener.php line 74

Open in your IDE?
  1. <?php
  3. namespace App\EventListener;
  5. use App\Domain\Event\Identification;
  6. use App\Entity\BankUser;
  7. use App\Repository\BankUserRepository;
  8. use App\Services\Clients\ClientSystemState\ClientSystemStateService;
  9. use App\Services\Clients\Identification\Idenfy\ClientDocumentService;
  10. use App\Services\Clients\Shareholder\ShareholderService;
  11. use App\Services\CommunicationService;
  12. use App\Utils\KafkaNotifier;
  13. use Psr\Log\LoggerInterface;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class IdentificationListener implements EventSubscriberInterface
  17. {
  18.     /**
  19.      * @var LoggerInterface
  20.      */
  21.     private $logger;
  23.     /**
  24.      * @var CommunicationService
  25.      */
  26.     private $communicationService;
  28.     /**
  29.      * @var KafkaNotifier
  30.      */
  31.     private $kafkaNotifier;
  33.     /**
  34.      * @var BankUserRepository
  35.      */
  36.     private $bankUserRepository;
  38.     /**
  39.      * @var ClientSystemStateService
  40.      */
  41.     private $systemStateService;
  43.     /**
  44.      * @var ShareholderService
  45.      */
  46.     private $shareholderService;
  48.     public function __construct(
  49.         CommunicationService $communicationService,
  50.         LoggerInterface $logger,
  51.         KafkaNotifier $kafkaNotifier,
  52.         BankUserRepository $bankUserRepository,
  53.         ClientSystemStateService $systemStateService,
  54.         ShareholderService $shareholderService
  55.     ) {
  56.         $this->communicationService = $communicationService;
  57.         $this->logger = $logger;
  58.         $this->kafkaNotifier = $kafkaNotifier;
  59.         $this->bankUserRepository = $bankUserRepository;
  60.         $this->systemStateService = $systemStateService;
  61.         $this->shareholderService = $shareholderService;
  62.     }
  64.     public function processClientSystemState(Identification $event)
  65.     {
  66.         $client = $event->getClient();
  67.         $this->systemStateService->processClientSystemState($client);
  68.         $verificationStatus = $event->getVerificationStatus();
  69.         if ($client->isPerson()) {
  70.             $this->shareholderService->setShareholderState($client->getPerson(), $verificationStatus);
  71.         }
  72.     }
  74.     public function sendSMS(Identification $event)
  75.     {
  76.         if ($event->getVerificationStatus() == ClientDocumentService::STATUS_APPROVED) {
  77.             $client = $event->getClient();
  78.             $this->communicationService->sendSmsIfConfirmedIdentifyMessage($client);
  79.         }
  80.     }
  82.     public function sendClientRecheck(Identification $event)
  83.     {
  84.         $client = $event->getClient();
  85.         $systemUser = $this->bankUserRepository->findByUsername(BankUser::SYSTEM_USER);
  86.         $requestingUserId = $systemUser ? $systemUser->getId() : null;
  87.         $this->kafkaNotifier->sendClientRecheck($client->getId(), $requestingUserId);
  88.     }
  90.     public static function getSubscribedEvents()
  91.     {
  92.         return [
  93.             Identification::IDENTIFICATION_EVENT => [['processClientSystemState'], ['sendSMS'], ['sendClientRecheck']],
  94.         ];
  95.     }
  96. }