package dk.daoas.daoadresseservice;

import java.util.List;
import java.util.Properties;
import java.util.logging.Logger;

import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.Session;
import javax.mail.Transport;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import javax.servlet.ServletContext;

import com.google.common.base.Splitter;

import dk.daoas.daoadresseservice.admin.ServiceConfig;
import dk.daoas.daoadresseservice.beans.DataStatisticsBean;
import dk.daoas.daoadresseservice.db.DatabaseLayerImplementation;

public class DataLoader {

	boolean isRunning = false;

	ServiceConfig config; 

	ServletContext ctxt;
	public DataLoader(ServletContext ctxt,ServiceConfig conf) {
		this.ctxt = ctxt;

		config = conf;
	}

	public void doLoad(String trigger) {
		synchronized(this) {
			if (isRunning == false) {
				isRunning = true;

				Thread t = new Thread( new DataLoadWorker(this, trigger), "SearchDataLoader");
				t.start();
			}
		}
	}

	public boolean isRunning() {
		synchronized(this) {
			return isRunning;	
		}		
	}

	protected void  setRunningFalse() {
		synchronized(this) {
			isRunning = false;
		}
	}




	public static class DataLoadWorker implements Runnable {

		static final Logger logger = Logger.getLogger(DataLoadWorker.class.getName());

		DataLoader loader;
		String trigger;
		public DataLoadWorker(DataLoader ld, String trigger) {
			this.loader = ld;
			this.trigger = trigger;
		}


		@Override
		public void run() {


			try {
				AddressSearch search = new AddressSearch(new DatabaseLayerImplementation(), loader.config);
				search.buildSearchStructures();

				AddressSearch oldSearch = (AddressSearch) loader.ctxt.getAttribute("search");
				loader.ctxt.setAttribute("search", search);

				if (loader.config.notifyEmail != null && loader.config.notifyEmail.length() > 0) {
					DataStatisticsBean oldStats = oldSearch != null ? oldSearch.getStatistics() : null;
					sendStatusEmail(search.getStatistics(), oldStats);
				}

				if (oldSearch != null) {
					oldSearch.clear();
				}

			} catch (Exception e) {
				sendEmail("Load errror", "Error loading data: " + e.getMessage() );
				System.out.println("Error loading data: " + e.getMessage() );
				e.printStackTrace();
				
			} finally {
				loader.setRunningFalse();
			}

		}

		protected void sendEmail(String subject, String body) {
			Properties props = new Properties();
			props.put("mail.smtp.host", "10.30.1.28");

			// create a message
			try {
				String mailStr = loader.config.notifyEmail.replace(';', ',');//Tag højde for at der kan være brugt semikolon
				List<String> mails = Splitter.on(',')
						 .trimResults()
						 .omitEmptyStrings()
						 .splitToList( mailStr );

				// create some properties and get the default Session
				Session session = Session.getDefaultInstance(props, null);
				session.setDebug(false);

				MimeMessage msg = new MimeMessage(session);
				msg.setFrom( new InternetAddress("no-reply@daoas.dk") );
				for (String recipient : mails) {
					msg.addRecipient(Message.RecipientType.TO, new InternetAddress(recipient ) );
				}

				msg.setSubject(subject);			
				msg.setText(body);

				Transport.send(msg);
			} catch (MessagingException e) {
				logger.warning("Unable to send CircuitBreaker notification mail " + e );
			}


		}

		protected void sendStatusEmail(DataStatisticsBean newStats, DataStatisticsBean oldStats) {

			String body = "Trigger: " + trigger + "\r\n\r\n";
			body += "New stats:\r\n";

			body += "Direkte:      " + newStats.direkteCount + "\r\n";
			body += "Extended:     " + newStats.extendedCount + "\r\n";
			body += "100%:         " + newStats.hundredePctCount + "\r\n";
			body += "Ikke-daekket: " + newStats.ikkeDaekketCount + "\r\n";
			body += "Total:        " + newStats.totalCount + "\r\n";					
			body += "Elapsed:      " + newStats.elapsed + "\r\n";

			if (oldStats != null) {
				body += "\r\n";
				body += "Delta to previous\r\n";
				body += "Direkte:      " + (newStats.direkteCount-oldStats.direkteCount) + "\r\n";
				body += "Extended:     " + (newStats.extendedCount-oldStats.extendedCount) + "\r\n";
				body += "100:          " + (newStats.hundredePctCount-oldStats.hundredePctCount) + "\r\n";
				body += "Ikke-daekket: " + (newStats.ikkeDaekketCount-oldStats.ikkeDaekketCount) + "\r\n";
				body += "Total:        " + (newStats.totalCount-oldStats.totalCount) + "\r\n";

			}

			sendEmail("DaoAdresseService load, trigger: " + trigger, body);

		}
	}

}