--- dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/LookupWorker.java 2014/09/11 08:14:40 2200 +++ dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/LookupWorker.java 2014/10/08 08:44:56 2231 @@ -1,12 +1,18 @@ package dk.daoas.fulddaekning; import java.sql.SQLException; -import java.util.ArrayList; import java.util.Queue; import java.util.logging.Level; import java.util.logging.Logger; public class LookupWorker implements Runnable { + class LookupResult { + double bedsteAfstand = 9999999.999; + Adresse bedsteAdr = null; + } + + Constants consts; + Logger logger = Logger.getLogger( LookupWorker.class.getName() ); int workerId; @@ -15,13 +21,15 @@ public LookupWorker(int workerId, Lookup lookup) { this.workerId = workerId; this.lookup = lookup; + + consts = Constants.getInstance(); } @Override public void run() { Constants consts = Constants.getInstance(); - ArrayList daekkede = lookup.getDaekkedeAdresser(); + Adresse daekkede[] = lookup.getDaekkedeAdresser(); Queue queue = lookup.getQueue(); Database db = lookup.getDb(); @@ -32,28 +40,25 @@ while ( (qAdresse = queue.poll()) != null) { //logger.info("Worker " + workerId + ", analyzing " + qAdresse); - double bedsteAfstand = 9999999.999; - Adresse bedsteAdr = null; - for (int i=0; i" + bedsteAdr + " ::: " + bedsteAfstand ); + logger.info("(" +workerId + ") Bedste: " + qAdresse + "==>" + result.bedsteAdr + " ::: " + result.bedsteAfstand ); } try { - db.gemResultat(qAdresse, bedsteAdr, bedsteAfstand); + db.gemResultat(qAdresse, result.bedsteAdr, result.bedsteAfstand); } catch (SQLException e) { logger.log(Level.WARNING, "Error saving result", e); logger.warning("Shutting down"); @@ -61,7 +66,7 @@ System.exit(0); //hvis at indsættelsen fejler skal vi afbryde med det samme } } else { - logger.info("(" +workerId + ") For stor afstand " + qAdresse + " -> " + bedsteAfstand); + logger.info("(" +workerId + ") For stor afstand " + qAdresse + " -> " + result.bedsteAfstand); } } else { logger.warning("(" +workerId + ") Ingen match til " + qAdresse); @@ -72,5 +77,29 @@ lookup.shutdownWorker( workerId); } + + LookupResult findBedsteAdresse(Adresse qAdresse, Adresse daekkede[]) { + LookupResult result = new LookupResult(); + + for (int i=0; i" + daekket); //Skal udkommenteres senere når HO check er valideret + continue; + } + } + + double afstand = Adresse.beregnAfstand(qAdresse, daekket); + + if (afstand < result.bedsteAfstand) { + result.bedsteAfstand = afstand; + result.bedsteAdr = daekket; + } + } + return result; + + } }