This commit is contained in:
Rudolf Hangl
2007-07-03 15:28:29 +00:00
parent 855bcda5a1
commit 8743be22e2
10 changed files with 161 additions and 132 deletions
+12 -8
View File
@@ -11,15 +11,16 @@
//*
//*
include('../../../vilesci/config.inc.php');
include('../../../include/adresse.class.php');
include('../../../include/firma.class.php');
require_once('../../../vilesci/config.inc.php');
require_once('../../../include/adresse.class.php');
require_once('../../../include/firma.class.php');
require_once('../sync_config.inc.php');
$conn=pg_connect(CONN_STRING) or die("Connection zur Portal Datenbank fehlgeschlagen");
$conn_fas=pg_connect(CONN_STRING_FAS) or die("Connection zur FAS Datenbank fehlgeschlagen");
//$adress='ruhan@technikum-wien.at';
$adress='fas_sync@technikum-wien.at';
//$adress='fas_sync@technikum-wien.at';
$error_log='';
$text = '';
@@ -257,9 +258,12 @@ if($result = pg_query($conn_fas, $qry))
$ausgabe_adresse="Insertvon: '".$adresse->insertvon."' (statt '".$row2->insertvon."')";
}
}
// update adresse, wenn datensatz bereits vorhanden
$adresse->new=false;
$adresse->adresse_id=$row2->adresse_id;
if ($update && $dont_sync_sql)
{
// update adresse, wenn datensatz bereits vorhanden
$adresse->new=false;
$adresse->adresse_id=$row2->adresse_id;
}
}
}
else
@@ -343,7 +347,7 @@ if($result = pg_query($conn_fas, $qry))
if(!$error)
{
if($adresse->new || $update)
if($adresse->new || ($update && $dont_sync_sql))
{
if(!$adresse->save())
{
@@ -11,13 +11,14 @@
//*
//*
include('../../../vilesci/config.inc.php');
require_once('../../../vilesci/config.inc.php');
require_once('../sync_config.inc.php');
$conn=pg_connect(CONN_STRING) or die("Connection zur Portal Datenbank fehlgeschlagen");
$conn_fas=pg_connect(CONN_STRING_FAS) or die("Connection zur FAS Datenbank fehlgeschlagen");
$adress='ruhan@technikum-wien.at';
//$adress='ruhan@technikum-wien.at';
//$adress='fas_sync@technikum-wien.at';
$error_log='';
@@ -172,28 +173,31 @@ if($result = pg_query($conn_fas, $qry))
{
if($rowchk2=pg_fetch_object($resultchk2))
{
//update
if($rowchk2->studiensemester_kurzbz<$studiensemester_kurzbz)
if($dont_sync_sql)
{
$qrybg="UPDATE public.tbl_benutzergruppe SET ".
"uid=".myaddslashes($uid).", ".
"gruppe_kurzbz=".myaddslashes($gruppe_kurzbz).", ".
"studiensemester_kurzbz=".myaddslashes($studiensemester_kurzbz).", ".
"insertamum=".myaddslashes($insertamum).", ".
"insertvon=".myaddslashes($insertvon).", ".
"updateamum=now(), ".
"updatevon='SYNC'".
"WHERE uid='".$uid."' AND gruppe_kurzbz='".$gruppe_kurzbz."';";
if($resultbg=pg_query($conn, $qrybg))
//update
if($rowchk2->studiensemester_kurzbz<$studiensemester_kurzbz)
{
$anzahl_update++;
$ausgabe="Benutzergruppe auf UID='".$uid."', Gruppe='".$gruppe_kurzbz."', Studiensemester='".$studiensemester_kurzbz."' geändert (statt UID='".$rowchk2->uid."', Gruppe='".$rowchk2->gruppe_kurzbz."', Studiensemester='".$rowchk2->studiensemester_kurzbz."').\n";
}
else
{
$anzahl_fehler++;
$error_log="Fehler beim Ändern in Tabelle tbl_benutzergruppe. ".$qrybg."\n";
$qrybg="UPDATE public.tbl_benutzergruppe SET ".
"uid=".myaddslashes($uid).", ".
"gruppe_kurzbz=".myaddslashes($gruppe_kurzbz).", ".
"studiensemester_kurzbz=".myaddslashes($studiensemester_kurzbz).", ".
"insertamum=".myaddslashes($insertamum).", ".
"insertvon=".myaddslashes($insertvon).", ".
"updateamum=now(), ".
"updatevon='SYNC'".
"WHERE uid='".$uid."' AND gruppe_kurzbz='".$gruppe_kurzbz."';";
if($resultbg=pg_query($conn, $qrybg))
{
$anzahl_update++;
$ausgabe="Benutzergruppe auf UID='".$uid."', Gruppe='".$gruppe_kurzbz."', Studiensemester='".$studiensemester_kurzbz."' geändert (statt UID='".$rowchk2->uid."', Gruppe='".$rowchk2->gruppe_kurzbz."', Studiensemester='".$rowchk2->studiensemester_kurzbz."').\n";
}
else
{
$anzahl_fehler++;
$error_log="Fehler beim Ändern in Tabelle tbl_benutzergruppe. ".$qrybg."\n";
}
}
}
}
+13 -8
View File
@@ -12,14 +12,15 @@
//*
//*benötigt: tbl_kontakttyp, tbl_syncperson
include('../../../vilesci/config.inc.php');
include('../../../include/kontakt.class.php');
require_once('../../../vilesci/config.inc.php');
require_once('../../../include/kontakt.class.php');
require_once('../sync_config.inc.php');
$conn=pg_connect(CONN_STRING) or die("Connection zur Portal Datenbank fehlgeschlagen");
$conn_fas=pg_connect(CONN_STRING_FAS) or die("Connection zur FAS Datenbank fehlgeschlagen");
//$adress='ruhan@technikum-wien.at';
$adress='fas_sync@technikum-wien.at';
//$adress='fas_sync@technikum-wien.at';
$error_log='';
$text = '';
@@ -126,10 +127,13 @@ if($result = pg_query($conn_fas, $qry))
$ausgabe_email="Zustelladresse: '".($row->zustelladresse=='J'?'true':'false')."'";
}
}
// update , wenn datensatz bereits vorhanden
$kontakt->person_id=$row1->person_portal;
$kontakt->kontakt_id=$row2->kontakt_id;
$kontakt->new=false;
if($update && $dont_sync_sql)
{
// update , wenn datensatz bereits vorhanden
$kontakt->person_id=$row1->person_portal;
$kontakt->kontakt_id=$row2->kontakt_id;
$kontakt->new=false;
}
}
}
else
@@ -151,7 +155,7 @@ if($result = pg_query($conn_fas, $qry))
}
If (!$error)
{
if($kontakt->new || $update)
if($kontakt->new || ($update && $dont_sync_sql))
{
if(!$kontakt->save())
{
@@ -175,6 +179,7 @@ if($result = pg_query($conn_fas, $qry))
}
}
}
echo nl2br($ausgabe);
}
}
}
+28 -24
View File
@@ -11,13 +11,14 @@
//*
//*
include('../../../vilesci/config.inc.php');
require_once('../../../vilesci/config.inc.php');
require_once('../sync_config.inc.php');
$conn=pg_connect(CONN_STRING) or die("Connection zur Portal Datenbank fehlgeschlagen");
$conn_fas=pg_connect(CONN_STRING_FAS) or die("Connection zur FAS Datenbank fehlgeschlagen");
$adress='ruhan@technikum-wien.at';
//$adress='ruhan@technikum-wien.at';
//$adress='fas_sync@technikum-wien.at';
$error_log='';
@@ -198,33 +199,36 @@ if($result = pg_query($conn_fas, $qry))
if($result2 = pg_query($conn, $qry2))
{
if($row2=pg_fetch_object($result2))
{
//Eintrag bereits vorhanden - Eintragung in Sync-Tabelle
$qrysync="SELECT * FROM sync.tbl_syncgruppe WHERE fas_gruppe='".$ext_id."' AND vilesci_gruppe='".$gruppe_kurzbz."';";
if($resultsync = pg_query($conn, $qrysync))
{
$qryupd="UPDATE public.tbl_gruppe SET ext_id='".$ext_id."' WHERE gruppe_kurzbz='".$gruppe_kurzbz."' AND studiengang_kz='".$studiengang_kz."';";
if($resultupd = pg_query($conn, $qryupd))
{
if($dont_sync_sql)
{
//Eintrag bereits vorhanden - Eintragung in Sync-Tabelle
$qrysync="SELECT * FROM sync.tbl_syncgruppe WHERE fas_gruppe='".$ext_id."' AND vilesci_gruppe='".$gruppe_kurzbz."';";
if($resultsync = pg_query($conn, $qrysync))
{
$anzahl_update++;
if(pg_num_rows($resultsync)<1)
$qryupd="UPDATE public.tbl_gruppe SET ext_id='".$ext_id."' WHERE gruppe_kurzbz='".$gruppe_kurzbz."' AND studiengang_kz='".$studiengang_kz."';";
if($resultupd = pg_query($conn, $qryupd))
{
//Sync-Eintrag nicht vorhanden
$qryinss="INSERT INTO sync.tbl_syncgruppe (fas_gruppe, vilesci_gruppe) VALUES ('".$ext_id."','".$gruppe_kurzbz."');";
$ausgabe="Gruppe in Vilesci bereits vorhanden.\n";
$ausgabe.="---Sync-Eintrag : FAS-'".$ext_id."', Vilesci-'".$gruppe_kurzbz."'.\n";
if(!(pg_query($conn, $qryinss)))
$anzahl_update++;
if(pg_num_rows($resultsync)<1)
{
$error=true;
$error_log="Eintrag in Tabelle tbl_syncgruppe fehlgeschlagen: ".$qryinss."\n";
//Sync-Eintrag nicht vorhanden
$qryinss="INSERT INTO sync.tbl_syncgruppe (fas_gruppe, vilesci_gruppe) VALUES ('".$ext_id."','".$gruppe_kurzbz."');";
$ausgabe="Gruppe in Vilesci bereits vorhanden.\n";
$ausgabe.="---Sync-Eintrag : FAS-'".$ext_id."', Vilesci-'".$gruppe_kurzbz."'.\n";
if(!(pg_query($conn, $qryinss)))
{
$error=true;
$error_log="Eintrag in Tabelle tbl_syncgruppe fehlgeschlagen: ".$qryinss."\n";
}
}
}
}
else
{
$error=true;
$error_log="Update in Tabelle tbl_gruppe fehlgeschlagen: ".$qryupd."\n";
else
{
$error=true;
$error_log="Update in Tabelle tbl_gruppe fehlgeschlagen: ".$qryupd."\n";
}
}
}
}
+2 -1
View File
@@ -14,12 +14,13 @@
require_once('../../../vilesci/config.inc.php');
require_once('../../../include/konto.class.php');
require_once('../../../include/functions.inc.php');
require_once('../sync_config.inc.php');
$conn=pg_connect(CONN_STRING) or die("Connection zur Portal Datenbank fehlgeschlagen");
$conn_fas=pg_connect(CONN_STRING_FAS) or die("Connection zur FAS Datenbank fehlgeschlagen");
//$adress='ruhan@technikum-wien.at';
$adress='fas_sync@technikum-wien.at';
//$adress='fas_sync@technikum-wien.at';
$error_log='';
$text = '';
@@ -488,6 +488,8 @@ if($result = pg_query($conn_fas, $qry_main))
$insertvon=$rowcu->name;
}
}
$lg_ext_id=$row->mitarbeiter_lehreinheit_pk;
$qry="SELECT * FROM lehre.tbl_lehreinheit join lehre.tbl_lehreinheitgruppe USING (lehreinheit_id) WHERE tbl_lehreinheitgruppe.ext_id='".$lg_ext_id."';";
if($result3 = pg_query($conn, $qry))
@@ -552,12 +554,9 @@ if($result = pg_query($conn_fas, $qry_main))
" AND ".($gruppe!=''?"gruppe=".myaddslashes($gruppe):"gruppe IS NULL").
" AND gruppe_kurzbz IS NULL));";
*/
//echo "-".$start_kw."-".$qry;exit;
//fwrite($dateiausgabe,"-".$start_kw."-".$qry);
if($result2 = pg_query($conn, $qry))
{
@@ -1647,7 +1646,7 @@ if($result = pg_query($conn_fas, $qry_main))
}
else
{
$ausgabe.="Partizipierende Lehreinheit lvnr='".$lvnr."' (Lehreinheit id/pk .'".$row5->lehreinheit_id."'/'".$ext_id."') in synclehreinheit gefunden.\n";
//$ausgabe.="Partizipierende Lehreinheit lvnr='".$lvnr."' (Lehreinheit id/pk .'".$row5->lehreinheit_id."'/'".$ext_id."') in synclehreinheit gefunden.\n";
$anzahl_part2++;
//ext_id für gruppe zusammenstellen
$qry="SELECT *, tbl_lehreinheitmitarbeiter.ext_id as lg_ext_id FROM lehre.tbl_lehreinheit JOIN lehre.tbl_lehreinheitmitarbeiter USING(lehreinheit_id) WHERE lehreinheit_id=".myaddslashes($row5->lehreinheit_id)." ORDER BY tbl_lehreinheitmitarbeiter.ext_id ASC;";
@@ -7,9 +7,10 @@
// **************************************
require_once('../../../vilesci/config.inc.php');
require_once('../../../include/lehrveranstaltung.class.php');
require_once('../sync_config.inc.php');
//$adress='fas_sync@technikum-wien.at';
//$adress='oesi@technikum-wien.at';
$adress='ruhan@technikum-wien.at';
//$adress='ruhan@technikum-wien.at';
$conn=pg_connect(CONN_STRING);
$conn_fas=pg_connect(CONN_STRING_FAS);
@@ -235,28 +236,31 @@
if($row_found = pg_fetch_object($result))
{
//Datensatz aktualisieren
$qry = getupdateqry($row_found, $row_fas_alle);
if($qry!='')
if ($dont_sync_sql)
{
if(pg_query($conn, $qry))
//Datensatz aktualisieren
$qry = getupdateqry($row_found, $row_fas_alle);
if($qry!='')
{
if(pg_query($conn, $qry))
{
//Eintrag zur Synctabelle hinzufuegen
synctabentry($row_found->lehrveranstaltung_id, $row_fas_alle->lehrveranstaltung_pk);
$text.="LVA wurde aktualisiert: $qry\n";
$anz_update++;
}
else
{
$text.="Fehler beim Update einer LVA: $qry\n";
$update_error++;
}
}
else
{
//Eintrag zur Synctabelle hinzufuegen
synctabentry($row_found->lehrveranstaltung_id, $row_fas_alle->lehrveranstaltung_pk);
$text.="LVA wurde aktualisiert: $qry\n";
$anz_update++;
$text.="SYNC-Eintrag wurde angelegt!\n";
}
else
{
$text.="Fehler beim Update einer LVA: $qry\n";
$update_error++;
}
}
else
{
synctabentry($row_found->lehrveranstaltung_id, $row_fas_alle->lehrveranstaltung_pk);
$text.="SYNC-Eintrag wurde angelegt!\n";
}
}
else
@@ -279,29 +283,32 @@
{
if($row_found = pg_fetch_object($result))
{
//Gefunden->Update und Synctab-Eintrag
//$text.='FOUND on Name LVA '.getlvabez($row_fas_alle)." -> UPDATE & SYNCTAB-Insert\n";
$qry = getupdateqry($row_found, $row_fas_alle);
if($qry!='')
if($dont_sync_sql)
{
if(pg_query($conn, $qry))
//Gefunden->Update und Synctab-Eintrag
//$text.='FOUND on Name LVA '.getlvabez($row_fas_alle)." -> UPDATE & SYNCTAB-Insert\n";
$qry = getupdateqry($row_found, $row_fas_alle);
if($qry!='')
{
if(pg_query($conn, $qry))
{
//Eintrag zur Synctabelle hinzufuegen
synctabentry($row_found->lehrveranstaltung_id, $row_fas_alle->lehrveranstaltung_pk);
$text.="LVA wurde aktualisiert: $qry\n";
$anz_update++;
}
else
{
$text.="Fehler beim Update einer LVA: $qry\n";
$update_error++;
}
}
else
{
//Eintrag zur Synctabelle hinzufuegen
synctabentry($row_found->lehrveranstaltung_id, $row_fas_alle->lehrveranstaltung_pk);
$text.="LVA wurde aktualisiert: $qry\n";
$anz_update++;
$text.="SYNC-Eintrag wurde angelegt!\n";
}
else
{
$text.="Fehler beim Update einer LVA: $qry\n";
$update_error++;
}
}
else
{
synctabentry($row_found->lehrveranstaltung_id, $row_fas_alle->lehrveranstaltung_pk);
$text.="SYNC-Eintrag wurde angelegt!\n";
}
}
else
@@ -369,20 +376,23 @@
//UPDATE
if($row_found = pg_fetch_object($result))
{
//Datensatz aktualisieren
$qry = getupdateqry($row_found, $row_fas_alle);
if($qry!='')
if($dont_sync_sql)
{
if(pg_query($conn, $qry))
//Datensatz aktualisieren
$qry = getupdateqry($row_found, $row_fas_alle);
if($qry!='')
{
$text.="LVA wurde aktualisiert: $qry\n";
$anz_update++;
}
else
{
$text.="Fehler beim Update einer LVA: $qry\n";
$update_error++;
if(pg_query($conn, $qry))
{
$text.="LVA wurde aktualisiert: $qry\n";
$anz_update++;
}
else
{
$text.="Fehler beim Update einer LVA: $qry\n";
$update_error++;
}
}
}
}
@@ -442,7 +452,7 @@
if($msg!='')
{
$text.="\nMails an Studiengang ".$stg_data[$stg]['kuerzel'].'('.$stg_data[$stg]['mail'].") ... ";
if(mail('ruhan@technikum-wien.at',"FAS - Vilesci (Lehrveranstaltungen) ".$stg_data[$stg]['kuerzel'],$head_stg_text.$msg,"From: vilesci@technikum-wien.at"))
if(mail($adress,"FAS - Vilesci (Lehrveranstaltungen) ".$stg_data[$stg]['kuerzel'],$head_stg_text.$msg,"From: vilesci@technikum-wien.at"))
$text.="gesendet\n\n$msg";
else
$text.="FEHLER beim senden\n\n$msg";
+5 -6
View File
@@ -11,6 +11,7 @@
*/
require_once('../../../vilesci/config.inc.php');
require_once('../../../include/datum.class.php');
require_once('../sync_config.inc.php');
$conn=pg_connect(CONN_STRING) or die("Connection zur Portal Datenbank fehlgeschlagen");
$conn_fas=pg_connect(CONN_STRING_FAS) or die("Connection zur FAS Datenbank fehlgeschlagen");
@@ -70,8 +71,6 @@ foreach ($studiengangfk AS $stg)
}
set_time_limit(60);
//$adress='ruhan@technikum-wien.at';
$adress='fas_sync@technikum-wien.at';
function myaddslashes($var)
{
@@ -1172,7 +1171,7 @@ if($result = pg_query($conn_fas, $qry))
$ausgabe_person="Insertvon: '".$insertvon."' (statt '".$row1->insertvon."')";
}
}
if($updatep && $studiengang_kz!=299)
if($updatep && $dont_sync_sql)
{
$qry = 'UPDATE public.tbl_person SET'.
' sprache='.myaddslashes($sprache).','.
@@ -1577,7 +1576,7 @@ if($result = pg_query($conn_fas, $qry))
$ausgabe_pre="Insertvon: '".$insertvon."'";
}
}
if($updater && $studiengang_kz!=299)
if($updater && $dont_sync_sql)
{
$qry = 'UPDATE public.tbl_prestudent SET'.
' aufmerksamdurch_kurzbz='.myaddslashes($aufmerksamdurch_kurzbz).','.
@@ -2062,7 +2061,7 @@ if($result = pg_query($conn_fas, $qry))
$ausgabe_benutzer="Insertvon: '".$insertvon."' statt('".$rows->insertvon."')";
}
}
if($updateb && $studiengang_kz!=299)
if($updateb && $dont_sync_sql)
{
$qry = 'UPDATE public.tbl_benutzer SET'.
' uid='.myaddslashes($student_uid).','.
@@ -2260,7 +2259,7 @@ if($result = pg_query($conn_fas, $qry))
$ausgabe_student="Insertvon: '".$insertvon."' (statt '".$rows->insertvon."')";
}
}
if($updates && $studiengang_kz!=299)
if($updates && $dont_sync_sql)
{
$qry = 'UPDATE public.tbl_student SET'.
' student_uid='.myaddslashes($student_uid).','.
@@ -11,13 +11,14 @@
//*
//*
include('../../../vilesci/config.inc.php');
require_once('../../../vilesci/config.inc.php');
require_once('../sync_config.inc.php');
$conn=pg_connect(CONN_STRING) or die("Connection zur Portal Datenbank fehlgeschlagen");
$conn_fas=pg_connect(CONN_STRING_FAS) or die("Connection zur FAS Datenbank fehlgeschlagen");
$adress='ruhan@technikum-wien.at';
//$adress='ruhan@technikum-wien.at';
//$adress='fas_sync@technikum-wien.at';
$error_log='';
@@ -309,7 +310,8 @@ if($result = pg_query($conn_fas, $qry))
{
//update
$updates=false;
$updates=false;
$ausgabe_slv="";
if(trim($row4->student_uid)!=trim($student_uid))
{
$updates=true;
@@ -385,7 +387,7 @@ if($result = pg_query($conn_fas, $qry))
}
}
}
if($updates)
if($updates && $dont_sync_sql)
{
$anzahl_update++;
$qry = "UPDATE public.tbl_studentlehrverband SET".
+4 -3
View File
@@ -12,14 +12,15 @@
//*
//* benötigt: tbl_syncperson, tbl_kontakttyp
include('../../../vilesci/config.inc.php');
include('../../../include/kontakt.class.php');
require_once('../../../vilesci/config.inc.php');
require_once('../../../include/kontakt.class.php');
require_once('../sync_config.inc.php');
$conn=pg_connect(CONN_STRING) or die("Connection zur Portal Datenbank fehlgeschlagen");
$conn_fas=pg_connect(CONN_STRING_FAS) or die("Connection zur FAS Datenbank fehlgeschlagen");
//$adress='ruhan@technikum-wien.at';
$adress='fas_sync@technikum-wien.at';
//$adress='fas_sync@technikum-wien.at';
$error_log='';
$text = '';