=') && extension_loaded('xsl')) { require_once($include_path.'/xslt-php4-to-php5.inc.php'); } function _item_z3950_($param) { global $catalog; global $n_typ_total; if (isset($param["IMPORT"]) && $param["IMPORT"]=="yes") { $t["NAME"]=$param["NAME"]; $t["INDEX"]=$n_typ_total; $t["PATH"]=$param["PATH"]; $catalog[]=$t; } $n_typ_total++; } class z3950 extends connector { public $profiles; //Profils par défaut public $convert_path_order=array(); //Table de correspondance entre le chemin d'une conversion et son suméro d'ordre public function __construct($connector_path="") { parent::__construct($connector_path); } public function get_id() { return "z3950"; } //Est-ce un entrepot ? public function is_repository() { return 2; } public function get_profiles() { $xml_profile = file_get_contents($this->connector_path."/profil.xml"); $param = _parser_text_no_function_($xml_profile, "PROFILES"); $nb_profiles = count($param["PROFILE"]); for ($i = 0; $i < $nb_profiles; $i++) { $profile = $param["PROFILE"][$i]; $t = array(); $t["name"] = $profile["NAME"]; if (substr($profile["COMMENT"], 0, 4) == "msg:") { $t["comment"] = $this->msg[substr($profile["COMMENT"], 4)]; } else { $t["comment"] = $profile["COMMENT"]; } $nb_ufields = count($profile["UFIELDS"][0]["UFIELD"]); for ($j = 0; $j < $nb_ufields; $j++) { $ufield = $profile["UFIELDS"][0]["UFIELD"][$j]; $t["ufields"][$ufield["NAME"]] = $ufield["IDS"]; } if (isset($profile["OPERATORS"][0]["OPERATOR"])) { $nb_operators = count($profile["OPERATORS"][0]["OPERATOR"]); for ($j = 0; $j < $nb_operators; $j++) { $operator = $profile["OPERATORS"][0]["OPERATOR"][$j]; $t["operators"][$operator["NAME"]] = $operator["TYPES"]; } } $this->profiles[]=$t; } } public function parse_convert_catalog() { global $catalog,$base_path; //Liste des transformations possibles avant import $catalog=array(); $n_typ_total=0; if (file_exists("$base_path/admin/convert/imports/catalog_subst.xml")) $fic_catal = "$base_path/admin/convert/imports/catalog_subst.xml"; else $fic_catal = "$base_path/admin/convert/imports/catalog.xml"; _parser_($fic_catal, array("ITEM" => "_item_z3950_"), "CATALOG"); $this->convert_path_order=$catalog; } public function source_get_property_form($source_id) { global $charset, $base_path, $catalog, $reload, $xslt_exemplaire; if (!$reload) { $params=$this->get_source_params($source_id); if ($params["PARAMETERS"]) { //Affichage du formulaire avec $params["PARAMETERS"] $vars=unserialize($params["PARAMETERS"]); foreach ($vars as $key=>$val) { global ${$key}; ${$key}=$val; } } } else { global $z3950_profil,$url,$z3950_base,$z3950_login,$z3950_password,$z3950_format,$z3950_port,$z3950_convert,$z3950_max_notices; } if (!($z3950_max_notices*1)) $z3950_max_notices=100; //Liste des transformations possibles avant import $this->parse_convert_catalog(); //Création de la liste des types d'import $export_type=""; $form="

".$this->msg["z3950_url"]."

".$this->msg["z3950_port"]."

".$this->msg["z3950_base"]."

".$this->msg["z3950_login"]."

".$this->msg["z3950_password"]."

".$this->msg["z3950_format"]."

".$this->msg["z3950_max_notices"]."

".$this->msg["z3950_convert"]."

".$export_type."

"; $xsl_exemplaire_input = ""; if (!empty($xslt_exemplaire)) { $xsl_exemplaire_input .= ''; } $xsl_exemplaire_input .= ' '; $form.="

".$this->msg["z3950_xsl_exemplaire"]."

".$xsl_exemplaire_input."

"; //Lecture des profils $this->get_profiles(); $profils=" ".$this->msg["z3950_warning_bib1"]."\n"; $form.="

".$this->msg["z3950_profils"]."

".$profils."

"; $fields=$this->get_unimarc_search_fields(); //Si c'est un recalcul if ($reload) { //Recherche du profil for ($i=0; $iprofiles); $i++) { if ($this->profiles[$i]["name"]==$z3950_profil) { $profil=$this->profiles[$i]; break; } } } $form_bib1="\n"; foreach ($fields as $ufield=>$values) { if ($ufield!="FORBIDDEN") { $form_bib1.="\n"; } } $form_bib1.="

Unimarc

Champ

Propriétés

".htmlentities(" (".$ufield.")",ENT_QUOTES,$charset)."

".nl2br(htmlentities(implode("\n",$values["TITLE"]),ENT_QUOTES,$charset))."

