src/Services/Transaction/Workflow/EventSubscriber/Internal/OutboundTrxSubscriber.php line 83

Open in your IDE?
  1. <?php
  3. namespace App\Services\Transaction\Workflow\EventSubscriber\Internal;
  5. use App\Services\Transaction\StatusManagement\ToSignTransactionComponent;
  6. use App\Services\Transaction\Fee\Builder\FeeBuilder;
  7. use App\Services\Transaction\Fee\PaymentFeeService;
  8. use App\Services\Transaction\FeeTransactionService;
  9. use App\Services\Transaction\TransactionCancelService;
  10. use App\Services\Transaction\TransactionReturnService;
  11. use App\Services\Transaction\TransactionService;
  12. use App\Entity\Transaction;
  13. use App\Repository\TransactionRepository;
  14. use BrokerAction\DTO\TransactionMessage\MessageComponent\Payload;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Symfony\Component\Workflow\Event\Event;
  18. /**
  19.  * Class OutboundTrxSubscriber.
  20.  */
  21. class OutboundTrxSubscriber implements EventSubscriberInterface
  22. {
  23.     /**
  24.      * @var FeeTransactionService
  25.      */
  26.     private $feeTransactionService;
  28.     /**
  29.      * @var TransactionReturnService
  30.      */
  31.     private $trxReturnService;
  33.     /**
  34.      * @var PaymentFeeService
  35.      */
  36.     private $paymentFeeService;
  38.     public function __construct(
  39.         FeeTransactionService $feeTransactionService,
  40.         TransactionRepository $transactionRepository,
  41.         TransactionService $transactionService,
  42.         FeeBuilder $feeBuilder,
  43.         TransactionReturnService $trxReturnService,
  44.         ToSignTransactionComponent $toSignTransactionComponent,
  45.         TransactionCancelService $trxCancelService,
  46.         PaymentFeeService $paymentFeeService
  47.     ) {
  48.         $this->feeTransactionService = $feeTransactionService;
  49.         $this->transactionRepository = $transactionRepository;
  50.         $this->transactionService = $transactionService;
  51.         $this->feeBuilder = $feeBuilder;
  52.         $this->trxReturnService = $trxReturnService;
  53.         $this->toSignTransactionComponent = $toSignTransactionComponent;
  54.         $this->trxCancelService = $trxCancelService;
  55.         $this->paymentFeeService = $paymentFeeService;
  56.     }
  58.     public static function getSubscribedEvents()
  59.     {
  60.         return [
  61.             'workflow.internal_transaction_creating.completed.reject' => 'cancelOutboundMainTrx',
  62.             'workflow.internal_transaction_creating.completed.set_reserved' => 'makeOutboundTrx',
  63.         ];
  64.     }
  66.     public function cancelOutboundMainTrx(Event $event)
  67.     {
  68.         /** @var Transaction $pmtTrx */
  69.         $pmtTrx = $event->getSubject()->getEntity();
  71.         $isRejectedByBank = $event->getTransition()->getFroms()[0] == 'review';
  72.         if (
  73.             !$isRejectedByBank
  74.             && ($pmtTrx->hasTypePayment() || $pmtTrx->hasTypePaymentReturn())
  75.             && $pmtTrx->getOutbound() && $pmtTrx->isMoneyReleased()
  76.         ) {
  77.             $this->trxReturnService->processSepaSentButRejectedTrx($pmtTrx);
  78.         }
  80.         $this->feeTransactionService->cancelFeeByMainTrx($pmtTrx);
  81.     }
  83.     public function makeOutboundTrx(Event $event)
  84.     {
  85.         /** @var Transaction $mainTransaction */
  86.         $mainTransaction = $event->getSubject()->getEntity();
  87.         $product = $mainTransaction->getProduct();
  88.         if ($product->debtorPaysFee() && !$mainTransaction->isDropFees()) {
  89.             $this->paymentFeeService->createOutbound(new Payload(['transaction_id' => $mainTransaction->getId()]));
  90.         }
  91.     }
  92. }