custom/plugins/OkeonlineKejeLogin/src/Core/Checkout/Customer/Subscriber/CustomerEntityWrittenSubscriber.php line 43

Open in your IDE?
  1. <?php
  3. namespace Okeonline\KejeLogin\Core\Checkout\Customer\Subscriber;
  5. use Doctrine\DBAL\Connection;
  6. use Okeonline\KejeLogin\Core\Checkout\Customer\Exception\LoginIdentifierNotUniqueException;
  7. use Shopware\Core\Checkout\Customer\CustomerEvents;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\NotFilter;
  13. use Shopware\Core\System\SystemConfig\SystemConfigService;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class CustomerEntityWrittenSubscriber implements EventSubscriberInterface
  18. {
  19.     protected $systemConfigService;
  21.     protected $customerRepository;
  23.     protected $connection;
  25.     public function __construct(
  26.         SystemConfigService $systemConfigService,
  27.         EntityRepository $customerRepository,
  28.         Connection $connection
  29.     )
  30.     {
  31.         $this->systemConfigService = $systemConfigService;
  32.         $this->customerRepository = $customerRepository;
  33.         $this->connection = $connection;
  34.     }
  36.     public static function getSubscribedEvents()
  37.     {
  38.         return [
  39.             CustomerEvents::CUSTOMER_WRITTEN_EVENT => 'customerEntityWritten'
  40.         ];
  41.     }
  43.     public function customerEntityWritten(EntityWrittenEvent $event)
  44.     {
  45.         // check if module is active
  46.         if(!$this->systemConfigService->get('OkeonlineKejeLogin.config.active'))
  47.         {
  48.             return;
  49.         }
  51.         $identifier = $this->systemConfigService->get('OkeonlineKejeLogin.config.identifier') ?? 'customer.customerNumber';
  52.         $namespace = explode('.', $identifier);
  53.         $identifier = array_pop($namespace);
  55.         foreach($event->getWriteResults() as $writeResult)
  56.         {
  57.             $writeKey = $writeResult->getPrimaryKey();
  59.             // Is there any $identifier key changed? No? Continue
  60.             if(!array_key_exists($identifier, $writeResult->getPayload()))
  61.             {
  62.                 continue;
  63.             }
  65.             $identifierValue = $writeResult->getPayload()[$identifier];
  67.             // search repository, where not id, and is $identifier = $identifierValue
  68.             $criteria = new Criteria();
  69.             $criteria->addFilter(new EqualsFilter($identifier, $identifierValue));
  70.             $criteria->addFilter(new NotFilter(
  71.                 NotFilter::CONNECTION_AND,
  72.                 [
  73.                     new EqualsFilter('id', $writeKey)
  74.                 ]
  75.             ));
  77.             $result = $this->customerRepository->search($criteria, $event->getContext());
  79.             // Other entities with same $identifier?
  80.             if($result->getTotal() !== 0)
  81.             {
  83.                 $this->connection->executeQuery(
  84.                     'UPDATE `customer` SET `'.$this->_decamelize($identifier).'` = "'.$identifierValue.'_notUnique" WHERE `id` = UNHEX(\''.$writeKey.'\');'
  85.                 );
  87.                 throw new LoginIdentifierNotUniqueException($identifier, $identifierValue);
  88.             }
  90.             unset($writeKey, $identifierValue);
  91.         }
  92.     }
  94.     protected function _decamelize($string) {
  95.         return strtolower(preg_replace(['/([a-z\d])([A-Z])/', '/([^_])([A-Z][a-z])/'], '$1_$2', $string));
  96.     }
  97. }
  98. ?>