--- dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/Lookup.java 2014/09/22 07:39:46 2227 +++ dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/Lookup.java 2014/10/08 09:16:18 2234 @@ -40,6 +40,8 @@ static Statistik mestBrugteTid = new Statistik(); static Statistik stoersteDataset = new Statistik(); + static Adresse[] alleDaekkedeAdresser; + static class Statistik { int postnr; @@ -87,6 +89,14 @@ long start2 = 0; try { + + logger.info("Henter _ikke_ daekkede adresser i " + postnr); + queue = db.hentIkkedaekkedeAdresser(postnr); + if (queue.size() == 0) { + logger.info("Fandt ikke nogen _ikke_ daekkede adresser i " + postnr); + return; + } + BoundingBox bbox = db.getBoundingbox(postnr); bbox.validateBbox(); @@ -97,9 +107,6 @@ logger.info("Henter daekkede adresser i " + postnr); daekkedeAdresser = db.hentDaekkedeAdresser(bbox); - logger.info("Henter _ikke_ daekkede adresser i " + postnr); - queue = db.hentIkkedaekkedeAdresser(postnr); - stat.postnr = postnr; stat.antalDaekkede = daekkedeAdresser.length; stat.antalIkkeDaekkede = queue.size(); @@ -143,11 +150,11 @@ } public void shutdownWorker(int workerid) { - logger.info("Shutting down worker: " + workerid); + //logger.info("Shutting down worker: " + workerid); LookupWorker key = workers.remove(workerid); if (key == null) { - System.out.println("Error removing worker from set"); + System.out.println("Error removing worker from set " + workerid); System.exit(0); } } @@ -211,64 +218,80 @@ distributor = conf.getSafeProperty("DISTRIBUTOR"); distributor = distributor.toUpperCase(); + logger.info("Starting for DISTRIBUTOR:" + distributor); + Constants.init(distributor); - + Constants consts = Constants.getInstance(); Database db = new Database(conf); - + boolean testRun= false; long start = System.currentTimeMillis(); - logger.info("Finder postnumre"); - List postnumre = db.hentPostnumre(); - - // Først validerer vi BBox på alle postnummre, for at undgå fuldt stop midt i beregningen - for(Integer postnr : postnumre) { // - logger.info("Validerer BBox for " + postnr); - BoundingBox bbox = db.getBoundingbox(postnr); - bbox.validateBbox(); - } - + if (testRun == false) { - //pre-check er ok - reset tmp tabel og start søgningen - db.resetResultTable(); - - for(Integer postnr : postnumre) { - Lookup lookup = new Lookup(postnr, db); - lookup.doLookup(); - } - - if (rename_tables) { - db.renameResultTables(); + logger.info("Finder postnumre"); + List postnumre = db.hentPostnumre(); + + // Først validerer vi BBox på alle postnummre, for at undgå fuldt stop midt i beregningen + for(Integer postnr : postnumre) { // + logger.info("Validerer BBox for " + postnr); + BoundingBox bbox = db.getBoundingbox(postnr); + bbox.validateBbox(); + } + + if (consts.doExtendedLookup()) { + logger.info("Henter alle daekkede adresser"); + alleDaekkedeAdresser = db.hentAlleDaekkedeAdresser(); + logger.info( "AlleDaekkedeAdresser.length=" + alleDaekkedeAdresser.length); + } + + + //pre-check er ok - reset tmp tabel og start søgningen + db.resetResultTable(); + + for(Integer postnr : postnumre) { + Lookup lookup = new Lookup(postnr, db); + lookup.doLookup(); + } + + if (rename_tables) { + db.renameResultTables(); + } else { + logger.info( "Rename tables is disabled !!!" ); + } + + + } else { - logger.info( "Rename tables is disabled !!!" ); + /// Test + db.resetResultTable(); + + if (consts.doExtendedLookup()) { + alleDaekkedeAdresser = db.hentAlleDaekkedeAdresser(); + logger.info( "AlleDaekkedeAdresser.length=" + alleDaekkedeAdresser.length); + } + + Lookup lookup = new Lookup(4583, db); + lookup.doLookup(); } long now = System.currentTimeMillis(); long elapsed = now - start ; - + logger.info("Mest brugte tid: " + mestBrugteTid); logger.info("Flest Ikke-dækkede, " + flestIkkeDaekkede); logger.info("Flest Dækkede, " + flestDaekkede); - logger.info("Største Dataset, " + stoersteDataset); + logger.info("Største Dataset, " + stoersteDataset); logger.info("Fuld load done : " + formatMilliSeconds(elapsed) ); - - - /* - /// Test - db.resetResultTable(); - Lookup lookup = new Lookup(2750, db); - lookup.doLookup(); - long now = System.currentTimeMillis(); - long elapsed = now - start ; - logger.info("Fuld load done : " + formatMilliSeconds(elapsed) );*/ } + static String formatMilliSeconds(long milliseconds) { int mseconds = (int) milliseconds % 1000; int seconds = (int) (milliseconds / 1000) % 60 ;