daoas/adressevedligehold/AddressSourceBK.java

package dk.daoas.adressevedligehold;

import java.io.IOException;
import java.util.List;

import org.apache.commons.fileupload.FileItem;

import com.google.common.base.CharMatcher;
import com.google.common.base.Splitter;

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

public class AddressSourceBK extends AbstractAddressSource {
        
        Splitter splitter = Splitter.on(';').trimResults( CharMatcher.is('"') );
                
        public AddressSourceBK(FileItem file) throws Exception {
                super(file);
        }

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

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