Skip to content

B
business-java
Commit b238bdce authored by agaikwad's avatar agaikwad
Browse files
Options

Request_id-F15GDOS001 

Amount getting seprated  in Bank statement table, if selected all in Bank Reco. process.


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@36981 ce508802-f39f-4f6c-b175-0d175dae99d5
parent c3e5b16f
Show whitespace changes
Inline Side-by-side
Showing with 782 additions and 649 deletions
webitm-fin/ibase/webitm/ejb/fin/adv/BankRecoPrc.java
View file @ b238bdce
/* /*
Window Name : w_bank_reco Window Name : w_bank_reco
Button Name : Process Button Name : Process
Action : It Select data from BANKTRAN_LOG and after that Action : It Select data from BANKTRAN_LOG and after that
Insert into BANK_STATEMENT,BANKRECO_TRACE Also Insert into BANK_STATEMENT,BANKRECO_TRACE Also
Update STATUS Field of BANKTRAN_LOG Table. Update STATUS Field of BANKTRAN_LOG Table.
*/ */
package ibase.webitm.ejb.fin.adv; package ibase.webitm.ejb.fin.adv;
import java.rmi.RemoteException; import java.rmi.RemoteException;
import java.util.*; import java.util.*;
import java.sql.*; import java.sql.*;
import org.w3c.dom.*; import org.w3c.dom.*;
import javax.ejb.*; import javax.ejb.*;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
...@@ -21,65 +21,52 @@ import ibase.webitm.utility.TransIDGenerator; ...@@ -21,65 +21,52 @@ import ibase.webitm.utility.TransIDGenerator;
import ibase.system.config.*; import ibase.system.config.*;
import javax.ejb.Stateless; // added for ejb3 import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3 @Stateless
// added for ejb3
public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankRecoPrcRemote //SessionBean public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,
BankRecoPrcRemote // SessionBean
{ {
/*public void ejbCreate() throws RemoteException, CreateException /*
{ * public void ejbCreate() throws RemoteException, CreateException { try {
try * System.out.println("ProcessEJB ejbCreate called.........");
{ *
System.out.println("ProcessEJB ejbCreate called........."); * } catch (Exception e) {
* System.out.println("Exception :ProcessEJB :ejbCreate :==>"+e); throw new
} * CreateException(); } } public void ejbRemove() { } public void
catch (Exception e) * ejbActivate() { } public void ejbPassivate() { }
{ */
System.out.println("Exception :ProcessEJB :ejbCreate :==>"+e); public String process() throws RemoteException, ITMException {
throw new CreateException();
}
}
public void ejbRemove()
{
}
public void ejbActivate()
{
}
public void ejbPassivate()
{
}*/
public String process() throws RemoteException,ITMException
{
return ""; return "";
} }
public String getData(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException
{ public String getData(String xmlString, String xmlString2,
String windowName, String xtraParams) throws RemoteException,
ITMException {
String rtrStr = ""; String rtrStr = "";
Document dom = null; Document dom = null;
Document dom1 = null; Document dom1 = null;
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
try try {
{ if (xmlString != null && xmlString.trim().length() != 0) {
if(xmlString != null && xmlString.trim().length()!=0) System.out.println("XML String :" + xmlString);
{
System.out.println("XML String :"+xmlString);
dom = genericUtility.parseString(xmlString); dom = genericUtility.parseString(xmlString);
} }
if(xmlString2 != null && xmlString2.trim().length()!=0) if (xmlString2 != null && xmlString2.trim().length() != 0) {
{ System.out.println("XML String :" + xmlString2);
System.out.println("XML String :"+xmlString2);
dom1 = genericUtility.parseString(xmlString2); dom1 = genericUtility.parseString(xmlString2);
} }
rtrStr = getData(dom, dom1, windowName, xtraParams); rtrStr = getData(dom, dom1, windowName, xtraParams);
} } catch (Exception e) {
catch (Exception e) System.out
{ .println("Exception :BankRecoEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):"
System.out.println("Exception :BankRecoEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":"); + e.getMessage() + ":");
throw new ITMException(e); throw new ITMException(e);
} }
return rtrStr; return rtrStr;
} }
public String getData(Document dom, Document dom2, String windowName, String xtraParams) throws RemoteException,ITMException
{ public String getData(Document dom, Document dom2, String windowName,
String xtraParams) throws RemoteException, ITMException {
String getDataSql = ""; String getDataSql = "";
String bankCode = ""; String bankCode = "";
String effDate = ""; String effDate = "";
...@@ -93,195 +80,240 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -93,195 +80,240 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
int cnt = 0; int cnt = 0;
java.sql.Timestamp refDateTs = null; java.sql.Timestamp refDateTs = null;
//StringBuffer retTabSepStrBuff = new StringBuffer(); // StringBuffer retTabSepStrBuff = new StringBuffer();
StringBuffer retTabSepStrBuff = new StringBuffer("<?xml version = \"1.0\"?>"); StringBuffer retTabSepStrBuff = new StringBuffer(
"<?xml version = \"1.0\"?>");
retTabSepStrBuff.append("<DocumentRoot>"); retTabSepStrBuff.append("<DocumentRoot>");
retTabSepStrBuff.append("<description>").append("Datawindow Root").append("</description>"); retTabSepStrBuff.append("<description>").append("Datawindow Root")
.append("</description>");
retTabSepStrBuff.append("<group0>"); retTabSepStrBuff.append("<group0>");
retTabSepStrBuff.append("<description>").append("Group0 description").append("</description>"); retTabSepStrBuff.append("<description>").append("Group0 description")
.append("</description>");
retTabSepStrBuff.append("<Header0>"); retTabSepStrBuff.append("<Header0>");
ConnDriver connDriver = new ConnDriver(); ConnDriver connDriver = new ConnDriver();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB(); ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
SimpleDateFormat sdf=null; SimpleDateFormat sdf = null;
try try {
{
conn = connDriver.getConnectDB("DriverITM"); conn = connDriver.getConnectDB("DriverITM");
bankCode = genericUtility.getColumnValue("bank_code",dom); bankCode = genericUtility.getColumnValue("bank_code", dom);
effDate = genericUtility.getColumnValue("eff_date",dom); effDate = genericUtility.getColumnValue("eff_date", dom);
refDate = genericUtility.getColumnValue("ref_date",dom); refDate = genericUtility.getColumnValue("ref_date", dom);
sdf=new SimpleDateFormat(genericUtility.getApplDateFormat()); sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
if( refDate != null ) if (refDate != null) {
{ refDateTs = Timestamp.valueOf(genericUtility
refDateTs = Timestamp.valueOf(genericUtility.getValidDateString(refDate, genericUtility.getApplDateFormat(), genericUtility.getDBDateFormat()) + " 00:00:00.0"); .getValidDateString(refDate, genericUtility
} .getApplDateFormat(), genericUtility
getDataSql ="SELECT TRAN_ID," .getDBDateFormat())
+" TRAN_TYPE," + " 00:00:00.0");
+" TRAN_DATE," }
+" BANK_CODE," getDataSql = "SELECT TRAN_ID,"
+" SITE_CODE," + " TRAN_TYPE,"
+" TRAN_SER," + " TRAN_DATE,"
+" TRAN_NO," + " BANK_CODE,"
+" REF_NO," + " SITE_CODE,"
+" REF_DATE," + " TRAN_SER,"
+" REF_MODE," + " TRAN_NO,"
+" AMOUNT," + " REF_NO,"
+" SUNDRY_CODE," + " REF_DATE,"
+" ACCT_CODE," + " REF_MODE,"
+" CCTR_CODE," + " AMOUNT,"
+" STATUS," + " SUNDRY_CODE,"
+" AMT_ADJ," + " ACCT_CODE,"
+" REMARKS," + " CCTR_CODE,"
+" EXCH_RATE," + " STATUS,"
+" CURR_CODE," + " AMT_ADJ,"
+" ENTRY_BATCH_NO, " + " REMARKS,"
+ " FN_SUNDRY_NAME (SUNDRY_TYPE, SUNDRY_CODE, 'L') AS SUNDRY_NAME " // 04/03/15 manoharan F14LVIJ001 + " EXCH_RATE,"
+"FROM BANKTRAN_LOG " + " CURR_CODE,"
+"WHERE (BANKTRAN_LOG.BANK_CODE = ? ) " + " ENTRY_BATCH_NO, "
+" AND( BANKTRAN_LOG.STATUS IN ( 'P','E' ) ) " + " FN_SUNDRY_NAME (SUNDRY_TYPE, SUNDRY_CODE, 'L') AS SUNDRY_NAME " // 04/03/15
+" AND ( BANKTRAN_LOG.TRAN_DATE <= ? ) ORDER BY TRAN_ID"; // manoharan
// F14LVIJ001
+ "FROM BANKTRAN_LOG "
+ "WHERE (BANKTRAN_LOG.BANK_CODE = ? ) "
+ " AND( BANKTRAN_LOG.STATUS IN ( 'P','E' ) ) "
+ " AND ( BANKTRAN_LOG.TRAN_DATE <= ? ) ORDER BY TRAN_ID";
System.out.println("The getDataSql becomes :"+getDataSql); System.out.println("The getDataSql becomes :" + getDataSql);
pstmt = conn.prepareStatement( getDataSql ); pstmt = conn.prepareStatement(getDataSql);
pstmt.setString( 1, bankCode ); pstmt.setString(1, bankCode);
pstmt.setTimestamp( 2, refDateTs ); pstmt.setTimestamp(2, refDateTs);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if (rs.next()) if (rs.next()) {
{ do {
do /*
{ * retTabSepStrBuff.append(rs.getString(1)).append("\t");
/*retTabSepStrBuff.append(rs.getString(1)).append("\t"); * retTabSepStrBuff.append(rs.getString(2)).append("\t");
retTabSepStrBuff.append(rs.getString(2)).append("\t"); * retTabSepStrBuff.append(rs.getString(3)).append("\t");
retTabSepStrBuff.append(rs.getString(3)).append("\t"); * retTabSepStrBuff.append(rs.getString(4)).append("\t");
retTabSepStrBuff.append(rs.getString(4)).append("\t"); * retTabSepStrBuff.append(rs.getString(5)).append("\t");
retTabSepStrBuff.append(rs.getString(5)).append("\t"); * retTabSepStrBuff.append(rs.getString(6)).append("\t");
retTabSepStrBuff.append(rs.getString(6)).append("\t"); * retTabSepStrBuff.append(rs.getString(7)).append("\t");
retTabSepStrBuff.append(rs.getString(7)).append("\t"); * retTabSepStrBuff.append(rs.getString(8)).append("\t");
retTabSepStrBuff.append(rs.getString(8)).append("\t"); * retTabSepStrBuff.append(rs.getString(9)).append("\t");
retTabSepStrBuff.append(rs.getString(9)).append("\t"); * retTabSepStrBuff.append(rs.getString(10)).append("\t");
retTabSepStrBuff.append(rs.getString(10)).append("\t"); * retTabSepStrBuff.append(rs.getDouble(11)).append("\t");
retTabSepStrBuff.append(rs.getDouble(11)).append("\t"); * retTabSepStrBuff.append(rs.getString(12)).append("\t");
retTabSepStrBuff.append(rs.getString(12)).append("\t"); * retTabSepStrBuff.append(rs.getString(13)).append("\t");
retTabSepStrBuff.append(rs.getString(13)).append("\t"); * retTabSepStrBuff.append(rs.getString(14)).append("\t");
retTabSepStrBuff.append(rs.getString(14)).append("\t"); * retTabSepStrBuff.append(rs.getString(15)).append("\t");
retTabSepStrBuff.append(rs.getString(15)).append("\t"); * retTabSepStrBuff.append(rs.getDouble(16)).append("\t");
retTabSepStrBuff.append(rs.getDouble(16)).append("\t"); * retTabSepStrBuff.append(rs.getString(17)).append("\t");
retTabSepStrBuff.append(rs.getString(17)).append("\t"); * retTabSepStrBuff.append(rs.getDouble(18)).append("\t");
retTabSepStrBuff.append(rs.getDouble(18)).append("\t"); * retTabSepStrBuff.append(rs.getString(19)).append("\t");
retTabSepStrBuff.append(rs.getString(19)).append("\t"); * //retTabSepStrBuff.append(rs.getString(20)).append("\n");
//retTabSepStrBuff.append(rs.getString(20)).append("\n"); //Gulzar 20/12/06 * //Gulzar 20/12/06 //Added by Gulzar 20/12/06 entryBatchNo
//Added by Gulzar 20/12/06 * = rs.getString(20); if (entryBatchNo == null) {
entryBatchNo = rs.getString(20); * entryBatchNo = " "; }
if (entryBatchNo == null) * retTabSepStrBuff.append(entryBatchNo).append("\n"); //End
{ * Addition Gulzar 20/12/06
entryBatchNo = " ";
}
retTabSepStrBuff.append(entryBatchNo).append("\n");
//End Addition Gulzar 20/12/06
*/ */
entryBatchNo = rs.getString("ENTRY_BATCH_NO"); entryBatchNo = rs.getString("ENTRY_BATCH_NO");
if (entryBatchNo == null) if (entryBatchNo == null) {
{
entryBatchNo = " "; entryBatchNo = " ";
} }
retTabSepStrBuff.append("<Detail2>"); retTabSepStrBuff.append("<Detail2>");
retTabSepStrBuff.append("<entry_batch_no>").append("<![CDATA[" + entryBatchNo +"]]>").append("</entry_batch_no>"); retTabSepStrBuff.append("<entry_batch_no>").append(
retTabSepStrBuff.append("<ref_no>").append("<![CDATA[" + rs.getString("REF_NO") +"]]>").append("</ref_no>"); "<![CDATA[" + entryBatchNo + "]]>").append(
retTabSepStrBuff.append("<ref_date>").append("<![CDATA[" +sdf.format(rs.getTimestamp("REF_DATE")) +"]]>").append("</ref_date>"); "</entry_batch_no>");
retTabSepStrBuff.append("<amount>").append("<![CDATA[" + rs.getString("AMOUNT") +"]]>").append("</amount>"); retTabSepStrBuff.append("<ref_no>").append(
retTabSepStrBuff.append("<curr_code>").append("<![CDATA[" + rs.getString("CURR_CODE") +"]]>").append("</curr_code>"); "<![CDATA[" + rs.getString("REF_NO") + "]]>")
retTabSepStrBuff.append("<amount_curr>").append("<![CDATA[" + rs.getDouble("AMOUNT") / rs.getDouble("EXCH_RATE") +"]]>").append("</amount_curr>"); .append("</ref_no>");
retTabSepStrBuff.append("<tran_type>").append("<![CDATA[" + rs.getString("TRAN_TYPE") +"]]>").append("</tran_type>"); retTabSepStrBuff.append("<ref_date>").append(
retTabSepStrBuff.append("<sundry_code>").append("<![CDATA[" + rs.getString("SUNDRY_CODE") +"]]>").append("</sundry_code>"); "<![CDATA["
retTabSepStrBuff.append("<sundry_name>").append("<![CDATA[" + rs.getString("SUNDRY_NAME") +"]]>").append("</sundry_name>"); + sdf.format(rs.getTimestamp("REF_DATE"))
retTabSepStrBuff.append("<amt_adj>").append("<![CDATA[" + rs.getString("AMT_ADJ") +"]]>").append("</amt_adj>"); + "]]>").append("</ref_date>");
retTabSepStrBuff.append("<tran_date>").append("<![CDATA[" +sdf.format(rs.getTimestamp("TRAN_DATE")) +"]]>").append("</tran_date>"); retTabSepStrBuff.append("<amount>").append(
retTabSepStrBuff.append("<ref_mode>").append("<![CDATA[" + rs.getString("REF_MODE") +"]]>").append("</ref_mode>"); "<![CDATA[" + rs.getString("AMOUNT") + "]]>")
retTabSepStrBuff.append("<tran_ser>").append("<![CDATA[" + rs.getString("TRAN_SER") +"]]>").append("</tran_ser>"); .append("</amount>");
retTabSepStrBuff.append("<tran_no>").append("<![CDATA[" + rs.getString("TRAN_NO") +"]]>").append("</tran_no>"); retTabSepStrBuff.append("<curr_code>").append(
retTabSepStrBuff.append("<bank_code>").append("<![CDATA[" + rs.getString("BANK_CODE") +"]]>").append("</bank_code>"); "<![CDATA[" + rs.getString("CURR_CODE") + "]]>")
retTabSepStrBuff.append("<site_code>").append("<![CDATA[" + rs.getString("SITE_CODE") +"]]>").append("</site_code>"); .append("</curr_code>");
retTabSepStrBuff.append("<acct_code>").append("<![CDATA[" + rs.getString("ACCT_CODE") +"]]>").append("</acct_code>"); retTabSepStrBuff.append("<amount_curr>").append(
retTabSepStrBuff.append("<cctr_code>").append("<![CDATA[" + rs.getString("CCTR_CODE") +"]]>").append("</cctr_code>"); "<![CDATA[" + rs.getDouble("AMOUNT")
retTabSepStrBuff.append("<status>").append("<![CDATA[" + rs.getString("STATUS") +"]]>").append("</status>"); / rs.getDouble("EXCH_RATE") + "]]>")
retTabSepStrBuff.append("<tran_id>").append("<![CDATA[" + rs.getString("TRAN_ID") +"]]>").append("</tran_id>"); .append("</amount_curr>");
retTabSepStrBuff.append("<remarks>").append("<![CDATA[" + rs.getString("REMARKS") +"]]>").append("</remarks>"); retTabSepStrBuff.append("<tran_type>").append(
retTabSepStrBuff.append("<exch_rate>").append("<![CDATA[" + rs.getString("EXCH_RATE") +"]]>").append("</exch_rate>"); "<![CDATA[" + rs.getString("TRAN_TYPE") + "]]>")
.append("</tran_type>");
retTabSepStrBuff.append("<sundry_code>").append(
"<![CDATA[" + rs.getString("SUNDRY_CODE") + "]]>")
.append("</sundry_code>");
retTabSepStrBuff.append("<sundry_name>").append(
"<![CDATA[" + rs.getString("SUNDRY_NAME") + "]]>")
.append("</sundry_name>");
retTabSepStrBuff.append("<amt_adj>").append(
"<![CDATA[" + rs.getString("AMT_ADJ") + "]]>")
.append("</amt_adj>");
retTabSepStrBuff.append("<tran_date>").append(
"<![CDATA["
+ sdf.format(rs.getTimestamp("TRAN_DATE"))
+ "]]>").append("</tran_date>");
retTabSepStrBuff.append("<ref_mode>").append(
"<![CDATA[" + rs.getString("REF_MODE") + "]]>")
.append("</ref_mode>");
retTabSepStrBuff.append("<tran_ser>").append(
"<![CDATA[" + rs.getString("TRAN_SER") + "]]>")
.append("</tran_ser>");
retTabSepStrBuff.append("<tran_no>").append(
"<![CDATA[" + rs.getString("TRAN_NO") + "]]>")
.append("</tran_no>");
retTabSepStrBuff.append("<bank_code>").append(
"<![CDATA[" + rs.getString("BANK_CODE") + "]]>")
.append("</bank_code>");
retTabSepStrBuff.append("<site_code>").append(
"<![CDATA[" + rs.getString("SITE_CODE") + "]]>")
.append("</site_code>");
retTabSepStrBuff.append("<acct_code>").append(
"<![CDATA[" + rs.getString("ACCT_CODE") + "]]>")
.append("</acct_code>");
retTabSepStrBuff.append("<cctr_code>").append(
"<![CDATA[" + rs.getString("CCTR_CODE") + "]]>")
.append("</cctr_code>");
retTabSepStrBuff.append("<status>").append(
"<![CDATA[" + rs.getString("STATUS") + "]]>")
.append("</status>");
retTabSepStrBuff.append("<tran_id>").append(
"<![CDATA[" + rs.getString("TRAN_ID") + "]]>")
.append("</tran_id>");
retTabSepStrBuff.append("<remarks>").append(
"<![CDATA[" + rs.getString("REMARKS") + "]]>")
.append("</remarks>");
retTabSepStrBuff.append("<exch_rate>").append(
"<![CDATA[" + rs.getString("EXCH_RATE") + "]]>")
.append("</exch_rate>");
retTabSepStrBuff.append("</Detail2>"); retTabSepStrBuff.append("</Detail2>");
cnt++; cnt++;
}while(rs.next()); } while (rs.next());
retTabSepStrBuff.append("</Header0>"); retTabSepStrBuff.append("</Header0>");
retTabSepStrBuff.append("</group0>"); retTabSepStrBuff.append("</group0>");
retTabSepStrBuff.append("</DocumentRoot>"); retTabSepStrBuff.append("</DocumentRoot>");
resultString = retTabSepStrBuff.toString(); resultString = retTabSepStrBuff.toString();
} else {
errCode = "VTNOREC2";
} }
else if (errCode != null && errCode.trim().length() > 0) {
{ errString = itmDBAccessEJB.getErrorString("", errCode, "", "",
errCode ="VTNOREC2"; conn);
}
if (errCode != null && errCode.trim().length()>0)
{
errString = itmDBAccessEJB.getErrorString("", errCode, "", "", conn);
resultString = errString; resultString = errString;
System.out.println("errString: "+errString); System.out.println("errString: " + errString);
}
} }
catch (SQLException e) } catch (SQLException e) {
{ System.out
System.out.println("Exception :BankRecoEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":"); .println("Exception :BankRecoEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):"
+ e.getMessage() + ":");
throw new ITMException(e); throw new ITMException(e);
} } catch (Exception e) {
catch (Exception e) System.out
{ .println("Exception :BankRecoEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):"
System.out.println("Exception :BankRecoEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":"); + e.getMessage() + ":");
throw new ITMException(e); throw new ITMException(e);
} } finally {
finally try {
{
try
{
System.out.println("Closing Connection....."); System.out.println("Closing Connection.....");
conn.close(); conn.close();
conn = null; conn = null;
}catch(Exception e){} } catch (Exception e) {
}
} }
return resultString; return resultString;
} }
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException
{ public String process(String xmlString, String xmlString2,
String windowName, String xtraParams) throws RemoteException,
ITMException {
String retStr = ""; String retStr = "";
Document detailDom = null; Document detailDom = null;
Document headerDom = null; Document headerDom = null;
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
try try {
{ if (xmlString2 != null && xmlString2.trim().length() != 0) {
if(xmlString2 != null && xmlString2.trim().length()!=0) System.out.println("Detail XML String :" + xmlString2);
{
System.out.println("Detail XML String :"+xmlString2);
detailDom = genericUtility.parseString(xmlString2); detailDom = genericUtility.parseString(xmlString2);
} }
if(xmlString != null && xmlString.trim().length()!=0) if (xmlString != null && xmlString.trim().length() != 0) {
{ System.out.println("Header XML String :" + xmlString);
System.out.println("Header XML String :"+xmlString);
headerDom = genericUtility.parseString(xmlString); headerDom = genericUtility.parseString(xmlString);
} }
retStr = process(headerDom, detailDom, windowName, xtraParams); retStr = process(headerDom, detailDom, windowName, xtraParams);
} } catch (Exception e) {
catch (Exception e) System.out
{ .println("Exception :BankRecoEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):"
System.out.println("Exception :BankRecoEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":"); + e.getMessage() + ":");
throw new ITMException(e); throw new ITMException(e);
} }
return retStr; return retStr;
} }
public String process(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException public String process(Document headerDom, Document detailDom,
{ String windowName, String xtraParams) throws RemoteException,
ITMException {
double amount = 0; double amount = 0;
double amount1 = 0; double amount1 = 0;
double amtAdj = 0; double amtAdj = 0;
...@@ -302,7 +334,7 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -302,7 +334,7 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
String errString = ""; String errString = "";
ResultSet rs = null; ResultSet rs = null;
Connection conn = null; Connection conn = null;
//Statement stmt = null; // Statement stmt = null;
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
Document dom1; Document dom1;
int childNodeListLength = 0; int childNodeListLength = 0;
...@@ -314,130 +346,122 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -314,130 +346,122 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
ConnDriver connDriver = new ConnDriver(); ConnDriver connDriver = new ConnDriver();
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB(); ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
try try {
{
conn = connDriver.getConnectDB("DriverITM"); conn = connDriver.getConnectDB("DriverITM");
parentNodeList = detailDom.getElementsByTagName("Detail2"); parentNodeList = detailDom.getElementsByTagName("Detail2");
parentNodeListLength = parentNodeList.getLength(); parentNodeListLength = parentNodeList.getLength();
sql = "SELECT AMOUNT, AMT_ADJ, STATUS, EXCH_RATE FROM BANKTRAN_LOG WHERE TRAN_ID = ? ";//'"+tranId+"'"; sql = "SELECT AMOUNT, AMT_ADJ, STATUS, EXCH_RATE FROM BANKTRAN_LOG WHERE TRAN_ID = ? ";// '"+tranId+"'";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
for (int header = 0; header < parentNodeListLength; header++) for (int header = 0; header < parentNodeListLength; header++) {
{
parentNode = parentNodeList.item(header); parentNode = parentNodeList.item(header);
childNodeList = parentNode.getChildNodes(); childNodeList = parentNode.getChildNodes();
childNodeListLength = childNodeList.getLength(); childNodeListLength = childNodeList.getLength();
for (int cntr = 0; cntr < childNodeListLength; cntr++) for (int cntr = 0; cntr < childNodeListLength; cntr++) {
{
childNode = childNodeList.item(cntr); childNode = childNodeList.item(cntr);
childNodeName = childNode.getNodeName(); childNodeName = childNode.getNodeName();
System.out.println("childNodeName [" + childNodeName + "]"); System.out.println("childNodeName [" + childNodeName + "]");
if (childNodeName.equals("tran_id")) if (childNodeName.equals("tran_id")) {
{ if (childNode.getFirstChild() != null) {
if(childNode.getFirstChild() != null)
{
tranId = childNode.getFirstChild().getNodeValue(); tranId = childNode.getFirstChild().getNodeValue();
System.out.println("childNodeName [" + childNodeName + "] NodeValue [" + childNode.getFirstChild().getNodeValue() + "]"); System.out.println("childNodeName ["
+ childNodeName + "] NodeValue ["
+ childNode.getFirstChild().getNodeValue()
+ "]");
} }
} } else if (childNodeName.equals("tran_ser")) {
else if (childNodeName.equals("tran_ser")) if (childNode.getFirstChild() != null) {
{
if(childNode.getFirstChild() != null)
{
tranSer = childNode.getFirstChild().getNodeValue(); tranSer = childNode.getFirstChild().getNodeValue();
} }
System.out.println("childNodeName [" + childNodeName + "] NodeValue [" + childNode.getFirstChild().getNodeValue() + "]"); System.out.println("childNodeName [" + childNodeName
} + "] NodeValue ["
else if (childNodeName.equals("tran_no")) + childNode.getFirstChild().getNodeValue()
{ + "]");
if(childNode.getFirstChild() != null) } else if (childNodeName.equals("tran_no")) {
{ if (childNode.getFirstChild() != null) {
tranNo = childNode.getFirstChild().getNodeValue(); tranNo = childNode.getFirstChild().getNodeValue();
} }
System.out.println("childNodeName [" + childNodeName + "] NodeValue [" + childNode.getFirstChild().getNodeValue() + "]"); System.out.println("childNodeName [" + childNodeName
+ "] NodeValue ["
+ childNode.getFirstChild().getNodeValue()
+ "]");
} }
} }
pstmt.setString(1,tranId); pstmt.setString(1, tranId);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
//stmt = conn.createStatement(); // stmt = conn.createStatement();
//rs = stmt.executeQuery(sql); // rs = stmt.executeQuery(sql);
if (rs.next()) if (rs.next()) {
{
amount = rs.getDouble(1); amount = rs.getDouble(1);
amtAdj = rs.getDouble(2); amtAdj = rs.getDouble(2);
status = rs.getString(3); status = rs.getString(3);
exchRate = rs.getDouble(4); exchRate = rs.getDouble(4);
if (exchRate == 0) if (exchRate == 0) {
{ xmlStr = getBanklogExchRate(tranSer, tranNo);
xmlStr = getBanklogExchRate(tranSer,tranNo);
dom1 = genericUtility.parseString(xmlStr); dom1 = genericUtility.parseString(xmlStr);
currCode = genericUtility.getColumnValue("curr_code",dom1); currCode = genericUtility.getColumnValue("curr_code",
exchRate1 = genericUtility.getColumnValue("exch_rate",dom1); dom1);
exchRate1 = genericUtility.getColumnValue("exch_rate",
dom1);
} }
if (!status.equals("R")) if (!status.equals("R")) {
{
amount = amount - amtAdj; amount = amount - amtAdj;
amount1 = amount1 + amount; amount1 = amount1 + amount;
totalAmtBc = amount1 * exchRate; totalAmtBc = amount1 * exchRate;
totalAmtCurr = amount1 / exchRate; totalAmtCurr = amount1 / exchRate;
cnt++; cnt++;
} } else {
else
{
errCode = "VTRECON1"; errCode = "VTRECON1";
break; break;
} }
}//if end }// if end
rs.close(); rs.close();
rs = null; rs = null;
pstmt.clearParameters(); pstmt.clearParameters();
}//outer for end }// outer for end
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
System.out.println(" total cnt :"+cnt); System.out.println(" total cnt :" + cnt);
if (cnt <= 0) if (cnt <= 0) {
{
return ""; return "";
} }
if (errCode != null && errCode.trim().length() > 0) if (errCode != null && errCode.trim().length() > 0) {
{ errString = itmDBAccessEJB.getErrorString("", errCode, "", "",
errString = itmDBAccessEJB.getErrorString("", errCode, "", "", conn); conn);
conn.close(); conn.close();
conn = null; conn = null;
return errString; return errString;
} }
errCode = updateTable(cnt,headerDom,detailDom,conn); errCode = updateTable(cnt, headerDom, detailDom, conn);
if (errCode != null || errCode.trim().length()>0) if (errCode != null || errCode.trim().length() > 0) {
{ errString = itmDBAccessEJB.getErrorString("", errCode, "", "",
errString = itmDBAccessEJB.getErrorString("", errCode, "", "", conn); conn);
System.out.println("errString becomes: "+errString); System.out.println("errString becomes: " + errString);
} } else {
else errString = itmDBAccessEJB.getErrorString("", "VTRECOSUCC", "",
{ "", conn);
errString = itmDBAccessEJB.getErrorString("", "VTRECOSUCC", "", "", conn); }
} } catch (Exception e) {
} System.out
catch(Exception e) .println("Exception :BankRecoEJB :process(String xmlString2, String xmlString2, String windowName, String xtraParams):"
{ + e.getMessage() + ":");
System.out.println("Exception :BankRecoEJB :process(String xmlString2, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":");
throw new ITMException(e); throw new ITMException(e);
} } finally {
finally try {
{
try
{
System.out.println("Closing Connection....."); System.out.println("Closing Connection.....");
conn.close(); conn.close();
conn = null; conn = null;
}catch(Exception se){} } catch (Exception se) {
}
} }
return errString; return errString;
} }
private String updateTable(int cnt, Document headerDom, Document detailDom, Connection conn) throws RemoteException, ITMException private String updateTable(int cnt, Document headerDom, Document detailDom,
{ Connection conn) throws RemoteException, ITMException {
Document dom1 = null; Document dom1 = null;
System.out.println("Counter :"+ cnt + "\n detailDom :"+detailDom + "\n headerDom :"+headerDom); System.out.println("Counter :" + cnt + "\n detailDom :" + detailDom
+ "\n headerDom :" + headerDom);
String errCode = ""; String errCode = "";
String errString = ""; String errString = "";
String childNodeName = null; String childNodeName = null;
...@@ -464,7 +488,7 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -464,7 +488,7 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
ArrayList tranIdList = new ArrayList(); ArrayList tranIdList = new ArrayList();
ArrayList amountList = new ArrayList(); ArrayList amountList = new ArrayList();
ArrayList amtAdjList = new ArrayList(); ArrayList amtAdjList = new ArrayList();
//Connection conn = null; //commented by rajendra on 31/03/09 // Connection conn = null; //commented by rajendra on 31/03/09
ResultSet rSet = null; ResultSet rSet = null;
Statement stmt = null; Statement stmt = null;
String keyStringQuery = ""; String keyStringQuery = "";
...@@ -484,24 +508,25 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -484,24 +508,25 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
double amtLog = 0; double amtLog = 0;
double amtAdj1 = 0; double amtAdj1 = 0;
int comp = 0; int comp = 0;
double exchRateD = 0;
double amtAdjD = 0;
NodeList parentNodeList = null; NodeList parentNodeList = null;
NodeList childNodeList = null; NodeList childNodeList = null;
Node parentNode = null; Node parentNode = null;
Node childNode = null; Node childNode = null;
String xmlValues = "";
String effDate = ""; String effDate = "";
java.sql.Timestamp refDateTs = null, effDateTs = null; java.sql.Timestamp refDateTs = null, effDateTs = null;
//commented by rajendra on 31/03/09 // commented by rajendra on 31/03/09
// ConnDriver connDriver = new ConnDriver(); // ConnDriver connDriver = new ConnDriver();
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB(); ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
try try {
{ // conn = getConnection();
//conn = getConnection(); // commented by rajendra on 31/03/09
//commented by rajendra on 31/03/09 // conn = connDriver.getConnectDB("DriverITM");
//conn = connDriver.getConnectDB("DriverITM"); // ended by rajendra on 31/03/09
//ended by rajendra on 31/03/09
/*--- Commented by Gulzar as the logic to process single and multiple record should same 15/11/06 /*--- Commented by Gulzar as the logic to process single and multiple record should same 15/11/06
if (cnt == 1) if (cnt == 1)
...@@ -610,226 +635,169 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -610,226 +635,169 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
} }
}//End of If() }//End of If()
else else
{*/ //End Comment Gulzar 15/11/06 {*/// End Comment Gulzar 15/11/06
bankCode = genericUtility.getColumnValue("bank_code",headerDom); bankCode = genericUtility.getColumnValue("bank_code", headerDom);
effDate = genericUtility.getColumnValue("eff_date",headerDom); effDate = genericUtility.getColumnValue("eff_date", headerDom);
refDate = genericUtility.getColumnValue("ref_date",headerDom); refDate = genericUtility.getColumnValue("ref_date", headerDom);
if( effDate != null ) if (effDate != null) {
{ effDateTs = Timestamp.valueOf(genericUtility
effDateTs = Timestamp.valueOf(genericUtility.getValidDateString(effDate, genericUtility.getApplDateFormat(), genericUtility.getDBDateFormat()) + " 00:00:00.0"); .getValidDateString(effDate, genericUtility
} .getApplDateFormat(), genericUtility
if( refDate != null ) .getDBDateFormat())
{ + " 00:00:00.0");
refDateTs = Timestamp.valueOf(genericUtility.getValidDateString(refDate, genericUtility.getApplDateFormat(), genericUtility.getDBDateFormat()) + " 00:00:00.0"); }
if (refDate != null) {
refDateTs = Timestamp.valueOf(genericUtility
.getValidDateString(refDate, genericUtility
.getApplDateFormat(), genericUtility
.getDBDateFormat())
+ " 00:00:00.0");
}
/**
* Amount getting seprated in Bank statement table, if selected all
* in Bank Reco. process Abhijit Gaikwad 16/10/15 Start
*/
keyStringQuery = "SELECT KEY_STRING, TRAN_ID_COL, REF_SER FROM TRANSETUP WHERE UPPER(TRAN_WINDOW) = 'W_BANK_STATEMENT'";
stmt = conn.createStatement();
rSet = stmt.executeQuery(keyStringQuery);
String tranSer1 = "";
String keyString = "";
String keyCol = "";
String uniqueKey = null;
String insertSql = "";
String updateSql = "";
int insertCnt = 0;
int updateCnt = 0;
if (rSet.next()) {
keyString = rSet.getString(1);
keyCol = rSet.getString(2);
tranSer1 = rSet.getString(3);
} else {
errCode = "VTSEQ";
return errCode;
} }
parentNodeList = detailDom.getElementsByTagName("Detail2"); parentNodeList = detailDom.getElementsByTagName("Detail2");
parentNodeListLength = parentNodeList.getLength(); parentNodeListLength = parentNodeList.getLength();
for (int cntr = 0; cntr < parentNodeListLength; cntr++) System.out.println("parentNodeListLength:::::::::"
{ + parentNodeListLength);
parentNode = parentNodeList.item(cntr); for (int selectedRow = 0; selectedRow < parentNodeListLength; selectedRow++) {
parentNode = parentNodeList.item(selectedRow);
childNodeList = parentNode.getChildNodes(); childNodeList = parentNode.getChildNodes();
childNodeListLength = childNodeList.getLength(); childNodeListLength = childNodeList.getLength();
for (int cnt2 = 0; cnt2 < childNodeListLength; cnt2++) System.out.println("childNodeListLength::: "
{ + childNodeListLength + "\n");
childNode = childNodeList.item(cnt2); for (int childRow = 0; childRow < childNodeListLength; childRow++) {
childNode = childNodeList.item(childRow);
childNodeName = childNode.getNodeName(); childNodeName = childNode.getNodeName();
if (childNodeName.equals("tran_id")) System.out.println("Child node" + childNodeName);
{ if (childNodeName.equals("tran_id")) {
tranId = childNode.getFirstChild().getNodeValue(); tranId = childNode.getFirstChild().getNodeValue();
tranIdList.add(cntr,tranId); System.out.println("Tran id is:" + tranId);
} } else if (childNodeName.equals("amount")) {
if (childNodeName.equals("amount"))
{
amount = childNode.getFirstChild().getNodeValue(); amount = childNode.getFirstChild().getNodeValue();
amountList.add(cntr,amount); System.out.println("Amount is:" + amount);
} } else if (childNodeName.equals("amt_adj")) {
if (childNodeName.equals("amt_adj"))
{
amtAdj = childNode.getFirstChild().getNodeValue(); amtAdj = childNode.getFirstChild().getNodeValue();
amtAdjList.add(cntr,amtAdj); //Gulzar 15/11/06 System.out.println("Amount Adj is:" + amtAdj);
}
}//end inner for
counter++;
}//end outer for
/*int loop = amountList.size();
/* --Commented Changes below by Gulzar 15/11/06
for (int c = 0; c < loop; c++)
{
amt2 = Double.parseDouble(amountList.get(c).toString()) - Double.parseDouble(amtAdj);
amountList.add(c, new Double(amt2));
amt = amt + Double.parseDouble(amountList.get(c).toString());
} }
*///End Comment Gulzar 15/11/06
//Added By Gulzar 15/11/06 else if (childNodeName.equals("tran_type")) {
/*for (int c = 0; c < loop; c++)
{
amt = amt + Double.parseDouble(amountList.get(c).toString()); //Sum the original amount
amt2 = Double.parseDouble(amountList.get(c).toString()) - Double.parseDouble(amtAdjList.get(c).toString());
amountList.set(c, new Double(amt2));
amt3 = amt3 + Double.parseDouble(amountList.get(c).toString()); //Sum the amount after adjusted
} */
//End Addition gulzar 15/11/06
System.out.println("Sum Of Original Amount (amt) is : " + amt);
System.out.println("Sum Of Amount After adjusted (amt3) is : " + amt3);
System.out.println("Amount in amountList after update : " + amountList);
parentNode = parentNodeList.item(0);
childNodeList = parentNode.getChildNodes();
childNodeListLength = childNodeList.getLength();
for (int cnt1 = 0; cnt1 < childNodeListLength; cnt1++)
{
childNode = childNodeList.item(cnt1);
childNodeName = childNode.getNodeName();
if (childNodeName.equals("tran_type"))
{
tranType = childNode.getFirstChild().getNodeValue(); tranType = childNode.getFirstChild().getNodeValue();
} } else if (childNodeName.equals("tran_date")) {
else if (childNodeName.equals("tran_date"))
{
tranDate = childNode.getFirstChild().getNodeValue(); tranDate = childNode.getFirstChild().getNodeValue();
} } else if (childNodeName.equals("bank_code")) {
else if (childNodeName.equals("bank_code"))
{
bankCode = childNode.getFirstChild().getNodeValue(); bankCode = childNode.getFirstChild().getNodeValue();
} } else if (childNodeName.equals("site_code")) {
else if (childNodeName.equals("site_code"))
{
siteCode = childNode.getFirstChild().getNodeValue(); siteCode = childNode.getFirstChild().getNodeValue();
} } else if (childNodeName.equals("tran_ser")) {
else if (childNodeName.equals("tran_ser"))
{
tranSer = childNode.getFirstChild().getNodeValue(); tranSer = childNode.getFirstChild().getNodeValue();
} } else if (childNodeName.equals("tran_no")) {
else if (childNodeName.equals("tran_no"))
{
tranNo = childNode.getFirstChild().getNodeValue(); tranNo = childNode.getFirstChild().getNodeValue();
} } else if (childNodeName.equals("ref_no")) {
else if (childNodeName.equals("ref_no"))
{
refNo = childNode.getFirstChild().getNodeValue(); refNo = childNode.getFirstChild().getNodeValue();
} } else if (childNodeName.equals("ref_date")) {
else if (childNodeName.equals("ref_date"))
{
refDate = childNode.getFirstChild().getNodeValue(); refDate = childNode.getFirstChild().getNodeValue();
} } else if (childNodeName.equals("ref_mode")) {
else if (childNodeName.equals("ref_mode"))
{
refMode = childNode.getFirstChild().getNodeValue(); refMode = childNode.getFirstChild().getNodeValue();
} } else if (childNodeName.equals("sundry_code")) {
else if (childNodeName.equals("sundry_code"))
{
sundryCode = childNode.getFirstChild().getNodeValue(); sundryCode = childNode.getFirstChild().getNodeValue();
} } else if (childNodeName.equals("acct_code")) {
else if (childNodeName.equals("acct_code"))
{
acctCode = childNode.getFirstChild().getNodeValue(); acctCode = childNode.getFirstChild().getNodeValue();
} } else if (childNodeName.equals("cctr_code")) {
else if (childNodeName.equals("cctr_code"))
{
cctrCode = childNode.getFirstChild().getNodeValue(); cctrCode = childNode.getFirstChild().getNodeValue();
} } else if (childNodeName.equals("remarks")) {
else if (childNodeName.equals("remarks"))
{
remarks = childNode.getFirstChild().getNodeValue(); remarks = childNode.getFirstChild().getNodeValue();
} } else if (childNodeName.equals("curr_code")) {
else if (childNodeName.equals("curr_code"))
{
currCode = childNode.getFirstChild().getNodeValue(); currCode = childNode.getFirstChild().getNodeValue();
} } else if (childNodeName.equals("exch_rate")) {
else if (childNodeName.equals("exch_rate"))
{
exchRate = childNode.getFirstChild().getNodeValue(); exchRate = childNode.getFirstChild().getNodeValue();
} }
}//for end }// end inner for
status = "R"; xmlValues = "<?xml version=\"1.0\" encoding=\"utf-8\"?><Root>";
xmlValues = xmlValues + "<Header></Header>";
xmlValues = xmlValues + "<Detail1>";
xmlValues = xmlValues + "</Detail1></Root>";
System.out.println("xmlValues :[" + xmlValues + "]");
TransIDGenerator tg = new TransIDGenerator(xmlValues, "BASE",
"");
uniqueKey = tg.generateTranSeqID(tranSer1, keyCol, keyString,
conn);
System.out.println("uniqueKey :" + uniqueKey);
if (uniqueKey.equals("ERROR")) {
errCode = "VTTRANID";
return errCode;
}
if (Double.parseDouble(exchRate) == 0) status = "R";
{ exchRate = exchRate != null && exchRate.trim().length() > 0 ? exchRate
.trim()
: "0";
amtAdj = amtAdj != null && amtAdj.trim().length() > 0 ? amtAdj
.trim() : "0";
exchRateD = Double.parseDouble(exchRate);
amtAdjD = Double.parseDouble(amtAdj);
if (exchRateD == 0) {
xmlStr = getBanklogExchRate(tranSer, tranNo); xmlStr = getBanklogExchRate(tranSer, tranNo);
dom1 = genericUtility.parseString(xmlStr); dom1 = genericUtility.parseString(xmlStr);
currCode = genericUtility.getColumnValue("curr_code",dom1); currCode = genericUtility.getColumnValue("curr_code", dom1);
exchRate = genericUtility.getColumnValue("exch_rate",dom1); exchRate = genericUtility.getColumnValue("exch_rate", dom1);
} amtAdjBase = amtAdjD * exchRateD;
amtAdjBase = Double.parseDouble(amtAdj) * Double.parseDouble(exchRate); } else {
//}//End of Else() //Gulzar : removed the if block amtAdjBase = amtAdjD * exchRateD;
}
// amtAdjBase = Double.parseDouble(amtAdj) *
// Double.parseDouble(exchRate);
// }//End of Else() //Gulzar : removed the if block
/* insert data into the 'bank_statement' table */ /* insert data into the 'bank_statement' table */
currDate = new java.sql.Date(System.currentTimeMillis()); currDate = new java.sql.Date(System.currentTimeMillis());
effDate = genericUtility.getColumnValue("eff_date", headerDom); effDate = genericUtility.getColumnValue("eff_date", headerDom);
keyStringQuery = "SELECT KEY_STRING, TRAN_ID_COL, REF_SER FROM TRANSETUP WHERE UPPER(TRAN_WINDOW) = 'W_BANK_STATEMENT'";
stmt = conn.createStatement();
rSet = stmt.executeQuery(keyStringQuery);
String tranSer1 = "";
String keyString = "";
String keyCol = "";
String uniqueKey = null;
String insertSql = "";
String updateSql = "";
int insertCnt = 0;
int updateCnt = 0;
if (rSet.next())
{
keyString = rSet.getString(1);
keyCol = rSet.getString(2);
tranSer1 = rSet.getString(3);
}
else
{
errCode = "VTSEQ";
return errCode;
}
int loop = amountList.size();
/* --Commented Changes below by Gulzar 15/11/06
for (int c = 0; c < loop; c++)
{
amt2 = Double.parseDouble(amountList.get(c).toString()) - Double.parseDouble(amtAdj);
amountList.add(c, new Double(amt2));
amt = amt + Double.parseDouble(amountList.get(c).toString());
}
*///End Comment Gulzar 15/11/06
//Added By Gulzar 15/11/06
for (int c = 0; c < loop; c++)
{
String xmlValues = "";
xmlValues ="<?xml version=\"1.0\" encoding=\"utf-8\"?><Root>"; // int loop = amountList.size();
xmlValues = xmlValues + "<Header></Header>"; if (remarks == null) {
xmlValues = xmlValues + "<Detail1>";
xmlValues = xmlValues +"</Detail1></Root>";
System.out.println("xmlValues :["+xmlValues+"]");
TransIDGenerator tg = new TransIDGenerator(xmlValues, "BASE", "");
uniqueKey = tg.generateTranSeqID(tranSer1, keyCol, keyString, conn);
System.out.println("uniqueKey :"+uniqueKey);
if (uniqueKey.equals("ERROR"))
{
errCode = "VTTRANID";
return errCode;
}
if (remarks == null)
{
remarks = " "; remarks = " ";
} }
/* Gulzar 15/11/06 amt = Double.valueOf(amount);
if (cnt > 1) System.out.println("Amount@@@@@@@@@@@@" + amt);
{ amt3 = Double.valueOf(amtAdj);
amtAdj = Double.toString(amt); System.out.println("Adj Amount@@@@@@@@@@@@" + amt3);
}*///Gulzar 15/11/06 java.sql.Date effDate1 = java.sql.Date.valueOf(genericUtility
//double amtAdj1 = Double.parseDouble(amtAdj); //Gulzar 15/11/06 .getValidDateString(effDate, genericUtility
amt = Double.parseDouble(amountList.get(c).toString()); .getApplDateFormat(), genericUtility
System.out.println("Amount@@@@@@@@@@@@"+amt); .getDBDateFormat()));
amt3 = Double.parseDouble(amtAdjList.get(c).toString()); System.out.println("effDate1 :" + effDate1);
System.out.println("Adj Amount@@@@@@@@@@@@"+amt3); System.out.println("refDate :"
java.sql.Date effDate1 = java.sql.Date.valueOf(genericUtility.getValidDateString(effDate,genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat())); + new java.sql.Date(System.currentTimeMillis()));
System.out.println("effDate1 :"+effDate1); // String refDate1 = refDate.substring(0,10);
System.out.println("refDate :"+new java.sql.Date(System.currentTimeMillis())); java.sql.Date refDate2 = java.sql.Date.valueOf(genericUtility
//String refDate1 = refDate.substring(0,10); .getValidDateString(refDate, genericUtility
java.sql.Date refDate2 = java.sql.Date.valueOf(genericUtility.getValidDateString(refDate,genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat())); .getApplDateFormat(), genericUtility
System.out.println("refDate2 :"+refDate2); .getDBDateFormat()));
insertSql ="INSERT INTO BANK_STATEMENT(TRAN_ID, BANK_CODE, SITE_CODE, REF_NO, REF_DATE," System.out.println("refDate2 :" + refDate2);
+" REF_MODE, AMOUNT, TRAN_TYPE, EDI_REF, REMARKS, STATUS, CHG_DATE, CHG_USER, CHG_TERM," insertSql = "INSERT INTO BANK_STATEMENT(TRAN_ID, BANK_CODE, SITE_CODE, REF_NO, REF_DATE,"
+" AMT_ADJ, EFF_DATE, AUTO_ENTRY, STATUS_DATE, EXCH_RATE, CURR_CODE , STAT_DATE)" + " REF_MODE, AMOUNT, TRAN_TYPE, EDI_REF, REMARKS, STATUS, CHG_DATE, CHG_USER, CHG_TERM,"
+" VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"; + " AMT_ADJ, EFF_DATE, AUTO_ENTRY, STATUS_DATE, EXCH_RATE, CURR_CODE , STAT_DATE)"
+ " VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
PreparedStatement pstmt = conn.prepareStatement(insertSql); PreparedStatement pstmt = conn.prepareStatement(insertSql);
pstmt.setString(1, uniqueKey); pstmt.setString(1, uniqueKey);
pstmt.setString(2, bankCode); pstmt.setString(2, bankCode);
...@@ -849,116 +817,290 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -849,116 +817,290 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
pstmt.setDate(16, effDate1); pstmt.setDate(16, effDate1);
pstmt.setString(17, "Y"); pstmt.setString(17, "Y");
pstmt.setDate(18, currDate); pstmt.setDate(18, currDate);
pstmt.setString(19, exchRate); pstmt.setDouble(19, exchRateD);
pstmt.setString(20, currCode); pstmt.setString(20, currCode);
pstmt.setDate(21, effDate1); pstmt.setDate(21, effDate1);
insertCnt = pstmt.executeUpdate(); insertCnt = pstmt.executeUpdate();
System.out.println("insertSql is :"+insertSql); System.out.println("insertSql is :" + insertSql);
System.out.println("insertCnt :"+insertCnt); System.out.println("insertCnt :" + insertCnt);
System.out.println("counter :"+counter); System.out.println("counter :" + counter);
if (insertCnt != 0) if (insertCnt != 0) {
{
//for (int intcnt = 0; intcnt < counter; intcnt++)
//{
/* -- Commented and Changes below by Gulzar 15/11/06
if (cnt == 1)
{
amt = Double.parseDouble(amtAdj);
System.out.println("amt from if :"+amt);
}
else
{
amt = Double.parseDouble(amountList.get(intcnt).toString());
System.out.println("amt from else :"+amt);
}*///End Comment Gulzar 15/11/06
amt = Double.parseDouble(amountList.get(c).toString());
System.out.println("amt while inseting into bankreco_trace is :"+amt);
insertSql = "insert into bankreco_trace(tran_id__stat, tran_id__log, amount) values (?, ?, ?)"; insertSql = "insert into bankreco_trace(tran_id__stat, tran_id__log, amount) values (?, ?, ?)";
System.out.println("insertSql :"+insertSql); System.out.println("insertSql :" + insertSql);
System.out.println("tranIdList.get(intcnt).toString() :"+tranIdList.get(c).toString()); System.out.println("tranIdList.get(intcnt).toString() :"
+ tranId);
PreparedStatement pstmt1 = conn.prepareStatement(insertSql); PreparedStatement pstmt1 = conn.prepareStatement(insertSql);
pstmt1.setString(1, uniqueKey); pstmt1.setString(1, uniqueKey);
pstmt1.setString(2, tranIdList.get(c).toString()); pstmt1.setString(2, tranId);
pstmt1.setDouble(3, amt); pstmt1.setDouble(3, amt);
insertCnt = pstmt1.executeUpdate(); insertCnt = pstmt1.executeUpdate();
pstmt1.close(); pstmt1.close();
pstmt1 = null; pstmt1 = null;
System.out.println("insertCnt :"+insertCnt); System.out.println("insertCnt :" + insertCnt);
System.out.println("cnt :"+cnt); System.out.println("cnt :" + cnt);
/* -- Commented and Changes below by Gulzar 15/11/06
if (cnt ==1)
{
amtAdj1 = amtAdj1 + amtAdj1;
System.out.println("amtAdj1 :"+amtAdj1);
}
else
{
amtAdj1 = Double.parseDouble(amountList.get(intcnt).toString());
System.out.println("amtAdj1 :"+amtAdj1);
}*///End Comment Gulzar 15/11/06
updateSql = "UPDATE BANKTRAN_LOG SET STATUS = ?, AMT_ADJ = AMT_ADJ + ?, EXCH_RATE = ?, CURR_CODE = ?" updateSql = "UPDATE BANKTRAN_LOG SET STATUS = ?, AMT_ADJ = AMT_ADJ + ?, EXCH_RATE = ?, CURR_CODE = ?"
+" WHERE TRAN_ID = ?"; + " WHERE TRAN_ID = ?";
System.out.println("updateSql :"+updateSql); System.out.println("updateSql :" + updateSql);
PreparedStatement pstmt2 = conn.prepareStatement(updateSql); PreparedStatement pstmt2 = conn.prepareStatement(updateSql);
pstmt2.setString(1, status); pstmt2.setString(1, status);
pstmt2.setDouble(2, amt); pstmt2.setDouble(2, amt);
pstmt2.setDouble(3, Double.parseDouble(exchRate)); pstmt2.setDouble(3, exchRateD);
pstmt2.setString(4, currCode); pstmt2.setString(4, currCode);
pstmt2.setString(5, tranIdList.get(c).toString()); pstmt2.setString(5, tranId);
updateCnt = pstmt2.executeUpdate(); updateCnt = pstmt2.executeUpdate();
System.out.println("updateCnt :"+updateCnt); System.out.println("updateCnt :" + updateCnt);
pstmt2.close(); pstmt2.close();
pstmt2 = null; pstmt2 = null;
conn.commit(); conn.commit();
// 12/05/09 manoharan changed the message // 12/05/09 manoharan changed the message
//errCode = "VMSUCC"; // errCode = "VMSUCC";
errCode = "VTPRC1"; errCode = "VTPRC1";
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
} } else {
else
{
errCode = "VTPROCUS"; errCode = "VTPROCUS";
} }
} }// end outer for /** Abhijit Gaikwad 16/10/15 End
/*
* parentNodeList = detailDom.getElementsByTagName("Detail2");
* parentNodeListLength = parentNodeList.getLength(); for (int cntr
* = 0; cntr < parentNodeListLength; cntr++) { parentNode =
* parentNodeList.item(cntr); childNodeList =
* parentNode.getChildNodes(); childNodeListLength =
* childNodeList.getLength(); for (int cnt2 = 0; cnt2 <
* childNodeListLength; cnt2++) { childNode =
* childNodeList.item(cnt2); childNodeName =
* childNode.getNodeName(); if (childNodeName.equals("tran_id")) {
* tranId = childNode.getFirstChild().getNodeValue();
* tranIdList.add(cntr,tranId); } if
* (childNodeName.equals("amount")) { amount =
* childNode.getFirstChild().getNodeValue();
* amountList.add(cntr,amount); } if
* (childNodeName.equals("amt_adj")) { amtAdj =
* childNode.getFirstChild().getNodeValue();
* amtAdjList.add(cntr,amtAdj); //Gulzar 15/11/06 } }//end inner for
* counter++; }//end outer for /*int loop = amountList.size(); /*
* --Commented Changes below by Gulzar 15/11/06 for (int c = 0; c <
* loop; c++) { amt2 =
* Double.parseDouble(amountList.get(c).toString()) -
* Double.parseDouble(amtAdj); amountList.add(c, new Double(amt2));
* amt = amt + Double.parseDouble(amountList.get(c).toString()); }
*/// End Comment Gulzar 15/11/06
// Added By Gulzar 15/11/06
/*
* for (int c = 0; c < loop; c++) { amt = amt +
* Double.parseDouble(amountList.get(c).toString()); //Sum the
* original amount amt2 =
* Double.parseDouble(amountList.get(c).toString()) -
* Double.parseDouble(amtAdjList.get(c).toString());
* amountList.set(c, new Double(amt2)); amt3 = amt3 +
* Double.parseDouble(amountList.get(c).toString()); //Sum the
* amount after adjusted }
*/
// End Addition gulzar 15/11/06
/*
* System.out.println("Sum Of Original Amount (amt) is : " + amt);
* System.out.println("Sum Of Amount After adjusted (amt3) is : " +
* amt3); System.out.println("Amount in amountList after update : "
* + amountList); parentNode = parentNodeList.item(0); childNodeList
* = parentNode.getChildNodes(); childNodeListLength =
* childNodeList.getLength(); for (int cnt1 = 0; cnt1 <
* childNodeListLength; cnt1++) { childNode =
* childNodeList.item(cnt1); childNodeName =
* childNode.getNodeName(); if (childNodeName.equals("tran_type")) {
* tranType = childNode.getFirstChild().getNodeValue(); } else if
* (childNodeName.equals("tran_date")) { tranDate =
* childNode.getFirstChild().getNodeValue(); } else if
* (childNodeName.equals("bank_code")) { bankCode =
* childNode.getFirstChild().getNodeValue(); } else if
* (childNodeName.equals("site_code")) { siteCode =
* childNode.getFirstChild().getNodeValue(); } else if
* (childNodeName.equals("tran_ser")) { tranSer =
* childNode.getFirstChild().getNodeValue(); } else if
* (childNodeName.equals("tran_no")) { tranNo =
* childNode.getFirstChild().getNodeValue(); } else if
* (childNodeName.equals("ref_no")) { refNo =
* childNode.getFirstChild().getNodeValue(); } else if
* (childNodeName.equals("ref_date")) { refDate =
* childNode.getFirstChild().getNodeValue(); } else if
* (childNodeName.equals("ref_mode")) { refMode =
* childNode.getFirstChild().getNodeValue(); } else if
* (childNodeName.equals("sundry_code")) { sundryCode =
* childNode.getFirstChild().getNodeValue(); } else if
* (childNodeName.equals("acct_code")) { acctCode =
* childNode.getFirstChild().getNodeValue(); } else if
* (childNodeName.equals("cctr_code")) { cctrCode =
* childNode.getFirstChild().getNodeValue(); } else if
* (childNodeName.equals("remarks")) { remarks =
* childNode.getFirstChild().getNodeValue(); } else if
* (childNodeName.equals("curr_code")) { currCode =
* childNode.getFirstChild().getNodeValue(); } else if
* (childNodeName.equals("exch_rate")) { exchRate =
* childNode.getFirstChild().getNodeValue(); } }//for end status =
* "R";
*
* if (Double.parseDouble(exchRate) == 0) { xmlStr =
* getBanklogExchRate(tranSer, tranNo); dom1 =
* genericUtility.parseString(xmlStr); currCode =
* genericUtility.getColumnValue("curr_code",dom1); exchRate =
* genericUtility.getColumnValue("exch_rate",dom1); } amtAdjBase =
* Double.parseDouble(amtAdj) * Double.parseDouble(exchRate);
* //}//End of Else() //Gulzar : removed the if block
*
* /* insert data into the 'bank_statement' table
*/
/*
* currDate = new java.sql.Date(System.currentTimeMillis()); effDate
* = genericUtility.getColumnValue("eff_date", headerDom);
* keyStringQuery =
* "SELECT KEY_STRING, TRAN_ID_COL, REF_SER FROM TRANSETUP WHERE UPPER(TRAN_WINDOW) = 'W_BANK_STATEMENT'"
* ; stmt = conn.createStatement(); rSet =
* stmt.executeQuery(keyStringQuery); String tranSer1 = ""; String
* keyString = ""; String keyCol = ""; String uniqueKey = null;
* String insertSql = ""; String updateSql = ""; int insertCnt = 0;
* int updateCnt = 0; if (rSet.next()) { keyString =
* rSet.getString(1); keyCol = rSet.getString(2); tranSer1 =
* rSet.getString(3); } else { errCode = "VTSEQ"; return errCode; }
* int loop = amountList.size(); /* --Commented Changes below by
* Gulzar 15/11/06 for (int c = 0; c < loop; c++) { amt2 =
* Double.parseDouble(amountList.get(c).toString()) -
* Double.parseDouble(amtAdj); amountList.add(c, new Double(amt2));
* amt = amt + Double.parseDouble(amountList.get(c).toString()); }
*/// End Comment Gulzar 15/11/06
// Added By Gulzar 15/11/06
/*
* for (int c = 0; c < loop; c++) { String xmlValues = "";
*
* xmlValues ="<?xml version=\"1.0\" encoding=\"utf-8\"?><Root>";
* xmlValues = xmlValues + "<Header></Header>"; xmlValues =
* xmlValues + "<Detail1>"; xmlValues = xmlValues
* +"</Detail1></Root>";
* System.out.println("xmlValues :["+xmlValues+"]");
* TransIDGenerator tg = new TransIDGenerator(xmlValues, "BASE",
* ""); uniqueKey = tg.generateTranSeqID(tranSer1, keyCol,
* keyString, conn); System.out.println("uniqueKey :"+uniqueKey); if
* (uniqueKey.equals("ERROR")) { errCode = "VTTRANID"; return
* errCode; } if (remarks == null) { remarks = " "; } /* Gulzar
* 15/11/06 if (cnt > 1) { amtAdj = Double.toString(amt); }
*/// Gulzar 15/11/06
// double amtAdj1 = Double.parseDouble(amtAdj); //Gulzar 15/11/06
/*
* amt = Double.parseDouble(amountList.get(c).toString());
* System.out.println("Amount@@@@@@@@@@@@"+amt); amt3 =
* Double.parseDouble(amtAdjList.get(c).toString());
* System.out.println("Adj Amount@@@@@@@@@@@@"+amt3); java.sql.Date
* effDate1 =
* java.sql.Date.valueOf(genericUtility.getValidDateString
* (effDate,genericUtility
* .getApplDateFormat(),genericUtility.getDBDateFormat()));
* System.out.println("effDate1 :"+effDate1);
* System.out.println("refDate :"+new
* java.sql.Date(System.currentTimeMillis())); //String refDate1 =
* refDate.substring(0,10); java.sql.Date refDate2 =
* java.sql.Date.valueOf
* (genericUtility.getValidDateString(refDate,genericUtility
* .getApplDateFormat(),genericUtility.getDBDateFormat()));
* System.out.println("refDate2 :"+refDate2); insertSql=
* "INSERT INTO BANK_STATEMENT(TRAN_ID, BANK_CODE, SITE_CODE, REF_NO, REF_DATE,"
* +
* " REF_MODE, AMOUNT, TRAN_TYPE, EDI_REF, REMARKS, STATUS, CHG_DATE, CHG_USER, CHG_TERM,"
* +
* " AMT_ADJ, EFF_DATE, AUTO_ENTRY, STATUS_DATE, EXCH_RATE, CURR_CODE , STAT_DATE)"
* +
* " VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"
* ; PreparedStatement pstmt = conn.prepareStatement(insertSql);
* pstmt.setString(1, uniqueKey); pstmt.setString(2, bankCode);
* pstmt.setString(3, siteCode); pstmt.setString(4, refNo);
* pstmt.setDate(5, refDate2); pstmt.setString(6, refMode);
* pstmt.setDouble(7, amt); pstmt.setString(8, tranType);
* pstmt.setString(9, " "); pstmt.setString(10, remarks);
* pstmt.setString(11, status); pstmt.setDate(12, currDate);
* pstmt.setString(13, "Base"); pstmt.setString(14, "Base");
* pstmt.setDouble(15, amt3); pstmt.setDate(16, effDate1);
* pstmt.setString(17, "Y"); pstmt.setDate(18, currDate);
* pstmt.setString(19, exchRate); pstmt.setString(20, currCode);
* pstmt.setDate(21, effDate1); insertCnt = pstmt.executeUpdate();
* System.out.println("insertSql is :"+insertSql);
* System.out.println("insertCnt :"+insertCnt);
* System.out.println("counter :"+counter); if (insertCnt != 0) {
* //for (int intcnt = 0; intcnt < counter; intcnt++) //{ /* --
* Commented and Changes below by Gulzar 15/11/06 if (cnt == 1) {
* amt = Double.parseDouble(amtAdj);
* System.out.println("amt from if :"+amt); } else { amt =
* Double.parseDouble(amountList.get(intcnt).toString());
* System.out.println("amt from else :"+amt); }
*/// End Comment Gulzar 15/11/06
/*
* amt = Double.parseDouble(amountList.get(c).toString());
* System.out
* .println("amt while inseting into bankreco_trace is :"+amt);
*
* insertSql =
* "insert into bankreco_trace(tran_id__stat, tran_id__log, amount) values (?, ?, ?)"
* ; System.out.println("insertSql :"+insertSql);
* System.out.println(
* "tranIdList.get(intcnt).toString() :"+tranIdList
* .get(c).toString());
*
* PreparedStatement pstmt1 = conn.prepareStatement(insertSql);
* pstmt1.setString(1, uniqueKey); pstmt1.setString(2,
* tranIdList.get(c).toString()); pstmt1.setDouble(3, amt);
* insertCnt = pstmt1.executeUpdate(); pstmt1.close(); pstmt1 =
* null; System.out.println("insertCnt :"+insertCnt);
* System.out.println("cnt :"+cnt); /* -- Commented and Changes
* below by Gulzar 15/11/06 if (cnt ==1) { amtAdj1 = amtAdj1 +
* amtAdj1; System.out.println("amtAdj1 :"+amtAdj1);
*
* } else { amtAdj1 =
* Double.parseDouble(amountList.get(intcnt).toString());
* System.out.println("amtAdj1 :"+amtAdj1); }
*/// End Comment Gulzar 15/11/06
/*
* updateSql =
* "UPDATE BANKTRAN_LOG SET STATUS = ?, AMT_ADJ = AMT_ADJ + ?, EXCH_RATE = ?, CURR_CODE = ?"
* +" WHERE TRAN_ID = ?";
* System.out.println("updateSql :"+updateSql); PreparedStatement
* pstmt2 = conn.prepareStatement(updateSql); pstmt2.setString(1,
* status); pstmt2.setDouble(2, amt); pstmt2.setDouble(3,
* Double.parseDouble(exchRate)); pstmt2.setString(4, currCode);
* pstmt2.setString(5, tranIdList.get(c).toString()); updateCnt =
* pstmt2.executeUpdate();
* System.out.println("updateCnt :"+updateCnt); pstmt2.close();
* pstmt2 = null;
*
* conn.commit(); // 12/05/09 manoharan changed the message
* //errCode = "VMSUCC"; errCode = "VTPRC1"; pstmt.close(); pstmt =
* null; } else { errCode = "VTPROCUS"; } }
*/
} }
catch(SQLException e) catch (SQLException e) {
{
e.printStackTrace(); e.printStackTrace();
throw new ITMException(e); throw new ITMException(e);
} } catch (Exception e) {
catch(Exception e)
{
e.printStackTrace(); e.printStackTrace();
throw new ITMException(e); throw new ITMException(e);
} }
// 12/05/09 manoharan passed connection not to be closed // 12/05/09 manoharan passed connection not to be closed
/*finally /*
{ * finally { try { System.out.println("Closing Connection......");
try * conn.close(); conn = null; } catch(SQLException se){} }
{ */
System.out.println("Closing Connection......"); System.out.println("errString: " + errCode);
conn.close();
conn = null;
}
catch(SQLException se){}
}*/
System.out.println("errString: "+errCode);
return errCode; return errCode;
} }
private String getBanklogExchRate(String tranSer, String tranNo) throws RemoteException,ITMException private String getBanklogExchRate(String tranSer, String tranNo)
{ throws RemoteException, ITMException {
System.out.println("TranSer :"+tranSer); System.out.println("TranSer :" + tranSer);
String currCode = ""; String currCode = "";
StringBuffer valueXmlString = new StringBuffer("<?xml version=\"1.0\"?>\r\n<Root>\r\n"); StringBuffer valueXmlString = new StringBuffer(
"<?xml version=\"1.0\"?>\r\n<Root>\r\n");
double exchRate = 0; double exchRate = 0;
Statement stmt = null; Statement stmt = null;
Connection conn = null; Connection conn = null;
...@@ -966,79 +1108,70 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -966,79 +1108,70 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
boolean isSql = false; boolean isSql = false;
ConnDriver connDriver = new ConnDriver(); ConnDriver connDriver = new ConnDriver();
String sql = ""; String sql = "";
try try {
{
conn = connDriver.getConnectDB("DriverITM"); conn = connDriver.getConnectDB("DriverITM");
stmt = conn.createStatement(); stmt = conn.createStatement();
if (tranSer.equals("E-PAY")) if (tranSer.equals("E-PAY")) {
{ sql = "SELECT CURR_CODE, EXCH_RATE FROM PAYMENT_EXP WHERE TRAN_ID = '"
sql = "SELECT CURR_CODE, EXCH_RATE FROM PAYMENT_EXP WHERE TRAN_ID = '"+ tranNo +"'"; + tranNo + "'";
isSql = true; isSql = true;
} } else if (tranSer.equals("F-XFR")) {
else if (tranSer.equals("F-XFR")) sql = "SELECT CURR_CODE, EXCH_RATE FROM FUNDTRANSFER WHERE TRAN_ID = '"
{ + tranNo + "'";
sql = "SELECT CURR_CODE, EXCH_RATE FROM FUNDTRANSFER WHERE TRAN_ID = '"+ tranNo +"'";
isSql = true; isSql = true;
} } else if (tranSer.equals("M-PAY")) {
else if (tranSer.equals("M-PAY")) sql = "SELECT CURR_CODE, EXCH_RATE FROM MISC_PAYMENT WHERE TRAN_ID = '"
{ + tranNo + "'";
sql = "SELECT CURR_CODE, EXCH_RATE FROM MISC_PAYMENT WHERE TRAN_ID = '"+ tranNo +"'";
isSql = true; isSql = true;
} } else if (tranSer.equals("M-RCP")) {
else if (tranSer.equals("M-RCP")) sql = "SELECT CURR_CODE, EXCH_RATE FROM MISC_RECEIPT WHERE TRAN_ID = '"
{ + tranNo + "'";
sql = "SELECT CURR_CODE, EXCH_RATE FROM MISC_RECEIPT WHERE TRAN_ID = '"+ tranNo +"'";
isSql = true; isSql = true;
} } else if (tranSer.equals("MPCANC")) {
else if (tranSer.equals("MPCANC")) sql = "SELECT CURR_CODE, EXCH_RATE FROM MISC_PAYMENT_CANC WHERE TRAN_ID = '"
{ + tranNo + "'";
sql = "SELECT CURR_CODE, EXCH_RATE FROM MISC_PAYMENT_CANC WHERE TRAN_ID = '"+ tranNo +"'";
isSql = true; isSql = true;
} } else if (tranSer.equals("R-DIS")) {
else if (tranSer.equals("R-DIS")) sql = "SELECT CURR_CODE, EXCH_RATE FROM RCPDISHNR WHERE TRAN_ID = '"
{ + tranNo + "'";
sql = "SELECT CURR_CODE, EXCH_RATE FROM RCPDISHNR WHERE TRAN_ID = '"+ tranNo +"'";
isSql = true; isSql = true;
} } else if (tranSer.equals("RCP")) {
else if (tranSer.equals("RCP")) sql = "SELECT CURR_CODE, EXCH_RATE FROM RECEIPT WHERE TRAN_ID = '"
{ + tranNo + "'";
sql = "SELECT CURR_CODE, EXCH_RATE FROM RECEIPT WHERE TRAN_ID = '"+ tranNo +"'";
isSql = true; isSql = true;
} } else if (tranSer.equals("E-FUND")) {
else if (tranSer.equals("E-FUND")) sql = "SELECT CURR_CODE, EXCH_RATE FROM EXPORT_FUND WHERE TRAN_ID = '"
{ + tranNo + "'";
sql = "SELECT CURR_CODE, EXCH_RATE FROM EXPORT_FUND WHERE TRAN_ID = '"+ tranNo +"'";
isSql = true; isSql = true;
} }
if (isSql) if (isSql) {
{
rs = stmt.executeQuery(sql); rs = stmt.executeQuery(sql);
if (rs.next()) if (rs.next()) {
{
valueXmlString.append("<Detail>\r\n"); valueXmlString.append("<Detail>\r\n");
valueXmlString.append("<curr_code>").append(rs.getString(1)).append("</curr_code>\r\n") ; valueXmlString.append("<curr_code>")
valueXmlString.append("<exch_rate>").append(rs.getString(2)).append("</exch_rate>\r\n"); .append(rs.getString(1)).append("</curr_code>\r\n");
valueXmlString.append("<exch_rate>")
.append(rs.getString(2)).append("</exch_rate>\r\n");
valueXmlString.append("</Detail>\r\n"); valueXmlString.append("</Detail>\r\n");
} }
} }
stmt.close(); stmt.close();
valueXmlString.append("</Root>\r\n"); valueXmlString.append("</Root>\r\n");
} } catch (Exception e) {
catch(Exception e) System.out
{ .println("Exception :ITMDBAccessEJB :getBanklogExchRate(String xmlString, String xmlString2):"
System.out.println("Exception :ITMDBAccessEJB :getBanklogExchRate(String xmlString, String xmlString2):" + e.getMessage() + ":"); + e.getMessage() + ":");
throw new ITMException(e); throw new ITMException(e);
} } finally {
finally try {
{
try
{
System.out.println("Closing Connection......."); System.out.println("Closing Connection.......");
conn.close(); conn.close();
conn = null; conn = null;
}catch(Exception se){} } catch (Exception se) {
}
} }
System.out.println("valueXmlString.toString() :"+valueXmlString.toString()); System.out.println("valueXmlString.toString() :"
+ valueXmlString.toString());
return valueXmlString.toString(); return valueXmlString.toString();
} }
} }
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment