custom/static-plugins/EfbStorefront/Subscriber/OrderSubscriber.php line 48

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Uandi\EFB\Storefront\Subscriber;
  7. use Exception;
  8. use Psr\Log\LoggerInterface;
  9. use Shopware\Core\Framework\Context;
  10. use Shopware\Core\Checkout\Order\OrderEvents;
  11. use Symfony\Component\HttpFoundation\RequestStack;
  12. use Shopware\Core\Checkout\Cart\AbstractCartPersister;
  13. use Uandi\EFB\Storefront\Struct\CartPreferenceExtension;
  14. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  17. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  19. class OrderSubscriber implements EventSubscriberInterface
  20. {
  21.     private EntityRepositoryInterface $orderRepository;
  22.     private RequestStack $requestStack;
  23.     private AbstractCartPersister $cartPersister;
  24.     private LoggerInterface $logger;
  25.     private EntityRepositoryInterface $customerRepository;
  27.     public function __construct(
  28.         EntityRepositoryInterface $orderRepository,
  29.         RequestStack $requestStack,
  30.         AbstractCartPersister $cartPersister,
  31.         LoggerInterface $logger,
  32.         EntityRepositoryInterface $customerRepository
  33.     ) {
  34.         $this->orderRepository = $orderRepository;
  35.         $this->requestStack = $requestStack;
  36.         $this->cartPersister = $cartPersister;
  37.         $this->logger = $logger;
  38.         $this->customerRepository = $customerRepository;
  39.     }
  41.     public static function getSubscribedEvents(): array
  42.     {
  43.         return [
  44.             OrderEvents::ORDER_WRITTEN_EVENT => 'onOrderWritten'
  45.         ];
  46.     }
  48.     public function onOrderWritten(EntityWrittenEvent $event)
  49.     {
  50.         $request = $this->requestStack->getCurrentRequest();
  52.         if (null === $request) return;
  54.         /** @var SalesChannelContext $salesChannelContext */
  55.         $salesChannelContext = $request->get('sw-sales-channel-context') ?? null;
  57.         if (null === $salesChannelContext) {
  58.             $this->logger->error('Not possible to save preferences into order. salesChannelContext not found.');
  59.             return;
  60.         }
  62.         if ($salesChannelContext->getCustomerId()) {
  63.             $this->tagCustomer($salesChannelContext->getCustomerId(), $event->getContext());
  64.         }
  66.         $av_contact_person = $request->get('av_contact_person') ? $request->get('av_contact_person') : null;
  67.         $av_phone_number = $request->get('av_phone_number') ? $request->get('av_phone_number') : null;
  68.         $av_active = $request->get('av_active') ? 'true' : 'false';
  70.         $context = $event->getContext();
  71.         foreach ($event->getWriteResults() as $writeResult) {
  72.             if ($writeResult->getExistence() !== null && $writeResult->getExistence()->exists()) continue;
  73.             if ($writeResult->getOperation() !== 'insert') continue;
  75.             $payload = $writeResult->getPayload();
  76.             if (empty($payload)) continue;
  78.             $customFields = !empty($payload['customFields']) ? $payload['customFields'] : [];
  80.             if (!empty($customFields) && !empty($customFields['preferences'])) continue;
  82.             try {
  83.                 $customFields['preferences'] = $this->getCartPreferences($salesChannelContext->getToken() ?? '', $salesChannelContext);
  84.                 $customFields['av_contact_person'] = $av_contact_person;
  85.                 $customFields['av_phone_number'] = $av_phone_number;
  86.                 $customFields['av_active'] = $av_active;
  88.                 $data = [
  89.                     [
  90.                         'id' => $payload['id'],
  91.                         'customFields' => $customFields
  92.                     ]
  93.                 ];
  95.                 $this->orderRepository->update($data, $context);
  96.             } catch (Exception $exception) {
  97.                 $this->logger->error('Error while processing saving preferences into order: ' . $exception->getMessage());
  98.             }
  99.         }
  100.     }
  102.     private function getCartPreferences(string $cartToken, SalesChannelContext $salesChannelContext): array
  103.     {
  104.         $cart = $this->cartPersister->load($cartToken, $salesChannelContext);
  105.         $cartPreferences = $cart->getExtension(CartPreferenceExtension::NAME);
  107.         return $cartPreferences->getCartPreferences() ?? [];
  108.     }
  110.     private function tagCustomer(string $customerId, Context $context): void
  111.     {
  112.         $this->customerRepository->upsert([[
  113.             'id' => $customerId,
  114.             'customFields' => ['emz_customer_has_ordered_in_shop' => true]
  115.         ]], $context);
  116.     }
  117. }