blackicedbear/FHC-Core
1
0
Fork 0
mirror of https://github.com/FH-Complete/FHC-Core.git synced 2026-07-26 09:04:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

SYNC Mitarbeiter und Reihungstest

Browse Source
This commit is contained in:
Rudolf Hangl
2007-01-11 10:35:07 +00:00
parent b6c0f75778
commit e5b7169561
14 changed files with 858 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files
admin/sync/fas/sync_fas_portal_adresse.php
+2 -2
View File
@@ -21,7 +21,7 @@
*/
//*
//* Synchronisiert Adressendatensaetze von Vilesci DB in PORTAL DB
//* Synchronisiert Adressendatensaetze von FAS DB in PORTAL DB
//*
//*
@@ -55,7 +55,7 @@ function validate($row)
<html>
<head>
<title>Synchro - Vilesci -> Portal - Adresse</title>
<title>Synchro - FAS -> Portal - Adresse</title>
<meta http-equiv="Content-Type" content="text/html; charset=iso-8859-1">
</head>
<body>
admin/sync/fas/sync_fas_portal_mitarbeiter.php
+184
View File
@@ -0,0 +1,184 @@
<?php
/* Copyright (C) 2007 Technikum-Wien
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as
* published by the Free Software Foundation; either version 2 of the
* License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307, USA.
*
* Authors: Christian Paminger <[email protected]>,
* Andreas Oesterreicher <[email protected]> and
* Rudolf Hangl <[email protected]>.
*/
/**
* Synchronisiert Mitarbeiterdatensaetze von FAS DB in PORTAL DB
*
*/
require_once('../../../vilesci/config.inc.php');
require_once('../../../include/person.class.php');
require_once('../../../include/benutzer.class.php');
require_once('../../../include/mitarbeiter.class.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");
$error_log='';
$text = '';
$anzahl_eingefuegt=0;
$anzahl_fehler=0;
// ***********************************
// * VILESCI->PORTAL - Synchronisation
// ***********************************
//Mitarbeiter
$qry = "SELECT * FROM person JOIN mitarbeiter ON person_fk=person_pk WHERE uid NOT LIKE '\_dummy%'";
if($result = pg_query($conn_fas, $qry))
{
$text.="\n Sync Mitarbeiter\n\n";
while($row = pg_fetch_object($result))
{
$error=false;
$mitarbeiter = new mitarbeiter($conn);
//if($row->personalnummer!='')
//{
$mitarbeiter->sprache='German';
$mitarbeiter->anrede=$row->anrede;
$mitarbeiter->titelpost=$row->postnomentitel;
$mitarbeiter->titelpre=$row->titel;
$mitarbeiter->nachname=$row->familienname;
$mitarbeiter->vorname=$row->vorname;
$mitarbeiter->vornamen=$row->vornamen;
$mitarbeiter->gebdatum=$row->gebdat;
$mitarbeiter->gebort=$row->gebort;
$mitarbeiter->geburtsnation=$row->gebnation;
$mitarbeiter->foto='';
$mitarbeiter->anmerkungen=$row->bemerkung;
$mitarbeiter->svnr=$row->svnr;
$mitarbeiter->geschlecht=strtolower($row->geschlecht);
$mitarbeiter->ersatzkennzeichen=$row->ersatzkennzeichen;
$mitarbeiter->familienstand=$row->familienstand;
$mitarbeiter->anzahlkinder=$row->anzahlderkinder;
$mitarbeiter->aktiv=($row->aktiv=='t'?true:false);
$mitarbeiter->insertvon='SYNC';
$mitarbeiter->insertamum='';
$mitarbeiter->updateamum='';
$mitarbeiter->updatevon='SYNC';
$mitarbeiter->ext_id=$row->person_pk;
$mitarbeiter->ext_id_mitarbeiter=$row->mitarbeiter_pk;
$mitarbeiter->kurzbz=$row->kurzbez;
$mitarbeiter->uid=$row->uid;
$mitarbeiter->ausbildungcode=$row->ausbildung;
$mitarbeiter->personalnummer=$row->persnr;
$mitarbeiter->gebzeit='';
$mitarbeiter->ort_kurzbz='';
$mitarbeiter->homepage='';
$mitarbeiter->alias='';
$mitarbeiter->lektor=true;
$mitarbeiter->fixangestellt=false;
$mitarbeiter->telefonklappe='';
$qry = "SELECT person_id FROM public.tbl_benutzer WHERE uid='$row->uid'";
if($result1 = pg_query($conn, $qry))
{
if(pg_num_rows($result1)>0) //wenn dieser eintrag schon vorhanden ist
{
if($row1=pg_fetch_object($result1))
{
$qry2="SELECT * FROM public.tbl_mitarbeiter JOIN public.tbl_benutzer ON mitarbeiter_uid=public.tbl_benutzer.uid JOIN public.tbl_person USING (person_id) WHERE mitarbeiter_uid='$row->uid'";
if($result2 = pg_query($conn, $qry2))
{
if(pg_num_rows($result2)>0) //wenn dieser eintrag schon vorhanden ist
{
if($row2=pg_fetch_object($result2))
{
//Mitarbeiterdaten updaten
$mitarbeiter->new=false;
$mitarbeiter->person_id=$row1->person_id;
$mitarbeiter->gebzeit=$row2->gebzeit;
$mitarbeiter->ort_kurzbz=$row2->ort_kurzbz;
$mitarbeiter->homepage=$row2->homepage;
$mitarbeiter->alias=$row2->alias;
$mitarbeiter->lektor=($row2->lektor=='t'?true:false);
$mitarbeiter->fixangestellt=($row2->fixangestellt=='t'?true:false);
$mitarbeiter->telefonklappe=$row2->telefonklappe;
}
}
else
{
//Mitarbeiter neu anlegen
$mitarbeiter->new=true;
}
}
else
{
$error_log.="Mitarbeiter von $row->uid konnte nicht gefunden werden\n";
$error=true;
}
}
else
{
$error_log.="Person_id von $row->uid konnte nicht ermittelt werden\n";
$error=true;
}
}
else
{
//Mitarbeiter neu anlegen
$mitarbeiter->new=true;
}
if(!$error)
if(!$mitarbeiter->save())
{
$error_log.=$mitarbeiter->errormsg."\n";
$anzahl_fehler++;
}
else
$anzahl_eingefuegt++;
else
$anzahl_fehler++;
}
else
$error_log .= "Fehler beim ermitteln der UID\n";
//}
//else
// $error_log .= "$row->nachname ($row->uid) hat keine Personalnummer\n";
}
}
else
{
$error_log .= 'Mitarbeiterdatensaetze konnten nicht geladen werden\n';
}
$text.="Anzahl aktualisierte Datensaetze: $anzahl_eingefuegt\n";
$text.="Anzahl der Fehler: $anzahl_fehler\n";
?>
<html>
<head>
<title>Synchro - Vilesci -> Portal - Mitarbeiter</title>
<meta http-equiv="Content-Type" content="text/html; charset=iso-8859-1">
</head>
<body>
<?php
echo nl2br($text);
echo nl2br($error_log);
?>
</body>
</html>
admin/sync/fas/sync_fas_portal_person.php
-2
View File
@@ -121,7 +121,6 @@ if($result = pg_query($conn_fas, $qry))
//update
$person->person_id=$rowu->person_id;
$person->new=false;
//echo nl2br("update1 von ".$row->uid.", ".$row->familienname."\n");
}
else
{
@@ -141,7 +140,6 @@ if($result = pg_query($conn_fas, $qry))
//update
$person->person_id=$row1->person_portal;
$person->new=false;
//echo nl2br("update2 von ".$row->uid.", ".$row->familienname."\n");
}
else
{
admin/sync/fas/sync_fas_portal_reihungstest.php
+134
View File
@@ -0,0 +1,134 @@
<?php
/* Copyright (C) 2007 Technikum-Wien
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as
* published by the Free Software Foundation; either version 2 of the
* License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307, USA.
*
* Authors: Christian Paminger <[email protected]>,
* Andreas Oesterreicher <[email protected]> and
* Rudolf Hangl <[email protected]>.
*/
//*
//* Synchronisiert Reihungstestdatensaetze von FAS DB in PORTAL DB
//*
//*
require_once('../../../vilesci/config.inc.php');
require_once('../../../include/reihungstest.class.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='[email protected]';
//$adress='[email protected]';
$error_log='';
$text = '';
$anzahl_quelle=0;
$anzahl_eingefuegt=0;
$anzahl_fehler=0;
$anzahl_quelle2=0;
$anzahl_eingefuegt2=0;
$anzahl_fehler2=0;
function validate($row)
{
}
/*************************
* FAS-PORTAL - Synchronisation
*/
?>
<html>
<head>
<title>Synchro - FAS -> Portal - Reihungstest</title>
<meta http-equiv="Content-Type" content="text/html; charset=iso-8859-1">
</head>
<body>
<?php
//nation
$qry = "SELECT * FROM reihungstest ORDER BY datum;";
if($result = pg_query($conn_fas, $qry))
{
echo nl2br("Reihungstest Sync\n-------------------\n");
$anzahl_quelle=pg_num_rows($result);
while($row = pg_fetch_object($result))
{
$error=false;
$reihungstest =new reihungstest($conn);
$studiengang_kz ='';
$reihungstest->ort_kurzbz ='';
$reihungstest->anmerkung =$row->raum;
$reihungstest->datum =$row->datum;
$reihungstest->uhrzeit =$row->uhrzeit;
//$reihungstest->updateamum =$row->;
$reihungstest->updatevon ="SYNC";
//$reihungstest->insertamum =$row->;
$reihungstest->insertvon ="SYNC";
$reihungstest->ext_id =$row->reihungstest_pk;
//echo nl2br ($reihungstest->ext_id."\n");
$qry2="SELECT reihungstest_id, ext_id FROM tbl_reihungstest WHERE ext_id=".$row->reihungstest_pk.";";
if($result2 = pg_query($conn, $qry2))
{
if(pg_num_rows($result2)>0) //eintrag gefunden
{
if($row2=pg_fetch_object($result2))
{
// update adresse, wenn datensatz bereits vorhanden
$reihungstest->new=false;
$reihungstest->reihungstest_id=$row2->reihungstest_id;
}
}
else
{
// insert, wenn datensatz noch nicht vorhanden
$reihungstest->new=true;
}
}
if(!$error)
{
if(!$reihungstest->save())
{
$error_log.=$reihungstest->errormsg."\n";
$anzahl_fehler++;
}
else
{
$anzahl_eingefuegt++;
echo "- ";
ob_flush();
flush();
}
}
flush();
}
}
//echo nl2br($text);
echo nl2br($error_log);
echo nl2br("\nGesamt: $anzahl_quelle / Eingefügt: $anzahl_eingefuegt / Fehler: $anzahl_fehler");
?>
</body>
</html>
admin/sync/fas/sync_fas_portal_schluessel.php
+4 -3
View File
@@ -39,6 +39,7 @@ $text = '';
$anzahl_quelle=0;
$anzahl_eingefuegt=0;
$anzahl_fehler=0;
$krit='';
function validate($row)
{
@@ -90,16 +91,16 @@ if($result = pg_query($conn_fas, $qry))
{
$schluessel->person_id=$row1->person_portal;
//Schlüsseltyp feststellen
$qry2="SELECT schluesseltyp FROM tbl_schluesseltyp WHERE schluesseltyp=".$row->name.";";
$qry2="SELECT * FROM tbl_syncschluesseltyp WHERE fas_typ='".$row->schluessel_fk."';";
if($result2 = pg_query($conn, $qry2))
{
if(pg_num_rows($result2)>0) //eintrag gefunden
{
if($row2=pg_fetch_object($result2))
{
$schluessel->schluesseltyp=$row2->schluesseltyp;
$schluessel->schluesseltyp=$row2->portal_typ;
//Insert oder Update
$qry3="SELECT schluessel_id FROM tbl_schluessel WHERE beschreibung=".$row->name.";";
$qry3="SELECT schluessel_id FROM tbl_schluessel WHERE ext_id=".$row->schluessel_fk.";";
if($result3 = pg_query($conn, $qry3))
{
if(pg_num_rows($result3)>0) //eintrag gefunden
admin/sync/fas/sync_fas_portal_schluesseltyp.php
+3 -3
View File
@@ -95,13 +95,13 @@ if($result = pg_query($conn_fas, $qry))
{
//überprüfen, ob sync-eintrag schon vorhanden
$qryz="SELECT * FROM tbl_syncschluesseltyp WHERE fas_typ='$row->schluesseltyp_pk' AND portal_typ='$schluesseltyp->schluesseltyp'";
$qryz="SELECT * FROM tbl_syncschluesseltyp WHERE fas_typ='$row->schluessel_pk' AND portal_typ='$schluesseltyp->schluesseltyp'";
if($resultz = pg_query($conn, $qryz))
{
if(pg_num_rows($resultz)==0) //wenn dieser eintrag noch nicht vorhanden ist
{
$qry='INSERT INTO tbl_syncschluesseltyp (fas_typ, portal_typ)'.
'VALUES ('.$row->schluesseltyp_pk.', '.$person->schluesseltyp.');';
$qry="INSERT INTO tbl_syncschluesseltyp (fas_typ, portal_typ)".
"VALUES ('".$row->schluessel_pk."', '".$schluesseltyp->schluesseltyp."');";
$resulti = pg_query($conn, $qry);
}
}
admin/sync/fas/sync_fas_portal_student.php
+265
View File
@@ -0,0 +1,265 @@
<?php
/* Copyright (C) 2007 Technikum-Wien
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as
* published by the Free Software Foundation; either version 2 of the
* License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307, USA.
*
* Authors: Christian Paminger <[email protected]>,
* Andreas Oesterreicher <[email protected]> and
* Rudolf Hangl <[email protected]>.
*/
/**
* Synchronisiert Studentendatensaetze von FAS DB in PORTAL DB
*
*/
require_once('../../../vilesci/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");
$error_log='';
$text = '';
$anzahl_eingefuegt=0;
$anzahl_fehler=0;
// ***********************************
// * VILESCI->PORTAL - Synchronisation
// ***********************************
//Mitarbeiter
$qry = "SELECT * FROM person JOIN student ON person_fk=person_pk WHERE uid NOT LIKE '\_dummy%'";
if($result = pg_query($conn_fas, $qry))
{
$text.="\n Sync Student\n\n";
while($row = pg_fetch_object($result))
{
$error=false;
//Attribute Person
$staatsbuergerschaft=$row->staatsbuergerschaft;
$geburtsnation=$row->gebnation;
$sprache='German';
$anrede=$row->anrede;
$titelpost=$row->postnomentitel;
$titelpre=$row->titel;
$nachname=$row->familienname;
$vorname=$row->vorname;
$vornamen=$row->vornamen;
$gebdatum=$row->gebdat;
$gebort=$row->gebort;
$gebzeit=''; //bei insert auslassen
$foto=''; //bei insert auslassen
$anmerkungen=$row->bemerkung;
$svnr=$row->svnr;
$ersatzkennzeichen=$row->ersatzkennzeichen;
$familienstand=$row->familienstand;
$geschlecht=strtolower($row->geschlecht);
$anzahlkinder=$row->anzahlderkinder;
$aktiv=($row->aktiv=='t'?true:false);
$insertvon='SYNC';
$insertamum='';
$updateamum='';
$updatevon='SYNC';
$ext_id_person=$row->person_pk;
//Attribute Benutzer
$uid='';
$person_id='';
$aktiv='';
$alias='';
//Attribute Prestudent
$aufmerksam_kurzbz=$row->aufmerksamdurch;
$person_id='';
$studiengang_kz='';
$beruftaetigkeit_code=$row->berufstaetigkeit;
$ausbildungcode='';
$zgv_code=$row->zgv;
$zgvort=$row->zgvort;
$zgvdatum=$row->zgvdatum;
$zgvmas_code=$row->zgvmagister;
$zgvmaort=$row->zgvmagisterortort;
$zgvmadatum=$row->zgvmagisterdatum;
$facheinschlberuf=($row->berufstätigkeit=='J'?true:false);
$reihungstest_id='';
$punkte='';
$ext_id_pre=$row->person_pk;
$anmeldungreihungstest='';
//Attribute Student
$student_uid=$row->uid;
$matrikelnr=$row->perskz;
$prestudent_id='';
//studiengang_kz bei prestudent
$semester='';
$verband='';
$gruppe='';
$ext_id_student=$row->student_pk;
//Ermittlung der Daten des Reihungstests
$qry_rt1="SELECT student_fk, reihungstest_fk, anmeldungreihungstest FROM student_reihungstest WHERE student_fk=".$row->student_pk.";";
if($result_rt1 = pg_query($conn, $qry_rt1))
{
if($row_rt1=pg_fetch_object($result_rt1))
{
$qry_rt2="SELECT reihungstest_id FROM public.tbl_reihungstest WHERE ext_id=".$row_rt1->reihungstest_fk.";";
if($result_rt2 = pg_query($conn, $qry_rt2))
{
if($row_rt2=pg_fetch_object($result_rt2))
{
$reihungstest_id=$row_rt2->reihungstest_id;
$anmeldungreihungstest=$row_rt1->anmeldungreihungstest;
}
else
{
$error_log.="Reihungstest_id von $row_rt1->reihungstest_fk konnte nicht gefunden werden.\n";
$error=true;
}
}
else
{
$error_log.="Reihungstest von $row_rt1->reihungstest_fk wurde nicht gefunden.\n";
$error=true;
}
}
else
{
$error_log.="Fehler beim Ermitteln des Reihungstests von Student $row->familienname, $row->vorname aufgetreten!\n";
$error=true;
}
}
//Start der Transaktion
pg_query($this->conn,'BEGIN;');
//Reihenfolge: person - prestudent - student - benutzer
//insert oder update bei person?
$qry="SELECT person_id FROM public.tbl_benutzer WHERE uid='$row->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))
{
//update
$person_id=$rowu->person_id;
$new_person=false;
}
else
{
$error=true;
$error_log.="benutzer von $row->uid konnte nicht ermittelt werden\n";
}
}
else
{
$qry1="SELECT person_fas, person_portal FROM public.tbl_syncperson WHERE person_fas='$row->person_pk'";
if($result1 = pg_query($conn, $qry1))
{
if(pg_num_rows($result1)>0) //wenn dieser eintrag schon vorhanden ist
{
if($row1=pg_fetch_object($result1))
{
//update
$person_id=$row1->person_portal;
$new_person=false;
}
else
{
$error=true;
$error_log.="person von $row->person_pk konnte nicht ermittelt werden\n";
}
}
else
{
//vergleich svnr und ersatzkennzeichen
$qryz="SELECT person_id FROM public.tbl_person
WHERE ('$row->svnr' is not null AND svnr = '$row->svnr')
OR ('$row->ersatzkennzeichen' is not null AND ersatzkennzeichen = '$row->ersatzkennzeichen')";
if($resultz = pg_query($conn, $qryz))
{
if(pg_num_rows($resultz)>0) //wenn dieser eintrag schon vorhanden ist
{
if($rowz=pg_fetch_object($resultz))
{
$new_person=false;
$person_id=$rowz->person_id;
//echo nl2br("update3 von ".$row->uid.", ".$row->familienname."\n");
}
else
{
$error=true;
$error_log.="person mit svnr: $row->svnr bzw. ersatzkennzeichen: $row->ersatzkennzeichen konnte nicht ermittelt werden (".pg_num_rows($resultz).")\n";
}
}
else
{
//insert
$new_person=true;
//echo nl2br("insert von ".$row->uid.", ".$row->familienname."\n");
}
}
}
}
}
}
if(new_person)
{
//insert person
}
else
{
//update person
}
if(!$error)
{
//Reihenfolge: prestudent - student - benutzer
}
else
{
pg_query($this->conn,'ROLLBACK;');
}
//Basisdaten speichern
if(!benutzer::save())
{
pg_query($this->conn,'ROLLBACK;');
return false;
}
}
}
?>
<html>
<head>
<title>Synchro - Vilesci -> Portal - Student</title>
<meta http-equiv="Content-Type" content="text/html; charset=iso-8859-1">
</head>
<body>
<?php
echo nl2br($text);
echo nl2br($error_log);
?>
</body>
</html>
admin/sync/fas/sync_fas_portal_telefon.php
+16 -1
View File
@@ -72,7 +72,22 @@ if($result = pg_query($conn_fas, $qry))
$error=false;
$kontakt =new kontakt($conn);
$kontakt->firma_id ='';
$kontakt->kontakttyp ='telefon';
If($row->typ<'20')
{
$kontakt->kontakttyp ='telefon';
}
elseif($row->typ>='20' && $row->typ<'30')
{
$kontakt->kontakttyp ='mobil';
}
elseif($row->typ>='30' && $row->typ<'40')
{
$kontakt->kontakttyp ='fax';
}
else
{
$kontakt->kontakttyp ='so.tel';
}
$kontakt->anmerkung =$row->name;
$kontakt->kontakt =$row->nummer;
$kontakt->zustellung =false;