daoas/daoadresseservice/DataLoader.java

package dk.daoas.daoadresseservice;

import java.sql.SQLException;
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 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 (SQLException e) {
                        System.out.println("Error loading data: " + e.getMessage());
                } finally {
                        loader.setRunningFalse();
                }
                
                }
                
                protected void sendStatusEmail(DataStatisticsBean newStats, DataStatisticsBean oldStats) {
                        Properties props = new Properties();
                        props.put("mail.smtp.host", "10.30.1.28");
                        
                        try {
                                        // create some properties and get the default Session
                                        Session session = Session.getDefaultInstance(props, null);
                                        session.setDebug(false);
                                        
                                        
                                        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";
                                                
                                        }
                                                        
                                        
                                        // create a message
                                        
                                        MimeMessage msg = new MimeMessage(session);
                                        msg.setFrom( new InternetAddress("no-reply@daoas.dk") );
                                        
                                        msg.setRecipient(Message.RecipientType.TO, new InternetAddress(loader.config.notifyEmail) );
                                        msg.setSubject("DaoAdresseService load, trigger: " + trigger);                  
                                        msg.setText(body);
                                        
                                        Transport.send(msg);
                        } catch (MessagingException e) {
                                logger.warning("Unable to send CircuitBreaker notification mail " + e );
                        }
                }
                

        }

}
1	torben	2337	package dk.daoas.daoadresseservice;
2
3			import java.sql.SQLException;
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	2350	import dk.daoas.daoadresseservice.admin.ServiceConfig;
16	torben	2769	import dk.daoas.daoadresseservice.beans.DataStatisticsBean;
17	torben	2608	import dk.daoas.daoadresseservice.db.DatabaseLayerImplementation;
18	torben	2350
19	torben	2337	public class DataLoader {
20
21			boolean isRunning = false;
22
23	torben	2350	ServiceConfig config;
24
25	torben	2337	ServletContext ctxt;
26	torben	2351	public DataLoader(ServletContext ctxt,ServiceConfig conf) {
27	torben	2337	this.ctxt = ctxt;
28	torben	2350
29	torben	2351	config = conf;
30	torben	2337	}
31
32	torben	2769	public void doLoad(String trigger) {
33	torben	2337	synchronized(this) {
34			if (isRunning == false) {
35			isRunning = true;
36
37	torben	2769	Thread t = new Thread( new DataLoadWorker(this, trigger), "SearchDataLoader");
38	torben	2337	t.start();
39			}
40			}
41			}
42
43			public boolean isRunning() {
44			synchronized(this) {
45			return isRunning;
46			}
47			}
48
49			protected void setRunningFalse() {
50			synchronized(this) {
51			isRunning = false;
52			}
53			}
54
55
56
57
58			public static class DataLoadWorker implements Runnable {
59	torben	2768
60			static final Logger logger = Logger.getLogger(DataLoadWorker.class.getName());
61
62	torben	2337	DataLoader loader;
63	torben	2769	String trigger;
64			public DataLoadWorker(DataLoader ld, String trigger) {
65	torben	2337	this.loader = ld;
66	torben	2769	this.trigger = trigger;
67	torben	2337	}
68
69
70			@Override
71			public void run() {
72
73
74			try {
75	torben	2608	AddressSearch search = new AddressSearch(new DatabaseLayerImplementation(), loader.config);
76	torben	2337	search.buildSearchStructures();
77
78	torben	2410	AddressSearch oldSearch = (AddressSearch) loader.ctxt.getAttribute("search");
79	torben	2337	loader.ctxt.setAttribute("search", search);
80
81	torben	2768	if (loader.config.notifyEmail != null && loader.config.notifyEmail.length() > 0) {
82	torben	2769	DataStatisticsBean oldStats = oldSearch != null ? oldSearch.getStatistics() : null;
83			sendStatusEmail(search.getStatistics(), oldStats);
84	torben	2768	}
85
86	torben	2337	if (oldSearch != null) {
87			oldSearch.clear();
88			}
89
90			} catch (SQLException e) {
91			System.out.println("Error loading data: " + e.getMessage());
92			} finally {
93			loader.setRunningFalse();
94			}
95
96			}
97
98	torben	2769	protected void sendStatusEmail(DataStatisticsBean newStats, DataStatisticsBean oldStats) {
99	torben	2768	Properties props = new Properties();
100			props.put("mail.smtp.host", "10.30.1.28");
101
102			try {
103			// create some properties and get the default Session
104			Session session = Session.getDefaultInstance(props, null);
105			session.setDebug(false);
106
107
108	torben	2769	String body = "Trigger: " + trigger + "\r\n\r\n";
109			body += "New stats:\r\n";
110
111			body += "Direkte: " + newStats.direkteCount + "\r\n";
112			body += "Extended: " + newStats.extendedCount + "\r\n";
113			body += "100%: " + newStats.hundredePctCount + "\r\n";
114			body += "Ikke-daekket: " + newStats.ikkeDaekketCount + "\r\n";
115			body += "Total: " + newStats.totalCount + "\r\n";
116			body += "Elapsed: " + newStats.elapsed + "\r\n";
117
118			if (oldStats != null) {
119			body += "\r\n";
120			body += "Delta to previous\r\n";
121			body += "Direkte: " + (newStats.direkteCount-oldStats.direkteCount) + "\r\n";
122			body += "Extended: " + (newStats.extendedCount-oldStats.extendedCount) + "\r\n";
123			body += "100: " + (newStats.hundredePctCount-oldStats.hundredePctCount) + "\r\n";
124			body += "Ikke-daekket: " + (newStats.ikkeDaekketCount-oldStats.ikkeDaekketCount) + "\r\n";
125			body += "Total: " + (newStats.totalCount-oldStats.totalCount) + "\r\n";
126
127			}
128
129
130	torben	2768	// create a message
131
132			MimeMessage msg = new MimeMessage(session);
133			msg.setFrom( new InternetAddress("no-reply@daoas.dk") );
134
135			msg.setRecipient(Message.RecipientType.TO, new InternetAddress(loader.config.notifyEmail) );
136	torben	2769	msg.setSubject("DaoAdresseService load, trigger: " + trigger);
137			msg.setText(body);
138	torben	2768
139			Transport.send(msg);
140	torben	2833	} catch (MessagingException e) {
141	torben	2768	logger.warning("Unable to send CircuitBreaker notification mail " + e );
142			}
143			}
144
145	torben	2337
146			}
147
148			}