/[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 2840 by torben, Mon Jan 25 10:25:22 2016 UTC dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/fileupload/AddressTask.java revision 2947 by torben, Sat Feb 13 15:45:02 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;
4    
5    import dk.daoas.adressevedligehold.ReloadHelper;
6  import dk.daoas.adressevedligehold.tasks.Task;  import dk.daoas.adressevedligehold.tasks.Task;
7    import dk.daoas.adressevedligehold.tasks.TaskLogger;
8  import dk.daoas.adressevedligehold.util.TimingHelper;  import dk.daoas.adressevedligehold.util.TimingHelper;
9    
10  /*  /*
# Line 10  import dk.daoas.adressevedligehold.util. Line 14  import dk.daoas.adressevedligehold.util.
14    
15  public class AddressTask extends Task {  public class AddressTask extends Task {
16                    
17            private TaskLogger logger = TaskLogger.getInstance();
18            
19          AddressSource source;          AddressSource source;
20          boolean writeBack;          boolean writeBack;
21                    
# Line 18  public class AddressTask extends Task { Line 24  public class AddressTask extends Task {
24                  this.source = source;                  this.source = source;
25                  this.writeBack = writeBack;                  this.writeBack = writeBack;
26          }          }
27            
28            
29    
30          @Override          @Override
31          protected void taskRun() {          protected void taskRun() throws Exception {
32                                    
33                  try {                  try {
34                          TimingHelper timer = new TimingHelper();                          TimingHelper timer = new TimingHelper();
35                          System.out.println("Reading data from DB");                          
36                            logger.info("Validating Source");
37                            source.validate();
38                            
39                            logger.info("Reading data from DB");
40                          AddressManager addrManager = new AddressManager();                          AddressManager addrManager = new AddressManager();
41                                                    
42                          System.out.println("Data is ready");                          logger.info("Data is ready");
43                                                    
44                          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
45                                                    
# Line 55  public class AddressTask extends Task { Line 67  public class AddressTask extends Task {
67                                  addrManager.dumpChanged();                                        addrManager.dumpChanged();      
68                          }                          }
69                                                    
70                          AddressReport report = new AddressReport(addrManager, entryCount, ugedage, source, timer, writeBack);                          AddressReport report = new AddressReport(addrManager, entryCount, ugedage, source, timer, writeBack, addrManager.getDuplicateCount() );
71                          report.sendRapport();                          report.sendRapport();
72                                                    
73                                                    
74                            if (writeBack) {
75                                    ReloadHelper.triggerReload( "Indlaesning/" + source.getDistributor() );
76                            }
77                            
78                            
79                                                    
80                  } catch (Exception e) {                  } catch(Exception e) {
81                          e.printStackTrace();                          
82                  }                          String subject = "Error loading data for " + source.getDistributor();
83                                            String body = "File: " + source.getFilename();
84                                            body += "<br><br>";
85                  try {                          body += "Exception:<br>";
86                          System.out.println("Cleaning up resources");                          body += ExceptionUtils.getStackTrace(e);
87                          source.close();                          AddressReport.sendMail(subject, body);
88                  } catch (Exception e) {                          
89                          System.out.println("Error during cleanup: " + e.getMessage() );                          throw e; //rethrow exception
90                    } finally  {
91                            
92                            try {
93                                    logger.info("Cleaning up resources");
94                                    source.close();
95                            } catch (Exception e) {
96                                    logger.warning("Error during cleanup: ", e );
97                            }                      
98                  }                  }
99    
100          }          }
101    
102          @Override          @Override
# Line 79  public class AddressTask extends Task { Line 105  public class AddressTask extends Task {
105          }          }
106    
107          @Override          @Override
108          public short getPercentCompleted() {          public double getPercentCompleted() {
109                  return 0;                  return -1;
110          }          }
111    
112          @Override          @Override
Legend:
Removed from v.2840  
changed lines
  Added in v.2947
  ViewVC Help
Powered by ViewVC 1.1.20