DX: Improve Lux address import command - WIP

This commit is contained in:
nobohan 2024-06-28 09:27:45 +02:00
parent d9c50cffb7
commit c5a24e8ac5

View File

@ -42,9 +42,9 @@ class AddressReferenceLU
fclose($file); fclose($file);
$uncompressedStream = gzopen($tmpname, 'r'); //$uncompressedStream = gzopen($tmpname, 'r');
$csv = Reader::createFromStream($uncompressedStream); $csv = Reader::createFromStream($file);
$csv->setDelimiter(';'); $csv->setDelimiter(';');
$csv->setHeaderOffset(0); $csv->setHeaderOffset(0);
@ -54,7 +54,7 @@ class AddressReferenceLU
$this->addressToReferenceMatcher->checkAddressesMatchingReferences(); $this->addressToReferenceMatcher->checkAddressesMatchingReferences();
gzclose($uncompressedStream); //gzclose($uncompressedStream);
} }
private function process_address(Reader $csv): void private function process_address(Reader $csv): void
@ -67,7 +67,7 @@ class AddressReferenceLU
$record['code_postal'], $record['code_postal'],
$record['rue'], $record['rue'],
$record['numero'], $record['numero'],
'bd addresses', 'bd-addresses.lux',
(float) $record['lat_wgs84'], (float) $record['lat_wgs84'],
(float) $record['lon_wgs84'], (float) $record['lon_wgs84'],
4326 4326
@ -82,7 +82,8 @@ class AddressReferenceLU
$stmt = Statement::create()->process($csv); $stmt = Statement::create()->process($csv);
$arr_postal_codes = []; $arr_postal_codes = [];
foreach ($stmt as $record) { foreach ($stmt as $record) {
if (false === \in_array($record['code_postal'], $arr_postal_codes, true)) { //if (false === \in_array($record['code_postal'], $arr_postal_codes, true)) {
if (false === \array_key_exists($record['code_postal'], $arr_postal_codes, true)) {
$this->postalCodeBaseImporter->importCode( $this->postalCodeBaseImporter->importCode(
'LU', 'LU',
trim((string) $record['localite']), trim((string) $record['localite']),
@ -93,7 +94,7 @@ class AddressReferenceLU
(float) $record['lon_wgs84'], (float) $record['lon_wgs84'],
4326 4326
); );
\array_push($arr_postal_codes, $record['code_postal']); $arr_postal_codes[$record['code_postal']] = 1;
} }
} }
} }