traininfoservice/banedk/TritinfoFetcher.java

package dk.thoerup.traininfoservice.banedk;

import java.net.URL;
import java.util.logging.Logger;

import org.jsoup.nodes.Element;
import org.jsoup.select.Elements;

import dk.thoerup.android.traininfo.common.DepartureBean;
import dk.thoerup.android.traininfo.common.DepartureEntry;
import dk.thoerup.android.traininfo.common.StationEntry;
import dk.thoerup.circuitbreaker.CircuitBreaker;
import dk.thoerup.circuitbreaker.CircuitBreakerManager;
import dk.thoerup.traininfoservice.TraininfoSettings;

public class TritinfoFetcher {
        
        Logger logger = Logger.getLogger( TritinfoFetcher.class.getName() );
        TraininfoSettings settings;
        
        public TritinfoFetcher(TraininfoSettings settings) {
                this.settings = settings;
        }
        
        
        
        
        public void injectTritinfoData(DepartureBean departureBean, StationEntry station) throws Exception {
            String uri = "http://tritinfo.pallas.dk/webtavle?page=stationcontent&staid=" + station.getTritStation();
            logger.fine("URI:" + uri);
            

            JsoupInvocation wrapper = new JsoupInvocation( new URL(uri), settings.getReplyTimeout() ); 
            CircuitBreaker breaker = CircuitBreakerManager.getManager().getCircuitBreaker("tritinfo");
            
            Element page = (Element) breaker.invoke(wrapper);           
            
            Element table = page.getElementsByClass("passages").get(0);
            
            Elements trains = table.getElementsByClass("train");
            
            for (int i=0; i<trains.size(); i++) {
                Element train = trains.get(i);
                
                //String trainType = train.getElementsByClass("trainType").get(0).text();
                String trainNumber = train.getElementsByClass("trainNumber").get(0).text();             
                
                Elements trackElems = train.getElementsByClass("plannedTrack");
                if (trackElems.size() == 0) {
                        trackElems = train.getElementsByClass("expectedTrack");
                }
                String track = trackElems.get(0).text().trim();
                String trackType = train.getElementsByClass("trackType").get(0).text().trim();
                
        
                String platform = track;
                        if ( !trackType.equals("")) {
                                platform += trackType;
                        }
                
                for (DepartureEntry entry : departureBean.entries) {
                        String entryTrainId = entry.getTrainNumber().split(" ")[1];
                        if ( entryTrainId.equals(trainNumber)) {
                                
                                entry.setPlatform(platform);
                                break;
                        }
                }
            }
        }

}
1	package dk.thoerup.traininfoservice.banedk;
2
3	import java.net.URL;
4	import java.util.logging.Logger;
5
6	import org.jsoup.nodes.Element;
7	import org.jsoup.select.Elements;
8
9	import dk.thoerup.android.traininfo.common.DepartureBean;
10	import dk.thoerup.android.traininfo.common.DepartureEntry;
11	import dk.thoerup.android.traininfo.common.StationEntry;
12	import dk.thoerup.circuitbreaker.CircuitBreaker;
13	import dk.thoerup.circuitbreaker.CircuitBreakerManager;
14	import dk.thoerup.traininfoservice.TraininfoSettings;
15
16	public class TritinfoFetcher {
17
18	Logger logger = Logger.getLogger( TritinfoFetcher.class.getName() );
19	TraininfoSettings settings;
20
21	public TritinfoFetcher(TraininfoSettings settings) {
22	this.settings = settings;
23	}
24
25
26
27
28	public void injectTritinfoData(DepartureBean departureBean, StationEntry station) throws Exception {
29	String uri = "http://tritinfo.pallas.dk/webtavle?page=stationcontent&staid=" + station.getTritStation();
30	logger.fine("URI:" + uri);
31
32
33	JsoupInvocation wrapper = new JsoupInvocation( new URL(uri), settings.getReplyTimeout() );
34	CircuitBreaker breaker = CircuitBreakerManager.getManager().getCircuitBreaker("tritinfo");
35
36	Element page = (Element) breaker.invoke(wrapper);
37
38	Element table = page.getElementsByClass("passages").get(0);
39
40	Elements trains = table.getElementsByClass("train");
41
42	for (int i=0; i<trains.size(); i++) {
43	Element train = trains.get(i);
44
45	//String trainType = train.getElementsByClass("trainType").get(0).text();
46	String trainNumber = train.getElementsByClass("trainNumber").get(0).text();
47
48	Elements trackElems = train.getElementsByClass("plannedTrack");
49	if (trackElems.size() == 0) {
50	trackElems = train.getElementsByClass("expectedTrack");
51	}
52	String track = trackElems.get(0).text().trim();
53	String trackType = train.getElementsByClass("trackType").get(0).text().trim();
54
55
56	String platform = track;
57	if ( !trackType.equals("")) {
58	platform += trackType;
59	}
60
61	for (DepartureEntry entry : departureBean.entries) {
62	String entryTrainId = entry.getTrainNumber().split(" ")[1];
63	if ( entryTrainId.equals(trainNumber)) {
64
65	entry.setPlatform(platform);
66	break;
67	}
68	}
69	}
70	}
71
72	}