datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/StatisticsServlet.java

   1 /*******************************************************************************\r
   2  * ============LICENSE_START==================================================\r
   3  * * org.onap.dmaap\r
   4  * * ===========================================================================\r
   5  * * Copyright © 2017 AT&T Intellectual Property. All rights reserved.\r
   6  * * ===========================================================================\r
   7  * * Licensed under the Apache License, Version 2.0 (the "License");\r
   8  * * you may not use this file except in compliance with the License.\r
   9  * * You may obtain a copy of the License at\r
  10  * *\r
  11  *  *      http://www.apache.org/licenses/LICENSE-2.0\r
  12  * *\r
  13  *  * Unless required by applicable law or agreed to in writing, software\r
  14  * * distributed under the License is distributed on an "AS IS" BASIS,\r
  15  * * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
  16  * * See the License for the specific language governing permissions and\r
  17  * * limitations under the License.\r
  18  * * ============LICENSE_END====================================================\r
  19  * *\r
  20  * * ECOMP is a trademark and service mark of AT&T Intellectual Property.\r
  21  * *\r
  22  ******************************************************************************/\r
  23 \r
  24 package org.onap.dmaap.datarouter.provisioning;\r
  25 \r
  26 import java.io.IOException;\r
  27 import java.sql.Connection;\r
  28 import java.sql.PreparedStatement;\r
  29 import java.sql.ResultSet;\r
  30 import java.sql.SQLException;\r
  31 import java.sql.Statement;\r
  32 import java.text.ParseException;\r
  33 import java.text.SimpleDateFormat;\r
  34 import java.util.Calendar;\r
  35 import java.util.Date;\r
  36 import java.util.HashMap;\r
  37 import java.util.Map;\r
  38 import java.util.TimeZone;\r
  39 import javax.servlet.ServletOutputStream;\r
  40 import javax.servlet.http.HttpServletRequest;\r
  41 import javax.servlet.http.HttpServletResponse;\r
  42 import org.json.JSONException;\r
  43 import org.onap.dmaap.datarouter.provisioning.beans.EventLogRecord;\r
  44 import org.onap.dmaap.datarouter.provisioning.utils.DB;\r
  45 import org.onap.dmaap.datarouter.provisioning.utils.LOGJSONObject;\r
  46 \r
  47 /**\r
  48  * This Servlet handles requests to the &lt;Statistics API&gt; and  &lt;Statistics consilidated\r
  49  * resultset&gt;,\r
  50  *\r
  51  * @author Manish Singh\r
  52  * @version $Id: StatisticsServlet.java,v 1.11 2016/08/10 17:27:02 Manish Exp $\r
  53  */\r
  54 @SuppressWarnings("serial")\r
  55 \r
  56 public class StatisticsServlet extends BaseServlet {\r
  57 \r
  58   private static final long TWENTYFOUR_HOURS = (24 * 60 * 60 * 1000L);\r
  59   private static final String fmt1 = "yyyy-MM-dd'T'HH:mm:ss'Z'";\r
  60   private static final String fmt2 = "yyyy-MM-dd'T'HH:mm:ss.SSS'Z'";\r
  61 \r
  62 \r
  63   /**\r
  64    * DELETE a logging URL -- not supported.\r
  65    */\r
  66   @Override\r
  67   public void doDelete(HttpServletRequest req, HttpServletResponse resp) throws IOException {\r
  68     String message = "DELETE not allowed for the logURL.";\r
  69     EventLogRecord elr = new EventLogRecord(req);\r
  70     elr.setMessage(message);\r
  71     elr.setResult(HttpServletResponse.SC_METHOD_NOT_ALLOWED);\r
  72     eventlogger.info(elr);\r
  73     resp.sendError(HttpServletResponse.SC_METHOD_NOT_ALLOWED, message);\r
  74   }\r
  75 \r
  76   /**\r
  77    * GET a Statistics URL -- retrieve Statistics data for a feed or subscription. See the\r
  78    * <b>Statistics API</b> document for details on how this     method should be invoked.\r
  79    */\r
  80   @Override\r
  81   public void doGet(HttpServletRequest req, HttpServletResponse resp) throws IOException {\r
  82 \r
  83     Map<String, String> map = buildMapFromRequest(req);\r
  84     if (map.get("err") != null) {\r
  85       resp.sendError(HttpServletResponse.SC_BAD_REQUEST, "Invalid arguments: " + map.get("err"));\r
  86       return;\r
  87     }\r
  88     // check Accept: header??\r
  89 \r
  90     resp.setStatus(HttpServletResponse.SC_OK);\r
  91     resp.setContentType(LOGLIST_CONTENT_TYPE);\r
  92     ServletOutputStream out = resp.getOutputStream();\r
  93 \r
  94     String outputType = "json";\r
  95     String feedids = null;\r
  96 \r
  97     if (req.getParameter("feedid") == null && req.getParameter("groupid") == null) {\r
  98       out.print("Invalid request, Feedid or Group ID is required.");\r
  99     }\r
 100 \r
 101     if (req.getParameter("feedid") != null && req.getParameter("groupid") == null) {\r
 102       map.put("feedids", req.getParameter("feedid").replace("|", ",").toString());\r
 103     }\r
 104 \r
 105     if (req.getParameter("groupid") != null && req.getParameter("feedid") == null) {\r
 106       StringBuffer groupid1 = new StringBuffer();\r
 107 \r
 108       try {\r
 109         System.out.println("feeedidsssssssss");\r
 110         groupid1 = this.getFeedIdsByGroupId(Integer.parseInt(req.getParameter("groupid")));\r
 111         System.out.println("feeedids" + req.getParameter("groupid"));\r
 112 \r
 113         map.put("feedids", groupid1.toString());\r
 114         System.out.println("groupid1" + groupid1.toString());\r
 115 \r
 116 \r
 117       } catch (NumberFormatException e) {\r
 118         e.printStackTrace();\r
 119       } catch (SQLException e) {\r
 120         e.printStackTrace();\r
 121       }\r
 122     }\r
 123     if (req.getParameter("groupid") != null && req.getParameter("feedid") != null) {\r
 124       StringBuffer groupid1 = new StringBuffer();\r
 125 \r
 126       try {\r
 127         System.out.println("both r not null");\r
 128         groupid1 = this.getFeedIdsByGroupId(Integer.parseInt(req.getParameter("groupid")));\r
 129         System.out.println("feeedids" + req.getParameter("groupid"));\r
 130         groupid1.append(",");\r
 131         groupid1.append(req.getParameter("feedid").replace("|", ",").toString());\r
 132 \r
 133         map.put("feedids", groupid1.toString());\r
 134 \r
 135         System.out.println("groupid1" + groupid1.toString());\r
 136 \r
 137 \r
 138       } catch (NumberFormatException e) {\r
 139         e.printStackTrace();\r
 140       } catch (SQLException e) {\r
 141         e.printStackTrace();\r
 142       }\r
 143     }\r
 144 \r
 145     if (req.getParameter("subid") != null && req.getParameter("feedid") != null) {\r
 146       StringBuffer subidstr = new StringBuffer();\r
 147       subidstr.append("and e.DELIVERY_SUBID in(");\r
 148 \r
 149       subidstr.append(req.getParameter("subid").replace("|", ",").toString());\r
 150       subidstr.append(")");\r
 151       map.put("subid", subidstr.toString());\r
 152     }\r
 153     if (req.getParameter("subid") != null && req.getParameter("groupid") != null) {\r
 154       StringBuffer subidstr = new StringBuffer();\r
 155       subidstr.append("and e.DELIVERY_SUBID in(");\r
 156 \r
 157       subidstr.append(req.getParameter("subid").replace("|", ",").toString());\r
 158       subidstr.append(")");\r
 159       map.put("subid", subidstr.toString());\r
 160     }\r
 161     if (req.getParameter("type") != null) {\r
 162       map.put("eventType", req.getParameter("type").replace("|", ",").toString());\r
 163     }\r
 164     if (req.getParameter("output_type") != null) {\r
 165       map.put("output_type", req.getParameter("output_type").toString());\r
 166     }\r
 167     if (req.getParameter("start_time") != null) {\r
 168       map.put("start_time", req.getParameter("start_time").toString());\r
 169     }\r
 170     if (req.getParameter("end_time") != null) {\r
 171       map.put("end_time", req.getParameter("end_time").toString());\r
 172     }\r
 173 \r
 174     if (req.getParameter("time") != null) {\r
 175       map.put("start_time", req.getParameter("time").toString());\r
 176       map.put("end_time", null);\r
 177     }\r
 178 \r
 179     if (req.getParameter("output_type") != null) {\r
 180       outputType = req.getParameter("output_type");\r
 181     }\r
 182 \r
 183     this.getRecordsForSQL(map, outputType, out, resp);\r
 184 \r
 185   }\r
 186 \r
 187 \r
 188   /**\r
 189    * rsToJson - Converting RS to JSON object\r
 190    *\r
 191    * @param out ServletOutputStream, rs as ResultSet\r
 192    * @throws IOException, SQLException\r
 193    */\r
 194   public void rsToCSV(ResultSet rs, ServletOutputStream out) throws IOException, SQLException {\r
 195     String header = "FEEDNAME,FEEDID,FILES_PUBLISHED,PUBLISH_LENGTH, FILES_DELIVERED, DELIVERED_LENGTH, SUBSCRIBER_URL, SUBID, PUBLISH_TIME,DELIVERY_TIME, AverageDelay\n";\r
 196 \r
 197     out.write(header.getBytes());\r
 198 \r
 199     while (rs.next()) {\r
 200       StringBuffer line = new StringBuffer();\r
 201       line.append(rs.getString("FEEDNAME"));\r
 202       line.append(",");\r
 203       line.append(rs.getString("FEEDID"));\r
 204       line.append(",");\r
 205       line.append(rs.getString("FILES_PUBLISHED"));\r
 206       line.append(",");\r
 207       line.append(rs.getString("PUBLISH_LENGTH"));\r
 208       line.append(",");\r
 209       line.append(rs.getString("FILES_DELIVERED"));\r
 210       line.append(",");\r
 211       line.append(rs.getString("DELIVERED_LENGTH"));\r
 212       line.append(",");\r
 213       line.append(rs.getString("SUBSCRIBER_URL"));\r
 214       line.append(",");\r
 215       line.append(rs.getString("SUBID"));\r
 216       line.append(",");\r
 217       line.append(rs.getString("PUBLISH_TIME"));\r
 218       line.append(",");\r
 219       line.append(rs.getString("DELIVERY_TIME"));\r
 220       line.append(",");\r
 221       line.append(rs.getString("AverageDelay"));\r
 222       line.append(",");\r
 223 \r
 224       line.append("\n");\r
 225       out.write(line.toString().getBytes());\r
 226       out.flush();\r
 227     }\r
 228   }\r
 229 \r
 230   /**\r
 231    * rsToJson - Converting RS to JSON object\r
 232    *\r
 233    * @param out ServletOutputStream, rs as ResultSet\r
 234    * @throws IOException, SQLException\r
 235    */\r
 236   public void rsToJson(ResultSet rs, ServletOutputStream out) throws IOException, SQLException {\r
 237 \r
 238     String fields[] = {"FEEDNAME", "FEEDID", "FILES_PUBLISHED", "PUBLISH_LENGTH", "FILES_DELIVERED",\r
 239         "DELIVERED_LENGTH", "SUBSCRIBER_URL", "SUBID", "PUBLISH_TIME", "DELIVERY_TIME",\r
 240         "AverageDelay"};\r
 241     StringBuffer line = new StringBuffer();\r
 242 \r
 243     line.append("[\n");\r
 244 \r
 245     while (rs.next()) {\r
 246       LOGJSONObject j2 = new LOGJSONObject();\r
 247       for (String key : fields) {\r
 248         Object v = rs.getString(key);\r
 249         if (v != null) {\r
 250           j2.put(key.toLowerCase(), v);\r
 251         } else {\r
 252           j2.put(key.toLowerCase(), "");\r
 253         }\r
 254       }\r
 255       line = line.append(j2.toString());\r
 256       line.append(",\n");\r
 257     }\r
 258     line.append("]");\r
 259     out.print(line.toString());\r
 260   }\r
 261 \r
 262   /**\r
 263    * getFeedIdsByGroupId - Getting FEEDID's by GROUP ID.\r
 264    *\r
 265    * @throws SQLException Query SQLException.\r
 266    */\r
 267   public StringBuffer getFeedIdsByGroupId(int groupIds) throws SQLException {\r
 268 \r
 269     DB db = null;\r
 270     Connection conn = null;\r
 271     //PreparedStatement prepareStatement = null;\r
 272     ResultSet resultSet = null;\r
 273     String sqlGoupid = null;\r
 274     StringBuffer feedIds = new StringBuffer();\r
 275 \r
 276     try {\r
 277       db = new DB();\r
 278       conn = db.getConnection();\r
 279       sqlGoupid = " SELECT FEEDID from FEEDS  WHERE GROUPID = ?";\r
 280       try(PreparedStatement prepareStatement = conn.prepareStatement(sqlGoupid)) {\r
 281           prepareStatement.setInt(1, groupIds);\r
 282           resultSet = prepareStatement.executeQuery();\r
 283           while (resultSet.next()) {\r
 284               feedIds.append(resultSet.getInt("FEEDID"));\r
 285               feedIds.append(",");\r
 286           }\r
 287           feedIds.deleteCharAt(feedIds.length() - 1);\r
 288           System.out.println("feedIds" + feedIds.toString());\r
 289       }\r
 290     } catch (SQLException e) {\r
 291       e.printStackTrace();\r
 292     } finally {\r
 293       try {\r
 294         if (resultSet != null) {\r
 295           resultSet.close();\r
 296           resultSet = null;\r
 297         }\r
 298           if (conn != null) {\r
 299           db.release(conn);\r
 300         }\r
 301       } catch (Exception e) {\r
 302         e.printStackTrace();\r
 303       }\r
 304     }\r
 305     return feedIds;\r
 306   }\r
 307 \r
 308 \r
 309   /**\r
 310    * queryGeneretor - Generating sql query\r
 311    *\r
 312    * @param map as key value pare of all user input fields\r
 313    */\r
 314   public String queryGeneretor(Map<String, String> map) throws ParseException {\r
 315 \r
 316     String sql = null;\r
 317     String eventType = null;\r
 318     String feedids = null;\r
 319     String start_time = null;\r
 320     String end_time = null;\r
 321     String subid = " ";\r
 322     if (map.get("eventType") != null) {\r
 323       eventType = (String) map.get("eventType");\r
 324     }\r
 325     if (map.get("feedids") != null) {\r
 326       feedids = (String) map.get("feedids");\r
 327     }\r
 328     if (map.get("start_time") != null) {\r
 329       start_time = (String) map.get("start_time");\r
 330     }\r
 331     if (map.get("end_time") != null) {\r
 332       end_time = (String) map.get("end_time");\r
 333     }\r
 334     if ("all".equalsIgnoreCase(eventType)) {\r
 335       eventType = "PUB','DEL, EXP, PBF";\r
 336     }\r
 337     if (map.get("subid") != null) {\r
 338       subid = (String) map.get("subid");\r
 339     }\r
 340 \r
 341     eventlogger.info("Generating sql query to get Statistics resultset. ");\r
 342 \r
 343     if (end_time == null && start_time == null) {\r
 344 \r
 345       sql = "SELECT (SELECT NAME FROM FEEDS AS f WHERE f.FEEDID in(" + feedids\r
 346           + ") and f.FEEDID=e.FEEDID) AS FEEDNAME, e.FEEDID as FEEDID, (SELECT COUNT(*) FROM LOG_RECORDS AS c WHERE c.FEEDID in("\r
 347           + feedids\r
 348           + ") and c.FEEDID=e.FEEDID AND c.TYPE='PUB') AS FILES_PUBLISHED,(SELECT SUM(content_length) FROM LOG_RECORDS AS c WHERE c.FEEDID in("\r
 349           + feedids\r
 350           + ")  and c.FEEDID=e.FEEDID AND c.TYPE='PUB') AS PUBLISH_LENGTH, COUNT(e.EVENT_TIME) as FILES_DELIVERED,  sum(m.content_length) as DELIVERED_LENGTH,SUBSTRING_INDEX(e.REQURI,'/',+3) as SUBSCRIBER_URL, e.DELIVERY_SUBID as SUBID, e.EVENT_TIME AS PUBLISH_TIME, m.EVENT_TIME AS DELIVERY_TIME,  AVG(e.EVENT_TIME - m.EVENT_TIME)/1000 as AverageDelay FROM LOG_RECORDS e JOIN LOG_RECORDS m ON m.PUBLISH_ID = e.PUBLISH_ID AND e.FEEDID IN ("\r
 351           + feedids + ") " + subid + " AND m.STATUS=204 AND e.RESULT=204  group by SUBID";\r
 352 \r
 353       return sql;\r
 354     } else if (start_time != null && end_time == null) {\r
 355 \r
 356       long inputTimeInMilli = 60000 * Long.parseLong(start_time);\r
 357       Calendar cal = Calendar.getInstance(TimeZone.getTimeZone("GMT"));\r
 358       long currentTimeInMilli = cal.getTimeInMillis();\r
 359       long compareTime = currentTimeInMilli - inputTimeInMilli;\r
 360 \r
 361       sql = "SELECT (SELECT NAME FROM FEEDS AS f WHERE f.FEEDID in(" + feedids\r
 362           + ") and f.FEEDID=e.FEEDID) AS FEEDNAME, e.FEEDID as FEEDID, (SELECT COUNT(*) FROM LOG_RECORDS AS c WHERE c.FEEDID in("\r
 363           + feedids\r
 364           + ") and c.FEEDID=e.FEEDID AND c.TYPE='PUB') AS FILES_PUBLISHED,(SELECT SUM(content_length) FROM LOG_RECORDS AS c WHERE c.FEEDID in("\r
 365           + feedids\r
 366           + ")  and c.FEEDID=e.FEEDID AND c.TYPE='PUB') AS PUBLISH_LENGTH, COUNT(e.EVENT_TIME) as FILES_DELIVERED,  sum(m.content_length) as DELIVERED_LENGTH,SUBSTRING_INDEX(e.REQURI,'/',+3) as SUBSCRIBER_URL, e.DELIVERY_SUBID as SUBID, e.EVENT_TIME AS PUBLISH_TIME, m.EVENT_TIME AS DELIVERY_TIME,  AVG(e.EVENT_TIME - m.EVENT_TIME)/1000 as AverageDelay FROM LOG_RECORDS e JOIN LOG_RECORDS m ON m.PUBLISH_ID = e.PUBLISH_ID AND e.FEEDID IN ("\r
 367           + feedids + ") " + subid + " AND m.STATUS=204 AND e.RESULT=204 and e.event_time>="\r
 368           + compareTime + " group by SUBID";\r
 369 \r
 370       return sql;\r
 371 \r
 372     } else {\r
 373       SimpleDateFormat inFormat = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss");\r
 374       Date startDate = inFormat.parse(start_time);\r
 375       Date endDate = inFormat.parse(end_time);\r
 376 \r
 377       long startInMillis = startDate.getTime();\r
 378       long endInMillis = endDate.getTime();\r
 379 \r
 380       {\r
 381 \r
 382         sql = "SELECT (SELECT NAME FROM FEEDS AS f WHERE f.FEEDID in(" + feedids\r
 383             + ") and f.FEEDID=e.FEEDID) AS FEEDNAME, e.FEEDID as FEEDID, (SELECT COUNT(*) FROM LOG_RECORDS AS c WHERE c.FEEDID in("\r
 384             + feedids\r
 385             + ") and c.FEEDID=e.FEEDID AND c.TYPE='PUB') AS FILES_PUBLISHED,(SELECT SUM(content_length) FROM LOG_RECORDS AS c WHERE c.FEEDID in("\r
 386             + feedids\r
 387             + ")  and c.FEEDID=e.FEEDID AND c.TYPE='PUB') AS PUBLISH_LENGTH, COUNT(e.EVENT_TIME) as FILES_DELIVERED,  sum(m.content_length) as DELIVERED_LENGTH,SUBSTRING_INDEX(e.REQURI,'/',+3) as SUBSCRIBER_URL, e.DELIVERY_SUBID as SUBID, e.EVENT_TIME AS PUBLISH_TIME, m.EVENT_TIME AS DELIVERY_TIME,  AVG(e.EVENT_TIME - m.EVENT_TIME)/1000 as AverageDelay FROM LOG_RECORDS e JOIN LOG_RECORDS m ON m.PUBLISH_ID = e.PUBLISH_ID AND e.FEEDID IN ("\r
 388             + feedids + ") " + subid\r
 389             + " AND m.STATUS=204 AND e.RESULT=204 and e.event_time between " + startInMillis\r
 390             + " and " + endInMillis + " group by SUBID";\r
 391 \r
 392       }\r
 393       return sql;\r
 394     }\r
 395   }\r
 396 \r
 397 \r
 398   /**\r
 399    * PUT a Statistics URL -- not supported.\r
 400    */\r
 401   @Override\r
 402   public void doPut(HttpServletRequest req, HttpServletResponse resp) throws IOException {\r
 403     String message = "PUT not allowed for the StatisticsURL.";\r
 404     EventLogRecord elr = new EventLogRecord(req);\r
 405     elr.setMessage(message);\r
 406     elr.setResult(HttpServletResponse.SC_METHOD_NOT_ALLOWED);\r
 407     eventlogger.info(elr);\r
 408     resp.sendError(HttpServletResponse.SC_METHOD_NOT_ALLOWED, message);\r
 409   }\r
 410 \r
 411   /**\r
 412    * POST a Statistics URL -- not supported.\r
 413    */\r
 414   @Override\r
 415   public void doPost(HttpServletRequest req, HttpServletResponse resp) throws IOException {\r
 416     String message = "POST not allowed for the StatisticsURL.";\r
 417     EventLogRecord elr = new EventLogRecord(req);\r
 418     elr.setMessage(message);\r
 419     elr.setResult(HttpServletResponse.SC_METHOD_NOT_ALLOWED);\r
 420     eventlogger.info(elr);\r
 421     resp.sendError(HttpServletResponse.SC_METHOD_NOT_ALLOWED, message);\r
 422   }\r
 423 \r
 424   private Map<String, String> buildMapFromRequest(HttpServletRequest req) {\r
 425     Map<String, String> map = new HashMap<String, String>();\r
 426     String s = req.getParameter("type");\r
 427     if (s != null) {\r
 428       if (s.equals("pub") || s.equals("del") || s.equals("exp")) {\r
 429         map.put("type", s);\r
 430       } else {\r
 431         map.put("err", "bad type");\r
 432         return map;\r
 433       }\r
 434     } else {\r
 435       map.put("type", "all");\r
 436     }\r
 437     map.put("publishSQL", "");\r
 438     map.put("statusSQL", "");\r
 439     map.put("resultSQL", "");\r
 440     map.put("reasonSQL", "");\r
 441 \r
 442     s = req.getParameter("publishId");\r
 443     if (s != null) {\r
 444       if (s.indexOf("'") >= 0) {\r
 445         map.put("err", "bad publishId");\r
 446         return map;\r
 447       }\r
 448       map.put("publishSQL", " AND PUBLISH_ID = '" + s + "'");\r
 449     }\r
 450 \r
 451     s = req.getParameter("statusCode");\r
 452     if (s != null) {\r
 453       String sql = null;\r
 454       if (s.equals("success")) {\r
 455         sql = " AND STATUS >= 200 AND STATUS < 300";\r
 456       } else if (s.equals("redirect")) {\r
 457         sql = " AND STATUS >= 300 AND STATUS < 400";\r
 458       } else if (s.equals("failure")) {\r
 459         sql = " AND STATUS >= 400";\r
 460       } else {\r
 461         try {\r
 462           Integer n = Integer.parseInt(s);\r
 463           if ((n >= 100 && n < 600) || (n == -1)) {\r
 464             sql = " AND STATUS = " + n;\r
 465           }\r
 466         } catch (NumberFormatException e) {\r
 467         }\r
 468       }\r
 469       if (sql == null) {\r
 470         map.put("err", "bad statusCode");\r
 471         return map;\r
 472       }\r
 473       map.put("statusSQL", sql);\r
 474       map.put("resultSQL", sql.replaceAll("STATUS", "RESULT"));\r
 475     }\r
 476 \r
 477     s = req.getParameter("expiryReason");\r
 478     if (s != null) {\r
 479       map.put("type", "exp");\r
 480       if (s.equals("notRetryable")) {\r
 481         map.put("reasonSQL", " AND REASON = 'notRetryable'");\r
 482       } else if (s.equals("retriesExhausted")) {\r
 483         map.put("reasonSQL", " AND REASON = 'retriesExhausted'");\r
 484       } else if (s.equals("diskFull")) {\r
 485         map.put("reasonSQL", " AND REASON = 'diskFull'");\r
 486       } else if (s.equals("other")) {\r
 487         map.put("reasonSQL", " AND REASON = 'other'");\r
 488       } else {\r
 489         map.put("err", "bad expiryReason");\r
 490         return map;\r
 491       }\r
 492     }\r
 493 \r
 494     long stime = getTimeFromParam(req.getParameter("start"));\r
 495     if (stime < 0) {\r
 496       map.put("err", "bad start");\r
 497       return map;\r
 498     }\r
 499     long etime = getTimeFromParam(req.getParameter("end"));\r
 500     if (etime < 0) {\r
 501       map.put("err", "bad end");\r
 502       return map;\r
 503     }\r
 504     if (stime == 0 && etime == 0) {\r
 505       etime = System.currentTimeMillis();\r
 506       stime = etime - TWENTYFOUR_HOURS;\r
 507     } else if (stime == 0) {\r
 508       stime = etime - TWENTYFOUR_HOURS;\r
 509     } else if (etime == 0) {\r
 510       etime = stime + TWENTYFOUR_HOURS;\r
 511     }\r
 512     map.put("timeSQL", String.format(" AND EVENT_TIME >= %d AND EVENT_TIME <= %d", stime, etime));\r
 513     return map;\r
 514   }\r
 515 \r
 516   private long getTimeFromParam(final String s) {\r
 517     if (s == null) {\r
 518       return 0;\r
 519     }\r
 520     try {\r
 521       // First, look for an RFC 3339 date\r
 522       String fmt = (s.indexOf('.') > 0) ? fmt2 : fmt1;\r
 523       SimpleDateFormat sdf = new SimpleDateFormat(fmt);\r
 524       Date d = sdf.parse(s);\r
 525       return d.getTime();\r
 526     } catch (ParseException e) {\r
 527     }\r
 528     try {\r
 529       // Also allow a long (in ms); useful for testing\r
 530       long n = Long.parseLong(s);\r
 531       return n;\r
 532     } catch (NumberFormatException e) {\r
 533     }\r
 534     intlogger.info("Error parsing time=" + s);\r
 535     return -1;\r
 536   }\r
 537 \r
 538   private void getRecordsForSQL(Map<String, String> map, String outputType, ServletOutputStream out, HttpServletResponse resp) {\r
 539     try {\r
 540 \r
 541       String filterQuery = this.queryGeneretor(map);\r
 542       eventlogger.debug("SQL Query for Statistics resultset. " + filterQuery);\r
 543       intlogger.debug(filterQuery);\r
 544       long start = System.currentTimeMillis();\r
 545       DB db = new DB();\r
 546       ResultSet rs = null;\r
 547       try (Connection conn = db.getConnection()) {\r
 548         try (PreparedStatement pst = conn.prepareStatement(filterQuery)) {\r
 549           rs = pst.executeQuery();\r
 550           if (outputType.equals("csv")) {\r
 551             resp.setContentType("application/octet-stream");\r
 552             Date date = new Date();\r
 553             SimpleDateFormat dateFormat = new SimpleDateFormat("dd-MM-YYYY HH:mm:ss");\r
 554             resp.setHeader("Content-Disposition",\r
 555                     "attachment; filename=\"result:" + dateFormat.format(date) + ".csv\"");\r
 556             eventlogger.info("Generating CSV file from Statistics resultset");\r
 557 \r
 558             rsToCSV(rs, out);\r
 559           } else {\r
 560             eventlogger.info("Generating JSON for Statistics resultset");\r
 561             this.rsToJson(rs, out);\r
 562           }\r
 563         }\r
 564       } catch (SQLException e) {\r
 565         e.printStackTrace();\r
 566       }\r
 567       intlogger.debug("Time: " + (System.currentTimeMillis() - start) + " ms");\r
 568     } catch (IOException e) {\r
 569       eventlogger.error("IOException - Generating JSON/CSV:" + e);\r
 570       e.printStackTrace();\r
 571     } catch (JSONException e) {\r
 572       eventlogger.error("JSONException - executing SQL query:" + e);\r
 573       e.printStackTrace();\r
 574     } catch (ParseException e) {\r
 575       eventlogger.error("ParseException - executing SQL query:" + e);\r
 576       e.printStackTrace();\r
 577     }\r
 578   }\r
 579 }\r
 580 \r