--- dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/Lookup.java 2014/12/10 08:26:12 2240 +++ dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/Lookup.java 2014/12/10 09:50:33 2241 @@ -1,30 +1,18 @@ package dk.daoas.fulddaekning; -import java.io.File; -import java.io.FileReader; -import java.util.List; import java.util.Map; import java.util.Queue; import java.util.concurrent.ConcurrentHashMap; -import java.util.logging.FileHandler; import java.util.logging.Level; import java.util.logging.Logger; -import java.util.logging.SimpleFormatter; import dk.daoas.fulddaekning.BoundingBox.BoundingBoxException; public class Lookup { - static final String CONFIG_FILENAME = "fulddaekning.properties"; - - static int max_workers; - static boolean verbose; - static boolean rename_tables; - static String distributor; - static SafeProperties conf; - static Logger logger = Logger.getLogger( Lookup.class.toString() ); + final static Logger logger = Logger.getLogger( Lookup.class.toString() ); String postnr; Database db; @@ -35,50 +23,15 @@ Map workers = new ConcurrentHashMap(); - static Statistik flestDaekkede = new Statistik(); - static Statistik flestIkkeDaekkede = new Statistik(); - static Statistik mestBrugteTid = new Statistik(); - static Statistik stoersteDataset = new Statistik(); - - static Adresse[] alleDaekkedeAdresser; - - - static class Statistik { - String postnr; - int antalDaekkede = 0; - int antalIkkeDaekkede = 0; - int totalDataset = 0; - long forbrugtTid = 0; - @Override - public String toString() { - return "postnr=" + postnr + " antalIkkeDaekkede=" + antalIkkeDaekkede + " antalDaekkede=" + antalDaekkede + " forbrugtTid=" + forbrugtTid + " totalDataset=" + totalDataset; - } - } - public Lookup(String postnr, Database db) { this.postnr = postnr; this.db = db; } - public static void saveStatistics(Statistik stat) { - if (stat.antalDaekkede > flestDaekkede.antalDaekkede) { - flestDaekkede = stat; - } - if (stat.antalIkkeDaekkede > flestIkkeDaekkede.antalIkkeDaekkede) { - flestIkkeDaekkede = stat; - } - - if (stat.totalDataset > mestBrugteTid.totalDataset) { - stoersteDataset = stat; - } - - if (stat.forbrugtTid > mestBrugteTid.forbrugtTid) { - mestBrugteTid = stat; - } - } + public void doLookup() throws BoundingBoxException { logger.info("Starting for postnr=" + postnr); @@ -116,7 +69,7 @@ logger.info("Starter beregning for " + postnr); start2 = System.currentTimeMillis(); - for (int i =0; i postnumre = db.hentPostnumre(); - - // Først validerer vi BBox på alle postnummre, for at undgå fuldt stop midt i beregningen - for(String 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(String postnr : postnumre) { - Lookup lookup = new Lookup(postnr, db); - lookup.doLookup(); - } - - if (rename_tables) { - db.renameResultTables(); - } else { - logger.info( "Rename tables is disabled !!!" ); - } - - - - } else { - /// Test - db.resetResultTable(); - - if (consts.doExtendedLookup()) { - alleDaekkedeAdresser = db.hentAlleDaekkedeAdresser(); - logger.info( "AlleDaekkedeAdresser.length=" + alleDaekkedeAdresser.length); - } - - Lookup lookup = new Lookup("458x", 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("Fuld load done : " + formatMilliSeconds(elapsed) ); - } - - - static String formatMilliSeconds(long milliseconds) { - int mseconds = (int) milliseconds % 1000; - int seconds = (int) (milliseconds / 1000) % 60 ; - int minutes = (int) ((milliseconds / (1000*60)) % 60); - int hours = (int) ((milliseconds / (1000*60*60)) % 24); - - return String.format("%02d:%02d:%02d.%03d", hours, minutes, seconds, mseconds); - } - }