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