adressevedligehold/fileupload/AddressSourceBK.java

package dk.daoas.adressevedligehold;

import java.io.IOException;

import org.apache.commons.fileupload.FileItem;

import dk.daoas.adressevedligehold.AddressSourceEntry.EntryType;
import dk.daoas.adressevedligehold.util.SafeParsers;

public class AddressSourceBK extends AbstractAddressSource {
        
                
        public AddressSourceBK(FileItem file) throws Exception {
                super(file);
        }

        
        @Override
        public void validate() throws IOException {
                super.validatNoHeaderLine(13, ';');
        }

        //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 = "BK";
                
                String[] parts = line.split(";");
                
                if (parts.length != 13) {
                        throw new IOException("Not enough fields in CSV file. Found " + parts.length + ", expected 13");
                }
                
                entry.postnr = Short.parseShort( parts[0]);
                entry.vejnavn = parts[1].replace("\"", "");
                entry.husnr = Short.parseShort( parts[2] );
                entry.litra = parts[3].replace("\"", "");
                entry.vejkode = SafeParsers.parseShort( parts[4] );
                entry.kommunekode = SafeParsers.parseShort( parts[5] );
                entry.gadeid = Integer.parseInt( parts[6] );
                
                String ugedage = parts[7].replace("\"", "");
                
                String laesnr = parts[8].replace("\"", "");
                
                //String distnr = parts[9].replace("\"", ""); //Bruges ikke
                String foede = parts[10].replace("\"", "");
                String jobnr = parts[11].replace("\"", "");
                String tklaes = parts[12].replace("\"", "");
                
                entry.rute = laesnr;
                entry.koreliste = "/" + foede + "/" + tklaes + "/" + jobnr;
                
                entry.rute = dirigeringsCache.getInstance(entry.rute);
                entry.koreliste = dirigeringsCache.getInstance(entry.koreliste);
                
                switch (ugedage) {              
                case "1234000":
                        entry.ugedage = EntryUgedage.MAN_TOR;
                        break;
                case "0000500":
                        entry.ugedage = EntryUgedage.FRE;
                        break;
                case "0000060":
                        entry.ugedage = EntryUgedage.LOR;
                        break;
                case "0000007":
                        entry.ugedage = EntryUgedage.SON;
                        break;
                default:
                        throw new IOException("Ukendt ugedag:" + ugedage);
                }

                
                lineCount++;
                
                return entry;
        }
        
        @Override
        public String getDistributor() {
                return "BK";
        }

}
1	torben	2838	package dk.daoas.adressevedligehold;
2
3			import java.io.IOException;
4
5			import org.apache.commons.fileupload.FileItem;
6
7			import dk.daoas.adressevedligehold.AddressSourceEntry.EntryType;
8			import dk.daoas.adressevedligehold.util.SafeParsers;
9
10	torben	2868	public class AddressSourceBK extends AbstractAddressSource {
11	torben	2838
12
13			public AddressSourceBK(FileItem file) throws Exception {
14	torben	2868	super(file);
15	torben	2838	}
16
17
18	torben	2844	@Override
19			public void validate() throws IOException {
20	torben	2869	super.validatNoHeaderLine(13, ';');
21	torben	2844	}
22
23	torben	2838	//TODO: Skal csv parsning klares med Apache Commons CSV ?
24
25			@Override
26			public AddressSourceEntry getNextEntry() throws IOException {
27			String line = br.readLine();
28			if (line == null) // end of file
29			return null;
30
31			if (line.trim().equals(""))
32			return null;
33
34			//System.out.println(line);
35
36			AddressSourceEntry entry = new AddressSourceEntry( EntryType.TypeSingleAddress);
37			entry.distributor = "BK";
38
39			String[] parts = line.split(";");
40	torben	2857
41			if (parts.length != 13) {
42			throw new IOException("Not enough fields in CSV file. Found " + parts.length + ", expected 13");
43			}
44
45	torben	2838	entry.postnr = Short.parseShort( parts[0]);
46			entry.vejnavn = parts[1].replace("\"", "");
47			entry.husnr = Short.parseShort( parts[2] );
48			entry.litra = parts[3].replace("\"", "");
49			entry.vejkode = SafeParsers.parseShort( parts[4] );
50			entry.kommunekode = SafeParsers.parseShort( parts[5] );
51			entry.gadeid = Integer.parseInt( parts[6] );
52
53			String ugedage = parts[7].replace("\"", "");
54
55			String laesnr = parts[8].replace("\"", "");
56
57	torben	2844	//String distnr = parts[9].replace("\"", ""); //Bruges ikke
58	torben	2838	String foede = parts[10].replace("\"", "");
59			String jobnr = parts[11].replace("\"", "");
60			String tklaes = parts[12].replace("\"", "");
61
62			entry.rute = laesnr;
63			entry.koreliste = "/" + foede + "/" + tklaes + "/" + jobnr;
64
65			entry.rute = dirigeringsCache.getInstance(entry.rute);
66			entry.koreliste = dirigeringsCache.getInstance(entry.koreliste);
67
68			switch (ugedage) {
69			case "1234000":
70			entry.ugedage = EntryUgedage.MAN_TOR;
71			break;
72			case "0000500":
73			entry.ugedage = EntryUgedage.FRE;
74			break;
75			case "0000060":
76			entry.ugedage = EntryUgedage.LOR;
77			break;
78			case "0000007":
79			entry.ugedage = EntryUgedage.SON;
80			break;
81			default:
82			throw new IOException("Ukendt ugedag:" + ugedage);
83			}
84
85
86			lineCount++;
87
88			return entry;
89			}
90
91			@Override
92			public String getDistributor() {
93			return "BK";
94			}
95
96			}