From: hickert <hickert@594d385d-05f5-0310-b6e9-bd551577e9d8>
Date: Tue, 6 Dec 2005 09:02:12 +0000 (+0000)
Subject: Added classes
X-Git-Url: https://git.tokkee.org/?a=commitdiff_plain;h=109185cb5f552e468119d99238d16aee58f96157;p=gosa.git

Added classes


git-svn-id: https://oss.gonicus.de/repositories/gosa/trunk@2237 594d385d-05f5-0310-b6e9-bd551577e9d8
---

diff --git a/include/class_opengw.inc b/include/class_opengw.inc
new file mode 100755
index 000000000..159ddf28b
--- /dev/null
+++ b/include/class_opengw.inc
@@ -0,0 +1,470 @@
+<?php
+
+require_once("class_pgsql_opengw.inc");
+
+class ogw{
+  var $info;
+  var $ogo;
+  
+  var $validLocationTeam;
+  var $validTemplateUser;
+  var $validTeams;
+
+
+  var $InfoOK = false;
+
+  var $MUST = array("name","login","template_user_id");
+  
+  var $MAY = array( "salutation","firstname","description","degree",
+                    "birthday","sex","street","zip","country","zipcity",
+                    "state","name1","value_string","number","db_status",
+                    "object_version","is_locked","LocationTeamID","TeamIDis");
+
+  var $LastError  = "";
+  var $option     = "";
+
+  function ogw($username,$password,$host,$db)
+  {
+    $this->ogo  = new pgre_sql($username,$password,$host,$db);
+
+    $this->validLocationTeam  = $this->ogo->GetLocationTeam();
+    $this->validTemplateUser  = $this->ogo->GetTemplateUser();
+    $this->validTeams         = $this->ogo->GetTeams();
+  }
+ 
+  function SetInfos($infos)
+  {   
+    $this->info = $infos;
+    $info['name1']              = $info['name'];
+  }
+
+  function GetInfos()
+  {   
+    return("NIY");
+  }
+
+  function Perform($option)
+  {
+    if(!in_array($option,array("ADD","EDIT","REMOVE"))){
+      $this->LastError = sprintf("Option '%s' is not allowed, possible options are 'ADD' 'EDIT' 'REMOVE'.",$option);
+      return(false);
+    }else{
+      $this->option = $option;
+      if(($this->option == "EDIT")||($this->option=="ADD")){
+
+        /* Static variables */
+        $this->info['is_person']          = 1;
+        $this->info['is_account']         = 1;
+        $this->info['is_intra_account']   = 1;
+        $this->info['is_extra_account']   = 0;
+        $this->info['owner_id']           = 10000;
+        $this->info['is_team']            = 0;
+
+        $this->InfoOK = $this->checkInfos();
+
+        if($this->InfoOK){
+          $qry = "SELECT * FROM person WHERE login='".$this->info['login']."';";
+          $ist = $this->ogo->FetchAllRows($this->ogo->Query($qry));
+
+          if($this->option == "ADD"){
+            if($this->CheckExistence()){
+              $this->LastError="Can't add entry already exists.";
+              return(false);
+            }else{
+              $this->info['db_status']          = "inserted";
+              $this->info['object_version']     = 1;
+              return($this->ADD());
+            }
+          }else{
+            if(!$this->CheckExistence()){
+              $this->LastError="Can't edit entry, entry doesn't exists.";
+              return(false);
+            }else{
+              $this->info['db_status']          = "edited";
+              $this->info['object_version']     = $ist[0]['object_version']++;
+              return($this->EDIT());
+            }
+          }
+        }else{
+          return($this->InfoOK);
+        }
+      }
+      if($this->option == "REMOVE"){
+    
+        if((!isset($this->info['login']))||(empty($this->info['login']))){
+          $this->LastError = "Require login to detect existence";
+          return(false);
+        }else{
+    
+          if($this->CheckExistence()){
+            return($this->REMOVE());
+          }else{
+            $this->LastError="Can't remove non existing entry";
+            return(false);
+          }
+        }
+      }
+    }
+  }
+
+  function CheckExistence()
+  {
+    /* Check if thios entry already exists */
+    $qry = "SELECT * FROM person WHERE login='".$this->info['login']."';";
+    $ist = $this->ogo->FetchAllRows($this->ogo->Query($qry));
+    if($ist){
+      return(true);
+    }else{
+      return(false);
+    }
+  }
+
+  function checkInfos()
+  {
+    foreach($this->MUST as $name){
+      if((!isset($this->info[$name]))||(empty($this->info[$name]))){
+        $this->LastError = sprintf("Must attribute '%s' wasn't set.",$name);
+        return(false);
+      }
+    }
+
+    foreach($this->MAY as $name){
+      if((!isset($this->info[$name]))||(empty($this->info[$name]))){
+        $info[$name] = false;
+      }
+    }
+
+    $tmp = array(false,"",0);
+    foreach($this->validLocationTeam as $id){
+      $tmp[]= $id['company_id'];
+    }
+    if(!in_array($this->info['LocationTeamID'],$tmp)){
+      $this->LastError = "Given 'Location Team' is invalid.";
+      return(false);
+    }
+
+    $tmp = array();
+    foreach($this->validTemplateUser as $id){
+      $tmp[]= $id['company_id'];
+    }
+    if(!in_array($this->info['template_user_id'],$tmp)){
+      $this->LastError = "Given 'Template User ID' is invalid.";
+      return(false);
+    }
+
+    
+    $tmp = array();
+    foreach($this->validTeams as $id){
+      $tmp[]= $id['company_id'];
+    }
+    foreach($this->info['TeamIDis'] as $id){
+      if(!in_array($id,$tmp)){
+        $this->LastError = sprintf("Given 'Team ID':%s is invalid.",$id);
+       return(false);
+      }
+    }
+    return(true);
+  }
+
+  function REMOVE()
+  {
+    $qry = "SELECT * FROM person WHERE login='".$this->info['login']."';";
+    $ist = $this->ogo->FetchAllRows($this->ogo->Query($qry));
+    if((!$ist)||(!isset($ist[0]['company_id']))||($ist[0]['company_id']<=0)){
+      $this->LastError(sprintf("Can't get company id for login %s",$this->info['login']));
+      return(false);
+    }else{
+      $company_id     = $ist[0]['company_id'];
+      $this->ogo->Query("DELETE FROM telephone WHERE company_id=".$company_id.";");
+      $this->ogo->Query("DELETE FROM address  WHERE company_id=".$company_id.";");
+      $this->ogo->Query("DELETE FROM company_info WHERE company_id=".$company_id.";");
+      $this->ogo->Query("DELETE FROM company_value WHERE company_id=".$company_id.";");
+      $this->ogo->Query("DELETE FROM company_assignment WHERE sub_company_id=".$company_id.";");
+      $this->ogo->Query("DELETE FROM person WHERE company_id=".$company_id.";");
+      $this->ogo->Query("DELETE FROM staff WHERE company_id=".$company_id.";");
+      return(true);
+    }
+  }
+
+  function ADD()
+  {
+    /* 
+       Entry settings for personm table 
+     */
+    $arr = array( "company_id","object_version","owner_id","template_user_id",
+                  "is_person","is_account","is_intra_account","is_extra_account",
+                  "number","description","is_locked","login","name","name","firstname",
+                  "salutation","degree","birthday","sex","db_status");
+    $this->info['company_id']  = $this->ogo->gen_id();
+    $userID             = "OGo".$this->info['company_id'];
+    foreach($arr as $attr){
+      if($attr == "number"){
+        $add_user[$attr]  = $this->info['userID'];
+      }else{
+        $add_user[$attr]  = $this->info[$attr];
+      }
+    }
+    $QUERY[] = gen_syntax($add_user,"person","ADD",false);
+
+
+    /*
+       Entry for staff table
+     */
+    $arr = array("staff_id","company_id","description","login","is_team","is_account","db_status");
+    $this->info['staff_id'] = $this->ogo->gen_id();
+    foreach($arr as $attr){
+      $add_staff[$attr] = $this->info[$attr];
+    }
+    $QUERY[] = gen_syntax($add_staff,"staff","ADD",false);
+
+
+    /* 
+       Create entries for company nfo 
+     */
+    $arr = array("company_info_id","company_id","db_status");
+    $this->info['company_info_id']  = $this->ogo->gen_id();
+    foreach($arr as $attr){
+      $add_company_info[$attr]  = $this->info[$attr];
+    }
+    $QUERY[] = gen_syntax($add_company_info,"company_info","ADD",false);
+
+
+    /* 
+       Create entries for company value 
+     */
+    $arr = array("db_status","value_string","attribute","company_id","company_value_id");
+    $this->info['attribute']        = "email1";
+    $this->info['company_value_id'] = $this->ogo->gen_id();
+    foreach($arr as $attr){
+      $add_company_value[$attr]  = $this->info[$attr];
+    }
+    $QUERY[] = gen_syntax($add_company_value,"company_value","ADD",false);
+
+
+    /* 
+       address entries 
+     */
+    $arr = array("company_id","address_id","street","zip","country","zipcity","state","db_status","name1","type");
+    foreach(array("private","mailing","location") as  $type){
+      
+      $this->info['address_id'] = $this->ogo->gen_id();
+      $this->info['type']       = $type;
+      foreach($arr as $attr){
+        $add_address[$attr]  = $this->info[$attr];
+      }
+      $QUERY[] = gen_syntax($add_address,"address","ADD",false);
+    }
+
+
+    /*
+       telephone entries 
+     */
+    $arr = array("telephone_id","object_version","company_id","number","type","db_status");
+    foreach(array("01_tel","02_tel","03_tel_funk","05_tel_private","10_fax","fax_private") as $type){
+      $this->info['type']       = $type;
+      $this->info['telephone_id']     = $this->ogo->gen_id();
+      foreach($arr as $attr){
+        $add_telephone[$attr]  = $this->info[$attr];
+      }
+      $QUERY[] = gen_syntax($add_telephone,"telephone","ADD",false);
+    }
+
+    /*
+       company_assignment entries (Location Team) 
+     */
+    $this->info['old_company_id']       = $this->info['company_id'];
+    $this->info['sub_company_id']       = $this->info['old_company_id'];
+
+    $this->info['company_assignment_id']= $this->ogo->gen_id();
+    $this->info['company_id']           = $this->info['LocationTeamID'];
+    $arr = array("company_assignment_id","company_id","sub_company_id","db_status");
+    foreach($arr as $attr){
+      $add_company_assignment[$attr]  = $this->info[$attr];
+    }
+    $QUERY[] = gen_syntax($add_company_assignment,"company_assignment","ADD",false);
+
+
+    /*
+       company_assignment entries (Teams) 
+     */
+    $arr = array("company_assignment_id","company_id","sub_company_id","db_status");
+    foreach($this->info['TeamIDis'] as $TeamID){
+      
+      $this->info['company_id']           = $TeamID;
+      $this->info['sub_company_id']       = $this->info['old_company_id'];
+      $this->info['company_assignment_id']= $this->ogo->gen_id();
+      foreach($arr as $attr){
+        $add_company_assignment[$attr]  = $this->info[$attr]; 
+      }    
+      $QUERY[] = gen_syntax($add_company_assignment,"company_assignment","ADD",false);
+    }
+
+    $remove_all = false;
+    foreach($QUERY as $q ){
+      if(!$this->ogo->Query($q)){
+        $remove_all = true;
+        break;
+      }
+    }
+    
+    if($remove_all== true){
+      $this->ogo->Query("DELETE FROM telephone WHERE company_id=".$this->info['company_id'].";");
+      $this->ogo->Query("DELETE FROM address WHERE company_id=".$this->info['company_id'].";");
+      $this->ogo->Query("DELETE FROM company_assignment WHERE company_id=".$this->info['company_id'].";");
+      $this->ogo->Query("DELETE FROM company_info WHERE company_id=".$this->info['company_id'].";");
+      $this->ogo->Query("DELETE FROM company_value WHERE company_id=".$this->info['company_id'].";");
+      $this->ogo->Query("DELETE FROM staff WHERE company_id=".$this->info['company_id'].";");
+      $this->ogo->Query("DELETE FROM person WHERE company_id=".$this->info['company_id'].";");
+      $this->LastError="Query failed, removed all added entries";
+      return(false);
+    }
+    return(true);
+  }
+
+
+  function EDIT()
+  {
+    $qry = "SELECT * FROM person WHERE login='".$this->info['login']."';";
+    $ist = $this->ogo->FetchAllRows($this->ogo->Query($qry));
+    /* 
+       Entry settings for personm table 
+     */
+    $arr = array( "company_id","object_version","owner_id",
+                  "template_user_id","is_person","is_account","is_intra_account",
+                  "is_extra_account","number","description","is_locked","login","name",
+                  "firstname","salutation","degree","birthday","sex","db_status");
+    $this->info['company_id'] = $ist[0]['company_id'];
+    $this->info['userID']     = "OGo".$this->info['company_id'];
+    foreach($arr as $attr){
+      if($attr == "number"){
+        $add_user[$attr]  = $this->info['userID'];
+      }else{
+        $add_user[$attr]  = $this->info[$attr];
+      }
+    }
+    $QUERY[] = gen_syntax($add_user,"person","EDIT",$ist);
+
+
+    /*
+       Entry for staff table
+     */
+    $arr = array("staff_id","company_id","description","login","is_team","is_account","db_status");
+    $this->info['staff_id'] = $this->ogo->gen_id();
+    foreach($arr as $attr){
+      $add_staff[$attr] = $this->info[$attr];
+    }
+    $QUERY[] = gen_syntax($add_staff,"staff","EDIT",$ist);
+
+
+    /* 
+       Create entries for company nfo 
+     */
+    $arr = array("company_info_id","company_id","db_status");
+    $this->info['company_info_id']    = $this->ogo->gen_id();
+    foreach($arr as $attr){
+      $add_company_info[$attr]  = $this->info[$attr];
+    }
+    $QUERY[] = gen_syntax($add_company_info,"company_info","EDIT",$ist);
+
+
+    /* 
+       Create entries for company value 
+     */
+    $arr = array("db_status","value_string","attribute","company_id","company_value_id");
+    $this->info['attribute']        = "email1";
+    $this->info['company_value_id'] = $this->ogo->gen_id();
+    foreach($arr as $attr){
+      $add_company_value[$attr]  = $this->info[$attr];
+    }
+    $QUERY[] = gen_syntax($add_company_value,"company_value","EDIT",$ist);
+
+
+    /* 
+       address entries 
+     */
+    $QUERY[] = "DELETE FROM address WHERE company_id=".$ist[0]['company_id'].";";
+    $this->info['company_id'] = $ist[0]['company_id'];
+    $arr = array("company_id","address_id","street","zip","country","zipcity","state","db_status","name1","type");
+    foreach(array("private","mailing","location") as  $type){
+      $this->info['type']       = $type;
+      $this->info['address_id'] = $this->ogo->gen_id();
+      foreach($arr as $attr){
+        $add_address[$attr]  = $this->info[$attr];
+      } 
+      $QUERY[] = gen_syntax($add_address,"address","ADD",false);
+    }
+
+
+    /*
+       telephone entries 
+     */
+    $QUERY[] = "DELETE FROM telephone WHERE company_id=".$ist[0]['company_id'].";";
+    $this->info['company_id'] = $ist[0]['company_id'];
+    $arr = array("telephone_id","object_version","company_id","number","type","db_status");
+    foreach(array("01_tel","02_tel","03_tel_funk","05_tel_private","10_fax","fax_private") as $type){
+      $this->info['type']           = $type;
+      $this->info['telephone_id']   = $this->ogo->gen_id();
+      foreach($arr as $attr){
+        $add_telephone[$attr]  = $this->info[$attr];
+      }
+
+      $QUERY[] = gen_syntax($add_telephone,"telephone","ADD",false);
+    }
+
+
+    /*
+       company_assignment entries (Location Team) 
+     */
+    $this->info['old_company_id'] = $this->info['company_id'];
+    
+    /* First remove location team */
+    $QUERY[] = "DELETE FROM company_assignment WHERE (sub_company_id=".$ist[0]['company_id'].") AND
+      company_id in (SELECT company_id FROM team WHERE is_location_team=1);";
+
+    $this->info['sub_company_id']       = $ist[0]['company_id'];
+    $this->info['company_assignment_id']= $this->ogo->gen_id();
+    $this->info['company_id']           = $this->info['LocationTeamID'];
+    $arr = array("company_assignment_id","company_id","sub_company_id","db_status");
+    foreach($arr as $attr){
+      $add_company_assignment[$attr]  = $this->info[$attr];
+    }
+    $QUERY[] = gen_syntax($add_company_assignment,"company_assignment","ADD",false);
+
+
+    /*
+       company_assignment entries (Teams) 
+     */
+    /* First remove location team */
+    $QUERY[] = "DELETE FROM company_assignment 
+                WHERE 
+                    (sub_company_id=".$ist[0]['company_id'].") 
+                  AND
+                    company_id IN 
+                      (SELECT company_id FROM team  WHERE  (is_team=1) AND company_id NOT IN 
+                         (SELECT company_id FROM team WHERE is_location_team=1));";
+
+    $arr = array("company_assignment_id","company_id","sub_company_id","db_status");
+    foreach($this->info['TeamIDis'] as $TeamID){
+      $this->info['company_id']           = $TeamID;
+      $this->info['sub_company_id']       = $ist[0]['company_id'];
+      $this->info['company_assignment_id']= $this->ogo->gen_id();
+      foreach($arr as $attr){
+        $add_company_assignment[$attr]  = $this->info[$attr];
+      }    
+      $QUERY[] = gen_syntax($add_company_assignment,"company_assignment","ADD",false);
+    }
+
+    $remove_all = false;
+
+    foreach($QUERY as $q ){
+      if(!$this->ogo-> Query($q)){
+        print $q;
+        $remove_all = true;
+        break;
+      }
+    }
+  }
+}
+
+// vim:tabstop=2:expandtab:shiftwidth=2:filetype=php:syntax:ruler:
+?>
diff --git a/include/class_pgsql_opengw.inc b/include/class_pgsql_opengw.inc
new file mode 100644
index 000000000..ed9544ada
--- /dev/null
+++ b/include/class_pgsql_opengw.inc
@@ -0,0 +1,149 @@
+<?php
+
+class pgre_sql{
+
+  var $handle;
+  var $query_log;
+  var $user;
+  var $server;
+  var $db;
+  var $pwd;
+  var $is_connected = false;
+
+  function pgre_sql($user,$pwd,$server,$db)
+  {
+    $this->user   = $user;
+    $this->pwd  = $pwd;
+    $this->server = $server;
+    $this->db   = $db;
+
+    if($this->_connect()){
+      $this->is_connected = true;
+    }
+
+    return($this->is_connected);
+  }
+
+  function _connect()
+  {
+	error_reporting(E_ALL);
+	if(is_callable("pg_connect")){
+		$this->handle = pg_connect("dbname=".$this->db." host=".$this->server." user=".$this->user);
+		if(!$this->handle){
+			print "can't connect to pgsql :";
+			exit();
+		}
+	}else{
+		print "Extension fpr pgsql is missing";
+		$this->handle = false;
+	}
+	return($this->handle);
+  }
+
+  function Query($a_query)
+  {
+    if(is_array($a_query)){
+      foreach($a_query as $nr => $query){
+        return($this->_query($query));
+      }
+    }else{
+      return($this->_query($a_query));
+    }
+  }
+	
+  function _query($query)
+  {
+    return(pg_query($this->handle,$query));
+  }
+
+  function FetchAllRows($res)
+  {
+    return(pg_fetch_all($res))  ;
+  }
+
+  function gen_id()
+  {
+	  $tmp = $this->_query("select nextval('key_generator');");
+	  $tmp = ($this->FetchAllRows($tmp));
+	  return($tmp[0]['nextval']);
+  }
+
+
+  function GetTemplateUser(){
+	  $data = array();
+	  $qry = "SELECT description,name,company_id FROM company WHERE is_template_user=1;";
+	  $res = $this->_query($qry);
+	  $tmp = $this->FetchAllRows($res);
+	  foreach($tmp as $attr){
+		  $data[$attr['name']] = $attr;
+	  }
+	  return $data;
+  }
+  function GetLocationTeam(){
+	  $data = array();
+	  $qry = "SELECT description,name,company_id FROM team WHERE is_location_team=1;";
+	  $res = $this->_query($qry);
+	  $tmp = $this->FetchAllRows($res);
+	  foreach($tmp as $attr){
+		  $data[$attr['description']] = $attr;
+	  }
+	  return $data;
+  }
+  function GetTeams(){
+	  $data = array();
+	  $qry = "SELECT description,name,company_id FROM team 
+				WHERE (is_team=1) AND company_id 
+					NOT IN (SELECT company_id FROM company WHERE is_location_team=1);";
+	  $res = $this->_query($qry);
+	  $tmp = $this->FetchAllRows($res);
+	  foreach($tmp as $attr){
+		  $data[$attr['description']] = $attr;
+	  }
+	  return $data;
+  }
+}
+
+
+function gen_syntax($array,$tablename,$act,$ist)
+{
+	if($act == "EDIT"){
+		$str = "UPDATE ".$tablename." SET ";
+		$company_id = $ist[0]['company_id'];
+
+		foreach($array as $name => $value){
+			if(empty($value)) continue;
+		
+			if(!is_numeric($value)){
+				$str.= " ".$name."='".$value."', ";
+			}else{
+				$str.= " ".$name."=".$value.", ";
+			}
+		}
+		$str = preg_replace("/, $/","",$str);
+		$str .= " WHERE company_id=".$company_id.";\n";
+		return $str;
+	}
+	if($act == "ADD"){
+		$str = "INSERT into ".$tablename." (";
+		$attrs  = "";
+		$values = "";
+		foreach($array as $name => $attribute){
+
+			if(empty($attribute)) continue;
+
+			if(is_numeric($attribute)){
+				$attrs  .= $name.", ";
+				$values .= $attribute.", ";
+			}else{
+				$attrs  .= $name.", ";
+				$values .= "'".$attribute."', ";
+			}
+		}
+		$attrs = preg_replace("/, $/","",$attrs);
+		$values= preg_replace("/, $/","",$values);
+		$str .= $attrs." ) \nVALUES\n (".$values.");\n";
+		return $str;
+	}
+}
+
+?>