/[projects]/dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/fileupload/AddressTask.java
ViewVC logotype

Diff of /dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/fileupload/AddressTask.java

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

dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/AddressTask.java revision 2896 by torben, Mon Feb 1 08:32:44 2016 UTC dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/fileupload/AddressTask.java revision 2954 by torben, Tue Feb 16 13:15:25 2016 UTC
# Line 1  Line 1 
1  package dk.daoas.adressevedligehold;  package dk.daoas.adressevedligehold.fileupload;
2    
3  import org.apache.commons.lang3.exception.ExceptionUtils;  import org.apache.commons.lang3.exception.ExceptionUtils;
4    
5    import dk.daoas.adressevedligehold.MailSender;
6    import dk.daoas.adressevedligehold.ReloadHelper;
7    import dk.daoas.adressevedligehold.afstandandenrute.AfstandAndenRuteTask;
8  import dk.daoas.adressevedligehold.tasks.Task;  import dk.daoas.adressevedligehold.tasks.Task;
9    import dk.daoas.adressevedligehold.tasks.TaskLogger;
10  import dk.daoas.adressevedligehold.util.TimingHelper;  import dk.daoas.adressevedligehold.util.TimingHelper;
11    
12  /*  /*
  * TODO: trigger indlæsning  
13   *     *  
14   */   */
15    
16  public class AddressTask extends Task {  public class AddressTask extends Task {
17                    
18            private TaskLogger logger = TaskLogger.getInstance();
19            
20          AddressSource source;          AddressSource source;
21          boolean writeBack;          boolean writeBack;
22                    
# Line 29  public class AddressTask extends Task { Line 34  public class AddressTask extends Task {
34                  try {                  try {
35                          TimingHelper timer = new TimingHelper();                          TimingHelper timer = new TimingHelper();
36                                                    
37                          System.out.println("Validating Source");                          logger.info("Validating Source");
38                          source.validate();                          source.validate();
39                                                    
40                          System.out.println("Reading data from DB");                          logger.info("Reading data from DB");
41                          AddressManager addrManager = new AddressManager();                          AddressManager addrManager = new AddressManager();
42                                                    
43                          System.out.println("Data is ready");                          logger.info("Data is ready");
44                                                    
45                          EntryUgedage ugedage = new EntryUgedage(); //saml op på hvilke ugedage der er blevet behandlet                          EntryUgedage ugedage = new EntryUgedage(); //saml op på hvilke ugedage der er blevet behandlet
46                                                    
# Line 63  public class AddressTask extends Task { Line 68  public class AddressTask extends Task {
68                                  addrManager.dumpChanged();                                        addrManager.dumpChanged();      
69                          }                          }
70                                                    
71                          AddressReport report = new AddressReport(addrManager, entryCount, ugedage, source, timer, writeBack);                          AddressReport report = new AddressReport(addrManager, entryCount, ugedage, source, timer, writeBack, addrManager.getDuplicateCount() );
72                          report.sendRapport();                          report.sendRapport();
73                                                    
                         ReloadHelper.triggerReload( "Indlaesning/" + source.getDistributor() );  
74                                                    
75                            if (writeBack) {
76                                    ReloadHelper.triggerReload( "Indlaesning/" + source.getDistributor() );
77                                    
78                                    
79                                    if (source.calculateDistances()) {
80                                            Task tsk = new AfstandAndenRuteTask(source.getDistributor(), AfstandAndenRuteTask.INCREMENTAL);
81                                            manager.submitTask( tsk );
82                                    }                              
83                            }
84                                                    
85    
86                                                    
87                  } catch(Exception e) {                  } catch(Exception e) {
88                                                    
# Line 77  public class AddressTask extends Task { Line 91  public class AddressTask extends Task {
91                          body += "<br><br>";                          body += "<br><br>";
92                          body += "Exception:<br>";                          body += "Exception:<br>";
93                          body += ExceptionUtils.getStackTrace(e);                          body += ExceptionUtils.getStackTrace(e);
94                          AddressReport.sendMail(subject, body);                          MailSender.sendMail(subject, body);
95                                                    
96                          throw e; //rethrow exception                          throw e; //rethrow exception
97                  } finally  {                  } finally  {
98                                                    
99                          try {                          try {
100                                  System.out.println("Cleaning up resources");                                  logger.info("Cleaning up resources");
101                                  source.close();                                  source.close();
102                          } catch (Exception e) {                          } catch (Exception e) {
103                                  System.out.println("Error during cleanup: " + e.getMessage() );                                  logger.warning("Error during cleanup: ", e );
104                          }                                                }                      
105                  }                  }
106    
Legend:
Removed from v.2896  
changed lines
  Added in v.2954
  ViewVC Help
Powered by ViewVC 1.1.20