--- dao/DaoAdresseService/src/dk/daoas/daoadresseservice/AddressSearch.java 2015/03/02 07:45:27 2419 +++ dao/DaoAdresseService/src/main/java/dk/daoas/daoadresseservice/AddressSearch.java 2015/05/11 07:24:54 2534 @@ -9,7 +9,10 @@ import java.util.HashSet; import java.util.List; import java.util.Map; +import java.util.Map.Entry; import java.util.Set; +import java.util.TreeMap; +import java.util.TreeSet; import java.util.concurrent.ConcurrentHashMap; import org.apache.commons.lang3.StringUtils; @@ -24,15 +27,17 @@ import dk.daoas.daoadresseservice.beans.SearchResult; import dk.daoas.daoadresseservice.beans.SearchResult.Status; import dk.daoas.daoadresseservice.db.DatabaseLayer; +import dk.daoas.daoadresseservice.util.DeduplicateHelper; +import dk.daoas.daoadresseservice.util.NaturalOrderComparator; public class AddressSearch { - private Map> searchPostnrVejnavnGadeid; - private Map> searchGadeidentAdresser; + private Map> searchPostnrVejnavnGadeid; + private Map> searchGadeidentAdresser; private List
alleAdresser; - private Map helperCache; + private Map helperCache; private DataStatisticsBean stats = new DataStatisticsBean(); @@ -53,6 +58,11 @@ public SearchResult search(String postnrStr, String adresse) { + + postnrStr = postnrStr.trim(); + adresse = adresse.trim(); + + SearchRequest request = new SearchRequest(); SearchResult result = new SearchResult(); @@ -60,7 +70,7 @@ String helperSearchKey = ""; try { - request.postnr = Integer.parseInt(postnrStr); + request.postnr = Short.parseShort(postnrStr); } catch (Exception E) { result.status = Status.ERROR_UNKNOWN_POSTAL; return result; @@ -89,6 +99,7 @@ if (request.vasketVejnavn.indexOf("pakkebo") > -1 + || request.vasketVejnavn.indexOf("pakkepost") > -1 || request.vasketVejnavn.indexOf("døgnpost") > -1 || request.vasketVejnavn.indexOf("døgnbo") > -1 || request.vasketVejnavn.equals("id") @@ -97,7 +108,7 @@ return result; } - Long gadeident = request.streetNames.get(request.vasketVejnavn); + Integer gadeident = request.streetNames.get(request.vasketVejnavn); if ( gadeident == null) { @@ -173,12 +184,12 @@ return result; } - private Long helperWrapper(String vej, Map postnrVeje, String helperSearchKey) { + private Integer helperWrapper(String vej, Map postnrVeje, String helperSearchKey) { if (vej == null) return null; String vejVasket = AddressUtils.vaskVejnavn( vej ); - Long gadeident = postnrVeje.get(vejVasket); + Integer gadeident = postnrVeje.get(vejVasket); if (gadeident != null) { helperCache.put(helperSearchKey, gadeident); @@ -187,16 +198,16 @@ } - public Map getStretsByPostal(int zip) { + public Map getStretsByPostal(int zip) { return searchPostnrVejnavnGadeid.get(zip); } public void buildSearchStructures() throws SQLException{ - searchPostnrVejnavnGadeid = new HashMap>(); - searchGadeidentAdresser = new HashMap>(); - helperCache = new ConcurrentHashMap(); + searchPostnrVejnavnGadeid = new HashMap>(); + searchGadeidentAdresser = new HashMap>(); + helperCache = new ConcurrentHashMap(); long start1 = System.currentTimeMillis(); System.out.println("Build -- stage 1"); @@ -206,19 +217,22 @@ /* Mapper mellem db Row ID og adresse noden */ Map idAddressMap = new HashMap( alleAdresser.size() ); + DeduplicateHelper aliasHelper = new DeduplicateHelper(); + DeduplicateHelper husnrHelper = new DeduplicateHelper(); for (Address a : alleAdresser) { idAddressMap.put(a.id, a); - Map postnrVeje = searchPostnrVejnavnGadeid.get(a.postnr); + Map postnrVeje = searchPostnrVejnavnGadeid.get(a.postnr); if (postnrVeje == null) { - postnrVeje = new ConcurrentHashMap(); + postnrVeje = new ConcurrentHashMap(); searchPostnrVejnavnGadeid.put(a.postnr, postnrVeje); } + String vasketVejnavn = AddressUtils.vaskVejnavn(a.vejnavn); - Long gadeident = postnrVeje.get(vasketVejnavn); + Integer gadeident = postnrVeje.get(vasketVejnavn); if (gadeident == null) { //postnrVeje.put(vasketVejnavn, a.gadeid); @@ -227,6 +241,8 @@ Set aliaser = findVejAliaser(a.vejnavn); for(String alias : aliaser) { String vasketAlias = AddressUtils.vaskVejnavn(alias); + vasketAlias = aliasHelper.getInstance(vasketAlias); + postnrVeje.put(vasketAlias, gadeident); } } @@ -237,6 +253,7 @@ searchGadeidentAdresser.put(gadeident, gade); } String husnrSearch = "" + a.husnr + a.husnrbogstav; + husnrSearch = husnrHelper.getInstance(husnrSearch); gade.put(husnrSearch, a); } @@ -248,7 +265,7 @@ int vaskCount = 0; List aliasList = DatabaseLayer.getAliasList(); for (AliasBean alias : aliasList) { - Map postnrVeje = searchPostnrVejnavnGadeid.get(alias.postnr); + Map postnrVeje = searchPostnrVejnavnGadeid.get(alias.postnr); if (postnrVeje == null) { //Burde ikke kunne ske - men better safe than sorry @@ -258,13 +275,13 @@ String vasketVej = AddressUtils.vaskVejnavn(alias.vejnavn); String vasketAlias = AddressUtils.vaskVejnavn(alias.aliasVejnavn); - Long gadeident = postnrVeje.get(vasketVej); + Integer gadeident = postnrVeje.get(vasketVej); if (gadeident == null) { //Kender ikke den oprindelige vej continue; } - Long aliasIdent = postnrVeje.get(vasketAlias); + Integer aliasIdent = postnrVeje.get(vasketAlias); if (aliasIdent == null) { //Vi kender ikke denne variant af vejnavnet postnrVeje.put(vasketAlias, gadeident); @@ -280,6 +297,9 @@ System.out.println("Build, stage2 elapsed: " + (start3-start2) ); System.out.println("Build -- stage 3 udvidet dækning"); + DeduplicateHelper ruteHelper = new DeduplicateHelper(); + DeduplicateHelper korelisteHelper = new DeduplicateHelper(); + List extDao = DatabaseLayer.getExtendedAdresslist(); for (ExtendedBean eb : extDao) { @@ -287,15 +307,24 @@ if (orgAddress == null) continue; + if (orgAddress.daekningsType != DaekningsType.DAEKNING_IKKEDAEKKET) { + //kan være at adressen er blevet markeret dækket og - find-nærmeste data ikke er opdateret i mellemtiden + continue; + } + Address targetAddress = idAddressMap.get(eb.targetId); - if (targetAddress == null) + if (targetAddress == null) { continue; + } - if (orgAddress.distributor != null && orgAddress.distributor.equals("LUKKET")) { + + if ( StringUtils.equals(orgAddress.distributor, "LUKKET") ) { continue; } - if (targetAddress.distributor.equals("LUKKET")) { + + + if ( StringUtils.equals(targetAddress.distributor, "LUKKET") ) { continue; } @@ -304,7 +333,9 @@ boolean covered = false; if (targetAddress.distributor.equals("DAO")) { - orgAddress.rute = calculateExtendedDaoRoute(eb,orgAddress,targetAddress); + orgAddress.rute = calculateExtendedDaoRoute(eb,orgAddress,targetAddress); + orgAddress.rute = ruteHelper.getInstance(orgAddress.rute); + if (orgAddress.rute != null) { orgAddress.koreliste = targetAddress.koreliste; covered = true; @@ -312,7 +343,9 @@ } if (targetAddress.distributor.equals("BK")) { - orgAddress.koreliste = calculateExtendedBkKoreliste(eb,orgAddress,targetAddress); + orgAddress.koreliste = calculateExtendedBkKoreliste(eb,orgAddress,targetAddress); + orgAddress.koreliste = korelisteHelper.getInstance(orgAddress.koreliste); + if (orgAddress.koreliste != null) { orgAddress.rute = targetAddress.rute; covered = true; @@ -339,7 +372,7 @@ System.out.println("Build, stage3 elapsed: " + (start4-start3) ); System.out.println("Build -- stage 4 - 100pct"); - Map hundredePct = DatabaseLayer.get100PctList(); + Map hundredePct = DatabaseLayer.get100PctList(); for (Address addr : alleAdresser) { if (addr.daekningsType != DaekningsType.DAEKNING_IKKEDAEKKET) { continue; @@ -410,6 +443,9 @@ private String calculateExtendedDaoRoute(ExtendedBean eb, Address orgAddress, Address targetAddress) { + if (targetAddress.rute == null) { //hvis targetAdress.rute er null så er adressen ikke dækket alligevel + return null; + } // /////////////////////////////////////////////////////////////////// switch( eb.transport) { @@ -483,6 +519,8 @@ aliasSet.add(vejnavn.replace("alle", "allé") ); aliasSet.add(vejnavn.replace("allé", "alle") ); + + // forkortelser aliasSet.add(vejnavn.replace("dronningens", "dr") ); aliasSet.add(vejnavn.replace("dr.", "dronningens") ); aliasSet.add(vejnavn.replace("dr ", "dronningens") ); @@ -517,19 +555,34 @@ aliasSet.add(vejnavn.replace("nordre", "ndr") ); aliasSet.add(vejnavn.replace("ndr", "nordre") ); + + aliasSet.add(vejnavn.replace("borgmester", "borgm") ); + aliasSet.add(vejnavn.replace("borgm", "borgmester") ); + aliasSet.add(vejnavn.replace("sankt", "skt") ); aliasSet.add(vejnavn.replace("sankt", "sct") ); aliasSet.add(vejnavn.replace("skt", "sankt") ); aliasSet.add(vejnavn.replace("skt", "sct") ); - aliasSet.add(vejnavn.replace("sct", "skt") ); + aliasSet.add(vejnavn.replace("sct", "skt") ); + // fornavn forkortelser aliasSet.add(vejnavn.replace("john", "j") ); aliasSet.add(vejnavn.replace("thomas", "th") ); aliasSet.add(vejnavn.replace("thorvald", "th") ); + + + aliasSet.add(vejnavn.replace("christian", "chr") ); + aliasSet.add(vejnavn.replace("kristian", "kr") ); + + + // alternative stavninger + aliasSet.add(vejnavn.replace("peder", "peter") ); + aliasSet.add(vejnavn.replace("peter", "peder") ); + // Romertal @@ -600,7 +653,7 @@ //danske tegn 2 aliasSet.add( vVejnavn.replace("æ", "ae").replace("ø", "oe") ); aliasSet.add( vVejnavn.replace("æ", "ae").replace("å", "aa") ); - aliasSet.add( vVejnavn.replace("ø", "ae").replace("å", "aa") ); + aliasSet.add( vVejnavn.replace("ø", "oe").replace("å", "aa") ); aliasSet.add( vVejnavn.replace("ae", "æ").replace("oe","ø") ); aliasSet.add( vVejnavn.replace("ae", "æ").replace("aa","å") ); aliasSet.add( vVejnavn.replace("oe", "ø").replace("aa", "å") ); @@ -613,5 +666,35 @@ return aliasSet; } + public Set getPostnumre() { + return new TreeSet( searchPostnrVejnavnGadeid.keySet() ); + } + + public Set> getVejnavne(short postnr) { + Map map = searchPostnrVejnavnGadeid.get(postnr); + TreeMap newMap = new TreeMap(); + for (Entry entry : map.entrySet() ) { + newMap.put(entry.getKey(), entry.getValue()); + } + + return newMap.entrySet(); + } + public Set getHusnumre(int gadeid) { + + Map gade = searchGadeidentAdresser.get(gadeid); + + Set set = new TreeSet( new NaturalOrderComparator() ); + set.addAll( gade.keySet() ); + + return set; + } + + public Address getAdresse(int gadeid, String husnr) { + + Map gade = searchGadeidentAdresser.get(gadeid); + return gade.get(husnr); + + } + }