custom/plugins/SwagB2bPlatform/components/Address/BridgePlatform/AddressSynchronizationSubscriber.php line 73

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.     /**
  22.      * @var CustomerAddressDataService
  23.      */
  24.     private $customerAddressDataService;
  26.     /**
  27.      * @var AuthenticationService
  28.      */
  29.     private $authenticationService;
  31.     /**
  32.      * @var EntityRepositoryInterface
  33.      */
  34.     private $customerRepository;
  36.     /**
  37.      * @var DebtorRepositoryInterface
  38.      */
  39.     private $debtorRepository;
  41.     public function __construct(
  42.         CustomerAddressDataService $customerAddressDataService,
  43.         AuthenticationService $authenticationService,
  44.         EntityRepositoryInterface $customerRepository,
  45.         DebtorRepositoryInterface $debtorRepository
  46.     ) {
  47.         $this->customerAddressDataService = $customerAddressDataService;
  48.         $this->authenticationService = $authenticationService;
  49.         $this->customerRepository = $customerRepository;
  50.         $this->debtorRepository = $debtorRepository;
  51.     }
  53.     public static function getSubscribedEvents(): array
  54.     {
  55.         return [
  56.             CustomerEvents::CUSTOMER_ADDRESS_WRITTEN_EVENT => 'syncAddressesByAddressWritten',
  57.             CustomerLoginEvent::class => ['syncAddressesByCustomerLogin', self::SUBSCRIBER_PRIORITY],
  58.         ];
  59.     }
  61.     public function syncAddressesByCustomerLogin(CustomerLoginEvent $event): void
  62.     {
  63.         if (!$this->authenticationService->isB2b()) {
  64.             return;
  65.         }
  67.         $customer = $event->getCustomer();
  69.         $this->customerAddressDataService
  70.             ->synchronizeCustomerAddresses($customer);
  71.     }
  73.     public function syncAddressesByAddressWritten(EntityWrittenEvent $event): void
  74.     {
  75.         if ($event->getEntityName() !== CustomerAddressDefinition::ENTITY_NAME) {
  76.             return;
  77.         }
  79.         $writtenResults = $event->getPayloads();
  80.         $customerIds = [];
  82.         foreach ($writtenResults as $address) {
  83.             $customerId = $address['customerId'];
  85.             try {
  86.                 $this->debtorRepository->fetchOneById(IdValue::create($customerId));
  87.             } catch (NotFoundException $exception) {
  88.                 continue;
  89.             }
  91.             $customerIds[] = $customerId;
  92.         }
  94.         if (!$customerIds) {
  95.             return;
  96.         }
  98.         $result = $this->customerRepository
  99.             ->search(new Criteria($customerIds), $event->getContext());
  101.         foreach ($result->getEntities() as $entity) {
  102.             $this->customerAddressDataService
  103.                 ->synchronizeCustomerAddresses($entity);
  104.         }
  105.     }
  106. }