daoas/adressevedligehold/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	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	public class AddressSourceFD extends AbstractAddressSource {
16
17
18	String filenameFirst2;
19
20	public AddressSourceFD(FileItem file) throws Exception {
21	super(file);
22
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
35	if (line == null) {
36	throw new IOException("Can't read 1st line - is file empty?");
37	}
38
39	String[] parts = line.split(";");
40	if (parts.length != 9) {
41	throw new IOException("Not enough fields in CSV file. Found " + parts.length + ", expected 9");
42	}
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	}