daoas/adressevedligehold/AddressTask.java

package dk.daoas.adressevedligehold;

import org.apache.commons.lang3.exception.ExceptionUtils;

import dk.daoas.adressevedligehold.tasks.Task;
import dk.daoas.adressevedligehold.util.TimingHelper;

/*
 * TODO: trigger indlæsning
 *   
 */

public class AddressTask extends Task {
        
        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();
                        
                        System.out.println("Validating Source");
                        source.validate();
                        
                        System.out.println("Reading data from DB");
                        AddressManager addrManager = new AddressManager();
                        
                        System.out.println("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);
                        report.sendRapport();
                        
                        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 {
                                System.out.println("Cleaning up resources");
                                source.close();
                        } catch (Exception e) {
                                System.out.println("Error during cleanup: " + e.getMessage() );
                        }                       
                }

        }

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

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

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

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