EP/myep
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore: remote obsolete contingents-related plumbing

Browse Source
This commit is contained in:
Björn Fromme
2026-06-11 16:19:14 +02:00
parent 8c99fba6fa
commit b2fccae431
19 changed files with 1 additions and 1711 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/BusProNet/Model/ContingentCalendarEvent.php
-22
View File
@@ -1,22 +0,0 @@
<?php
declare(strict_types=1);
namespace App\BusProNet\Model;
use Symfony\Component\Serializer\Attribute\Groups;
class ContingentCalendarEvent
{
public function __construct(
#[Groups(['api:contingent'])]
public string $date,
#[Groups(['api:contingent'])]
public string $status,
#[Groups(['api:contingent'])]
public int $pax,
#[Groups(['api:contingent'])]
public int $available,
) {
}
}
src/BusProNet/Model/ContingentDateSummary.php
-22
View File
@@ -1,22 +0,0 @@
<?php
declare(strict_types=1);
namespace App\BusProNet\Model;
use Symfony\Component\Serializer\Attribute\Groups;
class ContingentDateSummary
{
public function __construct(
#[Groups(['api:contingent'])]
public string $date,
#[Groups(['api:contingent'])]
public ?int $minNights,
#[Groups(['api:contingent'])]
public int $total,
#[Groups(['api:contingent'])]
public int $capacity,
) {
}
}
src/BusProNet/Model/ContingentRoomAvailability.php
-38
View File
@@ -1,38 +0,0 @@
<?php
declare(strict_types=1);
namespace App\BusProNet\Model;
use Symfony\Component\Serializer\Attribute\Groups;
class ContingentRoomAvailability
{
public function __construct(
#[Groups(['api:contingent'])]
public string $date,
#[Groups(['api:contingent'])]
public string $roomCode,
#[Groups(['api:contingent'])]
public string $roomLabel,
#[Groups(['api:contingent'])]
public string $bookingUrl,
#[Groups(['api:contingent'])]
public int $pax,
#[Groups(['api:contingent'])]
public int $available,
#[Groups(['api:contingent'])]
public string $status,
#[Groups(['api:contingent'])]
public ?float $minPrice,
#[Groups(['api:contingent'])]
public ?int $minNights,
#[Groups(['api:contingent'])]
public ?float $additionalNightMinPrice,
#[Groups(['api:contingent'])]
public ?int $additionalNightMinNights,
#[Groups(['api:contingent'])]
public float $priceForSelection,
) {
}
}
src/BusProNet/Utility/BookingUrlUtility.php
-38
View File
@@ -1,38 +0,0 @@
<?php
declare(strict_types=1);
namespace App\BusProNet\Utility;
class BookingUrlUtility
{
public function __construct(
private readonly string $defaultBaseUrl,
) {
}
public function build(int $hotelId, int $dateId, ?string $myEpUrl = null): string
{
$query = http_build_query([
'date_id' => $dateId,
'hotel_id' => $hotelId,
], '', '&', PHP_QUERY_RFC3986);
$baseUrlInput = null !== $myEpUrl && '' !== trim($myEpUrl)
? $myEpUrl
: $this->defaultBaseUrl;
$baseUrl = $this->normalizeBaseUrl($baseUrlInput);
if ('' === $baseUrl) {
return sprintf('/bookings/create?%s', $query);
}
return sprintf('%s/bookings/create?%s', $baseUrl, $query);
}
private function normalizeBaseUrl(string $url): string
{
$trimmedUrl = trim($url);
return rtrim($trimmedUrl, '/');
}
}
src/BusProNet/XmlLoader/ContingentLoader.php
-127
View File
@@ -1,127 +0,0 @@
<?php
namespace App\BusProNet\XmlLoader;
use App\BusProNet\XmlParser\ContingentParser;
use League\Flysystem\FilesystemException;
use League\Flysystem\FilesystemOperator;
use League\Flysystem\StorageAttributes;
use Psr\Cache\InvalidArgumentException;
use Symfony\Contracts\Cache\ItemInterface;
use Symfony\Contracts\Cache\TagAwareCacheInterface;
class ContingentLoader extends AbstractLoader
{
public function __construct(
private readonly ContingentParser $parser,
TagAwareCacheInterface $cache,
FilesystemOperator $xmlExportContingents,
) {
parent::__construct($cache, $xmlExportContingents);
}
/**
* @return array<int, string>
*/
public function generateFilesMap(): array
{
try {
return $this->cache->get('bpn_contingent_files', function (ItemInterface $item) {
$item->expiresAfter(3 * 60 * 60);
$item->tag(['xml-sync']);
$xmlFiles = $this->xmlExport
->listContents('.')
->filter(fn (StorageAttributes $attributes) => $attributes->isFile() && str_starts_with($attributes->path(), 'HotelZimmer_'));
$mapping = [];
foreach ($xmlFiles as $file) {
if (1 !== preg_match('/HotelZimmer_(\d+)\.xml$/', $file->path(), $matches)) {
continue;
}
$mapping[(int) $matches[1]] = $file->path();
}
return $mapping;
});
} catch (InvalidArgumentException) {
return [];
}
}
/**
* @return array{roomTypes: array<int, array<string, mixed>>, rows: array<int, array<string, mixed>>}
*/
public function loadByHotelId(int $hotelId): array
{
$cacheKey = sprintf('contingent_hotel_%d', $hotelId);
try {
return $this->cache->get($cacheKey, function (ItemInterface $item) use ($hotelId) {
$item->expiresAfter(3600);
$item->tag(['xml-sync']);
return $this->loadByHotelIdUncached($hotelId);
});
} catch (InvalidArgumentException) {
return $this->loadByHotelIdUncached($hotelId);
}
}
/**
* @return array{roomTypes: array<int, array<string, mixed>>, rows: array<int, array<string, mixed>>}
*/
private function loadByHotelIdUncached(int $hotelId): array
{
$mapping = $this->generateFilesMap();
if (false === isset($mapping[$hotelId])) {
return ['roomTypes' => [], 'rows' => []];
}
$filename = $mapping[$hotelId];
try {
$xml = $this->xmlExport->read($filename);
} catch (FilesystemException) {
return ['roomTypes' => [], 'rows' => []];
}
$linkedHotelId = $this->getRootLinkedHotelId($xml);
if (null !== $linkedHotelId) {
if (false === isset($mapping[$linkedHotelId])) {
return ['roomTypes' => [], 'rows' => []];
}
try {
$xml = $this->xmlExport->read($mapping[$linkedHotelId]);
} catch (FilesystemException) {
return ['roomTypes' => [], 'rows' => []];
}
}
return $this->parser->parse($xml);
}
private function getRootLinkedHotelId(string $xml): ?int
{
$document = new \DOMDocument();
if (false === @$document->loadXML($xml)) {
return null;
}
$root = $document->documentElement;
if (null === $root) {
return null;
}
$link = $root->getAttribute('idbuspro_kontingent_aus');
if ('' === $link) {
return null;
}
return (int) $link;
}
}
src/BusProNet/XmlParser/ContingentParser.php
-151
View File
@@ -1,151 +0,0 @@
<?php
namespace App\BusProNet\XmlParser;
use Symfony\Component\DomCrawler\Crawler;
class ContingentParser extends AbstractParser
{
private const CONTROL_ROOM_CODE = 'BelKal';
/**
* @var array<string>
*/
private array $ignoredRoomCodes = [
'PDGS',
];
/**
* @return array{roomTypes: array<int, array<string, mixed>>, rows: array<int, array<string, mixed>>}
*/
public function parse(string $xml): array
{
$crawler = new Crawler($xml);
$roomTypes = $this->parseRoomTypes($crawler);
$rows = $this->parseRows($crawler, $roomTypes);
return [
'roomTypes' => $roomTypes,
'rows' => $rows,
];
}
/**
* @return array<int, array<string, mixed>>
*/
private function parseRoomTypes(Crawler $crawler): array
{
$roomTypes = [];
$crawler
->filterXPath('//unterbringungen/unterbringung')
->each(function (Crawler $node) use (&$roomTypes) {
$roomId = $this->getIntOrNullAttribute($node->attr('idbuspro'));
$code = $node->attr('code');
if (null === $roomId || null === $code) {
return;
}
if (true === in_array($code, $this->ignoredRoomCodes, true)) {
return;
}
$label = $node->attr('zimmerbezeichnung')
?? $this->getStringOrNullValue($node->filterXPath('.//text'))
?? $code;
$pax = $this->getIntOrNullAttribute($node->attr('pax_max')) ?? 0;
$link = $this->getIntOrNullAttribute($node->attr('idbuspro_kontingent_aus'));
$roomTypes[$roomId] = [
'idBusPro' => $roomId,
'code' => $code,
'pax' => $pax,
'label' => $label,
'isControlRoom' => self::CONTROL_ROOM_CODE === $code,
'link' => $link,
];
});
return $roomTypes;
}
/**
* @param array<int, array<string, mixed>> $roomTypes
*
* @return array<int, array<string, mixed>>
*/
private function parseRows(Crawler $crawler, array $roomTypes): array
{
$rows = [];
$crawler
->filterXPath('//kapazitaeten/kapazitaet')
->each(function (Crawler $dateNode) use (&$rows, $roomTypes) {
$date = $this->stringToDate($dateNode->attr('termin'));
if (null === $date) {
return;
}
foreach ($roomTypes as $roomType) {
$roomId = $roomType['link'] ?? $roomType['idBusPro'];
$roomNode = $this->findRoomNode($dateNode, $roomId);
if (null === $roomNode) {
continue;
}
$capacity = $this->getIntOrNullAttribute($roomNode->attr('kontingent')) ?? 0;
$free = $this->getIntOrNullAttribute($roomNode->attr('frei')) ?? 0;
$statusRaw = $roomNode->attr('status') ?? '';
$rows[] = [
'date' => $date,
'roomCode' => $roomType['code'],
'roomLabel' => $roomType['label'],
'pax' => $roomType['isControlRoom'] ? 0 : $capacity * (int) ($roomType['pax'] ?? 0),
'available' => $roomType['isControlRoom'] ? 0 : $free * (int) ($roomType['pax'] ?? 0),
'status' => $this->mapStatus($statusRaw),
'minPrice' => $this->stringToFloat($roomNode->attr('abpreis')),
'minNights' => $this->getIntOrNullAttribute($roomNode->attr('abpreis_naechte')),
'additionalNightMinPrice' => $this->stringToFloat($roomNode->attr('abpreis_verlaengerung')),
'additionalNightMinNights' => $this->getIntOrNullAttribute($roomNode->attr('abpreis_verlaengerung_naechte')),
'isControlRoom' => $roomType['isControlRoom'],
];
}
});
return $rows;
}
private function findRoomNode(Crawler $dateNode, int $roomId): ?Crawler
{
$roomNode = $dateNode->filterXPath(sprintf('.//zimmerliste/zimmer[@idbuspro="%d"]', $roomId));
if (0 < $roomNode->count()) {
return $roomNode->first();
}
$roomNode = $dateNode->filterXPath(sprintf('.//zimmerliste/zimmer[@id="%d"]', $roomId));
if (0 < $roomNode->count()) {
return $roomNode->first();
}
$roomNode = $dateNode->filterXPath(sprintf('.//zimmerliste/zimmer[@id_zimmer="%d"]', $roomId));
if (0 < $roomNode->count()) {
return $roomNode->first();
}
return null;
}
private function mapStatus(?string $status): string
{
return match (strtoupper((string) $status)) {
'A' => 'ON_REQUEST',
'S' => 'BLOCKED',
default => 'OK',
};
}
}
src/Command/BpnXmlCacheInvalidateCommand.php
-5
View File
@@ -31,7 +31,6 @@ class BpnXmlCacheInvalidateCommand extends Command
public function __construct(
private readonly FilesystemOperator $xmlExport,
private readonly FilesystemOperator $xmlExportContingents,
private readonly TagAwareCacheInterface $bpnCache,
private readonly CacheInterface $cache,
private readonly LoggerInterface $logger,
@@ -194,10 +193,6 @@ class BpnXmlCacheInvalidateCommand extends Command
'name' => 'travel',
'storage' => $this->xmlExport,
],
[
'name' => 'contingents',
'storage' => $this->xmlExportContingents,
],
];
}
}
src/Controller/Api/ContingentController.php
-242
View File
@@ -1,242 +0,0 @@
<?php
namespace App\Controller\Api;
use App\BusProNet\Utility\DateCodeUtility;
use App\Exception\HotelNotInTravelException;
use App\Exception\TravelNotFoundException;
use App\Service\ContingentDataService;
use App\Service\TravelDataProvider;
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Component\HttpFoundation\JsonResponse;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\Routing\Attribute\Route;
use Symfony\Component\Security\Http\Attribute\IsGranted;
/**
* API endpoints for contingent availability data.
*
* References are accepted as either numeric IDs or business codes:
* - `hotelRef`: hotel ID (`idbuspro`) or hotel code
* - `dateRef`: date ID or date code (sanitized before mapping)
*/
#[Route('/api')]
#[IsGranted('ROLE_OAUTH2_API')]
class ContingentController extends AbstractController
{
public function __construct(
private readonly ContingentDataService $contingentDataService,
private readonly TravelDataProvider $travelDataProvider,
) {
}
#[Route(
'/contingents/calendar',
name: 'api_contingents_calendar',
methods: ['GET'],
)]
public function calendar(Request $request): JsonResponse
{
$hotelReference = $request->query->get('hotelRef');
if (null === $hotelReference || '' === trim($hotelReference)) {
return $this->json(['error' => 'hotelRef is required'], Response::HTTP_BAD_REQUEST);
}
return $this->handleCalendar($request, $hotelReference);
}
#[Route(
'/contingents',
name: 'api_contingents_single',
methods: ['GET'],
)]
public function byDate(Request $request): JsonResponse
{
$hotelReference = $request->query->get('hotelRef');
$dateReference = $request->query->get('dateRef');
if (null === $hotelReference || '' === trim($hotelReference)) {
return $this->json(['error' => 'hotelRef is required'], Response::HTTP_BAD_REQUEST);
}
if (null === $dateReference || '' === trim($dateReference)) {
return $this->json(['error' => 'dateRef is required'], Response::HTTP_BAD_REQUEST);
}
return $this->handleByDate($hotelReference, $dateReference);
}
#[Route(
'/contingents/rooms',
name: 'api_contingents_rooms',
methods: ['GET'],
)]
public function rooms(Request $request): JsonResponse
{
$hotelReference = $request->query->get('hotelRef');
$dateReference = $request->query->get('dateRef');
$dateFrom = $request->query->get('dateFrom');
$dateTo = $request->query->get('dateTo');
$myEpUrl = $request->query->get('my_ep_url');
if (null === $hotelReference || '' === trim($hotelReference)) {
return $this->json(['error' => 'hotelRef is required'], Response::HTTP_BAD_REQUEST);
}
if (null === $dateReference || '' === trim($dateReference)) {
return $this->json(['error' => 'dateRef is required'], Response::HTTP_BAD_REQUEST);
}
if (null === $dateFrom || null === $dateTo) {
return $this->json(['error' => 'dateFrom and dateTo are required'], Response::HTTP_BAD_REQUEST);
}
return $this->handleRooms(
$hotelReference,
$dateReference,
$dateFrom,
$dateTo,
is_string($myEpUrl) ? $myEpUrl : null,
);
}
/**
* Shared execution path for calendar data after hotel reference validation.
*/
private function handleCalendar(Request $request, string $hotelReference): JsonResponse
{
$hotelId = $this->resolveHotelId($hotelReference);
if (null === $hotelId) {
return $this->json(['message' => 'Not found'], Response::HTTP_NOT_FOUND);
}
$dateFrom = $request->query->get('dateFrom');
$dateTo = $request->query->get('dateTo');
if (null === $dateFrom || null === $dateTo) {
return $this->json(['error' => 'dateFrom and dateTo are required'], Response::HTTP_BAD_REQUEST);
}
try {
$events = $this->contingentDataService->getCalendarEvents($hotelId, $dateFrom, $dateTo);
} catch (\InvalidArgumentException $e) {
return $this->json(['error' => $e->getMessage()], Response::HTTP_BAD_REQUEST);
}
return $this->json($events, Response::HTTP_OK, [], ['groups' => ['api:contingent']]);
}
/**
* Shared execution path for daily contingent summary after reference validation.
*/
private function handleByDate(string $hotelReference, string $dateReference): JsonResponse
{
$hotelId = $this->resolveHotelId($hotelReference);
$dateId = $this->resolveDateId($dateReference);
if (null === $hotelId || null === $dateId) {
return $this->json(['message' => 'Not found'], Response::HTTP_NOT_FOUND);
}
try {
$contingents = $this->contingentDataService->getAvailableContingents($hotelId, $dateId);
} catch (TravelNotFoundException|HotelNotInTravelException) {
return $this->json(['message' => 'Not found'], Response::HTTP_NOT_FOUND);
}
return $this->json($contingents, Response::HTTP_OK, [], ['groups' => ['api:contingent']]);
}
/**
* Shared execution path for room-level availability after reference validation.
*/
private function handleRooms(
string $hotelReference,
string $dateReference,
string $dateFrom,
string $dateTo,
?string $myEpUrl = null,
): JsonResponse {
$hotelId = $this->resolveHotelId($hotelReference);
$dateId = $this->resolveDateId($dateReference);
if (null === $hotelId || null === $dateId) {
return $this->json(['message' => 'Not found'], Response::HTTP_NOT_FOUND);
}
try {
$rooms = $this->contingentDataService->getAvailableRooms($dateFrom, $dateTo, $hotelId, $dateId, $myEpUrl);
} catch (TravelNotFoundException|HotelNotInTravelException) {
return $this->json(['message' => 'Not found'], Response::HTTP_NOT_FOUND);
} catch (\InvalidArgumentException $e) {
return $this->json(['error' => $e->getMessage()], Response::HTTP_BAD_REQUEST);
}
return $this->json($rooms, Response::HTTP_OK, [], ['groups' => ['api:contingent']]);
}
/**
* Resolves a hotel reference to hotel ID.
*
* Numeric values are treated as IDs, otherwise mapped as hotel code.
*/
private function resolveHotelId(string $hotelReference): ?int
{
return $this->resolveReferenceId(
$hotelReference,
fn (string $reference): ?int => $this->travelDataProvider->mapHotelCodeToId($reference),
);
}
/**
* Resolves a date reference to date ID.
*
* Numeric values are treated as IDs, otherwise mapped as date code.
* Date codes are sanitized first (uppercased and separators removed).
*/
private function resolveDateId(string $dateReference): ?int
{
return $this->resolveReferenceId(
$dateReference,
fn (string $reference): ?int => $this->travelDataProvider->mapDateCodeToId($reference),
fn (string $reference): string => (new DateCodeUtility())->sanitize($reference),
);
}
/**
* Generic resolver for mixed ID/code references.
*
* Flow:
* 1. Trim and reject empty values.
* 2. If numeric, return as integer ID.
* 3. Optionally normalize the value.
* 4. Map normalized code to ID.
*
* @param callable $mapper maps code input to ID
* @param callable|null $normalizer optional code normalizer before mapping
*/
private function resolveReferenceId(
string $reference,
callable $mapper,
?callable $normalizer = null,
): ?int {
$trimmedReference = trim($reference);
if ('' === $trimmedReference) {
return null;
}
if (true === ctype_digit($trimmedReference)) {
return (int) $trimmedReference;
}
if (null !== $normalizer) {
$trimmedReference = $normalizer($trimmedReference);
}
return $mapper($trimmedReference);
}
}
src/Service/BpnXmlSyncManager.php
-3
View File
@@ -21,8 +21,6 @@ final class BpnXmlSyncManager
public function __construct(
private readonly FilesystemOperator $xmlSource,
private readonly FilesystemOperator $xmlExport,
private readonly FilesystemOperator $xmlSourceContingents,
private readonly FilesystemOperator $xmlExportContingents,
private readonly TagAwareCacheInterface $bpnCache,
private readonly LoggerInterface $logger,
) {
@@ -35,7 +33,6 @@ final class BpnXmlSyncManager
{
return [
new BpnXmlSyncTarget('travel', $this->xmlSource, $this->xmlExport),
new BpnXmlSyncTarget('contingents', $this->xmlSourceContingents, $this->xmlExportContingents),
];
}
src/Service/ContingentDataService.php
-258
View File
@@ -1,258 +0,0 @@
<?php
declare(strict_types=1);
namespace App\Service;
use App\BusProNet\Model\ContingentCalendarEvent;
use App\BusProNet\Model\ContingentDateSummary;
use App\BusProNet\Model\ContingentRoomAvailability;
use App\BusProNet\Utility\BookingUrlUtility;
use App\BusProNet\XmlLoader\ContingentLoader;
use App\BusProNet\XmlLoader\TravelLoader;
use App\Exception\HotelNotInTravelException;
use App\Exception\TravelNotFoundException;
class ContingentDataService
{
private const STATUS_ORDER = [
'OK' => 0,
'ON_REQUEST' => 1,
'BLOCKED' => 2,
];
public function __construct(
private readonly ContingentLoader $contingentLoader,
private readonly TravelLoader $travelLoader,
private readonly BookingUrlUtility $bookingUrlUtility,
) {
}
/**
* @return array<string, ContingentDateSummary>
*
* @throws TravelNotFoundException
* @throws HotelNotInTravelException
*/
public function getAvailableContingents(int $hotelId, int $dateId): array
{
$travel = $this->travelLoader->loadById($dateId, $hotelId);
if (null === $travel->dateFrom || null === $travel->dateTo) {
return [];
}
$data = $this->contingentLoader->loadByHotelId($hotelId);
$rows = $this->filterRowsByRange($data['rows'], $travel->dateFrom, $travel->dateTo);
$belKalStatusByDate = $this->getBelKalStatusByDate($rows);
$result = [];
foreach ($rows as $row) {
if (true === ($row['isControlRoom'] ?? false)) {
continue;
}
$dateKey = $row['date']->format('Y-m-d');
if (false === isset($result[$dateKey])) {
$result[$dateKey] = new ContingentDateSummary($dateKey, null, 0, 0);
}
if (null !== $row['minNights']) {
$result[$dateKey]->minNights = null === $result[$dateKey]->minNights
? $row['minNights']
: min($result[$dateKey]->minNights, $row['minNights']);
}
$result[$dateKey]->total += (int) ($row['available'] ?? 0);
$result[$dateKey]->capacity += (int) ($row['pax'] ?? 0);
}
foreach ($belKalStatusByDate as $dateKey => $status) {
if (false === isset($result[$dateKey])) {
continue;
}
if ('OK' !== $status) {
$result[$dateKey]->total = 0;
}
}
return $result;
}
/**
* @return array<int, ContingentRoomAvailability>
*
* @throws TravelNotFoundException
* @throws HotelNotInTravelException
* @throws \InvalidArgumentException
*/
public function getAvailableRooms(
string $dateFrom,
string $dateTo,
int $hotelId,
int $dateId,
?string $myEpUrl = null,
): array {
$range = $this->parseDateRange($dateFrom, $dateTo);
$travel = $this->travelLoader->loadById($dateId, $hotelId);
if (null !== $travel->dateFrom && null !== $travel->dateTo) {
if ($range['from'] < $travel->dateFrom || $range['to'] > $travel->dateTo) {
throw new \InvalidArgumentException('Requested range must be within the travel date range');
}
}
$data = $this->contingentLoader->loadByHotelId($hotelId);
$rows = $this->filterRowsByRange($data['rows'], $range['from'], $range['to']);
$belKalStatusByDate = $this->getBelKalStatusByDate($rows);
$nights = $range['from']->diff($range['to'])->days;
$bookingUrl = $this->bookingUrlUtility->build($hotelId, $dateId, $myEpUrl);
$result = [];
foreach ($rows as $row) {
if (true === ($row['isControlRoom'] ?? false)) {
continue;
}
$dateKey = $row['date']->format('Y-m-d');
$status = $row['status'] ?? 'OK';
if (isset($belKalStatusByDate[$dateKey]) && 'OK' !== $belKalStatusByDate[$dateKey]) {
$status = $belKalStatusByDate[$dateKey];
}
$minNights = $row['minNights'] ?? 0;
$additionalNightMinPrice = $row['additionalNightMinPrice'] ?? 0.0;
$minPrice = $row['minPrice'] ?? 0.0;
$extraNights = max(0, $nights - (int) $minNights);
$priceForSelection = $minPrice + ($extraNights * $additionalNightMinPrice);
$result[] = new ContingentRoomAvailability(
date: $dateKey,
roomCode: (string) $row['roomCode'],
roomLabel: (string) $row['roomLabel'],
bookingUrl: $bookingUrl,
pax: (int) ($row['pax'] ?? 0),
available: 'OK' === $status ? (int) ($row['available'] ?? 0) : 0,
status: $status,
minPrice: $row['minPrice'],
minNights: $row['minNights'],
additionalNightMinPrice: $row['additionalNightMinPrice'],
additionalNightMinNights: $row['additionalNightMinNights'],
priceForSelection: (float) $priceForSelection,
);
}
return $result;
}
/**
* @return array<int, ContingentCalendarEvent>
*/
public function getCalendarEvents(int $hotelId, string $dateFrom, string $dateTo): array
{
$range = $this->parseDateRange($dateFrom, $dateTo);
$data = $this->contingentLoader->loadByHotelId($hotelId);
$rows = $this->filterRowsByRange($data['rows'], $range['from'], $range['to']);
$events = [];
foreach ($rows as $row) {
$dateKey = $row['date']->format('Y-m-d');
if (false === isset($events[$dateKey])) {
$events[$dateKey] = new ContingentCalendarEvent($dateKey, 'OK', 0, 0);
}
$events[$dateKey]->status = $this->mergeStatus(
$events[$dateKey]->status,
$row['status'] ?? 'OK'
);
if (false === ($row['isControlRoom'] ?? false)) {
$events[$dateKey]->pax += (int) ($row['pax'] ?? 0);
$events[$dateKey]->available += (int) ($row['available'] ?? 0);
}
}
ksort($events);
return array_values($events);
}
/**
* @param array<int, array<string, mixed>> $rows
*
* @return array<int, array<string, mixed>>
*/
private function filterRowsByRange(array $rows, \DateTimeImmutable $dateFrom, \DateTimeImmutable $dateTo): array
{
return array_values(array_filter($rows, function (array $row) use ($dateFrom, $dateTo) {
if (false === isset($row['date']) || !$row['date'] instanceof \DateTimeImmutable) {
return false;
}
return $row['date'] >= $dateFrom && $row['date'] <= $dateTo;
}));
}
/**
* @param array<int, array<string, mixed>> $rows
*
* @return array<string, string>
*/
private function getBelKalStatusByDate(array $rows): array
{
$statuses = [];
foreach ($rows as $row) {
if (false === ($row['isControlRoom'] ?? false)) {
continue;
}
$dateKey = $row['date']->format('Y-m-d');
$statuses[$dateKey] = $this->mergeStatus($statuses[$dateKey] ?? 'OK', $row['status'] ?? 'OK');
}
return $statuses;
}
private function mergeStatus(string $current, string $candidate): string
{
$currentOrder = self::STATUS_ORDER[$current] ?? 0;
$candidateOrder = self::STATUS_ORDER[$candidate] ?? 0;
return $candidateOrder > $currentOrder ? $candidate : $current;
}
/**
* @return array{from: \DateTimeImmutable, to: \DateTimeImmutable}
*/
private function parseDateRange(string $dateFrom, string $dateTo): array
{
$from = $this->parseDate($dateFrom);
$to = $this->parseDate($dateTo);
if ($to < $from) {
throw new \InvalidArgumentException('dateTo must be on or after dateFrom');
}
return ['from' => $from, 'to' => $to];
}
private function parseDate(string $date): \DateTimeImmutable
{
$parsed = \DateTimeImmutable::createFromFormat('Y-m-d', $date);
if (false === $parsed || $parsed->format('Y-m-d') !== $date) {
throw new \InvalidArgumentException('Invalid date format, expected Y-m-d');
}
return $parsed->setTime(0, 0, 0);
}
}