Script de chargement de masse d'adresse mail à partir d'un CSV

<?php
/******************************************************************************/
/*                                                                            */
/*                       __        ____                                       */
/*                 ___  / /  ___  / __/__  __ _____________ ___               */
/*                / _ \/ _ \/ _ \_\ \/ _ \/ // / __/ __/ -_|_-<               */
/*               / .__/_//_/ .__/___/\___/\_,_/_/  \__/\__/___/               */
/*              /_/       /_/                                                 */
/*                                                                            */
/*                                                                            */
/******************************************************************************/
/*                                                                            */
/* Titre          : Script de chargement de masse d'adresse mail à partir...  */
/*                                                                            */
/* URL            : http://www.phpsources.org/scripts500-PHP.htm              */
/* Auteur         : bemale                                                    */
/* Date édition   : 29 Mars 2009                                              */
/* Website auteur : http://frederic.morinfj.free.fr                           */
/*                                                                            */
/******************************************************************************/

/*
 * Définition des variables globales 
 */
define("_fic_trav_","fic_trav.txt");
define("_server_","localhost");//Adresse de la base de données
define("_username_","root");//Nom utilisateur BDD
define("_password_","");//Mot de passe
define("_schema_","test");//Nom du schema
define("_table_","mail");//Nom de la table
define("_sql_create_","CREATE TABLE "._table_." (
   mail VARCHAR(128) NOT NULL DEFAULT '',
   UNIQUE Index_mail(mail)
);"); //SQL de création de la table
define("_champ_","mail");

//On test si on a passé un fichier ou le textarea
if (empty($_FILES) && empty($_POST["list_mail"]))
{
?>
<div align="center">
    <h1>On peut soit charger un csv soit renseigner la zone de texte en séparant
 les adresses par des ; ou des , ou des Tab</h1>
    <hr />    
    <form method="post" action="<?php echo $_SERVER["PHP_SELF"];?>
" enctype="multipart/form-data">
        Position de l'adresse mail : <SELECT name="position_mail">
<?php
        for($i=1;$i<=10;$i++)
        {
            echo '<OPTION value="'.$i.'">'.$i.'°</OPTION>
            ';
        } 
?>        
        </SELECT> place.
        <br />
        <b>Séparateur : </b><select name="separateur">
            <option value="1">;</option>
            <option value="2">,</option>
            <option value="3">Tab</option>
        </select>
        <br />
        <input name="fichier" type="file">
        <br />
        <textarea name="list_mail" rows="20" ></textarea>
        <br />        
        <input type="submit">
    </form>
</div>
<?php
}
else
{
    $pos = (empty($_POST["position_mail"]))?$_POST["position_mail"]:1;
    $pos--; //On décrémente premier index du tableau = 0 
    
    //On définit le séparateur
    if (!empty($_POST["separateur"]))
    {
        switch ($_POST["separateur"])
        {
            case 1 :
            {
                $sep = ';'; //Point virgule
                break;
            }
            case 2 :
            {
                $sep = ','; //virgule
                break;
            }
            case 3 :
            {
                $sep = '    '; //Tab
                break;
            }
            default:
            {
                $sep = ';';
                break;    
            }
        }
    }
    
    //Si il y a eu un fichier uploadé
    if (!empty($_FILES) && ($_FILES["fichier"]["error"]==0))
    {


        $temp_file = $_FILES["fichier"]["tmp_name"];
        if (!move_uploaded_file($temp_file, "./"._fic_trav_)) 
        {
            echo "La copie du fichier ".$_FILES["fichier"]["name"].
" n'a pas réussi...<be />"; 
        }
        
        if (is_file(_fic_trav_))
        {
            $file = fopen(_fic_trav_, "rb");
            while ($ligne = fgetcsv($file,'',$sep)) 
            {

                if (!empty($ligne[$pos])) 
//On evite de rajouter un élément vide
                    $tab[] = $ligne[$pos];
            }
            fclose($file);
            unlink(_fic_trav_); //Suppression du fichier de travail

        }
        else
        {
            echo "Il est ou ton fichier";
        }
    }
    
    //Si on a renseigné la zone de texte
    if (!empty($_POST["list_mail"]))
    {
        $textarerea = explode("\n",$_POST["list_mail"]);
        foreach ($textarerea as $ligne)
        {
            $ligne = explode(";",stripslashes($ligne));
            if (!empty($ligne[$pos])) //On evite de rajouter un élément vide
                $tab[] = $ligne[$pos];
        }
        
    }

    $rejet=array();
    $bdd = new connexion();
    foreach ($tab as $valeur)
    {
        /*
         * Supérieur à la version 5.2.1 pour éviter les failles de sécurité sur 5.2.0
 et 5.2.1
         * http://www.php-security.org/MOPB/PMOPB-45-2007.html
         */
        if ((phpversion() > "5.2.1") && filter_var($valeur,FILTER_VALIDATE_EMAIL
))
        {
            if (!$bdd->ajoute($valeur))
                $rejet["Doublon"][]=$valeur;
        }
        elseif (preg_match(
"/^[_a-zA-Z0-9-]+(\.[_a-zA-Z0-9-]+)*@([a-zA-Z0-9-]+\.)+[a-zA-Z]{2,4}$/", $valeur
))
        {
            if (!$bdd->ajoute($valeur))
                $rejet["Doublon"][]=$valeur;
        }
        else 
            $rejet["Invalide"][]=$valeur;
    }
    
    // On affiche les doublons
    if (!empty($rejet["Doublon"]))
    {
        echo '<h1>Rejet des mails en doublon</h1>';
        foreach ($rejet["Doublon"] as $adresse)
        {
            echo $adresse.'<br />';
        }
    }
    
    // On affiche les invalides
    if (!empty($rejet["Invalide"]))
    {
        echo '<h1>Rejet des mails invalide</h1>';
        foreach ($rejet["Invalide"] as $adresse)
        {
            echo $adresse.'<br />';
        }
    }
} 

