=') && extension_loaded('xsl')) {
require_once($include_path.'/xslt-php4-to-php5.inc.php');
}
class oai extends connector {
//Variables internes pour la progression de la récupération des notices
public $current_set; //Set en cours de synchronisation
public $total_sets; //Nombre total de sets sélectionnés
public $metadata_prefix; //Préfixe du format de données courant
public $n_recu; //Nombre de notices reçues
public $xslt_transform; //Feuille xslt transmise
public $sets_names; //Nom des sets pour faire plus joli !!
public function __construct($connector_path="") {
parent::__construct($connector_path);
}
public function get_id() {
return "oai";
}
//Est-ce un entrepot ?
public function is_repository() {
return 1;
}
public function source_get_property_form($source_id) {
global $base_path, $charset, $clean_base_url, $sets, $formats, $xsl_transform, $url;
global $del_deleted, $clean_html;
$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;
}
}
$form = "
";
if (empty($url)) {
$form .= "
".$this->msg["rec_addr"]."
";
} else {
//Intérogation du serveur
$oai_p = new oai20($url, $charset, $params["TIMEOUT"]);
if ($oai_p->error) {
$form .= "
";
return $form;
}
//Nécessaire pour passer les valeurs obtenues dans form_pour_maj_entrepot au javascript asynchrone
public function get_maj_environnement($source_id) {
global $form_from;
global $form_until;
global $form_radio;
$envt=array();
$envt["form_from"]=$form_from;
$envt["form_until"]=$form_until;
$envt["form_radio"]=$form_radio;
return $envt;
}
public function maj_entrepot($source_id,$callback_progress="",$recover=false,$recover_env="") {
global $form_from, $form_until, $form_radio;
$this->callback_progress=$callback_progress;
$params=$this->unserialize_source_params($source_id);
$p=$params["PARAMETERS"];
$this->metadata_prefix=$p["formats"];
$this->source_id=$source_id;
$this->n_recu=0;
$this->xslt_transform=$p["xsl_transform"]["code"];
//Connexion
$oai20=new oai20($p["url"],"utf-8",$params["TIMEOUT"],$p["clean_base_url"]);
if (!$oai20->error) {
if ($recover) {
$envt=unserialize($recover_env);
$sets=$envt["sets"];
$date_start=$envt["date_start"];
$date_end=$envt["date_end"];
$this->del_old=false;
} else {
//Affectation de la date de départ
if ($form_radio == "all_notices") {
$date_start = '';
$date_end = '';
} else if ($form_radio == "last_sync") {
//Recherche de la dernière date...
$requete="select unix_timestamp(max(date_import)) from entrepot_source_".$source_id." where 1;";
$resultat=pmb_mysql_query($requete);
if (pmb_mysql_num_rows($resultat)) {
$last_date=pmb_mysql_result($resultat,0,0);
if ($last_date) {
//En fonction de la granularité, on ajoute une seconde ou un jour !
if ($oai20->granularity=="YYYY-MM-DD") $last_date+=3600*24; else $last_date+=1;
} else {
$earliest_date=new iso8601($oai20->granularity);
$last_date=$earliest_date->iso8601_to_unixtime($oai20->earliestDatestamp);
}
} else {
$earliest_date=new iso8601($oai20->granularity);
$last_date=$earliest_date->iso8601_to_unixtime($oai20->earliestDatestamp);
}
$date_start=$last_date;
} else {
if ($form_from)
$date_start=strtotime($form_from);
if ($form_until)
$date_end = strtotime($form_until);
else
$date_end = '';
}
//Recherche des sets sélectionnés
$sets_names = array();
foreach ($oai20->sets as $code=>$set) {
$sets_names[$code] = $set['name'];
}
$this->sets_names=$sets_names;
for ($i=0; $isets[$p["sets"][$i]]) {
$sets[]=$p["sets"][$i];
}
}
$this->del_old=true;
}
//Mise à jour de source_sync pour reprise en cas d'erreur
$envt["sets"]=$sets;
$envt["date_start"]=$date_start;
$envt["date_end"]=$date_end;
$requete="update source_sync set env='".addslashes(serialize($envt))."' where source_id=".$source_id;
pmb_mysql_query($requete);
//Lancement de la requête
$this->current_set=0;
$this->total_sets=count($sets);
if (count($sets)) {
for ($i=0; $icurrent_set=$i;
$oai20->list_records($date_start,$date_end,$sets[$i],$p["formats"],array(&$this,"rec_record"),array(&$this,"progress"));
if (($oai20->error)&&($oai20->error_oai_code!="noRecordsMatch")) {
$this->error=true;
$this->error_message.=$oai20->error_message." ";
}
}
} else {
$this->current_set=0;
$this->total_sets=1;
$oai20->list_records($date_start,$date_end,"",$p["formats"],array(&$this,"rec_record"),array(&$this,"progress"));
if (($oai20->error)&&($oai20->error_oai_code!="noRecordsMatch")) {
$this->error=true;
$this->error_message.=$oai20->error_message." ";
}
}
} else {
$this->error=true;
$this->error_message=$oai20->error_message;
}
return $this->n_recu;
}
public static function get_syncronised_sets_template($elements, $caller, $element_name, $element_id, $completion) {
$display = '';
$display .= templates::get_event_add_completion_field($element_name, $element_id, $completion);
$display .= templates::get_button_selector($caller.'_'.$element_name.'_selector', $completion, $caller, '¶m1='.$element_id.'¶m2='.$element_name);
$display .= templates::get_button_clear_values($element_name, $element_id);
$display .= templates::get_button_add_completion_field($element_name, $element_id, $completion);
if (!empty($elements)) {
foreach ($elements as $i => $element) {
$display .= "