SH-Arbitrate
/
Mediation-Backend


			
							123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437
							package com.ruoyi.common.utils;


import com.ruoyi.common.utils.uuid.UUID;
import com.sun.net.ssl.internal.ssl.Provider;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.mail.SimpleMailMessage;

import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.mail.javamail.JavaMailSenderImpl;
import org.springframework.mail.javamail.MimeMessageHelper;
import org.springframework.stereotype.Component;

import javax.activation.DataHandler;
import javax.mail.*;
import javax.mail.internet.*;
import javax.mail.search.*;
import javax.mail.util.ByteArrayDataSource;
import javax.validation.constraints.NotNull;
import java.io.*;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.security.Security;
import java.util.*;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import java.util.stream.Stream;

/**
 * @ClassName EmailInUtil
 * @Description 邮件发送工具
 */
@Component
@Data
@Slf4j
public class EmailOutUtil {
    private static Pattern emailPattern = Pattern.compile("^[a-zA-Z0-9_-]+@[a-zA-Z0-9_-]+(\\.[a-zA-Z0-9_-]+)+$");
    //    private static Pattern phonePattern = Pattern.compile("0?(13|14|15|18)[0-9]{9}");
    private static Pattern phonePattern = Pattern.compile("^1\\d{10}$");


//    @Autowired
//    private JavaMailSender mailSender;

    // 发送发邮箱地址(外网地址)
//    @Value("${spring.mail-out-network.from}")
//    private static String fromOut;
    @Value("${spring.mail.host}")
    private String hostOut;
//    @Value("${spring.mail.username}")
//    private String usernameOut;
    private String usernameOut="wq18792927508@163.com";
//    @Value("${spring.mail.password}")
//    private String passwordOut;
    private String passwordOut= "WDFHKSEMCKVRELEA";
    @Value("${spring.mail.port}")
    private Integer portOut;

    public JavaMailSender rebuildMailSender() {
        JavaMailSenderImpl mailSender = new JavaMailSenderImpl();
        mailSender.setHost(hostOut);
        mailSender.setUsername(usernameOut);
        mailSender.setPassword(passwordOut);
        mailSender.setPort(portOut);
        mailSender.setProtocol("smtp");
        mailSender.setDefaultEncoding("UTF-8");
        return mailSender;
    }

    /**
     * 发送纯文本邮件信息
     *
     * @param to      接收方
     * @param subject 邮件主题
     * @param content 邮件内容（发送内容）
     */
    public void sendMessage(String to, String subject, String content, String from, JavaMailSender mailSender) {
        // 创建一个邮件对象
        SimpleMailMessage msg = new SimpleMailMessage();
        msg.setFrom(from);
        msg.setTo(to);
        // 设置邮件主题
        msg.setSubject(subject);
        // 设置邮件内容
        msg.setText(content);
        // 发送邮件
        mailSender.send(msg);
        ////System.out.println("发送成功：" + from + ":to:" + to);
    }

    /**
     * @param to       收件人
     * @param message  邮件内容
     * @param subject  邮件主题
     * @param fileList 邮件附件
     */
    public  Boolean sendEmil(String to, String message, String subject, List<File> fileList, File file) {
        try {
            String messageContent = "<html><body><p style=\"font-family: Arial, sans-serif; font-size: 18px;\">"+message+"。</p></body></html>";
            MimeBodyPart messageBodyPart = new MimeBodyPart();
            messageBodyPart.setContent(messageContent, "text/html;charset=utf-8");
            messageBodyPart.setContentID(UUID.randomUUID().toString());
            Security.addProvider(new Provider());
            final String SSL_FACTORY = "javax.net.ssl.SSLSocketFactory";
            //设置邮件会话参数
            Properties props = new Properties();
            //邮箱的发送服务器地址
            props.setProperty("mail.smtp.host", "smtp.163.com");
            props.setProperty("mail.smtp.socketFactory.class", SSL_FACTORY);
            props.setProperty("mail.smtp.socketFactory.fallback", "false");
            //邮箱发送服务器端口,这里设置为465端口
            props.setProperty("mail.smtp.port", "465");
            props.setProperty("mail.smtp.socketFactory.port", "465");
            props.put("mail.smtp.auth", "true");
            //获取到邮箱会话,利用匿名内部类的方式,将发送者邮箱用户名和密码授权给jvm
            Session session = Session.getDefaultInstance(props, new Authenticator() {
                @Override
                protected PasswordAuthentication getPasswordAuthentication() {
                    return new PasswordAuthentication(usernameOut, passwordOut);
                }
            });
            //通过会话,得到一个邮件,用于发送
            Message msg = new MimeMessage(session);
            //设置发件人
            msg.setFrom(new InternetAddress(usernameOut));
            //设置收件人,to为收件人,cc为抄送,bcc为密送
            msg.setRecipients(Message.RecipientType.TO, InternetAddress.parse(to, false));
            msg.setRecipients(Message.RecipientType.CC, InternetAddress.parse(to, false));
            msg.setRecipients(Message.RecipientType.BCC, InternetAddress.parse(to, false));
            //设置邮件消息
            msg.setSubject(subject);
            msg.setText(message);
            msg.setDescription("messageutf-8html");
            //设置发送的日期
            msg.setSentDate(new Date());
            // 创建邮件正文
            MimeMultipart multipart = new MimeMultipart();
//            MimeBodyPart bodyPart = new MimeBodyPart();
//            bodyPart.setContent("This is the body of the email", "text/html");
            multipart.addBodyPart(messageBodyPart);
            // 添加附件
            if (file != null) {
                MimeBodyPart attachmentPart = new MimeBodyPart();
                attachmentPart.attachFile(file);
                attachmentPart.setFileName(MimeUtility.encodeText(file.getName()));
                multipart.addBodyPart(attachmentPart);
                //将multipart对象放入邮件
                msg.setContent(multipart);
            } else if (fileList != null && fileList.size() > 0) {
                // 添加附件（多个）
                if (fileList != null && fileList.size() > 0) {
                    for (File tempfile : fileList) {
                        MimeBodyPart attachmentPart = new MimeBodyPart();
                        attachmentPart.attachFile(tempfile);
                        attachmentPart.setFileName(MimeUtility.encodeText(tempfile.getName()));
                        multipart.addBodyPart(attachmentPart);
                    }
                    msg.setContent(multipart);
                }
            }
            //调用Transport的send方法去发送邮件
            Transport.send(msg);
        }catch (Exception e) {
            e.printStackTrace();
            return Boolean.FALSE;
        }
        return Boolean.TRUE;
    }

