/[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 2890 by torben, Sun Jan 31 21:56:30 2016 UTC revision 2903 by torben, Wed Feb 3 18:45:33 2016 UTC
# Line 11  import java.util.concurrent.Executors; Line 11  import java.util.concurrent.Executors;
11  import java.util.concurrent.ThreadFactory;  import java.util.concurrent.ThreadFactory;
12  import java.util.concurrent.ThreadPoolExecutor;  import java.util.concurrent.ThreadPoolExecutor;
13  import java.util.concurrent.atomic.AtomicInteger;  import java.util.concurrent.atomic.AtomicInteger;
 import java.util.logging.FileHandler;  
 import java.util.logging.Logger;  
 import java.util.logging.SimpleFormatter;  
14    
15  import ags.utils.dataStructures.trees.thirdGenKD.KdTree;  import ags.utils.dataStructures.trees.thirdGenKD.KdTree;
16    import dk.daoas.adressevedligehold.ReloadHelper;
17  import dk.daoas.adressevedligehold.ServiceConfig;  import dk.daoas.adressevedligehold.ServiceConfig;
18  import dk.daoas.adressevedligehold.beans.Address;  import dk.daoas.adressevedligehold.beans.Address;
19  import dk.daoas.adressevedligehold.db.DBConnection;  import dk.daoas.adressevedligehold.db.DBConnection;
20  import dk.daoas.adressevedligehold.tasks.Task;  import dk.daoas.adressevedligehold.tasks.Task;
21  import dk.daoas.adressevedligehold.util.HttpUtil;  import dk.daoas.adressevedligehold.tasks.TaskLogger;
22    
23    
24    
25  public class AfstandAndenRuteTask extends Task {  public class AfstandAndenRuteTask extends Task {
26    
27          final Logger logger = Logger.getLogger( AfstandAndenRuteTask.class.toString() );          private TaskLogger logger = TaskLogger.getInstance();
28    
29          final boolean verbose = false;//          final boolean verbose = false;//
30    
# Line 35  public class AfstandAndenRuteTask extend Line 33  public class AfstandAndenRuteTask extend
33    
34    
35          String distributor;          String distributor;
36            int antalIkkeDaekkede = -1;
37            
38            AtomicInteger antalBeregnet = new AtomicInteger();
39    
40    
41    
# Line 54  public class AfstandAndenRuteTask extend Line 55  public class AfstandAndenRuteTask extend
55    
56    
57                  //Setup j.u.l Logger                  //Setup j.u.l Logger
58                  Logger root = Logger.getLogger("");                  //Logger root = Logger.getLogger("");
59                  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
60                  fhandler.setFormatter( new SimpleFormatter() );                  //fhandler.setFormatter( new SimpleFormatter() );
61                  root.addHandler( fhandler );                  //root.addHandler( fhandler );
62    
63    
64    
# Line 79  public class AfstandAndenRuteTask extend Line 80  public class AfstandAndenRuteTask extend
80                  logger.info("Starting with MAX_WORKERS:" + max_workers);                          logger.info("Starting with MAX_WORKERS:" + max_workers);        
81                  setupThreadPool(max_workers);                  setupThreadPool(max_workers);
82    
83                  int antalIkkeDaekkede = -1;  
84    
85                  try (Connection conn = DBConnection.getConnection() ) {                  try (Connection conn = DBConnection.getConnection() ) {
86                          Database db = new Database(conn);                          Database db = new Database(conn);
# Line 144  public class AfstandAndenRuteTask extend Line 145  public class AfstandAndenRuteTask extend
145                                  CyclicBarrier barrier = new CyclicBarrier(max_workers + 1);                                  CyclicBarrier barrier = new CyclicBarrier(max_workers + 1);
146    
147                                  for (int i=0; i<max_workers; i++) {                                  for (int i=0; i<max_workers; i++) {
148                                          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);
149                                          threadPool.submit( worker );                                          threadPool.submit( worker );
150                                  }                                  }
151    
# Line 159  public class AfstandAndenRuteTask extend Line 160  public class AfstandAndenRuteTask extend
160    
161                                  if (test_mode == false && this.isAborted() == false) {                                  if (test_mode == false && this.isAborted() == false) {
162                                          db.renameResultTables();                                          db.renameResultTables();
163                                            
164                                            ReloadHelper.triggerReload( "AfstandAndenRute/" + distributor );
165    
                                         String trigger_url = ServiceConfig.getInstance().trigger_url;  
   
                                         logger.info("Calling trigger URL");  
                                         String url = trigger_url + "&trigger=AfstandAndenRute/" + distributor;  
   
                                         HttpUtil.getContentString(url, 500);  
166    
167                                  } else {                                  } else {
168                                          logger.info( "Rename tables is disabled !!!" );                                          logger.info( "Rename tables is disabled !!!" );
# Line 236  public class AfstandAndenRuteTask extend Line 233  public class AfstandAndenRuteTask extend
233    
234          @Override          @Override
235          public String getDescription() {          public String getDescription() {
236                  return "Afstand anden rute";                  return "Afstand anden rute/" + distributor;
237          }          }
238    
239    
# Line 244  public class AfstandAndenRuteTask extend Line 241  public class AfstandAndenRuteTask extend
241          @Override          @Override
242          public String getDetail() {          public String getDetail() {
243                  // TODO Auto-generated method stub                  // TODO Auto-generated method stub
244                  return null;                  return "";
245          }          }
246    
247    
248    
249          @Override          @Override
250          public short getPercentCompleted() {          public double getPercentCompleted() {
251                  // TODO Auto-generated method stub                  return (antalBeregnet.get() / ((float)antalIkkeDaekkede)) * 100.0;
                 return 0;  
252          }          }
253  }  }
Legend:
Removed from v.2890  
changed lines
  Added in v.2903
  ViewVC Help
Powered by ViewVC 1.1.20