src/JanusHercules/ConversionEventTracking/Presentation/EventSubscriber/Step1TrackingSubscriber.php line 52

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace JanusHercules\ConversionEventTracking\Presentation\EventSubscriber;
  7. use App\Entity\ConversionEvent;
  8. use App\Service\ConversionEventService;
  9. use App\Service\SessionService;
  10. use Doctrine\ORM\EntityManagerInterface;
  11. use Exception;
  12. use JanusHercules\ConversionEventTracking\Domain\Dto\CampaignSubcampaignPairDto;
  13. use JanusHercules\ConversionEventTracking\Presentation\Service\Step0SessionServiceInterface;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Symfony\Component\HttpKernel\Event\RequestEvent;
  16. use Symfony\Component\HttpKernel\KernelEvents;
  18. /**
  19. * Event Subscriber für Step 1 Tracking (Link Clicked).
  20. *
  21. * Erkennt den __ggcts1 URL-Parameter und erstellt Step 1 Events
  22. * für alle enthaltenen Campaign/Subcampaign-Paare.
  23. *
  24. * @see https://github.com/joboo-gmbh/joboo-marketing/blob/main/docs/outbound-url-tracking.md
  25. */
  26. final class Step1TrackingSubscriber implements EventSubscriberInterface
  27. {
  28. /**
  29. * URL-Parameter für Step 1 Tracking.
  30. * __ggcts1 = go-gastro Conversion Tracking Step 1.
  31. */
  32. private const PARAM_NAME = '__ggcts1';
  34. public function __construct(
  35. private readonly ConversionEventService $conversionEventService,
  36. private readonly SessionService $sessionService,
  37. private readonly Step0SessionServiceInterface $step0SessionService,
  38. private readonly EntityManagerInterface $entityManager
  39. ) {
  40. }
  42. public static function getSubscribedEvents(): array
  43. {
  44. return [
  45. KernelEvents::REQUEST => 'onKernelRequest',
  46. ];
  47. }
  49. /**
  50. * @throws Exception
  51. */
  52. public function onKernelRequest(RequestEvent $event): void
  53. {
  54. if (!$event->isMainRequest()) {
  55. return;
  56. }
  58. $request = $event->getRequest();
  59. $paramValue = $request->query->get(self::PARAM_NAME);
  61. if (empty($paramValue) || !is_string($paramValue)) {
  62. return;
  63. }
  65. $session = $request->getSession();
  66. if (!$session->isStarted()) {
  67. return;
  68. }
  70. $step0EventIds = $this->step0SessionService->getAllStep0EventIds($session);
  72. // Parse: "117:0,118:0" → [CampaignSubcampaignPairDto(117, 0), CampaignSubcampaignPairDto(118, 0)]
  73. $pairs = CampaignSubcampaignPairDto::parseFromUrlParam($paramValue);
  75. foreach ($pairs as $pair) {
  76. $sessionKey = $pair->getSessionKey();
  77. $step0EventId = $step0EventIds[$sessionKey] ?? null;
  79. if ($step0EventId !== null) {
  80. // Step 0 Event aus DB laden
  81. /** @var ConversionEvent|null $step0Event */
  82. $step0Event = $this->entityManager->find(ConversionEvent::class, $step0EventId);
  84. if ($step0Event !== null) {
  85. // Step 1 Event erstellen (referenziert auf Step 0)
  86. $step1Event = $this->conversionEventService->createStepLinkClickedConversionEvent(
  87. $step0Event,
  88. $request
  89. );
  91. // Step 1 Event-ID für Goal-Tracking speichern
  92. $this->sessionService->addConversionEventId(
  93. $session,
  94. $step1Event->getId(),
  95. $pair->campaignId,
  96. $pair->subcampaignId,
  97. null
  98. );
  99. }
  101. // Step 0 aus Session entfernen (wurde verarbeitet)
  102. unset($step0EventIds[$sessionKey]);
  103. } else {
  104. // Fallback: Kein Step 0 vorhanden (z.B. JS war deaktiviert)
  105. // → Step 0 + Step 1 zusammen erstellen
  106. $this->conversionEventService->initiateGoalReachedConversionTracking(
  107. null,
  108. $pair->campaignId,
  109. $pair->subcampaignId,
  110. null,
  111. $request
  112. );
  113. }
  114. }
  116. // Aktualisierte Step 0 IDs zurückschreiben:
  117. // Die Session kann mehrere Step 0 Event-IDs enthalten (z.B. wenn der User mehrere
  118. // Landingpages besucht hat). Oben wurden nur die Step 0 IDs verarbeitet, die im
  119. // URL-Parameter __ggcts1 referenziert wurden – diese wurden via unset() aus dem
  120. // Array entfernt. Hier schreiben wir das bereinigte Array zurück, damit:
  121. // 1. Verarbeitete Step 0 IDs nicht erneut zu Step 1 konvertiert werden (F5/Zurück)
  122. // 2. Nicht-verarbeitete Step 0 IDs für spätere Klicks erhalten bleiben
  123. $this->step0SessionService->setAllStep0EventIds($session, $step0EventIds);
  125. // Parameter aus Request entfernen (für saubere URLs in Logs etc.)
  126. $request->query->remove(self::PARAM_NAME);
  127. }
  128. }