'maj_dt_reprise',
'data' => 0,
);
$sql_dt = "SELECT count(dossier) FROM ".DB_PREFIXE."dossier
LEFT OUTER JOIN ".DB_PREFIXE."donnees_techniques ON dossier.dossier=donnees_techniques.dossier_instruction
WHERE donnees_techniques.donnees_techniques IS NULL";
$res_dt = $f->db->getone($sql_dt);
$f->addToLog("app/update_DA.php: db->getone(\"".$sql_dt."\");", DEBUG_MODE);
if($f->isDatabaseError($res_dt)){
$f->addToLog("app/update_DA.php: db->query(\"".$sql_dt."\");", DEBUG_MODE);
die();
}
$round = round($res_dt/1000)+1;
$count_dt = 0;
$data = "''";
gc_enable();
for($i=0; $i<= $round; $i++) {
ob_start();
$postfields['data']=$data;
$post = http_build_query($postfields);
// Données passées en POST
curl_setopt($curl, CURLOPT_POSTFIELDS, $post);
// Retour de la session cURL
$return = curl_exec($curl);
// Decode du json et crée un objet
$return = json_decode($return);
if($return->http_code != 200) {
echo $return->message."
";
}
$ret = explode("|", $return->message);
$data.=$ret[1];
$count_dt += $ret[0];
echo "
". str_replace("'", "DA sans DT : ",str_replace("', ","
",$ret[1]));
echo $count_dt."/".$res_dt."
";
gc_collect_cycles();
$time_end = microtime(true);
$time = round($time_end - $time_start, 2);
echo $time." "._("secondes")."
";
echo round(memory_get_usage()/1024)." ko
";
$content = ob_get_clean();
file_put_contents('../tmp/update_da.log', str_replace("
", "\n", $content), FILE_APPEND);
}
curl_close($curl);
echo "Fin création DT manquantes
";
$content = ob_get_clean();
file_put_contents('../tmp/update_da.log', str_replace("
", "\n", $content), FILE_APPEND);
ob_start();
$sql_date_depot = "UPDATE ".DB_PREFIXE."dossier_autorisation as da SET date_depot = d.date_depot
FROM ".DB_PREFIXE."dossier as d WHERE da.dossier_autorisation=d.dossier_autorisation AND d.version=0";
$res_date_depot = $f->db->query($sql_date_depot);
$f->addToLog("app/update_DA.php: db->query(\"".$sql_date_depot."\");", DEBUG_MODE);
$f->isDatabaseError($res_date_depot);
echo "Update date dépôt initiale
";
$content = ob_get_clean();
file_put_contents('../tmp/update_da.log', str_replace("
", "\n", $content), FILE_APPEND);
// Initialisation session cURL
$curl = curl_init();
// Url de la page à récupérer
curl_setopt($curl, CURLOPT_URL, $url);
// Permet de récupérer le résultat au lieu de l'afficher
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
// Démarrer un nouveau cookie de session
curl_setopt($curl, CURLOPT_COOKIESESSION, true);
curl_setopt($curl, CURLOPT_POST, true);
$postfields = array(
'module' => 'maj_da_reprise',
'data' => array('offset' => 0),
);
$sql_da = "SELECT count(*) FROM ".DB_PREFIXE."dossier_autorisation";
$res_da = $f->db->getone($sql_da);
$f->addToLog("app/update_DA.php: db->query(\"".$sql_da."\");", DEBUG_MODE);
$f->isDatabaseError($res_da);
$round = round($res_da/1000)+1;
$count_da = 0;
gc_enable();
for($i=0; $i<= $round; $i++) {
ob_start();
$postfields['data']['offset']=$i*1000;
$post = http_build_query($postfields);
// Données passées en POST
curl_setopt($curl, CURLOPT_POSTFIELDS, $post);
// Retour de la session cURL
$return = curl_exec($curl);
// Decode du json et crée un objet
$return = json_decode($return);
if($return->http_code != 200) {
echo $return->message."
";
}
$ret = explode("|", $return->message);
$count_da = $count_da + $ret[0];
echo "
".$ret[1];
echo $count_da."/".$res_da."
";
gc_collect_cycles();
$time_end = microtime(true);
$time = round($time_end - $time_start, 2);
echo $time." "._("secondes")."
";
echo round(memory_get_usage()/1024)." ko
";
$content = ob_get_clean();
file_put_contents('../tmp/update_da.log', str_replace("
", "\n", $content), FILE_APPEND);
}
curl_close($curl);
$f->db->commit();
gc_disable();
?>