Changes in Automatic Payment scheduler code

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@98497 ce508802-f39f-4f6c-b175-0d175dae99d5

webitm-fin/ibase/webitm/ejb/fin/AutoPmtPrcSch.java

@@ -12,6 +12,8 @@ import java.io.File;
 import java.io.FileOutputStream;
 import java.sql.*;
 import org.w3c.dom.*;
+
+import ibase.webitm.ejb.ITMDBAccessEJB;
 import ibase.webitm.utility.ITMException;
 import ibase.webitm.utility.GenericUtility;
 import ibase.system.config.*;
@@ -199,14 +201,20 @@ public class AutoPmtPrcSch implements Schedule
 		String strToWrite = "";
 		String endDateStr = null;
 		String errString ="";
-		
+		int cnt=0;
+		String errorType = "";
+		String childNodeName = null;
 		boolean flag=false;
+		ArrayList<String> errList = new ArrayList<String>();
+		ArrayList<String> errFields = new ArrayList<String>();
 		
+		String errCode="";
 		java.util.Date startDate = new java.util.Date(System.currentTimeMillis());
 		java.util.Date endDate = new java.util.Date(System.currentTimeMillis());
 		ArrayList<String> sundryCodeList = new ArrayList<String>();
 		AutoPmtGenPrc aPayPrc=new AutoPmtGenPrc();
 		FinCommon fin =new FinCommon();
+		ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
 		try
 		{
 			ConnDriver connDriver = new ConnDriver();
@@ -236,19 +244,43 @@ public class AutoPmtPrcSch implements Schedule
 			
 			System.out.println("XTRAPARAMS@@@@@@@@@@@######:"+xtraParams);
 			
-			sql="select bank_code from site where site_code = ? ";
+			
+			sql="select count(1) from bank where site_code = ? and bank_code=? ";
 			pstmt = conn.prepareStatement(sql);
 			pstmt.setString(1,siteCode);
+			pstmt.setString(2,bankCod);
 			rs = pstmt.executeQuery();
 			if(rs.next())
 			{
-				bankCode=rs.getString("bank_code");
+				cnt=rs.getInt(1);
 			}
 			rs.close();
 			rs = null;
 			pstmt.close();
 			pstmt = null;
 			
+			if(cnt==0)
+			{
+				/*errCode = "VMBANKMIS1 ";
+				errList.add(errCode);
+				errFields.add("bank_code".toLowerCase());*/
+				errString = itmDBAccessLocal.getErrorString("","VMBANKMIS1","");
+				return errString;
+			}
+			
+		/*	sql="select bank_code from site where site_code = ? ";
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setString(1,siteCode);
+			rs = pstmt.executeQuery();
+			if(rs.next())
+			{
+				bankCode=rs.getString("bank_code");
+			}
+			rs.close();
+			rs = null;
+			pstmt.close();
+			pstmt = null;*/
+			bankCode=bankCod;
 			
 			sql = "SELECT BANK_NAME,chq1,chq3 FROM BANK WHERE BANK_CODE = ?";			
 			pstmt = conn.prepareStatement(sql);
@@ -521,6 +553,47 @@ public class AutoPmtPrcSch implements Schedule
 
 	}
 	
-
+	private String errorType(Connection conn , String errorCode)
+	{
+		String msgType = "";
+		PreparedStatement pstmt = null ; 
+		ResultSet rs = null;
+		try
+		{			
+			String  sql = " SELECT MSG_TYPE FROM MESSAGES WHERE MSG_NO = ? ";
+			pstmt = conn.prepareStatement(sql);			
+			pstmt.setString(1, errorCode);			
+			rs = pstmt.executeQuery();
+			while(rs.next())
+			{
+				msgType = rs.getString("MSG_TYPE");
+			}			
+		}
+		catch(Exception ex)
+		{
+			ex.printStackTrace();
+		}		
+		finally
+		{
+			try
+			{
+				if(rs != null)
+				{
+					rs.close();
+					rs = null;
+				}
+				if(pstmt != null)
+				{
+					pstmt.close();
+					pstmt = null;
+				}
+			}
+			catch(Exception e)
+			{
+				e.printStackTrace();
+			}
+		}		
+		return msgType;
+	}
 
 }

webitm-fin/ibase/webitm/ejb/fin/FinCommon.java

@@ -1489,6 +1489,9 @@ public class FinCommon
 			if (rs.next())
 			{
 				lc_exch_rate = rs.getDouble(1);
+			}
+			rs.close(); rs = null;
+			pstmt.close(); pstmt = null; // ADDED BY ALKA
 				if (lc_exch_rate == 0)
 				{
 					sql = "SELECT EXCH_RATE FROM DAILY_EXCH_RATE_SELL_BUY WHERE CURR_CODE = '"+ls_curr_code__to.trim()+"' AND CURR_CODE__TO = '"+as_curr_code.trim()+"' AND ? BETWEEN FROM_DATE AND TO_DATE";
@@ -1506,9 +1509,7 @@ public class FinCommon
 					rs1.close(); rs1 = null;
 					pstmt1.close(); pstmt1 = null;
 				}
-			}
-			rs.close(); rs = null;
-			pstmt.close(); pstmt = null; // ADDED BY ALKA
+			
 		}
 		catch(SQLException e)
 		{
@@ -1558,6 +1559,9 @@ public class FinCommon
 				if (rs.next())
 				{
 					lc_exch_rate = rs.getDouble(1);
+				}
+				rs.close(); rs = null;
+				pstmt.close(); pstmt = null; // ADDED BY ALKA
 					if (lc_exch_rate == 0)
 					{
 						sql = "SELECT EXCH_RATE FROM DAILY_EXCH_RATE_SELL_BUY WHERE CURR_CODE = '"+ls_curr_code__to.trim()+"' AND CURR_CODE__TO = '"+as_curr_code.trim()+"' AND ? BETWEEN FROM_DATE AND TO_DATE";
@@ -1575,9 +1579,7 @@ public class FinCommon
 						rs1.close(); rs1 = null;
 						pstmt1.close(); pstmt1 = null;
 					}
-				}
-				rs.close(); rs = null;
-				pstmt.close(); pstmt = null; // ADDED BY ALKA
+				
 			}
 			catch(SQLException e)
 			{