java从腾讯邮箱获得文件

秒速五厘米 2022-09-15 13:57 136阅读 0赞

package com.jack.platformweb.email.service;
    
    import com.sun.mail.imap.IMAPStore;
    import com.jack.common.redis.service.RedisService;
    import com.jack.common.utils.DateUtils;
    import com.jack.common.utils.JsonUtils;
    import com.jack.common.utils.ZipUtils;
    import com.jack.db.urgerobot.robot.model.RobotInfo;
    import com.jack.platformweb.partner.service.GzOutUrgeFileService;
    import com.jack.platformweb.robot.service.RobotInfoService;
    import net.lingala.zip4j.exception.ZipException;
    import org.apache.commons.lang3.StringUtils;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.stereotype.Service;
    
    import javax.mail.*;
    import javax.mail.internet.InternetAddress;
    import javax.mail.internet.MimeUtility;
    import javax.print.DocFlavor;
    import java.io.*;
    import java.util.*;
    import java.util.List;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    /**
     * @Description
     * @Author zhenghao
     * @Date 2021/8/17 22:07
     **/
    @Service
    public class RemoteEmailService {
    
        private static Logger log = LoggerFactory.getLogger(RemoteEmailService.class);
    
        @Value("${gz.local.path}")
        private String attachFilePath;
        @Autowired
        private GzOutUrgeFileService gzOutUrgeFileService;
        @Autowired
        private RobotInfoService robotInfoService;
        @Autowired
        private RedisService redisService;
    
        //从哪个邮箱地址获取内容
        private static String username = "test@qq.com";
        private static String password = "123456";
    
        private static Integer robotId = 161;
        //过滤发件人
        private static List<String> monitoringEmail = Stream.of("tt@qq.com").collect(Collectors.toList());
    
        private IMAPStore getConnect() {
            log.info("开始获得邮件链接");
            // 准备连接服务器的会话信息
            IMAPStore store = null;
            try {
                Properties props = new Properties();
    //            props.setProperty("mail.store.protocol", "imap");
    //            props.setProperty("mail.imap.host", "imap.exmail.qq.com");
    //            props.setProperty("mail.imap.port", "993");
    //            props.setProperty("mail.imap.ssl.enable", "true");
    //
    //            props.setProperty("mail.imap.auth.plain.disable", "true");
    //
    //            Session session = Session.getInstance(props, new javax.mail.Authenticator() {
    //                @Override
    //
    //                protected PasswordAuthentication getPasswordAuthentication() {
    //                    return new PasswordAuthentication(username, password
    //
    //                    );
    //
    //                }
    //
    //            });
                props.put("mail.imap.host", "imap.exmail.qq.com");//QQ邮箱为：imap.qq.com
                props.put("mail.imap.auth", "true");
                props.setProperty("mail.store.protocol", "imap");
                props.put("mail.imap.starttls.enable", "true");
                Session session = Session.getInstance(props);
    
    //            // 创建Session实例对象
    //            Session session = Session.getInstance(props);
    
                // 创建IMAP协议的Store对象
                store = (IMAPStore) session.getStore("imap");
    
                // 连接邮件服务器
                store.connect("imap.exmail.qq.com", username, password);
            } catch (Exception e) {
                log.info("成功获得邮件链接失败");
                e.printStackTrace();
            }
            log.info("成功获得邮件链接");
            return store;
        }
    
    
        public boolean receiveEmail() {
            log.info("开始执行远程获得邮件任务");
            try {
                String key = "remoteEmailkey" + DateUtils.getToDayStartYYMMMDD();
                String s = redisService.get(key);
                if (StringUtils.isNotEmpty(s)) {
                    log.info("远程获得邮件已经成功执行");
                    return false;
                }
                /**
                 * 1. 取得链接
                 */
                IMAPStore imapStore = getConnect();
                if (null == imapStore) {
                    log.error("获取邮箱imap连接失败。方法执行失败。退出当前方法！！！！！！！");
                    return false;
                }
                Folder defaultFolder = imapStore.getDefaultFolder();
                if (defaultFolder == null) {
                    log.info("服务器不可用");
                    return false;
    
                }
                Folder folder = imapStore.getFolder("INBOX");
                folder.open(Folder.READ_WRITE);
    
                //获得所有近30天的邮件，近30天是在客户端配置的
                Message[] messages = folder.getMessages();
    //        Message[] messages = folder.getMessages(folder.getMessageCount() - folder.getUnreadMessageCount() + 1, folder.getMessageCount());
                log.info("未读邮件数量:　{}", messages.length);
                for (Message msg : messages) {
                    try {
                        //邮件发送日期超过两天 退出遍历方法
                        if (!outDays(msg)) {
                            log.info("邮件{}已过期，退出循环", msg.getSubject());
                            continue;
                        }
                        //不是最新邮件，跳过
                        //                if (isNew(msg)) {
                        //                    log.info("邮件不是新邮件，跳过");
                        //                    continue;
                        //                }
                        //是否属于需要处理的邮件
                        if (needProcessEmail(msg)) {
                            redisService.setex(key, 20 * 60 * 60, "1");
                            break;
                        } else {
                            log.info("邮件不需要处理，跳过");
                        }
    
                    } catch (Exception e) {
    
                        log.error(e.getMessage(), e);
                    }
                }
                //关闭资源
                folder.close(true);
                imapStore.close();
            } catch (MessagingException e) {
                e.printStackTrace();
            }
            return false;
        }
    
        /**
         * @param
         * @param msg
         * @return boolean
         * @author FeianLing
         * @date 2019/8/20
         * @desc 检查当前邮件是否已超过1天, 接收时间大于1天以前 返回true
         */
        private boolean outDays(Message msg) {
            String s = "";
            Date receiveDate = null;
            try {
                receiveDate = msg.getReceivedDate();
                s = DateUtils.formatYYYYMMDD(receiveDate);
                log.info("邮件接收时间：{}", DateUtils.formatYYYYMMDD(receiveDate));
    
                return DateUtils.getToDayYYYYMMDD().equals(s);
            } catch (MessagingException e) {
                e.printStackTrace();
            }
            return true;
        }
    
        /**
         * @param
         * @param msg
         * @return boolean
         * @author FeianLing
         * @date 2019/8/20
         * @desc 判断邮件是否是新的邮件
         */
        private boolean isNew(Message msg) throws MessagingException {
            boolean isNewFlag = false;
            Flags flags = msg.getFlags();
            Flags.Flag[] flagsArr = flags.getSystemFlags();
            log.info("邮件状态：" + JsonUtils.writeValue(flagsArr));
            for (Flags.Flag flag : flagsArr) {
                if (flag == Flags.Flag.SEEN) {
                    isNewFlag = true;
                    log.info("当前邮件为未读状态！");
                    break;
                }
            }
            return isNewFlag;
        }
    
        /**
         * @param
         * @param msg
         * @return boolean
         * @author FeianLing
         * @date 2019/8/20
         * @desc 检查邮件内容是否需要我们处理
         * 1. 检查发件人是否满足要求
         * 2. 检查是否包含附件
         * 3. 检查是否有满足条件的附件
         */
        private boolean needProcessEmail(Message msg) throws Exception {
            log.info("needProcessEmail  > 当前邮件的标题：{}", msg.getSubject());
            // 1. 检查发件人邮箱是否包含在我们监控的邮箱列表里面
            String from = getFrom(msg);
            if (!monitoringEmail.contains(from)) {
                log.info("当前邮件的发件人[{}]不是我们要监控的对象", from);
                return false;
            }
            if (!isContainAttach((Part) msg)) {
                log.info("发件人满足要求但是附件为空，不满足我们监控的需求！");
                return false;
            }
            Map<String, InputStream> fileMap = new HashMap<>();
            getFileInputStream(msg, fileMap);
            if (fileMap.isEmpty()) {
                log.info("尽管邮件中有附件但是邮件中的附件却无一个满足要求！");
                return false;
            } else {
                //写入本地文件
                for (String s : fileMap.keySet()) {
                    InputStream inputStream = fileMap.get(s);
                    this.getFile(inputStream, attachFilePath + "/" + s);
                    this.dealFileData(attachFilePath + "/" + s);
                    break;
                }
    
    
            }
            return true;
        }
    
        /**
         * @param
         * @param part
         * @return java.io.InputStream
         * @author FeianLing
         * @date 2019/8/20
         * @desc 获取文件输入流
         */
        private void getFileInputStream(Part part, Map<String, InputStream> inputStreamMap) throws Exception {
            String fileName;
            if (part.isMimeType("multipart/*")) {
                Multipart mp = (Multipart) part.getContent();
                for (int i = 0; i < mp.getCount(); i++) {
                    BodyPart mPart = mp.getBodyPart(i);
                    String disposition = mPart.getDisposition();
                    if ((disposition != null)
                            && ((disposition.equals(Part.ATTACHMENT)) || (disposition
                            .equals(Part.INLINE)))) {
                        fileName = mPart.getFileName();
                        fileName = MimeUtility.decodeText(fileName);
                        if (checkFileName(fileName)) {
                            inputStreamMap.put(fileName, mPart.getInputStream());
                        }
                    } else if (mPart.isMimeType("multipart/*")) {
                        log.info("子邮件里面的附件");
                        getFileInputStream(mPart, inputStreamMap);
                    } else {
                        fileName = mPart.getFileName();
                        if ((fileName != null)
                                && (fileName.toLowerCase().indexOf("GB2312") != -1)) {
                            fileName = MimeUtility.decodeText(fileName);
                            if (checkFileName(fileName)) {
                                inputStreamMap.put(fileName, mPart.getInputStream());
                            }
                        }
                    }
                }
            } else if (part.isMimeType("message/rfc822")) {
                getFileInputStream((Part) part.getContent(), inputStreamMap);
            }
        }
    
        /**
         * @param
         * @param fileName
         * @return boolean
         * @author FeianLing
         * @date 2019/8/20
         * @desc 检查文件名称是否符合要求 AI智能语音催收名单——智清厂商-0803.xls
         */
        private boolean checkFileName(String fileName) {
            return (fileName.contains("AI外呼剔除名单") || fileName.contains("AI外呼提出名单"));
        }
    
        /**
         * @param
         * @param part
         * @return boolean
         * @author FeianLing
         * @date 2019/8/20
         * @desc 判断邮件是否包含附件，如果没有包含附件，返回false 反之返回true
         */
        private boolean isContainAttach(Part part) throws Exception {
            boolean attachFlag = false;
            // String contentType = part.getContentType();
            if (part.isMimeType("multipart/*")) {
                Multipart mp = (Multipart) part.getContent();
                for (int i = 0; i < mp.getCount(); i++) {
                    BodyPart mPart = mp.getBodyPart(i);
                    String disposition = mPart.getDisposition();
                    if ((disposition != null)
                            && ((disposition.equals(Part.ATTACHMENT)) || (disposition
                            .equals(Part.INLINE)))) {
                        attachFlag = true;
                    } else if (mPart.isMimeType("multipart/*")) {
                        attachFlag = isContainAttach((Part) mPart);
                    } else {
                        String conType = mPart.getContentType();
    
                        if (conType.toLowerCase().indexOf("application") != -1) {
                            attachFlag = true;
                        }
                        if (conType.toLowerCase().indexOf("name") != -1) {
                            attachFlag = true;
                        }
                    }
                }
            } else if (part.isMimeType("message/rfc822")) {
                attachFlag = isContainAttach((Part) part.getContent());
            }
            return attachFlag;
        }
    
        /**
         * @param
         * @param msg
         * @return java.lang.String
         * @author FeianLing
         * @date 2019/8/20
         * @desc 获取发送地址
         */
        private String getFrom(Message msg) throws MessagingException {
            String from = "";
            InternetAddress[] addresses = (InternetAddress[]) msg.getFrom();
            if (null == addresses || addresses.length == 0) {
                log.error("无法获取发送人地址信息！");
                return from;
            }
            Address address = addresses[0];
            log.info("发件人地址json：" + JsonUtils.writeValue(address));
            String form = ((InternetAddress) address).getAddress();
            return form;
        }
    
        public void getFile(InputStream is, String fileName) {
            try {
                BufferedInputStream in = null;
                BufferedOutputStream out = null;
                in = new BufferedInputStream(is);
                out = new BufferedOutputStream(new FileOutputStream(fileName));
                int len = -1;
                byte[] b = new byte[1024];
                while ((len = in.read(b)) != -1) {
                    out.write(b, 0, len);
                }
                in.close();
                out.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        //业务处理方法
        public void dealFileData(String filePath) {
            try {
                log.info("开始处理文件:" + filePath);
                File file = new File(filePath);
                String name = file.getName();
                String fileName = name.replace(".zip", ".xls");
                ZipUtils.unZip(file, attachFilePath, "111111");
                RobotInfo robotInfoById = robotInfoService.getRobotInfoById(robotId);
                String tempFilePath = attachFilePath + "/" + fileName;
                log.info("处理文件路径:" + tempFilePath);
                gzOutUrgeFileService.autoOutUrge(robotInfoById, tempFilePath);
                log.info("出催文件处理完毕");
            } catch (ZipException e) {
                e.printStackTrace();
            }
    
        }
    
    
        public static void main(String[] args) {
    
        }
    }