custom/plugins/AcrisTaxCS/src/Storefront/Subscriber/VatIdValidationSubscriber.php line 128

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Acris\Tax\Storefront\Subscriber;
  5. use Acris\Tax\Components\Service\VatIdValidationService;
  6. use Acris\Tax\Core\Checkout\Customer\Validation\Constraint\CustomerVatId;
  7. use Shopware\Core\Checkout\Customer\Aggregate\CustomerAddress\CustomerAddressEntity;
  8. use Shopware\Core\Checkout\Customer\CustomerEntity;
  9. use Shopware\Core\Checkout\Customer\Event\CustomerRegisterEvent;
  10. use Shopware\Core\Checkout\Customer\Event\GuestCustomerRegisterEvent;
  11. use Shopware\Core\Framework\Validation\BuildValidationEvent;
  12. use Shopware\Core\Framework\Validation\DataBag\DataBag;
  13. use Shopware\Core\PlatformRequest;
  14. use Shopware\Core\System\Country\CountryEntity;
  15. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  16. use Shopware\Core\System\SystemConfig\SystemConfigService;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\HttpFoundation\RequestStack;
  20. class VatIdValidationSubscriber implements EventSubscriberInterface
  21. {
  22.     /**
  23.      * @var SystemConfigService
  24.      */
  25.     private $systemConfigService;
  27.     /**
  28.      * @var RequestStack
  29.      */
  30.     private $requestStack;
  32.     /**
  33.      * @var VatIdValidationService
  34.      */
  35.     private $vatIdValidationService;
  37.     /**
  38.      * @var array
  39.      */
  40.     private $vatIds;
  42.     /**
  43.      * @var bool
  44.      */
  45.     private $addressAllowed;
  47.     private int $count;
  49.     public function __construct(SystemConfigService $systemConfigService, RequestStack $requestStack, VatIdValidationService $vatIdValidationService)
  50.     {
  51.         $this->systemConfigService = $systemConfigService;
  52.         $this->requestStack = $requestStack;
  53.         $this->vatIdValidationService = $vatIdValidationService;
  54.         $this->vatIds = [];
  55.         $this->addressAllowed = false;
  56.         $this->count = 0;
  57.     }
  59.     public static function getSubscribedEvents(): array
  60.     {
  61.         return [
  62.             'framework.validation.customer.profile.update' => 'onValidateCustomerUpdate',
  63.             'framework.validation.customer.create' => 'onValidateCustomerCreate',
  64.             'framework.validation.address.create' => 'onValidateAddress',
  65.             'framework.validation.address.update' => 'onValidateAddress',
  66.             'framework.validation.order.update' => 'onValidateOrder',
  67.             'framework.validation.order.create' => 'onValidateOrder',
  68.             CustomerRegisterEvent::class => 'onCustomerRegister',
  69.             GuestCustomerRegisterEvent::class => 'onGuestCustomerRegister'
  70.         ];
  71.     }
  73.     public function onValidateCustomerUpdate(BuildValidationEvent $event): void
  74.     {
  75.         if(empty($this->requestStack) === true || empty($request = $this->requestStack->getCurrentRequest()) === true) {
  76.             return;
  77.         }
  78.         $salesChannelContext = $request->attributes->get(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_CONTEXT_OBJECT);
  79.         $salesChannelId = $request->attributes->get(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_ID);
  80.         if(!$salesChannelContext instanceof SalesChannelContext || empty($salesChannelId) === true || empty($request->get('vatIds')) === true || !is_array($request->get('vatIds'))) {
  81.             return;
  82.         }
  84.         $customer = $salesChannelContext->getCustomer();
  85.         if(!$customer instanceof CustomerEntity) {
  86.             return;
  87.         }
  89.         $billingAddress = $customer->getDefaultBillingAddress();
  90.         if (empty($billingAddress) === true) {
  91.             return;
  92.         }
  94.         $billingAddressArray = $this->convertAddress($billingAddress, $customer->getId(), $customer->getCompany(), $event->getData());
  96.         if (empty($billingAddressArray) === true || !array_key_exists('company', $billingAddressArray) || empty($billingAddressArray['company'])) {
  97.             return;
  98.         }
  100.         $this->vatIdValidationService->checkVatIdsForCustomer($request->get('vatIds'), $customer, $salesChannelContext);
  102.         $this->checkVatIdValidation($billingAddressArray, $event, $salesChannelId, $salesChannelContext, $request->get('vatIds'), 'customer-update', false, 'customerUpdate');
  103.     }
  105.     public function onValidateCustomerCreate(BuildValidationEvent $event): void
  106.     {
  107.         if(empty($this->requestStack) === true || empty($request = $this->requestStack->getCurrentRequest()) === true) {
  108.             return;
  109.         }
  110.         $salesChannelContext = $request->attributes->get(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_CONTEXT_OBJECT);
  111.         $salesChannelId = $request->attributes->get(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_ID);
  112.         if(!$salesChannelContext instanceof SalesChannelContext || empty($salesChannelId) === true || empty($request->get('vatIds')) === true || !is_array($request->get('vatIds'))) {
  113.             return;
  114.         }
  116.         $billingAddress = $request->get('billingAddress');
  117.         if (empty($billingAddress) === true) {
  118.             $billingAddress = $request->get('address');
  119.         }
  121.         if (empty($billingAddress) === true || !array_key_exists('company', $billingAddress) || empty($billingAddress['company'])) {
  122.             return;
  123.         }
  125.         $this->checkVatIdValidation($billingAddress, $event, $salesChannelId, $salesChannelContext, $request->get('vatIds'), 'customer-create', false, 'customerCreate');
  126.     }
  128.     public function onValidateAddress(BuildValidationEvent $event): void
  129.     {
  130.         $this->count++;
  131.         $currentAddress = 'billingAddress';
  132.         if(empty($this->requestStack) === true || empty($request = $this->requestStack->getCurrentRequest()) === true) {
  133.             return;
  134.         }
  135.         $salesChannelContext = $request->attributes->get(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_CONTEXT_OBJECT);
  136.         $salesChannelId = $request->attributes->get(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_ID);
  137.         if(!$salesChannelContext instanceof SalesChannelContext || empty($salesChannelId) === true) {
  138.             return;
  139.         }
  141.         //check address
  142.         $address = $request->get('shippingAddress');
  144.         if (!empty($address)) $currentAddress = 'shippingAddress';
  146.         if ($this->addressAllowed !== true) {
  147.             $this->addressAllowed = true;
  148.             if (!empty($address)) {
  149.                 return;
  150.             }
  151.         }
  153.         if (!empty($address)) {
  154.             if (!$request->request->has('differentShippingAddress') || boolval($request->request->get('differentShippingAddress')) !== true) {
  155.                 return;
  156.             }
  157.         }
  159.         if (empty($address) === true) {
  160.             $address = $request->get('address');
  161.         }
  163.         if (empty($address) === true || !array_key_exists('company', $address) || empty($address['company'])) {
  164.             return;
  165.         }
  167.         if (!empty($address) && array_key_exists('customFields', $address) && !empty($address['customFields'])) {
  168.             $customFields = $address['customFields'];
  170.             if (is_array($customFields) && array_key_exists('acris_address_vat_id', $customFields) && empty($customFields['acris_address_vat_id']) !== true) {
  171.                 $addressVatId = $customFields['acris_address_vat_id'];
  173.                 if (empty($addressVatId) || !is_string($addressVatId) || in_array($addressVatId, $this->vatIds)) return;
  174.                 $this->vatIds[] = $addressVatId;
  176.                 $this->checkVatIdValidation($address, $event, $salesChannelId, $salesChannelContext, [$addressVatId], 'address-save-or-update', false, $currentAddress);
  177.             }
  178.         }
  179.     }
  181.     public function onValidateOrder(BuildValidationEvent $event)
  182.     {
  183.         if(empty($this->requestStack) === true || empty($request = $this->requestStack->getCurrentRequest()) === true) {
  184.             return;
  185.         }
  186.         $salesChannelContext = $request->attributes->get(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_CONTEXT_OBJECT);
  187.         $salesChannelId = $request->attributes->get(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_ID);
  188.         if(!$salesChannelContext instanceof SalesChannelContext || empty($salesChannelId) === true) {
  189.             return;
  190.         }
  192.         if (!$this->systemConfigService->get('AcrisTaxCS.config.validateVatIDOnOrder', $salesChannelId)) {
  193.             return;
  194.         }
  196.         // validate personal data and billing address
  197.         if(empty($salesChannelContext->getCustomer()) !== true && !empty($salesChannelContext->getCustomer()->getDefaultBillingAddress())) {
  198.             $billingAddressVatId = !empty($salesChannelContext->getCustomer() && !empty($salesChannelContext->getCustomer()->getDefaultBillingAddress())) ? $this->getBillingAddressVatId($salesChannelContext->getCustomer()->getDefaultBillingAddress()) : null;
  199.             $billingAddressArray = $this->convertAddress($salesChannelContext->getCustomer()->getDefaultBillingAddress(), $salesChannelContext->getCustomer()->getId(), $salesChannelContext->getCustomer()->getCompany());
  201.             if (empty($billingAddressArray) !== true && array_key_exists('company', $billingAddressArray) && !empty($billingAddressArray['company'])) {
  202.                 if (!empty($salesChannelContext->getCustomer()->getVatIds()) && is_array($salesChannelContext->getCustomer()->getVatIds())) {
  203.                     $billingAddressArray['vatIdValidationEntry'] = 'personalData';
  204.                     $this->checkVatIdValidation($billingAddressArray, $event, $salesChannelId, $salesChannelContext, $salesChannelContext->getCustomer()->getVatIds(), 'order-save-or-update', true, 'orderAddress');
  205.                 }
  206.                 if (!empty($billingAddressVatId) && is_string($billingAddressVatId)) {
  207.                     $billingAddressArray['vatIdValidationEntry'] = 'billingAddress';
  208.                     if (array_key_exists('addressCompany', $billingAddressArray) && !empty($billingAddressArray['addressCompany'])) $billingAddressArray['company'] = $billingAddressArray['addressCompany'];
  209.                     $this->checkVatIdValidation($billingAddressArray, $event, $salesChannelId, $salesChannelContext, [$billingAddressVatId], 'order-save-or-update', true, 'orderAddress');
  210.                 }
  211.             }
  212.         }
  214.         // validate shipping address
  215.         if(empty($salesChannelContext->getCustomer()) !== true && !empty($salesChannelContext->getCustomer()->getDefaultShippingAddress())) {
  216.             $shippingAddressVatId = !empty($salesChannelContext->getCustomer() && !empty($salesChannelContext->getCustomer()->getDefaultShippingAddress())) ? $this->getBillingAddressVatId($salesChannelContext->getCustomer()->getDefaultShippingAddress()) : null;
  217.             $shippingAddressArray = $this->convertAddress($salesChannelContext->getCustomer()->getDefaultShippingAddress(), $salesChannelContext->getCustomer()->getId(), $salesChannelContext->getCustomer()->getCompany());
  219.             if (empty($shippingAddressArray) !== true && array_key_exists('company', $shippingAddressArray) && !empty($shippingAddressArray['company'])) {
  220.                 if (!empty($shippingAddressVatId) && is_string($shippingAddressVatId)) {
  221.                     $shippingAddressArray['vatIdValidationEntry'] = 'shippingAddress';
  222.                     if (array_key_exists('addressCompany', $shippingAddressArray) && !empty($shippingAddressArray['addressCompany'])) $shippingAddressArray['company'] = $shippingAddressArray['addressCompany'];
  223.                     $this->checkVatIdValidation($shippingAddressArray, $event, $salesChannelId, $salesChannelContext, [$shippingAddressVatId], 'order-save-or-update', true, 'orderAddress');
  224.                 }
  225.             }
  226.         }
  227.     }
  229.     public function onCustomerRegister(CustomerRegisterEvent $event): void
  230.     {
  231.         if (empty($event->getCustomerId())) return;
  233.         $this->vatIdValidationService->assignTheCustomerToLogEntity($event->getCustomer(), $event->getSalesChannelContext());
  234.     }
  236.     public function onGuestCustomerRegister(GuestCustomerRegisterEvent $event): void
  237.     {
  238.         if (empty($event->getCustomerId())) return;
  240.         $this->vatIdValidationService->assignTheCustomerToLogEntity($event->getCustomer(), $event->getSalesChannelContext());
  241.     }
  243.     private function convertAddress(CustomerAddressEntity $addressEntity, string $customerId, ?string $company, ?DataBag $dataBag = null): array
  244.     {
  245.         $addressData = [
  246.             'customerId' => $customerId,
  247.             'street' => $addressEntity->getStreet(),
  248.             'city' => $addressEntity->getCity(),
  249.             'zipcode' => $addressEntity->getZipcode(),
  250.             'countryId' => $addressEntity->getCountryId()
  251.         ];
  253.         if (!empty($addressEntity->getCompany())) $addressData['addressCompany'] = $addressEntity->getCompany();
  255.         if (!empty($company)) {
  256.             if (array_key_exists('addressCompany', $addressData) && !empty($addressData['addressCompany'])) {
  257.                 $addressData['company'] = $company;
  258.             }
  259.         }
  261.         if (!empty($dataBag) && !empty($dataBag->get('company'))) {
  262.             $addressData['company'] = $dataBag->get('company');
  263.         }
  265.         return $addressData;
  266.     }
  268.     private function validateVatIds($vatIds, array $billingAddress, BuildValidationEvent $event, SalesChannelContext $salesChannelContext, ?CountryEntity $country, string $cause, bool $checkOrder, string $currentAddress)
  269.     {
  270.         if(empty($vatIds)) {
  271.             return;
  272.         }
  274.         foreach ($vatIds as $vatId) {
  275.             if(empty($vatId)) {
  276.                 continue;
  277.             }
  279.             $options = [
  280.                 'address' => $billingAddress,
  281.                 'vatId' => $vatId,
  282.                 'context' => $event->getContext(),
  283.                 'salesChannelContext' => $salesChannelContext,
  284.                 'country' => $country,
  285.                 'cause' => $cause,
  286.                 'isCheckOrder' => $checkOrder,
  287.                 'currentAddress' => $currentAddress
  288.             ];
  289.             $properties = $event->getDefinition()->getProperties();
  291.             if (!array_key_exists('vatIds', $properties) || $cause = 'customer-update') {
  292.                 $event->getDefinition()->add('vatIds', new CustomerVatId($options));
  293.             }
  294.         }
  295.     }
  297.     private function checkVatIdValidation(array $address, $event, string $salesChannelId, SalesChannelContext $salesChannelContext, ?array $vatIds, string $cause, bool $checkOrder, string $currentAddress): void
  298.     {
  299.         if (empty($vatIds)) return;
  301.         $countryId = array_key_exists('countryId', $address) && !empty($address['countryId']) ? $address['countryId'] : null;
  303.         if (empty($countryId)) return;
  305.         $country = $this->vatIdValidationService->getCountry($countryId, $event->getContext());
  307.         $vatIdFormatValidation = $this->systemConfigService->get('AcrisTaxCS.config.validateVatIDFormatAllEUCountries', $salesChannelId);
  308.         $vatIdApiServiceValidation = $this->systemConfigService->get('AcrisTaxCS.config.VatIDAPIValidationAllEUCountries', $salesChannelId);
  310.         if ((!empty($vatIdFormatValidation) && ($vatIdFormatValidation === VatIdValidationService::DEFAULT_ENABLE_FORMAT_VAT_ID_ALL_EU_COUNTRIES || ($vatIdFormatValidation === VatIdValidationService::DEFAULT_OPTION_STANDARD && $this->vatIdValidationService->checkCountryFormatValidation($country))))
  311.             || (!empty($vatIdApiServiceValidation) && (($vatIdApiServiceValidation === VatIdValidationService::DEFAULT_ENABLE_VAT_ID_VALIDATION_API_SERVICE_ALL_EU_COUNTRIES || $vatIdApiServiceValidation === VatIdValidationService::DEFAULT_ENABLE_VAT_ID_COMPANY_VALIDATION_API_SERVICE_ALL_EU_COUNTRIES
  312.                         || $vatIdApiServiceValidation === VatIdValidationService::DEFAULT_ENABLE_VAT_ID_ADDRESS_VALIDATION_API_SERVICE_ALL_EU_COUNTRIES || $vatIdApiServiceValidation === VatIdValidationService::DEFAULT_ENABLE_VAT_ID_COMPANY_ADDRESS_VALIDATION_API_SERVICE_ALL_EU_COUNTRIES)
  313.                     || ($vatIdApiServiceValidation === VatIdValidationService::DEFAULT_OPTION_STANDARD && $this->vatIdValidationService->checkCountryVatIdValidationApiService($country))))) {
  314.             $this->validateVatIds($vatIds, $address, $event, $salesChannelContext, $country, $cause, $checkOrder, $currentAddress);
  315.         }
  316.     }
  318.     private function getBillingAddressVatId(CustomerAddressEntity $address): ?string
  319.     {
  320.         if (empty($address->getCustomFields()) || !is_array($address->getCustomFields()) || !array_key_exists('acris_address_vat_id', $address->getCustomFields()) || empty($address->getCustomFields()['acris_address_vat_id'])) return null;
  322.         return $address->getCustomFields()['acris_address_vat_id'];
  323.     }
  324. }