/[projects]/dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/afstandandenrute/AfstandAndenRuteTask.java
ViewVC logotype

Diff of /dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/afstandandenrute/AfstandAndenRuteTask.java

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

revision 2878 by torben, Sat Jan 30 14:05:53 2016 UTC revision 2896 by torben, Mon Feb 1 08:32:44 2016 UTC
# Line 1  Line 1 
1  package dk.daoas.adressevedligehold.afstandandenrute;  package dk.daoas.adressevedligehold.afstandandenrute;
2    
 import java.io.File;  
 import java.io.FileReader;  
3  import java.sql.Connection;  import java.sql.Connection;
4  import java.util.HashMap;  import java.util.HashMap;
5  import java.util.List;  import java.util.List;
# Line 18  import java.util.logging.Logger; Line 16  import java.util.logging.Logger;
16  import java.util.logging.SimpleFormatter;  import java.util.logging.SimpleFormatter;
17    
18  import ags.utils.dataStructures.trees.thirdGenKD.KdTree;  import ags.utils.dataStructures.trees.thirdGenKD.KdTree;
19    import dk.daoas.adressevedligehold.ReloadHelper;
20  import dk.daoas.adressevedligehold.ServiceConfig;  import dk.daoas.adressevedligehold.ServiceConfig;
21  import dk.daoas.adressevedligehold.beans.Address;  import dk.daoas.adressevedligehold.beans.Address;
22  import dk.daoas.adressevedligehold.db.DBConnection;  import dk.daoas.adressevedligehold.db.DBConnection;
# Line 37  public class AfstandAndenRuteTask extend Line 36  public class AfstandAndenRuteTask extend
36    
37    
38          String distributor;          String distributor;
39            int antalIkkeDaekkede = -1;
40            
41            AtomicInteger antalBeregnet = new AtomicInteger();
42    
43    
44    
# Line 56  public class AfstandAndenRuteTask extend Line 58  public class AfstandAndenRuteTask extend
58    
59    
60                  //Setup j.u.l Logger                  //Setup j.u.l Logger
61                  Logger root = Logger.getLogger("");                  //Logger root = Logger.getLogger("");
62                  FileHandler fhandler = new FileHandler("fulddaekning.log"); // Ingen max størrelse, ingen rotation og ingen append                  //FileHandler fhandler = new FileHandler("fulddaekning.log"); // Ingen max størrelse, ingen rotation og ingen append
63                  fhandler.setFormatter( new SimpleFormatter() );                  //fhandler.setFormatter( new SimpleFormatter() );
64                  root.addHandler( fhandler );                  //root.addHandler( fhandler );
65    
66    
67    
# Line 81  public class AfstandAndenRuteTask extend Line 83  public class AfstandAndenRuteTask extend
83                  logger.info("Starting with MAX_WORKERS:" + max_workers);                          logger.info("Starting with MAX_WORKERS:" + max_workers);        
84                  setupThreadPool(max_workers);                  setupThreadPool(max_workers);
85    
86                  int antalIkkeDaekkede = -1;  
87    
88                  try (Connection conn = DBConnection.getConnection() ) {                  try (Connection conn = DBConnection.getConnection() ) {
89                          Database db = new Database(conn);                          Database db = new Database(conn);
# Line 146  public class AfstandAndenRuteTask extend Line 148  public class AfstandAndenRuteTask extend
148                                  CyclicBarrier barrier = new CyclicBarrier(max_workers + 1);                                  CyclicBarrier barrier = new CyclicBarrier(max_workers + 1);
149    
150                                  for (int i=0; i<max_workers; i++) {                                  for (int i=0; i<max_workers; i++) {
151                                          LookupWorker worker = new LookupWorker(i, this, barrier, ikkeDaekkede, hoTrees,antalFundne,db,verbose,consts);                                          LookupWorker worker = new LookupWorker(i, this, barrier, ikkeDaekkede, hoTrees,antalFundne,antalBeregnet,db,verbose,consts);
152                                          threadPool.submit( worker );                                          threadPool.submit( worker );
153                                  }                                  }
154    
# Line 161  public class AfstandAndenRuteTask extend Line 163  public class AfstandAndenRuteTask extend
163    
164                                  if (test_mode == false && this.isAborted() == false) {                                  if (test_mode == false && this.isAborted() == false) {
165                                          db.renameResultTables();                                          db.renameResultTables();
166                                            
167                                            ReloadHelper.triggerReload( "AfstandAndenRute/" + distributor );
168    
                                         String trigger_url = ServiceConfig.getInstance().trigger_url;  
   
                                         logger.info("Calling trigger URL");  
                                         String url = trigger_url + "&trigger=AfstandAndenRute/" + distributor;  
   
                                         HttpUtil.getContentString(url, 500);  
169    
170                                  } else {                                  } else {
171                                          logger.info( "Rename tables is disabled !!!" );                                          logger.info( "Rename tables is disabled !!!" );
# Line 238  public class AfstandAndenRuteTask extend Line 236  public class AfstandAndenRuteTask extend
236    
237          @Override          @Override
238          public String getDescription() {          public String getDescription() {
239                  return "Afstand anden rute";                  return "Afstand anden rute/" + distributor;
240          }          }
241    
242    
# Line 246  public class AfstandAndenRuteTask extend Line 244  public class AfstandAndenRuteTask extend
244          @Override          @Override
245          public String getDetail() {          public String getDetail() {
246                  // TODO Auto-generated method stub                  // TODO Auto-generated method stub
247                  return null;                  return "";
248          }          }
249    
250    
251    
252          @Override          @Override
253          public short getPercentCompleted() {          public double getPercentCompleted() {
254                  // TODO Auto-generated method stub                  return (antalBeregnet.get() / ((float)antalIkkeDaekkede)) * 100.0;
                 return 0;  
255          }          }
256  }  }
Legend:
Removed from v.2878  
changed lines
  Added in v.2896
  ViewVC Help
Powered by ViewVC 1.1.20