id=$id;
$this->n_ligne=$n_ligne;
$this->params=$params;
$this->search=&$search;
}
//fonction de recuperation des operateurs disponibles pour ce champ spécial (renvoie un tableau d'opérateurs)
public function get_op() {
$operators = array();
$operators["EQ"]="=";
return $operators;
}
//fonction de recuperation de l'affichage de la saisie du critère
public function get_input_box() {
global $msg,$charset;
//Recuperation de la valeur de saisie
$valeur_="field_".$this->n_ligne."_s_".$this->id;
global ${$valeur_};
$valeur=${$valeur_};
if ((!$valeur)&&(isset($_SESSION["checked_sources"]))) $valeur=$_SESSION["checked_sources"];
if (!is_array($valeur)) $valeur=array();
//Recherche des sources
$requete="SELECT connectors_categ_sources.num_categ, connectors_sources.source_id, connectors_categ.connectors_categ_name as categ_name, connectors_sources.name, connectors_sources.comment, connectors_sources.repository, connectors_sources.opac_allowed, source_sync.cancel FROM connectors_sources LEFT JOIN connectors_categ_sources ON (connectors_categ_sources.num_source = connectors_sources.source_id) LEFT JOIN connectors_categ ON (connectors_categ.connectors_categ_id = connectors_categ_sources.num_categ) LEFT JOIN source_sync ON (connectors_sources.source_id = source_sync.source_id AND connectors_sources.repository=2) ORDER BY connectors_categ_sources.num_categ DESC, connectors_sources.name";
$resultat=pmb_mysql_query($requete);
$r="";
return $r;
}
//fonction de conversion de la saisie en quelque chose de compatible avec l'environnement
public function transform_input() {
}
//fonction de creation de la requete (retourne une table temporaire)
public function make_search() {
global $selected_sources;
global $search;
global $msg;
$error_messages = array();
//On modifie l'operateur suivant !!
$inter_next="inter_".($this->n_ligne+1)."_".$search[$this->n_ligne+1];
global ${$inter_next};
if (${$inter_next}) ${$inter_next}="or";
//Recuperation de la valeur de saisie
$valeur_="field_".$this->n_ligne."_s_".$this->id;
global ${$valeur_};
$valeur=${$valeur_};
if(is_array($valeur)) {
$_SESSION["checked_sources"] = $valeur;
}
global $charset, $class_path,$include_path,$base_path;
//Override le timeout du serveur mysql, pour être sûr que le socket dure assez longtemps pour aller jusqu'aux ajouts des résultats dans la base.
$sql = "set wait_timeout = 300";
pmb_mysql_query($sql);
for ($i=0; $iget_source_params($valeur[$i]);
if ($params["REPOSITORY"]==2) {
$source_id=$valeur[$i];
$source_name_sql = "SELECT name FROM connectors_sources WHERE source_id = ".addslashes($source_id);
$source_name = pmb_mysql_result(pmb_mysql_query($source_name_sql), 0, 0);
$unimarc_query=$this->search->make_unimarc_query();
$search_id=md5(serialize($unimarc_query));
//Suppression des vieilles notices
//Vérification du ttl
$ttl=$params["TTL"];
$requete="delete from entrepot_source_$source_id where unix_timestamp(now())-unix_timestamp(date_import)>".$ttl.';';
pmb_mysql_query($requete);
$requete="select count(1) from entrepot_source_$source_id where search_id='".addslashes($search_id)."'";
$resultat=pmb_mysql_query($requete);
$search_exists=pmb_mysql_result($resultat,0,0);
$requete="select count(1) from entrepot_source_$source_id where search_id='".addslashes($search_id)."' and unix_timestamp(now())-unix_timestamp(date_import)>".$ttl;
$resultat=pmb_mysql_query($requete);
if ((pmb_mysql_result($resultat,0,0)) || ((!pmb_mysql_result($resultat,0,0))&&(!$search_exists))) {
//Recherche si on a le droit
$flag_search=true;
$requete="select (unix_timestamp(now())-unix_timestamp(date_sync)) as sec from source_sync where source_id=$source_id";
$res_sync=pmb_mysql_query($requete);
if (pmb_mysql_num_rows($res_sync)) {
$rsync=pmb_mysql_fetch_object($res_sync);
if ($rsync->sec>300) {
pmb_mysql_query("delete from source_sync where source_id=".$source_id);
} else $flag_search=false;
}
if ($flag_search) {
$flag_error=false;
for ($j=0; $j<$params["RETRY"]; $j++) {
$src->search($valeur[$i],$unimarc_query,$search_id);
if (!$src->error)
break;
else {
$flag_error=true;
$error_messages[$source_name][] = $src->error_message;
/*print $src->error_message." "*/;
}
}
//Il y a eu trois essais infructueux, on d�sactive pendant 5 min !!
if ($flag_error) {
pmb_mysql_query("insert into source_sync (source_id,date_sync,cancel) values($source_id,now(),2)");
$error_messages[$source_name][] = sprintf($msg["externalsource_isblocked"], date("H:i", time() + 5*60));
}
}
}
}
}
if ($error_messages) {
echo '
';
}
//Sources
$tvaleur=array();
for ($i=0; $in_ligne;
//$requete="create temporary table ".$t_table." select distinct recid as notice_id from entrepots where source_id in (".implode(",",$valeur).")";
$requete="create temporary table ".$t_table." (notice_id integer unsigned not null)";
pmb_mysql_query($requete);
return $t_table;
}
//fonction de traduction littérale de la requête effectuée (renvoie un tableau des termes saisis)
public function make_human_query() {
global $msg;
global $include_path;
$litteral=array();
//Récupération de la valeur de saisie
$valeur_="field_".$this->n_ligne."_s_".$this->id;
global ${$valeur_};
$valeur=${$valeur_};
if(isset($valeur) && is_array($valeur) && count($valeur)){
$requete="select name from connectors_sources where source_id in (".implode(",",$valeur).")";
$resultat=pmb_mysql_query($requete);
while ($r=pmb_mysql_fetch_object($resultat)) {
$litteral[]=$r->name;
}
}
return $litteral;
}
public function make_unimarc_query() {
return array();
}
//fonction de vérification du champ saisi ou sélectionné
public function is_empty($valeur) {
if (count($valeur)) return false; else return true;
}
}
?>