adressevedligehold/coveragefileupload/AddressTask.java

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;

/*
 * TODO: trigger afstand-anden-rute beregning
 *   
 */

public class AddressTask extends Task {
        
        private TaskLogger logger = TaskLogger.getInstance();
        
        AddressSource source;
        boolean writeBack;
        
        public AddressTask(AddressSource source, boolean writeBack) {
                
                this.source = source;
                this.writeBack = writeBack;
        }
        
        

        @Override
        protected void taskRun() throws Exception {
                
                try {
                        TimingHelper timer = new TimingHelper();
                        
                        logger.info("Validating Source");
                        source.validate();
                        
                        logger.info("Reading data from DB");
                        AddressManager addrManager = new AddressManager();
                        
                        logger.info("Data is ready");
                        
                        EntryUgedage ugedage = new EntryUgedage(); //saml op på hvilke ugedage der er blevet behandlet
                        
                                                
                        int entryCount = 0;
                        
                        AddressSourceEntry entry;
                        while ( (entry = source.getNextEntry()) != null) {
                                if (super.abort) {
                                        break;
                                }
                                
                                addrManager.visit(entry);
                                ugedage.merge(entry.ugedage);
                                entryCount++;
                        }
                        
                        addrManager.closeUnvisitedAddresses( source.getDistributor(), ugedage );
                        

                        
                        if (writeBack) {
                                addrManager.writeBackChanges();
                        } else {
                                addrManager.dumpChanged();      
                        }
                        
                        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 += "<br><br>";
                        body += "Exception:<br>";
                        body += ExceptionUtils.getStackTrace(e);
                        AddressReport.sendMail(subject, body);
                        
                        throw e; //rethrow exception
                } finally  {
                        
                        try {
                                logger.info("Cleaning up resources");
                                source.close();
                        } catch (Exception e) {
                                logger.warning("Error during cleanup: ", e );
                        }                       
                }

        }

        @Override
        public String getDescription() {
                return "AddressTask " + source.getDistributor();
        }

        @Override
        public double getPercentCompleted() {
                return -1;
        }

        @Override
        public String getDetail() {
                return source.getFilename();
        }

}
1	torben	2947	package dk.daoas.adressevedligehold.fileupload;
2	torben	2838
3	torben	2856	import org.apache.commons.lang3.exception.ExceptionUtils;
4
5	torben	2947	import dk.daoas.adressevedligehold.ReloadHelper;
6	torben	2838	import dk.daoas.adressevedligehold.tasks.Task;
7	torben	2903	import dk.daoas.adressevedligehold.tasks.TaskLogger;
8	torben	2838	import dk.daoas.adressevedligehold.util.TimingHelper;
9
10	torben	2840	/*
11	torben	2949	* TODO: trigger afstand-anden-rute beregning
12	torben	2840	*
13			*/
14
15	torben	2838	public class AddressTask extends Task {
16
17	torben	2903	private TaskLogger logger = TaskLogger.getInstance();
18
19	torben	2838	AddressSource source;
20			boolean writeBack;
21
22			public AddressTask(AddressSource source, boolean writeBack) {
23
24			this.source = source;
25			this.writeBack = writeBack;
26			}
27	torben	2844
28
29	torben	2838
30			@Override
31	torben	2844	protected void taskRun() throws Exception {
32	torben	2838
33			try {
34			TimingHelper timer = new TimingHelper();
35	torben	2844
36	torben	2903	logger.info("Validating Source");
37	torben	2844	source.validate();
38
39	torben	2903	logger.info("Reading data from DB");
40	torben	2838	AddressManager addrManager = new AddressManager();
41
42	torben	2903	logger.info("Data is ready");
43	torben	2838
44			EntryUgedage ugedage = new EntryUgedage(); //saml op på hvilke ugedage der er blevet behandlet
45
46
47			int entryCount = 0;
48
49			AddressSourceEntry entry;
50			while ( (entry = source.getNextEntry()) != null) {
51			if (super.abort) {
52			break;
53			}
54
55			addrManager.visit(entry);
56			ugedage.merge(entry.ugedage);
57			entryCount++;
58			}
59
60			addrManager.closeUnvisitedAddresses( source.getDistributor(), ugedage );
61
62
63
64			if (writeBack) {
65			addrManager.writeBackChanges();
66			} else {
67			addrManager.dumpChanged();
68			}
69
70	torben	2924	AddressReport report = new AddressReport(addrManager, entryCount, ugedage, source, timer, writeBack, addrManager.getDuplicateCount() );
71	torben	2838	report.sendRapport();
72
73
74	torben	2897	if (writeBack) {
75			ReloadHelper.triggerReload( "Indlaesning/" + source.getDistributor() );
76			}
77	torben	2838
78	torben	2896
79	torben	2897
80	torben	2856	} catch(Exception e) {
81
82			String subject = "Error loading data for " + source.getDistributor();
83			String body = "File: " + source.getFilename();
84			body += "<br><br>";
85			body += "Exception:<br>";
86			body += ExceptionUtils.getStackTrace(e);
87			AddressReport.sendMail(subject, body);
88
89			throw e; //rethrow exception
90	torben	2844	} finally {
91
92			try {
93	torben	2903	logger.info("Cleaning up resources");
94	torben	2844	source.close();
95			} catch (Exception e) {
96	torben	2903	logger.warning("Error during cleanup: ", e );
97	torben	2844	}
98	torben	2838	}
99	torben	2844
100	torben	2838	}
101
102			@Override
103			public String getDescription() {
104			return "AddressTask " + source.getDistributor();
105			}
106
107			@Override
108	torben	2891	public double getPercentCompleted() {
109			return -1;
110	torben	2838	}
111
112			@Override
113			public String getDetail() {
114			return source.getFilename();
115			}
116
117			}