"; $form_bib1.="\n"; $form_bib1.="\n"; //Calcul du Att1 si reload if ($reload) { foreach ($values["OPERATORS"] as $op=>$top) { $bibli="bib1_".str_replace("\$","",$ufield)."_".$op."_0"; global ${$bibli}; ${$bibli}=$profil["ufields"][$ufield]; if ($profil["operators"][$op]) { $ops=explode(",",$profil["operators"][$op]); for ($i=0; $i$bib1_value) { global ${$bib1}; ${$bib1}=$bib1_value; } } foreach ($values["OPERATORS"] as $op=>$top) { $form_bib1.=""; for ($i=0; $i<6; $i++) { $bibli="bib1_".str_replace("\$","",$ufield)."_".$op."_".$i; global ${$bibli}; $form_bib1.=""; } $form_bib1.=""; } $form_bib1.="

Opérateur	Att. 1 (Use)	Att. 2 (Relation)	Att. 3 (Position)	Att. 4 (Structure)	Att. 5 (Truncation)	Att. 6 (Completeness)
".htmlentities(($top?$top:$op),ENT_QUOTES,$charset)."

\n"; $form_bib1.="

\n"; $form.="\n"; $form.=gen_plus("bib1",$this->msg["z3950_bib1"],$form_bib1); $form.="

