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;
}
}
//URL
if (!isset($url))
$url = "http://www.oecd-ilibrary.org/fr/emploi/livres/2012";
$form="
";
return $form;
}
public function make_serialized_source_properties($source_id) {
global $url;
$t = array();
$t["url"]=stripslashes($url);
$this->sources[$source_id]["PARAMETERS"]=serialize($t);
}
//Récupération des proriétés globales par défaut du connecteur (timeout, retry, repository, parameters)
public function fetch_default_global_values() {
parent::fetch_default_global_values();
$this->timeout=40;
$this->repository=1;
$this->ttl=60000;
}
public function progress($query,$token) {
$callback_progress=$this->callback_progress;
if ($token["completeListSize"]) {
$percent=($this->current_set/$this->total_sets)+(($token["cursor"]/$token["completeListSize"])/$this->total_sets);
$nlu=$this->n_recu;
$ntotal="inconnu";
//$nlu=$token["cursor"];
//$ntotal=$token["completeListSize"];
} else {
$percent=($this->current_set/$this->total_sets);
$nlu=$this->n_recu;
$ntotal="inconnu";
}
call_user_func($callback_progress,$percent,$nlu,$ntotal);
}
public function cancel_maj($source_id) {
return true;
}
public function break_maj($source_id) {
return true;
}
public function maj_entrepot($source_id,$callback_progress="",$recover=false,$recover_env="") {
global $base_path,$charset;
$this->n_recu=0;
$this->callback_progress=$callback_progress;
$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 (!isset($url)) {
$this->error_message = $this->msg["oecd_unconfigured"];
$this->error = 1;
return;
}
//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) {
$last_date+=3600*24;
}
}
$ch = curl_init();
// http://www.oecd-ilibrary.org/fr/emploi/livres/2012
// http://www.oecd-ilibrary.org/fr/questionssociales/livres/2012
$addr=$url;
$sortir=0;// pour sortir du while!
$page=0;
do{
// configuration des options CURL
curl_setopt($ch, CURLOPT_URL, $addr);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
configurer_proxy_curl($ch,$addr);
$html=curl_exec($ch);
if (!$html) {
$sortir=1;
} else {
if (strtoupper($charset)!="UTF-8") $html=utf8_decode($html);
$notice_list=$this->get_field_betwen_2sep($html,"\n","\n");
$sep_notices="\n