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	torben	2077	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			}