diff --git a/system/sync/stp/sync_stp_vilesci_adressen.php b/system/sync/stp/sync_stp_vilesci_adressen.php index be47de1f4..6964c9b4c 100644 --- a/system/sync/stp/sync_stp_vilesci_adressen.php +++ b/system/sync/stp/sync_stp_vilesci_adressen.php @@ -234,6 +234,7 @@ if($result = pg_query($conn, $qry)) NULL, now(), 'sync', now(), 'sync', NULL);"; if(!$result_neu = pg_query($conn, $sql)) { + $fehler++; $error_log.= $sql."\n".pg_last_error($conn)." \n"; pg_query($conn, "ROLLBACK"); } @@ -334,9 +335,13 @@ if($result = pg_query($conn, $qry)) if(strlen(trim($sql))>0) { - $sql="UPDATE public.tbl_adresse SET ".$sql." WHERE person_id='".$person_id."';"; + $sql="UPDATE public.tbl_adresse SET ".$sql." + WHERE person_id='".$person_id."' + AND trim(strasse)='".trim(trim(addslashes($row->chstrasse))." ".trim($row->chhausnr))."' + AND plz='".$row->chplz."' AND trim(ort)='".trim(addslashes($row->chort))."';"; if(!$result_neu = pg_query($conn, $sql)) { + $fehler++; $error_log.= "\n".$sql."\n".pg_last_error($conn)." \n"; pg_query($conn, "ROLLBACK"); } @@ -349,11 +354,19 @@ if($result = pg_query($conn, $qry)) pg_query($conn, "COMMIT"); } } + else + { + //$ausgabe.="\n------------------------------------\nGeändert: ".$row->_person." - ".trim($row->chtitel)." ".trim($row->chnachname).", ".trim($row->chvorname); + //$ausgabe.="\n---Adresse: ".$row_dubel->strasse.", ".$row_dubel->plz.", ".$row_dubel->ort.", ".$row_dubel->nation.", Typ: ".$row_dubel->typ; + //$ausgabe.="\n--->bereits vorhanden. keine Änderung."; + $dublette++; + } } } } else { + $fehler++; $error_log.= "\n".$sql."\n".pg_last_error($conn)." \n"; pg_query($conn, "ROLLBACK"); } @@ -361,6 +374,7 @@ if($result = pg_query($conn, $qry)) } else { + $fehler++; echo "
".$qry."
".pg_last_error($conn)."
"; } @@ -368,7 +382,10 @@ else echo "

Eingefügt: ".$eingefuegt; echo "
Updates: ".$updates; +echo "
Doppelt: ".$dublette; echo "
Fehler: ".$fehler; +//echo "

Summe: ".($eingefuegt+$updates+$dublette+$fehler); + echo "

"; if($error_log=='' && $log_updates=='') {