adressevedligehold/coveragefileupload/AddressSourceFD.java

package dk.daoas.adressevedligehold;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.nio.charset.Charset;
import java.util.List;

import org.apache.commons.fileupload.FileItem;

import com.google.common.base.Splitter;

import dk.daoas.adressevedligehold.AddressSourceEntry.EntryType;

public class AddressSourceFD extends AbstractAddressSource {
                
        
        String filenameFirst2;
                
        public AddressSourceFD(FileItem file) throws Exception {
                super(file);
                
                filenameFirst2 = file.getName().substring(0, 2).toUpperCase();
        }
        
        @Override
        public void validate() throws IOException {
                try {
                        is = file.getInputStream();
                        isr = new InputStreamReader(is, Charset.forName("ISO-8859-1") );
                        br = new BufferedReader(isr);
                        
                        String line = br.readLine();
                        
                        if (line == null) {
                                throw new IOException("Can't read 1st line - is file empty?");
                        }       
                        
                        String[] parts = line.split(";");
                        if (parts.length != 9) {
                                throw new IOException("Not enough fields in CSV file. Found " + parts.length + ", expected 9");
                        }


                } catch (Exception e) {
                        try {
                                br.close();
                                isr.close();
                                is.close();
                        } catch (Exception e2) {
                                System.out.println("Error cleaning up resources");
                        }
                        
                        throw e; // Re-throw
                         
                }
        }
        

        //TODO: Skal csv parsning klares med Apache Commons CSV ?

        @Override
        public AddressSourceEntry getNextEntry() throws IOException {
                String line = br.readLine();
                if (line == null) // end of file
                        return null;
                
                if (line.trim().equals(""))
                        return null;
                
                //System.out.println(line);
                
                AddressSourceEntry entry = new AddressSourceEntry( EntryType.TypeSingleAddress);
                entry.distributor = "FD";
                
                List<String> parts = Splitter.on(';').splitToList(line);
                
                if (parts.size() != 9) {
                        throw new IOException("Not enough fields in line " + line);
                }
                
                entry.postnr = Short.parseShort( parts.get(0) );
                entry.vejnavn = parts.get(1);
                entry.husnr = Short.parseShort( parts.get(2) );
                entry.litra = parts.get(3);
                entry.vejkode = Short.parseShort( parts.get(4) );
                entry.kommunekode = Short.parseShort( parts.get(5) );
                entry.gadeid = Integer.parseInt( parts.get(6) );
                entry.rute = dirigeringsCache.getInstance( parts.get(7) );
                entry.koreliste = dirigeringsCache.getInstance( parts.get(8) );
                
                switch(filenameFirst2) {
                case "HV":
                        entry.ugedage = EntryUgedage.MAN_FRE;
                        break;
                case "LO":
                        entry.ugedage = EntryUgedage.LOR;
                        break;
                case "SO":
                        entry.ugedage = EntryUgedage.SON;
                        break;
                default:
                        throw new IOException("Ukendt ugedage " + filenameFirst2);
                }
                
                
                lineCount++;
                
                return entry;
        }
        
        @Override
        public String getDistributor() {
                return "FD";
        }

}
1	torben	2852	package dk.daoas.adressevedligehold;
2
3			import java.io.BufferedReader;
4			import java.io.IOException;
5			import java.io.InputStreamReader;
6			import java.nio.charset.Charset;
7			import java.util.List;
8
9			import org.apache.commons.fileupload.FileItem;
10
11			import com.google.common.base.Splitter;
12
13			import dk.daoas.adressevedligehold.AddressSourceEntry.EntryType;
14
15	torben	2868	public class AddressSourceFD extends AbstractAddressSource {
16
17	torben	2852
18			String filenameFirst2;
19
20			public AddressSourceFD(FileItem file) throws Exception {
21	torben	2868	super(file);
22	torben	2852
23			filenameFirst2 = file.getName().substring(0, 2).toUpperCase();
24			}
25
26			@Override
27			public void validate() throws IOException {
28			try {
29			is = file.getInputStream();
30			isr = new InputStreamReader(is, Charset.forName("ISO-8859-1") );
31			br = new BufferedReader(isr);
32
33			String line = br.readLine();
34	torben	2861
35			if (line == null) {
36			throw new IOException("Can't read 1st line - is file empty?");
37			}
38
39	torben	2852	String[] parts = line.split(";");
40	torben	2861	if (parts.length != 9) {
41			throw new IOException("Not enough fields in CSV file. Found " + parts.length + ", expected 9");
42	torben	2852	}
43
44
45
46			} catch (Exception e) {
47			try {
48			br.close();
49			isr.close();
50			is.close();
51			} catch (Exception e2) {
52			System.out.println("Error cleaning up resources");
53			}
54
55			throw e; // Re-throw
56
57			}
58			}
59
60
61			//TODO: Skal csv parsning klares med Apache Commons CSV ?
62
63			@Override
64			public AddressSourceEntry getNextEntry() throws IOException {
65			String line = br.readLine();
66			if (line == null) // end of file
67			return null;
68
69			if (line.trim().equals(""))
70			return null;
71
72			//System.out.println(line);
73
74			AddressSourceEntry entry = new AddressSourceEntry( EntryType.TypeSingleAddress);
75			entry.distributor = "FD";
76
77			List<String> parts = Splitter.on(';').splitToList(line);
78
79			if (parts.size() != 9) {
80			throw new IOException("Not enough fields in line " + line);
81			}
82
83			entry.postnr = Short.parseShort( parts.get(0) );
84			entry.vejnavn = parts.get(1);
85			entry.husnr = Short.parseShort( parts.get(2) );
86			entry.litra = parts.get(3);
87			entry.vejkode = Short.parseShort( parts.get(4) );
88			entry.kommunekode = Short.parseShort( parts.get(5) );
89			entry.gadeid = Integer.parseInt( parts.get(6) );
90			entry.rute = dirigeringsCache.getInstance( parts.get(7) );
91			entry.koreliste = dirigeringsCache.getInstance( parts.get(8) );
92
93			switch(filenameFirst2) {
94			case "HV":
95			entry.ugedage = EntryUgedage.MAN_FRE;
96			break;
97			case "LO":
98			entry.ugedage = EntryUgedage.LOR;
99			break;
100			case "SO":
101			entry.ugedage = EntryUgedage.SON;
102			break;
103			default:
104			throw new IOException("Ukendt ugedage " + filenameFirst2);
105			}
106
107
108			lineCount++;
109
110			return entry;
111			}
112
113			@Override
114			public String getDistributor() {
115			return "FD";
116			}
117
118			}