custom/plugins/SwagB2bPlatform/components/Budget/BridgePlatform/BudgetTransactionOrderSync.php line 81

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\B2B\Budget\BridgePlatform;
  5. use Shopware\B2B\Budget\Framework\BudgetService;
  6. use Shopware\B2B\Budget\Framework\InsufficientBudgetException;
  7. use Shopware\B2B\Currency\Framework\CurrencyService;
  8. use Shopware\B2B\Order\BridgePlatform\OrderContextStateChangedEvent;
  9. use Shopware\B2B\Order\Framework\OrderContextRepository;
  10. use Shopware\B2B\StoreFrontAuthentication\Framework\AuthenticationService;
  11. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. class BudgetTransactionOrderSync implements EventSubscriberInterface
  15. {
  16.     /**
  17.      * @var AuthenticationService
  18.      */
  19.     private $authenticationService;
  21.     /**
  22.      * @var CurrencyService
  23.      */
  24.     private $currencyService;
  26.     /**
  27.      * @var OrderContextRepository
  28.      */
  29.     private $orderContextRepository;
  31.     /**
  32.      * @var BudgetService
  33.      */
  34.     private $budgetService;
  36.     public static function getSubscribedEvents(): array
  37.     {
  38.         return [
  39.             CheckoutOrderPlacedEvent::class => 'addTransaction',
  40.             OrderContextStateChangedEvent::class => 'updateTransactionStatus',
  41.         ];
  42.     }
  44.     public function __construct(
  45.         AuthenticationService $authenticationService,
  46.         OrderContextRepository $orderContextRepository,
  47.         BudgetService $budgetService,
  48.         CurrencyService $currencyService
  49.     ) {
  50.         $this->authenticationService = $authenticationService;
  51.         $this->currencyService = $currencyService;
  52.         $this->orderContextRepository = $orderContextRepository;
  53.         $this->budgetService = $budgetService;
  54.     }
  56.     public function addTransaction(CheckoutOrderPlacedEvent $event): void
  57.     {
  58.         if (!$this->authenticationService->isB2b()) {
  59.             return;
  60.         }
  62.         $order = $event->getOrder();
  63.         $currencyContext = $this->currencyService->createCurrencyContext();
  65.         $identity = $this->authenticationService->getIdentity();
  66.         $amount = $order->getAmountNet() + $order->getShippingTotal();
  68.         $orderContext = $this->orderContextRepository
  69.             ->fetchOneOrderContextByOrderNumber($order->getOrderNumber());
  71.         try {
  72.             $this->budgetService
  73.                 ->addTransaction($orderContext, $amount, $currencyContext, $identity->getOwnershipContext());
  74.         } catch (InsufficientBudgetException $e) {
  75.             if (!$identity->isSuperAdmin()) {
  76.                 throw $e;
  77.             }
  78.         }
  79.     }
  81.     public function updateTransactionStatus(OrderContextStateChangedEvent $event): void
  82.     {
  83.         $this->budgetService->updateTransactionStatus($event->getOrderContext());
  84.     }
  85. }