3 |
import java.util.ArrayList; |
import java.util.ArrayList; |
4 |
import java.util.List; |
import java.util.List; |
5 |
import java.util.Map; |
import java.util.Map; |
|
import java.util.Set; |
|
6 |
import java.util.TreeMap; |
import java.util.TreeMap; |
|
import java.util.TreeSet; |
|
7 |
|
|
8 |
import dk.daoas.adressevedligehold.MailSender; |
import dk.daoas.adressevedligehold.MailSender; |
9 |
import dk.daoas.adressevedligehold.beans.Address; |
import dk.daoas.adressevedligehold.beans.Address; |
11 |
import dk.daoas.adressevedligehold.db.DatabaseCoverageUpdate; |
import dk.daoas.adressevedligehold.db.DatabaseCoverageUpdate; |
12 |
import dk.daoas.adressevedligehold.tasks.Task; |
import dk.daoas.adressevedligehold.tasks.Task; |
13 |
import dk.daoas.adressevedligehold.tasks.TaskLogger; |
import dk.daoas.adressevedligehold.tasks.TaskLogger; |
14 |
|
import dk.daoas.adressevedligehold.util.CountMap; |
15 |
import dk.daoas.adressevedligehold.util.DeduplicateHelper; |
import dk.daoas.adressevedligehold.util.DeduplicateHelper; |
16 |
import dk.daoas.adressevedligehold.util.TimingHelper; |
import dk.daoas.adressevedligehold.util.TimingHelper; |
17 |
|
|
93 |
|
|
94 |
List<Address> dawaListe = dawa.adresserIKommune(kommunekode); |
List<Address> dawaListe = dawa.adresserIKommune(kommunekode); |
95 |
// stage 3 søg |
// stage 3 søg |
96 |
Set<String> ukendteDAV = new TreeSet<>(); |
CountMap ukendteDAV = new CountMap(); |
97 |
Set<String> dobbeltGadeidDAV = new TreeSet<>(); |
CountMap dobbeltGadeidDAV = new CountMap(); |
98 |
List<Address> nyeAdresser = new ArrayList<>(); |
List<Address> nyeAdresser = new ArrayList<>(); |
99 |
|
|
100 |
for (Address dawaAddr : dawaListe) { |
for (Address dawaAddr : dawaListe) { |
101 |
String dav = getDAVid(dawaAddr); |
String dav = getDAVid(dawaAddr); |
102 |
DawaGade gade = search.get(dav); |
DawaGade gade = search.get(dav); |
103 |
if (gade == null) { |
if (gade == null) { |
104 |
ukendteDAV.add(dav + " " + dawaAddr.vejnavn); |
String key = dav + " " + dawaAddr.vejnavn; |
105 |
|
ukendteDAV.increment(key); |
106 |
continue; |
continue; |
107 |
} |
} |
108 |
|
|
109 |
if (gade.gadeids.size() != 1) { |
if (gade.gadeids.size() != 1) { |
110 |
dobbeltGadeidDAV.add(dav + " " + dawaAddr.vejnavn); |
String key = dav + " " + dawaAddr.vejnavn; |
111 |
|
dobbeltGadeidDAV.increment(key); |
112 |
|
continue; |
113 |
} |
} |
114 |
|
|
115 |
boolean fundet = false; |
boolean fundet = false; |
131 |
|
|
132 |
db.saveNewAddresses(nyeAdresser); |
db.saveNewAddresses(nyeAdresser); |
133 |
|
|
134 |
logger.info("Save to db done - sending report mail"); |
logger.info("Save to db done - adding to report mail"); |
135 |
|
|
136 |
List<Address> saveOK = new ArrayList<>(); |
List<Address> saveOK = new ArrayList<>(); |
137 |
List<Address> saveFail = new ArrayList<>(); |
List<Address> saveFail = new ArrayList<>(); |
150 |
|
|
151 |
|
|
152 |
sb.append("<h2>Kommune: " + kommunenavn + "</h2>\n"); |
sb.append("<h2>Kommune: " + kommunenavn + "</h2>\n"); |
153 |
|
|
154 |
|
sb.append("Kommunekode: " + kommunekode + "<br>\n"); |
155 |
sb.append("Antal Inserts: " + saveOK.size() + "<br>\n"); |
sb.append("Antal Inserts: " + saveOK.size() + "<br>\n"); |
156 |
sb.append("Antal insert fails: " + saveFail.size() + "<br>\n"); |
sb.append("Antal insert fails: " + saveFail.size() + "<br>\n"); |
157 |
sb.append("Antal ukendte dav: " + ukendteDAV.size() + "<br>\n"); |
sb.append("Antal ukendte dav: " + ukendteDAV.size() + "<br>\n"); |
164 |
addressTable(sb, saveFail); |
addressTable(sb, saveFail); |
165 |
|
|
166 |
sb.append("<h3>Ukendte DAV:</h3>\n"); |
sb.append("<h3>Ukendte DAV:</h3>\n"); |
167 |
for (String dav : ukendteDAV) { |
for (Map.Entry<String, Integer> dav : ukendteDAV.entrySet()) { |
168 |
sb.append(dav + "<br>\n"); |
sb.append(dav.getKey() + " : " + dav.getValue() + "<br>\n"); |
169 |
} |
} |
170 |
|
|
171 |
sb.append("<h3>Dobbelt gadeid DAV:</h3>\n"); |
sb.append("<h3>Dobbelt gadeid DAV:</h3>\n"); |
172 |
for (String dav : dobbeltGadeidDAV) { |
for (Map.Entry<String, Integer> dav : dobbeltGadeidDAV.entrySet()) { |
173 |
sb.append(dav + "<br>\n"); |
sb.append(dav.getKey() + " : " + dav.getValue() + "<br>\n"); |
174 |
} |
} |
|
|
|
175 |
} |
} |
176 |
|
logger.info("Sendingreport mail"); |
177 |
|
|
178 |
headerSB.append("Antal Inserts: " + totalAntalNye + "<br>\n"); |
headerSB.append("Antal Inserts: " + totalAntalNye + "<br>\n"); |
179 |
headerSB.append("Antal insert fails: " + totalAntalFejl + "<br>\n"); |
headerSB.append("Antal insert fails: " + totalAntalFejl + "<br>\n"); |