daoas/adressevedligehold/AddressSourceNS.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;

public class AddressSourceNS extends AbstractAddressSource {
        
        enum NextUgedag {
                MANDAG,TIRSDAG,ONSDAG,TORSDAG,FREDAG,LORDAG,SONDAG
        }
                
        
        final Splitter splitter = Splitter.on(',')
                                                                .trimResults( CharMatcher.is('"') );
        
        List<String> parts;
        
        
        NextUgedag nextUgedag = NextUgedag.MANDAG;
                
        public AddressSourceNS(FileItem file) throws Exception {
                super(file);
        }

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

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

        @Override
        public AddressSourceEntry getNextEntry() throws IOException {
                if (nextUgedag == NextUgedag.MANDAG) {
                        String line = br.readLine();
                        if (line == null) // end of file
                                return null;
                        
                        if (line.trim().equals(""))
                                return null;
                        parts = splitter.splitToList(line);
                        
                        if (parts.size() != 22) {
                                throw new IOException("Not enough fields in line " + line);
                        }
                }
                
                
                
                
                AddressSourceEntry entry = new AddressSourceEntry( EntryType.TypeAddressRange );
                entry.distributor = "NS";
                
                
                entry.gadeid = Integer.parseInt( parts.get(0) );
                entry.vejnavn = parts.get(1);
                //stednavn = parts.get(2);
                //ukendtt = parts.get(3);
                entry.postnr = Short.parseShort( parts.get(4) );
                entry.rute = dirigeringsCache.getInstance( parts.get(5) );
                entry.husnr = Short.parseShort( parts.get(6) );
                entry.litra = parts.get(7);
                entry.tilHusnr = Short.parseShort( parts.get(8) );
                entry.tilLitra = parts.get(9);
                //sekvens = parts.get(10)
                //fradato = parts.get(11)
                //tildato = parts.get(12)
                //distributor = parts.get(13)
                //inspektorkode = parts.get(21)
                
                switch (nextUgedag) {           
                case MANDAG:
                        entry.koreliste = dirigeringsCache.getInstance( parts.get(14) );
                        entry.ugedage = EntryUgedage.MAN;
                        nextUgedag = NextUgedag.TIRSDAG;
                        break;
                case TIRSDAG:
                        entry.koreliste = dirigeringsCache.getInstance( parts.get(15) );
                        entry.ugedage = EntryUgedage.TIR;
                        nextUgedag = NextUgedag.ONSDAG;
                        break;
                case ONSDAG:
                        entry.koreliste = dirigeringsCache.getInstance( parts.get(16) );
                        entry.ugedage = EntryUgedage.ONS;
                        nextUgedag = NextUgedag.TORSDAG;
                        break;
                case TORSDAG:
                        entry.koreliste = dirigeringsCache.getInstance( parts.get(17) );
                        entry.ugedage = EntryUgedage.TOR;
                        nextUgedag = NextUgedag.FREDAG;
                        break;
                case FREDAG:
                        entry.koreliste = dirigeringsCache.getInstance( parts.get(18) );
                        entry.ugedage = EntryUgedage.FRE;
                        nextUgedag = NextUgedag.LORDAG;
                        break;
                case LORDAG:
                        entry.koreliste = dirigeringsCache.getInstance( parts.get(19) );
                        entry.ugedage = EntryUgedage.LOR;
                        nextUgedag = NextUgedag.SONDAG;
                        break;
                case SONDAG:
                        entry.koreliste = dirigeringsCache.getInstance( parts.get(20) );
                        entry.ugedage = EntryUgedage.SON;
                        nextUgedag = NextUgedag.MANDAG;
                        break;
                default:
                        throw new IOException("Ukendt ugedag:" + nextUgedag);
                }

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

}
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
13	public class AddressSourceNS extends AbstractAddressSource {
14
15	enum NextUgedag {
16	MANDAG,TIRSDAG,ONSDAG,TORSDAG,FREDAG,LORDAG,SONDAG
17	}
18
19
20	final Splitter splitter = Splitter.on(',')
21	.trimResults( CharMatcher.is('"') );
22
23	List<String> parts;
24
25
26	NextUgedag nextUgedag = NextUgedag.MANDAG;
27
28	public AddressSourceNS(FileItem file) throws Exception {
29	super(file);
30	}
31
32
33	@Override
34	public void validate() throws IOException {
35	super.validatNoHeaderLine(22, ',');
36	}
37
38	//TODO: Skal csv parsning klares med Apache Commons CSV ?
39
40	@Override
41	public AddressSourceEntry getNextEntry() throws IOException {
42	if (nextUgedag == NextUgedag.MANDAG) {
43	String line = br.readLine();
44	if (line == null) // end of file
45	return null;
46
47	if (line.trim().equals(""))
48	return null;
49	parts = splitter.splitToList(line);
50
51	if (parts.size() != 22) {
52	throw new IOException("Not enough fields in line " + line);
53	}
54	}
55
56
57
58
59	AddressSourceEntry entry = new AddressSourceEntry( EntryType.TypeAddressRange );
60	entry.distributor = "NS";
61
62
63	entry.gadeid = Integer.parseInt( parts.get(0) );
64	entry.vejnavn = parts.get(1);
65	//stednavn = parts.get(2);
66	//ukendtt = parts.get(3);
67	entry.postnr = Short.parseShort( parts.get(4) );
68	entry.rute = dirigeringsCache.getInstance( parts.get(5) );
69	entry.husnr = Short.parseShort( parts.get(6) );
70	entry.litra = parts.get(7);
71	entry.tilHusnr = Short.parseShort( parts.get(8) );
72	entry.tilLitra = parts.get(9);
73	//sekvens = parts.get(10)
74	//fradato = parts.get(11)
75	//tildato = parts.get(12)
76	//distributor = parts.get(13)
77	//inspektorkode = parts.get(21)
78
79	switch (nextUgedag) {
80	case MANDAG:
81	entry.koreliste = dirigeringsCache.getInstance( parts.get(14) );
82	entry.ugedage = EntryUgedage.MAN;
83	nextUgedag = NextUgedag.TIRSDAG;
84	break;
85	case TIRSDAG:
86	entry.koreliste = dirigeringsCache.getInstance( parts.get(15) );
87	entry.ugedage = EntryUgedage.TIR;
88	nextUgedag = NextUgedag.ONSDAG;
89	break;
90	case ONSDAG:
91	entry.koreliste = dirigeringsCache.getInstance( parts.get(16) );
92	entry.ugedage = EntryUgedage.ONS;
93	nextUgedag = NextUgedag.TORSDAG;
94	break;
95	case TORSDAG:
96	entry.koreliste = dirigeringsCache.getInstance( parts.get(17) );
97	entry.ugedage = EntryUgedage.TOR;
98	nextUgedag = NextUgedag.FREDAG;
99	break;
100	case FREDAG:
101	entry.koreliste = dirigeringsCache.getInstance( parts.get(18) );
102	entry.ugedage = EntryUgedage.FRE;
103	nextUgedag = NextUgedag.LORDAG;
104	break;
105	case LORDAG:
106	entry.koreliste = dirigeringsCache.getInstance( parts.get(19) );
107	entry.ugedage = EntryUgedage.LOR;
108	nextUgedag = NextUgedag.SONDAG;
109	break;
110	case SONDAG:
111	entry.koreliste = dirigeringsCache.getInstance( parts.get(20) );
112	entry.ugedage = EntryUgedage.SON;
113	nextUgedag = NextUgedag.MANDAG;
114	break;
115	default:
116	throw new IOException("Ukendt ugedag:" + nextUgedag);
117	}
118
119
120	lineCount++;
121
122	return entry;
123	}
124
125	@Override
126	public String getDistributor() {
127	return "NS";
128	}
129
130	}