daoas/adressevedligehold/AddressTask.java

package dk.daoas.adressevedligehold;

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();
                        
                        
                        
                } 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 short getPercentCompleted() {
                return 0;
        }

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

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