custom/plugins/CioBudget/src/Subscriber/FilterCustomerEntityBudgetsSubscriber.php line 39

Open in your IDE?
  1. <?php
  4. namespace CioBudget\Subscriber;
  6. use CioBudget\Definition\Budget\BudgetEntity;
  7. use CioBudget\Service\BudgetLoaderService;
  8. use Shopware\Core\Checkout\Customer\CustomerEntity;
  9. use Shopware\Core\Checkout\Customer\CustomerEvents;
  10. use Shopware\Core\Framework\Api\Context\SalesChannelApiSource;
  11. use Shopware\Core\Framework\Context;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\RangeFilter;
  15. use Symfony\Component\DependencyInjection\Container;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. class FilterCustomerEntityBudgetsSubscriber implements EventSubscriberInterface
  19. {
  20.     private BudgetLoaderService $budgetLoaderService;
  21.     private Container $container;
  23.     public function __construct(
  24.         Container $container,
  25.         BudgetLoaderService $budgetLoaderService
  26.     )
  27.     {
  28.         $this->budgetLoaderService = $budgetLoaderService;
  29.         $this->container = $container;
  30.     }
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             CustomerEvents::CUSTOMER_LOADED_EVENT => 'onLoaded'
  36.         ];
  37.     }
  39.     public function onLoaded(EntityLoadedEvent $event)
  40.     {
  41.         /** @var BudgetLoaderService $budgetLoaderService */
  43.         if ($event->getContext()->getScope() !== 'user' || !($event->getContext()->getSource() instanceof SalesChannelApiSource)) {
  44.             return;
  45.         }
  47.         /** @var CustomerEntity $customer */
  48.         $customers = $event->getEntities();
  50.         foreach ($customers as $customer) {
  51.             $customFields = $customer->getCustomFields();
  52.             $customerBudgets = $this->budgetLoaderService->getActiveBudgetsByCustomer($customer, $event->getContext());
  54.             if ($customerBudgets) {
  55.                 $customFields['cio_active_budgets'] = array_map(function ($customerBudget) {
  56.                     return $customerBudget->getId();
  57.                 }, $customerBudgets->getElements());
  58.             }
  59.             $customer->setCustomFields($customFields);
  60.         }
  61.     }
  63. }