/[projects]/android/TrainInfoService/src/dk/thoerup/traininfoservice/banedk/TimetableServlet.java
ViewVC logotype

Diff of /android/TrainInfoService/src/dk/thoerup/traininfoservice/banedk/TimetableServlet.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 378 by torben, Thu Oct 1 08:31:47 2009 UTC revision 859 by torben, Wed Jun 16 08:20:01 2010 UTC
# Line 10  import javax.servlet.http.HttpServlet; Line 10  import javax.servlet.http.HttpServlet;
10  import javax.servlet.http.HttpServletRequest;  import javax.servlet.http.HttpServletRequest;
11  import javax.servlet.http.HttpServletResponse;  import javax.servlet.http.HttpServletResponse;
12    
13    import dk.thoerup.circuitbreaker.CircuitBreakerException;
14    import dk.thoerup.traininfoservice.Statistics;
15    
16  /**  /**
17   * Servlet implementation class TimetableServlet   * Servlet implementation class TimetableServlet
18   */   */
# Line 19  public class TimetableServlet extends Ht Line 22  public class TimetableServlet extends Ht
22                    
23          Logger logger = Logger.getLogger( TimetableServlet.class.getName() );          Logger logger = Logger.getLogger( TimetableServlet.class.getName() );
24                    
25          TimetableFetcher fetcher = new TimetableFetcher();          TimetableFetcher fetcher;
26            
27            @Override
28            public void init() throws ServletException {
29                    super.init();
30                    
31                    boolean useTempSite =  Boolean.parseBoolean( getServletContext().getInitParameter("usetempsite") );
32                    int cacheTimeout =  Integer.parseInt( getServletContext().getInitParameter("cache_timeout") );
33                    logger.info( "TimetableServlet, use temp site=" + useTempSite + ", cache=" + cacheTimeout);
34                    fetcher = new TimetableFetcher(useTempSite,cacheTimeout);
35            }
36                    
37            @Override
38          protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {          protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
39                  String train = request.getParameter("train").trim();                  if (request.getParameter("train") == null) {
40                                            response.sendError(400, "not enough parameters (train)");
41                  String sections[] = train.split(" ");                          return;
42                  if (sections.length != 2) {                  }
43                          response.sendError(400, "Invalid parameter");                  if (request.getParameter("type") == null) {
44                            response.sendError(400, "not enough parameters (type)");
45                          return;                          return;
46                  }                  }
47                    Statistics.getInstance().incrementTimetableLookups();
48                                    
49                  String type = lookupType(sections[0]);                  String train = request.getParameter("train").trim();
50                  String trainID = sections[1];                  String type = request.getParameter("type").trim();
51                                    
52                  try                  try
53                  {                  {
54                          List<TimetableBean> timetable = fetcher.lookupTimetable(trainID, type);                          List<TimetableBean> timetable = fetcher.cachedLookupTimetable(train, type);
55                                    
56                          String responseXML = formatTimetable(timetable);                          String responseXML = formatTimetable(timetable);
57                                    
58                          response.setContentType("text/xml");                          response.setContentType("text/xml");
59                          response.getWriter().print(responseXML);                          response.getWriter().print(responseXML);
60                  } catch (java.net.SocketTimeoutException ste) {                  } catch (java.io.IOException ioe) {
61                          logger.warning("(timetable) Read timed out, train="+train);                          logger.warning("(timetable) Read failed, type=" + type + ", train="+train + ". " + ioe.getMessage());
62                            Statistics.getInstance().incrementTimetableErrors();
63                          response.sendError(500, "Backend timed out");                          response.sendError(500, "Backend timed out");
64                  } catch (Exception e) {                  } catch (CircuitBreakerException cbe) {
65                          logger.log(Level.WARNING, "failure looking up timetable: train=" +train, e);                          logger.warning("Circuitbreaker - failing fast");
66                            Statistics.getInstance().incrementTimetableErrors();
67                            response.sendError(500);
68                    }catch (Exception e) {
69                            logger.log(Level.WARNING, "failure looking up timetable: type=" + type + ",train=" +train, e);
70                            Statistics.getInstance().incrementTimetableErrors();
71                          response.sendError(500);                          response.sendError(500);
72                  }                  }
73                                    
74          }          }
75                    
         String lookupType(String trainCode) {  
                 trainCode = trainCode.toLowerCase();  
                   
                 if (trainCode.equals("a") || trainCode.equals("b") || trainCode.equals("bx") || trainCode.equals("c") ||  
                                 trainCode.equals("e") || trainCode.equals("f") || trainCode.equals("h")) {  
                         return "S2";  
                 } else {  
                         return "FJRN";  
                 }  
         }  
           
76          String formatTimetable(List<TimetableBean> timetable) {          String formatTimetable(List<TimetableBean> timetable) {
77                  StringBuffer sb = new StringBuffer();                  StringBuffer sb = new StringBuffer();
78                    //sb.append("<?xml version=\"1.0\" encoding=\"ISO-8859-1\"?>\n");
79                                    
80                  sb.append("<timetable>");                  sb.append("<timetable>");
81                                    
# Line 75  public class TimetableServlet extends Ht Line 88  public class TimetableServlet extends Ht
88                          sb.append("<station>").append( bean.getStation() ).append("</station>");                          sb.append("<station>").append( bean.getStation() ).append("</station>");
89                          sb.append("<arrival>").append( bean.getArrival() ).append("</arrival>");                          sb.append("<arrival>").append( bean.getArrival() ).append("</arrival>");
90                          sb.append("<departure>").append( bean.getDeparture() ).append("</departure>");                          sb.append("<departure>").append( bean.getDeparture() ).append("</departure>");
91                            sb.append("<stationid>").append( bean.getStationId() ).append("</stationid>");
92                                                    
93                          sb.append("</entry>");                          sb.append("</entry>");
94                  }                  }
Legend:
Removed from v.378  
changed lines
  Added in v.859
  ViewVC Help
Powered by ViewVC 1.1.20