src/EventSubscriber/JourneySubscriber.php line 71

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Event\JourneyEvent;
  6. use App\Event\ModeEvent;
  7. use App\Model\Mode;
  8. use App\Normalizer\DisruptionNormalizer;
  9. use App\Normalizer\JourneyGroupNormalizer;
  10. use App\Service\Internal\DisruptionService;
  11. use App\Service\Internal\JourneyService;
  12. use App\Service\Internal\LogService;
  13. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class JourneySubscriber implements EventSubscriberInterface
  17. {
  18. /**
  19. * @var EventDispatcherInterface
  20. */
  21. protected $eventDispatcher;
  23. /**
  24. * @var JourneyService
  25. */
  26. protected $journeyService;
  28. /** @var DisruptionService */
  29. protected $disruptionService;
  31. /**
  32. * @var LogService
  33. */
  34. protected $logService;
  36. /**
  37. * @var string
  38. */
  39. protected $networkId;
  41. /**
  42. * @var JourneyGroupNormalizer
  43. */
  44. protected $journeyGroupNormalizer;
  46. public function __construct(
  47. EventDispatcherInterface $eventDispatcher,
  48. JourneyService $journeyService,
  49. DisruptionService $disruptionService,
  50. LogService $logService,
  51. string $networkId,
  52. JourneyGroupNormalizer $journeyGroupNormalizer
  53. ) {
  54. $this->eventDispatcher = $eventDispatcher;
  55. $this->journeyService = $journeyService;
  56. $this->disruptionService = $disruptionService;
  57. $this->logService = $logService;
  58. $this->networkId = $networkId;
  59. $this->journeyGroupNormalizer = $journeyGroupNormalizer;
  60. }
  62. public static function getSubscribedEvents(): array
  63. {
  64. return [
  65. JourneyEvent::NAME => [
  66. ['journeyCalculation', 0]
  67. ]
  68. ];
  69. }
  71. public function journeyCalculation(JourneyEvent $event)
  72. {
  73. $bodyRequest = $event->getBodyRequest();
  75. $userModes = [];
  76. if (isset($bodyRequest['modes'])) {
  77. $userModes = $bodyRequest['modes'];
  78. unset($bodyRequest['modes']);
  79. }
  81. $modeEvent = new ModeEvent($userModes);
  82. $this->eventDispatcher->dispatch($modeEvent, ModeEvent::NAME);
  83. $bodyRequest['excludedModes'] = $modeEvent->getExcludedModes();
  85. $totalNumberJourneys = 0;
  86. $journeys = [];
  87. $layoutModes = isset ($bodyRequest['layoutMode']) ? [$bodyRequest['layoutMode']] : $modeEvent->getLayoutModes();
  89. $isSubNetworks = '';
  90. $currentDisruptions = $this->disruptionService->getDisruptions($isSubNetworks, DisruptionNormalizer::STATUS_ONGOING);
  91. $disruptions = $currentDisruptions['disruptions'] ?? [];
  92. foreach ($layoutModes as $layout) {
  93. $layoutTotalJourneys = 0;
  94. $journeys[$layout] = $this->journeyService->getJourneysByLayoutMode($layout, $bodyRequest);
  96. if (isset($journeys[$layout]['groups'])) {
  97. $layoutTotalJourneys = $this->getTotalNumberJourneysByLayoutMode($journeys[$layout]['groups']);
  98. $totalNumberJourneys += $layoutTotalJourneys;
  100. $journeys[$layout] = $this->journeyGroupNormalizer->normalize($layout, $journeys[$layout], $disruptions);
  101. }
  103. if (Mode::TAB_TRANSPORT === $layout && 0 === $layoutTotalJourneys) {
  104. $wsUrl = preg_replace(
  105. ['/%1/', '/%2/'],
  106. [$this->networkId, $layout],
  107. JourneyService::PATH_JOURNEYS_BY_LAYOUT_MODE
  108. );
  109. $this->logService->sendLog($wsUrl, JourneyService::LOG_NO_JOURNEYS_FOUND);
  110. }
  111. }
  113. $event->setJourneyResults($journeys);
  114. $event->setTotalNumberJourneys($totalNumberJourneys);
  115. }
  117. public function getTotalNumberJourneysByLayoutMode(array $journeysGroup): int
  118. {
  119. $total = 0;
  120. foreach ($journeysGroup as $group) {
  121. if (isset($group['results']['journeycount'])) {
  122. $total += $group['results']['journeycount'];
  123. }
  124. }
  126. return $total;
  127. }
  129. }