vendor/croisiland/common-bundle/src/Helper/Cruise/CruiseHelper.php line 244

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Croisiland\CommonBundle\Helper\Cruise;
  7. use Crea\MediaBundle\Entity\Enum\MediaFamilyCodeEnum;
  8. use Crea\MediaBundle\Entity\MediaTagOwnerInterface;
  9. use Crea\MediaBundle\Helper\MediaTagOwnerHelper;
  10. use Croisiland\CommonBundle\Entity\Company\Atmosphere;
  11. use Croisiland\CommonBundle\Entity\Cruise\Cruise;
  12. use Croisiland\CommonBundle\Entity\Cruise\CruiseInterface;
  13. use Croisiland\CommonBundle\Entity\Itinerary\DestinationMain;
  14. use Croisiland\CommonBundle\Entity\Itinerary\Itinerary;
  15. use Croisiland\CommonBundle\Entity\Itinerary\Stopover;
  16. use Croisiland\CommonBundle\Entity\Offer\Offer;
  17. use Croisiland\CommonBundle\Entity\Itinerary\ItinerarySegment;
  18. use Croisiland\CommonBundle\Entity\Ship\Ship;
  19. use Croisiland\CommonBundle\Enum\SegmentTypeEnum;
  20. use Croisiland\CommonBundle\Helper\DomDocumentHelper;
  21. use Croisiland\CommonBundle\Helper\Itinerary\ItineraryHelper;
  22. use Croisiland\CommonBundle\Repository\Cruise\CruiseRepository;
  23. use Croisiland\CommonBundle\Repository\Itinerary\ItinerarySegmentRepository;
  24. use Croisiland\CommonBundle\RepositoryView\Offer\OfferCruiseViewRepository;
  25. use Doctrine\ORM\NonUniqueResultException;
  26. use Doctrine\ORM\NoResultException;
  27. use function PHPUnit\Framework\matches;
  29. class CruiseHelper
  30. {
  32. public function __construct(
  33. private readonly CruiseRepository $cruiseRepository,
  34. private readonly OfferCruiseViewRepository $offerCruiseRepository,
  35. private readonly ItinerarySegmentRepository $itinerarySegmentRepository,
  36. private readonly DomDocumentHelper $domDocumentHelper,
  37. private readonly ItineraryHelper $itineraryHelper,
  38. private readonly MediaTagOwnerHelper $mediaTagOwnerHelper,
  39. )
  40. {
  41. }
  43. public function getUpdatedCruiseName(Cruise $cruise): string
  44. {
  45. $newName = '';
  47. $companyName = null;
  48. if (null !== $cruise->getShip() && null !== $cruise->getShip()->getCompany()) {
  49. $companyName = $cruise->getShip()->getCompany()->getName();
  50. }
  52. $itineraryName = null;
  53. if (null !== $cruise->getItinerary()) {
  54. $itineraryName = $cruise->getItinerary()->getName();
  55. }
  57. if (null !== $companyName && null !== $itineraryName) {
  58. $newName = $companyName.' : '.$itineraryName;
  60. if (strlen($newName) > 255) {
  61. $newName = substr($newName, 0, 252).'...';
  62. }
  63. }
  65. return $newName;
  66. }
  68. /**
  69. * @param array<int, int> $cruises
  70. *
  71. * @return Cruise[]
  72. */
  73. public function getCruisesFromIds(array $cruises, ?callable $callback = null): array
  74. {
  75. $resultSet = [];
  76. foreach ($cruises as $cruiseId) {
  77. $cruise = $this->cruiseRepository->find($cruiseId);
  78. if ($cruise instanceof Cruise && (null === $callback || $callback($cruise))) {
  79. $resultSet[] = $cruise;
  80. }
  81. }
  83. return $resultSet;
  84. }
  86. /**
  87. * Récupère un propriétaire de balise média (avatar) pour une croisière.
  88. * L'avatar est sélectionné selon cet ordre de priorité :
  89. * 1. Une escale aléatoire (en excluant le premier et dernier segment si plus de 2 segments).
  90. * 2. Le navire de la croisière.
  91. * 3. La destination de l'itinéraire.
  92. *
  93. * @param CruiseInterface $cruise La croisière pour laquelle récupérer l'avatar.
  94. * @return MediaTagOwnerInterface|null Le propriétaire de balise média ou null si aucun candidat valide n'est trouvé.
  95. */
  96. public function getCruiseAvatarOwner(CruiseInterface $cruise): ?MediaTagOwnerInterface
  97. {
  98. // Liste des candidats potentiels pour l'avatar, dans l'ordre de priorité.
  99. $avatarCandidates = [
  100. $this->getRandomStopover($cruise),
  101. $cruise->getShip(),
  102. $cruise->getItinerary()->getDestination(),
  103. ];
  105. // Sélectionner le premier candidat ayant des médias associés.
  106. foreach ($avatarCandidates as $avatarCandidate) {
  107. /** @var MediaTagOwnerInterface $avatarCandidate */
  108. $criteria = $this->getCruiseAvatarCriteria($avatarCandidate);
  109. try {
  110. if ($avatarCandidate !== null && $this->mediaTagOwnerHelper->hasMedia($avatarCandidate, MediaFamilyCodeEnum::FAM_IMAGE, $criteria)) {
  111. return $avatarCandidate;
  112. }
  113. } catch (NoResultException|NonUniqueResultException $e) {
  114. continue;
  115. }
  116. }
  118. return null;
  119. }
  121. /**
  122. * @return array<string|array<string>>
  123. */
  124. private function getCruiseAvatarCriteria(?MediaTagOwnerInterface $mediaOwner): array
  125. {
  126. return match (true) {
  127. $mediaOwner instanceof Stopover,
  128. $mediaOwner instanceof Ship,
  129. $mediaOwner instanceof DestinationMain => ['main'],
  130. default => [],
  131. };
  132. }
  134. /**
  135. * Commun Bundle
  136. */
  137. protected function getRandomStopover(CruiseInterface $cruise): ?Stopover
  138. {
  139. $segments = $this->itinerarySegmentRepository->getStopoverSegmentsForItinerary($cruise->getItinerary());
  141. if (empty($segments)) {
  142. return null;
  143. }
  145. // Filtrer les segments pour ignorer le premier et le dernier si plus de 2 segments.
  146. if (count($segments) > 2) {
  147. $segments = array_slice($segments, 1, -1);
  148. }
  150. shuffle($segments);
  152. // Sélectionner un segment aléatoire.
  153. foreach ($segments as $segment) {
  154. if ($this->mediaTagOwnerHelper->hasMedia($segment->getStopover(), MediaFamilyCodeEnum::FAM_IMAGE, $this->getCruiseAvatarCriteria($segment->getStopover()))) {
  155. return $segment->getStopover();
  156. }
  157. }
  158. return null;
  159. }
  161. public function getCruiseDisplayName(Cruise $cruise): string
  162. {
  163. if ($cruise->getItinerary() instanceof Itinerary) {
  164. $itineraryName = $this->itineraryHelper->getName($cruise->getItinerary());
  165. if ($itineraryName !== null && $itineraryName !== '') {
  166. return $itineraryName;
  167. }
  168. }
  170. return $cruise->getShip()->getCompany()->getName() .':'. $cruise->getShip()->getName() . ' - ' . $cruise->getDepartureDate()->format('d/m/Y');
  171. }
  173. public function getCruiseSelectName(Cruise $cruise): string
  174. {
  175. return sprintf(
  176. ' [%s] %s • %s (%s)',
  177. $cruise->getId(),
  178. $cruise->getCode(),
  179. $this->getCruiseDisplayName($cruise),
  180. $cruise->getDepartureDate()->format('d/m/Y').' - '.$cruise->getArrivalDate()->format('d/m/Y'),
  182. );
  183. }
  184. /**
  185. * Retourne le nombre de croisières actives ou non pour une Offer donnée
  186. * concernant les croisières dont la date de départ est dans le futur ou égale à aujourd'hui
  187. */
  188. public function getNbCruisesByOffer(Offer $offer):int
  189. {
  190. $cruiseIds = $this->offerCruiseRepository->findAllCruiseIdsPerOffer($offer);
  192. return count($cruiseIds);
  193. }
  195. /**
  196. * Retourne le nombre de croisières actives pour une Offer donnée
  197. * concernant les croisières dont la date de départ est dans le futur ou égale à aujourd'hui
  198. */
  199. public function getNbActiveCruisesByOffer(Offer $offer): int
  200. {
  201. $cruises = $this->cruiseRepository->findUpComingCruiseByOffer($offer, true);
  203. return count($cruises);
  204. }
  206. public function determineOfferOrigin(Offer $offer):?string
  207. {
  208. $results = $this->offerCruiseRepository->findResultsPerOffer($offer);
  209. $counts = array_count_values(array_column($results, 'linkType'));
  211. $nbDirect = $counts['direct'] ?? 0;
  212. $nbViaPrice = $counts['via_price'] ?? 0;
  214. if ($nbDirect > 0 && $nbViaPrice > 0) {
  215. return 'mixed';
  216. } elseif ($nbDirect > 0) {
  217. return 'direct';
  218. } elseif ($nbViaPrice > 0) {
  219. return 'via_price';
  220. }
  222. return null;
  223. }
  225. public function getCruiseIncludeForAtmosphereArray(Cruise $cruise, ?Atmosphere $atmosphere = null): array
  226. {
  227. return $this->getCruiseItemsForAtmosphereArray($cruise, $atmosphere, 'included');
  228. }
  230. public function getCruiseExcludeForAtmosphereArray(Cruise $cruise, ?Atmosphere $atmosphere = null): array
  231. {
  232. return $this->getCruiseItemsForAtmosphereArray($cruise, $atmosphere, 'excluded');
  233. }
  235. private function getCruiseItemsForAtmosphereArray(Cruise $cruise, ?Atmosphere $atmosphere, string $propertyName): array
  236. {
  237. $method = 'get' . mb_convert_case($propertyName, MB_CASE_TITLE, 'UTF-8');
  239. $cruiseItems = $this->domDocumentHelper->parseHtmlListToArray($cruise->$method());
  240. if (!empty($cruiseItems)) {
  241. return $cruiseItems;
  242. }
  244. $itineraryItems = $this->domDocumentHelper->parseHtmlListToArray($cruise->getItinerary()->$method());
  245. if (!empty($itineraryItems)) {
  246. return $itineraryItems;
  247. }
  249. $companyItems = $this->domDocumentHelper->parseHtmlListToArray($cruise->getShip()->getCompany()->$method());
  250. if ($atmosphere === null) {
  251. return $companyItems;
  252. }
  254. $atmosphereItems = $this->domDocumentHelper->parseHtmlListToArray($atmosphere->$method());
  255. if (empty($atmosphereItems)) {
  256. return $companyItems;
  257. }
  259. return array_unique(array_merge($companyItems, $atmosphereItems));
  260. }
  263. }