added marketing servlet code

src/ibase/webitm/marketing/servlet/ServletContextListnerExpMkt.java

+package ibase.webitm.marketing.servlet;
+
+import java.util.Date;
+import java.util.Iterator;
+import javax.servlet.ServletContext;
+import java.util.TimerTask;
+import java.util.Timer;
+import java.util.Calendar;
+import ibase.utility.BaseLogger;
+import java.util.Map;
+import java.util.Hashtable;
+import javax.naming.InitialContext;
+import ibase.system.config.AppConnectParm;
+import java.util.ArrayList;
+import java.util.HashMap;
+import javax.servlet.ServletContextEvent;
+import javax.servlet.ServletContextListener;
+
+public class ServletContextListnerExpMkt implements ServletContextListener {
+	public void contextDestroyed(final ServletContextEvent contextEvent) {
+		System.out.println("ServletContextListnerExpMkt is now destroyed");
+	}
+
+	public void contextInitialized(final ServletContextEvent contextEvent) {
+		System.out.println("*** STARTED >> ServletContextListnerExpMkt is initialize ***");
+		Map<String, ArrayList<String>> unAllocDocMap = new HashMap<String, ArrayList<String>>();
+		System.out.println("@ contextEvent>> " + contextEvent);
+		try {
+			final AppConnectParm appConnect = new AppConnectParm();
+			System.out.println("@ appConnect>> " + appConnect);
+			final InitialContext ictx = new InitialContext(appConnect.getProperty());
+			System.out.println("@ Amit  ictx for  getProperty " + ictx);
+			final UnallocatedMrketingDoc ejbRemote = new UnallocatedMrketingDoc();
+			System.out.println(" @ Amit ejbRemote " + ejbRemote);
+			unAllocDocMap = (Map<String, ArrayList<String>>) ejbRemote.addDocument();
+			System.out.println("@ Amit unAllocDocMap " + unAllocDocMap);
+			final String maxDocumentTime = ejbRemote.getDocumentTime();
+			System.out.println("@ Amit >>  maxDocumentTime" + maxDocumentTime);
+			final ServletContext ctx = contextEvent.getServletContext();
+			System.out.println("@ Amit >>  ctx" + ctx);
+			ctx.setAttribute("unAllocDocMapMarkt", (Object) unAllocDocMap);
+			for (final Map.Entry<String, ArrayList<String>> unalloc : unAllocDocMap.entrySet()) {
+				BaseLogger.info((Object) "--------------- In addDocument ---------------");
+				BaseLogger.info(
+						(Object) (String.valueOf(String.valueOf(unalloc.getValue().toString())) + " : Document added"));
+			}
+			System.out.println("before  MyTimerTask");
+			final MyTimerTask task = new MyTimerTask(ctx, unAllocDocMap, (UnallocatedMrketingDocRemote) ejbRemote,
+					maxDocumentTime);
+			System.out.println("@ Amit task>> " + task);
+			final Calendar calendar = Calendar.getInstance();
+			final Date startTime = calendar.getTime();
+			final Timer timer = new Timer();
+			timer.scheduleAtFixedRate(task, startTime, 600000L);
+			ctx.setAttribute("timer", (Object) timer);
+			System.out.println("*** ENDED >> ServletContextListnerExpMkt is initialize ***");
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+	}
+
+	class MyTimerTask extends TimerTask {
+		HashMap<String, ArrayList<String>> unAllocDocMap;
+		UnallocatedMrketingDocRemote unallocatedDocEJBRemote;
+		ServletContext ctx;
+		String maxDocumentTime;
+		String inProcessDocids;
+
+		MyTimerTask() {
+		}
+
+		MyTimerTask(final ServletContext ctx, final Map<String, ArrayList<String>> unAllocDocMap,
+				final UnallocatedMrketingDocRemote unallocatedDocEJBRemote, final String maxDocumentTime) {
+			System.out.println("Inside  MyTimerTask");
+			this.unAllocDocMap = (HashMap<String, ArrayList<String>>) (HashMap) unAllocDocMap;
+			this.unallocatedDocEJBRemote = unallocatedDocEJBRemote;
+			this.ctx = ctx;
+			this.maxDocumentTime = maxDocumentTime;
+			this.inProcessDocids = this.inProcessDocids;
+		}
+
+		@Override
+		public void run() {
+			if (this.ctx.getAttribute("inProcessDocIds") != null) {
+				this.inProcessDocids = (String) this.ctx.getAttribute("inProcessDocIds");
+			}
+			System.out.println("inProcessDocids = [" + this.inProcessDocids + "]");
+			if (this.inProcessDocids != null && this.inProcessDocids.trim().length() > 2) {
+				this.inProcessDocids = this.inProcessDocids.substring(1, this.inProcessDocids.length() - 2);
+				this.inProcessDocids = this.inProcessDocids.trim();
+			}
+			System.out.println("inProcessDocids = [" + this.inProcessDocids + "]");
+			this.unAllocDocMap = (HashMap<String, ArrayList<String>>) this.unallocatedDocEJBRemote.appendDocument();
+			System.out.println(
+					"@ Amit unAllocDocMap inside the HashMap<String, ArrayList<String>>) " + this.unAllocDocMap);
+			final Map<String, ArrayList<String>> newUnAllocDocMap = (Map<String, ArrayList<String>>) this.ctx
+					.getAttribute("unAllocDocMapMarkt");
+			System.out.println("");
+			ArrayList<String> newArrayList = new ArrayList<String>();
+			String objName = "";
+			for (final Map.Entry<String, ArrayList<String>> entry : this.unAllocDocMap.entrySet()) {
+				System.out.println(String.valueOf(String.valueOf(entry.getKey())) + " : " + entry.getValue());
+				objName = entry.getKey();
+				newArrayList = entry.getValue();
+				if (newUnAllocDocMap.containsKey(objName)) {
+					BaseLogger.info((Object) "--------------- In appendDocument ---------------");
+					final ArrayList<String> oldArrayList = newUnAllocDocMap.get(objName);
+					for (int i = 0; i < newArrayList.size(); ++i) {
+						if (!oldArrayList.contains(newArrayList.get(i))) {
+							oldArrayList.add(newArrayList.get(i));
+							System.out.println("New element add in list = " + newArrayList.get(i));
+							BaseLogger.info((Object) ("[" + newArrayList.get(i) + "] : Document added"));
+						}
+					}
+					newUnAllocDocMap.put(objName, oldArrayList);
+				} else {
+					newUnAllocDocMap.put(objName, newArrayList);
+				}
+			}
+			for (final Map.Entry<String, ArrayList<String>> entry : newUnAllocDocMap.entrySet()) {
+				System.out.println(String.valueOf(String.valueOf(entry.getKey())) + " : " + entry.getValue() + " "
+						+ new Date().toString());
+			}
+			this.ctx.setAttribute("unAllocDocMapMarkt", (Object) newUnAllocDocMap);
+			this.maxDocumentTime = this.unallocatedDocEJBRemote.getDocumentTime();
+		}
+	}
+}
\ No newline at end of file

src/ibase/webitm/marketing/servlet/UnallocatedMrketingDoc.java

+package ibase.webitm.marketing.servlet;
+
+import ibase.system.config.AppConnectParm;
+import ibase.system.config.ConnDriver;
+import ibase.webitm.ejb.DocumentHandlerWrapperLocal;
+import ibase.webitm.utility.ITMException;
+import java.rmi.RemoteException;
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.Map;
+import java.util.Map.Entry;
+import javax.ejb.Stateless;
+import javax.naming.InitialContext;
+
+@Stateless
+public class UnallocatedMrketingDoc implements UnallocatedMrketingDocRemote, UnallocatedMrketingDocLocal {
+	Map<String, ArrayList<String>> mapList = new HashMap();
+
+	public Map<String, ArrayList<String>> addDocument() {
+		String strGetObj = "select obj_name from unallocated_attach WHERE STATUS='N' AND upper(obj_name) = 'MARKETING_BILL' group by obj_name";
+		String objName = "";
+		Connection conn = null;
+
+		try {
+			ConnDriver connDriver = new ConnDriver();
+			conn = connDriver.getConnectDB("DriverITM");
+			ArrayList docIds = new ArrayList();
+			PreparedStatement pstmtParamName = conn.prepareStatement(
+					"select obj_name from unallocated_attach WHERE STATUS='N' AND upper(obj_name) = 'MARKETING_BILL' group by obj_name");
+			ResultSet rsCnt = pstmtParamName.executeQuery();
+
+			String unallocDocIds;
+			while (rsCnt.next()) {
+				System.out.println("obj name = " + rsCnt.getString(1));
+				objName = rsCnt.getString(1);
+				unallocDocIds = "select doc_id from UNALLOCATED_ATTACH where STATUS='N' and OBJ_NAME =? order by Added_on , ref_id";
+				PreparedStatement pstmtParamName2 = conn.prepareStatement(
+						"select doc_id from UNALLOCATED_ATTACH where STATUS='N' and OBJ_NAME =? order by Added_on , ref_id");
+				pstmtParamName2.setString(1, rsCnt.getString(1));
+				ResultSet rsCnt2 = pstmtParamName2.executeQuery();
+
+				while (rsCnt2.next()) {
+					docIds.add(rsCnt2.getString(1));
+				}
+
+				this.mapList.put(objName, docIds);
+			}
+
+			pstmtParamName.close();
+			pstmtParamName = null;
+			rsCnt.close();
+			rsCnt = null;
+			if (docIds != null && !docIds.isEmpty()) {
+				unallocDocIds = "";
+
+				int updateCnt;
+				for (updateCnt = 0; updateCnt < docIds.size(); ++updateCnt) {
+					unallocDocIds = String.valueOf(unallocDocIds) + "'" + docIds.get(updateCnt) + "', ";
+				}
+
+				unallocDocIds = unallocDocIds.trim();
+				if (unallocDocIds.trim().length() > 2) {
+					unallocDocIds = unallocDocIds.substring(1, unallocDocIds.length() - 2);
+				}
+
+				System.out.println("unallocDocIds = " + unallocDocIds);
+				updateCnt = this.updateUnallocAttachAddedToMap(objName, unallocDocIds);
+				System.out.println(String.valueOf(updateCnt) + " rows of UNALLOCATED_ATTACH updated.");
+			}
+
+			System.out.println(
+					"\n=========================================================In addDocument()=======================================================================\n");
+			Iterator var29 = this.mapList.entrySet().iterator();
+
+			while (var29.hasNext()) {
+				Entry entry = (Entry) var29.next();
+				String key = entry.getKey().toString();
+				ArrayList values = (ArrayList) entry.getValue();
+				System.out.println("ObjName = [" + key + "] Document Ids = [" + values + "]");
+			}
+		} catch (SQLException var24) {
+			var24.printStackTrace();
+		} catch (Exception var25) {
+			var25.printStackTrace();
+		} finally {
+			try {
+				if (conn != null) {
+					conn.close();
+				}
+
+				conn = null;
+			} catch (Exception var22) {
+				var22.printStackTrace();
+			}
+
+		}
+
+		try {
+			if (conn != null) {
+				conn.close();
+			}
+
+			conn = null;
+		} catch (Exception var23) {
+			var23.printStackTrace();
+		}
+
+		return this.mapList;
+	}
+
+	public void getDocumentList(String objName) {
+		if (this.mapList.containsKey(objName)) {
+			System.out.println(
+					"\n=========================================================In getDocumentList()=======================================================================\n");
+			System.out.println("obj_name = " + objName);
+			ArrayList arrayList = (ArrayList) this.mapList.get(objName);
+			System.out.println("document Id List = " + arrayList);
+		} else {
+			System.out.println("Document you want to view not present in hashmap");
+		}
+
+	}
+
+	public void isDocumentExist(String objName, String docId) {
+		if (this.mapList.containsKey(objName)) {
+			ArrayList arrayList = (ArrayList) this.mapList.get(objName);
+			if (arrayList.contains(docId)) {
+				System.out.println(" Document present in list ");
+			} else {
+				System.out.println(" Document is not present in list ");
+			}
+		} else {
+			System.out.println(" Document is not present in list ");
+		}
+
+	}
+
+	public void removeDocument(String objName, String docId) {
+		ArrayList oldArrayList;
+		if (this.mapList.containsKey(objName)) {
+			oldArrayList = (ArrayList) this.mapList.get(objName);
+			if (oldArrayList.contains(docId)) {
+				((ArrayList) this.mapList.get(objName)).remove(docId);
+				System.out.println(" Document remove from list");
+			} else {
+				System.out.println(" Document you want to remove not present in list");
+			}
+		} else {
+			System.out.println(" Document you want to remove note present in list");
+		}
+
+		System.out.println(
+				"\n================================= In removeDocument() ===================================\n");
+		System.out.println("obj_name = " + objName);
+		oldArrayList = (ArrayList) this.mapList.get(objName);
+		System.out.println("After remove document Ids List = " + oldArrayList);
+	}
+
+	public Map<String, ArrayList<String>> appendDocument(String endTime, String inProcessDocIds) {
+		String strGetObj = "select obj_name from unallocated_attach WHERE STATUS='N' AND upper(obj_name) = 'MARKETING_BILL' group by obj_name";
+		String objName = "";
+		Connection conn = null;
+		HashMap newUnAllocDocMap = new HashMap();
+
+		try {
+			ConnDriver connDriver = new ConnDriver();
+			conn = connDriver.getConnectDB("DriverITM");
+			PreparedStatement pstmtParamName = conn.prepareStatement(
+					"select obj_name from unallocated_attach WHERE STATUS='N' AND upper(obj_name) = 'MARKETING_BILL' group by obj_name");
+			ResultSet rsCnt = pstmtParamName.executeQuery();
+
+			ArrayList docIds;
+			while (rsCnt.next()) {
+				System.out.println("obj name = [" + rsCnt.getString(1) + "]");
+				objName = rsCnt.getString(1);
+				String strGetDocId = "";
+				if (endTime != null && endTime.trim().length() > 0) {
+					if (inProcessDocIds != null && inProcessDocIds.trim().length() > 0) {
+						strGetDocId = "select doc_id from UNALLOCATED_ATTACH where STATUS='N'  and OBJ_NAME = ? AND doc_id NOT IN(?) and to_char(added_on, 'dd/MM/yy HH24:MI:SS') >= ? order by Added_on ,ref_id";
+					} else {
+						strGetDocId = "select doc_id from UNALLOCATED_ATTACH where STATUS='N'  and OBJ_NAME = ? AND to_char(added_on, 'dd/MM/yy HH24:MI:SS') >= ? order by Added_on ,ref_id";
+					}
+				} else if (inProcessDocIds != null && inProcessDocIds.trim().length() > 0) {
+					strGetDocId = "select doc_id from UNALLOCATED_ATTACH where STATUS='N' and OBJ_NAME = ? AND doc_id NOT IN(?) order by Added_on ,ref_id";
+				} else {
+					strGetDocId = "select doc_id from UNALLOCATED_ATTACH where STATUS='N' and OBJ_NAME = ? order by Added_on ,ref_id";
+				}
+
+				PreparedStatement pstmtParamName2 = conn.prepareStatement(strGetDocId);
+				pstmtParamName2.setString(1, rsCnt.getString(1));
+				if (endTime != null && endTime.trim().length() > 0) {
+					if (inProcessDocIds != null && inProcessDocIds.trim().length() > 0) {
+						pstmtParamName2.setString(2, inProcessDocIds);
+						pstmtParamName2.setString(3, endTime);
+					} else {
+						pstmtParamName2.setString(2, endTime);
+					}
+				} else if (inProcessDocIds != null && inProcessDocIds.trim().length() > 0) {
+					pstmtParamName2.setString(2, inProcessDocIds);
+				}
+
+				ResultSet rsCnt2 = pstmtParamName2.executeQuery();
+				docIds = new ArrayList();
+
+				while (rsCnt2.next()) {
+					docIds.add(rsCnt2.getString(1));
+				}
+
+				this.mapList.put(objName, docIds);
+				newUnAllocDocMap.put(objName, docIds);
+			}
+
+			System.out.println(
+					"\n====================================== In appendDocument() ==========================================\n");
+			Iterator var29 = this.mapList.entrySet().iterator();
+
+			while (var29.hasNext()) {
+				Entry entry = (Entry) var29.next();
+				String key = entry.getKey().toString();
+				docIds = (ArrayList) entry.getValue();
+				System.out.println("ObjName = [" + key + "] Document Ids = [" + docIds + "]");
+			}
+		} catch (SQLException var26) {
+			var26.printStackTrace();
+		} catch (Exception var27) {
+			var27.printStackTrace();
+		} finally {
+			try {
+				if (conn != null) {
+					conn.close();
+				}
+
+				conn = null;
+			} catch (Exception var24) {
+				var24.printStackTrace();
+			}
+
+		}
+
+		try {
+			if (conn != null) {
+				conn.close();
+			}
+
+			conn = null;
+		} catch (Exception var25) {
+			var25.printStackTrace();
+		}
+
+		return newUnAllocDocMap;
+	}
+
+	public String getDocumentTime() {
+		Connection conn = null;
+		String maxTime = "";
+
+		try {
+			ConnDriver connDriver = new ConnDriver();
+			conn = connDriver.getConnectDB("DriverITM");
+			String sql = "SELECT to_char(MAX(added_on), 'dd/MM/yy HH24:MI:SS') FROM UNALLOCATED_ATTACH where STATUS='N'";
+			PreparedStatement pstmtParamName = conn.prepareStatement(
+					"SELECT to_char(MAX(added_on), 'dd/MM/yy HH24:MI:SS') FROM UNALLOCATED_ATTACH where STATUS='N'");
+
+			for (ResultSet rsCnt = pstmtParamName.executeQuery(); rsCnt.next(); maxTime = rsCnt.getString(1)) {
+				;
+			}
+
+			System.out.println("maxTime = [" + maxTime + "]");
+		} catch (SQLException var19) {
+			var19.printStackTrace();
+		} catch (Exception var20) {
+			var20.printStackTrace();
+		} finally {
+			try {
+				if (conn != null) {
+					conn.close();
+				}
+
+				conn = null;
+			} catch (Exception var17) {
+				var17.printStackTrace();
+			}
+
+		}
+
+		try {
+			if (conn != null) {
+				conn.close();
+			}
+
+			conn = null;
+		} catch (Exception var18) {
+			var18.printStackTrace();
+		}
+
+		return maxTime;
+	}
+
+	public String updateDocTransactionLink(String newObjName, String newRefId, String oldObjName, String docId,
+			String LoginEmpCode, Connection conn) throws RemoteException, ITMException {
+		ConnDriver connDriver = null;
+		connDriver = new ConnDriver();
+		PreparedStatement pstmt = null;
+		String newRefSer = "";
+		String oldRefSer = "";
+		String oldRefId = "";
+		String retVal = "success";
+		boolean localConn = false;
+
+		try {
+			if (conn == null) {
+				conn = connDriver.getConnectDB("DriverITM");
+				localConn = true;
+				conn.setAutoCommit(false);
+			}
+
+			newRefSer = this.getRefSer(conn, newObjName);
+			oldRefSer = this.getRefSer(conn, oldObjName);
+			oldRefId = this.getRefId(conn, oldRefSer, docId);
+			String docTranLinkSql = "UPDATE DOC_TRANSACTION_LINK SET REF_SER = ? , REF_ID = ? WHERE REF_SER = ? AND REF_ID = ? AND DOC_ID = ?";
+			pstmt = conn.prepareStatement(
+					"UPDATE DOC_TRANSACTION_LINK SET REF_SER = ? , REF_ID = ? WHERE REF_SER = ? AND REF_ID = ? AND DOC_ID = ?");
+			pstmt.setString(1, newRefSer);
+			pstmt.setString(2, newRefId);
+			pstmt.setString(3, oldRefSer);
+			pstmt.setString(4, oldRefId);
+			pstmt.setString(5, docId);
+			int updateCount = pstmt.executeUpdate();
+			System.out.println(String.valueOf(updateCount) + " rows of DOC_TRANSACTION_LINK updated.");
+			pstmt.close();
+			pstmt = null;
+			String unalSql = "UPDATE UNALLOCATED_ATTACH SET MOVED_ON = sysdate , MOVED_BY = ?, STATUS = ?, OBJ_NAME__NEW = ?, REF_ID__NEW = ? WHERE REF_ID = ? AND DOC_ID = ?";
+			pstmt = conn.prepareStatement(
+					"UPDATE UNALLOCATED_ATTACH SET MOVED_ON = sysdate , MOVED_BY = ?, STATUS = ?, OBJ_NAME__NEW = ?, REF_ID__NEW = ? WHERE REF_ID = ? AND DOC_ID = ?");
+			pstmt.setString(1, LoginEmpCode);
+			pstmt.setString(2, "Y");
+			pstmt.setString(3, newObjName);
+			pstmt.setString(4, newRefId);
+			pstmt.setString(5, oldRefId);
+			pstmt.setString(6, docId);
+			int update = pstmt.executeUpdate();
+			System.out.println(String.valueOf(update) + " rows of UNALLOCATED_ATTACH updated.");
+			pstmt.close();
+			pstmt = null;
+			AppConnectParm appConnect = new AppConnectParm();
+			InitialContext ctx = new InitialContext(appConnect.getProperty());
+			DocumentHandlerWrapperLocal docHandler = (DocumentHandlerWrapperLocal) ctx
+					.lookup("ibase/DocumentHandlerWrapperEJB/local");
+			docHandler.updateCountOfAttachments(newObjName, newRefId, newRefSer, conn, "");
+			if (localConn) {
+				conn.commit();
+			}
+		} catch (SQLException var31) {
+			retVal = "error";
+			var31.printStackTrace();
+			throw new ITMException(var31);
+		} catch (Exception var32) {
+			retVal = "error";
+			var32.printStackTrace();
+			throw new ITMException(var32);
+		} finally {
+			try {
+				if (localConn && conn != null) {
+					conn.close();
+					conn = null;
+				}
+			} catch (SQLException var29) {
+				var29.printStackTrace();
+			}
+
+		}
+
+		try {
+			if (localConn && conn != null) {
+				conn.close();
+				conn = null;
+			}
+		} catch (SQLException var30) {
+			var30.printStackTrace();
+		}
+
+		return retVal;
+	}
+
+	public String getRefSer(Connection conn, String objName) throws ITMException, RemoteException {
+		PreparedStatement pStmt = null;
+		ResultSet rs = null;
+		String sql = "";
+		String refSer = "";
+
+		try {
+			objName = "w_" + objName;
+			sql = "SELECT REF_SER FROM TRANSETUP WHERE TRAN_WINDOW = ?";
+			pStmt = conn.prepareStatement(sql);
+			pStmt.setString(1, objName);
+			rs = pStmt.executeQuery();
+			if (rs.next()) {
+				refSer = rs.getString("REF_SER") == null ? "" : rs.getString("REF_SER");
+			}
+		} catch (Exception var17) {
+			System.out.println("[UnallocatedMrketingDoc] :: [getRefSer()] :: " + var17.getMessage());
+			throw new ITMException(var17);
+		} finally {
+			try {
+				if (rs != null) {
+					rs.close();
+					rs = null;
+				}
+
+				if (pStmt != null) {
+					pStmt.close();
+					pStmt = null;
+				}
+			} catch (SQLException var16) {
+				System.out.println("[UnallocatedMrketingDoc] :: [getRefSer()] :finally: " + var16.getMessage());
+				throw new ITMException(var16);
+			}
+
+		}
+
+		try {
+			if (rs != null) {
+				rs.close();
+				rs = null;
+			}
+
+			if (pStmt != null) {
+				pStmt.close();
+				pStmt = null;
+			}
+
+			return refSer;
+		} catch (SQLException var15) {
+			System.out.println("[UnallocatedMrketingDoc] :: [getRefSer()] :finally: " + var15.getMessage());
+			throw new ITMException(var15);
+		}
+	}
+
+	public String getRefId(Connection conn, String refSer, String docId) throws ITMException, RemoteException {
+		PreparedStatement pStmt = null;
+		ResultSet rs = null;
+		String sql = "";
+		String refId = "";
+
+		try {
+			sql = "SELECT REF_ID FROM UNALLOCATED_ATTACH WHERE REF_SER = ? AND DOC_ID = ?";
+			pStmt = conn.prepareStatement(sql);
+			pStmt.setString(1, refSer);
+			pStmt.setString(2, docId);
+			rs = pStmt.executeQuery();
+			if (rs.next()) {
+				refId = rs.getString("REF_ID") == null ? "" : rs.getString("REF_ID");
+			}
+		} catch (Exception var18) {
+			System.out.println("[UnallocatedMrketingDoc] :: [getRefId()] :: " + var18.getMessage());
+			throw new ITMException(var18);
+		} finally {
+			try {
+				if (rs != null) {
+					rs.close();
+					rs = null;
+				}
+
+				if (pStmt != null) {
+					pStmt.close();
+					pStmt = null;
+				}
+			} catch (SQLException var17) {
+				System.out.println("[UnallocatedMrketingDoc] :: [getRefId()] :finally: " + var17.getMessage());
+				throw new ITMException(var17);
+			}
+
+		}
+
+		try {
+			if (rs != null) {
+				rs.close();
+				rs = null;
+			}
+
+			if (pStmt != null) {
+				pStmt.close();
+				pStmt = null;
+			}
+
+			return refId;
+		} catch (SQLException var16) {
+			System.out.println("[UnallocatedMrketingDoc] :: [getRefId()] :finally: " + var16.getMessage());
+			throw new ITMException(var16);
+		}
+	}
+
+	public Map<String, ArrayList<String>> appendDocument() {
+		System.out.println(
+				"\n====================================== In appendDocument() ==========================================\n");
+		String objName = "";
+		Connection conn = null;
+		HashMap newUnAllocDocMap = new HashMap();
+
+		try {
+			ConnDriver connDriver = new ConnDriver();
+			conn = connDriver.getConnectDB("DriverITM");
+			String strGetObj = "select obj_name from unallocated_attach WHERE STATUS='N' AND upper(obj_name) = 'MARKETING_BILL' group by obj_name";
+			ArrayList docIds = new ArrayList();
+			PreparedStatement pstmtParamName = conn.prepareStatement(
+					"select obj_name from unallocated_attach WHERE STATUS='N' AND upper(obj_name) = 'MARKETING_BILL' group by obj_name");
+			ResultSet rsCnt = pstmtParamName.executeQuery();
+
+			String unallocDocIds;
+			while (rsCnt.next()) {
+				objName = rsCnt.getString(1);
+				System.out.println("objName = [" + objName + "]");
+				unallocDocIds = "";
+				unallocDocIds = "SELECT DOC_ID FROM UNALLOCATED_ATTACH WHERE STATUS='N' AND OBJ_NAME = ? AND ADDED_TO_MAP != 1 ORDER BY ADDED_ON, REF_ID";
+				PreparedStatement pstmtParamName2 = conn.prepareStatement(unallocDocIds);
+				pstmtParamName2.setString(1, objName);
+				ResultSet rsCnt2 = pstmtParamName2.executeQuery();
+
+				while (rsCnt2.next()) {
+					docIds.add(rsCnt2.getString(1));
+				}
+
+				newUnAllocDocMap.put(objName, docIds);
+			}
+
+			pstmtParamName.close();
+			pstmtParamName = null;
+			rsCnt.close();
+			rsCnt = null;
+			if (docIds != null && !docIds.isEmpty()) {
+				unallocDocIds = "";
+
+				int updateCnt;
+				for (updateCnt = 0; updateCnt < docIds.size(); ++updateCnt) {
+					unallocDocIds = String.valueOf(unallocDocIds) + "'" + docIds.get(updateCnt) + "', ";
+				}
+
+				unallocDocIds = unallocDocIds.trim();
+				if (unallocDocIds.length() > 2) {
+					unallocDocIds = unallocDocIds.substring(1, unallocDocIds.length() - 2);
+				}
+
+				System.out.println("unallocDocIds = " + unallocDocIds);
+				updateCnt = this.updateUnallocAttachAddedToMap(objName, unallocDocIds);
+				System.out.println(String.valueOf(updateCnt) + " rows of UNALLOCATED_ATTACH updated.");
+			}
+		} catch (SQLException var24) {
+			var24.printStackTrace();
+		} catch (Exception var25) {
+			var25.printStackTrace();
+		} finally {
+			try {
+				if (conn != null) {
+					conn.close();
+				}
+
+				conn = null;
+			} catch (Exception var22) {
+				var22.printStackTrace();
+			}
+
+		}
+
+		try {
+			if (conn != null) {
+				conn.close();
+			}
+
+			conn = null;
+		} catch (Exception var23) {
+			var23.printStackTrace();
+		}
+
+		return newUnAllocDocMap;
+	}
+
+	private int updateUnallocAttachAddedToMap(String objName, String unallocDocIds) {
+		int updateCnt = 0;
+		Connection conn = null;
+		PreparedStatement pstmt = null;
+
+		try {
+			ConnDriver connDriver = new ConnDriver();
+			conn = connDriver.getConnectDB("DriverITM");
+			conn.setAutoCommit(false);
+			if (unallocDocIds == null || unallocDocIds.trim().isEmpty()) {
+				return updateCnt;
+			}
+
+			String updateUnallocIds = "UPDATE UNALLOCATED_ATTACH SET ADDED_TO_MAP = '1' WHERE DOC_ID IN ('"
+					+ unallocDocIds + "') AND OBJ_NAME = ?";
+			pstmt = conn.prepareStatement(updateUnallocIds);
+			pstmt.setString(1, objName);
+			updateCnt = pstmt.executeUpdate();
+			System.out.println(String.valueOf(updateCnt) + " rows of UNALLOCATED_ATTACH updated.");
+			pstmt.close();
+			pstmt = null;
+			if (updateCnt > 0) {
+				conn.commit();
+			}
+		} catch (SQLException var23) {
+			var23.printStackTrace();
+		} catch (Exception var24) {
+			var24.printStackTrace();
+
+			try {
+				if (conn != null) {
+					conn.close();
+					conn = null;
+				}
+			} catch (SQLException var22) {
+				var24.printStackTrace();
+			}
+		} finally {
+			try {
+				if (conn != null) {
+					conn.close();
+					conn = null;
+				}
+			} catch (SQLException var20) {
+				var20.printStackTrace();
+			}
+
+		}
+
+		try {
+			if (conn != null) {
+				conn.close();
+				conn = null;
+			}
+		} catch (SQLException var21) {
+			var21.printStackTrace();
+		}
+
+		return updateCnt;
+	}
+}
\ No newline at end of file

src/ibase/webitm/marketing/servlet/UnallocatedMrketingDocLocal.java

+package ibase.webitm.marketing.servlet;
+
+import ibase.webitm.utility.ITMException;
+import java.rmi.RemoteException;
+import java.sql.Connection;
+import java.util.ArrayList;
+import java.util.Map;
+import javax.ejb.Local;
+
+@Local
+public interface UnallocatedMrketingDocLocal {
+	Map<String, ArrayList<String>> addDocument();
+
+	void isDocumentExist(String var1, String var2);
+
+	void getDocumentList(String var1);
+
+	void removeDocument(String var1, String var2);
+
+	Map<String, ArrayList<String>> appendDocument(String var1, String var2);
+
+	String getDocumentTime();
+
+	String updateDocTransactionLink(String var1, String var2, String var3, String var4, String var5, Connection var6)
+			throws RemoteException, ITMException;
+
+	Map<String, ArrayList<String>> appendDocument();
+}
\ No newline at end of file

src/ibase/webitm/marketing/servlet/UnallocatedMrketingDocRemote.java

+package ibase.webitm.marketing.servlet;
+
+import ibase.webitm.utility.ITMException;
+import java.rmi.RemoteException;
+import java.sql.Connection;
+import java.util.ArrayList;
+import java.util.Map;
+import javax.ejb.Remote;
+
+@Remote
+public interface UnallocatedMrketingDocRemote {
+	Map<String, ArrayList<String>> addDocument();
+
+	void isDocumentExist(String var1, String var2);
+
+	void getDocumentList(String var1);
+
+	void removeDocument(String var1, String var2);
+
+	Map<String, ArrayList<String>> appendDocument(String var1, String var2);
+
+	String getDocumentTime();
+
+	String updateDocTransactionLink(String var1, String var2, String var3, String var4, String var5, Connection var6)
+			throws RemoteException, ITMException;
+
+	Map<String, ArrayList<String>> appendDocument();
+}
\ No newline at end of file