Skip to content

B
business-java
Commit ea8e008c authored by manohar's avatar manohar
Browse files
Options

instead of tab delimited xml returned 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@94465 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 0deb726d
Hide whitespace changes
Inline Side-by-side
Showing with 121 additions and 37 deletions
webitm-fin/ibase/webitm/ejb/fin/adv/BankRecoPrc.java
View file @ ea8e008c
...@@ -13,7 +13,7 @@ import java.util.*; ...@@ -13,7 +13,7 @@ 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 ibase.webitm.utility.ITMException; import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*; import ibase.webitm.ejb.*;
import ibase.webitm.utility.GenericUtility; import ibase.webitm.utility.GenericUtility;
...@@ -93,40 +93,48 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -93,40 +93,48 @@ 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();
ConnDriver connDriver = new ConnDriver(); StringBuffer retTabSepStrBuff = new StringBuffer("<?xml version = \"1.0\"?>");
retTabSepStrBuff.append("<DocumentRoot>");
retTabSepStrBuff.append("<description>").append("Datawindow Root").append("</description>");
retTabSepStrBuff.append("<group0>");
retTabSepStrBuff.append("<description>").append("Group0 description").append("</description>");
retTabSepStrBuff.append("<Header0>");
ConnDriver connDriver = new ConnDriver();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB(); ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
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());
if( refDate != null ) if( refDate != null )
{ {
refDateTs = Timestamp.valueOf(genericUtility.getValidDateString(refDate, genericUtility.getApplDateFormat(), genericUtility.getDBDateFormat()) + " 00:00:00.0"); refDateTs = Timestamp.valueOf(genericUtility.getValidDateString(refDate, genericUtility.getApplDateFormat(), genericUtility.getDBDateFormat()) + " 00:00:00.0");
} }
getDataSql ="SELECT BANKTRAN_LOG.TRAN_ID," getDataSql ="SELECT TRAN_ID,"
+"BANKTRAN_LOG.TRAN_TYPE," +" TRAN_TYPE,"
+"BANKTRAN_LOG.TRAN_DATE," +" TRAN_DATE,"
+"BANKTRAN_LOG.BANK_CODE," +" BANK_CODE,"
+"BANKTRAN_LOG.SITE_CODE," +" SITE_CODE,"
+"BANKTRAN_LOG.TRAN_SER," +" TRAN_SER,"
+"BANKTRAN_LOG.TRAN_NO," +" TRAN_NO,"
+"BANKTRAN_LOG.REF_NO," +" REF_NO,"
+"BANKTRAN_LOG.REF_DATE," +" REF_DATE,"
+"BANKTRAN_LOG.REF_MODE," +" REF_MODE,"
+"BANKTRAN_LOG.AMOUNT," +" AMOUNT,"
+"BANKTRAN_LOG.SUNDRY_CODE," +" SUNDRY_CODE,"
+"BANKTRAN_LOG.ACCT_CODE," +" ACCT_CODE,"
+"BANKTRAN_LOG.CCTR_CODE," +" CCTR_CODE,"
+"BANKTRAN_LOG.STATUS," +" STATUS,"
+"BANKTRAN_LOG.AMT_ADJ," +" AMT_ADJ,"
+"BANKTRAN_LOG.REMARKS," +" REMARKS,"
+"BANKTRAN_LOG.EXCH_RATE," +" EXCH_RATE,"
+"BANKTRAN_LOG.CURR_CODE," +" CURR_CODE,"
+"BANKTRAN_LOG.ENTRY_BATCH_NO " +" ENTRY_BATCH_NO "
+"FROM BANKTRAN_LOG " +"FROM BANKTRAN_LOG "
+"WHERE (BANKTRAN_LOG.BANK_CODE = ? ) " +"WHERE (BANKTRAN_LOG.BANK_CODE = ? ) "
+" AND( BANKTRAN_LOG.STATUS IN ( 'P','E' ) ) " +" AND( BANKTRAN_LOG.STATUS IN ( 'P','E' ) ) "
...@@ -142,7 +150,7 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -142,7 +150,7 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
{ {
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");
...@@ -170,9 +178,43 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -170,9 +178,43 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
} }
retTabSepStrBuff.append(entryBatchNo).append("\n"); retTabSepStrBuff.append(entryBatchNo).append("\n");
//End Addition Gulzar 20/12/06 //End Addition Gulzar 20/12/06
*/
entryBatchNo = rs.getString("ENTRY_BATCH_NO");
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("<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++; cnt++;
}while(rs.next()); }while(rs.next());
retTabSepStrBuff.append("</Header0>");
retTabSepStrBuff.append("</group0>");
retTabSepStrBuff.append("</DocumentRoot>");
resultString = retTabSepStrBuff.toString(); resultString = retTabSepStrBuff.toString();
} }
else else
...@@ -257,7 +299,8 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -257,7 +299,8 @@ 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;
Document dom1; Document dom1;
int childNodeListLength = 0; int childNodeListLength = 0;
int parentNodeListLength = 0; int parentNodeListLength = 0;
...@@ -273,6 +316,8 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -273,6 +316,8 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
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+"'";
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);
...@@ -282,23 +327,36 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -282,23 +327,36 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
{ {
childNode = childNodeList.item(cntr); childNode = childNodeList.item(cntr);
childNodeName = childNode.getNodeName(); childNodeName = childNode.getNodeName();
System.out.println("childNodeName [" + childNodeName + "]");
if (childNodeName.equals("tran_id")) if (childNodeName.equals("tran_id"))
{ {
tranId = childNode.getFirstChild().getNodeValue(); if(childNode.getFirstChild() != null)
{
tranId = childNode.getFirstChild().getNodeValue();
System.out.println("childNodeName [" + childNodeName + "] NodeValue [" + childNode.getFirstChild().getNodeValue() + "]");
}
} }
else if (childNodeName.equals("tran_ser")) else if (childNodeName.equals("tran_ser"))
{ {
tranSer = childNode.getFirstChild().getNodeValue(); if(childNode.getFirstChild() != null)
{
tranSer = childNode.getFirstChild().getNodeValue();
}
System.out.println("childNodeName [" + childNodeName + "] NodeValue [" + childNode.getFirstChild().getNodeValue() + "]");
} }
else if (childNodeName.equals("tran_no")) else if (childNodeName.equals("tran_no"))
{ {
tranNo = childNode.getFirstChild().getNodeValue(); if(childNode.getFirstChild() != null)
{
tranNo = childNode.getFirstChild().getNodeValue();
}
System.out.println("childNodeName [" + childNodeName + "] NodeValue [" + childNode.getFirstChild().getNodeValue() + "]");
} }
} }
sql = "SELECT AMOUNT, AMT_ADJ, STATUS, EXCH_RATE FROM BANKTRAN_LOG WHERE TRAN_ID = '"+tranId+"'"; pstmt.setString(1,tranId);
System.out.println("The sql becomes :"+sql); 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);
...@@ -326,9 +384,14 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -326,9 +384,14 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
break; break;
} }
}//if end }//if end
rs.close();
rs = null;
pstmt.clearParameters();
}//outer for end }//outer for end
System.out.println("cnt :"+cnt); pstmt.close();
pstmt = null;
System.out.println(" total cnt :"+cnt);
if (cnt <= 0) if (cnt <= 0)
{ {
return ""; return "";
...@@ -346,6 +409,10 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -346,6 +409,10 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
errString = itmDBAccessEJB.getErrorString("", errCode, "", "", conn); errString = itmDBAccessEJB.getErrorString("", errCode, "", "", conn);
System.out.println("errString becomes: "+errString); System.out.println("errString becomes: "+errString);
} }
else
{
errString = itmDBAccessEJB.getErrorString("", "VTRECOSUCC", "", "", conn);
}
} }
catch(Exception e) catch(Exception e)
{ {
...@@ -418,6 +485,10 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -418,6 +485,10 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
NodeList childNodeList = null; NodeList childNodeList = null;
Node parentNode = null; Node parentNode = null;
Node childNode = null; Node childNode = null;
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(); // ConnDriver connDriver = new ConnDriver();
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
...@@ -537,6 +608,19 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -537,6 +608,19 @@ 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);
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");
}
parentNodeList = detailDom.getElementsByTagName("Detail2"); parentNodeList = detailDom.getElementsByTagName("Detail2");
parentNodeListLength = parentNodeList.getLength(); parentNodeListLength = parentNodeList.getLength();
for (int cntr = 0; cntr < parentNodeListLength; cntr++) for (int cntr = 0; cntr < parentNodeListLength; cntr++)
...@@ -669,7 +753,7 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -669,7 +753,7 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
/* 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());
String 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'"; keyStringQuery = "SELECT KEY_STRING, TRAN_ID_COL, REF_SER FROM TRANSETUP WHERE UPPER(TRAN_WINDOW) = 'W_BANK_STATEMENT'";
stmt = conn.createStatement(); stmt = conn.createStatement();
rSet = stmt.executeQuery(keyStringQuery); rSet = stmt.executeQuery(keyStringQuery);
...@@ -716,11 +800,11 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco ...@@ -716,11 +800,11 @@ public class BankRecoPrc extends ProcessEJB implements BankRecoPrcLocal,BankReco
amtAdj = Double.toString(amt); amtAdj = Double.toString(amt);
}*///Gulzar 15/11/06 }*///Gulzar 15/11/06
//double amtAdj1 = Double.parseDouble(amtAdj); //Gulzar 15/11/06 //double amtAdj1 = Double.parseDouble(amtAdj); //Gulzar 15/11/06
java.sql.Date effDate1 = java.sql.Date.valueOf(genericUtility.getValidDateString(effDate,"dd/MM/yy",genericUtility.getDBDateFormat())); java.sql.Date effDate1 = java.sql.Date.valueOf(genericUtility.getValidDateString(effDate,genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat()));
System.out.println("effDate1 :"+effDate1); System.out.println("effDate1 :"+effDate1);
System.out.println("refDate :"+new java.sql.Date(System.currentTimeMillis())); System.out.println("refDate :"+new java.sql.Date(System.currentTimeMillis()));
String refDate1 = refDate.substring(0,10); //String refDate1 = refDate.substring(0,10);
java.sql.Date refDate2 = java.sql.Date.valueOf(refDate1); java.sql.Date refDate2 = java.sql.Date.valueOf(genericUtility.getValidDateString(refDate,genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat()));
System.out.println("refDate2 :"+refDate2); System.out.println("refDate2 :"+refDate2);
insertSql ="INSERT INTO BANK_STATEMENT(TRAN_ID, BANK_CODE, SITE_CODE, REF_NO, REF_DATE," 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," +" REF_MODE, AMOUNT, TRAN_TYPE, EDI_REF, REMARKS, STATUS, CHG_DATE, CHG_USER, CHG_TERM,"
......
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