EP/website-typo3
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: limit hotels to configured folder when importing contingents

Browse Source
This commit is contained in:
Björn Fromme
2025-07-01 16:39:38 +02:00
parent 59d295430a
commit 600cf8f3cb
2 changed files with 45 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files
public/typo3conf/ext/ep_products/Classes/Service/ContingentImportService.php
+39 -24
View File
@@ -58,7 +58,12 @@ class ContingentImportService implements SingletonInterface, LoggerAwareInterfac
/** /**
* @var int * @var int
*/ */
protected $pid = 0; protected $contingentsPid = 0;
/**
* @var int
*/
protected $hotelsPid = 0;
/** /**
* @var Connection * @var Connection
@@ -66,7 +71,6 @@ class ContingentImportService implements SingletonInterface, LoggerAwareInterfac
protected $db; protected $db;
/** /**
* @param ConfigurationManagerInterface $manager
* @throws \Doctrine\DBAL\DBALException * @throws \Doctrine\DBAL\DBALException
*/ */
public function __construct(ConfigurationManagerInterface $manager) public function __construct(ConfigurationManagerInterface $manager)
@@ -76,16 +80,25 @@ class ContingentImportService implements SingletonInterface, LoggerAwareInterfac
$settings = GeneralUtility::removeDotsFromTS( $settings = GeneralUtility::removeDotsFromTS(
$this->configurationManager->getConfiguration(ConfigurationManagerInterface::CONFIGURATION_TYPE_FULL_TYPOSCRIPT) $this->configurationManager->getConfiguration(ConfigurationManagerInterface::CONFIGURATION_TYPE_FULL_TYPOSCRIPT)
); );
if (isset($settings['plugin']['tx_epproducts']['persistence']['storagePid'])) { if (isset($settings['plugin']['tx_epproducts']['persistence']['storagePid'])) {
$this->pid = $settings['plugin']['tx_epproducts']['persistence']['storagePid']; $this->contingentsPid = $settings['plugin']['tx_epproducts']['persistence']['storagePid'];
} elseif (isset($settings['module']['tx_epproducts']['persistence']['storagePid'])) { } elseif (isset($settings['module']['tx_epproducts']['persistence']['storagePid'])) {
$this->pid = $settings['module']['tx_epproducts']['persistence']['storagePid']; $this->contingentsPid = $settings['module']['tx_epproducts']['persistence']['storagePid'];
} }
if (isset($settings['plugin']['tx_epproducts']['settings']['hotelsPid'])) {
$this->hotelsPid = $settings['plugin']['tx_epproducts']['settings']['hotelsPid'];
} elseif (isset($settings['module']['tx_epproducts']['settings']['hotelsPid'])) {
$this->hotelsPid = $settings['module']['tx_epproducts']['settings']['hotelsPid'];
}
$this->db = $this->getDbConnection(); $this->db = $this->getDbConnection();
} }
/** /**
* @return int * @return int
*
* @throws \Doctrine\DBAL\DBALException * @throws \Doctrine\DBAL\DBALException
*/ */
public function import() public function import()
@@ -96,6 +109,7 @@ class ContingentImportService implements SingletonInterface, LoggerAwareInterfac
$this->clearTable(); $this->clearTable();
$this->copyTable(); $this->copyTable();
$this->clearTempTable(); $this->clearTempTable();
return $contingentCount; return $contingentCount;
} }
@@ -118,7 +132,7 @@ class ContingentImportService implements SingletonInterface, LoggerAwareInterfac
$path = GeneralUtility::getFileAbsFileName(self::XML_PATH); $path = GeneralUtility::getFileAbsFileName(self::XML_PATH);
$folder = opendir($path); $folder = opendir($path);
while (($fileName = readdir($folder)) !== false) { while (($fileName = readdir($folder)) !== false) {
if (strpos($fileName, 'HotelZimmer') === 0) { if (0 === strpos($fileName, 'HotelZimmer')) {
$dateCount += $this->parseContingentXmlFile($path, $fileName); $dateCount += $this->parseContingentXmlFile($path, $fileName);
} }
} }
@@ -128,6 +142,7 @@ class ContingentImportService implements SingletonInterface, LoggerAwareInterfac
/** /**
* @param string $fileName * @param string $fileName
*
* @return int * @return int
*/ */
public function parseContingentXmlFile($path, $fileName) public function parseContingentXmlFile($path, $fileName)
@@ -150,6 +165,7 @@ class ContingentImportService implements SingletonInterface, LoggerAwareInterfac
/** @var \SimpleXMLElement $xmlData */ /** @var \SimpleXMLElement $xmlData */
if (!$xmlData = simplexml_load_string(file_get_contents($file))) { if (!$xmlData = simplexml_load_string(file_get_contents($file))) {
libxml_clear_errors(); libxml_clear_errors();
return null; return null;
} }
@@ -161,7 +177,7 @@ class ContingentImportService implements SingletonInterface, LoggerAwareInterfac
*/ */
public function createTempTable() public function createTempTable()
{ {
$this->db->exec('CREATE TABLE IF NOT EXISTS tx_epproducts_domain_model_contingent_temp LIKE tx_epproducts_domain_model_contingent'); $this->db->executeStatement('CREATE TABLE IF NOT EXISTS tx_epproducts_domain_model_contingent_temp LIKE tx_epproducts_domain_model_contingent');
} }
/** /**
@@ -169,7 +185,7 @@ class ContingentImportService implements SingletonInterface, LoggerAwareInterfac
*/ */
public function clearTable() public function clearTable()
{ {
$this->db->exec('TRUNCATE TABLE tx_epproducts_domain_model_contingent'); $this->db->executeStatement('TRUNCATE TABLE tx_epproducts_domain_model_contingent');
} }
/** /**
@@ -177,7 +193,7 @@ class ContingentImportService implements SingletonInterface, LoggerAwareInterfac
*/ */
public function copyTable() public function copyTable()
{ {
$this->db->exec('INSERT INTO tx_epproducts_domain_model_contingent SELECT * FROM tx_epproducts_domain_model_contingent_temp'); $this->db->executeStatement('INSERT INTO tx_epproducts_domain_model_contingent SELECT * FROM tx_epproducts_domain_model_contingent_temp');
} }
/** /**
@@ -185,11 +201,10 @@ class ContingentImportService implements SingletonInterface, LoggerAwareInterfac
*/ */
public function clearTempTable() public function clearTempTable()
{ {
$this->db->exec('TRUNCATE TABLE tx_epproducts_domain_model_contingent_temp'); $this->db->executeStatement('TRUNCATE TABLE tx_epproducts_domain_model_contingent_temp');
} }
/** /**
* @param \SimpleXMLElement $xmlContingent
* @return int * @return int
*/ */
protected function parseContingent(\SimpleXMLElement $xmlContingent) protected function parseContingent(\SimpleXMLElement $xmlContingent)
@@ -197,14 +212,14 @@ class ContingentImportService implements SingletonInterface, LoggerAwareInterfac
$hotelCode = (string) $xmlContingent['code']; $hotelCode = (string) $xmlContingent['code'];
$sql = 'SELECT h.uid uid $sql = 'SELECT h.uid uid
FROM tx_epproducts_domain_model_hotel h FROM tx_epproducts_domain_model_hotel h
LEFT JOIN tx_epproducts_domain_model_matchcode m ON (h.uid = m.entity AND m.entity_type = "hotel" AND m.deleted = 0) WHERE h.deleted = 0 AND h.hidden = 0 AND h.code = :code AND h.pid = :pid
WHERE h.deleted = 0 AND h.hidden = 0 AND h.code = :code OR m.code = :code
LIMIT 0,1'; LIMIT 0,1';
$hotelData = $this->db->fetchAssoc($sql, ['code' => $hotelCode]); $hotelData = $this->db->fetchAssociative($sql, ['code' => $hotelCode, 'pid' => $this->hotelsPid]);
// Skip import in case hotel can't be found // Skip import in case hotel can't be found
if ($hotelData === false) { if (false === $hotelData) {
$this->logger->warning('hotel not found', ['code' => $hotelCode]); $this->logger->warning('hotel not found', ['code' => $hotelCode]);
return 0; return 0;
} }
@@ -221,6 +236,7 @@ class ContingentImportService implements SingletonInterface, LoggerAwareInterfac
if (empty($xmlContingent->kapazitaeten)) { if (empty($xmlContingent->kapazitaeten)) {
$this->logger->warning('hotel has no contingents', ['code' => $hotelCode]); $this->logger->warning('hotel has no contingents', ['code' => $hotelCode]);
return 0; return 0;
} }
@@ -231,13 +247,13 @@ class ContingentImportService implements SingletonInterface, LoggerAwareInterfac
/** /**
* @param \SimpleXMLElement $xmlTypes * @param \SimpleXMLElement $xmlTypes
*
* @return array * @return array
*/ */
protected function parseRoomTypes($xmlTypes) protected function parseRoomTypes($xmlTypes)
{ {
$types = []; $types = [];
foreach ($xmlTypes->unterbringung as $xmlType) foreach ($xmlTypes->unterbringung as $xmlType) {
{
$idBusPro = (string) $xmlType['idbuspro']; $idBusPro = (string) $xmlType['idbuspro'];
$code = (string) $xmlType['code']; $code = (string) $xmlType['code'];
$types[] = [ $types[] = [
@@ -246,16 +262,15 @@ class ContingentImportService implements SingletonInterface, LoggerAwareInterfac
'pax' => (int) $xmlType['pax_max'], 'pax' => (int) $xmlType['pax_max'],
'code' => $code, 'code' => $code,
'label' => (string) $xmlType['zimmerbezeichnung'], 'label' => (string) $xmlType['zimmerbezeichnung'],
'ctrl' => $code === self::ROOMCODE_STATUS, 'ctrl' => self::ROOMCODE_STATUS === $code,
]; ];
} }
return $types; return $types;
} }
/** /**
* @param \SimpleXMLElement|\SimpleXMLElement[] $xmlDates * @param \SimpleXMLElement|\SimpleXMLElement[] $xmlDates
* @param array $hotelData
* @param array $roomTypes
* *
* @return int * @return int
*/ */
@@ -277,7 +292,7 @@ class ContingentImportService implements SingletonInterface, LoggerAwareInterfac
} }
$this->calculateContingent($xmlRoom, $roomType, $date, $hotelData); $this->calculateContingent($xmlRoom, $roomType, $date, $hotelData);
} }
$dateCount++; ++$dateCount;
} }
return $dateCount; return $dateCount;
@@ -288,10 +303,10 @@ class ContingentImportService implements SingletonInterface, LoggerAwareInterfac
$availablePax = 0; $availablePax = 0;
$capacity = 0; $capacity = 0;
$status = Contingent::STATUS_OK; $status = Contingent::STATUS_OK;
$isControlRoom = $roomType['ctrl'] === true; $isControlRoom = true === $roomType['ctrl'];
if ($isControlRoom && (string) $xmlRoom['status'] === 'A') { if ($isControlRoom && 'A' === (string) $xmlRoom['status']) {
$status = Contingent::STATUS_ONREQUEST; $status = Contingent::STATUS_ONREQUEST;
} elseif ($isControlRoom && (string) $xmlRoom['status'] === 'S') { } elseif ($isControlRoom && 'S' === (string) $xmlRoom['status']) {
$status = Contingent::STATUS_BLOCKED; $status = Contingent::STATUS_BLOCKED;
} else { } else {
$capacity = (int) $xmlRoom['kontingent'] * (int) $roomType['pax']; $capacity = (int) $xmlRoom['kontingent'] * (int) $roomType['pax'];
@@ -306,7 +321,7 @@ class ContingentImportService implements SingletonInterface, LoggerAwareInterfac
$this->db->insert( $this->db->insert(
'tx_epproducts_domain_model_contingent_temp', 'tx_epproducts_domain_model_contingent_temp',
[ [
'pid' => $this->pid, 'pid' => $this->contingentsPid,
'hotel' => $hotelData['uid'], 'hotel' => $hotelData['uid'],
'hotel_code' => $hotelData['code'], 'hotel_code' => $hotelData['code'],
'hotel_bus_pro_id' => $hotelData['busProId'], 'hotel_bus_pro_id' => $hotelData['busProId'],
public/typo3conf/ext/ep_products/Configuration/TypoScript/setup.typoscript
+1
View File
@@ -25,6 +25,7 @@ plugin.tx_epproducts {
} }
settings { settings {
productsPid = {$plugin.tx_epproducts.settings.productsStoragePid} productsPid = {$plugin.tx_epproducts.settings.productsStoragePid}
hotelsPid = {$plugin.tx_epproducts.settings.hotelsStoragePid}
destinationsStoragePid = {$plugin.tx_epproducts.settings.destinationsStoragePid} destinationsStoragePid = {$plugin.tx_epproducts.settings.destinationsStoragePid}
regionsStoragePid = {$plugin.tx_epproducts.settings.regionsStoragePid} regionsStoragePid = {$plugin.tx_epproducts.settings.regionsStoragePid}
citiesStoragePid = {$plugin.tx_epproducts.settings.citiesStoragePid} citiesStoragePid = {$plugin.tx_epproducts.settings.citiesStoragePid}