traininfo/provider/OfflineStationProvider.java

package dk.thoerup.traininfo.provider;

import java.io.File;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;

import org.simpleframework.xml.Serializer;
import org.simpleframework.xml.core.Persister;

import android.content.Context;
import android.location.Location;
import android.util.Log;
import dk.thoerup.android.traininfo.common.StationBean;
import dk.thoerup.android.traininfo.common.StationEntry;
import dk.thoerup.genericjavautils.HttpUtil;
import dk.thoerup.traininfo.util.IntSet;
import dk.thoerup.traininfo.util.XmlUtil;

public class OfflineStationProvider implements StationProvider {
        
        StationBean stations = new StationBean();


        public boolean loadStations(Context context) throws Exception {
                File parent = context.getFilesDir();
                File stationsFile = new File(parent, "stations.xml");
                
                if (!stationsFile.exists())
                        return false;
                
                int size = (int) stationsFile.length();
                byte data[] = new byte[size];
                
                RandomAccessFile raf = new RandomAccessFile(stationsFile, "r");
                raf.readFully(data);
                
                Serializer serializer = new Persister();
                stations = serializer.read(StationBean.class,  new String(data, "ISO-8859-1") );
                
                Log.e("OFFLINE", "loaded" + stations.entries.size());
                
                return true;
        }       
        
        public void downloadStations(Context context) throws IOException {
                File parent = context.getFilesDir();
                File stationsFile = new File(parent, "stations.xml");

                byte data[] = HttpUtil.getContent(XmlUtil.SERVICE_BASE + "/LocateStations?dump=1", 5000);
                
                RandomAccessFile raf = new RandomAccessFile(stationsFile, "rw");
                Log.e("OFFLINE", "data size" + data.length);
                raf.setLength(0); //truncate
                raf.write(data);
                raf.close();                            
        }
        
        
        @Override
        public void purgeOldEntries() {
        }

        
        @Override
        public StationBean lookupStationsByLocation(Location location) {
                
                Location tmpLoc = new Location("GPS");
                
                ArrayList<StationEntry> entries = new ArrayList<StationEntry>() ;
                
                for (StationEntry entry : stations.entries) {
                        tmpLoc.setLatitude(entry.getLatitude());
                        tmpLoc.setLongitude(entry.getLongitude());
                        
                        entry.setCalcdist( (int) location.distanceTo(tmpLoc) ); 
                        entries.add(entry);
                        
                }
                
                Collections.sort( entries, new Comparator<StationEntry>() {
                        @Override
                        public int compare(StationEntry object1, StationEntry object2) {
                                if (object1.getCalcdist() == object2.getCalcdist())                                     
                                        return 0;
                                
                                if (object1.getCalcdist() > object2.getCalcdist())
                                        return 1;
                                else
                                        return -1;
                        }
                        
                });
                
                
                StationBean tmpStations = new StationBean();
                for (int i = 0; i<8; i++) {
                        tmpStations.entries.add( entries.get(i) );
                }
                
                return tmpStations;
        }

        @Override
        public StationBean lookupStationsByName(String name) {
                
                name = name.toLowerCase();
                StationBean tmpStations = new StationBean();
                for (StationEntry entry : stations.entries) {
                        if (entry.getName().toLowerCase().startsWith(name) ) {
                                tmpStations.entries.add(entry);
                        }
                }
                                                
                return tmpStations;
        }

