REQUEST ID-F15DSUN009

Created postsave  for IBCA Payable


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

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

+
+//Created by  Priyanka Das DATE-15-JUL 15 For RequestID -F15DSUN009
+package ibase.webitm.ejb.fin;
+
+import ibase.system.config.ConnDriver;
+import ibase.webitm.ejb.ITMDBAccessEJB;
+import ibase.webitm.ejb.ValidatorEJB;
+import ibase.webitm.utility.GenericUtility;
+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 javax.ejb.Stateless;
+import org.w3c.dom.Document;
+@javax.ejb.Stateless
+public class PayIbcaPostSave extends ValidatorEJB implements PayIbcaPostSaveLocal,PayIbcaPostSaveRemote {
+	public String postSave()throws RemoteException,ITMException
+	{
+		return "";
+	}
+
+	public String postSave(String xmlString,String tranId,String editFlag, String xtraParams,Connection conn) throws RemoteException,ITMException
+	{		
+		System.out.println("xml String--->>["+xmlString+"]");
+		Document dom = null;
+		String errString="";
+		boolean isError =false;
+		
+		try
+		{
+			if (xmlString != null && xmlString.trim().length() > 0)
+			{
+				dom = parseString(xmlString);				
+				errString = postSave(dom,tranId,xtraParams,conn);
+			}
+			
+		}
+		catch(Exception e)
+		{
+			System.out.println("Exception : PayIbcaPostSave.java : postSave : ==>\n"+e.getMessage());
+			throw new ITMException(e);
+		}		
+		return errString;
+	}
+	
+	
+	public String postSave(Document dom,String tranId,String xtraParams,Connection conn) throws RemoteException,ITMException
+	{
+
+		System.out.println("in PayIbcaPostSave postSave tran_id---->>["+tranId+"]"); 
+		ResultSet rs=null;
+		PreparedStatement pstmt=null;
+		String sql="",errorString="",exchRateS="";
+		ConnDriver connDriver = null;
+		ITMDBAccessEJB itmDBAccessEJB = null;
+		boolean isError =false;
+		
+		double Amount=0,BaseAmt=0,exchRate=0,totAmt=0;	
+		int count=0;
+		try{
+			
+			if (conn == null) 
+				{
+				itmDBAccessEJB = new ITMDBAccessEJB();
+				connDriver = new ConnDriver();
+				conn = connDriver.getConnectDB("DriverITM");
+				connDriver = null;
+				conn.setAutoCommit(false);
+				}
+			
+			exchRateS = GenericUtility.getInstance().getColumnValue("exch_rate", dom);
+			exchRateS = exchRateS == null ? "0" : exchRateS.trim();
+				if (exchRateS.length() > 0) 
+					{
+					exchRate = Double.parseDouble(exchRateS);
+
+					}
+			
+			System.out.println("ExchRate>>>>>" + exchRate);
+			sql = "Select sum(tot_amt) from pay_ibca_det where tran_id =?";
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setString(1, tranId);
+			rs = pstmt.executeQuery();
+			if (rs.next())
+				{
+				totAmt = rs.getDouble(1);
+				
+				}
+				if (pstmt != null) 
+					{
+				pstmt.close();
+				pstmt = null;
+
+					}
+			if (rs != null) 
+			{
+				rs.close();
+				rs = null;
+			}
+			sql = "Select exch_rate from pay_ibca_det where tran_id =?";
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setString(1, tranId);
+			rs = pstmt.executeQuery();
+			if (rs.next())
+				{
+				
+				exchRate = rs.getDouble(1);
+				}
+				if (pstmt != null) 
+					{
+				pstmt.close();
+				pstmt = null;
+
+					}
+			if (rs != null) 
+			{
+				rs.close();
+				rs = null;
+			}
+			
+			System.out.println("totAmt>>>>>>>> " + totAmt);
+			System.out.println("ExchRate>>>>>>>>> " + exchRate);
+			Amount = totAmt;
+			BaseAmt = totAmt * exchRate;
+			System.out.println("BaseAmt>>>> " + BaseAmt);
+			sql = "update pay_ibca set amount = ?,exch_rate = ?,amount__bc = ? where tran_id = ?";
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setDouble(1, Amount);
+			pstmt.setDouble(2, exchRate);
+			pstmt.setDouble(3, BaseAmt);
+			pstmt.setString(4, tranId);
+			count = pstmt.executeUpdate();
+				if (count > 0) 
+					{
+					conn.commit();
+					}
+				else 
+					{
+					conn.rollback();
+					}
+			System.out.println("Post Update count>>>" + count);
+
+			}
+		catch(Exception e)
+		{
+			try
+				{
+				conn.rollback();
+				} catch (SQLException e1) {
+				// TODO Auto-generated catch block
+				e1.printStackTrace();
+				}
+			isError = true;
+			System.out.println("Exception :PayIbcaPostSaveEJB : :==>\n"+e.getMessage());
+			e.printStackTrace();
+			throw new ITMException(e);
+		}
+		finally
+		{
+			try
+			{
+				System.out.println("isError ["+isError+"]");
+				if( conn != null )
+				{
+
+					if( isError )
+					{
+						conn.rollback();
+					}
+					else
+					{
+						conn.commit();
+					}
+				}
+				if(pstmt != null)
+				{
+					pstmt.close();
+					pstmt = null;
+				}
+			}
+			catch(Exception e)
+			{
+				System.out.println("Exception :PayIbcaPostSaveEJB : :==>\n"+e.getMessage());
+				try
+				{
+					System.out.println("Before rollback");
+					conn.rollback();
+				}
+
+				catch(SQLException sqle)
+				{
+					System.out.println(sqle);
+				}
+				throw new ITMException(e);
+			}
+		}
+		System.out.println("Out PayIbcaPostSaveEJB ... ");
+		return "";     
+
+		
+		
+		
+	}
+}
+

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

+package ibase.webitm.ejb.fin;
+
+import ibase.webitm.ejb.ValidatorLocal;
+import ibase.webitm.utility.ITMException;
+
+import java.rmi.RemoteException;
+import java.sql.Connection;
+import javax.ejb.Local;
+@Local
+public interface PayIbcaPostSaveLocal extends ValidatorLocal
+{
+	public String postSave(String xmlString,String tranId,String editFlag, String xtraParams,Connection conn) throws RemoteException,ITMException; 
+	
+
+	
+}

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

+package ibase.webitm.ejb.fin;
+import java.rmi.RemoteException;
+import ibase.webitm.ejb.ValidatorRemote;
+import ibase.webitm.utility.ITMException;
+import java.sql.Connection;
+import javax.ejb.Remote;
+
+@Remote
+
+public interface PayIbcaPostSaveRemote extends ValidatorRemote {
+	public String postSave(String xmlString,String tranId,String editFlag, String xtraParams,Connection conn) throws RemoteException,ITMException;
+
+}