package com.nanometer.smartlab.util;

import com.nanometer.smartlab.exception.BusinessException;
import com.nanometer.smartlab.exception.ExceptionEnumCode;
import org.apache.log4j.Logger;

import javax.mail.Authenticator;
import javax.mail.Message;
import javax.mail.PasswordAuthentication;
import javax.mail.Session;
import javax.mail.Transport;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import java.text.MessageFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.Properties;
import com.sun.mail.util.MailSSLSocketFactory;

public class EmailSend {

    private static Logger logger = Logger.getLogger(EmailSend.class);

    public static void send(String to, String applyCode) {

        Transport transport = null;
        try {

            EmailConfigService cs = SpringUtil.getBean("emailConfigService", EmailConfigService.class);
            String smtp = cs.getSmtpHost();
            String user = cs.getSmtpUser();
            String password = cs.getSmtpPwd();
            String from = cs.getSmtpFrom();
            String subject = cs.getSmtpSubject();
            String content = MessageFormat.format(cs.getSmtpContent(), applyCode);

            Properties props = new Properties();
            props.put("mail.smtp.host", smtp);
            props.put("mail.smtp.auth", "true");
            Session ssn = Session.getInstance(props, new Authenticator() {
                @Override
                protected PasswordAuthentication getPasswordAuthentication() {
                    return new PasswordAuthentication(user, password);
                }
            });
            // 由邮件会话新建一个消息对象
            MimeMessage message = new MimeMessage(ssn);
            // 发件人的邮件地址
            InternetAddress fromAddress = new InternetAddress(from);
            // 设置发件人
            message.setFrom(fromAddress);
            // 收件人的邮件地址
            InternetAddress toAddress = new InternetAddress(to);
            // 设置收件人
            message.addRecipient(Message.RecipientType.TO, toAddress);
            // 设置标题
            message.setSubject(subject);
            // 设置内容
            message.setText(content);
            // 设置发信时间
            message.setSentDate(new Date());

            transport = ssn.getTransport("smtp");
            transport.connect(smtp, user, password);
            transport.sendMessage(message, message.getRecipients(Message.RecipientType.TO));
        } catch (Exception ex) {
            logger.error(ex.getMessage(), ex);
            throw new BusinessException(ExceptionEnumCode.MAIL_SEND_FAIL, "邮件发送失败。", ex);
        } finally {
            if (transport != null) {
                try {
                    transport.close();
                } catch (Exception ex) {

                }
            }
        }
    }


    public static void sendArrivalEmail(List<String> revicerList, String msg, String title){
        EmailConfigService cs = SpringUtil.getBean("emailConfigService", EmailConfigService.class);
        String sender = cs.getZkySmtpUser();/*发送人*/
        String password = cs.getZkySmtpPwd();

        String ZkySmtp = "smtp.cstnet.cn"; /*中科院邮件服务器*/
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
        Properties prop = new Properties();
        prop.setProperty("mail.host", ZkySmtp);
        prop.setProperty("mail.transport.protocol", "smtp"); // 邮件发送协议
        prop.setProperty("mail.smtp.auth", "true"); // 需要验证用户名密码
        prop.setProperty("mail.smtp.port", "25");

        MailSSLSocketFactory mailSSLSocketFactory = null;
        try{
            mailSSLSocketFactory = new MailSSLSocketFactory();
            mailSSLSocketFactory.setTrustAllHosts(true);
        }catch (Exception e){
            logger.error("邮件开启 MailSSLSocketFactory 失败:"+e.getMessage());
        }

        if (mailSSLSocketFactory != null) {

            prop.put("mail.smtp.ssl.enable", false);
            prop.put("mail.smtp.ssl.socketFactory", mailSSLSocketFactory);
            //创建定义整个应用程序所需的环境信息的 Session 对象
            Session session = Session.getDefaultInstance(prop, new Authenticator() {
                public PasswordAuthentication getPasswordAuthentication() {
                    //发件人邮件用户名、授权码
                    return new PasswordAuthentication(sender, password);
                }
            });

            for (String revicer : revicerList) {
                try {
                    //2、通过session得到transport对象
                    Transport ts = session.getTransport();
                    //3、使用邮箱的用户名和授权码连上邮件服务器
                    ts.connect(sender, password);
                    try {
                        //4、创建邮件
                        //创建邮件对象
                        MimeMessage message = new MimeMessage(session);
                        //指明邮件的发件人
                        message.setFrom(new InternetAddress(sender));
                        //指明邮件的收件人
                        message.setRecipient(Message.RecipientType.TO, new InternetAddress(revicer));
                        //邮件的标题
                        message.setSubject(sdf.format(new Date())+title);
                        //邮件的文本内容
                        message.setContent(msg, "text/html;charset=UTF-8");
                        //5、发送邮件
                        ts.sendMessage(message, message.getAllRecipients());
                    } catch (Exception e) {
                        logger.error("邮件发送" + "失败：" + e.getMessage());
                    }
                    ts.close();
                } catch (Exception e) {
                    logger.error("邮件发送失败：" + e.getMessage());
                }
            }
        }
        logger.error("邮件发送完成" + "时间：" + sdf.format(new Date()));
    }
}