custom/plugins/ProcB2BPasswordRecovery/src/Core/Checkout/Contact/Subscriber/ContactChangePasswordSubscriber.php line 45

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace ProcB2BPasswordRecovery\Core\Checkout\Contact\Subscriber;
  6. use Doctrine\DBAL\Connection;
  7. use Doctrine\DBAL\Exception;
  8. use Shopware\Core\Checkout\Customer\CustomerEvents;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  10. use Shopware\Core\Framework\Uuid\Uuid;
  11. use Shopware\Core\System\SystemConfig\SystemConfigService;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. class ContactChangePasswordSubscriber implements EventSubscriberInterface
  15. {
  16.     /**
  17.      * @var Connection
  18.      */
  19.     private Connection $connection;
  21.     /**
  22.      * @var SystemConfigService
  23.      */
  24.     private SystemConfigService $systemConfigService;
  26.     public function __construct(Connection $connection, SystemConfigService $systemConfigService)
  27.     {
  28.         $this->connection = $connection;
  29.         $this->systemConfigService = $systemConfigService;
  30.     }
  32.     /**
  33.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  34.      */
  35.     public static function getSubscribedEvents()
  36.     {
  37.         return [
  38.             CustomerEvents::CUSTOMER_WRITTEN_EVENT => 'onCustomerWritten',
  39.         ];
  40.     }
  42.     /**
  43.      * @throws Exception
  44.      */
  45.     public function onCustomerWritten(EntityWrittenEvent $event): void
  46.     {
  47.         if ($this->systemConfigService->get('ProcB2BPasswordRecovery.config.b2bContactPasswordRecovery')) {
  48.             $payloads = $event->getPayloads();
  49.             foreach ($payloads as $payload) {
  50.                 if (!empty($payload['password'])) {
  51.                     $this->changeContactPassword($payload['id'], $payload['password']);
  52.                 }
  53.             }
  54.         }
  55.     }
  58.     /**
  59.      * @throws Exception
  60.      */
  61.     private function changeContactPassword(string $customerId, string $password): void
  62.     {
  63.         $this->connection->executeUpdate(
  65.             'UPDATE `b2b_debtor_contact` SET `password` = :password WHERE email = (SELECT email FROM customer WHERE id = :id)',
  66.             [
  67.                 'id' => Uuid::fromHexToBytes($customerId),
  68.                 'password' => $password,
  69.             ]
  70.         );
  71.     }
  72. }