adressevedligehold/coveragefileupload/AddressReport.java

package dk.daoas.adressevedligehold.coveragefileupload;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;
import java.util.HashMap;
import java.util.List;
import java.util.Map.Entry;

import org.apache.commons.lang3.builder.CompareToBuilder;

import dk.daoas.adressevedligehold.MailSender;
import dk.daoas.adressevedligehold.beans.Address;
import dk.daoas.adressevedligehold.beans.Address.AddressState;
import dk.daoas.adressevedligehold.tasks.TaskLogger;
import dk.daoas.adressevedligehold.util.TimingHelper;

/* 
 * 
 */

public class AddressReport {

        static class NumEntry {
                int open = 0;
                int closed = 0;
                int modified = 0;
                int created = 0;

                public void updateFromState(AddressState st) {
                        if (st == AddressState.OPENED)
                                open++;
                        if (st == AddressState.MODIFIED)
                                modified++;
                        if (st == AddressState.CLOSED)
                                closed++;
                }
                public void updateFromOther(NumEntry other) {
                        this.open += other.open;
                        this.modified += other.modified;
                        this.closed += other.closed;
                        this.created += other.created;
                }
        }
        static class WeekEntry {
                NumEntry man = new NumEntry();
                NumEntry tir = new NumEntry();
                NumEntry ons = new NumEntry();
                NumEntry tor = new NumEntry();
                NumEntry fre = new NumEntry();
                NumEntry lor = new NumEntry();
                NumEntry son = new NumEntry();

                public void incrementFromOther(WeekEntry other) {
                        man.updateFromOther(other.man);
                        tir.updateFromOther(other.tir);
                        ons.updateFromOther(other.ons);
                        tor.updateFromOther(other.tor);
                        fre.updateFromOther(other.fre);
                        lor.updateFromOther(other.lor);
                        son.updateFromOther(other.son);
                }

                public void incrementCreated() {
                        man.created++;
                        tir.created++;
                        ons.created++;
                        tor.created++;
                        fre.created++;
                        lor.created++;
                        son.created++;
                }
        }

        private static TaskLogger logger = TaskLogger.getInstance();

        AddressManager addrManager;
        List<Address> addressList;
        int entryCount;
        EntryUgedage ugedage;
        AddressSource source;
        TimingHelper timer;
        boolean writeBack;
        int duplicateCount;


        public AddressReport(AddressManager addrManager, int entryCount, EntryUgedage ugedage, AddressSource source, TimingHelper timer, boolean writeBack, int duplicateCount ) {
                this.addrManager = addrManager;
                addressList = addrManager.getAddressList();
                this.entryCount = entryCount;
                this.ugedage = ugedage;
                this.source = source;
                this.timer = timer;
                this.writeBack = writeBack;
                this.duplicateCount = duplicateCount;
        }

        public void sendRapport(boolean failed) {
                logger.info("Sending mail, failed:" + failed);

                String reportData = getReportData();
                
                String subject = "Adresse indlæsnings rapport for " + source.getDistributor();
                
                if (failed) {
                        subject = "Error: too many closed addresses for " + source.getDistributor();
                        reportData = "<h1><font color='red'>Data er IKKE skrevet til DB</font></h1><br>\r\n" + reportData;
                }
                
                String newOpenCloseAttachment = getAttachement();

                MailSender.sendMailWithAttachment(subject, reportData, "Details.csv", newOpenCloseAttachment);

        }


