1 /*******************************************************************************
\r
2 * ============LICENSE_START==================================================
\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
11 * * http://www.apache.org/licenses/LICENSE-2.0
\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
20 * * ECOMP is a trademark and service mark of AT&T Intellectual Property.
\r
22 ******************************************************************************/
\r
25 package com.att.research.datarouter.reports;
\r
27 import java.io.FileNotFoundException;
\r
28 import java.io.PrintWriter;
\r
29 import java.sql.Connection;
\r
30 import java.sql.PreparedStatement;
\r
31 import java.sql.ResultSet;
\r
32 import java.sql.SQLException;
\r
33 import java.util.HashMap;
\r
34 import java.util.Map;
\r
35 import java.util.TreeSet;
\r
37 import com.att.research.datarouter.provisioning.utils.DB;
\r
40 * Generate a subscribers report. The report is a .CSV file. It contains information per-day and per-subscriber,
\r
41 * on the status codes returned from each delivery attempt (1XX, 2XX, etc.) as well as a count of 4XX instead of a 100.
\r
43 * @author Robert P. Eby
\r
44 * @version $Id: SubscriberReport.java,v 1.2 2013/11/06 16:23:55 eby Exp $
\r
46 public class SubscriberReport extends ReportBase {
\r
47 private static final String SELECT_SQL =
\r
48 "select date(from_unixtime(EVENT_TIME div 1000)) as DATE, DELIVERY_SUBID, RESULT, COUNT(RESULT) as COUNT" +
\r
49 " from LOG_RECORDS" +
\r
50 " where TYPE = 'del' and EVENT_TIME >= ? and EVENT_TIME <= ?" +
\r
51 " group by DATE, DELIVERY_SUBID, RESULT";
\r
52 private static final String SELECT_SQL2 =
\r
53 "select date(from_unixtime(EVENT_TIME div 1000)) as DATE, DELIVERY_SUBID, COUNT(CONTENT_LENGTH_2) as COUNT" +
\r
54 " from LOG_RECORDS" +
\r
55 " where TYPE = 'dlx' and CONTENT_LENGTH_2 = -1 and EVENT_TIME >= ? and EVENT_TIME <= ?" +
\r
56 " group by DATE, DELIVERY_SUBID";
\r
58 private class Counters {
\r
59 private String date;
\r
61 private int c100, c200, c300, c400, c500, cm1, cdlx;
\r
62 public Counters(String date, int sub) {
\r
65 c100 = c200 = c300 = c400 = c500 = cm1 = cdlx = 0;
\r
67 public void addCounts(int status, int n) {
\r
70 } else if (status >= 100 && status <= 199) {
\r
72 } else if (status >= 200 && status <= 299) {
\r
74 } else if (status >= 300 && status <= 399) {
\r
76 } else if (status >= 400 && status <= 499) {
\r
78 } else if (status >= 500 && status <= 599) {
\r
82 public void addDlxCount(int n) {
\r
86 public String toString() {
\r
87 return date + "," + sub + "," +
\r
88 c100 + "," + c200 + "," + c300 + "," + c400 + "," + c500 + "," +
\r
95 Map<String, Counters> map = new HashMap<String, Counters>();
\r
96 long start = System.currentTimeMillis();
\r
99 @SuppressWarnings("resource")
\r
100 Connection conn = db.getConnection();
\r
101 PreparedStatement ps = conn.prepareStatement(SELECT_SQL);
\r
102 ps.setLong(1, from);
\r
104 ResultSet rs = ps.executeQuery();
\r
105 while (rs.next()) {
\r
106 String date = rs.getString("DATE");
\r
107 int sub = rs.getInt("DELIVERY_SUBID");
\r
108 int res = rs.getInt("RESULT");
\r
109 int count = rs.getInt("COUNT");
\r
110 String key = date + "," + sub;
\r
111 Counters c = map.get(key);
\r
113 c = new Counters(date, sub);
\r
116 c.addCounts(res, count);
\r
121 ps = conn.prepareStatement(SELECT_SQL2);
\r
122 ps.setLong(1, from);
\r
124 rs = ps.executeQuery();
\r
125 while (rs.next()) {
\r
126 String date = rs.getString("DATE");
\r
127 int sub = rs.getInt("DELIVERY_SUBID");
\r
128 int count = rs.getInt("COUNT");
\r
129 String key = date + "," + sub;
\r
130 Counters c = map.get(key);
\r
132 c = new Counters(date, sub);
\r
135 c.addDlxCount(count);
\r
141 } catch (SQLException e) {
\r
142 e.printStackTrace();
\r
144 logger.debug("Query time: " + (System.currentTimeMillis()-start) + " ms");
\r
146 PrintWriter os = new PrintWriter(outfile);
\r
147 os.println("date,subid,count100,count200,count300,count400,count500,countminus1,countdlx");
\r
148 for (String key : new TreeSet<String>(map.keySet())) {
\r
149 Counters c = map.get(key);
\r
150 os.println(c.toString());
\r
153 } catch (FileNotFoundException e) {
\r
154 System.err.println("File cannot be written: "+outfile);
\r