/[projects]/dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/AddressReport.java
ViewVC logotype

Contents of /dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/AddressReport.java

Parent Directory Parent Directory | Revision Log Revision Log


Revision 2868 - (show annotations) (download)
Thu Jan 28 16:12:28 2016 UTC (8 years, 3 months ago) by torben
File size: 8109 byte(s)
Refactor common code from AddressSource* to AbstractAddressSource
1 package dk.daoas.adressevedligehold;
2
3 import java.util.HashMap;
4 import java.util.List;
5 import java.util.Properties;
6
7 import javax.mail.Message;
8 import javax.mail.MessagingException;
9 import javax.mail.Session;
10 import javax.mail.Transport;
11 import javax.mail.internet.InternetAddress;
12 import javax.mail.internet.MimeMessage;
13
14 import dk.daoas.adressevedligehold.beans.Address;
15 import dk.daoas.adressevedligehold.beans.Address.AddressState;
16 import dk.daoas.adressevedligehold.util.TimingHelper;
17
18 /*
19 * TODO: detail rapport pr postnr
20 * TODO: ved mangel oversigten - skeln mellem om det er nye/CREATED eller om det er gamle kendte adresser
21 */
22
23 public class AddressReport {
24
25 static class NumEntry {
26 int open = 0;
27 int closed = 0;
28 int modified = 0;
29 int created = 0;
30
31 public void updateFromState(AddressState st) {
32 if (st == AddressState.OPENED)
33 open++;
34 if (st == AddressState.MODIFIED)
35 modified++;
36 if (st == AddressState.CLOSED)
37 closed++;
38 }
39 public void updateFromOther(NumEntry other) {
40 this.open += other.open;
41 this.modified += other.modified;
42 this.closed += other.closed;
43 this.created += other.created;
44 }
45 }
46 static class WeekEntry {
47 NumEntry man = new NumEntry();
48 NumEntry tir = new NumEntry();
49 NumEntry ons = new NumEntry();
50 NumEntry tor = new NumEntry();
51 NumEntry fre = new NumEntry();
52 NumEntry lor = new NumEntry();
53 NumEntry son = new NumEntry();
54
55 public void incrementFromOther(WeekEntry other) {
56 man.updateFromOther(other.man);
57 tir.updateFromOther(other.tir);
58 ons.updateFromOther(other.ons);
59 tor.updateFromOther(other.tor);
60 fre.updateFromOther(other.fre);
61 lor.updateFromOther(other.lor);
62 son.updateFromOther(other.son);
63 }
64
65 public void incrementCreated() {
66 man.created++;
67 tir.created++;
68 ons.created++;
69 tor.created++;
70 fre.created++;
71 lor.created++;
72 son.created++;
73 }
74 }
75
76 AddressManager addrManager;
77 List<Address> addressList;
78 int entryCount;
79 EntryUgedage ugedage;
80 AddressSource source;
81 TimingHelper timer;
82 boolean writeBack;
83
84 //TODO: Afviste adresser
85 public AddressReport(AddressManager addrManager, int entryCount, EntryUgedage ugedage, AddressSource source, TimingHelper timer, boolean writeBack ) {
86 this.addrManager = addrManager;
87 addressList = addrManager.getAddressList();
88 this.entryCount = entryCount;
89 this.ugedage = ugedage;
90 this.source = source;
91 this.timer = timer;
92 this.writeBack = writeBack;
93
94 }
95
96 public void sendRapport() {
97 System.out.println("Sending mail");
98
99 String reportData = getReportData();
100 String subject = "Indlæsnings rapport for " + source.getDistributor();
101
102 AddressReport.sendMail(subject, reportData);
103
104 }
105
106 public static void sendMail(String subject, String htmlBody) {
107 Properties props = new Properties();
108 props.put("mail.smtp.host", "10.30.1.28");
109 //props.put("mail.smtp.host", "192.168.12.10");
110
111 try {
112 // create some properties and get the default Session
113 Session session = Session.getDefaultInstance(props, null);
114 session.setDebug(false);
115
116 MimeMessage msg = new MimeMessage(session);
117 msg.setFrom( new InternetAddress("no-reply@daoas.dk") );
118
119
120 msg.setRecipient(Message.RecipientType.TO, new InternetAddress("thn@daoas.dk") );//TODO: mulighed for at ændre modtager mail
121 msg.setSubject( subject );
122 msg.setContent(htmlBody, "text/html; charset=utf-8");
123
124 Transport.send(msg);
125
126
127 } catch (MessagingException e) {
128 System.out.println("Unable to send report mail " + e.getMessage() );
129 }
130 }
131
132
133 public String getReportData() {
134
135 WeekEntry total = new WeekEntry();
136 HashMap<Short, WeekEntry> postnrEntries = new HashMap<Short,WeekEntry>();
137
138
139 int antalUdenKommunekode = 0;
140 int antalUdenLatitude = 0;
141 int antalUdenDBKBane = 0;
142
143 // first gather the intel
144 for (Address a : addressList) {
145 if (a.kommunekode == 0 || a.vejkode == 0) {
146
147 antalUdenKommunekode++;
148 }
149
150 if (a.latitude == 0 || a.longitude == 0) {
151 antalUdenLatitude++;
152 }
153
154 if (a.state == AddressState.NOT_CHANGED) {
155 continue;
156 }
157 if (a.dbkBane == 0) {
158 antalUdenDBKBane++;
159 }
160
161 WeekEntry weekEntry = postnrEntries.get(a.postnr);
162 if (weekEntry == null) {
163 weekEntry = new WeekEntry();
164 postnrEntries.put(a.postnr, weekEntry);
165 }
166
167
168 if (a.state == AddressState.CREATED) {
169 weekEntry.incrementCreated();
170 } else {
171 weekEntry.man.updateFromState(a.stateMan);
172 weekEntry.tir.updateFromState(a.stateTir);
173 weekEntry.ons.updateFromState(a.stateOns);
174 weekEntry.tor.updateFromState(a.stateTor);
175 weekEntry.fre.updateFromState(a.stateFre);
176 weekEntry.lor.updateFromState(a.stateLor);
177 weekEntry.son.updateFromState(a.stateSon);
178
179 }
180 }
181 for (WeekEntry w : postnrEntries.values()) {
182 total.incrementFromOther(w);
183 }
184
185 StringBuilder sb = new StringBuilder();
186
187 sb.append("<h1>Indlæsnings rapport for " + source.getDistributor() + " </h1>");
188 sb.append("Filnavn: ").append( source.getFilename() ).append("<br>");
189 sb.append("Tidsforbrug: ").append( timer.getElapsed() ).append("ms. <br>");
190 sb.append("Skriv til DB: ").append( writeBack ).append("<br>");
191 sb.append("Antal entries: " ).append( entryCount ).append("<br>");
192 sb.append("Antal afviste: " ).append( addrManager.getRejectedCount() ).append("<br>");
193 sb.append("Filen indeholder data til: ");
194 if (ugedage.mandag) sb.append("Mandag, ");
195 if (ugedage.tirsdag) sb.append("Tirsdag, ");
196 if (ugedage.onsdag) sb.append("Onsdag, ");
197 if (ugedage.torsdag) sb.append("Torsdag, ");
198 if (ugedage.fredag) sb.append("Fredag, ");
199 if (ugedage.lordag) sb.append("Lørdag, ");
200 if (ugedage.sondag) sb.append("Søndag, ");
201 sb.append("<br>");
202
203 sb.append("<h2>Data Mangler</h2>\n");
204 sb.append("<pre>");
205 sb.append("Mangler kommune/vejkode: ").append(antalUdenKommunekode).append("\n");
206 sb.append("Mangler DBK bane: ").append(antalUdenDBKBane).append("\n");
207 sb.append("Mangler latitude/longitude: ").append(antalUdenLatitude).append("\n");
208 sb.append("</pre>");
209
210
211
212 sb.append("<h2>Ændrings oversigt</h2>\n");
213 sb.append("<table>");
214
215 sb.append("<tr><td>&nbsp;</td><td>Mandag</td><td>Tirsdag</td><td>Onsdag</td><td>Torsdag</td><td>Fredag</td><td>Lørdag</td><td>Søndag</td></tr>");
216 sb.append("<tr><td>Oprettet:</td><td>").append(total.man.created).append("</td><td>").append(total.tir.created).append("</td><td>").append(total.ons.created).append("</td><td>").append(total.tor.created).append("</td><td>").append(total.fre.created).append("</td><td>").append(total.lor.created).append("</td><td>").append(total.son.created).append("</td></tr>");
217 sb.append("<tr><td>Åbnet:</td><td>").append(total.man.open).append("</td><td>").append(total.tir.open).append("</td><td>").append(total.ons.open).append("</td><td>").append(total.tor.open).append("</td><td>").append(total.fre.open).append("</td><td>").append(total.lor.open).append("</td><td>").append(total.son.open).append("</td></tr>");
218 sb.append("<tr><td>Ændret:</td><td>").append(total.man.modified).append("</td><td>").append(total.tir.modified).append("</td><td>").append(total.ons.modified).append("</td><td>").append(total.tor.modified).append("</td><td>").append(total.fre.modified).append("</td><td>").append(total.lor.modified).append("</td><td>").append(total.son.modified).append("</td></tr>");
219 sb.append("<tr><td>Lukket:</td><td>").append(total.man.closed).append("</td><td>").append(total.tir.closed).append("</td><td>").append(total.ons.closed).append("</td><td>").append(total.tor.closed).append("</td><td>").append(total.fre.closed).append("</td><td>").append(total.lor.closed).append("</td><td>").append(total.son.closed).append("</td></tr>");
220
221
222
223 sb.append("</table><br>\n");
224
225 return sb.toString();
226 }
227 }

  ViewVC Help
Powered by ViewVC 1.1.20