        public String getReportData() {

                WeekEntry total = new WeekEntry();
                HashMap<Short, WeekEntry> postnrEntries = new HashMap<Short,WeekEntry>();

                int createFailCount = 0;

                int antalUdenGadeid = 0;
                int antalUdenKommunekode = 0;
                int antalUdenLatitude = 0;
                int antalUdenDBKBane = 0;

                // first gather the intel
                for (Address a : addressList) {

                        if (a.state == AddressState.CREATE_FAIL) {
                                createFailCount++;
                                continue;                       
                        }

                        if (a.gadeid == 0) {
                                antalUdenGadeid++;
                        }

                        if (a.kommunekode == 0 || a.vejkode == 0) {                             
                                antalUdenKommunekode++;
                        }

                        if (a.latitude == 0 || a.longitude == 0) {
                                antalUdenLatitude++;
                        }

                        if (a.state == AddressState.NOT_CHANGED) {
                                continue;
                        }
                        if (a.dbkBane == null || a.dbkBane.length() == 0) {
                                antalUdenDBKBane++;
                        }

                        WeekEntry weekEntry = postnrEntries.get(a.postnr);
                        if (weekEntry == null) {
                                weekEntry = new WeekEntry();
                                postnrEntries.put(a.postnr, weekEntry);
                        }


                        if (a.state == AddressState.CREATED) {
                                weekEntry.incrementCreated();
                        } else {
                                weekEntry.man.updateFromState(a.stateMan);
                                weekEntry.tir.updateFromState(a.stateTir);
                                weekEntry.ons.updateFromState(a.stateOns);
                                weekEntry.tor.updateFromState(a.stateTor);
                                weekEntry.fre.updateFromState(a.stateFre);
                                weekEntry.lor.updateFromState(a.stateLor);
                                weekEntry.son.updateFromState(a.stateSon);

                        }                       
                }
                for (WeekEntry w : postnrEntries.values()) {
                        total.incrementFromOther(w);
                }

                StringBuilder sb = new StringBuilder();

                sb.append("<h1>Indlæsnings rapport for " + source.getDistributor() + " </h1>");
                sb.append("Filnavn: ").append( source.getFilename() ).append("<br>");
                sb.append("Tidsforbrug: ").append( timer.getElapsed() ).append("ms. <br>");
                sb.append("Skriv til DB: ").append( writeBack ).append("<br>");
                sb.append("Antal entries: " ).append( entryCount ).append("<br>");
                sb.append("Antal afviste: " ).append( addrManager.getRejectedCount() ).append("<br>");
                sb.append("Antal dubletter: " ).append( duplicateCount ).append("<br>");
                sb.append("Antal fejlede inserts: ").append(createFailCount).append("<br>"); 
                sb.append("Filen indeholder data til: ");
                if (ugedage.mandag) sb.append("Mandag, ");
                if (ugedage.tirsdag) sb.append("Tirsdag, ");
                if (ugedage.onsdag) sb.append("Onsdag, ");
                if (ugedage.torsdag) sb.append("Torsdag, ");
                if (ugedage.fredag) sb.append("Fredag, ");
                if (ugedage.lordag) sb.append("Lørdag, ");
                if (ugedage.sondag) sb.append("Søndag, ");
                sb.append("<br><br>");

                sb.append("<h2>Data Mangler</h2>\n");
                sb.append("Mangler kommune/vejkode: ").append(antalUdenKommunekode).append("<br>");
                sb.append("Mangler gadeid: ").append(antalUdenGadeid).append("<br>");
                sb.append("Mangler DBK bane: ").append(antalUdenDBKBane).append("<br>");
                sb.append("Mangler latitude/longitude: ").append(antalUdenLatitude).append("<br>");
                sb.append("<br>");


                sb.append("<h2>Ændrings oversigt</h2>\n");
                sb.append("<table>");

                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>");
                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>");
                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>");
                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>");
                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>");
                sb.append("</table>");

                sb.append("<br>");
                sb.append("<h2>Nye/Ukendte gader</h2>");
                sb.append("<table>");
                sb.append("<tr><th>Gadeid</th><th>Vejnavn</th></tr>");
                for( Entry<Integer,String> unknownStreet : addrManager.getUnknownStreets().entrySet() ) {
                        sb.append("<tr><td>").append(unknownStreet.getKey()).append("</td><td>").append(unknownStreet.getValue()).append("</td></tr>");
                }
                sb.append("</table>");


                sb.append("</table><br>\n");

                return sb.toString();
        }
        
        public String getAttachement() {
                StringBuilder sb = new StringBuilder();
                sb.append("Status;Gadeid;Post;Vejnavn;Husnr;Litra\r\n");
                
                ArrayList<Address> attachmentData = new ArrayList<Address>();
                for (Address a : addressList) {
                        if (a.state == AddressState.CLOSED || a.state == AddressState.CREATED || a.state == AddressState.OPENED) {
                                attachmentData.add(a);
                        }
                }
                
                Collections.sort(attachmentData, new AttachmentComparator());           
                
                for (Address a : attachmentData) {
                        switch (a.state) {
                        case CLOSED:
                                sb.append("Closed;");
                                break;                          
                        case CREATED:
                                sb.append("Created;");
                                break;                          
                        case OPENED:
                                sb.append("Opened;");
                                break;
                        default:
                                break;
                        }
                        
                        //tilføj resten af dataene
                        sb.append( a.gadeid + ";" + a.postnr + ";" + a.vejnavn + ";" + a.husnr + ";" + a.husnrbogstav + "\r\n");
                }
                
                return sb.toString();
        }
        
        
        /*
         * Serializable is to silence findbugs
         */
        static class AttachmentComparator implements Comparator<Address>, Serializable {
                private static final long serialVersionUID = 1L;

