<?php include "init.php";
$indice = 500;
$indice2 = 2800;
$contatore = 0;
$quanti = 15000;
$oggi= date("Y-m-d");
$apri_xml = fopen("zip/area4.MDB.XML", "r");
while(!feof($apri_xml))
{
$buffer = ltrim(Chop(fgets($apri_xml, $indice)));
if (($buffer == "<RECORD>") && ($contatore < $quanti))
{ $inserisci=1; $contatore++;
//$salta sono righe con tag che non mi interessano
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
// la data la utilizzo per capire se ci sono state modifiche dall'ultimo aggiornamento sul mio sito
$data = ltrim(Chop(fgets($apri_xml, $indice)));
$data = ereg_replace("<A001 Type= 'Date/Time'>", "", $data);
$data = ereg_replace("</A001>", "", $data);
$data = ltrim($data);
$g=substr($data, 0, 2);
$m=substr($data, 3, 2);
$a=substr($data, 6, 4);
$data= $a.'-'.$m.'-'.$g;
$data2 = ltrim(Chop(fgets($apri_xml, $indice)));
$data2 = ereg_replace("<A002 Type= 'Date/Time'>", "", $data2);
$data2 = ereg_replace("</A002>", "", $data2);
$data2 = ltrim($data2);
$g=substr($data2, 0, 2);
$m=substr($data2, 3, 2);
$a=substr($data2, 6, 4);
$data2= $a.'-'.$m.'-'.$g;
$data3 = ltrim(Chop(fgets($apri_xml, $indice)));
$data3 = ereg_replace("<A003 Type= 'Date/Time'>", "", $data3);
$data3 = ereg_replace("</A003>", "", $data3);
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$tipo = ltrim(Chop(fgets($apri_xml, $indice)));
$tipo=substr($tipo, 9);
if ($tipo!='offerta') $inserisci=0;
//se la tipologia non è quella che mi interessa metto inserisci=0 ed alla fine controllo di non inserirlo nel DB
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$nazione = ltrim(Chop(fgets($apri_xml, $indice)));
$nazione = substr($nazione, 9);
if ($nazione!='ITALIA') $inserisci=0;
//se la nazione non è quella che mi interessa metto inserisci=0 ed alla fine controllo di non inserirlo nel DB
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$provincia = ltrim(Chop(fgets($apri_xml, $indice)));
$query="select * from province where sigla = '$provincia'";
$result = mysql_query($query) or die(mysql_error());
$prov = mysql_fetch_object($result);
$provincia=$prov->nome;
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$comune = ltrim(Chop(fgets($apri_xml, $indice)));
$comune = substr($comune, 9);
$comune=strtolower($comune);
$query="select * from comuni where codice_provincia = '$prov->codice'";
$result = mysql_query($query) or die(mysql_error());
while($comune2 = mysql_fetch_object($result)) {
$comune2_nome= strtolower($comune2->nome);
if ($comune==$comune2_nome) $comune= $comune2->nome;
}
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$zona = ltrim(Chop(fgets($apri_xml, $indice)));
$zona = substr($zona, 9);
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$cap = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$contratto = ltrim(Chop(fgets($apri_xml, $indice)));
$contratto = strtolower($contratto);
$contratto = ucfirst($contratto);
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$prezzo = ltrim(Chop(fgets($apri_xml, $indice)));
$prezzo = ereg_replace("<A014 Type= 'Double'>", "", $prezzo);
$prezzo = ereg_replace("</A014>", "", $prezzo);
$prezzo = ereg_replace(" ", "", $prezzo);
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$tipologia = ltrim(Chop(fgets($apri_xml, $indice)));
$tipologia = substr($tipologia, 9);
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$superficie = ltrim(Chop(fgets($apri_xml, $indice)));
$superficie = ereg_replace("<A018 Type= 'Double'>", "", $superficie);
$superficie = ereg_replace("</A018>", "", $superficie);
$superficie = ereg_replace(" ", "", $superficie);
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$descrizione = ltrim(Chop(fgets($apri_xml, $indice2)));
$descrizione2 = substr($descrizione, 0, 9);
if($descrizione2!='<![CDATA[')
$descrizione = ltrim(Chop(fgets($apri_xml, $indice2)));
$descrizione = substr($descrizione, 9);
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$nome_agenzia = ltrim(Chop(fgets($apri_xml, $indice)));
$nome_agenzia = substr($nome_agenzia, 9);
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$indirizzo = ltrim(Chop(fgets($apri_xml, $indice)));
$indirizzo = substr($indirizzo, 9);
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$comune_agenzia = ltrim(Chop(fgets($apri_xml, $indice)));
$comune_agenzia = substr($comune_agenzia, 9);
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$provincia_agenzia = ltrim(Chop(fgets($apri_xml, $indice)));
$query="select * from province where sigla = '$provincia_agenzia'";
$result = mysql_query($query) or die(mysql_error());
$prov = mysql_fetch_object($result);
$provincia_agenzia=$prov->nome;
$comune_agenzia=strtolower($comune_agenzia);
$query="select * from comuni where codice_provincia = '$prov->codice'";
$result = mysql_query($query) or die(mysql_error());
while($comune2 = mysql_fetch_object($result)) {
$comune2_nome= strtolower($comune2->nome);
if ($comune_agenzia==$comune2_nome) $comune_agenzia= $comune2->nome;
}
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$cap_agenzia = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$tel = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$fax = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$sito = ltrim(Chop(fgets($apri_xml, $indice)));
$sito = substr($sito, 4);
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$email = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$rif = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$id_agenzia = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$riservato = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$prima_img = ltrim(Chop(fgets($apri_xml, $indice)));
$path=substr($prima_img, 0, -5);
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$n_img = ltrim(Chop(fgets($apri_xml, $indice)));
$n_img = ereg_replace("<A080 Type= 'Integer'>", "", $n_img);
$n_img = ereg_replace("</A080>", "", $n_img);
$n_img = ereg_replace(" ", "", $n_img);
if($n_img>5) $n_img = 5;
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$id = ltrim(Chop(fgets($apri_xml, $indice)));
$query="select * from immobili where id_x= {$id}";
$result = mysql_query($query) or die(mysql_error());
$immobile = mysql_fetch_object($result);
if(($immobile)&&($immobile->modifica==$data2)) $inserisci=0;
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
$salta = ltrim(Chop(fgets($apri_xml, $indice)));
if($inserisci==1) { echo 'inserito<br>';
$a=0;
$query="select * from registrazioni where (id_x != 'NULL')&&(id_x != '0')";
$result = mysql_query($query) or die(mysql_error());
while ($agente = mysql_fetch_object($result)){
if($id_agenzia==$agente->id_x)
//il registrato è già presente nel DB, non è nuovo
$a=1; }
if ($a==0) {
//se il registrato non esiste nel DB, la inserisco
$query = "INSERT INTO registrazioni (registrato,nome,indirizzo,cap,provincia,comune,tel,fax,email,sito,date,id_immobilia2000) VALUES ( 'agente',"
.sql_string(trim($nome_agenzia)).","
.sql_string(trim($indirizzo)).","
.sql_string(trim($cap_agenzia)).","
.sql_string(trim($provincia_agenzia)).","
.sql_string(trim($comune_agenzia)).","
.sql_string(trim($tel)).","
.sql_string(trim($fax)).","
.sql_string(trim($email)).","
.sql_string(trim($sito)).","
.sql_string(trim($oggi)).","
.sql_string(trim($id_agenzia))." )";
$row_set = mysql_query($query, $conn) or die("Errore nella query di inserimento: " . mysql_error());
$cid = mysql_insert_id($conn); }
else {
$query="select * from registrazioni where id_x = '$id_agenzia'";
$result = mysql_query($query) or die(mysql_error());
$agente = mysql_fetch_object($result);
$cid=$agente->id;
}
$i=0;
$query="select * from immobili where (id_x != 'NULL')&&(id_immobilia2000 != '0')";
$result = mysql_query($query) or die(mysql_error());
while ($immobile = mysql_fetch_object($result)){
if($id==$immobile->id_x)
//l'offerta è già presente nel DB, non è nuova, forse da aggiornare
$i=1; }
if ($i==0) {
/l'offerta è nuova, la inserisco nel DB
$query = "INSERT INTO immobili (provincia,comune,zona,descrizione,prezzo,superficie,tipologia,cessione,contratto,id_registrato,registrato,pubblicato,date,modifica,n_foto,id_immobilia2000) VALUES ( "
.sql_string(trim($provincia)).","
.sql_string(trim($comune)).","
.sql_string(trim($zona)).","
.sql_string(trim($descrizione)).","
.sql_numeric(trim($prezzo)).","
.sql_numeric(trim($superficie)).","
.sql_string(trim($tipologia)).","
.sql_string(trim($cessione)).","
.sql_string(trim($contratto)).","
.sql_string(trim($cid)).", 'agente', 1, "
.sql_string(trim($data)).","
.sql_string(trim($data2)).","
.sql_numeric(trim($n_img)).","
.sql_string(trim($id))." )";
$row_set = mysql_query($query, $conn) or die("Errore nella query di inserimento: " . mysql_error());
$id_immobile = mysql_insert_id($conn);
//inserisco anche le foto
for ( $k = 1; $k <= $n_img; $k++)
{ $path_ok= $path.$k.'.jpg';
$query = "INSERT INTO `photo` VALUES (NULL, '{$path_ok}', {$id_immobile})";
$row_set = mysql_query($query, $conn);
}
} else {
//se l'offerta non è nuova la aggiorno se la data di ultima modifica "data2" è maggiore della data dell'ultimo aggiornamento
$query="select * from immobili where id_x = '$id'";
$result = mysql_query($query) or die(mysql_error());
$immobile = mysql_fetch_object($result);
$data_m=$immobile->modifica;
$data_m= convertiData($data_m);
if($data2>$data_m){
$query = "UPDATE `immobili` SET `provincia` = '{$provincia}',`comune` = '{$comune}',`zona` = '{$zona}',`descrizione` = '{$descrizione}',`prezzo` = '{$prezzo}',`superficie` = '{$superficie}',`tipologia` = '{$tipologia}',`cessione` = '{$cessione}',`contratto` = '{$contratto}',`id_registrato` = '{$cid}',`registrato` = 'agente',`pubblicato` = 1 ,`date` = '$data',`modifica` = '$data2',`n_foto` = '{$n_img}' WHERE `id_x` = '$id'";
$row_set = mysql_query($query, $conn) or die("Errore nella query di aggiornamento: " . mysql_error());
$query="select * from photo where id_immobile = '{$immobile->id}'";
$result = mysql_query($query) or die(mysql_error());
while($photo = mysql_fetch_object($result)) {
$query2= "DELETE FROM photo where id={$photo->id}";
$delete2= mysql_query($query2, $conn) or die("Errore nella query: $query " . mysql_error());;
}
$k=1;
while($k<=$n_img) {
// for ( $k = 1; $k <= $n_img; $k++)
//{
$path_ok= $path.$k.'.jpg';
$query = "INSERT INTO `photo` VALUES (NULL, '{$path_ok}', {$immobile->id})";
$row_set = mysql_query($query, $conn);
$k++;
}
}
}
} else echo 'saltato<br>';
}
}
echo $contatore;
fclose($apri_xml);