custom/static-plugins/AbasConnector/src/Subscribers/Customer/UpdateAddressSubscriber.php line 71

Open in your IDE?
  1. <?php
  3. namespace Abas\AbasConnector\Subscribers\Customer;
  5. use Abas\AbasConnector\Service\Mapper\Customer\Exceptions\NoAbasCustomerException;
  6. use Abas\AbasConnector\Service\Sync\AbasDataComponentSync;
  7. use Abas\AbasConnector\Service\Utils\Config\PluginConfigReader;
  8. use Exception;
  9. use Shopware\Core\Checkout\Customer\Aggregate\CustomerAddress\CustomerAddressEntity;
  10. use Shopware\Core\Checkout\Customer\CustomerEvents;
  11. use Shopware\Core\Framework\Context;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Exception\InconsistentCriteriaIdsException;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. class UpdateAddressSubscriber implements EventSubscriberInterface
  19. {
  20.     /**
  21.      * @var bool
  22.      */
  23.     protected static $running = false;
  25.     /**
  26.      * @var EntityRepositoryInterface
  27.      */
  28.     protected $entityRepository;
  30.     /**
  31.      * @var AbasDataComponentSync
  32.      */
  33.     protected $abasDataComponentSync;
  35.     /**
  36.      * @var PluginConfigReader
  37.      */
  38.     protected $pluginConfigReader;
  40.     /**
  41.      * @param EntityRepositoryInterface $entityRepository
  42.      * @param AbasDataComponentSync $abasDataComponentSync
  43.      * @param PluginConfigReader $pluginConfigReader
  44.      */
  45.     public function __construct(
  46.         EntityRepositoryInterface $entityRepository,
  47.         AbasDataComponentSync $abasDataComponentSync,
  48.         PluginConfigReader $pluginConfigReader
  49.     ) {
  50.         $this->entityRepository = $entityRepository;
  51.         $this->abasDataComponentSync = $abasDataComponentSync;
  52.         $this->pluginConfigReader = $pluginConfigReader;
  53.     }
  55.     /**
  56.      * @inheritDoc
  57.      */
  58.     public static function getSubscribedEvents()
  59.     {
  60.         return [
  61.             CustomerEvents::CUSTOMER_ADDRESS_WRITTEN_EVENT => 'onCustomerAddressWrittenEvent'
  62.         ];
  63.     }
  65.     /**
  66.      * @param EntityWrittenEvent $event
  67.      *
  68.      * @return void
  69.      * @throws Exception
  70.      */
  71.     public function onCustomerAddressWrittenEvent(EntityWrittenEvent $event)
  72.     {
  73.         if (self::$running || !$this->pluginConfigReader->getSyncShippingAddressesAsCustomerContacts()) {
  74.             return;
  75.         }
  77.         self::$running = true;
  78.         $context = $event->getContext();
  79.         $ids = $event->getIds();
  81.         try {
  82.             foreach ($ids as $id) {
  83.                 $this->syncCustomerAddress($id, $context);
  84.             }
  85.         } finally {
  86.             self::$running = false;
  87.         }
  88.     }
  90.     /**
  91.      * @param string $id
  92.      * @param Context $context
  93.      *
  94.      * @return void
  95.      */
  96.     protected function syncCustomerAddress(string $id, Context $context)
  97.     {
  98.         $customerAddressEntity = $this->getAddressCustomerAddressEntity($id, $context);
  99.         try {
  100.             $this->abasDataComponentSync->syncEntityToAbas($customerAddressEntity);
  101.         } catch (NoAbasCustomerException $exception) {
  102.         }
  103.     }
  105.     /**
  106.      * @param string $id
  107.      * @param Context $context
  108.      *
  109.      * @return CustomerAddressEntity|null
  110.      * @throws InconsistentCriteriaIdsException
  111.      */
  112.     protected function getAddressCustomerAddressEntity(string $id, Context $context): ?CustomerAddressEntity
  113.     {
  114.         $criteria = new Criteria([$id]);
  115.         $criteria->addAssociations(
  116.             [
  117.                 'customer',
  118.                 'country',
  119.                 'salutation'
  120.             ]
  121.         );
  122.         $criteria->setLimit(1);
  124.         return $this->entityRepository->search($criteria, $context)->first();
  125.     }
  126. }