--- android/TrainInfoService/src/dk/thoerup/traininfoservice/RequestPlotter.java 2010/06/24 16:29:44 893 +++ android/TrainInfoService/src/dk/thoerup/traininfoservice/RequestPlotter.java 2011/04/19 16:31:11 1311 @@ -4,12 +4,14 @@ import java.io.ByteArrayOutputStream; import java.io.File; import java.io.FileInputStream; +import java.io.FilenameFilter; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.ArrayList; +import java.util.Arrays; import java.util.Date; import java.util.List; import java.util.Map; @@ -20,12 +22,14 @@ import java.util.zip.ZipOutputStream; import javax.servlet.ServletException; +import javax.servlet.annotation.WebServlet; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import dk.thoerup.traininfoservice.banedk.TimeoutMap; +@WebServlet(urlPatterns={"/RequestPlotter"}) public class RequestPlotter extends HttpServlet { private static final long serialVersionUID = 1L; @@ -34,7 +38,7 @@ static final String KML = "application/vnd.google-earth.kml"; static final String KMZ = "application/vnd.google-earth.kmz"; - Map cache = new TimeoutMap(2*60*1000); + Map cache = new TimeoutMap(30*60*1000); class RequestPosition { public String ip; @@ -44,6 +48,7 @@ } class PositionContainer { + List blue = new ArrayList(); List green = new ArrayList(); List yellow = new ArrayList(); List red = new ArrayList(); @@ -53,7 +58,123 @@ boolean isGz(String fileStr) { return fileStr.substring(fileStr.length() - 3).equals(".gz"); } + + protected File[] getFiles(int count) { + File accessLogDir = new File("/home/app/domain1/logs/access/"); + //File accessLogDir = new File("/home/torben/inst/glassfishv3/glassfish/domains/domain1/logs/access/"); + + File logFiles[] = accessLogDir.listFiles( new FilenameFilter() { + @Override + public boolean accept(File dir, String name) { + //log.info("name:" + name); + return name.startsWith("server_access_log"); + } + }); + + Arrays.sort(logFiles); + + if (logFiles == null) { + File[] empty = {}; + log.info("file array was empty"); + return empty; + } + + int from = logFiles.length - (count); + int to = logFiles.length; + + return Arrays.copyOfRange(logFiles, from, to); + } + + protected PositionContainer getRequestsFromFileWorker(boolean multiple) throws IOException{ + PositionContainer positions = new PositionContainer(); + + try { + + int count; + + if (multiple == false) { + count = 1; + } else { + count = 4; + } + + File files[] = getFiles(count); + + SimpleDateFormat df = new SimpleDateFormat("dd/MMM/yyyy:HH:mm:ss"); + + Date now = new Date(); + for (File f : files ) { + log.info("Parsing file: " + f.getName() ); + + if ( !f.exists() ) { + continue; + } + + + InputStream input = new FileInputStream(f); + + + BufferedReader in = new BufferedReader( new InputStreamReader(input) ); + + + String line; + while ( (line=in.readLine()) != null) { + if (line.indexOf("LocateStation") == -1 ){ + continue; + } + + if (line.indexOf("latitude=") == -1 ) { + continue; + } + + if (line.indexOf("longitude=") == -1) { + continue; + } + + RequestPosition pos = new RequestPosition(); + + String toks[] = line.split(" "); + pos.ip = toks[0].replaceAll("\"", ""); + + pos.time = df.parse( toks[2].replace("\"", "") ); + + String argpart = toks[5].split("\\?")[1]; + + String args[] = argpart.split("&"); + + pos.lat = args[0].split("=")[1]; + pos.lng = args[1].split("=")[1]; + + + long timediff = now.getTime() - pos.time.getTime(); + if ( timediff < (3*60*60*1000) ) { + positions.red.add(pos); //RED + } else if ( timediff < (24*60*60*1000)) { + positions.yellow.add(pos); //YELLOW + } else if ( timediff < (7*24*60*60*1000)) { + positions.green.add(pos); //GREEN + } else { + positions.blue.add(pos); //BLUE + } + + } + in.close(); + input.close(); + + } + } catch (ParseException pe) { + log.log(Level.SEVERE, "parseException", pe); + throw new IOException(pe); + } catch (IOException e) { + log.log(Level.SEVERE, "getKml()", e); + throw e; + } + return positions; + } + + + /* old apache code protected PositionContainer getRequestsFromFileWorker(boolean multiple) throws IOException{ PositionContainer positions = new PositionContainer(); @@ -124,8 +245,10 @@ positions.red.add(pos); //RED } else if ( timediff < (24*60*60*1000)) { positions.yellow.add(pos); //YELLOW - } else { + } else if ( timediff < (7*24*60*60*1000)) { positions.green.add(pos); //GREEN + } else { + positions.blue.add(pos); //BLUE } } @@ -142,19 +265,20 @@ } return positions; - } + }*/ protected void formatPositions(StringBuilder sb, String color, List list) { sb.append( "\n"); sb.append( " " ).append(color).append("\n"); sb.append( " 0\n" ); - sb.append( " Count=").append(list.size()).append("\n"); - for(RequestPosition current : list) { - sb.append( " \n" ); - sb.append( " #" + color + "\n" ); - sb.append( " IP=" + current.ip + " Time=" + current.time + "\n" ); - sb.append( " " + current.lng + "," + current.lat + ",0\n" ); + int count=0; + for(RequestPosition current : list) { + String id = color + count++; + sb.append( " \n" ); + sb.append( " #").append(color).append("\n" ); + sb.append( " Time=").append(current.time).append("]]>\n" ); + sb.append( " ").append(current.lng).append(",").append(current.lat).append(",0\n" ); sb.append( " \n" ); } @@ -162,11 +286,17 @@ } protected String formatXml(PositionContainer positions) { - StringBuilder sb = new StringBuilder(); + StringBuilder sb = new StringBuilder(1024*1024); sb.append( "\n" ); sb.append( "\n" ); sb.append( "\n" ); + sb.append( " \n"); + sb.append( " Yellow:").append(positions.yellow.size()).append(" (within 24 hours)
\n"); + sb.append( " Green:").append(positions.green.size()).append(" (within one week)
\n"); + sb.append( " Blue:").append(positions.blue.size()).append(" (older)
\n"); + sb.append( " ]]>"); sb.append( " \n\n" ); + sb.append( " \n\n" ); /* String overlay = " " + @@ -200,6 +333,7 @@ */ + formatPositions(sb, "blue", positions.blue); formatPositions(sb, "green", positions.green); formatPositions(sb, "yellow", positions.yellow); formatPositions(sb, "red", positions.red); @@ -221,7 +355,7 @@ key = "kmldata-multi"; } - kmlData = cache.get(key); + kmlData = null;// = cache.get(key); if (kmlData == null) { kmlData = formatXml( getRequestsFromFileWorker(multiple) );