custom/plugins/CioBudget/src/Subscriber/CustomerGroupsLoadedSubscriber.php line 35

Open in your IDE?
  1. <?php
  3. namespace CioBudget\Subscriber;
  5. use CioBudget\Service\BudgetLoaderService;
  6. use CioBudget\Service\SessionService;
  7. use CioCustomerPermissionGroups\Event\CustomerGroupsLoadedEvent;
  8. use Shopware\Core\Checkout\Customer\Event\CustomerLoginEvent;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class CustomerGroupsLoadedSubscriber implements EventSubscriberInterface
  13. {
  15.     private SessionService $sessionService;
  16.     private EntityRepositoryInterface $customerRepository;
  17.     private BudgetLoaderService $budgetLoaderService;
  19.     public function __construct(EntityRepositoryInterface $customerRepository,
  20.                                 SessionService $sessionService,
  21.                                 BudgetLoaderService $budgetLoaderService)
  22.     {
  23.         $this->budgetLoaderService = $budgetLoaderService;
  24.         $this->sessionService = $sessionService;
  25.         $this->customerRepository = $customerRepository;
  26.     }
  28.     public static function getSubscribedEvents(): array
  29.     {
  30.         return [
  31.             CustomerGroupsLoadedEvent::class => 'onCustomerGroupsLoadedEvent'
  32.         ];
  33.     }
  35.     public function onCustomerGroupsLoadedEvent(CustomerGroupsLoadedEvent $event)
  36.     {
  37.         $groups = $event->getGroups();
  38.         $currentBudgetId = $this->sessionService->getCurrentBudgetId();
  40.         if (is_array($event->getCustomer()->getCustomFields()) && key_exists('cio_stores', $event->getCustomer()->getCustomFields()) && is_array($event->getCustomer()->getCustomFields()['cio_stores'])) {
  42.             $currentBudget = null;
  44.             // find current budget in all budgets of the customer
  45.             foreach ($event->getCustomer()->getCustomFields()['cio_stores'] as $customerStore) {
  47.                 if (is_array($customerStore) && key_exists('id', $customerStore)) {
  48.                     $storeBudgetId = $this->budgetLoaderService->getBudgetIdByStoreId($customerStore['id']);
  50.                     if ($storeBudgetId == $currentBudgetId) {
  51.                         // store data with ACL becomes budget data
  52.                         $currentBudget = $customerStore;
  53.                         $currentBudget['id'] = $storeBudgetId;
  55.                         break;
  56.                     }
  57.                 }
  58.             }
  60.             // iterate over all aclgroups of the current selected budget of the customer
  61.             if ($currentBudget && $currentBudget['aclgroup']) {
  62.                 if (is_array($currentBudget['aclgroup'])) {
  63.                     foreach ($currentBudget['aclgroup'] as $aclgroup) {
  64.                         $groups[] = $aclgroup;
  65.                     }
  66.                 }
  67.             }
  68.         }
  70.         $event->setGroups($groups);
  71.     }
  72. }