custom/plugins/CioBudget/src/Subscriber/BudgetShiftOrderPlacedCustomFieldSubscriber.php line 50

Open in your IDE?
  1. <?php
  4. namespace CioBudget\Subscriber;
  6. use CioBudget\Service\BudgetLoaderService;
  7. use CioBudget\Service\SessionService;
  8. use Shopware\Core\Checkout\Order\OrderEntity;
  9. use Shopware\Core\Checkout\Order\OrderEvents;
  10. use Shopware\Core\Checkout\Payment\PaymentMethodEntity;
  11. use Shopware\Core\Framework\Api\Context\AdminApiSource;
  12. use Shopware\Core\Framework\Context;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. class BudgetShiftOrderPlacedCustomFieldSubscriber implements EventSubscriberInterface
  20. {
  21.     public const CUSTOM_FIELD_BUDGET_NAME_SAVE_ON_ORDER = 'custom_field_budget_name_save_on_order';
  23.     private EntityRepositoryInterface $paymentMethodRepository;
  25.     private BudgetLoaderService $budgetLoaderService;
  26.     private SessionService $sessionService;
  28.     private EntityRepositoryInterface $orderRepository;
  30.     public function __construct(
  31.         EntityRepositoryInterface $paymentMethodRepository,
  32.         BudgetLoaderService       $budgetLoaderService,
  33.         SessionService            $sessionService,
  34.         EntityRepositoryInterface $orderRepository
  35.     )
  36.     {
  37.         $this->paymentMethodRepository = $paymentMethodRepository;
  38.         $this->budgetLoaderService = $budgetLoaderService;
  39.         $this->sessionService = $sessionService;
  40.         $this->orderRepository = $orderRepository;
  41.     }
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         return [
  46.             OrderEvents::ORDER_WRITTEN_EVENT => 'onCheckoutFinishPageLoaded'
  47.         ];
  48.     }
  50.     public function onCheckoutFinishPageLoaded(EntityWrittenEvent $event)
  51.     {
  53.         // if context is admin do nothing
  54.         if ($event->getContext()->getSource() instanceof AdminApiSource) {
  55.             return;
  56.         }
  58.         $writeResults = $event->getWriteResults();
  60.         if (!empty($writeResults) && isset($writeResults[0]) && isset($writeResults[0]->getPayload()['id'])) {
  61.             $orderId = $writeResults[0]->getPayload()['id'];
  63.             // Überprüfen, ob $orderId nicht leer ist
  64.             if (!empty($orderId)) {
  65.                 $criteria = (new Criteria())
  66.                     ->addFilter(new EqualsFilter('id', $orderId))
  67.                     ->addAssociation('transactions');
  69.                 $order = $this->orderRepository->search($criteria, $event->getContext())->first();
  70.                 $paymentMethods = $order->getTransactions()->getPaymentMethodIds();
  71.                 foreach ($paymentMethods as $paymentMethod) {
  73.                     /** @var PaymentMethodEntity $paymentMethod */
  74.                     if ($paymentMethod === $this->getBudgetPaymentMethodId()) {
  75.                         $budget = $this->budgetLoaderService->getBudgetById($this->sessionService->getBudgetIdFromSession());
  76.                         if (!is_null($budget)) {
  77.                             $customFields = $order->getCustomFields() ?? [];
  79.                             if (!array_key_exists(self::CUSTOM_FIELD_BUDGET_NAME_SAVE_ON_ORDER, $customFields)) {
  80.                                 $customFields[self::CUSTOM_FIELD_BUDGET_NAME_SAVE_ON_ORDER] = $budget->getName();
  82.                                 $data = [
  83.                                     [
  84.                                         'id' => $order->getId(),
  85.                                         'customFields' => $customFields
  86.                                     ]
  87.                                 ];
  88.                                 $this->orderRepository->upsert($data, $event->getContext());
  89.                             }
  90.                         }
  91.                     }
  92.                 }
  93.             }
  94.         }
  95.     }
  97.     private function getBudgetPaymentMethodId(): ?string
  98.     {
  99.         $paymentCriteria = (new Criteria())->addFilter(new EqualsFilter('name', 'budget'));
  100.         return $this->paymentMethodRepository->searchIds($paymentCriteria, Context::createDefaultContext())->firstId();
  101.     }
  103. }