adressevedligehold/fileupload/AddressTask.java

package dk.daoas.adressevedligehold.fileupload;

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

import dk.daoas.adressevedligehold.MailSender;
import dk.daoas.adressevedligehold.ReloadTask;
import dk.daoas.adressevedligehold.afstandandenrute.AfstandAndenRuteTask;
import dk.daoas.adressevedligehold.tasks.Task;
import dk.daoas.adressevedligehold.tasks.TaskLogger;
import dk.daoas.adressevedligehold.util.TimingHelper;

/*
 *   
 */

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

        @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) {
                                manager.submitTask( new ReloadTask("Indlaesning/" + source.getDistributor()) );
                                
                                
                                if (source.calculateDistances()) {
                                        Task tsk = new AfstandAndenRuteTask(source.getDistributor(), AfstandAndenRuteTask.INCREMENTAL);
                                        manager.submitTask( tsk );
                                }                               
                        }
                        

                        
                } 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);
                        MailSender.sendMail(subject, body);
                        
                        throw e; //rethrow exception
                } finally  {
                        
                        try {
                                logger.info("Cleaning up resources");
                                source.close();
                                source = null; //and release it for garbace collection
                        } catch (Exception e) {
                                logger.warning("Error during cleanup: ", e );
                        }                       
                }

        }

        @Override
        public String getDescription() {
                return "AddressTask " + distributor;
        }

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

        @Override
        public String getDetail() {
                return filename;
        }

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