        @Override
        public StationBean lookupStationsByIds(String ids) {
                IntSet idset = new IntSet();
                idset.fromString(ids);
                
                StationBean tmpStations = new StationBean();
                for (StationEntry entry : stations.entries) {
                        if (idset.contains( entry.getId() ) ) {
                                tmpStations.entries.add(entry);
                        }
                }
                
                
                return tmpStations;
        }

}
1	package dk.thoerup.traininfo.provider;
2
3	import java.io.File;
4	import java.io.IOException;
5	import java.io.RandomAccessFile;
6	import java.util.ArrayList;
7	import java.util.Collections;
8	import java.util.Comparator;
9
10	import org.simpleframework.xml.Serializer;
11	import org.simpleframework.xml.core.Persister;
12
13	import android.content.Context;
14	import android.location.Location;
15	import android.util.Log;
16	import dk.thoerup.android.traininfo.common.StationBean;
17	import dk.thoerup.android.traininfo.common.StationEntry;
18	import dk.thoerup.genericjavautils.HttpUtil;
19	import dk.thoerup.traininfo.util.IntSet;
20	import dk.thoerup.traininfo.util.XmlUtil;
21
22	public class OfflineStationProvider implements StationProvider {
23
24	StationBean stations = new StationBean();
25
26
27	public boolean loadStations(Context context) throws Exception {
28	File parent = context.getFilesDir();
29	File stationsFile = new File(parent, "stations.xml");
30
31	if (!stationsFile.exists())
32	return false;
33
34	int size = (int) stationsFile.length();
35	byte data[] = new byte[size];
36
37	RandomAccessFile raf = new RandomAccessFile(stationsFile, "r");
38	raf.readFully(data);
39
40	Serializer serializer = new Persister();
41	stations = serializer.read(StationBean.class, new String(data, "ISO-8859-1") );
42
43	Log.e("OFFLINE", "loaded" + stations.entries.size());
44
45	return true;
46	}
47
48	public void downloadStations(Context context) throws IOException {
49	File parent = context.getFilesDir();
50	File stationsFile = new File(parent, "stations.xml");
51
52	byte data[] = HttpUtil.getContent(XmlUtil.SERVICE_BASE + "/LocateStations?dump=1", 5000);
53
54	RandomAccessFile raf = new RandomAccessFile(stationsFile, "rw");
55	Log.e("OFFLINE", "data size" + data.length);
56	raf.setLength(0); //truncate
57	raf.write(data);
58	raf.close();
59	}
60
61
62
63	@Override
64	public void purgeOldEntries() {
65	}
66
67
68	@Override
69	public StationBean lookupStationsByLocation(Location location) {
70
71	Location tmpLoc = new Location("GPS");
72
73	ArrayList<StationEntry> entries = new ArrayList<StationEntry>() ;
74
75	for (StationEntry entry : stations.entries) {
76	tmpLoc.setLatitude(entry.getLatitude());
77	tmpLoc.setLongitude(entry.getLongitude());
78
79	entry.setCalcdist( (int) location.distanceTo(tmpLoc) );
80	entries.add(entry);
81
82	}
83
84	Collections.sort( entries, new Comparator<StationEntry>() {
85	@Override
86	public int compare(StationEntry object1, StationEntry object2) {
87	if (object1.getCalcdist() == object2.getCalcdist())
88	return 0;
89
90	if (object1.getCalcdist() > object2.getCalcdist())
91	return 1;
92	else
93	return -1;
94	}
95
96	});
97
98
99
100	StationBean tmpStations = new StationBean();
101	for (int i = 0; i<8; i++) {
102	tmpStations.entries.add( entries.get(i) );
103	}
104
105	return tmpStations;
106	}
107
108	@Override
109	public StationBean lookupStationsByName(String name) {
110
111	name = name.toLowerCase();
112	StationBean tmpStations = new StationBean();
113	for (StationEntry entry : stations.entries) {
114	if (entry.getName().toLowerCase().startsWith(name) ) {
115	tmpStations.entries.add(entry);
116	}
117	}
118
119	return tmpStations;
120	}
121
122	@Override
123	public StationBean lookupStationsByIds(String ids) {
124	IntSet idset = new IntSet();
125	idset.fromString(ids);
126
127	StationBean tmpStations = new StationBean();
128	for (StationEntry entry : stations.entries) {
129	if (idset.contains( entry.getId() ) ) {
130	tmpStations.entries.add(entry);
131	}
132	}
133
134
135
136	return tmpStations;
137	}
138
139	}