From 0f86a9484c3114d7b4f8bd129d4a89a42bb89890 Mon Sep 17 00:00:00 2001 From: Rudolf Hangl Date: Thu, 22 Mar 2007 15:51:35 +0000 Subject: [PATCH] --- .../sync/fas/sync_fas_vilesci_mitarbeiter.php | 55 ++++--- admin/sync/fas/sync_fas_vilesci_student.php | 142 ++++++++++++------ 2 files changed, 127 insertions(+), 70 deletions(-) diff --git a/admin/sync/fas/sync_fas_vilesci_mitarbeiter.php b/admin/sync/fas/sync_fas_vilesci_mitarbeiter.php index 9da4056ce..aa6f793e4 100644 --- a/admin/sync/fas/sync_fas_vilesci_mitarbeiter.php +++ b/admin/sync/fas/sync_fas_vilesci_mitarbeiter.php @@ -298,7 +298,7 @@ AND (p1.person_pk <> p2.person_pk) AND (p1.svnr<>'0005010400' AND p2.svnr<>'0005010400') AND (p1.familienname<>p2.familienname OR p1.vorname<>p2.vorname OR p1.vornamen<>p2.vornamen OR p1.geschlecht<>p2.geschlecht OR p1.gebdat<>p2.gebdat OR p1.gebort<>p2.gebort OR p1.staatsbuergerschaft<> p2.staatsbuergerschaft OR p1.familienstand<>p2.familienstand OR p1.svnr<>p2.svnr OR p1.ersatzkennzeichen<>p2.ersatzkennzeichen OR p1.anrede<>p2.anrede OR p1.anzahlderkinder<>p2.anzahlderkinder OR p1.titel<>p2.titel OR p1.gebnation<>p2.gebnation OR p1.postnomentitel<> p2.postnomentitel OR p1.beginndatum<>p2.beginndatum OR p1.akadgrad<>p2.akadgrad OR p1.habilitation<>p2.habilitation OR p1.mitgliedentwicklungsteam<>p2.mitgliedentwicklungsteam OR p1.qualifikation<>p2.qualifikation OR p1.hauptberuflich<>p2.hauptberuflich OR p1.hauptberuf<>p2.hauptberuf OR p1.semesterwochenstunden<>p2.semesterwochenstunden OR p1.persnr<>p2.persnr OR p1.beendigungsdatum<>p2.beendigungsdatum OR p1.ausgeschieden<>p2.ausgeschieden OR p1.kurzbez<>p2.kurzbez OR p1.stundensatz<>p2.stundensatz OR p1.ausbildung<>p2.ausbildung OR p1.aktiv<>p2.aktiv) -);"; +) ORDER BY p1.familienname;"; if($resultall = pg_query($conn_fas, $qryall)) { @@ -337,7 +337,7 @@ if($resultall = pg_query($conn_fas, $qryall)) $persongeschlecht=strtolower($rowall->geschlecht); $personext_id=$rowall->person_pk; $personaktiv=true; - $personupdatevon='SYNC'; + $personupdatevon=$rowall->creationuser; $personinsertvon='SYNC'; $personupdateamum=$rowall->creationdate; $personinsertvon=$rowall->creationdate; @@ -374,7 +374,7 @@ if($resultall = pg_query($conn_fas, $qryall)) $mitarbeiterkurzbz=trim($rowall->kurzbez); $mitarbeiterlektor=true; $mitarbeiterfixangestellt=($rowall->hauptberuflich=='J'?true:false); - $mitarbeiterstundensatz=0; + $mitarbeiterstundensatz=$rowall->stundensatz; if($rowall->ausbildung>0) { $mitarbeiterausbildungcode=$rowall->ausbildung; @@ -385,7 +385,7 @@ if($resultall = pg_query($conn_fas, $qryall)) } $mitarbeiterort_kurzbz=null; $mitarbeiteranmerkung=$rowall->bemerkung; - $mitarbeiterinsertvon='SYNC'; + $mitarbeiterinsertvon=$rowall->creationuser; $mitarbeiterinsertamum=$rowall->creationdate; $mitarbeiterupdateamum=$rowall->creationdate; $mitarbeiterupdatevon='SYNC'; @@ -398,7 +398,7 @@ if($resultall = pg_query($conn_fas, $qryall)) $benutzerperson_id=''; $benutzeraktiv=($rowall->aktiv=='t'?true:false); $benutzeralias=''; - $benutzerinsertvon='SYNC'; + $benutzerinsertvon=$rowall->creationuser; $benutzerinsertamum=$rowall->creationdate; $benutzerupdateamum=$rowall->creationdate; $benutzerupdatevon='SYNC'; @@ -504,9 +504,9 @@ if($resultall = pg_query($conn_fas, $qryall)) myaddslashes($personanzahlkinder).", ". myaddslashes($personaktiv?'true':'false').", ". myaddslashes($personinsertamum).", ". - myaddslashes($personinsertvon).", ". - myaddslashes($personupdateamum).", ". - myaddslashes($personupdatevon).", ". + myaddslashes($personinsertvon).", + now(), + 'SYNC', ". myaddslashes($persongeschlecht).", ". myaddslashes($persongeburtsnation).", ". myaddslashes($personstaatsbuergerschaft).", ". @@ -769,7 +769,7 @@ if($resultall = pg_query($conn_fas, $qryall)) anzahlkinder=".myaddslashes($personanzahlkinder).", aktiv=".myaddslashes($personaktiv?'true':'false').", updateamum=now(), - updatevon=".myaddslashes($personupdatevon).", + updatevon='SYNC', geschlecht=".myaddslashes($persongeschlecht).", geburtsnation=".myaddslashes($persongeburtsnation).", staatsbuergerschaft=".myaddslashes($personstaatsbuergerschaft).", @@ -834,9 +834,9 @@ if($resultall = pg_query($conn_fas, $qryall)) myaddslashes($benutzeralias).", ". myaddslashes($personperson_id).", ". myaddslashes($benutzerinsertamum).", ". - myaddslashes($benutzerinsertvon).", ". - myaddslashes($benutzerupdateamum).", ". - myaddslashes($benutzerupdatevon).");"; + myaddslashes($benutzerinsertvon).", + now() , + 'SYNC');"; $ausgabe_benutzer="Benutzer ".$benutzeruid." ".$benutzeralias." eingefügt.\n"; } else @@ -879,7 +879,7 @@ if($resultall = pg_query($conn_fas, $qryall)) aktiv=".myaddslashes($benutzeraktiv?'true':'false').", person_id=".myaddslashes($personperson_id).", updateamum=now(), - updatevon=".myaddslashes($benutzerupdatevon)." + updatevon='SYNC' WHERE uid='$benutzeruid';"; $ausgabe_benutzer="Änderungen bei Benutzer ".$benutzeruid." ".$benutzeralias.": ".$ausgabe_benutzer."\n"; } @@ -937,7 +937,7 @@ if($resultall = pg_query($conn_fas, $qryall)) { //Neuen Datensatz anlegen - $qry = "INSERT INTO public.tbl_mitarbeiter(mitarbeiter_uid, ausbildungcode, personalnummer, kurzbz, lektor, ort_kurzbz, fixangestellt, telefonklappe, anmerkung, updateamum, updatevon, insertamum, insertvon, ext_id) VALUES(". + $qry = "INSERT INTO public.tbl_mitarbeiter(mitarbeiter_uid, ausbildungcode, personalnummer, kurzbz, lektor, ort_kurzbz, fixangestellt, telefonklappe,stundensatz, anmerkung, updateamum, updatevon, insertamum, insertvon, ext_id) VALUES(". myaddslashes($mitarbeiteruid).", ". myaddslashes($mitarbeiterausbildungcode).", ". myaddslashes($mitarbeiterpersonalnummer)." , ". @@ -946,10 +946,11 @@ if($resultall = pg_query($conn_fas, $qryall)) myaddslashes($mitarbeiterort_kurzbz).", ". myaddslashes($mitarbeiterfixangestellt?'true':'false').", ". myaddslashes($mitarbeitertelefonklappe)." , ". - myaddslashes($mitarbeiteranmerkung).", ". + myaddslashes($mitarbeiterstundensatz)." , ". + myaddslashes($mitarbeiteranmerkung).", + now(), + 'SYNC' ,". myaddslashes($mitarbeiterinsertamum).", ". - myaddslashes($mitarbeiterupdatevon)." , ". - myaddslashes($mitarbeiterupdateamum).", ". myaddslashes($mitarbeiterinsertvon)." , ". myaddslashes($mitarbeiterext_id).");"; $ausgabe_mitarbeiter="Mitarbeiter ".$mitarbeiterpersonalnummer." ".$mitarbeiterkurzbz." eingefügt.\n"; @@ -999,6 +1000,18 @@ if($resultall = pg_query($conn_fas, $qryall)) $ausgabe_mitarbeiter="Kurzbezeichnung: '".$mitarbeiterkurzbz."'"; } } + if($rowu->stundensatz!=$mitarbeiterstundensatz) + { + $updatem=true; + if(strlen(trim($ausgabe_mitarbeiter))>0) + { + $ausgabe_mitarbeiter.=", Stundensatz: '".$mitarbeiterstundensatz."'"; + } + else + { + $ausgabe_mitarbeiter="Stundensatz: '".$mitarbeiterstundensatz."'"; + } + } if($rowu->telefonklappe!=$mitarbeitertelefonklappe) { $updatem=true; @@ -1043,11 +1056,12 @@ if($resultall = pg_query($conn_fas, $qryall)) ausbildungcode=".myaddslashes($mitarbeiterausbildungcode).", personalnummer=".myaddslashes($mitarbeiterpersonalnummer).", kurzbz=".myaddslashes($mitarbeiterkurzbz).", - telefonklappe=".myaddslashes($mitarbeitertelefonklappe).", + telefonklappe=".myaddslashes($mitarbeitertelefonklappe).", + stundensatz=".myaddslashes($mitarbeiterstundensatz).", ort_kurzbz=".myaddslashes($mitarbeiterort_kurzbz).", anmerkung=".myaddslashes($mitarbeiteranmerkung).", updateamum=now(), - updatevon=".myaddslashes($mitarbeiterupdatevon).", + updatevon='SYNC', ext_id=".myaddslashes($mitarbeiterext_id)." WHERE mitarbeiter_uid='$mitarbeiteruid';"; $ausgabe_mitarbeiter="Änderungen bei Mitarbeiter ".$mitarbeiteruid.": ".$ausgabe_mitarbeiter."\n"; @@ -1152,9 +1166,10 @@ echo nl2br("\n=====\n".$ausgabe); $ausgabe="Mitarbeiter Sync\n----------------\n\nGesamt FAS: $anzahl_quelle\nPerson: Eingefügt: $anzahl_eingefuegt_person / geaendert: $anzahl_geaendert_person / Fehler: $anzahl_fehler_person" ."\nBenutzer: Eingefügt: $anzahl_eingefuegt_benutzer / geaendert: $anzahl_geaendert_benutzer / Fehler: $anzahl_fehler_benutzer" ."\nMitarbeiter: Eingefügt: $anzahl_eingefuegt_mitarbeiter / geaendert: $anzahl_geaendert_mitarbeiter / Fehler: $anzahl_fehler_mitarbeiter.\n\n".$ausgabe; -$error_log="\n\n\nFehler:\n$error_log"; + if(strlen(trim($error_log))>0) { + $error_log="\n\n\nFehler:\n$error_log"; mail($adress, 'SYNC-Fehler Mitarbeiter von '.$_SERVER['HTTP_HOST'], $error_log,"From: vilesci@technikum-wien.at"); } mail($adress, 'SYNC Mitarbeiter von '.$_SERVER['HTTP_HOST'], $ausgabe,"From: vilesci@technikum-wien.at"); diff --git a/admin/sync/fas/sync_fas_vilesci_student.php b/admin/sync/fas/sync_fas_vilesci_student.php index f09b32dd7..e67fd4448 100644 --- a/admin/sync/fas/sync_fas_vilesci_student.php +++ b/admin/sync/fas/sync_fas_vilesci_student.php @@ -17,6 +17,7 @@ $conn_fas=pg_connect(CONN_STRING_FAS) or die("Connection zur FAS Datenbank fehlg $error_log=''; $text = ''; +$plausiueb=''; $dateiausgabe=''; //$dateiausgabe=fopen('sync_fas_vilesci_student_ausgabe.txt','w'); //fwrite($dateiausgabe,"Ausgabe der Studentensynchro vom ".date("d.m.Y H:i:s")." von ".$_SERVER['HTTP_HOST']."\n\n"); @@ -64,8 +65,8 @@ foreach ($studiengangfk AS $stg) } set_time_limit(60); -//$adress='ruhan@technikum-wien.at'; -$adress='fas_sync@technikum-wien.at'; +$adress='ruhan@technikum-wien.at'; +//$adress='fas_sync@technikum-wien.at'; function myaddslashes($var) { @@ -84,9 +85,9 @@ function myaddslashes($var) '') OR ((p1.svnr<>p2.svnr OR p1.svnr IS NOT NULL OR p1.svnr<>'') AND p1.familienname=p2.familienname AND p1.familienname IS NOT NULL AND p1.familienname!='' AND p1.gebdat=p2.gebdat AND p1.gebdat IS NOT NULL AND p1.gebdat>'1935-01-01' AND p1.gebdat<'2000-01-01')) -AND (p1.person_pk < p2.person_pk) AND (p1.studiengang_fk=p2.studiengang_fk) +AND (p1.person_pk < p2.person_pk) AND (p1.svnr<>'0005010400' AND p2.svnr<>'0005010400') AND (trim(p1.familienname)<>trim(p2.familienname) OR trim(p1.vorname)<>trim(p2.vorname) OR trim(p1.vornamen)<>trim(p2.vornamen) OR p1.geschlecht<>p2.geschlecht OR p1.gebort<>p2.gebort @@ -380,6 +385,7 @@ foreach ($studiengangfk AS $stg) { if(strlen(trim($error_log_fas[$stg]))>0) { + $errro_log_fas[$stg]=$plausiueb.$error_log_fas[$stg]; //mail(trim($rowass->email), 'Plausicheck von Studenten / Studiengang: '.$stg, $error_log_fas[$stg],"From: vilesci@technikum-wien.at"); mail($adress, 'Plausicheck von Studenten / Studiengang: '.$stg.", von ".$_SERVER['HTTP_HOST'], $error_log_fas[$stg],"From: vilesci@technikum-wien.at"); } @@ -406,7 +412,7 @@ FROM (person JOIN student ON person_pk=student.person_fk ) AS p1 CROSS JOIN (person JOIN student ON person_pk=student.person_fk) AS p2 WHERE ((p1.gebdat=p2.gebdat AND p1.familienname=p2.familienname AND p1.vorname=p2.vorname) OR ((p1.ersatzkennzeichen=p2.ersatzkennzeichen AND p1.ersatzkennzeichen<>'') OR (p1.svnr=p2.svnr AND p1.svnr<>''))) -AND (p1.person_pk <> p2.person_pk) AND (p1.studiengang_fk=p2.studiengang_fk) +AND (p1.person_pk <> p2.person_pk) AND ((p1.svnr=p2.svnr AND p1.svnr IS NOT NULL AND p1.svnr<>'') OR (p1.svnr<>p2.svnr AND p1.svnr IS NOT NULL AND p1.svnr<>'' AND p1.familienname=p2.familienname AND p1.familienname IS NOT NULL AND p1.familienname!='' AND p1.gebdat=p2.gebdat AND p1.gebdat IS NOT NULL AND p1.gebdat>'1935-01-01' AND p1.gebdat<'2000-01-01')) @@ -623,14 +629,14 @@ if($result = pg_query($conn_fas, $qry)) { $error_log = "Geschlecht muß entweder w oder m sein!: ".$nachname.", ".$vorname."\n"; } - if(strlen($uid)>16) + if(strlen($student_uid)>16) { $error_log = 'UID darf nicht laenger als 16 Zeichen sein. : '.$nachname.", ".$vorname."\n"; } - if($uid == '') + /*if($student_uid == '') { $error_log = 'UID muss eingegeben werden '.$nachname.", ".$vorname."\n"; - } + }*/ if(strlen($alias)>256) { $error_log = 'Alias darf nicht laenger als 256 Zeichen sein '.$nachname.", ".$vorname."\n"; @@ -722,7 +728,6 @@ if($result = pg_query($conn_fas, $qry)) $error_log.='Fehler beim Abfragen des aktuellen Status bei student_pk: '.$row->student_pk; echo nl2br('Fehler beim Abfragen des aktuellen Status bei student_pk: '.$row->student_pk); } - //Start der Transaktion pg_query($conn,'BEGIN;'); @@ -1488,26 +1493,7 @@ if($result = pg_query($conn_fas, $qry)) { //Weitere Reihenfolge: benutzer, student - //Student schon vorhanden? - $qry="SELECT student_uid FROM public.tbl_student WHERE student_uid='$student_uid'"; - if($resultu = pg_query($conn, $qry)) - { - if(pg_num_rows($resultu)>0) //wenn dieser eintrag schon vorhanden ist - { - if($rowu=pg_fetch_object($resultu)) - { - $student_uid=$rowu->student_uid; - $new_student=false; - } - else $new_student=true; - } - else $new_student=true; - } - else - { - $error=true; - $error_log.='Fehler beim Zugriff auf Tabelle tbl_student bei student_pk: '.$ext_id_student."\n".pg_errormessage($conn)."\n"; - } + //Gruppenverband ermitteln $qry="SELECT fas_function_find_verband_from_student(".$ext_id_student.") AS verband, @@ -1536,7 +1522,7 @@ if($result = pg_query($conn_fas, $qry)) { $gruppe=$rowu->gruppe; } - if($aktiv==false && $student_uid<>'' && $student_uid!=null && isset($student_uid)) + if(!$aktiv && $student_uid<>'' && $student_uid!=null && isset($student_uid) && $matrikelnr<>'' && $matrikelnr!=null && isset($matrikelnr)) { $semester='10'; } @@ -1553,7 +1539,6 @@ if($result = pg_query($conn_fas, $qry)) myaddslashes($verband).', '. myaddslashes($gruppe).', '. 'true, null , null );'; - $ausgabe_pre.="Semester: ".$semester.", Verband: ".$verband.", Gruppe: ".$gruppe."\n"; pg_query($conn, $qry); } @@ -1568,7 +1553,6 @@ if($result = pg_query($conn_fas, $qry)) myaddslashes($semester).', '. myaddslashes($verband).', '. "'', true, null, null);"; - //$ausgabe_pre.="Semester: ".$semester.", Verband: ".$verband.", Gruppe: ".$gruppe."\n"; pg_query($conn, $qry); } } @@ -1581,7 +1565,6 @@ if($result = pg_query($conn_fas, $qry)) VALUES('.myaddslashes($studiengang_kz).', '. myaddslashes($semester).', '. "'', '', true, null, null);"; - //$ausgabe_pre.="Semester: ".$semester.", Verband: ".$verband.", Gruppe: ".$gruppe."\n"; pg_query($conn, $qry); } } @@ -1637,15 +1620,15 @@ if($result = pg_query($conn_fas, $qry)) and $verband!=null and $gruppe!=null) { //Benutzer schon vorhanden? - $qry="SELECT uid, person_id FROM public.tbl_benutzer WHERE person_id='$person_id'"; + $qry="SELECT uid, person_id, ext_id FROM public.tbl_benutzer WHERE person_id='$person_id' AND uid='$student_uid'"; if($resultu = pg_query($conn, $qry)) { if(pg_num_rows($resultu)>0) //wenn dieser eintrag schon vorhanden ist { if($rowu=pg_fetch_object($resultu)) { - $new_benutzer=false; - $uid=$rowu->uid; + $new_benutzer=false; + //$ext_id_benutzer=$rowu->ext_id; } else $new_benutzer=true; } @@ -1656,6 +1639,28 @@ if($result = pg_query($conn_fas, $qry)) $error=true; $error_log.='Fehler beim Zugriff auf Tabelle tbl_benutzer bei person_id: '.$person_id."\n".pg_errormessage($conn)."\n"; } + //Student schon vorhanden? + $qry="SELECT student_uid FROM public.tbl_student WHERE student_uid='$student_uid'"; + if($resultu = pg_query($conn, $qry)) + { + if(pg_num_rows($resultu)>0) //wenn dieser eintrag schon vorhanden ist + { + if($rowu=pg_fetch_object($resultu)) + { + //$student_uid=$rowu->student_uid; + $new_student=false; + } + else $new_student=true; + } + else $new_student=true; + } + else + { + $error=true; + $error_log.='Fehler beim Zugriff auf Tabelle tbl_student bei student_pk: '.$ext_id_student."\n".pg_errormessage($conn)."\n"; + } + + if($new_benutzer) { //insert benutzer @@ -1669,7 +1674,7 @@ if($result = pg_query($conn_fas, $qry)) myaddslashes($updateamum).','. "'SYNC'".', '. myaddslashes($ext_id_benutzer).'); '; - $ausgabe_benutzer="Benutzer ".$benutzeruid." ".$benutzeralias." eingefügt.\n"; + $ausgabe_benutzer="Benutzer ".$student_uid." ".$alias." eingefügt.\n"; } else @@ -1686,25 +1691,60 @@ if($result = pg_query($conn_fas, $qry)) //update nur wenn änderungen gemacht - $qry="SELECT * FROM public.tbl_benutzer WHERE ext_id='$ext_id_benutzer';"; + $qry="SELECT * FROM public.tbl_benutzer WHERE person_id='$person_id' AND uid='$student_uid'"; if($results = pg_query($conn, $qry)) { while($rows = pg_fetch_object($results)) { - $updateb=false; + $updateb=false; + if($rows->uid!=$student_uid) + { + $updateb=true; + if(strlen(trim($ausgabe_benutzer))>0) + { + $ausgabe_benutzer.=", UID: '".$student_uid."' statt('".$rows->uid."')"; + } + else + { + $ausgabe_benutzer="UID: '".$student_uid."' statt('".$rows->uid."')"; + } + } + if($rows->person_id!=$person_id) + { + $updateb=true; + if(strlen(trim($ausgabe_benutzer))>0) + { + $ausgabe_benutzer.=", Person_ID: '".$person_id."' statt('".$rows->person_id."')"; + } + else + { + $ausgabe_benutzer="Person_ID: '".$person_id."' statt('".$rows->person_id."')"; + } + } if($rows->aktiv!=($aktiv?'t':'f')) { $updateb=true; if(strlen(trim($ausgabe_benutzer))>0) { - $ausgabe_benutzer.=", Aktiv: '".($aktiv?'true':'false')."'"; + $ausgabe_benutzer.=", Aktiv: '".($aktiv?'true':'false')."' statt ('".($rows->aktiv?'true':'false')."')"; } else { - $ausgabe_benutzer="Aktiv: '".($aktiv?'true':'false')."'"; + $ausgabe_benutzer="Aktiv: '".($aktiv?'true':'false')."' statt ('".($rows->aktiv?'true':'false')."')"; } } - + if($rows->ext_id!=$ext_id_benutzer) + { + $updateb=true; + if(strlen(trim($ausgabe_benutzer))>0) + { + $ausgabe_benutzer.=", Ext_ID: '".$ext_id_benutzer."' statt('".$rows->ext_id."')"; + } + else + { + $ausgabe_benutzer="Ext_ID: '".$ext_id_benutzer."' statt('".$rows->ext_id."')"; + } + } if($updateb) { $qry = 'UPDATE public.tbl_benutzer SET'. @@ -1712,9 +1752,10 @@ if($result = pg_query($conn_fas, $qry)) ' person_id='.myaddslashes($person_id).','. ' aktiv='.($aktiv?'true':'false').','. " updateamum=now()".','. - " updatevon=".myaddslashes($updatevon). - ' WHERE ext_id='.myaddslashes($ext_id_benutzer).';'; - $ausgabe_benutzer="Änderungen bei Benutzer ".$benutzeruid." ".$benutzeralias.": ".$ausgabe_benutzer.".\n"; + " updatevon=".myaddslashes($updatevon).', '. + " ext_id=".myaddslashes($ext_id_benutzer). + " WHERE person_id='$person_id' AND uid='$student_uid'"; + $ausgabe_benutzer="Änderungen bei Benutzer ".$student_uid." ".$alias.": ".$ausgabe_benutzer.".\n"; } } } @@ -1864,7 +1905,7 @@ if($result = pg_query($conn_fas, $qry)) } } } - if(!pg_query($conn,$qry)) + if(!@pg_query($conn,$qry)) { $error=true; $error_log.='Fehler beim Speichern des Student-Datensatzes:'.$nachname.' / '.$qry."\n".pg_errormessage($conn)."\n"; @@ -1890,7 +1931,7 @@ if($result = pg_query($conn_fas, $qry)) $ausgabe.=$ausgabe_benutzer; $ausgabe.=$ausgabe_student; //fwrite($dateiausgabe,$ausgabe); - $ausgabe=''; + //$ausgabe=''; pg_query($conn,'COMMIT;'); } else @@ -1925,9 +1966,9 @@ if($result = pg_query($conn_fas, $qry)) $text.="\n".$qry." C1\n"; $text.="***********\n\n"; } - //$ausgabe.=$ausgabe_person; + $ausgabe.=$ausgabe_person; //fwrite($dateiausgabe,$ausgabe); - $ausgabe=''; + //$ausgabe=''; pg_query($conn,'COMMIT;'); //Commit, wenn kein Gruppeneintrag gefunden (Interessent, Bewerber) => nur Person und Prestudent werden angelegt } @@ -1972,6 +2013,7 @@ mail($adress, 'SYNC-Fehler Student von '.$_SERVER['HTTP_HOST'], $error_log,"From ."Benutzer: Gesamt: ".$anzahl_benutzer_gesamt." / Eingefügt: ".$anzahl_benutzer_insert." / Geändert: ".$anzahl_benutzer_update." / Fehler: ".$anzahl_fehler_benutzer."\n" ."Nicht-Studenten: ".$anzahl_nichtstudenten."\n" ."Studenten: Gesamt: ".$anzahl_student_gesamt." / Eingefügt: ".$anzahl_student_insert." / Geändert: ".$anzahl_student_update." / Fehler: ".$anzahl_fehler_student); +fwrite($dateiausgabe,"Fertig: ".date("d.m.Y H:i:s")."\n\n"); fclose($dateiausgabe);*/ mail($adress, 'SYNC Student von '.$_SERVER['HTTP_HOST'], "Sync Student\n------------\n\nPersonen ohne Reihungstest: ".$notest." \n\n"