--- dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/AddressTask.java 2016/01/25 21:43:59 2844 +++ dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/fileupload/AddressTask.java 2016/02/13 15:45:02 2947 @@ -1,6 +1,10 @@ -package dk.daoas.adressevedligehold; +package dk.daoas.adressevedligehold.fileupload; +import org.apache.commons.lang3.exception.ExceptionUtils; + +import dk.daoas.adressevedligehold.ReloadHelper; import dk.daoas.adressevedligehold.tasks.Task; +import dk.daoas.adressevedligehold.tasks.TaskLogger; import dk.daoas.adressevedligehold.util.TimingHelper; /* @@ -10,6 +14,8 @@ public class AddressTask extends Task { + private TaskLogger logger = TaskLogger.getInstance(); + AddressSource source; boolean writeBack; @@ -27,13 +33,13 @@ try { TimingHelper timer = new TimingHelper(); - System.out.println("Validating Source"); + logger.info("Validating Source"); source.validate(); - System.out.println("Reading data from DB"); + logger.info("Reading data from DB"); AddressManager addrManager = new AddressManager(); - System.out.println("Data is ready"); + logger.info("Data is ready"); EntryUgedage ugedage = new EntryUgedage(); //saml op på hvilke ugedage der er blevet behandlet @@ -61,18 +67,33 @@ addrManager.dumpChanged(); } - AddressReport report = new AddressReport(addrManager, entryCount, ugedage, source, timer, writeBack); + AddressReport report = new AddressReport(addrManager, entryCount, ugedage, source, timer, writeBack, addrManager.getDuplicateCount() ); report.sendRapport(); + if (writeBack) { + ReloadHelper.triggerReload( "Indlaesning/" + source.getDistributor() ); + } + + + + } catch(Exception e) { + + String subject = "Error loading data for " + source.getDistributor(); + String body = "File: " + source.getFilename(); + body += "

"; + body += "Exception:
"; + body += ExceptionUtils.getStackTrace(e); + AddressReport.sendMail(subject, body); + throw e; //rethrow exception } finally { try { - System.out.println("Cleaning up resources"); + logger.info("Cleaning up resources"); source.close(); } catch (Exception e) { - System.out.println("Error during cleanup: " + e.getMessage() ); + logger.warning("Error during cleanup: ", e ); } } @@ -84,8 +105,8 @@ } @Override - public short getPercentCompleted() { - return 0; + public double getPercentCompleted() { + return -1; } @Override