Moi j'ai fais ce projet la pour inserer les donnée que moi déja recu de ma boite mail
et apres les transformer vers csv, alors moi je veux inserer les valeur du ces fichiers dans ma base de donnée et j'ai utilise ce code la mais il ya toujoues de problem aide moi
$connect = "{".$server_mail.":".$port."/pop3/notls}INBOX" or die("Erreur de connexion : ". imap_last_error());
//Connexion à la boite mail
$mail = imap_open($connect, $user_mail, $passwd_mail);
$nbmess = imap_num_msg($mail);
/*//Récupération des pièce jointes dans les messages
for($j=1;$j<=$nbmess;$j++)
{
$header = imap_headerinfo($mail,$j);
$sujet = $header->subject;
$struct = imap_fetchstructure($mail,$j);
if ($struct->type == 1)
{
$nbrparts = !$struct->parts ? "1" : count($struct->parts);
}
$piece = array();
for($h=1;$h<=$nbrparts;$h++)
{
$part = $struct->parts[1] ;
$piece = imap_fetchbody($mail,$j,$h+1);
if ($part->encoding == "3")
{
$nbparam = count($part->parameters);
$i=0;
while ($i < $nbparam)
{
$i++;
$param = $part->parameters[$i];
$nom_fichier = $struct->parts[$h]->dparameters[0]->value;
}
$piece = imap_base64($piece);
}
//Enregistrement de la pièce jointe
if($nom_fichier != null)
{
$newfichier = fopen("P:/FINANCE/Fraudes/Alarmes_Orange/".microtime()."_".$nom_fichier,"w+");
fwrite($newfichier,$piece);
fclose($newfichier);
}
}
}
*/
$dir = opendir($rep);
//Bibliothèque XLS vers CSV
require_once 'Excel/reader.php';
//Lister le contenu du répertoire $rep
while ($f = readdir($dir)) {
if(is_file($rep.$f)) {
$extension=strrchr($rep.$f,'.');
//Conversion des fichiers XLS en CSV
if ($extension == ".xls")
{
//Création du fichier CSV à partir du XLS
$xls2csv_fichier = fopen($rep.$f.".csv","w+");
$reader = new Spreadsheet_Excel_Reader();
$reader->setOutputEncoding('CP1251');
$reader->read($rep.$f);
foreach($reader->sheets as $k=>$data)
{
foreach($data['cells'] as $row)
{
foreach($row as $cell)
{
fwrite($xls2csv_fichier,$cell.";");
}
fwrite($xls2csv_fichier,"\n");
}
}
//Archivage du XLS d'origine
rename($rep.$f, $rep."Archive_XLS/".$f);
}
}
}
closedir($dir);
//Identification du type d'alarme et insertion en base de données.
$dir = opendir($rep);
while ($f = readdir($dir)) {
if(is_file($rep.$f))
{
$extension=strrchr($rep.$f,'.');
if ($extension == ".csv")
{
// Connexion à la base de donnée d'injection (Alarmes_Orange)
$connect_inject = mysql_connect($serverbdd_inject,$userbdd_inject,$passbdd_inject) or die ("Erreur de connexion à la BDD inject :".$serverbdd_inject);
$bdd_inject = mysql_select_db($base_inject) or die("pas possible de trouver la base");
//Connexion à la BDD de selection (VIRGIN_PROD)
$connect_select = mysql_connect($serverbdd_select,$userbdd_select,$pwdbdd_select) or die ("Erreur de connexion à la BDD select :".$serverbdd_select);
$bdd_select = mysql_select_db($base_select) or die("pas possible de trouver la base");
//Identification du type de fichier avec son nom
$type_alarm = preg_replace ("/([^_]*_)([^\.]*)(.*)/","$2",$f);
echo "Expression régulière : ".$type_alarm."<br>";
//Action en fonction du type
switch($type_alarm)
{
case "Surc_Virgin":
echo "Nom du fichier : ".$f."<br>";
//$inF = fopen($rep.$f, 'r');
$row = 0;
$inF = $rep.$f;
$handle = fopen($inF, "r") or die("Cannot open $inF");
//echo '<table border=\'1\'>';
while (($ligne = fgetcsv($handle, 4096, ";")) !== FALSE)
{
$valeur[$row]=explode(";",$ligne);
//$val = explode(";",$ligne);
$premrier_ligne = 0;
$num = count($ligne);
echo "<p> $num champs à la ligne $row: <br /></p>\n\n";
echo $ligne[0];
for ($c=0; $c < $num; $c++) {
echo $ligne[$c] . "<br />\n"; }
list($Nom, $IMSI, $SIM13, $DatOuvDossier, $Dossier, $Durée, $hhmmss, $Mont_Euros, $PaysdestinationouTypeAppel, $DateAlarme, $Date1ereAlarme, $Nbsortie) = $ligne;
print_r ($IMSI);
echo "<pre>";
print_r ($valeur[$row]);
echo "</pre>";
/* $req_insert = "INSERT INTO `Table_Temp` VALUES ('$IMSI','$DateAlarme','$Date1ereAlarme','','','$Durée','','','$Mont_Euros','');";
echo $req_insert."<br>";
$res = mysql_query($req_insert,$connect_inject) or die($req_insert." ".mysql_error()."<br>");
/* $select = "SELECT * FROM `Table_Temp`";
$test = mysql_query($select,$connect_inject) or die($select." ".mysql_error()."<br>");
$o_test = mysql_fetch_object($test);
echo "echo avant delete <br><pre>";print_r($o_test);echo "</pre>"; */
/* $req_del = "DELETE FROM `Table_Temp`;";
echo $req_del."<br>";
$res = mysql_query($req_del,$connect_inject) or die($req_del." ".mysql_error()."<br>");
/* $select = "SELECT * FROM `Table_Temp`";
$test = mysql_query($select,$connect_inject) or die($select." ".mysql_error()."<br>");
$o_test = mysql_fetch_object($test);
echo "echo apres delete <pre>";print_r($o_test);echo "</pre>"; */
$req = "SELECT se.IMSI, sm.NUM_ABO, se.NSCE, sm.MSISDN, cl.NUM_HIGHDEAL,tr.DATE_TRANS
FROM STOCK_NSCE as se
left join STOCK_MSISDN as sm on se.MSISDN = sm.MSISDN
left join CLIENT as cl on cl.ID_CLIENT = sm.ID_CLIENT
left join TRANSACTION as tr on tr.ID_CLIENT = cl.ID_CLIENT
WHERE IMSI = '$IMSI';";
$R_req = mysql_query($req, $connect_select) or die (mysql_error());
while($O_req = mysql_fetch_object($R_req))
{
echo $O_req->NUM_ABO . " : " . $O_req->NSCE . " : " . $O_req->MSISDN . " : " . $O_req->NUM_HIGHDEAL . " : " . $O_req->DATE_TRANS;
echo "<br />";
}
if($premrier_ligne > 1)
{
$nom = $valeur[$row][0];
$imsi = $valeur[$row][1];
$sim13 = $valeur[$row][2];
$datouvdossier = $valeur[$row][3];
$dossier = $valeur[$row][4];
$durée = $valeur[$row][5];
$hhmmss = $valeur[$row][6];
$mont_euros = $valeur[$row][7];
$PaysdestinationouTypeAppel = $valeur[$row][8];
$datealarme = $valeur[$row][9];
$Date1ereAlarme = $valeur[$row][10];
$Nbsortie = $valeur[$row][11];
//réccuperer les valeur du requete en variable
while($rows = mysql_fetch_array($R_req))
{
$NUM_ABO = $rows["NUM_ABO"];
$Nsce = $rows["Nsce"];
$MSISDN = $rows["MSISDN"];
$NUM_ABO = $rows["NUM_HIGHDEAL"];
$DATE_TRANS = $rows["DATE_TRANS"];
}
//requete insertion dans la base
$insert_req = "INSERT INTO `Alarmes` VALUES ('$NUM_ABO','$Nsce','$MSISDN','$NUM_HIGHDEAL','$DATE_TRANS','$DateAlarme','$Date1erAlarme','','','','','$Durée','','','$Montant');";
$res = mysql_query($insert_req, $connect_inject) or die($insert_req." ".mysql_error()."<br>");
echo $insert_req. "<br>";
echo "requete INSERTION EN BASE ALarmes_Oranges. ";
$premrier_ligne++;
}
/* $insert_req = "INSERT INTO `Alarmes` VALUES ('$NUM_ABO','$Nsce','$MSISDN','$NUM_HIGHDEAL','$DATE_TRANS','$DateAlarme','$Date1erAlarme','','','','','$Durée','','','$Montant');";
$res = mysql_query($insert_req,$connect_inject) or die($insert_req." ".mysql_error()."<br>"); */
$row++;
}
echo $Nom;
echo $IMSI;
echo $SIM13;
echo $DatOuvDossier;
echo $Dossier;
echo $Durée;
echo $hhmmss;
echo $Mont_Euros;
echo $PaysdestinationouTypeAppel;
echo $Date1ereAlarme;
echo $Nbsortie;
echo "<pre>";
print_r ($valeur[$row]);
echo "</pre>";
fclose($handle);
break;
case "Roam_Breizh":
echo "Nom du fichier : ".$f."<br>";
/* $inF = fopen($rep.$f,"r");
echo $rep.$f."<br>";
while (!feof($inF))
{
$ligne = fgets($inF, 4096);
$valeur = explode(";", $ligne);
//echo $ligne."<br>";
echo "<pre>";
print_r ($valeur);
echo "</pre>";
}
fclose($inF); */
break;
case "Surc_Breizh2008-142-BZH":
echo "Nom du fichier : ".$f."<br>";
/* $inF = fopen($rep.$f,"r");
echo $rep.$f."<br>";
while (!feof($inF))
{
$ligne = fgets($inF, 4096);
$valeur = explode(";", $ligne);
//echo $ligne."<br>";
echo "<pre>";
print_r ($valeur);
echo "</pre>";
}
fclose($inF); */
break;
case "Surc_Breizh":
echo "Nom du fichier : ".$f."<br>";
/* $inF = fopen($rep.$f,"r");
echo $rep.$f."<br>";
while (!feof($inF))
{
$ligne = fgets($inF, 4096);
$valeur = explode(";", $ligne);
//echo $ligne."<br>";
echo "<pre>";
print_r ($valeur);
echo "</pre>";
}
fclose($inF); */
break;
case "FAF_Breizh":
echo "Nom du fichier : ".$f."<br>";
/* $inF = fopen($rep.$f,"r");
echo $rep.$f."<br>";
while (!feof($inF))
{
$ligne = fgets($inF, 4096);
$valeur = explode(";", $ligne);
//echo $ligne."<br>";
echo "<pre>";
print_r ($valeur);
echo "</pre>";
}
fclose($inF); */
break;
case "FAF_Virgin":
echo "Nom du fichier : ".$f."<br>";
/* $inF = fopen($rep.$f,"r");
echo $rep.$f."<br>";
while (!feof($inF))
{
$ligne = fgets($inF, 4096);
$valeur = explode(";", $ligne);
//echo $ligne."<br>";
echo "<pre>";
print_r ($valeur);
echo "</pre>";
}
fclose($inF); */
break;
default:
echo $rep.$f."<br>";
break;
}
}
}
mysql_close($connect_select);
mysql_close($connect_inject);
}
?>