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

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\Framework\Api\Context\AdminApiSource;
  11. use Shopware\Core\Framework\Context;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. class BudgetShiftOrderPlacedCustomFieldSubscriber implements EventSubscriberInterface
  19. {
  20.     public const CUSTOM_FIELD_BUDGET_NAME_SAVE_ON_ORDER = 'custom_field_budget_name_save_on_order';
  22.     private EntityRepositoryInterface $paymentMethodRepository;
  24.     private BudgetLoaderService $budgetLoaderService;
  25.     private SessionService $sessionService;
  27.     private EntityRepositoryInterface $orderRepository;
  29.     public function __construct(
  30.         EntityRepositoryInterface $paymentMethodRepository,
  31.         BudgetLoaderService       $budgetLoaderService,
  32.         SessionService            $sessionService,
  33.         EntityRepositoryInterface $orderRepository
  34.     )
  35.     {
  36.         $this->paymentMethodRepository = $paymentMethodRepository;
  37.         $this->budgetLoaderService = $budgetLoaderService;
  38.         $this->sessionService = $sessionService;
  39.         $this->orderRepository = $orderRepository;
  40.     }
  42.     public static function getSubscribedEvents(): array
  43.     {
  44.         return [
  45.             OrderEvents::ORDER_WRITTEN_EVENT => 'onCheckoutFinishPageLoaded'
  46.         ];
  47.     }
  49.     public function onCheckoutFinishPageLoaded(EntityWrittenEvent $event)
  50.     {
  52.         // if context is admin do nothing
  53.         if ($event->getContext()->getSource() instanceof AdminApiSource) {
  54.             return;
  55.         }
  57.         $writeResults = $event->getWriteResults();
  59.         if (!empty($writeResults) && isset($writeResults[0]) && isset($writeResults[0]->getPayload()['id'])) {
  60.             $orderId = $writeResults[0]->getPayload()['id'];
  62.             // Überprüfen, ob $orderId nicht leer ist
  63.             if (!empty($orderId)) {
  64.                 $criteria = (new Criteria())
  65.                     ->addFilter(new EqualsFilter('id', $orderId))
  66.                     ->addAssociation('transactions');
  68.                 $order = $this->orderRepository->search($criteria, $event->getContext())->first();
  69.                 if (!$order instanceof OrderEntity) {
  70.                     return;
  71.                 }
  73.                 // CIO-AI-Driven: Null-Session sauber ignorieren
  74.                 $budgetId = $this->sessionService->getBudgetIdFromSession();
  75.                 if (!is_string($budgetId) || $budgetId === '') {
  76.                     return;
  77.                 }
  79.                 $paymentMethods = $order->getTransactions() ? $order->getTransactions()->getPaymentMethodIds() : [];
  80.                 foreach ($paymentMethods as $paymentMethod) {
  82.                     /** @var string $paymentMethod */
  83.                     if ($paymentMethod === $this->getBudgetPaymentMethodId()) {
  84.                         $budget = $this->budgetLoaderService->getBudgetById($budgetId);
  85.                         if (!is_null($budget)) {
  86.                             // CIO-AI-Driven: Merge statt Ueberschreiben, First-Write-Wins (kein Update bei bestehendem Wert)
  87.                             $customFields = $order->getCustomFields() ?? [];
  89.                             if (!array_key_exists(self::CUSTOM_FIELD_BUDGET_NAME_SAVE_ON_ORDER, $customFields)) {
  90.                                 $customFields[self::CUSTOM_FIELD_BUDGET_NAME_SAVE_ON_ORDER] = $budget->getName();
  92.                                 $data = [
  93.                                     [
  94.                                         'id' => $order->getId(),
  95.                                         'customFields' => $customFields
  96.                                     ]
  97.                                 ];
  98.                                 $this->orderRepository->upsert($data, $event->getContext());
  99.                             }
  100.                         }
  101.                     }
  102.                 }
  103.             }
  104.         }
  105.     }
  107.     private function getBudgetPaymentMethodId(): ?string
  108.     {
  109.         $paymentCriteria = (new Criteria())->addFilter(new EqualsFilter('name', 'budget'));
  110.         return $this->paymentMethodRepository->searchIds($paymentCriteria, Context::createDefaultContext())->firstId();
  111.     }
  113. }