    /**
     * 发送带附件的邮件信息
     *
     * @param to       接收方
     * @param subject  邮件主题
     * @param content  邮件内容（发送内容）
     * @param fileList 文件集合 // 可发送多个附件
     */
    public void sendMessageCarryFiles(String to, String subject, String content, List<File> fileList, String from, @NotNull JavaMailSender mailSender) {
        MimeMessage mimeMessage = mailSender.createMimeMessage();
        try {
            MimeMessageHelper helper = new MimeMessageHelper(mimeMessage, true);
            helper.setFrom(from);
            helper.setTo(to);
            // 设置邮件主题
            helper.setSubject(subject);
            // 设置邮件内容
            helper.setText(content);
            // 添加附件（多个）
            if (fileList != null && fileList.size() > 0) {
                for (File file : fileList) {
                    helper.addAttachment(file.getName(), file);
                }
            }
        } catch (MessagingException e) {
            e.printStackTrace();
        }
        // 发送邮件
        mailSender.send(mimeMessage);
    }

    /**
     * 发送带附件的邮件信息
     *
     * @param to      接收方
     * @param subject 邮件主题
     * @param content 邮件内容（发送内容）
     * @param file    单个文件
     */
    public void sendMessageCarryFile(String to, String subject, String content, File file, String from, JavaMailSender mailSender) {
        MimeMessage mimeMessage = mailSender.createMimeMessage();
        try {
            MimeMessageHelper helper = new MimeMessageHelper(mimeMessage, true);
            helper.setFrom(from);
            helper.setTo(to);
            // 设置邮件主题
            helper.setSubject(subject);
            // 设置邮件内容
            helper.setText(content);
            // 单个附件
            helper.addAttachment(file.getName(), file);
        } catch (MessagingException e) {
            e.printStackTrace();
        }
        // 发送邮件
        mailSender.send(mimeMessage);
    }

    /**
     * 初始化内外网邮件发送对象
     *
     * @param num
     */
//    public static JavaMailSender initJavaMailSender(Integer num) {
//        if (num != null && num == 1) {
//            //内网
//            return rebuildMailSender(hostIn, usernameIn, passwordIn, Integer.parseInt(portIn), "smtps");
//        } else {
//            //外网
//            return rebuildMailSender(hostOut, usernameOut, passwordOut, Integer.parseInt(portOut), "smtps");
//        }
//    }

//    public static String getInnerFrom() {
//        return EmailInUtil;
//    }
//
//    public static String getOutterFrom() {
//        return fromOut;
//    }

    /**
     * 验证邮箱格式
     *
     * @param str
     * @return
     */
    public static boolean isEmail(String str) {
        boolean flag = false;
        Matcher matcher = emailPattern.matcher(str);
        if (matcher.matches()) {
            flag = true;
        }
        return flag;
    }

