src/EventListener/MassPaymentInitiatedListener.php line 68

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