custom/plugins/WabsAuftragsdatenSync/src/Subscriber/WabsAuftragsdatenSyncSubscriber.php line 44

Open in your IDE?
  1. <?php declare(strict_types=1);
  4. namespace WabsAuftragsdatenSync\Subscriber;
  6. use Exception;
  7. use Psr\Log\LoggerInterface;
  8. use Shopware\Core\Checkout\Customer\CustomerEntity;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  10. use Shopware\Storefront\Page\Checkout\Finish\CheckoutFinishPageLoadedEvent;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use WabsAuftragsdatenSync\Services\WabsAuftragsdatenSyncService;
  15. class WabsAuftragsdatenSyncSubscriber implements EventSubscriberInterface
  16. {
  17.     /** @var WabsAuftragsdatenSyncService $wabsAuftragsdatenSyncService */
  18.     private $wabsAuftragsdatenSyncService;
  20.     /** @var LoggerInterface $logger */
  21.     private $logger;
  23.     /**  @var EntityRepositoryInterface */
  24.     private $orderCustomerRepository;
  26.     public function __construct(
  27.         WabsAuftragsdatenSyncService $wabsAuftragsdatenSyncService,
  28.         LoggerInterface $logger,
  29.         \Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface $orderCustomerRepository
  31.     ) {
  32.         $this->wabsAuftragsdatenSyncService = $wabsAuftragsdatenSyncService;
  33.         $this->logger = $logger;
  34.         $this->orderCustomerRepository = $orderCustomerRepository;
  35.     }
  37.     public static function getSubscribedEvents(): array
  38.     {
  39.         return [
  40.             CheckoutFinishPageLoadedEvent::class => 'onCheckoutFinish'
  41.         ];
  42.     }
  44.     public function onCheckoutFinish(CheckoutFinishPageLoadedEvent $event)
  45.     {
  46.         try {
  47.             $orderCustomer = $event->getPage()->getOrder()->getOrderCustomer();
  48.             $customerId = $orderCustomer->getCustomerId();
  49.             /** @var CustomerEntity $customer */
  50.             $customer = $this->wabsAuftragsdatenSyncService->getCustomerById($customerId);
  51.             $order = [
  52.                 "id" => $event->getPage()->getOrder()->getId(),
  53.                 "customFields" => [
  54.                     "igm_mbs_order_customer_group" => $customer->getGroupId()
  55.                 ]
  56.             ];
  57.             $this->wabsAuftragsdatenSyncService->saveGroupIdOnOrder($order);
  58.         } catch (Exception $exception) {
  59.             $this->logger->error("Could not save CustomerGroupId on Order!");
  60.         }
  62.         try {
  63.             $customerCustomFields = $customer->getCustomFields();
  64.             if (isset($customerCustomFields['customerDistrict'])) {
  65.                 $data = [
  66.                     'id' => $orderCustomer->getId(),
  67.                     'customFields' => ['customerDistrict' => $customerCustomFields['customerDistrict']]
  68.                 ];
  69.                 $this->orderCustomerRepository->update([$data], $event->getContext());
  70.             }
  71.         } catch (Exception $exception) {
  72.             $this->logger->error("Could not save customerDistrict on OrderCustomer!");
  73.         }
  74.     }
  75. }