adressevedligehold/fileupload/AddressTask.java

package dk.daoas.adressevedligehold;

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

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() {
                
                try {
                        TimingHelper timer = new TimingHelper();
                        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();
                        
                        
                        
                } catch (Exception e) {
                        e.printStackTrace();
                }
                
                
                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			public class AddressTask extends Task {
7
8			AddressSource source;
9			boolean writeBack;
10
11			public AddressTask(AddressSource source, boolean writeBack) {
12
13			this.source = source;
14			this.writeBack = writeBack;
15			}
16
17			@Override
18			protected void taskRun() {
19
20			try {
21			TimingHelper timer = new TimingHelper();
22			System.out.println("Reading data from DB");
23			AddressManager addrManager = new AddressManager();
24
25			System.out.println("Data is ready");
26
27			EntryUgedage ugedage = new EntryUgedage(); //saml op på hvilke ugedage der er blevet behandlet
28
29
30			int entryCount = 0;
31
32			AddressSourceEntry entry;
33			while ( (entry = source.getNextEntry()) != null) {
34			if (super.abort) {
35			break;
36			}
37
38			addrManager.visit(entry);
39			ugedage.merge(entry.ugedage);
40			entryCount++;
41			}
42
43			addrManager.closeUnvisitedAddresses( source.getDistributor(), ugedage );
44
45
46
47			if (writeBack) {
48			addrManager.writeBackChanges();
49			} else {
50			addrManager.dumpChanged();
51			}
52
53			AddressReport report = new AddressReport(addrManager, entryCount, ugedage, source, timer, writeBack);
54			report.sendRapport();
55
56
57
58			} catch (Exception e) {
59			e.printStackTrace();
60			}
61
62
63			try {
64			System.out.println("Cleaning up resources");
65			source.close();
66			} catch (Exception e) {
67			System.out.println("Error during cleanup: " + e.getMessage() );
68			}
69			}
70
71			@Override
72			public String getDescription() {
73			return "AddressTask " + source.getDistributor();
74			}
75
76			@Override
77			public short getPercentCompleted() {
78			return 0;
79			}
80
81			@Override
82			public String getDetail() {
83			return source.getFilename();
84			}
85
86			}