/[projects]/dao/FuldDaekningWorker/src/main/java/dk/daoas/fulddaekning/LookupMain.java
ViewVC logotype

Diff of /dao/FuldDaekningWorker/src/main/java/dk/daoas/fulddaekning/LookupMain.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 2587 by torben, Sun Jun 14 14:54:10 2015 UTC revision 2709 by torben, Sun Sep 27 18:22:02 2015 UTC
# Line 1  Line 1 
1  package dk.daoas.fulddaekning;  package dk.daoas.fulddaekning;
2    
 import geocode.GeoPoint;  
 import geocode.kdtree.KDTree;  
   
3  import java.io.File;  import java.io.File;
4  import java.io.FileReader;  import java.io.FileReader;
5  import java.sql.SQLException;  import java.sql.SQLException;
6    import java.util.Collection;
7    import java.util.HashMap;
8  import java.util.List;  import java.util.List;
9    import java.util.Map;
10  import java.util.Set;  import java.util.Set;
11  import java.util.logging.FileHandler;  import java.util.logging.FileHandler;
12  import java.util.logging.Level;  import java.util.logging.Level;
13  import java.util.logging.Logger;  import java.util.logging.Logger;
14  import java.util.logging.SimpleFormatter;  import java.util.logging.SimpleFormatter;
15    
16    import com.jwetherell.algorithms.data_structures.KdTree;
17    
18    import dk.daoas.fulddaekning.osrm.OSRMHelper;
19    
20  public class LookupMain {  public class LookupMain {
21                    
22           static class LookupResult {           static class LookupResult {
# Line 35  public class LookupMain { Line 39  public class LookupMain {
39                    
40                    
41                    
42          private static List<GeoPoint> alleDaekkedeAdresser;          static final int MAX_RESULTS = 100;
43            
44            static OSRMHelper osrmHelper = new OSRMHelper();
45    
46                    
47                    
# Line 76  public class LookupMain { Line 82  public class LookupMain {
82                                    
83                  Database db = new Database(conf);                  Database db = new Database(conf);
84                  Adresse ikkeDaekkede[] = db.hentAlleIkkedaekkedeAdresser(consts.getMinPostnr(), consts.getMaxPostnr() );                  Adresse ikkeDaekkede[] = db.hentAlleIkkedaekkedeAdresser(consts.getMinPostnr(), consts.getMaxPostnr() );
85                    logger.info("Antal ikke-daekkede: " + ikkeDaekkede.length);
86                                    
87                  boolean testRun= false;                  boolean testRun= false;
88                                    
89                  int antalFundne = 0;                  int antalFundne = 0;
90                                    
91                                    long beregnStart =0;
92                  long start = System.currentTimeMillis();                  long start = System.currentTimeMillis();
93                    int antalDaekkedeAdresser = -1;
94                                    
95                  if (testRun == false) {                  if (testRun == false) {
96                                    
# Line 99  public class LookupMain { Line 106  public class LookupMain {
106                                                    
107    
108                          logger.info("Henter alle daekkede adresser");                          logger.info("Henter alle daekkede adresser");
109                          alleDaekkedeAdresser = db.hentAlleDaekkedeAdresser();                          antalDaekkedeAdresser = db.hentAlleDaekkedeAdresser();
110                          logger.info( "AlleDaekkedeAdresser.length=" + alleDaekkedeAdresser.size());                          logger.info( "AlleDaekkedeAdresser.length=" + antalDaekkedeAdresser );
111                            
112                            Map<Short, List<Adresse>> addrHoList = db.getDaekkedeAdresserHO();
113                            
114                            Map<Short, KdTree<Adresse>> hoTrees = new HashMap<Short,KdTree<Adresse>>();
115                                                    
116                          KDTree<GeoPoint> addressTree = new KDTree<GeoPoint>(alleDaekkedeAdresser);                          for ( Map.Entry<Short, List<Adresse>> entry : addrHoList.entrySet() ) {
117                                    short ho = entry.getKey();
118                                    List<Adresse> geopoints = entry.getValue();
119                                    
120                                    logger.info("Opbygger KDTree for " + ho + " - antal=" + geopoints.size() );
121                                    
122                                    @SuppressWarnings("unchecked")
123                                    List<KdTree.XYZPoint> tmpPoints = (List<KdTree.XYZPoint>)(List<?>) geopoints;
124                                    
125                                    KdTree<Adresse> addressTree = new KdTree<Adresse>( tmpPoints );
126                                    hoTrees.put(ho, addressTree);                          
127                            }
128                                                    
129                          db.resetResultTable();                          db.resetResultTable();
130                                    
131                            beregnStart = System.currentTimeMillis();
132                          logger.info("Starter beregning");                          logger.info("Starter beregning");
133                                    
134                          final int workerId = -1;                          final int workerId = -1;
# Line 113  public class LookupMain { Line 136  public class LookupMain {
136                                                    
137                          for (Adresse qAdresse : ikkeDaekkede) {                          for (Adresse qAdresse : ikkeDaekkede) {
138                                                                    
139                                    short ho = qAdresse.ho;
140                                    KdTree<Adresse> addressTree = hoTrees.get(ho);
141                                                                    
142                                  LookupResult result = new LookupResult();                                  LookupResult result = new LookupResult();
143                                  result.bedsteAdr = (Adresse) addressTree.findNearest(qAdresse);                                  Collection<Adresse> res = addressTree.nearestNeighbourSearch(MAX_RESULTS, qAdresse);
144                                    if (res.size() > MAX_RESULTS ) {
145                                            System.out.println("Returnerede mere end MAX_RESULTS> " + res.size() );
146                                            System.exit(0);
147                                    }
148                                    
149                                    
150                                    result.bedsteAdr = osrmHelper.getNearestViaTable(qAdresse, res);
151                                    System.out.println("Bedste:" + result.bedsteAdr );
152    
153                                  result.bedsteAfstand = GeoPointHelper.beregnAfstand(qAdresse, result.bedsteAdr);                                  result.bedsteAfstand = GeoPointHelper.beregnAfstand(qAdresse, result.bedsteAdr);
154                                                    
155                                                    
                           
156                                  if (result.bedsteAfstand <= consts.getMaxDistance() ) { //Gem kun hvis distancen er under max_distance for distributøren                                  if (result.bedsteAfstand <= consts.getMaxDistance() ) { //Gem kun hvis distancen er under max_distance for distributøren
157                                          if (LookupMain.verbose == true) {                                          if (verbose == true) {
158                                                  logger.fine("(" +workerId + ") Bedste: " + qAdresse + "==>" + result.bedsteAdr + " ::: " + result.bedsteAfstand );                                                  logger.fine("(" +workerId + ") Bedste: " + qAdresse + "==>" + result.bedsteAdr + " ::: " + result.bedsteAfstand );
159                                          }                                          }
160                                                                                    
# Line 136  public class LookupMain { Line 169  public class LookupMain {
169                                                  System.exit(0); //hvis at indsættelsen fejler skal vi afbryde med det samme                                                  System.exit(0); //hvis at indsættelsen fejler skal vi afbryde med det samme
170                                          }                                          }
171                                  } else {                                  } else {
172                                          if (LookupMain.verbose == true) {                                          if (verbose == true) {
173                                                  System.out.println("For stor afstand: " + qAdresse + " > " + result.bedsteAfstand);                                                  System.out.println("For stor afstand: " + qAdresse + " > " + result.bedsteAfstand);
174                                          }                                          }
175                                  }                                  }
# Line 170  public class LookupMain { Line 203  public class LookupMain {
203                                    
204                  long now = System.currentTimeMillis();                  long now = System.currentTimeMillis();
205                  long elapsed = now - start ;                  long elapsed = now - start ;
206                    long elapsedBeregn = now - beregnStart;
207                                    
208    
209                  logger.info("Fuld load done : " + formatMilliSeconds(elapsed) );                  logger.info("Fuld load done : " + formatMilliSeconds(elapsed) );
210                  logger.info("Antal daekkede : " + alleDaekkedeAdresser.size() );                  logger.info("Fuld load done (beregning) : " + formatMilliSeconds(elapsedBeregn) );
211                    logger.info("Antal daekkede : " + antalDaekkedeAdresser );
212                  logger.info("Antal ikke-daekkede : " + ikkeDaekkede.length );                  logger.info("Antal ikke-daekkede : " + ikkeDaekkede.length );
213                  logger.info("Heraf, antal fundne : " + antalFundne );                  logger.info("Heraf, antal fundne : " + antalFundne );
214                  logger.info("Fandt adresser til : " + (antalFundne*100.0)/ikkeDaekkede.length + "%" );                  
215                    logger.info( String.format("Fandt adresser til : %.2f %%", (antalFundne*100.0)/ikkeDaekkede.length ) );
216                    //logger.info("Fandt adresser til : " + (antalFundne*100.0)/ikkeDaekkede.length + "%" );
217          }          }
218    
219                    
Legend:
Removed from v.2587  
changed lines
  Added in v.2709
  ViewVC Help
Powered by ViewVC 1.1.20