| 12
 3
 4
 5
 6
 7
 8
 9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 
 | public synchronized static void enregistrerPieceJointeMail(String host, String user, String password, String protocole, String filtreFrom, String filtreObjet, String repertoire, boolean archive) throws Exception {
 
        // Récupération des propriétés du système
        Properties props = new Properties();
 
        // Création d'un objet Session
        Session session = Session.getInstance(props, null);
        session.setDebug(false);
 
        // Création d'un objet Store qui implémente le protocole spécifié
        Store store = session.getStore(protocole);
 
        // Connexion à l'host courant en utilisant le nom d'utilisateur / mot de passe spécifiés
        store.connect(host, user, password);
 
        // Création d'un objet Folder, correspondant au nom indiqué
        Folder folder = store.getFolder("INBOX");
 
        // Ouverture du Folder
        folder.open(Folder.READ_WRITE);
 
 
        // Lecture des messages
        Message message[] = folder.getMessages();
 
        // on contrôle les messages suivant les filtres renseignés
        for (int i = 0; i < message.length; i++) {
            boolean mailValide = true;
 
            // test si le mail d'envoi correspond 
            if ( filtreFrom != null && filtreFrom.length() > 0 ) {
                Address address[] = message[i].getFrom();
                String adrFrom = address[0].toString();
 
                if ( !adrFrom.contains(filtreFrom)) {
                    mailValide = false;
                } 
            }
 
            // test si l'objet du message correspond
            if ( filtreObjet != null && filtreObjet.length() > 0 && mailValide ) {
                String objet = message[i].getSubject();
 
                if ( !objet.contains(filtreObjet)) {
                    mailValide = false;
                } 
            }
 
            // si le mail correspond aux filtres
            if ( mailValide ) {
 
                // lecture de la pièce jointe
                Multipart mp = (Multipart) message[i].getContent();
 
                for (int a = 0; a <  mp.getCount(); a++) {
 
                    BodyPart bodyPart = mp.getBodyPart(a);
                    String disposition = bodyPart.getDisposition();
 
                    if ((disposition != null) && ((disposition.equalsIgnoreCase(Part.ATTACHMENT) || (disposition.equals(Part.INLINE))))) {
                        File file = new File(repertoire + Systeme.getSeparateur() + bodyPart.getFileName());
                        // on enregistre le fichier dans le repertoire désiré
                        FileWriter ecriture=new FileWriter(file);
                        InputStreamReader lecture=new InputStreamReader(bodyPart.getInputStream());
                        int flux;
                        while ((flux=lecture.read())!=-1) {
                            ecriture.write(flux);
                        }
                        lecture.close();
                        ecriture.close();
 
                        // s'il s'agit d'une archive, on l'extrait dans le repertoire source
                        if (archive) {
                            Fichier.unzip(file, repertoire);
                        }
                    }
                }
                // suppression du message traité
                message[i].setFlag(Flags.Flag.DELETED,true);
            }
        }
 
        // fermeture de la connexion
        folder.close(true);
        store.close();
    } | 
Partager