custom/plugins/ImnxxCustomerHelper/src/Subscriber/AddressSubscriber.php line 151

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace ImnxxCustomerHelper\Subscriber;
  5. use ImnxxCustomerHelper\Service\HelperService;
  6. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  7. use Shopware\Storefront\Page\GenericPageLoadedEvent;
  8. use stdClass;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. class AddressSubscriber implements EventSubscriberInterface
  12. {
  13.     private HelperService $helperService;
  15.     public function __construct(HelperService $helperService)
  16.     {
  17.         $this->helperService = $helperService;
  18.     }
  20.     public static function getSubscribedEvents(): array
  21.     {
  22.         return [
  23.             GenericPageLoadedEvent::class => 'onPageLoaded',
  24.             CheckoutOrderPlacedEvent::class => 'onCheckoutOrderPlacedEvent',
  25.         ];
  26.     }
  28.     public function onCheckoutOrderPlacedEvent(CheckoutOrderPlacedEvent $event)
  29.     {
  30.         $_SESSION['GET_ADDRESSES'] = true;
  31.     }
  33.     private function getNwbGuestAddresses($addressGroupId, $nwbService)
  34.     {
  35.         $curl = curl_init('https://'.$nwbService.'/customercare/api/addresses/GetVisitorAddresses/' . $addressGroupId);
  36.         curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
  37.         $nwbAccountAddresses = json_decode(curl_exec($curl));
  38.         curl_close($curl);
  40.         return $nwbAccountAddresses;
  41.     }
  43.     private function getNwbAddresses($nwbAccountId, $nwbSessionId, $nwbService)
  44.     {
  45.         $curl = curl_init('https://'.$nwbService.'/customercare/api/addresses/GetUserAddresses/' . $nwbAccountId);
  46.         curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
  47.         curl_setopt($curl, CURLOPT_HTTPHEADER, ['x-nwb-sessionid: ' . $nwbSessionId]);
  48.         curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
  49.         $nwbAccountAddresses = json_decode(curl_exec($curl));
  50.         curl_close($curl);
  52.         return $nwbAccountAddresses;
  53.     }
  55.     private function getAddressState($swAddresses, $nwbAddresses): stdClass
  56.     {
  57.         $addressStatus = new stdClass();
  58.         $addressStatus->delete = [];
  59.         $addressStatus->update = [];
  60.         $addressStatus->add = [];
  62.         $swAddressIds = [];
  63.         $nwbAddressIds = [];
  65.         foreach ($swAddresses as $swAddress) {
  66.             if($swAddress->getCustomFields()['custom_address_attributs_nwb_address_id'] !== 0) {
  67.                 $swAddressIds[$swAddress->getCustomFields()['custom_address_attributs_nwb_address_id']] = $swAddress;
  68.             }
  69.         }
  71.         foreach ($nwbAddresses->Addresses as $nwbAddress) {
  72.             $nwbAddressIds[$nwbAddress->ID] = $nwbAddress;
  73.         }
  75.         foreach ($nwbAddressIds as $nwbId => $nwbAddress) {
  76.             if (isset($swAddressIds[$nwbId])) {
  77.                 $addressStatus->update[$nwbId] = $swAddressIds[$nwbId];
  78.             } else {
  79.                 $addressStatus->add[$nwbId] = $nwbAddress;
  80.             }
  81.         }
  83.         foreach ($swAddressIds as $nwbId => $swAddress) {
  84.             if (!isset($addressStatus->update[$nwbId])) {
  85.                 $addressStatus->delete[$swAddress->getId()] = $swAddress;
  86.             }
  87.         }
  89.         return $addressStatus;
  90.     }
  92.     public function convertNwbAddressToSwAddress($nwbAddress, $customerId, $context): array
  93.     {
  94.         if ($nwbAddress->Country != 'DE') {
  95.             // get Country ID, when not germany
  96.             $nwbAddress->Country_id = $this->helperService->getCountryIdByIso($nwbAddress->Country, $context);
  97.         } else {
  98.             $nwbAddress->Country_id = $this->helperService->getCountryIdByIso('DE', $context);
  99.         }
  101.         if (strtolower($nwbAddress->Salutation) == 'herr') {
  102.             $nwbAddress->Salutation_id = '5d6a01a988104035adc1e822e2d2ca7e';
  103.         } elseif (strtolower($nwbAddress->Salutation) == 'frau') {
  104.             $nwbAddress->Salutation_id = '7ae9a14f06db435bbbd95bcb0a92cf17';
  105.         } else {
  106.             $nwbAddress->Salutation_id = '40a8fca759e04bb5a372711c7aa63e10';
  107.         }
  109.         $phoneNr = '';
  110.         if (
  111.             isset($nwbAddress->TelephoneCityPrefix) &&
  112.             $nwbAddress->TelephoneCityPrefix != '' &&
  113.             isset($nwbAddress->TelephoneNumber) &&
  114.             $nwbAddress->TelephoneNumber != ''
  115.         ) {
  116.             $phoneNr = $nwbAddress->TelephoneCityPrefix . '/' . $nwbAddress->TelephoneNumber;
  117.         }
  119.         $street = $nwbAddress->Street;
  120.         $streetNumber = $nwbAddress->Streetnumber;
  121.         $salutationId = $nwbAddress->Salutation_id;
  123.         $address = [
  124.             'customerId' => $customerId,
  125.             'company' => isset($nwbAddress->Institution) ? $nwbAddress->Institution : '',
  126.             'department' => isset($nwbAddress->Department) ? $nwbAddress->Department : '',
  127.             'countryId' => $nwbAddress->Country_id,
  128.             'salutationId' => $salutationId,
  129.             'firstName' => $nwbAddress->Firstname,
  130.             'lastName' => $nwbAddress->Name,
  131.             'zipcode' => $nwbAddress->Postalcode,
  132.             'city' => $nwbAddress->City,
  133.             'street' => $street . ' ' . $streetNumber,
  134.             'phoneNumber' => $phoneNr,
  135.             'customFields' => [
  136.                 'custom_address_attributs_nwb_address_id' => $nwbAddress->ID,
  137.                 'acris_separate_street_address_street' => $street,
  138.                 'acris_separate_street_address_house_number' => $streetNumber,
  139.                 'iban' => isset($nwbAddress->IBAN) ? $nwbAddress->IBAN : '',
  140.                 'account_holder' => isset($nwbAddress->AccountHolder) ? $nwbAddress->AccountHolder : '',
  141.             ],
  142.         ];
  144.         if ($nwbAddress->Type == 0) {
  145.             $address['customFields']['nwb_address_is_billing'] = true;
  146.         }
  148.         return $address;
  149.     }
  151.     public function onPageLoaded(GenericPageLoadedEvent $event)
  152.     {
  153.         $nwbService = $event->getSalesChannelContext()->getSalesChannel()->getCustomFields()['bis_url'];
  154.         if (
  155.             $event->getSalesChannelContext()->getCustomer() != null &&
  156.             (
  157.                 (
  158.                     isset($_SERVER['HTTP_REFERER']) &&
  159.                     str_contains($_SERVER['HTTP_REFERER'], $nwbService)
  160.                 ) ||
  161.                 (
  162.                     isset($_SESSION['GET_ADDRESSES']) && !str_contains($_SERVER['REQUEST_URI'], '/checkout/finish')
  163.                 )
  164.             )
  165.         ) {
  166.             $customer = $this->helperService->getCustomerWithId(
  167.                 $event->getContext(),
  168.                 $event->getSalesChannelContext()->getCustomer()->getId()
  169.             );
  172.             $nwbAccountId = isset($customer->getCustomFields()['custom_customer_attributes_account_id'])
  173.                 ? $customer->getCustomFields()['custom_customer_attributes_account_id']
  174.                 : null;
  176.             $nwbSessionId = isset($customer->getCustomFields()['custom_customer_attributes_session_id'])
  177.                 ? $customer->getCustomFields()['custom_customer_attributes_session_id']
  178.                 : null;
  180.             $addressGroupId = $_SESSION['addressGroupId'] ?? null;
  181.             $nwbAddresses = null;
  183.             if ($addressGroupId != null) {
  184.                 $nwbAddresses = $this->getNwbGuestAddresses($_SESSION['addressGroupId'], $nwbService);
  185.             }
  187.             if ($nwbAccountId) {
  188.                 $nwbAddresses = $this->getNwbAddresses($nwbAccountId, $nwbSessionId, $nwbService);
  189.             }
  193.             if ($nwbAddresses != null) {
  194.                 $swAddresses = $this->helperService->getCustomerAddresses($customer->getId(), $event->getContext());
  195.                 $addressStatus = $this->getAddressState($swAddresses, $nwbAddresses);
  198.                 foreach ($addressStatus->update as $nwbAddressId => $swAddress) {
  199.                     $toUpdateNwbAddress = null;
  200.                     foreach ($nwbAddresses->Addresses as $nwbAddress) {
  201.                         if ($nwbAddressId == $nwbAddress->ID) {
  202.                             $toUpdateNwbAddress = $nwbAddress;
  203.                         }
  204.                     }
  206.                     $convertedAddress = $this->convertNwbAddressToSwAddress($toUpdateNwbAddress, $customer->getId(), $event->getContext());
  207.                     $this->helperService->updateCustomerAddress($swAddress->getId(), $convertedAddress, $event->getContext());
  208.                 }
  210.                 foreach ($addressStatus->add as $nwbAddressId => $nwbAddress) {
  211.                     $convertedAddress = $this->convertNwbAddressToSwAddress($nwbAddress, $customer->getId(), $event->getContext());
  213.                     $this->helperService->addCustomerAddress($convertedAddress, $event->getContext());
  214.                 }
  218.                 if ($nwbSessionId) {
  219.                     $swAddresses = $this->helperService->getCustomerAddresses($customer->getId(), $event->getContext());
  220.                     $nwbAddressIdForDefaultBillingAddress = null;
  221.                     $nwbAddressIdForDefaultShippingAddress = null;
  222.                     $nwbShippingAddresses = [];
  224.                     foreach ($nwbAddresses->Addresses as $nwbAddress) {
  225.                         if ($nwbAddress->Type == 1) {
  226.                             if ( $nwbAddress->IsDefaultAddress && is_null($nwbAddressIdForDefaultShippingAddress) ) {
  227.                                 $nwbAddressIdForDefaultShippingAddress = $nwbAddress->ID;
  228.                             }
  229.                             if ( isset($_GET['addressId']) && $_GET['addressId'] == $nwbAddress->ID ) {
  230.                                 $nwbAddressIdForDefaultShippingAddress = $nwbAddress->ID;
  231.                             }
  232.                             $nwbShippingAddresses[] = $nwbAddress;
  233.                         }
  234.                         if ($nwbAddress->Type == 0 /*&& $nwbAddress->IsDefaultAddress*/) {
  235.                             $nwbAddressIdForDefaultBillingAddress = $nwbAddress->ID;
  236.                         }
  237.                     }
  240.                     if ($nwbAddressIdForDefaultShippingAddress == null) {
  241.                         $nwbAddressIdForDefaultShippingAddress = array_shift($nwbShippingAddresses);
  243.                         if($nwbAddressIdForDefaultShippingAddress == null){
  244.                             $nwbAddressIdForDefaultShippingAddress = $nwbAddressIdForDefaultBillingAddress;
  245.                         }
  246.                     }
  248.                     foreach ($swAddresses as $swAddress) {
  249.                         if ($swAddress->getCustomFields()['custom_address_attributs_nwb_address_id'] == $nwbAddressIdForDefaultBillingAddress) {
  250.                             $paymentId = $this->helperService->getPaymentMethodIdByName('Kauf auf Rechnung', $event->getContext());
  251.                             $this->helperService->updateCustomer(
  252.                                 $customer->getId(),
  253.                                 [
  254.                                     'defaultBillingAddressId' => $swAddress->getId(),
  255.                                     'defaultPaymentMethodId' => $paymentId
  256.                                 ],
  257.                                 $event->getContext()
  258.                             );
  259.                         }
  261.                         if (
  262.                             $nwbAddressIdForDefaultShippingAddress != null &&
  263.                             $swAddress->getCustomFields()['custom_address_attributs_nwb_address_id'] == $nwbAddressIdForDefaultShippingAddress
  264.                         ) {
  265.                             $this->helperService->updateCustomer(
  266.                                 $customer->getId(),
  267.                                 ['defaultShippingAddressId' => $swAddress->getId()],
  268.                                 $event->getContext()
  269.                             );
  270.                         }
  272.                     }
  273.                 }
  274.                 foreach ($addressStatus->delete as $swId => $swAddress) {
  275.                     $this->helperService->deleteCustomerAddress($swId, $event->getContext());
  276.                 }
  277.             }
  278.             if(isset($_SESSION['GET_ADDRESSES'])){
  279.                 unset($_SESSION['GET_ADDRESSES']);
  280.             }
  281.             header('Refresh: 0');
  282.             die();
  283.         }
  284.     }
  285. }