From 6af0939000200f9cefb2c73575f107edf7c1cdb3 Mon Sep 17 00:00:00 2001 From: Rudolf Hangl Date: Wed, 29 Nov 2006 13:42:12 +0000 Subject: [PATCH] Funktion sync --- admin/sync/sync_vilesci_portal_funktion.php | 126 +++++++++++ include/fas/funktion.class.php | 239 ++++++++++++++++++++ 2 files changed, 365 insertions(+) create mode 100644 admin/sync/sync_vilesci_portal_funktion.php create mode 100644 include/fas/funktion.class.php diff --git a/admin/sync/sync_vilesci_portal_funktion.php b/admin/sync/sync_vilesci_portal_funktion.php new file mode 100644 index 000000000..dcf1fadd9 --- /dev/null +++ b/admin/sync/sync_vilesci_portal_funktion.php @@ -0,0 +1,126 @@ +, + * Andreas Oesterreicher and + * Rudolf Hangl . + */ + +//* +//* Synchronisiert Funktiondatensaetze von Vilesci DB in PORTAL DB +//* +//* + +include('../../vilesci/config.inc.php'); +include('../../include/fas/funktion.class.php'); + +$conn=pg_connect(CONN_STRING) or die("Connection zur Portal Datenbank fehlgeschlagen"); +$conn_vilesci=pg_connect(CONN_STRING_VILESCI) or die("Connection zur Vilesci Datenbank fehlgeschlagen"); + +$adress='ruhan@technikum-wien.at'; +//$adress='fas_sync@technikum-wien.at'; + +$error_log=''; +$text = ''; +$anzahl_quelle=0; +$anzahl_eingefuegt=0; +$anzahl_fehler=0; + +function validate($row) +{ +} + +/************************* + * VILESCI-PORTAL - Synchronisation + */ + +//funktion +$qry = "SELECT * FROM tbl_funktion"; + +if($result = pg_query($conn_vilesci, $qry)) +{ + echo nl2br("Funktion Sync\n----------------------\n"); + $anzahl_quelle=pg_num_rows($result); + while($row = pg_fetch_object($result)) + { + $error=false; + $funktion = new funktion($conn); + $funktion->bezeichnung=$row->bezeichnung; + $funktion->funktion_kurzbz=$row->funktion_kurzbz; + $funktion->aktiv=($row->aktiv=='t'?true:false); + //$funktion->insertamum=''; + $funktion->insertvon='SYNC'; + //$funktion->updateamum=''; + //$funktion->updatevon=$row->updatevon; + + $qry = "SELECT funktion_kurzbz FROM tbl_funktion WHERE funktion_kurzbz='$funktion->funktion_kurzbz'"; + if($result1 = pg_query($conn, $qry)) + { + if(pg_num_rows($result1)>0) //wenn dieser eintrag schon vorhanden ist + { + if($row1=pg_fetch_object($result1)) + { + //Lehrveranstaltungsdaten updaten + $funktion->new=false; + $funktion->funktion_kurzbz=$row->funktion_kurzbz; + } + else + { + $error_log.="funktion_kurzbz von $row->funktion_kurzbz konnte nicht ermittelt werden\n"; + $error=true; + } + } + else + { + //Funktion neu anlegen + $funktion->new=true; + } + + if(!$error) + if(!$funktion->save()) + { + $error_log.=$funktion->errormsg."\n"; + $anzahl_fehler++; + } + else + $anzahl_eingefuegt++; + else + $anzahl_fehler++; + } + } + echo nl2br("abgeschlossen\n\n"); +} +else + $error_log .= 'Funktiondatensaetze konnten nicht geladen werden'; + +?> + + + +Synchro - Vilesci -> Portal - Fachbereiche + + + + + + \ No newline at end of file diff --git a/include/fas/funktion.class.php b/include/fas/funktion.class.php new file mode 100644 index 000000000..442825b99 --- /dev/null +++ b/include/fas/funktion.class.php @@ -0,0 +1,239 @@ +, + * Andreas Oesterreicher and + * Rudolf Hangl . + */ +/** + * Klasse funktion (FAS-Online) + * @create 14-03-2006 + */ + +class funktion +{ + var $conn; // @var resource DB-Handle + var $new; // @var boolean + var $errormsg; // @var string + var $result = array(); // @var fachbereich Objekt + + //Tabellenspalten + var $funktion_kurzbz; // @var integer + var $bezeichnung; // @var string + var $aktiv; // @var boolean + var $updateamum; // @var timestamp + var $updatevon=0; // @var string + var $insertamum; // @var timestamp + var $insertvon=0; // @var string + var $ext_id; // @var bigint + + + /** + * Konstruktor + * @param $conn Connection zur DB + * $funktion_kurzbz ID der zu ladenden Funktion + */ + function funktion($conn, $funktion_kurzbz=null) + { + $this->conn = $conn; + if($funktion_kurzbz != null) + $this->load($funktion_kurzbz); + } + + /** + * Laedt alle verfuegbaren Funktionen + * @return true wenn ok, false im Fehlerfall + */ + function getAll() + { + $qry = 'SELECT * FROM tbl_funktion order by funktion_kurzbz;'; + + if(!$res = pg_query($this->conn, $qry)) + { + $this->errormsg = 'Fehler beim laden der Datensaetze'; + return false; + } + + while($row = pg_fetch_object($res)) + { + $funktion_obj = new funktion($this->conn); + + $funktion_obj->funktion_kurzbz = $row->funktion_kurzbz; + $funktion_obj->bezeichnung = $row->bezeichnung; + $funktion_obj->aktiv = $row->aktiv; + $funktion_obj->insertamum=$row->insertamum; + $funktion_obj->insertvon=$$row->insertvon; + $funktion_obj->updateamum=$row->updateamum; + $funktion_obj->updatevon=$row->updatevon; + + $this->result[] = $funktion_obj; + } + return true; + } + + /** + * Laedt eine Funktion + * @param $funktion_kurzbz ID der zu ladenden Funktion + * @return true wenn ok, false im Fehlerfall + */ + function load($funktion_kurzbz) + { + if($funktion_kurzbz == '') + { + $this->errormsg = 'funktion_bz darf nicht leer sein sein'; + return false; + } + + $qry = "SELECT * FROM tbl_funktion WHERE funktion_kurzbz = '$funktion_kurzbz';"; + + if(!$res = pg_query($this->conn, $qry)) + { + $this->errormsg = 'Fehler beim laden des Datensatzes'; + return false; + } + + if($row=pg_fetch_object($res)) + { + $this->funktion_kurzbz = $row->funktion_kurzbz; + $this->bezeichnung = $row->bezeichnung; + $this->aktiv = $row->aktiv; + $this->insertamum =$row->insertamum; + $this->insertvon =$row->insertvon; + $this->updateamum = $row->updateamum; + $this->updatevon = $row->updatevon; + } + else + { + $this->errormsg = 'Es ist kein Datensatz mit dieser ID vorhanden'; + return false; + } + + return true; + } + + /** + * Loescht einen Datensatz + * @param $fachb_id id des Datensatzes der geloescht werden soll + * @return true wenn ok, false im Fehlerfall + */ + function delete($funktion_kurzbz) + { + $this->errormsg = 'Noch nicht implementiert'; + return false; + } + function addslashes($var) + { + return ($var!=''?"'".addslashes($var)."'":'null'); + } + /** + * Speichert den aktuellen Datensatz + * @return true wenn ok, false im Fehlerfall + */ + /** + * Prueft die Gueltigkeit der Variablen + * @return true wenn ok, false im Fehlerfall + */ + function checkvars() + { + $this->bezeichnung = str_replace("'",'´',$this->bezeichnung); + + //Laenge Pruefen + if(strlen($this->bezeichnung)>64) + { + $this->errormsg = "Bezeichnung darf nicht laenger als 128 Zeichen sein bei $this->funktion_kurzbz - $this->bezeichnung"; + return false; + } + + $this->errormsg = ''; + return true; + } + function save() + { + //Gueltigkeit der Variablen pruefen + if(!$this->checkvars()) + return false; + + if($this->new) + { + //Pruefen ob funktion_kurzbz befüllt ist + if($this->funktion_kurzbz == '') + { + $this->errormsg = 'funktion_kurzbz darf nicht leer sein'; + return false; + } + //Neuen Datensatz anlegen + $qry = 'INSERT INTO tbl_funktion (funktion_kurzbz, bezeichnung, aktiv, insertamum, insertvon, + updateamum, updatevon) VALUES ('. + $this->addslashes($this->funktion_kurzbz).', '. + $this->addslashes($this->bezeichnung).', '. + ($this->aktiv?'true':'false').', '. + $this->addslashes($this->insertamum).', '. + $this->addslashes($this->insertvon).', '. + $this->addslashes($this->updateamum).', '. + $this->addslashes($this->updatevon).'); '; + } + else + { + //bestehenden Datensatz akualisieren + + //Pruefen ob fachbereich_id eine gueltige Zahl ist + if(!is_numeric($this->fachbereich_id) || $this->fachbereich_id == '') + { + $this->errormsg = 'fachbereich_id muss eine gueltige Zahl sein'; + return false; + } + + $qry = 'UPDATE tbl_funktion SET '. + 'funktion_kurzbz='.$this->addslashes($this->funktion_kurzbz).', '. + 'bezeichnung='.$this->addslashes($this->bezeichnung).', '. + 'aktiv='.($this->aktiv?'true':'false') .', '. + 'insertamum='.$this->addslashes($this->insertamum).', '. + 'insertvon='.$this->addslashes($this->insertvon).', '. + 'updateamum='.$this->addslashes($this->updateamum).', '. + 'updatevon='.$this->addslashes($this->updatevon).', '. + 'WHERE funktion_kurzbz = '.$this->addslashes($this->funktion_kurzbz).';'; + } + + if(pg_query($this->conn, $qry)) + { + /*//Log schreiben + $sql = $qry; + $qry = "SELECT nextval('log_seq') as id;"; + if(!$row = pg_fetch_object(pg_query($this->conn, $qry))) + { + $this->errormsg = 'Fehler beim Auslesen der Log-Sequence'; + return false; + } + + $qry = "INSERT INTO log(log_pk, creationdate, creationuser, sql) VALUES('$row->id', now(), '$this->updatevon', '".addslashes($sql)."')"; + if(pg_query($this->conn, $qry)) + return true; + else + { + $this->errormsg = 'Fehler beim Speichern des Log-Eintrages'; + return false; + }*/ + return true; + } + else + { + $this->errormsg = 'Fehler beim Speichern des Datensatzes'; + return false; + } + } +} +?> \ No newline at end of file