custom/plugins/KlikensteenThemeCustomChanges/src/Subscriber/AddressChangedSubscriber.php line 67

Open in your IDE?
  1. <?php
  3. namespace Klikensteen\ThemeCustomChanges\Subscriber;
  5. use Shopware\Core\Checkout\Customer\CustomerEvents;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Shopware\Core\Content\Product\Events\ProductListingCriteriaEvent;
  8. use Shopware\Core\Framework\Event\DataMappingEvent;
  9. use Shopware\Core\Framework\Uuid\Uuid;
  10. use Symfony\Component\DependencyInjection\ContainerInterface;
  11. use Symfony\Component\HttpFoundation\RequestStack;
  12. use Doctrine\DBAL\Connection;
  13. use Shopware\Core\Framework\Context;
  14. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  16. /**
  17.  * Class AllVariantDetailPage
  18.  *
  19.  * Used to collect the information of the variants
  20.  */
  21. class AddressChangedSubscriber implements EventSubscriberInterface
  22. {
  23.     /**
  24.      * @var ContainerInterface
  25.      */
  26.     private $container;
  28.     /**
  29.      * @var Connection
  30.      */
  31.     private $connection;
  33.     /**
  34.      * @var RequestStack
  35.      */
  36.     protected RequestStack $requestStack;
  38.     /**
  39.      * @var EntityRepository
  40.      */
  41.     private EntityRepository $customerRepo;
  43.     public function __construct(
  44.         ContainerInterface $container,
  45.         RequestStack $requestStack,
  46.         EntityRepository $customerRepo
  47.     ) {
  48.         $this->container = $container;
  49.         $this->requestStack = $requestStack;
  50.         $this->connection = $this->container->get(Connection::class);
  51.         $this->customerRepo = $customerRepo;
  52.     }
  54.     /**
  55.      * @return string[]
  56.      */
  57.     public static function getSubscribedEvents(): array
  58.     {
  59.         return [
  60.             CustomerEvents::MAPPING_ADDRESS_CREATE => 'onAddessSave',
  61.             // CustomerEvents::CUSTOMER_ADDRESS_WRITTEN_EVENT => 'onAddessSave',
  62.             //  ProductListingCriteriaEvent::class => 'onProductListingCriteria'
  63.         ];
  64.     }
  67.     public function onAddessSave(DataMappingEvent $event)
  68.     {
  69.         $request = $this->requestStack->getMainRequest();
  70.         $customFields = $request->request->get('custom_fields');
  71.         $vatIds = $request->request->get('vatIds');
  72.         $customer = $request->attributes->get('sw-sales-channel-context')->getCustomer();
  73.         $kvkNumber = $customFields['kvk_number'];
  74.         $orderReference = $customFields['order_reference'];
  76.         if ($customFields) {
  77.             try {
  78.                 $this->connection->executeStatement(
  79.                     'UPDATE customer
  80.                 SET custom_fields = JSON_SET(
  81.                     custom_fields,
  82.                     "$.kvk_number",
  83.                     ' . $kvkNumber . '
  84.                 ) WHERE id = :customer_id',
  85.                     ['customer_id' => Uuid::fromHexToBytes($customer->id)]
  86.                 );
  88.                 $this->connection->executeStatement(
  89.                     'UPDATE customer
  90.                 SET custom_fields = JSON_SET(
  91.                     custom_fields,
  92.                     "$.order_reference",
  93.                     ' . $orderReference . '
  94.                 ) WHERE id = :customer_id',
  95.                     ['customer_id' => Uuid::fromHexToBytes($customer->id)]
  96.                 );
  99.             } catch (\Exception $e) {
  100.                 dump($e);
  101.             }
  102.             if ($vatIds[0] != "") {
  103.                 $this->customerRepo->update([
  104.                     [
  105.                         'id' => $customer->id,
  106.                         'vatIds' => $vatIds
  107.                     ]
  108.                 ], Context::createDefaultContext());
  109.             }
  110.         }
  111.     }
  113.     public function onProductListingCriteria(ProductListingCriteriaEvent $event)
  114.     {
  115.         $criteria = $event->getCriteria();
  116.         $event->getCriteria()->addAssociation('properties');
  117.         $event->getCriteria()->addAssociation('properties.group');
  118.     }
  119. }