邮件预警,邮件控制

import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Properties;

import javax.mail.Flags;
import javax.mail.Folder;
import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.Multipart;
import javax.mail.NoSuchProviderException;
import javax.mail.Part;
import javax.mail.Session;
import javax.mail.Store;
import javax.mail.internet.MimeMessage;
import javax.mail.internet.MimeUtility;
import javax.mail.search.FlagTerm;

import com.sun.mail.imap.IMAPMessage;

public class GetQQMail {

    private MimeMessage mimeMessage = null;
    private StringBuffer bodyText = new StringBuffer(); // 存放邮件内容的StringBuffer对象

    /**
     * 构造函数,初始化一个MimeMessage对象
     */
    public GetQQMail(MimeMessage mimeMessage) {
        this.mimeMessage = mimeMessage;
        // System.out.println("创建一个ReceiveEmail对象....");
    }

    /**
     * * 获得邮件正文内容
     */
    public String getBodyText() {
        return bodyText.toString();
    }

    /**
     * @param args
     */
    public static void main(String[] args) {
        //Boolean fetchMail = fetchMail();
        String decode = decode("PGRpdj5zZGFkc2FkYXM8L2Rpdj4=");
        System.out.println(new String(decode));
    }

    public static int fetchMail() {
        Message[] message = null;
        Folder folder = null;
        Store store = null;
        try {
            String host = "pop.qq.com";
            String username = "23424621@qq.com";
            String password = "dwefnrndvvcrlyvhbieg";//邮箱授权码
            Properties p = new Properties();
            p.setProperty("mail.pop3.host", "pop.qq.com"); // 按需要更改
            p.setProperty("mail.pop3.port", "995");
            // SSL安全连接参数
            p.setProperty("mail.pop3.socketFactory.class", "javax.net.ssl.SSLSocketFactory");
            p.setProperty("mail.pop3.socketFactory.fallback", "true");
            p.setProperty("mail.pop3.socketFactory.port", "995");

            Session session = Session.getInstance(p, null);
            store = session.getStore("pop3");
            store.connect(host, username, password);
            folder = store.getFolder("INBOX");
            // 如果需要在取得邮件数后将邮件置为已读则这里需要使用READ_WRITE,否则READ_ONLY就可以
            folder.open(Folder.READ_WRITE);
            message = folder.getMessages();
            // System.out.println("邮件数量: " + message.length);

            if (null != message) {
                GetQQMail re = null;
                for (int i = 0; i < message.length; i++) {
                    re = new GetQQMail((MimeMessage) message[i]);
                    re.getMailContent((Part) message[i]);
                    String bodyText = "";
                    bodyText = re.getBodyText();
                    // 负数今天不再发 ,0恢复,N延迟N个小时,Integer.MAX_VALUE一直发
                    if (bodyText.contains("忽略")) {//邮件发送忽略两个字,今天不再发送邮件提醒
                        System.out.println("包含忽略");
                        String subject = message[i].getSubject();
                        // set the DELETE flag to true
                        message[i].setFlag(Flags.Flag.DELETED, true);
                        System.out.println("Marked DELETE for message: " + subject);
                        return -1;
                    } else if (bodyText.contains("恢复")) {//恢复到正常状态
                        System.out.println("包含恢复");
                        String subject = message[i].getSubject();
                        // set the DELETE flag to true
                        message[i].setFlag(Flags.Flag.DELETED, true);
                        System.out.println("Marked DELETE for message: " + subject);
                        return 0;
                    } else if (bodyText.contains("$$$")&&bodyText.contains("&&&")) {//$$$数字&&&
                        System.out.println("包含延迟");
                        String subject = message[i].getSubject();
                        // set the DELETE flag to true
                        message[i].setFlag(Flags.Flag.DELETED, true);
                        System.out.println("Marked DELETE for message: " + subject);
                        int indexOf = bodyText.indexOf("$$$");
                        int indexOf1 = bodyText.indexOf("&&&");
                        int count = Integer.parseInt(bodyText.substring(indexOf+3, indexOf1));
                        return count;//解析出的数字就是延迟几分钟
                    }
                }
            }
        } catch (NoSuchProviderException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (MessagingException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            // 释放资源
            try {
                folder.close(true);
                store.close();
            } catch (MessagingException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        return Integer.MAX_VALUE;
    }

    
    

    /**
     * * 解析邮件，把得到的邮件内容保存到一个StringBuffer对象中，解析邮件 *
     * 主要是根据MimeType类型的不同执行不同的操作，一步一步的解析
     */

    public void getMailContent(Part part) throws Exception {

        String contentType = part.getContentType();
        // 获得邮件的MimeType类型
        System.out.println("邮件的MimeType类型: " + contentType);

        int nameIndex = contentType.indexOf("name");

        boolean conName = false;

        if (nameIndex != -1) {
            conName = true;
        }

        System.out.println("邮件内容的类型:　" + contentType);

        if (part.isMimeType("text/plain") && conName == false) {
            // text/plain 类型      
            //decode 是BASE64解码里面只有内容部分是BASE64加密的,解码之后邮件内容会恢复
            String decodeStr = GetQQMail.decode((String) part.getContent());
            bodyText.append(decodeStr);
        } else if (part.isMimeType("text/html") && conName == false) {
            // text/html 类型
            //bodyText.append((String) part.getContent());
            String decodeStr = GetQQMail.decode((String) part.getContent());
            bodyText.append(decodeStr);
        } else if (part.isMimeType("multipart/*")) {
            // multipart/*
            Multipart multipart = (Multipart) part.getContent();
            int counts = multipart.getCount();
            for (int i = 0; i < counts; i++) {
                getMailContent(multipart.getBodyPart(i));
            }
        } else if (part.isMimeType("message/rfc822")) {
            // message/rfc822
            getMailContent((Part) part.getContent());
        } else {

        }
    }
    
     public static String decode(String str){    
           byte[] bt = null;    
           try {    
               sun.misc.BASE64Decoder decoder = new sun.misc.BASE64Decoder();    
               bt = decoder.decodeBuffer( str );    
           } catch (IOException e) {    
               e.printStackTrace();    
           }    
           
               return new String(bt);    
           }    

}