/[projects]/dao/DaoAdresseService/src/dk/daoas/daoadresseservice/AdressSearch.java
ViewVC logotype

Contents of /dao/DaoAdresseService/src/dk/daoas/daoadresseservice/AdressSearch.java

Parent Directory Parent Directory | Revision Log Revision Log


Revision 2310 - (show annotations) (download)
Mon Feb 16 13:49:56 2015 UTC (9 years, 3 months ago) by torben
File size: 13331 byte(s)
Udvidet dynamic alias opbygning
1 package dk.daoas.daoadresseservice;
2
3 import java.sql.SQLException;
4 import java.util.HashMap;
5 import java.util.HashSet;
6 import java.util.Iterator;
7 import java.util.List;
8 import java.util.Map;
9 import java.util.Set;
10 import java.util.concurrent.ConcurrentHashMap;
11
12 import dk.daoas.daoadresseservice.AddressUtils.SplitResult;
13 import dk.daoas.daoadresseservice.beans.Address;
14 import dk.daoas.daoadresseservice.beans.ExtendedBean;
15 import dk.daoas.daoadresseservice.beans.HundredePctBean;
16 import dk.daoas.daoadresseservice.beans.SearchResult;
17 import dk.daoas.daoadresseservice.beans.SearchResult.Status;
18 import dk.daoas.daoadresseservice.db.DatabaseLayer;
19
20 public class AdressSearch {
21
22 Map<Integer, Map<String,Long>> searchPostnrVejnavnGadeid;
23 Map<Long, Map<String,Address>> searchGadeidentAdresser;
24
25 List<Address> alleAdresser;
26
27 Map<String,Long> helperCache;
28
29
30 Map<Integer,HundredePctBean> hundredePct;
31
32
33 public SearchResult search(String postnrStr, String adresse) {
34
35 int postnr=0;
36 boolean google = false;
37 boolean osm = false;
38 String helperSearchKey = "";
39
40 try {
41 postnr = Integer.parseInt(postnrStr);
42 } catch (Exception E) {
43 return new SearchResult(Status.ERROR_UNKNOWN_POSTAL);
44 }
45
46 Map<String,Long> postnrVeje = searchPostnrVejnavnGadeid.get(postnr);
47
48 if (postnrVeje == null) {
49 return new SearchResult(Status.ERROR_UNKNOWN_POSTAL);
50 }
51
52
53 SplitResult split = AddressUtils.splitAdresse(adresse);
54 String vasketVejnavn = AddressUtils.vaskVejnavn( split.vej );
55
56 if (split.husnr.length() == 0) {
57 return new SearchResult(Status.ERROR_MISSING_HOUSENUMBER);
58 }
59
60 Long gadeident = postnrVeje.get(vasketVejnavn);
61
62
63 if ( gadeident == null) {
64 helperSearchKey = "" + postnr + "/" + vasketVejnavn;
65 gadeident = helperCache.get(helperSearchKey);
66 }
67
68
69 if ( gadeident == null) {
70 String googleVej = GeocodeHelper.googleHelper(postnr, split.vej );
71 google = true;
72
73 if (googleVej != null) {
74 String googleVasket = AddressUtils.vaskVejnavn( googleVej );
75 gadeident = postnrVeje.get(googleVasket);
76
77 if (gadeident != null) {
78 helperCache.put(helperSearchKey, gadeident);
79 }
80 }
81 }
82
83 if ( gadeident == null) {
84 String osmVej = GeocodeHelper.openstreetmapHelper(postnr, split.vej );
85 osm = true;
86
87 if (osmVej != null) {
88 String osmVasket = AddressUtils.vaskVejnavn( osmVej );
89 gadeident = postnrVeje.get(osmVasket);
90
91 if (gadeident != null) {
92 helperCache.put(helperSearchKey, gadeident);
93 }
94 }
95 }
96
97 if (gadeident == null) {
98 return new SearchResult(Status.ERROR_UNKNOWN_STREETNAME);
99 }
100
101 Map<String, Address> gade = searchGadeidentAdresser.get(gadeident); //Denne søgning må ikke fejle
102
103
104 String husnrSearch = "" + split.husnr + split.litra;
105 Address addr = gade.get(husnrSearch);
106
107 if (addr == null) {
108 return new SearchResult(Status.ERROR_UNKNOWN_ADDRESSPOINT);
109 }
110
111 if (addr.daekningsType == DaekningsType.DAEKNING_IKKEDAEKKET) {
112 return new SearchResult(Status.STATUS_NOT_COVERED);
113 }
114
115 if (addr.distributor.equals("LUKKET")) {
116 return new SearchResult(Status.STATUS_NOT_COVERED); //Skal vi have en special status til Lukkede adresser ?
117 }
118
119 SearchResult res = new SearchResult(addr);
120 res.google = google;
121 res.osm = osm;
122 return res;
123 }
124
125
126 public void buildSearchStructures() throws SQLException{
127 searchPostnrVejnavnGadeid = new HashMap<Integer, Map<String,Long>>();
128 searchGadeidentAdresser = new HashMap<Long, Map<String,Address>>();
129 helperCache = new ConcurrentHashMap<String,Long>();
130
131 long start1 = System.currentTimeMillis();
132 System.out.println("Build -- stage 1");
133
134 alleAdresser = DatabaseLayer.getAllAdresses();
135
136
137 /* Mapper mellem db Row ID og adresse noden */
138 Map<Integer,Address> idAddressMap = new HashMap<Integer,Address>( alleAdresser.size() );
139
140 for (Address a : alleAdresser) {
141 idAddressMap.put(a.id, a);
142
143 Map<String,Long> postnrVeje = searchPostnrVejnavnGadeid.get(a.postnr);
144
145 if (postnrVeje == null) {
146 postnrVeje = new ConcurrentHashMap<String,Long>();
147 searchPostnrVejnavnGadeid.put(a.postnr, postnrVeje);
148 }
149
150 String vasketVejnavn = AddressUtils.vaskVejnavn(a.vejnavn);
151 Long gadeident = postnrVeje.get(vasketVejnavn);
152 if (gadeident == null) {
153 //postnrVeje.put(vasketVejnavn, a.gadeid);
154
155 Set<String> aliaser = findVejAliaser(a.vejnavn);
156 for(String alias : aliaser) {
157 String vasketAlias = AddressUtils.vaskVejnavn(alias);
158 postnrVeje.put(vasketAlias, a.gadeid);
159 }
160
161 }
162
163 Map<String, Address> gade = searchGadeidentAdresser.get(a.gadeid);
164 if (gade == null) {
165 gade = new HashMap<String, Address>();
166 searchGadeidentAdresser.put(a.gadeid, gade);
167 }
168 String husnrSearch = "" + a.husnr + a.husnrbogstav;
169 gade.put(husnrSearch, a);
170 }
171
172
173 ////////////////////////////////////////////////////////////////////////////////////////
174 long start2 = System.currentTimeMillis();
175 System.out.println("Build, stage1 elapsed: " + (start2-start1) );
176 System.out.println("Build -- stage 2 udvidet dækning");
177
178 List<ExtendedBean> extDao = DatabaseLayer.getExtendedAdresslist();
179 for (ExtendedBean eb : extDao) {
180
181 Address orgAddress = idAddressMap.get(eb.orgId);
182 if (orgAddress == null)
183 continue;
184
185 Address targetAddress = idAddressMap.get(eb.targetId);
186 if (targetAddress == null)
187 continue;
188
189 if (orgAddress.distributor != null && orgAddress.distributor.equals("LUKKET")) {
190 continue;
191 }
192
193 if (targetAddress.distributor.equals("LUKKET")) {
194 continue;
195 }
196
197 orgAddress.extTarget = targetAddress;
198 orgAddress.extAfstand = eb.afstand;
199
200 boolean covered = false;
201 if (targetAddress.distributor.equals("DAO")) {
202 orgAddress.rute = calculateExtendedDaoRoute(eb,orgAddress,targetAddress);
203 if (orgAddress.rute != null) {
204 orgAddress.koreliste = targetAddress.koreliste;
205 covered = true;
206 }
207 }
208
209 if (targetAddress.distributor.equals("BK")) {
210 orgAddress.koreliste = calculateExtendedBkKoreliste(eb,orgAddress,targetAddress);
211 if (orgAddress.koreliste != null) {
212 orgAddress.rute = targetAddress.rute;
213 covered = true;
214 }
215 }
216
217 if (covered) { //Kopier resten af felterne
218 orgAddress.daekningsType = DaekningsType.DAEKNING_UDVIDET;
219 orgAddress.dbkBane = targetAddress.dbkBane;
220
221 /* Sådan gør den gamle service */
222 orgAddress.kommunekode = targetAddress.kommunekode;
223 orgAddress.vejkode = targetAddress.vejkode;
224
225 orgAddress.distributor = targetAddress.distributor;
226 }
227 }
228
229 // nu skal vi ikke bruge idAddressMap længere
230 idAddressMap = null;
231
232 //////////////////////////////////////////////////////////////////////////////////////
233 long start3 = System.currentTimeMillis();
234 System.out.println("Build, stage2 elapsed: " + (start3-start2) );
235 System.out.println("Build -- stage 3 - 100pct");
236
237 hundredePct = DatabaseLayer.get100PctList();
238 for (Address addr : alleAdresser) {
239 if (addr.daekningsType != DaekningsType.DAEKNING_IKKEDAEKKET) {
240 continue;
241 }
242
243 if (addr.distributor != null && addr.distributor.equals("LUKKET")) {
244 continue;
245 }
246
247
248 HundredePctBean bean = hundredePct.get(addr.postnr);
249 if (bean == null) {
250 continue;
251 }
252
253 addr.daekningsType = DaekningsType.DAEKNING_100PCT;
254 addr.rute = bean.rute;
255 addr.koreliste = bean.koreliste;
256 addr.dbkBane = bean.dbkBane;
257 addr.distributor = bean.distributor;
258 }
259
260 ////////////////////////////////////////////////////////////////////////////////////
261 long stop = System.currentTimeMillis();
262 System.out.println("Build, stage3 elapsed: " + (stop-start3) );
263 System.out.println("Build -- Gathering statistics");
264
265 int direkteCount = 0;
266 int extendedCount = 0;
267 int hundredePctCount = 0;
268 int ikkeDaekketCount = 0;
269
270 for (Address addr : alleAdresser) {
271 switch (addr.daekningsType) {
272 case DAEKNING_DIREKTE:
273 direkteCount++;
274 break;
275 case DAEKNING_UDVIDET:
276 extendedCount++;
277 break;
278 case DAEKNING_100PCT:
279 hundredePctCount++;
280 break;
281 default:
282 ikkeDaekketCount++;
283 }
284 }
285
286 System.out.println("Build: direkteCount: " + direkteCount);
287 System.out.println("Build: extendedCount: " + extendedCount);
288 System.out.println("Build: hundredePctCount: " + hundredePctCount);
289 System.out.println("Build: ikkeDaekketCount: " + ikkeDaekketCount);
290
291 System.out.println("Build: Total Elapsed: " + (stop-start1) );
292 System.out.println("Build Completed");
293
294 }
295
296
297 private String calculateExtendedDaoRoute(ExtendedBean eb, Address orgAddress, Address targetAddress) {
298
299 // ///////////////////////////////////////////////////////////////////
300 switch( eb.transport) {
301 case "cykel":
302 if (eb.afstand < 0.151) {
303 return "." + targetAddress.rute;
304 } else if (eb.afstand < 0.501) {
305 return ".." + targetAddress.rute;
306 } else if (eb.afstand < 0.701) {
307 return "..." + targetAddress.rute;
308 } else if (eb.afstand < 0.501) {
309 return "...." + targetAddress.rute;
310 }
311 break;
312 case "scooter":
313 if (eb.afstand < 0.151) {
314 return "." + targetAddress.rute;
315 } else if (eb.afstand < 0.801) {
316 return ".." + targetAddress.rute;
317 } else if (eb.afstand < 1.201) {
318 return "..." + targetAddress.rute;
319 } else if (eb.afstand < 2.101) {
320 return "...." + targetAddress.rute;
321 }
322 break;
323 case "bil":
324 if (eb.afstand < 0.151) {
325 return "." + targetAddress.rute;
326 } else if (eb.afstand < 1.001) {
327 return ".." + targetAddress.rute;
328 } else if (eb.afstand < 1.601) {
329 return "..." + targetAddress.rute;
330 } else if (eb.afstand < 2.601) {
331 return "...." + targetAddress.rute;
332 }
333 break;
334 }
335 return null;
336 }
337
338 ///////////////////////////////////////////////////////////
339 private String calculateExtendedBkKoreliste(ExtendedBean eb, Address orgAddress, Address targetAddress) {
340 String inject;
341 if (eb.afstand <= 0.500) {
342 inject = ".";
343 } else {
344 inject = "..";
345 }
346 return AddressUtils.injectIntoBk(targetAddress.koreliste, inject);
347 }
348
349 private Set<String> findVejAliaser(String vejnavn) {
350 vejnavn = vejnavn.toLowerCase();
351 HashSet<String> aliasSet = new HashSet<String>();
352 aliasSet.add(vejnavn);
353
354 aliasSet.add(vejnavn.replace("alle", "allé") );
355 aliasSet.add(vejnavn.replace("allé", "alle") );
356
357 aliasSet.add(vejnavn.replace("dronningens", "dr") );
358 aliasSet.add(vejnavn.replace("dr.", "dronningens") );
359 aliasSet.add(vejnavn.replace("dr ", "dronningens") );
360
361 aliasSet.add(vejnavn.replace("kvt", "kvarter") );
362 aliasSet.add(vejnavn.replace("kvarter", "kvt") );
363
364 aliasSet.add(vejnavn.replace("gl", "gammel") );
365 aliasSet.add(vejnavn.replace("gammel", "gl") );
366
367 aliasSet.add(vejnavn.replace("lille", "ll") );
368 aliasSet.add(vejnavn.replace("ll ", "lille") );
369 aliasSet.add(vejnavn.replace("ll.", "lille") );
370
371 aliasSet.add(vejnavn.replace("store", "st") );
372 aliasSet.add(vejnavn.replace("st ", "store") );
373 aliasSet.add(vejnavn.replace("st.", "store") );
374
375 aliasSet.add(vejnavn.replace("søndre", "sdr") );
376 aliasSet.add(vejnavn.replace("sdr", "søndre") );
377
378
379 aliasSet.add(vejnavn.replace("nørre", "nr") );
380 aliasSet.add(vejnavn.replace("nr", "nørre") );
381
382 aliasSet.add(vejnavn.replace("nordre", "ndr") );
383 aliasSet.add(vejnavn.replace("ndr", "nordre") );
384
385 aliasSet.add(vejnavn.replace("sankt", "skt") );
386 aliasSet.add(vejnavn.replace("sankt", "sct") );
387 aliasSet.add(vejnavn.replace("skt", "sankt") );
388
389 aliasSet.add(vejnavn.replace("skt", "sct") );
390 aliasSet.add(vejnavn.replace("sct", "skt") );
391
392 // Opbyg æøå varianter over alle fundne aliaser
393
394 @SuppressWarnings("unchecked")
395 HashSet<String> variants = (HashSet<String>) aliasSet.clone();
396
397 Iterator<String> vIt = variants.iterator();
398 while ( vIt.hasNext() ) {
399 String vVejnavn = vIt.next();
400
401 // danske tegn 1
402 aliasSet.add( vVejnavn.replace("æ", "ae") );
403 aliasSet.add( vVejnavn.replace("ø", "oe") );
404 aliasSet.add( vVejnavn.replace("å", "aa") );
405 aliasSet.add( vVejnavn.replace("ae", "æ") );
406 aliasSet.add( vVejnavn.replace("oe", "ø") );
407 aliasSet.add( vVejnavn.replace("aa", "å") );
408
409 //danske tegn 2
410 aliasSet.add( vVejnavn.replace("æ", "ae").replace("ø", "oe") );
411 aliasSet.add( vVejnavn.replace("æ", "ae").replace("å", "aa") );
412 aliasSet.add( vVejnavn.replace("ø", "ae").replace("å", "aa") );
413 aliasSet.add( vVejnavn.replace("ae", "æ").replace("oe","ø") );
414 aliasSet.add( vVejnavn.replace("ae", "æ").replace("aa","å") );
415 aliasSet.add( vVejnavn.replace("oe", "ø").replace("aa", "å") );
416
417 //danske tegn 3
418 aliasSet.add( vejnavn.replace("æ", "ae").replace("ø", "oe").replace("å", "aa") );
419 aliasSet.add( vejnavn.replace("ae", "æ").replace("oe", "ø").replace("aa", "å") );
420 }
421
422 return aliasSet;
423 }
424
425
426 }

  ViewVC Help
Powered by ViewVC 1.1.20