vendor/store.shopware.com/swagb2bplatform/components/Budget/BridgePlatform/BudgetTransactionOrderSync.php line 69

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.     private AuthenticationService $authenticationService;
  18.     private CurrencyService $currencyService;
  20.     private OrderContextRepository $orderContextRepository;
  22.     private BudgetService $budgetService;
  24.     public static function getSubscribedEvents(): array
  25.     {
  26.         return [
  27.             CheckoutOrderPlacedEvent::class => 'addTransaction',
  28.             OrderContextStateChangedEvent::class => 'updateTransactionStatus',
  29.         ];
  30.     }
  32.     public function __construct(
  33.         AuthenticationService $authenticationService,
  34.         OrderContextRepository $orderContextRepository,
  35.         BudgetService $budgetService,
  36.         CurrencyService $currencyService
  37.     ) {
  38.         $this->authenticationService = $authenticationService;
  39.         $this->currencyService = $currencyService;
  40.         $this->orderContextRepository = $orderContextRepository;
  41.         $this->budgetService = $budgetService;
  42.     }
  44.     public function addTransaction(CheckoutOrderPlacedEvent $event): void
  45.     {
  46.         if (!$this->authenticationService->isB2b()) {
  47.             return;
  48.         }
  50.         $order = $event->getOrder();
  51.         $currencyContext = $this->currencyService->createCurrencyContext();
  53.         $identity = $this->authenticationService->getIdentity();
  54.         $amount = $order->getAmountNet() + $order->getShippingTotal();
  56.         $orderContext = $this->orderContextRepository
  57.             ->fetchOneOrderContextByOrderNumber($order->getOrderNumber());
  59.         try {
  60.             $this->budgetService
  61.                 ->addTransaction($orderContext, $amount, $currencyContext, $identity->getOwnershipContext());
  62.         } catch (InsufficientBudgetException $e) {
  63.             if (!$identity->isSuperAdmin()) {
  64.                 throw $e;
  65.             }
  66.         }
  67.     }
  69.     public function updateTransactionStatus(OrderContextStateChangedEvent $event): void
  70.     {
  71.         $this->budgetService->updateTransactionStatus($event->getOrderContext());
  72.     }
  73. }