daoas/daoadresseservice/DataLoader.java

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);

                }
        }

}
1	torben	2337	package dk.daoas.daoadresseservice;
2
3	torben	3079	import java.util.List;
4	torben	2768	import java.util.Properties;
5			import java.util.logging.Logger;
6	torben	2337
7	torben	2768	import javax.mail.Message;
8	torben	2833	import javax.mail.MessagingException;
9	torben	2768	import javax.mail.Session;
10			import javax.mail.Transport;
11			import javax.mail.internet.InternetAddress;
12			import javax.mail.internet.MimeMessage;
13	torben	2337	import javax.servlet.ServletContext;
14
15	torben	3079	import com.google.common.base.Splitter;
16
17	torben	2350	import dk.daoas.daoadresseservice.admin.ServiceConfig;
18	torben	2769	import dk.daoas.daoadresseservice.beans.DataStatisticsBean;
19	torben	2608	import dk.daoas.daoadresseservice.db.DatabaseLayerImplementation;
20	torben	2350
21	torben	2337	public class DataLoader {
22	torben	3045
23	torben	2337	boolean isRunning = false;
24	torben	3045
25	torben	2350	ServiceConfig config;
26	torben	3045
27	torben	2337	ServletContext ctxt;
28	torben	2351	public DataLoader(ServletContext ctxt,ServiceConfig conf) {
29	torben	2337	this.ctxt = ctxt;
30	torben	3045
31	torben	2351	config = conf;
32	torben	2337	}
33	torben	3045
34	torben	2769	public void doLoad(String trigger) {
35	torben	2337	synchronized(this) {
36			if (isRunning == false) {
37			isRunning = true;
38	torben	3045
39	torben	2769	Thread t = new Thread( new DataLoadWorker(this, trigger), "SearchDataLoader");
40	torben	2337	t.start();
41			}
42			}
43			}
44	torben	3045
45	torben	2337	public boolean isRunning() {
46			synchronized(this) {
47			return isRunning;
48			}
49			}
50	torben	3045
51	torben	2337	protected void setRunningFalse() {
52			synchronized(this) {
53			isRunning = false;
54			}
55			}
56
57	torben	3045
58
59
60	torben	2337	public static class DataLoadWorker implements Runnable {
61	torben	3045
62	torben	2768	static final Logger logger = Logger.getLogger(DataLoadWorker.class.getName());
63	torben	3045
64	torben	2337	DataLoader loader;
65	torben	2769	String trigger;
66			public DataLoadWorker(DataLoader ld, String trigger) {
67	torben	2337	this.loader = ld;
68	torben	2769	this.trigger = trigger;
69	torben	2337	}
70
71	torben	3045
72	torben	2337	@Override
73			public void run() {
74	torben	3045
75
76			try {
77			AddressSearch search = new AddressSearch(new DatabaseLayerImplementation(), loader.config);
78			search.buildSearchStructures();
79
80			AddressSearch oldSearch = (AddressSearch) loader.ctxt.getAttribute("search");
81			loader.ctxt.setAttribute("search", search);
82
83			if (loader.config.notifyEmail != null && loader.config.notifyEmail.length() > 0) {
84			DataStatisticsBean oldStats = oldSearch != null ? oldSearch.getStatistics() : null;
85			sendStatusEmail(search.getStatistics(), oldStats);
86			}
87
88			if (oldSearch != null) {
89			oldSearch.clear();
90			}
91
92			} catch (Exception e) {
93			sendEmail("Load errror", "Error loading data: " + e.getMessage() );
94			System.out.println("Error loading data: " + e.getMessage() );
95			e.printStackTrace();
96
97			} finally {
98			loader.setRunningFalse();
99			}
100
101	torben	2337	}
102	torben	3045
103			protected void sendEmail(String subject, String body) {
104	torben	2768	Properties props = new Properties();
105			props.put("mail.smtp.host", "10.30.1.28");
106	torben	3045
107			// create a message
108	torben	2768	try {
109	torben	3079	String mailStr = loader.config.notifyEmail.replace(';', ',');//Tag højde for at der kan være brugt semikolon
110			List<String> mails = Splitter.on(',')
111			.trimResults()
112			.omitEmptyStrings()
113			.splitToList( mailStr );
114	torben	3045
115			// create some properties and get the default Session
116			Session session = Session.getDefaultInstance(props, null);
117			session.setDebug(false);
118
119			MimeMessage msg = new MimeMessage(session);
120	torben	3081	msg.setFrom( new InternetAddress("no-reply@daoas.dk") );
121	torben	3079	for (String recipient : mails) {
122			msg.addRecipient(Message.RecipientType.TO, new InternetAddress(recipient ) );
123			}
124	torben	3045
125			msg.setSubject(subject);
126			msg.setText(body);
127
128			Transport.send(msg);
129	torben	2833	} catch (MessagingException e) {
130	torben	2768	logger.warning("Unable to send CircuitBreaker notification mail " + e );
131			}
132	torben	3045
133
134	torben	2768	}
135	torben	2337
136	torben	3045	protected void sendStatusEmail(DataStatisticsBean newStats, DataStatisticsBean oldStats) {
137
138			String body = "Trigger: " + trigger + "\r\n\r\n";
139			body += "New stats:\r\n";
140
141			body += "Direkte: " + newStats.direkteCount + "\r\n";
142			body += "Extended: " + newStats.extendedCount + "\r\n";
143			body += "100%: " + newStats.hundredePctCount + "\r\n";
144			body += "Ikke-daekket: " + newStats.ikkeDaekketCount + "\r\n";
145			body += "Total: " + newStats.totalCount + "\r\n";
146			body += "Elapsed: " + newStats.elapsed + "\r\n";
147
148			if (oldStats != null) {
149			body += "\r\n";
150			body += "Delta to previous\r\n";
151			body += "Direkte: " + (newStats.direkteCount-oldStats.direkteCount) + "\r\n";
152			body += "Extended: " + (newStats.extendedCount-oldStats.extendedCount) + "\r\n";
153			body += "100: " + (newStats.hundredePctCount-oldStats.hundredePctCount) + "\r\n";
154			body += "Ikke-daekket: " + (newStats.ikkeDaekketCount-oldStats.ikkeDaekketCount) + "\r\n";
155			body += "Total: " + (newStats.totalCount-oldStats.totalCount) + "\r\n";
156
157			}
158
159			sendEmail("DaoAdresseService load, trigger: " + trigger, body);
160
161			}
162	torben	2337	}
163
164			}