1 2 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