custom/plugins/AbasBecoCustomizations/src/Subscribers/Customer/CustomerLoginSubscriber.php line 66

Open in your IDE?
  1. <?php
  3. namespace AbasBecoCustomizations\Subscribers\Customer;
  5. use Abas\AbasConnector\Service\RestApi\Client\AbasRestApiClient;
  6. use Abas\AbasConnector\Service\RestApi\Request\Factories\DataRequestFactory;
  7. use Abas\AbasConnector\Service\RestApi\Response\Content\ErpDataObject;
  8. use Cassandra\Exception\RuntimeException;
  9. use PHPUnit\TextUI\Exception;
  10. use Shopware\Core\Checkout\Customer\CustomerEvents;
  11. use Shopware\Core\Checkout\Customer\Event\CustomerLoginEvent;
  12. use Shopware\Core\Checkout\Customer\Event\CustomerLogoutEvent;
  13. use Shopware\Core\Framework\Context;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Entity;
  15. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Pricing\CashRoundingConfig;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  19. use Shopware\Core\Framework\Routing\Event\SalesChannelContextResolvedEvent;
  20. use Shopware\Core\Framework\Validation\DataBag\DataBag;
  21. use Shopware\Core\System\SalesChannel\SalesChannel\SalesChannelContextSwitcher;
  22. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  23. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  25. class CustomerLoginSubscriber implements EventSubscriberInterface
  26. {
  28.     /**
  29.      * @var EntityRepositoryInterface
  30.      */
  31.     private $currencyRepository;
  32.     /**
  33.      * @var EntityRepositoryInterface
  34.      */
  35.     private $customerRepository;
  36.     /**
  37.      * @var SalesChannelContextSwitcher
  38.      */
  39.     private $contextSwitcher;
  40.     /**
  41.      * @var AbasRestApiClient
  42.      */
  43.     private $apiClient;
  45.     public function __construct(
  46.         EntityRepositoryInterface $currencyRepository,
  47.         EntityRepositoryInterface $customerRepository,
  48.         SalesChannelContextSwitcher $contextSwitcher,
  49.         AbasRestApiClient $apiClient
  50.     ) {
  51.         $this->currencyRepository = $currencyRepository;
  52.         $this->customerRepository = $customerRepository;
  53.         $this->contextSwitcher = $contextSwitcher;
  54.         $this->apiClient = $apiClient;
  55.     }
  57.     public static function getSubscribedEvents()
  58.     {
  59.         return [
  60.             CustomerLoginEvent::class => 'setCurrency',
  61.             CustomerLogoutEvent::class => 'resetCurrency'
  62.         ];
  63.     }
  66.     public function setCurrency(CustomerLoginEvent $event)
  67.     {
  68.         $customFields = $event->getCustomer()->getCustomFields();
  69.         if($customFields && array_key_exists('abas_database_and_group', $customFields) && $customFields['abas_database_and_group'] === "0:1"){
  70.             $request = DataRequestFactory::createGetRequest('0:1', $this->getCustSelectionIdentifier($event->getCustomer()), 'waehr^iso3a');
  71.             $response = $this->apiClient->executeRequest($request);
  72.             $iso = $response->getObject(0)->getFieldValue("waehr^iso3a");
  73.             $this->setCurrencyInContext($iso, $event->getContext(), $event->getSalesChannelContext());
  75.         }
  76.     }
  78.     public function resetCurrency(CustomerLogoutEvent $event)
  79.     {
  80.         $this->setCurrencyInContext("EUR", $event->getContext(), $event->getSalesChannelContext());
  81.     }
  83.     private function setCurrencyInContext(string $iso, Context $context, SalesChannelContext $salesChannelContext)
  84.     {
  85.         $params=[];
  86.         try{
  87.             $newCurrencyId = $this->currencyRepository->search((new Criteria())->addFilter(new EqualsFilter("isoCode", $iso)), $context)->first()->getId();
  88.             if($newCurrencyId !== $salesChannelContext->getCurrencyId()) {
  89.                 $params["currencyId"] = $newCurrencyId;
  90.             }
  91.             $rounding = new CashRoundingConfig(3, 0.001, true);
  92.             $params['itemRoundings'] = $rounding;
  93.             $params['roundings'] = $rounding;
  95.             $data = new DataBag($params);
  96.             $this->contextSwitcher->update($data, $salesChannelContext);
  97.             //Just to be sure
  98.             $salesChannelContext->getContext()->setRounding($rounding);
  99.             $salesChannelContext->setItemRounding($rounding);
  100.         }catch (Exception $e){
  101.             // Propably ISO is not in SW
  102.         }
  103.     }
  105.     /**
  106.      * Return the abas identifier value (GUID or ID)
  107.      * @param Entity $entity
  108.      * @return string|null
  109.      */
  110.     protected function getCustSelectionIdentifier(Entity $entity)
  111.     {
  112.         $guid = $this->getCustomFieldValue($entity, 'abas_guid');
  113.         if ($guid) {
  114.             return 'guid==' . $guid;
  115.         }
  116.         return 'id==' . $this->getCustomFieldValue($entity, 'abas_id');
  117.     }
  119.     /**
  120.      * Get a customFields value
  121.      * @param Entity $entity
  122.      * @param string $key
  123.      * @return string|null
  124.      */
  125.     protected function getCustomFieldValue(Entity $entity, string $key): ?string
  126.     {
  127.         if ($entity->has('customFields')) {
  128.             $customFields = $entity->get('customFields');
  129.             if ($customFields && isset($customFields[$key])) {
  130.                 return $customFields[$key];
  131.             }
  132.         }
  133.         return null;
  134.     }
  136. }