Skip to content

B
business-java
Commit 37969283 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@98750 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 73ae6fb0
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 @ 37969283
/*
Window Name : w_bank_reco
Button Name : Process
Action : It Select data from BANKTRAN_LOG and after that
Insert into BANK_STATEMENT,BANKRECO_TRACE Also
Update STATUS Field of BANKTRAN_LOG Table.
*/
*/
package ibase.webitm.ejb.fin.adv;
import java.rmi.RemoteException;
import java.util.*;
import java.sql.*;
import org.w3c.dom.*;
import javax.ejb.*;
import java.text.SimpleDateFormat;
......@@ -21,65 +21,52 @@ import ibase.webitm.utility.TransIDGenerator;
import ibase.system.config.*;
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankRecoPrcRemote //SessionBean
@Stateless
// added for ejb3
public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,
BankRecoPrcRemote // SessionBean
{
/*public void ejbCreate() throws RemoteException, CreateException
{
try
{
System.out.println("ProcessEJB ejbCreate called.........");
}
catch (Exception e)
{
System.out.println("Exception :ProcessEJB :ejbCreate :==>"+e);
throw new CreateException();
}
}
public void ejbRemove()
{
}
public void ejbActivate()
{
}
public void ejbPassivate()
{
}*/
public String process() throws RemoteException,ITMException
{
/*
* public void ejbCreate() throws RemoteException, CreateException { try {
* System.out.println("ProcessEJB ejbCreate called.........");
*
* } catch (Exception e) {
* System.out.println("Exception :ProcessEJB :ejbCreate :==>"+e); throw new
* CreateException(); } } public void ejbRemove() { } public void
* ejbActivate() { } public void ejbPassivate() { }
*/
public String process() throws RemoteException, ITMException {
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 = "";
Document dom = null;
Document dom1 = null;
GenericUtility genericUtility = GenericUtility.getInstance();
try
{
if(xmlString != null && xmlString.trim().length()!=0)
{
System.out.println("XML String :"+xmlString);
try {
if (xmlString != null && xmlString.trim().length() != 0) {
System.out.println("XML String :" + xmlString);
dom = genericUtility.parseString(xmlString);
}
if(xmlString2 != null && xmlString2.trim().length()!=0)
{
System.out.println("XML String :"+xmlString2);
if (xmlString2 != null && xmlString2.trim().length() != 0) {
System.out.println("XML String :" + xmlString2);
dom1 = genericUtility.parseString(xmlString2);
}
rtrStr = getData(dom, dom1, windowName, xtraParams);
}
catch (Exception e)
{
System.out.println("Exception :BankRecoEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":");
} catch (Exception e) {
System.out
.println("Exception :BankRecoEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):"
+ e.getMessage() + ":");
throw new ITMException(e);
}
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 bankCode = "";
String effDate = "";
......@@ -93,195 +80,240 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
PreparedStatement pstmt = null;
int cnt = 0;
java.sql.Timestamp refDateTs = null;
//StringBuffer retTabSepStrBuff = new StringBuffer();
StringBuffer retTabSepStrBuff = new StringBuffer("<?xml version = \"1.0\"?>");
// StringBuffer retTabSepStrBuff = new StringBuffer();
StringBuffer retTabSepStrBuff = new StringBuffer(
"<?xml version = \"1.0\"?>");
retTabSepStrBuff.append("<DocumentRoot>");
retTabSepStrBuff.append("<description>").append("Datawindow Root").append("</description>");
retTabSepStrBuff.append("<description>").append("Datawindow Root")
.append("</description>");
retTabSepStrBuff.append("<group0>");
retTabSepStrBuff.append("<description>").append("Group0 description").append("</description>");
retTabSepStrBuff.append("<description>").append("Group0 description")
.append("</description>");
retTabSepStrBuff.append("<Header0>");
ConnDriver connDriver = new ConnDriver();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance();
SimpleDateFormat sdf=null;
try
{
SimpleDateFormat sdf = null;
try {
conn = connDriver.getConnectDB("DriverITM");
bankCode = genericUtility.getColumnValue("bank_code",dom);
effDate = genericUtility.getColumnValue("eff_date",dom);
refDate = genericUtility.getColumnValue("ref_date",dom);
sdf=new SimpleDateFormat(genericUtility.getApplDateFormat());
if( refDate != null )
{
refDateTs = Timestamp.valueOf(genericUtility.getValidDateString(refDate, genericUtility.getApplDateFormat(), genericUtility.getDBDateFormat()) + " 00:00:00.0");
}
getDataSql ="SELECT TRAN_ID,"
+" TRAN_TYPE,"
+" TRAN_DATE,"
+" BANK_CODE,"
+" SITE_CODE,"
+" TRAN_SER,"
+" TRAN_NO,"
+" REF_NO,"
+" REF_DATE,"
+" REF_MODE,"
+" AMOUNT,"
+" SUNDRY_CODE,"
+" ACCT_CODE,"
+" CCTR_CODE,"
+" STATUS,"
+" AMT_ADJ,"
+" REMARKS,"
+" EXCH_RATE,"
+" CURR_CODE,"
+" ENTRY_BATCH_NO, "
+ " FN_SUNDRY_NAME (SUNDRY_TYPE, SUNDRY_CODE, 'L') AS SUNDRY_NAME " // 04/03/15 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";
bankCode = genericUtility.getColumnValue("bank_code", dom);
effDate = genericUtility.getColumnValue("eff_date", dom);
refDate = genericUtility.getColumnValue("ref_date", dom);
sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
if (refDate != null) {
refDateTs = Timestamp.valueOf(genericUtility
.getValidDateString(refDate, genericUtility
.getApplDateFormat(), genericUtility
.getDBDateFormat())
+ " 00:00:00.0");
}
getDataSql = "SELECT TRAN_ID,"
+ " TRAN_TYPE,"
+ " TRAN_DATE,"
+ " BANK_CODE,"
+ " SITE_CODE,"
+ " TRAN_SER,"
+ " TRAN_NO,"
+ " REF_NO,"
+ " REF_DATE,"
+ " REF_MODE,"
+ " AMOUNT,"
+ " SUNDRY_CODE,"
+ " ACCT_CODE,"
+ " CCTR_CODE,"
+ " STATUS,"
+ " AMT_ADJ,"
+ " REMARKS,"
+ " EXCH_RATE,"
+ " CURR_CODE,"
+ " ENTRY_BATCH_NO, "
+ " FN_SUNDRY_NAME (SUNDRY_TYPE, SUNDRY_CODE, 'L') AS SUNDRY_NAME " // 04/03/15
// 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);
pstmt = conn.prepareStatement( getDataSql );
System.out.println("The getDataSql becomes :" + getDataSql);
pstmt = conn.prepareStatement(getDataSql);
pstmt.setString( 1, bankCode );
pstmt.setTimestamp( 2, refDateTs );
pstmt.setString(1, bankCode);
pstmt.setTimestamp(2, refDateTs);
rs = pstmt.executeQuery();
if (rs.next())
{
do
{
/*retTabSepStrBuff.append(rs.getString(1)).append("\t");
retTabSepStrBuff.append(rs.getString(2)).append("\t");
retTabSepStrBuff.append(rs.getString(3)).append("\t");
retTabSepStrBuff.append(rs.getString(4)).append("\t");
retTabSepStrBuff.append(rs.getString(5)).append("\t");
retTabSepStrBuff.append(rs.getString(6)).append("\t");
retTabSepStrBuff.append(rs.getString(7)).append("\t");
retTabSepStrBuff.append(rs.getString(8)).append("\t");
retTabSepStrBuff.append(rs.getString(9)).append("\t");
retTabSepStrBuff.append(rs.getString(10)).append("\t");
retTabSepStrBuff.append(rs.getDouble(11)).append("\t");
retTabSepStrBuff.append(rs.getString(12)).append("\t");
retTabSepStrBuff.append(rs.getString(13)).append("\t");
retTabSepStrBuff.append(rs.getString(14)).append("\t");
retTabSepStrBuff.append(rs.getString(15)).append("\t");
retTabSepStrBuff.append(rs.getDouble(16)).append("\t");
retTabSepStrBuff.append(rs.getString(17)).append("\t");
retTabSepStrBuff.append(rs.getDouble(18)).append("\t");
retTabSepStrBuff.append(rs.getString(19)).append("\t");
//retTabSepStrBuff.append(rs.getString(20)).append("\n"); //Gulzar 20/12/06
//Added by Gulzar 20/12/06
entryBatchNo = rs.getString(20);
if (entryBatchNo == null)
{
entryBatchNo = " ";
}
retTabSepStrBuff.append(entryBatchNo).append("\n");
//End Addition Gulzar 20/12/06
if (rs.next()) {
do {
/*
* retTabSepStrBuff.append(rs.getString(1)).append("\t");
* retTabSepStrBuff.append(rs.getString(2)).append("\t");
* retTabSepStrBuff.append(rs.getString(3)).append("\t");
* retTabSepStrBuff.append(rs.getString(4)).append("\t");
* retTabSepStrBuff.append(rs.getString(5)).append("\t");
* retTabSepStrBuff.append(rs.getString(6)).append("\t");
* retTabSepStrBuff.append(rs.getString(7)).append("\t");
* retTabSepStrBuff.append(rs.getString(8)).append("\t");
* retTabSepStrBuff.append(rs.getString(9)).append("\t");
* retTabSepStrBuff.append(rs.getString(10)).append("\t");
* retTabSepStrBuff.append(rs.getDouble(11)).append("\t");
* retTabSepStrBuff.append(rs.getString(12)).append("\t");
* retTabSepStrBuff.append(rs.getString(13)).append("\t");
* retTabSepStrBuff.append(rs.getString(14)).append("\t");
* retTabSepStrBuff.append(rs.getString(15)).append("\t");
* retTabSepStrBuff.append(rs.getDouble(16)).append("\t");
* retTabSepStrBuff.append(rs.getString(17)).append("\t");
* retTabSepStrBuff.append(rs.getDouble(18)).append("\t");
* retTabSepStrBuff.append(rs.getString(19)).append("\t");
* //retTabSepStrBuff.append(rs.getString(20)).append("\n");
* //Gulzar 20/12/06 //Added by Gulzar 20/12/06 entryBatchNo
* = rs.getString(20); if (entryBatchNo == null) {
* entryBatchNo = " "; }
* retTabSepStrBuff.append(entryBatchNo).append("\n"); //End
* Addition Gulzar 20/12/06
*/
entryBatchNo = rs.getString("ENTRY_BATCH_NO");
if (entryBatchNo == null)
{
if (entryBatchNo == null) {
entryBatchNo = " ";
}
retTabSepStrBuff.append("<Detail2>");
retTabSepStrBuff.append("<entry_batch_no>").append("<![CDATA[" + entryBatchNo +"]]>").append("</entry_batch_no>");
retTabSepStrBuff.append("<ref_no>").append("<![CDATA[" + rs.getString("REF_NO") +"]]>").append("</ref_no>");
retTabSepStrBuff.append("<ref_date>").append("<![CDATA[" +sdf.format(rs.getTimestamp("REF_DATE")) +"]]>").append("</ref_date>");
retTabSepStrBuff.append("<amount>").append("<![CDATA[" + rs.getString("AMOUNT") +"]]>").append("</amount>");
retTabSepStrBuff.append("<curr_code>").append("<![CDATA[" + rs.getString("CURR_CODE") +"]]>").append("</curr_code>");
retTabSepStrBuff.append("<amount_curr>").append("<![CDATA[" + rs.getDouble("AMOUNT") / rs.getDouble("EXCH_RATE") +"]]>").append("</amount_curr>");
retTabSepStrBuff.append("<tran_type>").append("<![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("<entry_batch_no>").append(
"<![CDATA[" + entryBatchNo + "]]>").append(
"</entry_batch_no>");
retTabSepStrBuff.append("<ref_no>").append(
"<![CDATA[" + rs.getString("REF_NO") + "]]>")
.append("</ref_no>");
retTabSepStrBuff.append("<ref_date>").append(
"<![CDATA["
+ sdf.format(rs.getTimestamp("REF_DATE"))
+ "]]>").append("</ref_date>");
retTabSepStrBuff.append("<amount>").append(
"<![CDATA[" + rs.getString("AMOUNT") + "]]>")
.append("</amount>");
retTabSepStrBuff.append("<curr_code>").append(
"<![CDATA[" + rs.getString("CURR_CODE") + "]]>")
.append("</curr_code>");
retTabSepStrBuff.append("<amount_curr>").append(
"<![CDATA[" + rs.getDouble("AMOUNT")
/ rs.getDouble("EXCH_RATE") + "]]>")
.append("</amount_curr>");
retTabSepStrBuff.append("<tran_type>").append(
"<![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>");
cnt++;
}while(rs.next());
} while (rs.next());
retTabSepStrBuff.append("</Header0>");
retTabSepStrBuff.append("</group0>");
retTabSepStrBuff.append("</DocumentRoot>");
resultString = retTabSepStrBuff.toString();
} else {
errCode = "VTNOREC2";
}
else
{
errCode ="VTNOREC2";
}
if (errCode != null && errCode.trim().length()>0)
{
errString = itmDBAccessEJB.getErrorString("", errCode, "", "", conn);
if (errCode != null && errCode.trim().length() > 0) {
errString = itmDBAccessEJB.getErrorString("", errCode, "", "",
conn);
resultString = errString;
System.out.println("errString: "+errString);
}
System.out.println("errString: " + errString);
}
catch (SQLException e)
{
System.out.println("Exception :BankRecoEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":");
} catch (SQLException e) {
System.out
.println("Exception :BankRecoEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):"
+ e.getMessage() + ":");
throw new ITMException(e);
}
catch (Exception e)
{
System.out.println("Exception :BankRecoEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":");
} catch (Exception e) {
System.out
.println("Exception :BankRecoEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):"
+ e.getMessage() + ":");
throw new ITMException(e);
}
finally
{
try
{
} finally {
try {
System.out.println("Closing Connection.....");
conn.close();
conn = null;
}catch(Exception e){}
} catch (Exception e) {
}
}
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 = "";
Document detailDom = null;
Document headerDom = null;
GenericUtility genericUtility = GenericUtility.getInstance();
try
{
if(xmlString2 != null && xmlString2.trim().length()!=0)
{
System.out.println("Detail XML String :"+xmlString2);
try {
if (xmlString2 != null && xmlString2.trim().length() != 0) {
System.out.println("Detail XML String :" + xmlString2);
detailDom = genericUtility.parseString(xmlString2);
}
if(xmlString != null && xmlString.trim().length()!=0)
{
System.out.println("Header XML String :"+xmlString);
if (xmlString != null && xmlString.trim().length() != 0) {
System.out.println("Header XML String :" + xmlString);
headerDom = genericUtility.parseString(xmlString);
}
retStr = process(headerDom, detailDom, windowName, xtraParams);
}
catch (Exception e)
{
System.out.println("Exception :BankRecoEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":");
} catch (Exception e) {
System.out
.println("Exception :BankRecoEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):"
+ e.getMessage() + ":");
throw new ITMException(e);
}
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 amount1 = 0;
double amtAdj = 0;
......@@ -302,7 +334,7 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
String errString = "";
ResultSet rs = null;
Connection conn = null;
//Statement stmt = null;
// Statement stmt = null;
PreparedStatement pstmt = null;
Document dom1;
int childNodeListLength = 0;
......@@ -314,130 +346,122 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
ConnDriver connDriver = new ConnDriver();
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
try
{
try {
conn = connDriver.getConnectDB("DriverITM");
parentNodeList = detailDom.getElementsByTagName("Detail2");
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);
for (int header = 0; header < parentNodeListLength; header++)
{
for (int header = 0; header < parentNodeListLength; header++) {
parentNode = parentNodeList.item(header);
childNodeList = parentNode.getChildNodes();
childNodeListLength = childNodeList.getLength();
for (int cntr = 0; cntr < childNodeListLength; cntr++)
{
for (int cntr = 0; cntr < childNodeListLength; cntr++) {
childNode = childNodeList.item(cntr);
childNodeName = childNode.getNodeName();
System.out.println("childNodeName [" + childNodeName + "]");
if (childNodeName.equals("tran_id"))
{
if(childNode.getFirstChild() != null)
{
if (childNodeName.equals("tran_id")) {
if (childNode.getFirstChild() != null) {
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"))
{
if(childNode.getFirstChild() != null)
{
} else if (childNodeName.equals("tran_ser")) {
if (childNode.getFirstChild() != null) {
tranSer = childNode.getFirstChild().getNodeValue();
}
System.out.println("childNodeName [" + childNodeName + "] NodeValue [" + childNode.getFirstChild().getNodeValue() + "]");
}
else if (childNodeName.equals("tran_no"))
{
if(childNode.getFirstChild() != null)
{
System.out.println("childNodeName [" + childNodeName
+ "] NodeValue ["
+ childNode.getFirstChild().getNodeValue()
+ "]");
} else if (childNodeName.equals("tran_no")) {
if (childNode.getFirstChild() != null) {
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();
//stmt = conn.createStatement();
//rs = stmt.executeQuery(sql);
if (rs.next())
{
// stmt = conn.createStatement();
// rs = stmt.executeQuery(sql);
if (rs.next()) {
amount = rs.getDouble(1);
amtAdj = rs.getDouble(2);
status = rs.getString(3);
exchRate = rs.getDouble(4);
if (exchRate == 0)
{
xmlStr = getBanklogExchRate(tranSer,tranNo);
if (exchRate == 0) {
xmlStr = getBanklogExchRate(tranSer, tranNo);
dom1 = genericUtility.parseString(xmlStr);
currCode = genericUtility.getColumnValue("curr_code",dom1);
exchRate1 = genericUtility.getColumnValue("exch_rate",dom1);
currCode = genericUtility.getColumnValue("curr_code",
dom1);
exchRate1 = genericUtility.getColumnValue("exch_rate",
dom1);
}
if (!status.equals("R"))
{
if (!status.equals("R")) {
amount = amount - amtAdj;
amount1 = amount1 + amount;
totalAmtBc = amount1 * exchRate;
totalAmtCurr = amount1 / exchRate;
cnt++;
}
else
{
} else {
errCode = "VTRECON1";
break;
}
}//if end
}// if end
rs.close();
rs = null;
pstmt.clearParameters();
}//outer for end
}// outer for end
pstmt.close();
pstmt = null;
System.out.println(" total cnt :"+cnt);
if (cnt <= 0)
{
System.out.println(" total cnt :" + cnt);
if (cnt <= 0) {
return "";
}
if (errCode != null && errCode.trim().length() > 0)
{
errString = itmDBAccessEJB.getErrorString("", errCode, "", "", conn);
if (errCode != null && errCode.trim().length() > 0) {
errString = itmDBAccessEJB.getErrorString("", errCode, "", "",
conn);
conn.close();
conn = null;
return errString;
}
errCode = updateTable(cnt,headerDom,detailDom,conn);
if (errCode != null || errCode.trim().length()>0)
{
errString = itmDBAccessEJB.getErrorString("", errCode, "", "", conn);
System.out.println("errString becomes: "+errString);
}
else
{
errString = itmDBAccessEJB.getErrorString("", "VTRECOSUCC", "", "", conn);
}
}
catch(Exception e)
{
System.out.println("Exception :BankRecoEJB :process(String xmlString2, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":");
errCode = updateTable(cnt, headerDom, detailDom, conn);
if (errCode != null || errCode.trim().length() > 0) {
errString = itmDBAccessEJB.getErrorString("", errCode, "", "",
conn);
System.out.println("errString becomes: " + errString);
} else {
errString = itmDBAccessEJB.getErrorString("", "VTRECOSUCC", "",
"", conn);
}
} catch (Exception e) {
System.out
.println("Exception :BankRecoEJB :process(String xmlString2, String xmlString2, String windowName, String xtraParams):"
+ e.getMessage() + ":");
throw new ITMException(e);
}
finally
{
try
{
} finally {
try {
System.out.println("Closing Connection.....");
conn.close();
conn = null;
}catch(Exception se){}
} catch (Exception se) {
}
}
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;
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 errString = "";
String childNodeName = null;
......@@ -464,7 +488,7 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
ArrayList tranIdList = new ArrayList();
ArrayList amountList = 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;
Statement stmt = null;
String keyStringQuery = "";
......@@ -484,24 +508,25 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
double amtLog = 0;
double amtAdj1 = 0;
int comp = 0;
double exchRateD = 0;
double amtAdjD = 0;
NodeList parentNodeList = null;
NodeList childNodeList = null;
Node parentNode = null;
Node childNode = null;
String xmlValues = "";
String effDate = "";
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();
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
try
{
//conn = getConnection();
//commented by rajendra on 31/03/09
//conn = connDriver.getConnectDB("DriverITM");
//ended by rajendra on 31/03/09
try {
// conn = getConnection();
// commented by rajendra on 31/03/09
// conn = connDriver.getConnectDB("DriverITM");
// ended by rajendra on 31/03/09
/*--- Commented by Gulzar as the logic to process single and multiple record should same 15/11/06
if (cnt == 1)
......@@ -610,226 +635,169 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
}
}//End of If()
else
{*/ //End Comment Gulzar 15/11/06
bankCode = genericUtility.getColumnValue("bank_code",headerDom);
effDate = genericUtility.getColumnValue("eff_date",headerDom);
refDate = genericUtility.getColumnValue("ref_date",headerDom);
if( effDate != null )
{
effDateTs = Timestamp.valueOf(genericUtility.getValidDateString(effDate, 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");
{*/// End Comment Gulzar 15/11/06
bankCode = genericUtility.getColumnValue("bank_code", headerDom);
effDate = genericUtility.getColumnValue("eff_date", headerDom);
refDate = genericUtility.getColumnValue("ref_date", headerDom);
if (effDate != null) {
effDateTs = Timestamp.valueOf(genericUtility
.getValidDateString(effDate, 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");
parentNodeListLength = parentNodeList.getLength();
for (int cntr = 0; cntr < parentNodeListLength; cntr++)
{
parentNode = parentNodeList.item(cntr);
System.out.println("parentNodeListLength:::::::::"
+ parentNodeListLength);
for (int selectedRow = 0; selectedRow < parentNodeListLength; selectedRow++) {
parentNode = parentNodeList.item(selectedRow);
childNodeList = parentNode.getChildNodes();
childNodeListLength = childNodeList.getLength();
for (int cnt2 = 0; cnt2 < childNodeListLength; cnt2++)
{
childNode = childNodeList.item(cnt2);
System.out.println("childNodeListLength::: "
+ childNodeListLength + "\n");
for (int childRow = 0; childRow < childNodeListLength; childRow++) {
childNode = childNodeList.item(childRow);
childNodeName = childNode.getNodeName();
if (childNodeName.equals("tran_id"))
{
System.out.println("Child node" + childNodeName);
if (childNodeName.equals("tran_id")) {
tranId = childNode.getFirstChild().getNodeValue();
tranIdList.add(cntr,tranId);
}
if (childNodeName.equals("amount"))
{
System.out.println("Tran id is:" + tranId);
} else if (childNodeName.equals("amount")) {
amount = childNode.getFirstChild().getNodeValue();
amountList.add(cntr,amount);
}
if (childNodeName.equals("amt_adj"))
{
System.out.println("Amount is:" + amount);
} else 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());
System.out.println("Amount Adj is:" + amtAdj);
}
*///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"))
{
else if (childNodeName.equals("tran_type")) {
tranType = childNode.getFirstChild().getNodeValue();
}
else if (childNodeName.equals("tran_date"))
{
} else if (childNodeName.equals("tran_date")) {
tranDate = childNode.getFirstChild().getNodeValue();
}
else if (childNodeName.equals("bank_code"))
{
} else if (childNodeName.equals("bank_code")) {
bankCode = childNode.getFirstChild().getNodeValue();
}
else if (childNodeName.equals("site_code"))
{
} else if (childNodeName.equals("site_code")) {
siteCode = childNode.getFirstChild().getNodeValue();
}
else if (childNodeName.equals("tran_ser"))
{
} else if (childNodeName.equals("tran_ser")) {
tranSer = childNode.getFirstChild().getNodeValue();
}
else if (childNodeName.equals("tran_no"))
{
} else if (childNodeName.equals("tran_no")) {
tranNo = childNode.getFirstChild().getNodeValue();
}
else if (childNodeName.equals("ref_no"))
{
} else if (childNodeName.equals("ref_no")) {
refNo = childNode.getFirstChild().getNodeValue();
}
else if (childNodeName.equals("ref_date"))
{
} else if (childNodeName.equals("ref_date")) {
refDate = childNode.getFirstChild().getNodeValue();
}
else if (childNodeName.equals("ref_mode"))
{
} else if (childNodeName.equals("ref_mode")) {
refMode = childNode.getFirstChild().getNodeValue();
}
else if (childNodeName.equals("sundry_code"))
{
} else if (childNodeName.equals("sundry_code")) {
sundryCode = childNode.getFirstChild().getNodeValue();
}
else if (childNodeName.equals("acct_code"))
{
} else if (childNodeName.equals("acct_code")) {
acctCode = childNode.getFirstChild().getNodeValue();
}
else if (childNodeName.equals("cctr_code"))
{
} else if (childNodeName.equals("cctr_code")) {
cctrCode = childNode.getFirstChild().getNodeValue();
}
else if (childNodeName.equals("remarks"))
{
} else if (childNodeName.equals("remarks")) {
remarks = childNode.getFirstChild().getNodeValue();
}
else if (childNodeName.equals("curr_code"))
{
} else if (childNodeName.equals("curr_code")) {
currCode = childNode.getFirstChild().getNodeValue();
}
else if (childNodeName.equals("exch_rate"))
{
} else if (childNodeName.equals("exch_rate")) {
exchRate = childNode.getFirstChild().getNodeValue();
}
}//for end
status = "R";
}// end inner for
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);
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
currCode = genericUtility.getColumnValue("curr_code", dom1);
exchRate = genericUtility.getColumnValue("exch_rate", dom1);
amtAdjBase = amtAdjD * exchRateD;
} else {
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 */
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)
{
// int loop = amountList.size();
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(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
amt = Double.valueOf(amount);
System.out.println("Amount@@@@@@@@@@@@" + amt);
amt3 = Double.valueOf(amtAdj);
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);
......@@ -849,116 +817,290 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
pstmt.setDate(16, effDate1);
pstmt.setString(17, "Y");
pstmt.setDate(18, currDate);
pstmt.setString(19, exchRate);
pstmt.setDouble(19, exchRateD);
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);
System.out.println("insertSql is :" + insertSql);
System.out.println("insertCnt :" + insertCnt);
System.out.println("counter :" + counter);
if (insertCnt != 0) {
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());
System.out.println("insertSql :" + insertSql);
System.out.println("tranIdList.get(intcnt).toString() :"
+ tranId);
PreparedStatement pstmt1 = conn.prepareStatement(insertSql);
pstmt1.setString(1, uniqueKey);
pstmt1.setString(2, tranIdList.get(c).toString());
pstmt1.setString(2, tranId);
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
System.out.println("insertCnt :" + insertCnt);
System.out.println("cnt :" + cnt);
updateSql = "UPDATE BANKTRAN_LOG SET STATUS = ?, AMT_ADJ = AMT_ADJ + ?, EXCH_RATE = ?, CURR_CODE = ?"
+" WHERE TRAN_ID = ?";
System.out.println("updateSql :"+updateSql);
+ " 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.setDouble(3, exchRateD);
pstmt2.setString(4, currCode);
pstmt2.setString(5, tranIdList.get(c).toString());
pstmt2.setString(5, tranId);
updateCnt = pstmt2.executeUpdate();
System.out.println("updateCnt :"+updateCnt);
System.out.println("updateCnt :" + updateCnt);
pstmt2.close();
pstmt2 = null;
conn.commit();
// 12/05/09 manoharan changed the message
//errCode = "VMSUCC";
// errCode = "VMSUCC";
errCode = "VTPRC1";
pstmt.close();
pstmt = null;
}
else
{
} else {
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();
throw new ITMException(e);
}
catch(Exception e)
{
} catch (Exception e) {
e.printStackTrace();
throw new ITMException(e);
}
// 12/05/09 manoharan passed connection not to be closed
/*finally
{
try
{
System.out.println("Closing Connection......");
conn.close();
conn = null;
}
catch(SQLException se){}
}*/
System.out.println("errString: "+errCode);
/*
* finally { try { System.out.println("Closing Connection......");
* conn.close(); conn = null; } catch(SQLException se){} }
*/
System.out.println("errString: " + errCode);
return errCode;
}
private String getBanklogExchRate(String tranSer, String tranNo) throws RemoteException,ITMException
{
System.out.println("TranSer :"+tranSer);
private String getBanklogExchRate(String tranSer, String tranNo)
throws RemoteException, ITMException {
System.out.println("TranSer :" + tranSer);
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;
Statement stmt = null;
Connection conn = null;
......@@ -966,79 +1108,70 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
boolean isSql = false;
ConnDriver connDriver = new ConnDriver();
String sql = "";
try
{
try {
conn = connDriver.getConnectDB("DriverITM");
stmt = conn.createStatement();
if (tranSer.equals("E-PAY"))
{
sql = "SELECT CURR_CODE, EXCH_RATE FROM PAYMENT_EXP WHERE TRAN_ID = '"+ tranNo +"'";
if (tranSer.equals("E-PAY")) {
sql = "SELECT CURR_CODE, EXCH_RATE FROM PAYMENT_EXP WHERE TRAN_ID = '"
+ tranNo + "'";
isSql = true;
}
else if (tranSer.equals("F-XFR"))
{
sql = "SELECT CURR_CODE, EXCH_RATE FROM FUNDTRANSFER WHERE TRAN_ID = '"+ tranNo +"'";
} else if (tranSer.equals("F-XFR")) {
sql = "SELECT CURR_CODE, EXCH_RATE FROM FUNDTRANSFER WHERE TRAN_ID = '"
+ tranNo + "'";
isSql = true;
}
else if (tranSer.equals("M-PAY"))
{
sql = "SELECT CURR_CODE, EXCH_RATE FROM MISC_PAYMENT WHERE TRAN_ID = '"+ tranNo +"'";
} else if (tranSer.equals("M-PAY")) {
sql = "SELECT CURR_CODE, EXCH_RATE FROM MISC_PAYMENT WHERE TRAN_ID = '"
+ tranNo + "'";
isSql = true;
}
else if (tranSer.equals("M-RCP"))
{
sql = "SELECT CURR_CODE, EXCH_RATE FROM MISC_RECEIPT WHERE TRAN_ID = '"+ tranNo +"'";
} else if (tranSer.equals("M-RCP")) {
sql = "SELECT CURR_CODE, EXCH_RATE FROM MISC_RECEIPT WHERE TRAN_ID = '"
+ tranNo + "'";
isSql = true;
}
else if (tranSer.equals("MPCANC"))
{
sql = "SELECT CURR_CODE, EXCH_RATE FROM MISC_PAYMENT_CANC WHERE TRAN_ID = '"+ tranNo +"'";
} else if (tranSer.equals("MPCANC")) {
sql = "SELECT CURR_CODE, EXCH_RATE FROM MISC_PAYMENT_CANC WHERE TRAN_ID = '"
+ tranNo + "'";
isSql = true;
}
else if (tranSer.equals("R-DIS"))
{
sql = "SELECT CURR_CODE, EXCH_RATE FROM RCPDISHNR WHERE TRAN_ID = '"+ tranNo +"'";
} else if (tranSer.equals("R-DIS")) {
sql = "SELECT CURR_CODE, EXCH_RATE FROM RCPDISHNR WHERE TRAN_ID = '"
+ tranNo + "'";
isSql = true;
}
else if (tranSer.equals("RCP"))
{
sql = "SELECT CURR_CODE, EXCH_RATE FROM RECEIPT WHERE TRAN_ID = '"+ tranNo +"'";
} else if (tranSer.equals("RCP")) {
sql = "SELECT CURR_CODE, EXCH_RATE FROM RECEIPT WHERE TRAN_ID = '"
+ tranNo + "'";
isSql = true;
}
else if (tranSer.equals("E-FUND"))
{
sql = "SELECT CURR_CODE, EXCH_RATE FROM EXPORT_FUND WHERE TRAN_ID = '"+ tranNo +"'";
} else if (tranSer.equals("E-FUND")) {
sql = "SELECT CURR_CODE, EXCH_RATE FROM EXPORT_FUND WHERE TRAN_ID = '"
+ tranNo + "'";
isSql = true;
}
if (isSql)
{
if (isSql) {
rs = stmt.executeQuery(sql);
if (rs.next())
{
if (rs.next()) {
valueXmlString.append("<Detail>\r\n");
valueXmlString.append("<curr_code>").append(rs.getString(1)).append("</curr_code>\r\n") ;
valueXmlString.append("<exch_rate>").append(rs.getString(2)).append("</exch_rate>\r\n");
valueXmlString.append("<curr_code>")
.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");
}
}
stmt.close();
valueXmlString.append("</Root>\r\n");
}
catch(Exception e)
{
System.out.println("Exception :ITMDBAccessEJB :getBanklogExchRate(String xmlString, String xmlString2):" + e.getMessage() + ":");
} catch (Exception e) {
System.out
.println("Exception :ITMDBAccessEJB :getBanklogExchRate(String xmlString, String xmlString2):"
+ e.getMessage() + ":");
throw new ITMException(e);
}
finally
{
try
{
} finally {
try {
System.out.println("Closing Connection.......");
conn.close();
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();
}
}
\ 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