/[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 468 by torben, Thu Oct 22 06:04:45 2009 UTC revision 1060 by torben, Thu Sep 16 13:32:10 2010 UTC
# Line 1  Line 1 
1  package dk.thoerup.traininfoservice.banedk;  package dk.thoerup.traininfoservice.banedk;
2    
3    import java.io.ByteArrayOutputStream;
4  import java.io.IOException;  import java.io.IOException;
5  import java.util.List;  
6  import java.util.logging.Level;  import java.util.logging.Level;
7  import java.util.logging.Logger;  import java.util.logging.Logger;
8    
9  import javax.servlet.ServletException;  import javax.servlet.ServletException;
10    import javax.servlet.annotation.WebServlet;
11  import javax.servlet.http.HttpServlet;  import javax.servlet.http.HttpServlet;
12  import javax.servlet.http.HttpServletRequest;  import javax.servlet.http.HttpServletRequest;
13  import javax.servlet.http.HttpServletResponse;  import javax.servlet.http.HttpServletResponse;
14    
15    import org.simpleframework.xml.Serializer;
16    import org.simpleframework.xml.core.Persister;
17    
18  import dk.thoerup.circuitbreaker.CircuitBreakerException;  import dk.thoerup.circuitbreaker.CircuitBreakerException;
19    import dk.thoerup.traininfoservice.Statistics;
20    
21  /**  /**
22   * Servlet implementation class TimetableServlet   * Servlet implementation class TimetableServlet
23   */   */
24    @WebServlet(urlPatterns={"/TimetableServlet"})
25  public class TimetableServlet extends HttpServlet {  public class TimetableServlet extends HttpServlet {
26          private static final long serialVersionUID = 1L;          private static final long serialVersionUID = 1L;
27                
28                    
29          Logger logger = Logger.getLogger( TimetableServlet.class.getName() );          Logger logger = Logger.getLogger( TimetableServlet.class.getName() );
30                    
31          TimetableFetcher fetcher = new TimetableFetcher();          TimetableFetcher fetcher;
32            
33            
34            @Override
35            public void init() throws ServletException {
36                    super.init();
37                    
38                    boolean useAzureSite =  Boolean.parseBoolean( getServletContext().getInitParameter("useazuresite") );
39                    int cacheTimeout =  Integer.parseInt( getServletContext().getInitParameter("cache_timeout") );
40                    int replyTimeout =  Integer.parseInt( getServletContext().getInitParameter("reply_timeout") );
41                    logger.info( "TimetableServlet, use azure site=" + useAzureSite + ", cache=" + cacheTimeout);
42                    fetcher = new TimetableFetcher(useAzureSite,cacheTimeout,replyTimeout);
43            }
44                    
45          @Override          @Override
46          protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {          protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
47                  if (request.getParameter("train") == null) {                  if (request.getParameter("train") == null) {
48                          response.sendError(400, "not enough parameters");                          response.sendError(400, "not enough parameters (train)");
49                          return;                          return;
50                  }                  }
51                                    if (request.getParameter("type") == null) {
52                  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");  
53                          return;                          return;
54                  }                  }
55                    Statistics.getInstance().incrementTimetableLookups();
56                                    
57                  String type = lookupType(sections[0]);                  String train = request.getParameter("train").trim();
58                  String trainID = sections[1];                  String type = request.getParameter("type").trim();
59                                    
60                  try                  try
61                  {                  {
62                          List<TimetableBean> timetable = fetcher.cachedLookupTimetable(trainID, type);                          TimetableBean timetable = fetcher.cachedLookupTimetable(train, type);
63                                    
64                          String responseXML = formatTimetable(timetable);                          String responseXML = formatTimetable(timetable);
65                                    
66                          response.setContentType("text/xml");                          response.setContentType("text/xml");
67                          response.getWriter().print(responseXML);                          response.getWriter().print(responseXML);
68                  } catch (java.io.IOException ioe) {                  } catch (java.io.IOException ioe) {
69                          logger.warning("(timetable) Read failed, train="+train + ". " + ioe.getMessage());                          logger.warning("(timetable) Read failed, type=" + type + ", train="+train + ". " + ioe.getMessage());
70                            Statistics.getInstance().incrementTimetableErrors();
71                          response.sendError(500, "Backend timed out");                          response.sendError(500, "Backend timed out");
72                  } catch (CircuitBreakerException cbe) {                  } catch (CircuitBreakerException cbe) {
73                          logger.warning("Circuitbreaker - failing fast");                          logger.warning("Circuitbreaker - failing fast");
74                            Statistics.getInstance().incrementTimetableErrors();
75                          response.sendError(500);                          response.sendError(500);
76                  }catch (Exception e) {                  }catch (Exception e) {
77                          logger.log(Level.WARNING, "failure looking up timetable: train=" +train, e);                          logger.log(Level.WARNING, "failure looking up timetable: type=" + type + ",train=" +train, e);
78                            Statistics.getInstance().incrementTimetableErrors();
79                          response.sendError(500);                          response.sendError(500);
80                  }                  }
81                                    
82          }          }
83                    
84          String lookupType(String trainCode) {          String formatTimetable(TimetableBean timetable) throws ServletException {
85                  trainCode = trainCode.toLowerCase();                  Serializer serializer = new Persister();
86                    
87                  if (trainCode.equals("a") || trainCode.equals("b") || trainCode.equals("bx") || trainCode.equals("c") ||                  ByteArrayOutputStream out = new ByteArrayOutputStream();
88                                  trainCode.equals("e") || trainCode.equals("f") || trainCode.equals("h")) {  
89                          return "S2";                  try {
90                  } else {                          serializer.write(timetable, out);
91                          return "FJRN";                  } catch (Exception e) {
92                  }                          throw new ServletException(e);
         }  
           
         String formatTimetable(List<TimetableBean> timetable) {  
                 StringBuffer sb = new StringBuffer();  
                   
                 sb.append("<timetable>");  
                   
                 for (TimetableBean bean : timetable) {  
                         sb.append("<entry");  
                         if (bean.isCurrent())  
                                 sb.append(" current=\"true\"");  
                         sb.append(">");  
                           
                         sb.append("<station>").append( bean.getStation() ).append("</station>");  
                         sb.append("<arrival>").append( bean.getArrival() ).append("</arrival>");  
                         sb.append("<departure>").append( bean.getDeparture() ).append("</departure>");  
                           
                         sb.append("</entry>");  
93                  }                  }
94                                    
95                  sb.append("</timetable>");                  return out.toString();
                   
                 return sb.toString();  
96          }          }
97    
98  }  }
Legend:
Removed from v.468  
changed lines
  Added in v.1060
  ViewVC Help
Powered by ViewVC 1.1.20