--- dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/dawa/DawaTask.java 2016/04/19 19:55:19 3008 +++ dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/dawa/DawaTask.java 2016/04/20 14:15:02 3013 @@ -3,9 +3,7 @@ import java.util.ArrayList; import java.util.List; import java.util.Map; -import java.util.Set; import java.util.TreeMap; -import java.util.TreeSet; import dk.daoas.adressevedligehold.MailSender; import dk.daoas.adressevedligehold.beans.Address; @@ -13,6 +11,7 @@ import dk.daoas.adressevedligehold.db.DatabaseCoverageUpdate; import dk.daoas.adressevedligehold.tasks.Task; import dk.daoas.adressevedligehold.tasks.TaskLogger; +import dk.daoas.adressevedligehold.util.CountMap; import dk.daoas.adressevedligehold.util.DeduplicateHelper; import dk.daoas.adressevedligehold.util.TimingHelper; @@ -94,20 +93,23 @@ List
dawaListe = dawa.adresserIKommune(kommunekode); // stage 3 søg - Set ukendteDAV = new TreeSet<>(); - Set dobbeltGadeidDAV = new TreeSet<>(); + CountMap ukendteDAV = new CountMap(); + CountMap dobbeltGadeidDAV = new CountMap(); List
nyeAdresser = new ArrayList<>(); for (Address dawaAddr : dawaListe) { String dav = getDAVid(dawaAddr); DawaGade gade = search.get(dav); if (gade == null) { - ukendteDAV.add(dav + " " + dawaAddr.vejnavn); + String key = dav + " " + dawaAddr.vejnavn; + ukendteDAV.increment(key); continue; } if (gade.gadeids.size() != 1) { - dobbeltGadeidDAV.add(dav + " " + dawaAddr.vejnavn); + String key = dav + " " + dawaAddr.vejnavn; + dobbeltGadeidDAV.increment(key); + continue; } boolean fundet = false; @@ -129,7 +131,7 @@ db.saveNewAddresses(nyeAdresser); - logger.info("Save to db done - sending report mail"); + logger.info("Save to db done - adding to report mail"); List
saveOK = new ArrayList<>(); List
saveFail = new ArrayList<>(); @@ -148,6 +150,8 @@ sb.append("

Kommune: " + kommunenavn + "

\n"); + + sb.append("Kommunekode: " + kommunekode + "
\n"); sb.append("Antal Inserts: " + saveOK.size() + "
\n"); sb.append("Antal insert fails: " + saveFail.size() + "
\n"); sb.append("Antal ukendte dav: " + ukendteDAV.size() + "
\n"); @@ -160,16 +164,16 @@ addressTable(sb, saveFail); sb.append("

Ukendte DAV:

\n"); - for (String dav : ukendteDAV) { - sb.append(dav + "
\n"); + for (Map.Entry dav : ukendteDAV.entrySet()) { + sb.append(dav.getKey() + " : " + dav.getValue() + "
\n"); } sb.append("

Dobbelt gadeid DAV:

\n"); - for (String dav : dobbeltGadeidDAV) { - sb.append(dav + "
\n"); - } - + for (Map.Entry dav : dobbeltGadeidDAV.entrySet()) { + sb.append(dav.getKey() + " : " + dav.getValue() + "
\n"); + } } + logger.info("Sendingreport mail"); headerSB.append("Antal Inserts: " + totalAntalNye + "
\n"); headerSB.append("Antal insert fails: " + totalAntalFejl + "
\n");