";
//// le Mois et l'année en cours///////////////////
$annee = date("Y");
//$mois = "08";
$mois = date("m");
$fichiermois = $annee.$mois;
//echo $annee.$mois;
$fichierAT = "1/".$fichiermois."01.dat";
$fichierAP = "2/".$fichiermois."01.dat";
$fichierFIB = "5/".$fichiermois."01.dat";
$fichierCAV = "7/".$fichiermois."01.dat";
//echo $fichierAT.$fichierAP.$fichierFIB.$fichierCAV;
//$dirname = "Z:";
$dirname = "D:/wamp/www/fichiers";
$dirtemp = "D:/wamp/www/temp/";
//$dir = opendir($dirname);
$array = array($fichierAT,$fichierAP,$fichierFIB ,$fichierCAV);
$tab_nom = array("AT","AP","FIB","CAV");
foreach ($array as $i => $value) {
$fichier = $dirname."/".$value;
$value = str_replace($array,$tab_nom,$value);
//On cherche le dernier enregistrement pour récupérer les valeurs en cas de démarrage à vide//////////
//////////au passage des mois///////////////////////////////////////////////////////
$val1_temp = strtolower($value)."_t";
$val2_temp= strtolower($value)."_hr";
$val3_temp = strtolower($value)."_p";
$val4_temp = strtolower($value)."_var";
$sql = "select $val1_temp, $val2_temp, $val3_temp, $val4_temp from hvac.hvac_pas where id in (SELECT max(id) from hvac.hvac_pas)";
$result2 = mysql_query($sql);
$tabligne2 = mysql_fetch_array($result2);
echo "$sql
";
echo "Temp: $tabligne2[$val1_temp] $tabligne2[$val2_temp] $tabligne2[$val3_temp] $tabligne2[$val4_temp]
";
///////////////////////////////////////////////////////////////////////////////////////////////////////
$ftemp=fopen($dirtemp.$value,"w");
echo $fichier;
if ($TabFich = file($fichier)) {
for($i = 0; $i < count($TabFich); $i++){
$pv = str_replace("\t",";",$TabFich[$i]);
if (fwrite($ftemp, $pv) === FALSE) {
echo 'Impossible d\'écrire dans le fichier '.$ftemp;
exit;
}
}
}
$fichier_t = $dirtemp.$value;
////////Import du fichier////////////////////////////////////////
$sql = "TRUNCATE TABLE `table 41` ";
mysql_query($sql) or die('Erreur SQL !'.$sql.'
'.mysql_error());
$sql = "LOAD DATA LOCAL INFILE '$fichier_t' REPLACE INTO TABLE `table 41`
FIELDS TERMINATED BY ';'
ENCLOSED BY ''
ESCAPED BY '\\\'
LINES TERMINATED BY '\\r\\n'";
mysql_query($sql) or die('Erreur SQL !'.$sql.'
'.mysql_error());
$sql = "SELECT max(`dat`) FROM `table 41`";
$result = mysql_query($sql);
$rep = mysql_fetch_array($result);
$tempsmax = $rep[0];
//////////////////////////////////////////////////////////////////////////
$date_cre = date("Y-m-d H:i:s");
$cabine = $value;
$compt = 0;
ini_set('max_execution_time', 1200);
echo $sql."
";
if ($value == 'AT'){
$sql = "select max(datestamp) from hvac.hvac_pas";
$result2 = mysql_query($sql);
$tabligne2 = mysql_fetch_array($result2);
$datestampdeb = $tabligne2[0];
$datestampdeb = $datestampdeb + 300;
$datestampfin = 86400*(floatval($tempsmax)-25569.08333);
Echo "Date Début: ".date('Y-m-d H:i:s', $datestampdeb). " Date de fin: ".date('Y-m-d H:i:s', $datestampfin)."
";
for ($i = $datestampdeb; $i <= $datestampfin; $i=$i+300) {
//echo $i." ".date('Y-m-d H:i:s', $i)."
";
$paspasmin_H = date('H:i:s', $i);
$paspasmin_D = date('Y-m-d', $i);
$heureExcel = ($i/86400) + 25569.08333;
$sql = "INSERT INTO `hvac_pas` (date_cre, datestamp, date_val, heure_val, fichier_date)
VALUES ('$date_cre', $i, '$paspasmin_D', '$paspasmin_H', $heureExcel)";
echo "$sql
";
mysql_query($sql) or die('Erreur SQL !'.$sql.'
'.mysql_error());
}
}
$sql = "SELECT * FROM hvac_pas where datestamp_$value = 0 and fichier_date <= $tempsmax";
$result2 = mysql_query($sql);
echo $sql."
";
while($tabstamp = mysql_fetch_array($result2)) {
$hdeb = $tabstamp['fichier_date'];
$hfin = $tabstamp['datestamp'];
$hfin = (($hfin+300)/86400) + 25569.08333;
$sql2 = "SELECT * FROM `TABLE 41` where dat >= $hdeb and dat < $hfin limit 0,1";
echo $sql2."
";
$result = mysql_query($sql2);
$tabligne = mysql_fetch_array($result);
//////////////////////////////////////////////////////////////////////////
$mytime = $tabligne['dat'];
$val1 = $tabligne['dat_p'];
$val2 = $tabligne['dat_q'];
$val3 = $tabligne['dat_r'];
$val4 = $tabligne['dat_s'];
echo $tabligne['dat']." ".$tabligne['dat_p']." ".$tabligne['dat_q']
." ".$tabligne['dat_r']." ".$tabligne['dat_s'].'
';
$dateheure = 86400*(floatval($tabligne['dat'])-25569.08333);
$dateheure = intval($dateheure);
$champ_t = strtolower($cabine)."_t";
$champ_hr = strtolower($cabine)."_hr";
$champ_p = strtolower($cabine)."_p";
$champ_var = strtolower($cabine)."_var";
$datestampcab = "datestamp_".$cabine;
$fichiercab = "fichier_".$cabine;
if (!empty($tabligne['dat'])){
echo $tabligne['dat']." ".$tabligne['dat_p']." ".$tabligne['dat_q']
." ".$tabligne['dat_r']." ".$tabligne['dat_s'].'
';
$valeurtemp = $tabligne['dat']." ".$tabligne['dat_p']." ".$tabligne['dat_q']
." ".$tabligne['dat_r']." ".$tabligne['dat_s'].'
';
$val1_temp=$val1 ;
$val2_temp=$val2;
$val3_temp=$val3;
$val4_temp=$val4;
}else{
echo "pas de valeur
";
$val1=$val1_temp;
$val2=$val2_temp;
$val3=$val3_temp;
$val4=$val4_temp;
}
///////////////////Mise à jour de la table////////////////////
$sql = "UPDATE hvac_pas SET $datestampcab = $dateheure, $fichiercab = '$cabine',
$champ_t = $val1, $champ_hr = $val2, $champ_p = $val3,
$champ_var = $val4
where id = $tabstamp[id]";
mysql_query($sql) or die('Erreur SQL !'.$sql.'
'.mysql_error());
echo "$sql
";
}
}
echo "Fin du traitement Intégration des données et mis au pas
";
?>