vendor/store.shopware.com/swagb2bplatform/components/Address/BridgePlatform/AddressSynchronizationSubscriber.php line 49

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\B2B\Address\BridgePlatform;
  5. use Shopware\B2B\Common\IdValue;
  6. use Shopware\B2B\Common\Repository\NotFoundException;
  7. use Shopware\B2B\Debtor\Framework\DebtorRepositoryInterface;
  8. use Shopware\B2B\StoreFrontAuthentication\Framework\AuthenticationService;
  9. use Shopware\Core\Checkout\Customer\Aggregate\CustomerAddress\CustomerAddressDefinition;
  10. use Shopware\Core\Checkout\Customer\CustomerEvents;
  11. use Shopware\Core\Checkout\Customer\Event\CustomerLoginEvent;
  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 Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class AddressSynchronizationSubscriber implements EventSubscriberInterface
  18. {
  19.     private const SUBSCRIBER_PRIORITY = -10;
  21.     private CustomerAddressDataService $customerAddressDataService;
  23.     private AuthenticationService $authenticationService;
  25.     private EntityRepositoryInterface $customerRepository;
  27.     private DebtorRepositoryInterface $debtorRepository;
  29.     public function __construct(
  30.         CustomerAddressDataService $customerAddressDataService,
  31.         AuthenticationService $authenticationService,
  32.         EntityRepositoryInterface $customerRepository,
  33.         DebtorRepositoryInterface $debtorRepository
  34.     ) {
  35.         $this->customerAddressDataService = $customerAddressDataService;
  36.         $this->authenticationService = $authenticationService;
  37.         $this->customerRepository = $customerRepository;
  38.         $this->debtorRepository = $debtorRepository;
  39.     }
  41.     public static function getSubscribedEvents(): array
  42.     {
  43.         return [
  44.             CustomerEvents::CUSTOMER_ADDRESS_WRITTEN_EVENT => 'syncAddressesByAddressWritten',
  45.             CustomerLoginEvent::class => ['syncAddressesByCustomerLogin', self::SUBSCRIBER_PRIORITY],
  46.         ];
  47.     }
  49.     public function syncAddressesByCustomerLogin(CustomerLoginEvent $event): void
  50.     {
  51.         if (!$this->authenticationService->isB2b()) {
  52.             return;
  53.         }
  55.         $customer = $event->getCustomer();
  57.         $this->customerAddressDataService
  58.             ->synchronizeCustomerAddresses($customer);
  59.     }
  61.     public function syncAddressesByAddressWritten(EntityWrittenEvent $event): void
  62.     {
  63.         if ($event->getEntityName() !== CustomerAddressDefinition::ENTITY_NAME) {
  64.             return;
  65.         }
  67.         $writtenResults = $event->getPayloads();
  68.         $customerIds = [];
  70.         foreach ($writtenResults as $address) {
  71.             $customerId = $address['customerId'];
  73.             try {
  74.                 $this->debtorRepository->fetchOneById(IdValue::create($customerId));
  75.             } catch (NotFoundException $exception) {
  76.                 continue;
  77.             }
  79.             $customerIds[] = $customerId;
  80.         }
  82.         if (!$customerIds) {
  83.             return;
  84.         }
  86.         $result = $this->customerRepository
  87.             ->search(new Criteria($customerIds), $event->getContext());
  89.         foreach ($result->getEntities() as $entity) {
  90.             $this->customerAddressDataService
  91.                 ->synchronizeCustomerAddresses($entity);
  92.         }
  93.     }
  94. }