package foundation.send.mail;

import java.util.Date;

import javax.mail.Session;
import javax.mail.Transport;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import foundation.action.ActionContext;
import foundation.action.SingletonActionProvider;
import foundation.dao.DataPackage;
import foundation.dao.DataReader;
import foundation.dao.DataWriter;
import foundation.data.entity.Entity;
import foundation.data.object.DataObject;
import foundation.data.object.EntitySaver;
import foundation.util.ID;
import foundation.util.Util;

public class MailCenter extends SingletonActionProvider {
	
	private static Logger logger;
	private static MailCenter instance;
    private static MailActionBucket actionBucket;
    private static DataObject mailLogObject;
	
    static {
    	logger = LogManager.getLogger(MailCenter.class);
    }

    private MailCenter() {
    	actionBucket = MailActionBucket.getInstance();
    	mailLogObject = DataObject.getInstance("sys_mail_log");
    }
    
    public static synchronized MailCenter getInstance() {
    	if (instance == null) {
    		instance = new MailCenter();
    	}
    	
    	return instance;
    }
    
	@Override
	protected void publishMethod() {
		//1. 发送文件
		addMethod("sendMail");
		
		//2. 获取邮件内容
		addMethod("getMail");
	}
	
	public void sendMail(ActionContext context) throws Exception {
		DataReader dataReader = context.getDataReader();
		DataWriter dataWriter = context.getDataWriter();
		DataPackage dataPackage = dataReader.getDataPackage();
		
		String mailName = dataReader.getString("mail_name");
		if (Util.isEmpty(mailName)) {
			mailName = context.getActionParam(); 
		}
		
        String message = sendMailByDataPackage(dataPackage, mailName);
        dataWriter.reportOneMessage(mailName, message);
	}
	
	public String sendMailByDataPackage(DataPackage dataPackage, String mailName) throws Exception {
		MailAction action = actionBucket.get(mailName);
		
		//1. 记录日志开始
		if (action == null) {
			logger.error("send mail error, mail action not exists: {}", mailName);
			return "mail action not exists";
		}

		String id = writeLogBegin(action);
		
		//2. 创建邮件内容对象
		Mail mail = new Mail(action);
		mail.build(dataPackage);
		
		//3. 创建邮件 session
		MailServer server = action.getServer();
        Session session = Session.getDefaultInstance(server.getPropertys(), server.getAuthenticator()); 
        
        //4.设置邮件内容
        MimeMessage mimeMessage = new MimeMessage(session);
        mimeMessage.setFrom(new InternetAddress(server.getAccount()));
        mimeMessage.setSubject(mail.getSubject()); 
        mimeMessage.setContent(mail.getMailContent(), mail.getContentType());
        
        //5. 发送邮件
        Transport transport = session.getTransport();
        transport.connect(server.getAccount(), server.getPassword());
        transport.sendMessage(mimeMessage, mail.getToAddress());
        
        //6. 记录日志结束
        writeLogEnd(id);
        
        //7. 返回提示
        String message = "[" + mail.getSubject() + "]邮件已发出";
        
        return message;
	}
	
	public void getMail(ActionContext context) throws Exception {
		DataReader dataReader = context.getDataReader();
		DataWriter dataWriter = context.getDataWriter();
		
		String mailName = dataReader.getString("mail_name");
		if (Util.isEmpty(mailName)) {
			mailName = context.getActionParam();
		}
		
		//1. 获取Mail 指令，并重新加载模板
		MailAction action = actionBucket.get(mailName);
		
		if (action == null) {
			logger.error("send mail error, mail action not exists: {}", mailName);
			return;
		}
		
		//2. 创建邮件内容对象
		DataPackage dataPackage = dataReader.getDataPackage();
		Mail mail = new Mail(action);
		mail.build(dataPackage);
		
		dataWriter.addValue("mail", mail.getMailContent());
	}

	private String writeLogBegin(MailAction action) throws Exception {
		String id = ID.newValue();
		String targetId = action.getFieldTargetId();
		String targetCode = action.getFieldTargetCode();
		String targetName = action.getFieldTargetName();
		String targetMailAddress = action.getFieldMailAddress();
		
		Entity logEntity = mailLogObject.createTableEntity(true);
		logEntity.set("id", id);
		logEntity.set("target_id", targetId);
		logEntity.set("target_code", targetCode);
		logEntity.set("target_name", targetName);
		logEntity.set("target_mail_address", targetMailAddress);
		logEntity.set("action_name", action.getName());
		logEntity.set("mail_subject", action.getSubject());
		logEntity.set("begin_time", new Date());
		
		mailLogObject.insertEntity(logEntity);
		
		return id;
	}

	private void writeLogEnd(String id) throws Exception {
		EntitySaver saver = mailLogObject.createEntitySaver(id);
		saver.set("end_time", new Date());
		saver.update();
	}
	
	protected boolean validateMethodParameter(Class<?>[] parameters) {
		return true;
	}

}