src/EventListener/AccountCreatedListener.php line 68

Open in your IDE?
  1. <?php
  3. namespace App\EventListener;
  5. use App\Domain\DTO\ProductSelectionDTO;
  6. use App\Domain\Event\AccountCreated;
  7. use App\Domain\Exception\DomainException;
  8. use App\Services\DomainValuesService;
  9. use App\Services\Aml\ProductPriceEngine;
  10. use App\Services\Transaction\Fee\FeeDestination;
  11. use App\Services\Transaction\Fee\ManualFee\ManualFeeService;
  12. use App\Entity\Account;
  13. use App\Entity\Product;
  14. use App\Entity\ProductAction;
  15. use App\Repository\ProductActionRepository;
  16. use BrokerAction\DTO\TransactionMessage\MessageComponent\Payload;
  17. use Psr\Log\LoggerInterface;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. class AccountCreatedListener implements EventSubscriberInterface
  21. {
  22.     /**
  23.      * @var ProductActionRepository
  24.      */
  25.     private $productActionRepository;
  27.     /**
  28.      * @var ProductPriceEngine
  29.      */
  30.     private $productEngine;
  32.     /**
  33.      * @var LoggerInterface
  34.      */
  35.     private $logger;
  37.     /**
  38.      * @var ManualFeeService
  39.      */
  40.     private $feeService;
  42.     /**
  43.      * @var DomainValuesService
  44.      */
  45.     private $domainValuesService;
  47.     /**
  48.      * @var FeeDestination
  49.      */
  50.     private $feeDestination;
  52.     public function __construct(
  53.         ProductActionRepository $productActionRepository,
  54.         ProductPriceEngine $productEngine,
  55.         LoggerInterface $logger,
  56.         ManualFeeService $feeService,
  57.         DomainValuesService $domainValuesService,
  58.         FeeDestination $feeDestination
  59.     ) {
  60.         $this->productActionRepository = $productActionRepository;
  61.         $this->productEngine = $productEngine;
  62.         $this->logger = $logger;
  63.         $this->feeService = $feeService;
  64.         $this->domainValuesService = $domainValuesService;
  65.         $this->feeDestination = $feeDestination;
  66.     }
  68.     public function createFee(AccountCreated $event)
  69.     {
  70.         try {
  71.             $account = $event->getAccount();
  72.             $productSelectionDTO = new ProductSelectionDTO(
  73.                 ProductAction::BANK_ACCOUNT,
  74.                 0,
  75.                 $account->getClient()->getId()
  76.             );
  78.             // if it's first account created, then product_instance with value 1 must be added to DTO.
  79.             $event->isFirst() && $productSelectionDTO->setProductInstance(1);
  81.             $engineResponse = $this->productEngine->run($productSelectionDTO);
  82.             /** @var Product $product */
  83.             $product = $engineResponse->getContent();
  84.             if (!$product) {
  85.                 throw new DomainException('Product was not found');
  87.                 return;
  88.             }
  90.             $this->feeService->sendMessage(new Payload([
  91.                 'product_id' => $product->getId(),
  92.                 'debtor_account_id' => $account->getId(),
  93.                 'currency' => $event->getCurrency(),
  94.             ]));
  95.         } catch (DomainException $exception) {
  96.             $this->logger->notice($exception->getMessage());
  97.         }
  98.     }
  100.     /**
  101.      * Returns an array of event names this subscriber wants to listen to.
  102.      *
  103.      * The array keys are event names and the value can be:
  104.      *
  105.      *  * The method name to call (priority defaults to 0)
  106.      *  * An array composed of the method name to call and the priority
  107.      *  * An array of arrays composed of the method names to call and respective
  108.      *    priorities, or 0 if unset
  109.      *
  110.      * For instance:
  111.      *
  112.      *  * array('eventName' => 'methodName')
  113.      *  * array('eventName' => array('methodName', $priority))
  114.      *  * array('eventName' => array(array('methodName1', $priority), array('methodName2')))
  115.      *
  116.      * @return array The event names to listen to
  117.      */
  118.     public static function getSubscribedEvents()
  119.     {
  120.         return [
  121.             Account::CREATE_EVENT => 'createFee',
  122.         ];
  123.     }
  124. }