    public static boolean isPhoneNumber(String str) {
        boolean flag = false;
        Matcher matcher = phonePattern.matcher(str);
        if (matcher.matches()) {
            flag = true;
        }
        return flag;
    }
public  void buildReceiveConnect() throws Exception {

    //POP3主机名
    String host = "pop3.163.com";
    //设置传输协议
    String protocol = "pop3";
    //用户账号
    String username = "wq18792927508@163.com";
    //密码或者授权码
    String password = "WDFHKSEMCKVRELEA";
    /*
     * 获取Session
     */
    Properties props = new Properties();
    //协议
    props.setProperty("mail.store.protocol", protocol);
    //POP3主机名
    props.setProperty("mail.pop3.host", host);
    props.setProperty("mail.smtp.auth", "true");
    props.setProperty("mail.pop3.default-encoding", "UTF-8");
    Session session = Session.getDefaultInstance(props, new Authenticator() {
        @Override
        protected PasswordAuthentication getPasswordAuthentication() {
            return new PasswordAuthentication(usernameOut, passwordOut);
        }
    });
    URLName urlName = new URLName(protocol, host, 110, null, username, password);
    Store store = session.getStore(urlName);
    store.connect(username, password);


    Folder folder = store.getFolder("INBOX");

    folder.open(Folder.READ_ONLY);

    }
    /**
     * 接收邮件
     */
    public List<String> receiverMail() {
        List<String> messageIds=new ArrayList<>();

//        session.setDebug(true);

        try {
            //POP3主机名
            String host = "pop3.163.com";
            //设置传输协议
            String protocol = "pop3";
            //用户账号
            String username = "wq18792927508@163.com";
            //密码或者授权码
            String password = "WDFHKSEMCKVRELEA";
            /*
             * 获取Session
             */
            Properties props = new Properties();
            //协议
            props.setProperty("mail.store.protocol", protocol);
            //POP3主机名
            props.setProperty("mail.pop3.host", host);
            props.setProperty("mail.smtp.auth", "true");
            props.setProperty("mail.pop3.default-encoding", "UTF-8");
            Session session = Session.getDefaultInstance(props, new Authenticator() {
                @Override
                protected PasswordAuthentication getPasswordAuthentication() {
                    return new PasswordAuthentication(usernameOut, passwordOut);
                }
            });
            URLName urlName = new URLName(protocol, host, 110, null, username, password);
            Store store = session.getStore(urlName);
            store.connect(username, password);


            Folder folder = store.getFolder("INBOX");
            folder.open(Folder.READ_ONLY);
            SearchTerm orTerm = new SubjectTerm("退信");
        //    Message[] messages = folder.search(orTerm);
            Date  endTime= new Date();
            long oneDayMillis=24*60*60*1000L;
            Date startTime=new Date(endTime.getTime()-oneDayMillis);
         //   SearchTerm comparisonTermGe = new SentDateTerm(ComparisonTerm.GE, startTime);
         //   SearchTerm comparisonTermLe = new SentDateTerm(ComparisonTerm.LE, endTime);
        //    SearchTerm comparisonAndTerm = new AndTerm(comparisonTermGe, comparisonTermLe);
          //  SearchTerm searchTerm = new AndTerm(comparisonAndTerm, orTerm);
            Message[] messages = folder.search(orTerm);
            if (messages != null) {

                Arrays.stream(messages).forEach(message -> {
                    String messageId="";
                    try {
                        messageId = EmailUtil.getMessageId(message,session);
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                    messageIds.add(messageId);
                });

            }

            folder.close(false);
            store.close();
        } catch (Exception e) {
           return messageIds;
        }
        return messageIds;
    }

    public void analyseMail(Session session, Object content) throws Exception {

        if (content instanceof Multipart) {
            Multipart multipart = (Multipart) content;
            for (int i = 0; i < multipart.getCount(); i++) {
                BodyPart bodyPart = multipart.getBodyPart(i);
//                if (bodyPart.isMimeType("message/rfc822")) {   if(bodyPart.getContentType().startsWith("Message/Rfc822"));
//                    MimeMessage mimeMessage = new MimeMessage(session, bodyPart.getInputStream());
//                }
                if(bodyPart.isMimeType("Message/Rfc822")){
                    MimeMessage mimeMessage = new MimeMessage(session, bodyPart.getInputStream());
                }
            }
        }
    }
    public static String getMessageId(Part part) throws Exception {
               if (!part.isMimeType("multipart/*")) {
                    return "";
                }

            Multipart multipart = (Multipart) part.getContent();
            for (int i = 0; i < multipart.getCount(); i++) {
                    BodyPart bodyPart = multipart.getBodyPart(i);

                    if (part.isMimeType("message/rfc822")) {
                         return getMessageId((Part) part.getContent());
                     }
                    InputStream inputStream = bodyPart.getInputStream();

                    try (BufferedReader br = new BufferedReader(new InputStreamReader(inputStream))) {
                         String strLine;
                         while ((strLine = br.readLine()) != null) {
                             if (strLine.startsWith("Message_Id:")) {
                                     String[] split = strLine.split("Message_Id:");
                                     return split.length > 1 ? split[1].trim() : null;
                                 }
                         }
                     }
                }

                return "";
            }


//检查退信邮件
//                Folder folder = ...; //打开收件箱
//                Message[] messages = folder.getMessages();
//                for (Message message : messages) {
//                    if (message.getSubject().contains("Delivery Status Notification")) {
//                        System.out.println("Delivery failed for recipient: " + message.getRecipients()[0]);
//                    }
//                }
}