/[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 581 by torben, Tue Feb 2 18:47:55 2010 UTC revision 1036 by torben, Wed Sep 8 12:49:22 2010 UTC
# Line 6  import java.util.logging.Level; Line 6  import java.util.logging.Level;
6  import java.util.logging.Logger;  import java.util.logging.Logger;
7    
8  import javax.servlet.ServletException;  import javax.servlet.ServletException;
9    import javax.servlet.annotation.WebServlet;
10  import javax.servlet.http.HttpServlet;  import javax.servlet.http.HttpServlet;
11  import javax.servlet.http.HttpServletRequest;  import javax.servlet.http.HttpServletRequest;
12  import javax.servlet.http.HttpServletResponse;  import javax.servlet.http.HttpServletResponse;
13    
14  import dk.thoerup.circuitbreaker.CircuitBreakerException;  import dk.thoerup.circuitbreaker.CircuitBreakerException;
15    import dk.thoerup.traininfoservice.Statistics;
16    
17  /**  /**
18   * Servlet implementation class TimetableServlet   * Servlet implementation class TimetableServlet
19   */   */
20    @WebServlet(urlPatterns={"/TimetableServlet"})
21  public class TimetableServlet extends HttpServlet {  public class TimetableServlet extends HttpServlet {
22          private static final long serialVersionUID = 1L;          private static final long serialVersionUID = 1L;
23                
# Line 23  public class TimetableServlet extends Ht Line 26  public class TimetableServlet extends Ht
26                    
27          TimetableFetcher fetcher;          TimetableFetcher fetcher;
28                    
29            
30          @Override          @Override
31          public void init() throws ServletException {          public void init() throws ServletException {
32                  super.init();                  super.init();
33                                    
34                  boolean useTempSite =  Boolean.parseBoolean( getInitParameter("usetempsite") );                  boolean useAzureSite =  Boolean.parseBoolean( getServletContext().getInitParameter("useazuresite") );
35                  logger.info( "TimetableServlet, use temp site=" + useTempSite );                  int cacheTimeout =  Integer.parseInt( getServletContext().getInitParameter("cache_timeout") );
36                  fetcher = new TimetableFetcher(useTempSite);                  int replyTimeout =  Integer.parseInt( getServletContext().getInitParameter("reply_timeout") );
37                    logger.info( "TimetableServlet, use azure site=" + useAzureSite + ", cache=" + cacheTimeout);
38                    fetcher = new TimetableFetcher(useAzureSite,cacheTimeout,replyTimeout);
39          }          }
40                    
41          @Override          @Override
42          protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {          protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
43                  if (request.getParameter("train") == null) {                  if (request.getParameter("train") == null) {
44                          response.sendError(400, "not enough parameters");                          response.sendError(400, "not enough parameters (train)");
45                          return;                          return;
46                  }                  }
47                                    if (request.getParameter("type") == null) {
48                  String train = request.getParameter("train").trim();                          response.sendError(400, "not enough parameters (type)");
                   
                 String sections[] = train.split(" ");  
                 if (sections.length != 2) {  
                         response.sendError(400, "Invalid parameter");  
49                          return;                          return;
50                  }                  }
51                    Statistics.getInstance().incrementTimetableLookups();
52                                    
53                  String type = lookupType(sections[0]);                  String train = request.getParameter("train").trim();
54                  String trainID = sections[1];                  String type = request.getParameter("type").trim();
55                                    
56                  try                  try
57                  {                  {
58                          List<TimetableBean> timetable = fetcher.cachedLookupTimetable(trainID, type);                          List<TimetableBean> timetable = fetcher.cachedLookupTimetable(train, type);
59                                    
60                          String responseXML = formatTimetable(timetable);                          String responseXML = formatTimetable(timetable);
61                                    
62                          response.setContentType("text/xml");                          response.setContentType("text/xml");
63                          response.getWriter().print(responseXML);                          response.getWriter().print(responseXML);
64                  } catch (java.io.IOException ioe) {                  } catch (java.io.IOException ioe) {
65                          logger.warning("(timetable) Read failed, train="+train + ". " + ioe.getMessage());                          logger.warning("(timetable) Read failed, type=" + type + ", train="+train + ". " + ioe.getMessage());
66                            Statistics.getInstance().incrementTimetableErrors();
67                          response.sendError(500, "Backend timed out");                          response.sendError(500, "Backend timed out");
68                  } catch (CircuitBreakerException cbe) {                  } catch (CircuitBreakerException cbe) {
69                          logger.warning("Circuitbreaker - failing fast");                          logger.warning("Circuitbreaker - failing fast");
70                            Statistics.getInstance().incrementTimetableErrors();
71                          response.sendError(500);                          response.sendError(500);
72                  }catch (Exception e) {                  }catch (Exception e) {
73                          logger.log(Level.WARNING, "failure looking up timetable: train=" +train, e);                          logger.log(Level.WARNING, "failure looking up timetable: type=" + type + ",train=" +train, e);
74                            Statistics.getInstance().incrementTimetableErrors();
75                          response.sendError(500);                          response.sendError(500);
76                  }                  }
77                                    
78          }          }
79                    
         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";  
                 }  
         }  
           
80          String formatTimetable(List<TimetableBean> timetable) {          String formatTimetable(List<TimetableBean> timetable) {
81                  StringBuffer sb = new StringBuffer();                  StringBuffer sb = new StringBuffer();
82                    //sb.append("<?xml version=\"1.0\" encoding=\"ISO-8859-1\"?>\n");
83                                    
84                  sb.append("<timetable>");                  sb.append("<timetable>");
85                                    
# Line 95  public class TimetableServlet extends Ht Line 92  public class TimetableServlet extends Ht
92                          sb.append("<station>").append( bean.getStation() ).append("</station>");                          sb.append("<station>").append( bean.getStation() ).append("</station>");
93                          sb.append("<arrival>").append( bean.getArrival() ).append("</arrival>");                          sb.append("<arrival>").append( bean.getArrival() ).append("</arrival>");
94                          sb.append("<departure>").append( bean.getDeparture() ).append("</departure>");                          sb.append("<departure>").append( bean.getDeparture() ).append("</departure>");
95                                                    sb.append("<stationid>").append( bean.getStationId() ).append("</stationid>");
96                            //sb.append("<cancelled>").append( bean.isCancelled() ).append("</cancelled>");
97                          sb.append("</entry>");                          sb.append("</entry>");
98                  }                  }
99                                    
Legend:
Removed from v.581  
changed lines
  Added in v.1036
  ViewVC Help
Powered by ViewVC 1.1.20