Symfony Profiler

<?php declare(strict_types=1);
namespace Cbax\ModulAnalytics\Subscriber;
use Shopware\Core\Framework\Uuid\Uuid;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Shopware\Core\Content\Product\Events\ProductSearchResultEvent;
use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
use Shopware\Storefront\Pagelet\Header\HeaderPageletLoadedEvent;
use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
use Shopware\Core\System\SystemConfig\SystemConfigService;
use Shopware\Core\Defaults;
use Shopware\Core\Checkout\Order\OrderDefinition;
use Shopware\Core\Checkout\Order\OrderEvents;
use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
use Doctrine\DBAL\Connection;
use Shopware\Core\Content\Category\Event\NavigationLoadedEvent;
class BackendSubscriber implements EventSubscriberInterface
{
const MODUL_NAME = 'CbaxModulAnalytics';
/**
* @var SystemConfigService
*/
private $systemConfigService;
/**
* @var
*/
private $config = null;
/**
* @var EntityRepositoryInterface
*/
private $searchRepository;
/**
* @var EntityRepositoryInterface
*/
private $orderRepository;
/**
* @var EntityRepositoryInterface
*/
private $poolRepository;
/**
* @var Connection
*/
private $connection;
const DEFAULT_DEVICES = [
'desktop',
'tablet',
'mobile'
];
public function __construct(
SystemConfigService $systemConfigService,
EntityRepositoryInterface $searchRepository,
EntityRepositoryInterface $orderRepository,
EntityRepositoryInterface $poolRepository,
Connection $connection
)
{
$this->systemConfigService = $systemConfigService;
$this->orderRepository = $orderRepository;
$this->searchRepository = $searchRepository;
$this->poolRepository = $poolRepository;
$this->connection = $connection;
}
public static function getSubscribedEvents(): array
{
return[
ProductSearchResultEvent::class => 'onProductSearch',
OrderEvents::ORDER_WRITTEN_EVENT => 'onOrderWritten',
ProductPageLoadedEvent::class => 'onProductPageLoaded',
HeaderPageletLoadedEvent::class => 'onHeaderPageletLoaded',
NavigationLoadedEvent::class => 'onNavigationLoaded'
];
}
public function getDomainString($url) {
if (empty($url)) {
return '';
}
$domainStr = str_replace(['http://', 'https://', 'www.'], '', $url);
$domainArr = explode('/', $domainStr);
return $domainArr[0];
}
public function onHeaderPageletLoaded(HeaderPageletLoadedEvent $event)
{
$salesChannelId = $event->getSalesChannelContext()->getSalesChannelID();
$this->config = $this->config ?? ($this->systemConfigService->get(self::MODUL_NAME . '.config', $salesChannelId) ?? []);
if (empty($this->config['recordVisitors'])) return;
if (empty($_SERVER)) return;
if (empty($_SERVER['HTTP_USER_AGENT'])) return;
$request = $event->getRequest();
$referer = $this->getDomainString($request->headers->get('referer'));
$host = $this->getDomainString($request->getHttpHost());
$context = $event->getContext();
$salesChannelIdBytes = Uuid::fromHexToBytes($salesChannelId);
$httpUserAgent = $_SERVER['HTTP_USER_AGENT'];
$deviceType = $this->getDeviceType($httpUserAgent);
//$userOS = $this->getOS($httpUserAgent);
//$userBrowser = $this->getBrowser($httpUserAgent);
$visitorHash = hash('md5', $request->getClientIp() . $httpUserAgent);
$date = (new \DateTimeImmutable())->format('Y-m-d');
$isNewVisitor = false;
$createdAt = (new \DateTimeImmutable())->format(Defaults::STORAGE_DATE_TIME_FORMAT);
/*
* Criteria für cbax_analytics_pool
*/
$poolCriteria = new Criteria();
$poolCriteria
->addFilter(new EqualsFilter('date', $date))
->addFilter(new EqualsFilter('remoteAddress', $visitorHash))
->addFilter(new EqualsFilter('salesChannelId', $salesChannelId));
$poolResult = $this->poolRepository->search($poolCriteria, $context)->first();
if (empty($poolResult)) {
$isNewVisitor = true;
$randomId = Uuid::randomBytes();
$this->connection->executeUpdate('
INSERT IGNORE INTO `cbax_analytics_pool`
(`id`, `date`, `remote_address`, `sales_channel_id`, `created_at`)
VALUES
(:id, :date, :remote_address, :sales_channel_id, :created_at);',
[
'id' => $randomId,
'date' => $date,
'remote_address' => $visitorHash,
'sales_channel_id' => $salesChannelIdBytes,
'created_at' => $createdAt
]
);
}
if ($isNewVisitor)
{
$randomId = Uuid::randomBytes();
$this->connection->executeUpdate('
INSERT INTO `cbax_analytics_visitors`
(`id`, `sales_channel_id`, `date`,`page_impressions`, `unique_visits`, `device_type`, `created_at`)
VALUES
(:id, :sales_channel_id, :date, :page_impressions, :unique_visits, :device_type, :created_at)
ON DUPLICATE KEY UPDATE page_impressions=page_impressions+1, unique_visits=unique_visits+1;',
[
'id' => $randomId,
'sales_channel_id' => $salesChannelIdBytes,
'date' => $date,
'page_impressions' => 1,
'unique_visits' => 1,
'device_type' => $deviceType,
'created_at' => $createdAt
]
);
} else {
$this->connection->executeUpdate('
UPDATE `cbax_analytics_visitors` SET page_impressions=page_impressions+1
WHERE `sales_channel_id`=? AND `date`=? AND `device_type`=?;',
[$salesChannelIdBytes, $date, $deviceType]
);
}
if (!empty($referer) && $referer != $host)
{
$randomId = Uuid::randomBytes();
$this->connection->executeUpdate('
INSERT INTO `cbax_analytics_referer`
(`id`, `date`,`referer`, `sales_channel_id`, `counted`, `device_type`, `created_at`)
VALUES
(:id, :date, :referer, :sales_channel_id, :counted, :device_type, :created_at)
ON DUPLICATE KEY UPDATE counted=counted+1;',
[
'id' => $randomId,
'date' => $date,
'referer' => $referer,
'sales_channel_id' => $salesChannelIdBytes,
'counted' => 1,
'device_type' => $deviceType,
'created_at' => $createdAt
]
);
}
}
public function onNavigationLoaded(NavigationLoadedEvent $event)
{
$salesChannelId = $event->getSalesChannelContext()->getSalesChannelID();
$this->config = $this->config ?? ($this->systemConfigService->get(self::MODUL_NAME . '.config', $salesChannelId) ?? []);
if (empty($this->config['recordVisitors'])) return;
$category = $event->getNavigation()->getActive();
$salesChannelIdBytes = Uuid::fromHexToBytes($salesChannelId);
$categoryId = $category->getId();
$date = (new \DateTime())->format(Defaults::STORAGE_DATE_FORMAT);
if (empty($_SERVER)) return;
if (empty($_SERVER['HTTP_USER_AGENT'])) return;
$httpUserAgent = $_SERVER['HTTP_USER_AGENT'];
$deviceType = $this->getDeviceType($httpUserAgent);
$createdAt = (new \DateTimeImmutable())->format(Defaults::STORAGE_DATE_TIME_FORMAT);
$randomId = Uuid::randomBytes();
$this->connection->executeUpdate('
INSERT INTO `cbax_analytics_category_impressions`
(`id`, `category_id`, `sales_channel_id`, `date`, `impressions`, `device_type`, `created_at`)
VALUES
(:id, :category_id, :sales_channel_id, :date, :impressions, :device_type, :created_at)
ON DUPLICATE KEY UPDATE impressions=impressions+1;',
[
'id' => $randomId,
'category_id' => Uuid::fromHexToBytes($categoryId),
'sales_channel_id' => $salesChannelIdBytes,
'date' => $date,
'impressions' => 1,
'device_type' => $deviceType,
'created_at' => $createdAt
]
);
}
public function onProductPageLoaded(ProductPageLoadedEvent $event)
{
$salesChannelId = $event->getSalesChannelContext()->getSalesChannelID();
$this->config = $this->config ?? ($this->systemConfigService->get(self::MODUL_NAME . '.config', $salesChannelId) ?? []);
if (empty($this->config['recordVisitors'])) return;
$page = $event->getPage();
$salesChannelIdBytes = Uuid::fromHexToBytes($salesChannelId);
$productId = $page->getProduct()->getId();
$date = (new \DateTime())->format(Defaults::STORAGE_DATE_FORMAT);
if (empty($_SERVER)) return;
if (empty($_SERVER['HTTP_USER_AGENT'])) return;
$httpUserAgent = $_SERVER['HTTP_USER_AGENT'];
$deviceType = $this->getDeviceType($httpUserAgent);
$createdAt = (new \DateTimeImmutable())->format(Defaults::STORAGE_DATE_TIME_FORMAT);
$randomId = Uuid::randomBytes();
$this->connection->executeUpdate('
INSERT INTO `cbax_analytics_product_impressions`
(`id`, `product_id`, `sales_channel_id`, `date`, `impressions`, `device_type`, `created_at`)
VALUES
(:id, :product_id, :sales_channel_id, :date, :impressions, :device_type, :created_at)
ON DUPLICATE KEY UPDATE impressions=impressions+1;',
[
'id' => $randomId,
'product_id' => Uuid::fromHexToBytes($productId),
'sales_channel_id' => $salesChannelIdBytes,
'date' => $date,
'impressions' => 1,
'device_type' => $deviceType,
'created_at' => $createdAt
]
);
$manufacturer = $page->getProduct()->getManufacturer();
if (empty($manufacturer)) return;
$manufacturerId = $manufacturer->getId();
$randomId = Uuid::randomBytes();
$this->connection->executeUpdate('
INSERT INTO `cbax_analytics_manufacturer_impressions`
(`id`, `manufacturer_id`, `sales_channel_id`, `date`, `impressions`, `device_type`, `created_at`)
VALUES
(:id, :manufacturer_id, :sales_channel_id, :date, :impressions, :device_type, :created_at)
ON DUPLICATE KEY UPDATE impressions=impressions+1;',
[
'id' => $randomId,
'manufacturer_id' => Uuid::fromHexToBytes($manufacturerId),
'sales_channel_id' => $salesChannelIdBytes,
'date' => $date,
'impressions' => 1,
'device_type' => $deviceType,
'created_at' => $createdAt
]
);
}
public function onOrderWritten(EntityWrittenEvent $event)
{
$this->config = $this->config ?? ($this->systemConfigService->get(self::MODUL_NAME . '.config') ?? []);
if (empty($this->config['recordAdditionalOrderData'])) return;
if (empty($_SERVER)) return;
if (empty($_SERVER['HTTP_USER_AGENT'])) return;
if ($event->getEntityName() !== OrderDefinition::ENTITY_NAME) return;
$httpUserAgent = $_SERVER['HTTP_USER_AGENT'];
$context = $event->getContext();
foreach ($event->getWriteResults() as $writeResult) {
if ($writeResult->getExistence() !== null && $writeResult->getExistence()->exists()) continue;
if ($writeResult->getOperation() !== 'insert') continue;
$payload = $writeResult->getPayload();
if (empty($payload)) continue;
$customFields = !empty($payload['customFields']) ? $payload['customFields'] : [];
if (empty($payload['versionId'])) continue;
if ($payload['versionId'] !== Defaults::LIVE_VERSION) continue;
if (!empty($customFields) && !empty($customFields['cbaxExternalOrderOrdernumber'])) continue;
$customFields['cbaxStatistics'] = [
'device' => $this->getDeviceType($httpUserAgent),
'os' => $this->getOS($httpUserAgent),
'browser' => $this->getBrowser($httpUserAgent)
];
$data = [
[
'id' => $payload['id'],
'customFields' => $customFields
]
];
$this->orderRepository->update($data, $context);
}
}
public function onProductSearch(ProductSearchResultEvent $event)
{
$salesChannelId = $event->getSalesChannelContext()->getSalesChannel()->getId();
$this->config = $this->config ?? ($this->systemConfigService->get(self::MODUL_NAME . '.config', $salesChannelId) ?? []);
if (empty($this->config['recordSearch'])) return;
$requestUri = $event->getRequest()->attributes->get('sw-original-request-uri');
if (empty($requestUri)) return;
if (str_starts_with($requestUri, '/widgets')) return;
$searchUriArray = explode('=', $requestUri);
$searchTerm = count($searchUriArray) > 1 ? strtolower(urldecode ($searchUriArray[1])) : '';
if (empty($searchTerm)) return;
$results = $event->getResult()->getTotal();
$context = $event->getContext();
$this->searchRepository->create([
[
'searchTerm' => $searchTerm,
'results' => $results,
'salesChannelId' => $salesChannelId
]
], $context);
}
private function getDeviceType($httpUserAgent)
{
$httpUserAgent = (string)$httpUserAgent;
if (!empty($_COOKIE) && !empty($_COOKIE['x-ua-device']))
{
$deviceType = strtolower($_COOKIE['x-ua-device']);
if (in_array($deviceType, self::DEFAULT_DEVICES))
{
return $deviceType;
}
}
$os = $this->getOS($httpUserAgent);
$mobileOS = ['Windows Phone 10','Windows Phone 8.1','Windows Phone 8','BlackBerry','Mobile'];
$tabletOS = ['Android','iOS'];
if (preg_match('/mobile|phone|ipod/i', $httpUserAgent) || in_array($os, $mobileOS))
{
return 'mobile';
}
if (preg_match('/tablet|ipad/i', $httpUserAgent) || in_array($os, $tabletOS))
{
return 'tablet';
}
return 'desktop';
}
private function getOS($httpUserAgent)
{
$httpUserAgent = (string)$httpUserAgent;
foreach (self::OS as $key => $value) {
if (preg_match($key, $httpUserAgent)) {
return $value;
}
}
return 'Not Detected';
}
private function getBrowser($httpUserAgent)
{
$httpUserAgent = (string)$httpUserAgent;
foreach (self::BROWSER as $key => $value) {
if (preg_match($key, $httpUserAgent)) {
return $value;
}
}
return 'Not Detected';
}
const OS = [
'/windows nt 11/i' => 'Windows 11',
'/windows nt 10/i' => 'Windows 10',
'/windows phone 10/i' => 'Windows Phone 10',
'/windows phone 8.1/i' => 'Windows Phone 8.1',
'/windows phone 8/i' => 'Windows Phone 8',
'/windows nt 6.3/i' => 'Windows 8.1',
'/windows nt 6.2/i' => 'Windows 8',
'/windows nt 6.1/i' => 'Windows 7',
'/windows nt 6.0/i' => 'Windows Vista',
'/windows nt 5.2/i' => 'Windows Server 2003/XP x64',
'/windows nt 5.1/i' => 'Windows XP',
'/windows xp/i' => 'Windows XP',
'/windows nt 5.0/i' => 'Windows 2000',
'/windows me/i' => 'Windows ME',
'/win98/i' => 'Windows 98',
'/win95/i' => 'Windows 95',
'/win16/i' => 'Windows 3.11',
'/macintosh|mac os x/i' => 'Mac OS X',
'/mac_powerpc/i' => 'Mac OS 9',
'/iphone/i' => 'iOS',
'/ipod/i' => 'iOS',
'/ipad/i' => 'iOS',
'/android/i' => 'Android',
'/linux/i' => 'Linux',
'/ubuntu/i' => 'Ubuntu',
'/blackberry/i' => 'BlackBerry',
'/webos/i' => 'Mobile'
];
const BROWSER = [
'/firefox/i' => 'Firefox',
'/msie/i' => 'Internet Explorer',
'/edge/i' => 'Edge',
'/edg/i' => 'Edge',
'/opera/i' => 'Opera',
'/chrome/i' => 'Chrome',
'/safari/i' => 'Safari',
'/mobile/i' => 'Handheld Browser',
'/netscape/i' => 'Netscape',
'/maxthon/i' => 'Maxthon',
'/konqueror/i' => 'Konqueror'
];
}

custom/plugins/CbaxModulAnalytics/src/Subscriber/BackendSubscriber.php line 348