Symfony Profiler

<?php
/**
* @copyright Copyright (c) 2020, Net Inventors GmbH
* @category Shopware
* @author malte
*/
namespace NetInventors\NetiNextAccessManager\Subscriber;
use NetInventors\NetiNextAccessManager\Constants\ConfigConstants;
use NetInventors\NetiNextAccessManager\Events\BusinessEvent\CustomerActivateEvent;
use NetInventors\NetiNextAccessManager\Events\BusinessEvent\CustomerDeactivateEvent;
use NetInventors\NetiNextAccessManager\Extension\Content\Customer\Aggregate\CustomerAttribute\CustomerAttributeEntity;
use NetInventors\NetiNextAccessManager\Service\CustomerService;
use NetInventors\NetiNextAccessManager\Service\PluginConfig;
use Shopware\Core\Checkout\Customer\CustomerEntity;
use Shopware\Core\Framework\Context;
use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
use Shopware\Core\PlatformRequest;
use Shopware\Core\System\SystemConfig\SystemConfigService;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Shopware\Core\Checkout\Customer\CustomerEvents;
use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
use Symfony\Component\HttpFoundation\RequestStack;
use Symfony\Component\HttpKernel\Event\RequestEvent;
use Symfony\Component\HttpKernel\KernelEvents;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;
class Customer implements EventSubscriberInterface
{
/**
* @var bool
*/
private $isFirstActivation = false;
/**
* @var RequestStack
*/
private $requestStack;
/**
* @var EntityRepositoryInterface
*/
private $customerRepository;
/**
* @var PluginConfig
*/
private $pluginConfig;
/**
* @var CustomerService
*/
private $customerService;
/**
* @var EventDispatcherInterface
*/
private $eventDispatcher;
/**
* Customer constructor.
*
* @param RequestStack $requestStack
* @param EntityRepositoryInterface $customerRepository
* @param PluginConfig $pluginConfig
* @param CustomerService $customerService
* @param EventDispatcherInterface $eventDispatcher
*/
public function __construct(
RequestStack $requestStack,
EntityRepositoryInterface $customerRepository,
PluginConfig $pluginConfig,
CustomerService $customerService,
EventDispatcherInterface $eventDispatcher
) {
$this->requestStack = $requestStack;
$this->customerRepository = $customerRepository;
$this->pluginConfig = $pluginConfig;
$this->customerService = $customerService;
$this->eventDispatcher = $eventDispatcher;
}
public static function getSubscribedEvents(): array
{
return [
CustomerEvents::CUSTOMER_WRITTEN_EVENT => 'onCustomerWritten',
KernelEvents::REQUEST => 'onKernelRequest',
CustomerEvents::CUSTOMER_LOADED_EVENT => 'onCustomerLoaded',
];
}
public function onCustomerLoaded(EntityLoadedEvent $event): void
{
$entities = $event->getEntities();
/** @var CustomerEntity $entity */
foreach ($entities as $entity) {
if (null === $entity->getExtension('netiAccessManagerCustomerAttribute')) {
$this->customerService->setActiveAttribute($entity->getId(), true, $event->getContext());
}
}
}
public function onCustomerWritten(EntityWrittenEvent $event): void
{
$masterRequest = $this->requestStack->getMasterRequest();
if (null === $masterRequest) {
return;
}
$attribute = $masterRequest->get('netiAccessManagerCustomerAttribute');
if (!
(
\is_array($attribute)
&& isset($attribute['activated'])
)
) {
return;
}
$customerId = $attribute['id'];
$customer = $this->customerRepository->search(new Criteria([ $customerId ]), $event->getContext())->first();
if (!$customer instanceof CustomerEntity) {
return;
}
$pluginConfig = $this->pluginConfig->loadConfigOfSalesChannel($customer->getSalesChannelId());
if (!$pluginConfig->isActive()) {
return;
}
$isMailSendingOnChangeActivation =
$pluginConfig->getStatusChangeNotification() === ConfigConstants::STATUS_CHANGE_NOTIFICATION_CHANGE;
$context = $event->getContext();
$customer = $this->customerService->getCustomerWithSalutation($customerId, $context);
if (!$customer instanceof CustomerEntity) {
throw new \RuntimeException('Customer was not found by id '. $customerId);
}
$customerContext = new Context(
$context->getSource(),
$context->getRuleIds(),
$context->getCurrencyId(),
[ $customer->getLanguageId() ]
);
if (
$attribute['activated']
&& (
$this->isFirstActivation
|| $isMailSendingOnChangeActivation
)
) {
$this->eventDispatcher->dispatch(new CustomerActivateEvent($customerContext, $customer));
} elseif ($attribute['activated'] === false && $isMailSendingOnChangeActivation) {
$this->eventDispatcher->dispatch(new CustomerDeactivateEvent($customerContext, $customer));
}
}
/**
* @param RequestEvent $event
*/
public function onKernelRequest(RequestEvent $event): void
{
$attribute = $event->getRequest()->get('netiAccessManagerCustomerAttribute');
if (
!(
\is_array($attribute)
&& isset($attribute['activated'])
&& $this->pluginConfig->isActive()
)
) {
return;
}
/** @var CustomerEntity $customer */
$customer = $this->customerRepository->search(new Criteria([$attribute['id']]), Context::createDefaultContext())->first();
if (!
(
$customer instanceof CustomerEntity
&& $customer->hasExtension('netiAccessManagerCustomerAttribute')
)
) {
return;
}
/** @var CustomerAttributeEntity $extension */
$extension = $customer->getExtension('netiAccessManagerCustomerAttribute');
$this->isFirstActivation = (CustomerAttributeEntity::ACTIVATED_BY_SYSTEM === $extension->getActivatedBy());
}
}

custom/plugins/NetiNextAccessManager/src/Subscriber/Customer.php line 107