"; return $form; } public function make_serialized_source_properties($source_id) { global $url,$z3950_base,$z3950_login,$z3950_password,$z3950_max_notices,$z3950_format,$z3950_port,$z3950_convert,$z3950_profil, $action_xsl_expl; $t["url"]=stripslashes($url); $t["z3950_base"]=stripslashes($z3950_base); $t["z3950_login"]=stripslashes($z3950_login); $t["z3950_password"]=stripslashes($z3950_password); $t["z3950_max_notices"]=stripslashes($z3950_max_notices); $t["z3950_format"]=stripslashes($z3950_format); $t["z3950_port"]=stripslashes($z3950_port); $t["z3950_convert"]=stripslashes($z3950_convert); $t["z3950_profil"]=stripslashes($z3950_profil); $fields=$this->get_unimarc_search_fields(); //Enregistrement des profils foreach ($fields as $ufield=>$values) { foreach ($values["OPERATORS"] as $op=>$top) { for ($i=0; $i<6; $i++) { $bib1="bib1_".str_replace("\$","",$ufield)."_".$op."_".$i; global ${$bib1}; $t["z3950_bib1"][$bib1]=${$bib1}; } } } if($action_xsl_expl == "keep") { $oldparams=$this->get_source_params($source_id); if ($oldparams["PARAMETERS"]) { //Affichage du formulaire avec $params["PARAMETERS"] $oldvars=unserialize($oldparams["PARAMETERS"]); } $t["xslt_exemplaire"] = $oldvars["xslt_exemplaire"]; } else { if (($_FILES["xsl_exemplaire"])&&(!$_FILES["xsl_exemplaire"]["error"])) { $axslt_info["name"] = $_FILES["xsl_exemplaire"]["name"]; $axslt_info["content"] = file_get_contents($_FILES["xsl_exemplaire"]["tmp_name"]); $t["xslt_exemplaire"] = $axslt_info; } } $this->sources[$source_id]["PARAMETERS"]=serialize($t); } public function rec_record($record,$source_id,$search_id) { global $charset,$base_path; $date_import=date("Y-m-d H:i:s",time()); $r=array(); //Inversion du tableau $r["rs"]=($record["RS"][0]["value"]?$record["RS"][0]["value"]:"*"); $r["ru"]=($record["RU"][0]["value"]?$record["RU"][0]["value"]:"*"); $r["el"]=($record["EL"][0]["value"]?$record["EL"][0]["value"]:"*"); $r["bl"]=($record["BL"][0]["value"]?$record["BL"][0]["value"]:"*"); $r["hl"]=($record["HL"][0]["value"]?$record["HL"][0]["value"]:"*"); $r["dt"]=($record["DT"][0]["value"]?$record["DT"][0]["value"]:"*"); $exemplaires = array(); for ($i=0; $idel_old) { $ref_exists = $this->has_ref($source_id, $ref); } //Si pas de conservation des anciennes notices, on supprime if ($this->del_old) { $this->delete_from_entrepot($source_id, $ref); $this->delete_from_external_count($source_id, $ref); } //Si pas de conservation ou reférence inexistante if (($this->del_old)||((!$this->del_old)&&(!$ref_exists))) { //Insertion de l'entête $n_header["rs"]=$record["rs"]; $n_header["ru"]=$record["ru"]; $n_header["el"]=$record["el"]; $n_header["bl"]=$record["bl"]; $n_header["hl"]=$record["hl"]; $n_header["dt"]=$record["dt"]; //Récupération d'un ID $recid = $this->insert_into_external_count($source_id, $ref); foreach($n_header as $hc=>$code) { $this->insert_header_into_entrepot($source_id, $ref, $date_import, $hc, $code, $recid, $search_id); } $field_order=0; foreach($exemplaires as $exemplaire) { $sub_field_order = 0; foreach($exemplaire as $exkey => $exvalue) { $this->insert_content_into_entrepot($source_id, $ref, $date_import, '996', $exkey, $field_order, $sub_field_order, $exvalue, $recid, $search_id); $sub_field_order++; } $field_order++; } foreach ($record as $field=>$val) { if(is_array($val)){//On ne remet pas les champs rs, el, ... for ($i=0; $i$vals) { for ($j=0; $jinsert_content_into_entrepot($source_id, $ref, $date_import, $field, $sfield, $field_order, $j, $vals[$j], $recid, $search_id); } } } else { $this->insert_content_into_entrepot($source_id, $ref, $date_import, $field, '', $field_order, 0, $val[$i], $recid, $search_id); } $field_order++;//Un champ peut-être répété pour une même notice } } } $this->rec_isbd_record($source_id, $ref, $recid); } } } public function parse_query($query) { global $z3950_bib1; $r=""; for ($i=count($query)-1; $i>=0; $i--) { //if (($query[$i]->inter)&&($i)) $r.=" ".$query[$i]->inter." "; if (!$query[$i]->sub) { $af=explode(":",$query[$i]->ufield); $isid=false; if (count($af)>1) { if ($af[0]=="id") $isid=true; $amf=$af[1]; } else $amf=$af[0]; $ufield=str_replace("\$","",$amf); if ($ufield!="FORBIDDEN") { if ($isid) { $value=$this->get_values_from_id($query[$i]->values[0],$amf); } else $value=$query[$i]->values[0]; //Recherche de la valeur $bib1="bib1_".$ufield."_".$query[$i]->op."_"; if ($z3950_bib1[$bib1."0"]) { if (($query[$i]->inter)&&($i>0)) { $r.=" @".$query[$i]->inter; } $uns=explode(",",$z3950_bib1[$bib1."0"]); for ($k=0; $kparse_query($query[$i]->sub); } } return $r; } public function get_convert_order($path) { if (count($this->convert_path_order)==0) { $this->parse_convert_catalog(); } foreach ($this->convert_path_order as $c) { if ($c["PATH"]==$path) return $c["INDEX"]; } return 0; } //Fonction de recherche public function search($source_id,$query,$search_id) { global $base_path, $charset, $include_path; //global $url,$z3950_base,$z3950_login,$z3950_password,$z3950_max_notices,$z3950_format,$z3950_port,$z3950_convert,$z3950_profil; $this->error=false; $this->error_message=""; $params=$this->get_source_params($source_id); $this->fetch_global_properties(); if ($params["PARAMETERS"]) { //Affichage du formulaire avec $params["PARAMETERS"] $vars=unserialize($params["PARAMETERS"]); foreach ($vars as $key=>$val) { global ${$key}; ${$key}=$val; } } if (!($z3950_max_notices*1)) $z3950_max_notices=100; //Tranformation de la recherche en requete rpn bib1 $rpn=$this->parse_query($query); $zurl=$url.($z3950_port?":".$z3950_port:"").($z3950_base?"/".$z3950_base:""); $opts=array(); if ($z3950_login) $opts["user"]=$z3950_login; if ($z3950_password) $opts["password"]=$z3950_password; $opts["piggyback"]=false; $yaz_id=yaz_connect($zurl,$opts); yaz_element($yaz_id,"F"); yaz_range($yaz_id,1,$z3950_max_notices); yaz_syntax($yaz_id,strtolower($z3950_format)); yaz_search($yaz_id,"rpn",$rpn." "); $opts_wait=array("timeout"=>$params["TIMEOUT"]); yaz_wait($opts_wait); if (yaz_error($yaz_id)) { $this->error=true; $this->error_message=yaz_error($yaz_id); } else { $n_results=yaz_hits($yaz_id); if ($n_results>$z3950_max_notices) $n_results=$z3950_max_notices; $convert_order=$this->get_convert_order($z3950_convert); for ($k=1; $k<=$n_results; $k++) { $notice = yaz_record($yaz_id, $k,"raw"); //Conversion de la notice if ($z3950_convert) { $export= new convert($notice,$convert_order) ; if (!$export->error) $cnotice=$export->output_notice; else $cnotice=""; } else $cnotice=$notice; if ($cnotice) { //Conversion de la notice en XML $xmlunimarc=new xml_unimarc(); $nxml=$xmlunimarc->iso2709toXML_notice($cnotice); $xmlunimarc->notices_xml_[0] = ''.$xmlunimarc->notices_xml_[0]; if ($xslt_exemplaire) { $xmlunimarc->notices_xml_[0] = $this->apply_xsl_to_xml($xmlunimarc->notices_xml_[0], $xslt_exemplaire["content"]); } // print_r($xmlunimarc->notices_xml_[0]); if ($nxml>=1) { $params=_parser_text_no_function_($xmlunimarc->notices_xml_[0] ,"NOTICE"); $this->rec_record($params,$source_id,$search_id); } } } } } } ?>