                @Override
                public int compare(Address a1, Address a2) {
                        
                        
                        //Brug apache commons lang3 
                        return new CompareToBuilder()
                                .append(a1.state, a2.state)
                                .append(a1.postnr, a2.postnr)
                                .append(a1.vejnavn, a2.vejnavn)
                                .append(a1.husnr, a2.husnr)
                                .append(a1.husnrbogstav, a2.husnrbogstav)
                                .toComparison();
                        }
                
        }
}
1	package dk.daoas.adressevedligehold.coveragefileupload;
2
3	import java.io.Serializable;
4	import java.util.ArrayList;
5	import java.util.Collections;
6	import java.util.Comparator;
7	import java.util.HashMap;
8	import java.util.List;
9	import java.util.Map.Entry;
10
11	import org.apache.commons.lang3.builder.CompareToBuilder;
12
13	import dk.daoas.adressevedligehold.MailSender;
14	import dk.daoas.adressevedligehold.beans.Address;
15	import dk.daoas.adressevedligehold.beans.Address.AddressState;
16	import dk.daoas.adressevedligehold.tasks.TaskLogger;
17	import dk.daoas.adressevedligehold.util.TimingHelper;
18
19	/*
20	*
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	private static TaskLogger logger = TaskLogger.getInstance();
77
78	AddressManager addrManager;
79	List<Address> addressList;
80	int entryCount;
81	EntryUgedage ugedage;
82	AddressSource source;
83	TimingHelper timer;
84	boolean writeBack;
85	int duplicateCount;
86
87
88	public AddressReport(AddressManager addrManager, int entryCount, EntryUgedage ugedage, AddressSource source, TimingHelper timer, boolean writeBack, int duplicateCount ) {
89	this.addrManager = addrManager;
90	addressList = addrManager.getAddressList();
91	this.entryCount = entryCount;
92	this.ugedage = ugedage;
93	this.source = source;
94	this.timer = timer;
95	this.writeBack = writeBack;
96	this.duplicateCount = duplicateCount;
97	}
98
99	public void sendRapport(boolean failed) {
100	logger.info("Sending mail, failed:" + failed);
101
102	String reportData = getReportData();
103
104	String subject = "Adresse indlæsnings rapport for " + source.getDistributor();
105
106	if (failed) {
107	subject = "Error: too many closed addresses for " + source.getDistributor();
108	reportData = "<h1><font color='red'>Data er IKKE skrevet til DB</font></h1><br>\r\n" + reportData;
109	}
110
111	String newOpenCloseAttachment = getAttachement();
112
113	MailSender.sendMailWithAttachment(subject, reportData, "Details.csv", newOpenCloseAttachment);
114
115	}
116
117
118
119	public String getReportData() {
120
121	WeekEntry total = new WeekEntry();
122	HashMap<Short, WeekEntry> postnrEntries = new HashMap<Short,WeekEntry>();
123
124	int createFailCount = 0;
125
126	int antalUdenGadeid = 0;
127	int antalUdenKommunekode = 0;
128	int antalUdenLatitude = 0;
129	int antalUdenDBKBane = 0;
130
131	// first gather the intel
132	for (Address a : addressList) {
133
134	if (a.state == AddressState.CREATE_FAIL) {
135	createFailCount++;
136	continue;
137	}
138
139	if (a.gadeid == 0) {
140	antalUdenGadeid++;
141	}
142
143	if (a.kommunekode == 0 \|\| a.vejkode == 0) {
144	antalUdenKommunekode++;
145	}
146
147	if (a.latitude == 0 \|\| a.longitude == 0) {
148	antalUdenLatitude++;
149	}
150
151	if (a.state == AddressState.NOT_CHANGED) {
152	continue;
153	}
154	if (a.dbkBane == null \|\| a.dbkBane.length() == 0) {
155	antalUdenDBKBane++;
156	}
157
158	WeekEntry weekEntry = postnrEntries.get(a.postnr);
159	if (weekEntry == null) {
160	weekEntry = new WeekEntry();
161	postnrEntries.put(a.postnr, weekEntry);
162	}
163
164
165
166	if (a.state == AddressState.CREATED) {
167	weekEntry.incrementCreated();
168	} else {
169	weekEntry.man.updateFromState(a.stateMan);
170	weekEntry.tir.updateFromState(a.stateTir);
171	weekEntry.ons.updateFromState(a.stateOns);
172	weekEntry.tor.updateFromState(a.stateTor);
173	weekEntry.fre.updateFromState(a.stateFre);
174	weekEntry.lor.updateFromState(a.stateLor);
175	weekEntry.son.updateFromState(a.stateSon);
176
177	}
178	}
179	for (WeekEntry w : postnrEntries.values()) {
180	total.incrementFromOther(w);
181	}
182
183	StringBuilder sb = new StringBuilder();
184
185	sb.append("<h1>Indlæsnings rapport for " + source.getDistributor() + " </h1>");
186	sb.append("Filnavn: ").append( source.getFilename() ).append("<br>");
187	sb.append("Tidsforbrug: ").append( timer.getElapsed() ).append("ms. <br>");
188	sb.append("Skriv til DB: ").append( writeBack ).append("<br>");
189	sb.append("Antal entries: " ).append( entryCount ).append("<br>");
190	sb.append("Antal afviste: " ).append( addrManager.getRejectedCount() ).append("<br>");
191	sb.append("Antal dubletter: " ).append( duplicateCount ).append("<br>");
192	sb.append("Antal fejlede inserts: ").append(createFailCount).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><br>");
202
203	sb.append("<h2>Data Mangler</h2>\n");
204	sb.append("Mangler kommune/vejkode: ").append(antalUdenKommunekode).append("<br>");
205	sb.append("Mangler gadeid: ").append(antalUdenGadeid).append("<br>");
206	sb.append("Mangler DBK bane: ").append(antalUdenDBKBane).append("<br>");
207	sb.append("Mangler latitude/longitude: ").append(antalUdenLatitude).append("<br>");
208	sb.append("<br>");
209
210
211
212	sb.append("<h2>Ændrings oversigt</h2>\n");
213	sb.append("<table>");
214
215	sb.append("<tr><td> </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	sb.append("</table>");
221
222	sb.append("<br>");
223	sb.append("<h2>Nye/Ukendte gader</h2>");
224	sb.append("<table>");
225	sb.append("<tr><th>Gadeid</th><th>Vejnavn</th></tr>");
226	for( Entry<Integer,String> unknownStreet : addrManager.getUnknownStreets().entrySet() ) {
227	sb.append("<tr><td>").append(unknownStreet.getKey()).append("</td><td>").append(unknownStreet.getValue()).append("</td></tr>");
228	}
229	sb.append("</table>");
230
231
232	sb.append("</table><br>\n");
233
234	return sb.toString();
235	}
236
237	public String getAttachement() {
238	StringBuilder sb = new StringBuilder();
239	sb.append("Status;Gadeid;Post;Vejnavn;Husnr;Litra\r\n");
240
241	ArrayList<Address> attachmentData = new ArrayList<Address>();
242	for (Address a : addressList) {
243	if (a.state == AddressState.CLOSED \|\| a.state == AddressState.CREATED \|\| a.state == AddressState.OPENED) {
244	attachmentData.add(a);
245	}
246	}
247
248	Collections.sort(attachmentData, new AttachmentComparator());
249
250	for (Address a : attachmentData) {
251	switch (a.state) {
252	case CLOSED:
253	sb.append("Closed;");
254	break;
255	case CREATED:
256	sb.append("Created;");
257	break;
258	case OPENED:
259	sb.append("Opened;");
260	break;
261	default:
262	break;
263	}
264
265	//tilføj resten af dataene
266	sb.append( a.gadeid + ";" + a.postnr + ";" + a.vejnavn + ";" + a.husnr + ";" + a.husnrbogstav + "\r\n");
267	}
268
269	return sb.toString();
270	}
271
272
273	/*
274	* Serializable is to silence findbugs
275	*/
276	static class AttachmentComparator implements Comparator<Address>, Serializable {
277	private static final long serialVersionUID = 1L;
278
279	@Override
280	public int compare(Address a1, Address a2) {
281
282
283	//Brug apache commons lang3
284	return new CompareToBuilder()
285	.append(a1.state, a2.state)
286	.append(a1.postnr, a2.postnr)
287	.append(a1.vejnavn, a2.vejnavn)
288	.append(a1.husnr, a2.husnr)
289	.append(a1.husnrbogstav, a2.husnrbogstav)
290	.toComparison();
291	}
292
293	}
294	}