X-Git-Url: https://gerrit.onap.org/r/gitweb?p=dmaap%2Fdatarouter.git;a=blobdiff_plain;f=datarouter-prov%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdatarouter%2Fprovisioning%2Fbeans%2FExpiryRecord.java;fp=datarouter-prov%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdatarouter%2Fprovisioning%2Fbeans%2FExpiryRecord.java;h=29a7feac57f7b6692bd2cd7d9963383a690ac1dc;hp=0000000000000000000000000000000000000000;hb=e4b20cc6f7c31f48ddd0de5bcd054b09a35cd510;hpb=315f5603d8e42969a13d985ca8bb50146e82325a

diff --git a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/beans/ExpiryRecord.java b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/beans/ExpiryRecord.java
new file mode 100644
index 00000000..29a7feac
--- /dev/null
+++ b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/beans/ExpiryRecord.java
@@ -0,0 +1,141 @@
+/*******************************************************************************
+ * ============LICENSE_START==================================================
+ * * org.onap.dmaap
+ * * ===========================================================================
+ * * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
+ * * ===========================================================================
+ * * Licensed under the Apache License, Version 2.0 (the "License");
+ * * you may not use this file except in compliance with the License.
+ * * You may obtain a copy of the License at
+ * * 
+ *  *      http://www.apache.org/licenses/LICENSE-2.0
+ * * 
+ *  * Unless required by applicable law or agreed to in writing, software
+ * * distributed under the License is distributed on an "AS IS" BASIS,
+ * * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * * See the License for the specific language governing permissions and
+ * * limitations under the License.
+ * * ============LICENSE_END====================================================
+ * *
+ * * ECOMP is a trademark and service mark of AT&T Intellectual Property.
+ * *
+ ******************************************************************************/
+
+
+package org.onap.dmaap.datarouter.provisioning.beans;
+
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Types;
+import java.text.ParseException;
+import java.util.LinkedHashMap;
+
+import org.json.LOGJSONObject;
+
+/**
+ * The representation of a Expiry Record, as retrieved from the DB.
+ * @author Robert Eby
+ * @version $Id: ExpiryRecord.java,v 1.4 2013/10/28 18:06:52 eby Exp $
+ */
+public class ExpiryRecord extends BaseLogRecord {
+	private int subid;
+	private String fileid;
+	private int attempts;
+	private String reason;
+
+	public ExpiryRecord(String[] pp) throws ParseException {
+		super(pp);
+		String fileid = pp[5];
+		if (fileid.lastIndexOf('/') >= 0)
+			fileid = fileid.substring(fileid.lastIndexOf('/')+1);
+		this.subid    = Integer.parseInt(pp[4]);
+		this.fileid   = fileid;
+		this.attempts = Integer.parseInt(pp[10]);
+		this.reason   = pp[9];
+		if (!reason.equals("notRetryable") && !reason.equals("retriesExhausted") && !reason.equals("diskFull"))
+			this.reason = "other";
+	}
+	public ExpiryRecord(ResultSet rs) throws SQLException {
+		super(rs);
+		this.subid    = rs.getInt("DELIVERY_SUBID");
+		this.fileid   = rs.getString("DELIVERY_FILEID");
+		this.attempts = rs.getInt("ATTEMPTS");
+		this.reason   = rs.getString("REASON");
+	}
+
+	public int getSubid() {
+		return subid;
+	}
+
+	public void setSubid(int subid) {
+		this.subid = subid;
+	}
+
+	public String getFileid() {
+		return fileid;
+	}
+
+	public void setFileid(String fileid) {
+		this.fileid = fileid;
+	}
+
+	public int getAttempts() {
+		return attempts;
+	}
+
+	public void setAttempts(int attempts) {
+		this.attempts = attempts;
+	}
+
+	public String getReason() {
+		return reason;
+	}
+
+	public void setReason(String reason) {
+		this.reason = reason;
+	}
+	
+	public LOGJSONObject reOrderObject(LOGJSONObject jo) {
+		LinkedHashMap<String,Object> logrecordObj = new LinkedHashMap<String,Object>();
+		
+		logrecordObj.put("expiryReason", jo.get("expiryReason"));
+		logrecordObj.put("publishId", jo.get("publishId"));
+		logrecordObj.put("attempts", jo.get("attempts"));
+		logrecordObj.put("requestURI", jo.get("requestURI"));
+		logrecordObj.put("method", jo.get("method"));
+		logrecordObj.put("contentType", jo.get("contentType"));
+		logrecordObj.put("type", jo.get("type"));
+		logrecordObj.put("date", jo.get("date"));
+		logrecordObj.put("contentLength", jo.get("contentLength"));
+
+		LOGJSONObject newjo = new LOGJSONObject(logrecordObj);
+		return newjo;
+	}
+	
+	@Override
+	public LOGJSONObject asJSONObject() {
+		LOGJSONObject jo = super.asJSONObject();
+		jo.put("type", "exp");
+		jo.put("expiryReason", reason);
+		jo.put("attempts", attempts);
+		
+		LOGJSONObject newjo = this.reOrderObject(jo);
+		return newjo;
+	}
+	@Override
+	public void load(PreparedStatement ps) throws SQLException {
+		ps.setString(1, "exp");		// field 1: type
+		super.load(ps);				// loads fields 2-8
+		ps.setNull  (9,  Types.VARCHAR);
+		ps.setNull  (10, Types.VARCHAR);
+		ps.setNull  (11, Types.VARCHAR);
+		ps.setNull  (12, Types.INTEGER);
+		ps.setInt   (13, getSubid());
+		ps.setString(14, getFileid());
+		ps.setNull  (15, Types.INTEGER);
+		ps.setInt   (16, getAttempts());
+		ps.setString(17, getReason());
+		ps.setNull  (19, Types.BIGINT);
+	}
+}