class connexion
{
    var $id;
    var $res;
    var $string=array("string","blob"); //prise en compte des blob
/*
 * Construtor
 */    
    function connexion()
    {
        
        if (!($this->id = mysql_connect(_server_,_username_,_password_)))
        {
            die ("ERREUR : la connexion à la BDD a échouée !");    
        }
        if (@defined("_schema_"))
        {
            mysql_selectdb(_schema_);
            
//Vérification de l'exitence de la table dans le schema puis crétion si non
            if (!$this->verif_table())
                $this->cree_table();
            
            //vérification de l'existence du champ dans la tables
            if (!$this->verif_champ())
            {
                die ("ERREUR : le champ "._champ_." n'existe pas dans la table "
._table_." !");        
            }
        }
        else
        {
            die ("ERREUR : le schema n'est pas renseigné !");    
        }    
    }
    
/*
 * Vérification de l'existence de la table dans le schema
 */
    function verif_table ()
    {
        $tables = mysql_list_tables(_schema_);
        if (@defined("_table_"))
        {
            $trouve = false;
            while (($tmp = mysql_fetch_assoc($tables)) && !$trouve)
            {
                foreach ($tmp as $table_nom)
                    $trouve = ($table_nom==_table_);
            }
            return $trouve;
        }
        else
        {
            die ("ERREUR : la table n'est pas définie !");    
        }    
    }
/*
 * On crée la table
 */    
    function cree_table()
    {
        mysql_query(_sql_create_);
    }
    
/*
 * Vérification de l'esistence du champ dans la table 
 */
    function verif_champ()
    {
        if (@defined("_champ_"))
        {
            $champs = mysql_query("SELECT * FROM "._table_." LIMIT 0,1 ");
            $trouve = false;
            while (($tmp = mysql_fetch_field($champs)) && !$trouve)
            {
                if (!empty($tmp->name))
                {
                    if (($tmp->name)==_champ_)
                    {
                        define("_type_",$tmp->type);
// On mémorise la type du champ
                        $trouve = true;
                    }
                }
            }
            return $trouve;
        }
        else
        {
            die ("ERREUR : le champ n'est pas défini !");
        }
    }
/*
 * Ajout d'une valeur 
 */    
    function ajoute($val) 
    {
        if (!$this->existe($val))
        {
            if (in_array(_type_,$this->string))
                $query = "INSERT INTO "._table_." ("._champ_.") VALUES ('".
mysql_escape_string($val)."')";
            else
                $query = "INSERT INTO "._table_." ("._champ_.") VALUES (".$val.
")";
                
            return mysql_query($query);
        }
        else
            return false;

    }
    
/*
 * Contôle l'existence d'une valeur
 */    
    function existe($val)
    {
            
            if (in_array(_type_,$this->string))
                $query = "SELECT * FROM "._table_." WHERE "._champ_."='".
mysql_escape_string($val)."'";
            else
                $query = "SELECT * FROM "._table_." WHERE "._champ_."=".$val;

            return (mysql_num_rows(mysql_query($query))>=1);
    }
}
?>