custom/plugins/MbPayerAddress/src/Subscriber/AppendPayerDataSubscriber.php line 49

Open in your IDE?
  1. <?php
  3. namespace MbPayerAddress\Subscriber;
  5. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  6. use Doctrine\DBAL\Connection;
  7. use MbPayerAddress\Entity\OrderPayerAddressEntity;
  8. use MojeBambino\Extensions\Struct\Kafelki;
  9. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  10. use Shopware\Core\Checkout\Customer\Aggregate\CustomerAddress\CustomerAddressEntity;
  11. use Shopware\Core\Checkout\Order\Aggregate\OrderDelivery\OrderDeliveryEntity;
  12. use Shopware\Core\Checkout\Order\OrderEntity;
  13. use Shopware\Core\Checkout\Order\OrderEvents;
  14. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  19. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  20. use Shopware\Core\Framework\Struct\ArrayEntity;
  21. use Shopware\Core\Framework\Struct\ArrayStruct;
  22. use Shopware\Core\Framework\Uuid\Uuid;
  23. use Shopware\Storefront\Page\Account\Overview\AccountOverviewPageLoadedEvent;
  24. use Shopware\Storefront\Page\Address\Listing\AddressListingPageLoadedEvent;
  25. use Shopware\Storefront\Page\Checkout\Confirm\CheckoutConfirmPageLoadedEvent;
  26. use Shopware\Storefront\Page\Checkout\Finish\CheckoutFinishPageLoadedEvent;
  28. class AppendPayerDataSubscriber implements EventSubscriberInterface {
  29.     private EntityRepository $customerAddressRespository;
  30.     private EntityRepository $customerRespository;
  31.     
  32.     public function __construct(
  33.         EntityRepository $customerAddressRespository,
  34.         EntityRepository $customerRespository,
  35.     ){
  36.         $this->customerAddressRespository = $customerAddressRespository;
  37.         $this->customerRespository = $customerRespository;
  38.     }
  39.     
  40.     public static function getSubscribedEvents(): array{
  41.         return [
  42.             CheckoutConfirmPageLoadedEvent::class => 'onCheckoutConfirmPageLoadedEvent',
  43.             AddressListingPageLoadedEvent::class => 'onAddressListingPageLoadedEvent',
  44.             CheckoutFinishPageLoadedEvent::class => 'onCheckoutFinishPageLoadedEvent',
  45.             AccountOverviewPageLoadedEvent::class => 'onAccountOverviewPageLoadedEvent',
  46.         ];
  47.     }
  48.     
  49.     function onCheckoutConfirmPageLoadedEvent(CheckoutConfirmPageLoadedEvent $event): void {
  50.         $payerAddressId = $this->getPayerAddressId($event);
  51.         $this->appendPayerAddressToPage($event, $payerAddressId);
  52.     }
  53.     
  54.     function onAddressListingPageLoadedEvent(AddressListingPageLoadedEvent $event) {
  55.         $payerAddressId = $this->getPayerAddressId($event);
  56.         
  57.         $currentAddressId = $event->getRequest()->get('id');
  58.         if($currentAddressId == $payerAddressId) {
  59.             $event->getPage()->addExtension('sameAsPayer', new ArrayStruct(['sameAsPayer' => true]));
  60.         } else {
  61.             $event->getPage()->addExtension('sameAsPayer', new ArrayStruct(['sameAsPayer' => false]));
  62.         }
  63.         
  64.         $this->appendPayerAddressToPage($event, $payerAddressId);
  65.     }
  66.     
  67.     public function onCheckoutFinishPageLoadedEvent(CheckoutFinishPageLoadedEvent $event) {
  68.         $payerAddressId = $this->getPayerAddressId($event);
  69.         $this->appendPayerAddressToPage($event, $payerAddressId);
  70.     }
  71.     
  72.     public function onAccountOverviewPageLoadedEvent(AccountOverviewPageLoadedEvent $event) {
  73.         $payerAddressId = $this->getPayerAddressId($event);
  74.         $this->appendPayerAddressToPage($event, $payerAddressId);
  75.     }
  76.     
  77.     
  78.     
  79.     private function getPayerAddressId($event) {
  80.         $id = $event->getSalesChannelContext()->getCustomer()->getId();
  81.         
  82.         $dbCustomer = $this->customerRespository
  83.             ->search(new Criteria([$id]), $event->getContext())
  84.             ->first();
  85.         
  86.         $customFields = $dbCustomer->getCustomFields();
  87.         
  88.         if(isset($customFields['payerAddressId'])) {
  89.             return $customFields['payerAddressId'];
  90.         } 
  91.         return $event->getSalesChannelContext()->getCustomer()->getDefaultBillingAddressId();
  92.     }
  93.     
  94.     private function appendPayerAddressToPage($event, $payerAddressId) {
  95.         $payerAddressEntity = $this->customerAddressRespository
  96.             ->search(new Criteria([$payerAddressId]), $event->getContext())
  97.             ->first();
  98.         $event->getPage()->addExtension('payerAddress', $payerAddressEntity);
  99.     }
  100. }