src/Services/Transaction/Workflow/EventSubscriber/Fps/Outbound/OutboundTrxSubscriber.php line 61

Open in your IDE?
  1. <?php
  3. namespace App\Services\Transaction\Workflow\EventSubscriber\Fps\Outbound;
  5. use App\Services\Transaction\StatusManagement\ToSignTransactionComponent;
  6. use App\Services\Transaction\Fee\PaymentFeeService;
  7. use App\Services\Transaction\FeeTransactionService;
  8. use App\Services\Transaction\TransactionCancelService;
  9. use App\Entity\Transaction;
  10. use BrokerAction\DTO\TransactionMessage\MessageComponent\Payload;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\Workflow\Event\Event;
  14. class OutboundTrxSubscriber implements EventSubscriberInterface
  15. {
  16.     /**
  17.      * @var TransactionCancelService
  18.      */
  19.     protected $trxCancelService;
  21.     /**
  22.      * @var FeeTransactionService
  23.      */
  24.     protected $feeTransactionService;
  26.     /**
  27.      * @var PaymentFeeService
  28.      */
  29.     private $paymentFeeService;
  31.     public function __construct(
  32.         TransactionCancelService $trxReadyToClearComponent,
  33.         FeeTransactionService $feeTransactionService,
  34.         ToSignTransactionComponent $toSignTransactionComponent,
  35.         PaymentFeeService $paymentFeeService
  36.     ) {
  37.         $this->trxCancelService = $trxReadyToClearComponent;
  38.         $this->feeTransactionService = $feeTransactionService;
  39.         $this->toSignTransactionComponent = $toSignTransactionComponent;
  40.         $this->paymentFeeService = $paymentFeeService;
  41.     }
  43.     public static function getSubscribedEvents()
  44.     {
  45.         return [
  46.             'workflow.starling_payment_outbound.completed.set_reserved' => 'makeOutboundTrx',
  47.             'workflow.starling_payment_outbound.enter.rejected' => 'cancelOutboundMainTrx',
  48.         ];
  49.     }
  51.     public function makeOutboundTrx(Event $event)
  52.     {
  53.         /** @var Transaction $mainTransaction */
  54.         $mainTransaction = $event->getSubject()->getEntity();
  55.         $product = $mainTransaction->getProduct();
  56.         if ($product->debtorPaysFee() && !$mainTransaction->isDropFees()) {
  57.             $this->paymentFeeService->createOutbound(new Payload(['transaction_id' => $mainTransaction->getId()]));
  58.         }
  59.     }
  61.     public function cancelOutboundMainTrx(Event $event)
  62.     {
  63.         /** @var Transaction $pmtTrx */
  64.         $mainTransaction = $event->getSubject()->getEntity();
  65.         $this->feeTransactionService->cancelFeeByMainTrx($mainTransaction);
  66.     }
  67. }