Skip to content

B
business-java
Commit 71bfc693 authored by prane's avatar prane
Browse files
Options

Open Cursor Issue in PayablesOpenings 

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@190826 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 52d28ae9
Hide whitespace changes
Inline Side-by-side
Showing with 224 additions and 103 deletions
webitm-fin/ibase/webitm/ejb/fin/PayableOpenings.java
View file @ 71bfc693
...@@ -80,8 +80,8 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -80,8 +80,8 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
{ {
Connection conn = null; Connection conn = null;
Statement stmt = null; //Statement stmt = null;
PreparedStatement pstmt = null; PreparedStatement pstmt = null, pstmt1 = null;
ResultSet rs = null; ResultSet rs = null;
ResultSet rs1 = null; ResultSet rs1 = null;
StringBuffer valueXmlString = new StringBuffer(); StringBuffer valueXmlString = new StringBuffer();
...@@ -165,12 +165,17 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -165,12 +165,17 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
sql = "SELECT ACCT_PRD FROM PARAMETER"; sql = "SELECT ACCT_PRD FROM PARAMETER";
stmt = conn.createStatement(); //stmt = conn.createStatement();
rs = stmt.executeQuery(sql); pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
accPrd = rs.getString(1); accPrd = rs.getString(1);
} }
rs.close();
rs = null;
pstmt.close();
pstmt = null;
try try
{ {
sql = "SELECT A.DESCR,A.FIN_ENTITY,B.CURR_CODE,C.DESCR " sql = "SELECT A.DESCR,A.FIN_ENTITY,B.CURR_CODE,C.DESCR "
...@@ -188,7 +193,10 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -188,7 +193,10 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
currCode = rs.getString(3); currCode = rs.getString(3);
currDescr = rs.getString(4); currDescr = rs.getString(4);
} }
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("SiteCode ::- "+loginSite); System.out.println("SiteCode ::- "+loginSite);
System.out.println("SiteCode Desc ::-"+siteDescr); System.out.println("SiteCode Desc ::-"+siteDescr);
System.out.println("FinEntity ::- "+finEnt); System.out.println("FinEntity ::- "+finEnt);
...@@ -237,7 +245,10 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -237,7 +245,10 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
currCode = rs.getString(3); currCode = rs.getString(3);
currDescr = rs.getString(4); currDescr = rs.getString(4);
} }
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("SiteCode ::- "+columnValue); System.out.println("SiteCode ::- "+columnValue);
System.out.println("SiteCode Desc ::- "+siteDescr); System.out.println("SiteCode Desc ::- "+siteDescr);
System.out.println("FinEntity ::- "+finEnt); System.out.println("FinEntity ::- "+finEnt);
...@@ -301,16 +312,19 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -301,16 +312,19 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
valueXmlString.append("<tran_id>").append(tranId).append("</tran_id>"); valueXmlString.append("<tran_id>").append(tranId).append("</tran_id>");
sqlEx = "SELECT CURR_CODE FROM FINENT WHERE FIN_ENTITY = '"+finEnt.trim()+"'"; sqlEx = "SELECT CURR_CODE FROM FINENT WHERE FIN_ENTITY = '"+finEnt.trim()+"'";
System.out.println("Exchange sql ::- " + sqlEx); //System.out.println("Exchange sql ::- " + sqlEx);
stmt = conn.createStatement(); //stmt = conn.createStatement();
rs = stmt.executeQuery(sqlEx); pstmt = conn.prepareStatement(sqlEx);
rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
dbCurrCode = rs.getString(1); dbCurrCode = rs.getString(1);
System.out.println("Curr Code from data base ::-"+dbCurrCode); System.out.println("Curr Code from data base ::-"+dbCurrCode);
} }
rs.close(); rs.close();
stmt.close(); rs = null;
pstmt.close();
pstmt = null;
if (currCode.trim().equalsIgnoreCase(dbCurrCode.trim())) if (currCode.trim().equalsIgnoreCase(dbCurrCode.trim()))
{ {
valueXmlString.append("<exch_rate protect = '1'>").append("1").append("</exch_rate>"); valueXmlString.append("<exch_rate protect = '1'>").append("1").append("</exch_rate>");
...@@ -333,21 +347,29 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -333,21 +347,29 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
sundryCode = " "; sundryCode = " ";
} }
sql = "SELECT CR_TERM FROM SUPPLIER WHERE SUPP_CODE = '"+sundryCode+"'"; sql = "SELECT CR_TERM FROM SUPPLIER WHERE SUPP_CODE = '"+sundryCode+"'";
stmt = conn.createStatement(); //stmt = conn.createStatement();
rs = stmt.executeQuery(sql); pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
crTerm = rs.getString("CR_TERM"); crTerm = rs.getString("CR_TERM");
} }
rs.close(); rs.close();
rs = null;
pstmt.close();
pstmt = null;
sql = "SELECT CR_DAYS FROM CRTERM WHERE CR_TERM ='" +crTerm+ "'"; sql = "SELECT CR_DAYS FROM CRTERM WHERE CR_TERM ='" +crTerm+ "'";
rs = stmt.executeQuery(sql); //rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
crDays = rs.getInt("CR_DAYS"); crDays = rs.getInt("CR_DAYS");
} }
rs.close(); rs.close();
stmt.close(); rs = null;
pstmt.close();
pstmt = null;
System.out.println("columnValue : " + columnValue); System.out.println("columnValue : " + columnValue);
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getApplDateFormat()); SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
Calendar cal = Calendar.getInstance(); Calendar cal = Calendar.getInstance();
...@@ -416,9 +438,10 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -416,9 +438,10 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
+ "PAY_MODE,ADV_AMT,PURC_ORDER,ENTRY_BATCH_NO " + "PAY_MODE,ADV_AMT,PURC_ORDER,ENTRY_BATCH_NO "
+ "FROM MISC_PAYABLES WHERE TRAN_SER = '"+tranSer.trim()+"' " + "FROM MISC_PAYABLES WHERE TRAN_SER = '"+tranSer.trim()+"' "
+ "AND REF_NO = '"+columnValue.trim()+"' AND REF_TYPE ='OPN'"; //REF_TYPE ADDED GULZAR 04-12-06 + "AND REF_NO = '"+columnValue.trim()+"' AND REF_TYPE ='OPN'"; //REF_TYPE ADDED GULZAR 04-12-06
System.out.println("REF SQL................."+refSql); //System.out.println("REF SQL................."+refSql);
stmt = conn.createStatement(); //stmt = conn.createStatement();
rs = stmt.executeQuery(refSql); pstmt = conn.prepareStatement(refSql);
rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
System.out.println("Inside result set................."); System.out.println("Inside result set.................");
...@@ -444,8 +467,8 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -444,8 +467,8 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
{ {
cctrCode = " "; cctrCode = " ";
} }
rs.close(); //rs.close();
stmt.close(); //stmt.close();
ArrayList arrList = new ArrayList(); ArrayList arrList = new ArrayList();
...@@ -483,16 +506,19 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -483,16 +506,19 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
valueXmlString.append("<cctr_code protect = '0'>").append("</cctr_code>"); valueXmlString.append("<cctr_code protect = '0'>").append("</cctr_code>");
sqlEx = "SELECT CURR_CODE FROM FINENT WHERE FIN_ENTITY ='" +finEnt+ "'"; sqlEx = "SELECT CURR_CODE FROM FINENT WHERE FIN_ENTITY ='" +finEnt+ "'";
System.out.println("EXCHANGE SQL 2 ::- "+sqlEx); //System.out.println("EXCHANGE SQL 2 ::- "+sqlEx);
stmt = conn.createStatement(); //stmt = conn.createStatement();
rs1 = stmt.executeQuery(sqlEx); pstmt1 = conn.prepareStatement(sqlEx);
rs1 = pstmt1.executeQuery();
if(rs1.next()) if(rs1.next())
{ {
dbCurrCode = rs1.getString(1); dbCurrCode = rs1.getString(1);
System.out.println("Curr Code from DATA BASE ::- "+dbCurrCode); System.out.println("Curr Code from DATA BASE ::- "+dbCurrCode);
} }
rs1.close(); rs1.close();
stmt.close(); rs1 = null;
pstmt1.close();
pstmt1 = null;
if (currCode.trim().equalsIgnoreCase(dbCurrCode)) if (currCode.trim().equalsIgnoreCase(dbCurrCode))
{ {
valueXmlString.append("<exch_rate protect = '1'>").append("1").append("</exch_rate>"); valueXmlString.append("<exch_rate protect = '1'>").append("1").append("</exch_rate>");
...@@ -513,6 +539,11 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -513,6 +539,11 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
valueXmlString.append("<purc_order>").append("</purc_order>"); valueXmlString.append("<purc_order>").append("</purc_order>");
valueXmlString.append("<entry_batch_no>").append("</entry_batch_no>"); valueXmlString.append("<entry_batch_no>").append("</entry_batch_no>");
} }
rs.close();
rs = null;
pstmt.close();
pstmt = null;
}//try }//try
catch(Exception e) catch(Exception e)
{ {
...@@ -601,21 +632,28 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -601,21 +632,28 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
columnValue = " "; columnValue = " ";
} }
sql = "SELECT CR_TERM FROM SUPPLIER WHERE SUPP_CODE = '"+columnValue+"'"; sql = "SELECT CR_TERM FROM SUPPLIER WHERE SUPP_CODE = '"+columnValue+"'";
stmt = conn.createStatement(); //stmt = conn.createStatement();
rs = stmt.executeQuery(sql); pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
crTerm = rs.getString("CR_TERM"); crTerm = rs.getString("CR_TERM");
} }
rs.close(); rs.close();
rs = null;
pstmt.close();
pstmt = null;
sql = "SELECT CR_DAYS FROM CRTERM WHERE CR_TERM ='" +crTerm+ "'"; sql = "SELECT CR_DAYS FROM CRTERM WHERE CR_TERM ='" +crTerm+ "'";
rs = stmt.executeQuery(sql); pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
crDays = rs.getInt("CR_DAYS"); crDays = rs.getInt("CR_DAYS");
} }
rs.close(); rs.close();
stmt.close(); rs = null;
pstmt.close();
pstmt = null;
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getApplDateFormat()); SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
Calendar cal = Calendar.getInstance(); Calendar cal = Calendar.getInstance();
...@@ -679,9 +717,9 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -679,9 +717,9 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
public String wfValData(Document dom, Document dom1,Document dom2, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException public String wfValData(Document dom, Document dom1,Document dom2, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException
{ {
Connection conn = null; Connection conn = null;
Statement stmt = null; //Statement stmt = null;
PreparedStatement pstmt = null; PreparedStatement pstmt = null, pstmt1 = null;
ResultSet rs = null; ResultSet rs = null,rs1 = null;
String errString = ""; String errString = "";
String errCode = ""; String errCode = "";
String sql = ""; String sql = "";
...@@ -705,7 +743,7 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -705,7 +743,7 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
try try
{ {
conn = getConnection(); conn = getConnection();
stmt = conn.createStatement(); //stmt = conn.createStatement();
userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"userId"); userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"userId");
System.out.println("userId = "+userId); System.out.println("userId = "+userId);
loginSite = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode"); loginSite = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode");
...@@ -841,24 +879,32 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -841,24 +879,32 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
System.out.println("tranSer : " + tranSer); System.out.println("tranSer : " + tranSer);
System.out.println("refNo : " + refNo); System.out.println("refNo : " + refNo);
sql = "SELECT COUNT(*) AS COUNT FROM MISC_PAYABLES WHERE TRAN_SER = '"+tranSer+"' AND REF_NO = '"+refNo+"'"; sql = "SELECT COUNT(*) AS COUNT FROM MISC_PAYABLES WHERE TRAN_SER = '"+tranSer+"' AND REF_NO = '"+refNo+"'";
System.out.println("sql : " + sql); //System.out.println("sql : " + sql);
rs = stmt.executeQuery(sql); pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
refTypeCnt = rs.getInt("COUNT"); refTypeCnt = rs.getInt("COUNT");
} }
rs.close(); rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("refTypeCnt : " + refTypeCnt); System.out.println("refTypeCnt : " + refTypeCnt);
if (refTypeCnt > 0) if (refTypeCnt > 0)
{ {
sql = "SELECT (CASE WHEN REF_TYPE IS NULL THEN ' ' ELSE REF_TYPE END) AS REF_TYPE FROM MISC_PAYABLES WHERE TRAN_SER = '"+tranSer+"' AND REF_NO = '"+refNo+"'"; sql = "SELECT (CASE WHEN REF_TYPE IS NULL THEN ' ' ELSE REF_TYPE END) AS REF_TYPE FROM MISC_PAYABLES WHERE TRAN_SER = '"+tranSer+"' AND REF_NO = '"+refNo+"'";
System.out.println("sql : " + sql); //System.out.println("sql : " + sql);
rs = stmt.executeQuery(sql); pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
refType = rs.getString("REF_TYPE"); refType = rs.getString("REF_TYPE");
} }
rs.close(); rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("refType : " + refType); System.out.println("refType : " + refType);
if (!refType.equals("OPN")) if (!refType.equals("OPN"))
{ {
...@@ -963,7 +1009,8 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -963,7 +1009,8 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
} }
currCode = childNode.getFirstChild().getNodeValue().trim(); currCode = childNode.getFirstChild().getNodeValue().trim();
sql = "SELECT COUNT(1) AS COUNT FROM CURRENCY WHERE CURR_CODE = '"+currCode.trim()+"'"; sql = "SELECT COUNT(1) AS COUNT FROM CURRENCY WHERE CURR_CODE = '"+currCode.trim()+"'";
rs = stmt.executeQuery(sql); pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
cnt = rs.getInt("COUNT"); cnt = rs.getInt("COUNT");
...@@ -974,6 +1021,10 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -974,6 +1021,10 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
break; break;
} }
} }
rs.close();
rs = null;
pstmt.close();
pstmt = null;
}//if }//if
else if(childNodeName.equals("exch_rate")) else if(childNodeName.equals("exch_rate"))
{ {
...@@ -1109,7 +1160,8 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -1109,7 +1160,8 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
private ArrayList sundryDesc(String sundryType,String columnValue,Connection conn) private ArrayList sundryDesc(String sundryType,String columnValue,Connection conn)
{ {
Statement stmt = null; //Statement stmt = null;
PreparedStatement pstmt = null;
ResultSet rs = null; ResultSet rs = null;
String sundrySql = ""; String sundrySql = "";
String sundryDescr = ""; String sundryDescr = "";
...@@ -1129,9 +1181,10 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -1129,9 +1181,10 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
{ {
System.out.println("SUNDRYTYPE ...................: B"); System.out.println("SUNDRYTYPE ...................: B");
sundrySql= " SELECT BANK_NAME,ACCT_CODE__BAL, CCTR_CODE__BAL FROM BANK WHERE BANK_CODE= '"+columnValue+ "'"; sundrySql= " SELECT BANK_NAME,ACCT_CODE__BAL, CCTR_CODE__BAL FROM BANK WHERE BANK_CODE= '"+columnValue+ "'";
System.out.println("SundrySql ::-"+sundrySql); //System.out.println("SundrySql ::-"+sundrySql);
stmt = conn.createStatement(); //stmt = conn.createStatement();
rs = stmt.executeQuery(sundrySql); pstmt = conn.prepareStatement(sundrySql);
rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
sundryDescr = rs.getString(1); sundryDescr = rs.getString(1);
...@@ -1141,15 +1194,19 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -1141,15 +1194,19 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
System.out.println("ACCT CODE..............."+acctCode); System.out.println("ACCT CODE..............."+acctCode);
System.out.println("CCTR CODE..............."+cctrCode); System.out.println("CCTR CODE..............."+cctrCode);
} }
rs.close();
rs = null;
pstmt.close();
pstmt = null;
} }
else if (sundryType.equals("E")) else if (sundryType.equals("E"))
{ {
System.out.println("SUNDRY TYPE ................... : E"); System.out.println("SUNDRY TYPE ................... : E");
sundrySql= " SELECT EMP_FNAME,EMP_MNAME,EMP_LNAME,ACCT_CODE__SAL, CCTR_CODE__SAL FROM EMPLOYEE WHERE EMP_CODE= '"+columnValue+ "'"; sundrySql= " SELECT EMP_FNAME,EMP_MNAME,EMP_LNAME,ACCT_CODE__SAL, CCTR_CODE__SAL FROM EMPLOYEE WHERE EMP_CODE= '"+columnValue+ "'";
System.out.println("SundrySql ::-"+sundrySql); //System.out.println("SundrySql ::-"+sundrySql);
stmt = conn.createStatement(); //pstmt = conn.createStatement();
rs = stmt.executeQuery(sundrySql); pstmt = conn.prepareStatement(sundrySql);
rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
fName = rs.getString(1); fName = rs.getString(1);
...@@ -1162,118 +1219,141 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca ...@@ -1162,118 +1219,141 @@ public class PayableOpenings extends ValidatorEJB implements PayableOpeningsLoca
System.out.println("ACCT CODE..............."+acctCode); System.out.println("ACCT CODE..............."+acctCode);
System.out.println("CCTR CODE..............."+cctrCode); System.out.println("CCTR CODE..............."+cctrCode);
} }
rs.close(); rs.close();
stmt.close(); rs = null;
pstmt.close();
pstmt = null;
} }
else if (sundryType.equals("C")) else if (sundryType.equals("C"))
{ {
System.out.println("SUNDRYTYPE ......................: C"); System.out.println("SUNDRYTYPE ......................: C");
sundrySql= " SELECT CUST_NAME,ACCT_CODE__AR,CCTR_CODE__AR FROM CUSTOMER WHERE CUST_CODE= '"+columnValue+ "'"; sundrySql= " SELECT CUST_NAME,ACCT_CODE__AR,CCTR_CODE__AR FROM CUSTOMER WHERE CUST_CODE= '"+columnValue+ "'";
System.out.println("SundrySql ::-"+sundrySql); //System.out.println("SundrySql ::-"+sundrySql);
stmt = conn.createStatement(); //stmt = conn.createStatement();
rs = stmt.executeQuery(sundrySql); pstmt = conn.prepareStatement(sundrySql);
rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
sundryDescr = rs.getString(1); sundryDescr = rs.getString(1);
acctCode = rs.getString(2); acctCode = rs.getString(2);
cctrCode = rs.getString(3); cctrCode = rs.getString(3);
} }
rs.close(); rs.close();
stmt.close(); rs = null;
pstmt.close();
pstmt = null;
} }
else if (sundryType.equals("T")) else if (sundryType.equals("T"))
{ {
System.out.println("SUNDRYTYPE ......................: T"); System.out.println("SUNDRYTYPE ......................: T");
sundrySql= " SELECT TRAN_NAME,ACCT_CODE__FP,CCTR_CODE__FP FROM TRANSPORTER WHERE TRAN_CODE= '"+columnValue+ "'"; sundrySql= " SELECT TRAN_NAME,ACCT_CODE__FP,CCTR_CODE__FP FROM TRANSPORTER WHERE TRAN_CODE= '"+columnValue+ "'";
System.out.println("SundrySql ::-"+sundrySql); System.out.println("SundrySql ::-"+sundrySql);
stmt = conn.createStatement(); //stmt = conn.createStatement();
rs = stmt.executeQuery(sundrySql); pstmt = conn.prepareStatement(sundrySql);
rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
sundryDescr = rs.getString(1); sundryDescr = rs.getString(1);
acctCode = rs.getString(2); acctCode = rs.getString(2);
cctrCode = rs.getString(3); cctrCode = rs.getString(3);
} }
rs.close(); rs.close();
stmt.close(); rs = null;
pstmt.close();
pstmt = null;
} }
else if (sundryType.equals("S")) else if (sundryType.equals("S"))
{ {
System.out.println("SUNDRYTYPE ..................... : S"); System.out.println("SUNDRYTYPE ..................... : S");
sundrySql= " SELECT SUPP_NAME,ACCT_CODE__AP,CCTR_CODE__AP FROM SUPPLIER WHERE SUPP_CODE= '"+columnValue+ "'"; sundrySql= " SELECT SUPP_NAME,ACCT_CODE__AP,CCTR_CODE__AP FROM SUPPLIER WHERE SUPP_CODE= '"+columnValue+ "'";
System.out.println("SundrySql ::-"+sundrySql); System.out.println("SundrySql ::-"+sundrySql);
stmt = conn.createStatement(); //stmt = conn.createStatement();
rs = stmt.executeQuery(sundrySql); pstmt = conn.prepareStatement(sundrySql);
rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
sundryDescr = rs.getString(1); sundryDescr = rs.getString(1);
acctCode = rs.getString(2); acctCode = rs.getString(2);
cctrCode = rs.getString(3); cctrCode = rs.getString(3);
} }
rs.close(); rs.close();
stmt.close(); rs = null;
pstmt.close();
pstmt = null;
} }
else if (sundryType.equals("X")) else if (sundryType.equals("X"))
{ {
System.out.println("SUNDRYTYPE ......................: X"); System.out.println("SUNDRYTYPE ......................: X");
sundrySql= " SELECT TAUTH_NAME,ACCT_CODE__AP,CCTR_CODE__AP FROM TAX_AUTHORITY WHERE TAUTH_CODE= '"+columnValue+ "'"; sundrySql= " SELECT TAUTH_NAME,ACCT_CODE__AP,CCTR_CODE__AP FROM TAX_AUTHORITY WHERE TAUTH_CODE= '"+columnValue+ "'";
System.out.println("SundrySql ::-"+sundrySql); System.out.println("SundrySql ::-"+sundrySql);
stmt = conn.createStatement(); //stmt = conn.createStatement();
rs = stmt.executeQuery(sundrySql); pstmt = conn.prepareStatement(sundrySql);
rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
sundryDescr = rs.getString(1); sundryDescr = rs.getString(1);
acctCode = rs.getString(2); acctCode = rs.getString(2);
cctrCode = rs.getString(3); cctrCode = rs.getString(3);
} }
rs.close(); rs.close();
stmt.close(); rs = null;
pstmt.close();
pstmt = null;
} }
else if (sundryType.equals("L")) else if (sundryType.equals("L"))
{ {
System.out.println("SUNDRYTYPE ..................... : L"); System.out.println("SUNDRYTYPE ..................... : L");
sundrySql= " SELECT PARTY_NAME,ACCT_CODE__AP,CCTR_CODE__AP FROM LOANPARTY WHERE PARTY_CODE= '"+columnValue+ "'"; sundrySql= " SELECT PARTY_NAME,ACCT_CODE__AP,CCTR_CODE__AP FROM LOANPARTY WHERE PARTY_CODE= '"+columnValue+ "'";
System.out.println("SundrySql ::-"+sundrySql); //System.out.println("SundrySql ::-"+sundrySql);
stmt = conn.createStatement(); //stmt = conn.createStatement();
rs = stmt.executeQuery(sundrySql); pstmt = conn.prepareStatement(sundrySql);
rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
sundryDescr = rs.getString(1); sundryDescr = rs.getString(1);
acctCode = rs.getString(2); acctCode = rs.getString(2);
cctrCode = rs.getString(3); cctrCode = rs.getString(3);
} }
rs.close(); rs.close();
stmt.close(); rs = null;
pstmt.close();
pstmt = null;
} }
else if (sundryType.equals("P")) else if (sundryType.equals("P"))
{ {
System.out.println("SUNDRYTYPE ..................... : P"); System.out.println("SUNDRYTYPE ..................... : P");
sundrySql= " SELECT SP_NAME,ACCT_CODE__AP,CCTR_CODE__AP FROM SALES_PERS WHERE SALES_PERS= '"+columnValue+ "'"; sundrySql= " SELECT SP_NAME,ACCT_CODE__AP,CCTR_CODE__AP FROM SALES_PERS WHERE SALES_PERS= '"+columnValue+ "'";
System.out.println("SundrySql ::-"+sundrySql); System.out.println("SundrySql ::-"+sundrySql);
stmt = conn.createStatement(); //stmt = conn.createStatement();
rs = stmt.executeQuery(sundrySql); pstmt = conn.prepareStatement(sundrySql);
rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
sundryDescr = rs.getString(1); sundryDescr = rs.getString(1);
acctCode = rs.getString(2); acctCode = rs.getString(2);
cctrCode = rs.getString(3); cctrCode = rs.getString(3);
} }
rs.close(); rs.close();
stmt.close(); rs = null;
pstmt.close();
pstmt = null;
} }
else if (sundryType.equals("O")) else if (sundryType.equals("O"))
{ {
System.out.println("SUNDRYTYPE ..................... : O"); System.out.println("SUNDRYTYPE ..................... : O");
sundrySql= " SELECT DESCR FROM ACCOUNTS WHERE ACCT_CODE= '"+columnValue+ "'"; sundrySql= " SELECT DESCR FROM ACCOUNTS WHERE ACCT_CODE= '"+columnValue+ "'";
System.out.println("SundrySql ::-"+sundrySql); //System.out.println("SundrySql ::-"+sundrySql);
stmt = conn.createStatement(); //stmt = conn.createStatement();
rs = stmt.executeQuery(sundrySql); pstmt = conn.prepareStatement(sundrySql);
rs = pstmt.executeQuery();
if (rs.next()) if (rs.next())
{ {
sundryDescr = rs.getString(1); sundryDescr = rs.getString(1);
} }
rs.close(); rs.close();
stmt.close(); rs = null;
pstmt.close();
pstmt = null;
} }
}//try }//try
catch(Exception e) catch(Exception e)
......
webitm-fin/ibase/webitm/ejb/fin/PayablesOpeningConf.java
View file @ 71bfc693
...@@ -58,7 +58,8 @@ public class PayablesOpeningConf extends ActionHandlerEJB implements PayablesO ...@@ -58,7 +58,8 @@ public class PayablesOpeningConf extends ActionHandlerEJB implements PayablesO
} }
private String confirmPayablesOpening(String tranID,String xtraParams)throws RemoteException,ITMException private String confirmPayablesOpening(String tranID,String xtraParams)throws RemoteException,ITMException
{ {
Statement stmt = null,stmt1 = null,stmtcc = null,stmtUpd = null, stmt2 = null, stmt3 = null; //Statement stmt = null,stmt1 = null,stmtcc = null,stmtUpd = null, stmt2 = null, stmt3 = null;
PreparedStatement pstmt1 = null,pstmt2 = null,pstmt3 = null;
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
ResultSet rs = null,rscc = null,rsMast = null,rsDtl = null; ResultSet rs = null,rscc = null,rsMast = null,rsDtl = null;
java.sql.Timestamp tranDate = null; java.sql.Timestamp tranDate = null;
...@@ -102,8 +103,9 @@ conn = getConnection(); ...@@ -102,8 +103,9 @@ conn = getConnection();
try try
{ {
sqlHdr = "SELECT TRAN_DATE,SITE_CODE,FIN_ENTITY,CURR_CODE,TOT_AMT,ADJ_AMT,CONFIRMED, ACCT_PRD FROM PAYABLES_HDR WHERE TRAN_ID ='"+tranID.trim()+"'"; sqlHdr = "SELECT TRAN_DATE,SITE_CODE,FIN_ENTITY,CURR_CODE,TOT_AMT,ADJ_AMT,CONFIRMED, ACCT_PRD FROM PAYABLES_HDR WHERE TRAN_ID ='"+tranID.trim()+"'";
stmt = conn.createStatement(); //stmt = conn.createStatement();
rs = stmt.executeQuery(sqlHdr); pstmt2 = conn.prepareStatement(sqlHdr);
rs = pstmt2.executeQuery();
if (rs.next()) if (rs.next())
{ {
System.out.println("Entering into Header if..................."); System.out.println("Entering into Header if...................");
...@@ -116,11 +118,16 @@ conn = getConnection(); ...@@ -116,11 +118,16 @@ conn = getConnection();
confirmed = rs.getString("CONFIRMED"); confirmed = rs.getString("CONFIRMED");
acctPrd = rs.getString("ACCT_PRD"); //Gulzar 04-12-06 acctPrd = rs.getString("ACCT_PRD"); //Gulzar 04-12-06
System.out.println("Tran_Id ::-"+tranID); System.out.println("Tran_Id ::-"+tranID);
} }
rs.close();
rs = null;
pstmt2.close();
pstmt2 = null;
}//try }//try
catch(SQLException se) catch(SQLException se)
{ {
System.out.println("SQLException []:[PayablesOpeningConfEJB][Excuting Query Failed]" + sqlHdr + se.getMessage()); System.out.println("SQLException []:[PayablesOpeningConfEJB][Excuting Query Failed]" + sqlHdr + se.getMessage());
se.printStackTrace();
} }
catch(Exception ex) catch(Exception ex)
{ {
...@@ -144,8 +151,9 @@ conn = getConnection(); ...@@ -144,8 +151,9 @@ conn = getConnection();
+ "EXCH_RATE,DUE_DATE,TOT_AMT,ADJ_AMT,DIFF_AMOUNT,TRAN_DATE,REF_DATE,BILL_NO," + "EXCH_RATE,DUE_DATE,TOT_AMT,ADJ_AMT,DIFF_AMOUNT,TRAN_DATE,REF_DATE,BILL_NO,"
+ "BILL_DATE,SUPP_BILL_AMT,PAY_MODE,ADV_AMT,PURC_ORDER,ENTRY_BATCH_NO " + "BILL_DATE,SUPP_BILL_AMT,PAY_MODE,ADV_AMT,PURC_ORDER,ENTRY_BATCH_NO "
+ "FROM PAYABLES_DTL WHERE TRAN_ID ='"+tranID+"'"; + "FROM PAYABLES_DTL WHERE TRAN_ID ='"+tranID+"'";
stmt = conn.createStatement(); //stmt = conn.createStatement();
rsDtl = stmt.executeQuery(sqlDtl); pstmt2 = conn.prepareStatement(sqlDtl);
rsDtl = pstmt2.executeQuery();
while (rsDtl.next()) while (rsDtl.next())
{ {
System.out.println("Entering into while..................."); System.out.println("Entering into while...................");
...@@ -177,12 +185,17 @@ conn = getConnection(); ...@@ -177,12 +185,17 @@ conn = getConnection();
+ "WHERE TRAN_SER = '"+tranSer.trim()+"' " + "WHERE TRAN_SER = '"+tranSer.trim()+"' "
+ "AND REF_NO = '"+refNo.trim()+"' " + "AND REF_NO = '"+refNo.trim()+"' "
+ "AND SITE_CODE = '"+siteCode.trim() +"'"; + "AND SITE_CODE = '"+siteCode.trim() +"'";
stmt1 = conn.createStatement(); //stmt1 = conn.createStatement();
rsMast = stmt1.executeQuery(sql); pstmt1 = conn.prepareStatement(sql);
rsMast = pstmt1.executeQuery();
if (rsMast.next()) if (rsMast.next())
{ {
cnt = rsMast.getInt("COUNT"); cnt = rsMast.getInt("COUNT");
} }
rsMast.close();
rsMast = null;
pstmt1.close();
pstmt1 = null;
}//try }//try
catch(SQLException se) catch(SQLException se)
{ {
...@@ -199,14 +212,19 @@ conn = getConnection(); ...@@ -199,14 +212,19 @@ conn = getConnection();
sql = "SELECT TOT_AMT FROM MISC_PAYABLES " sql = "SELECT TOT_AMT FROM MISC_PAYABLES "
+ "WHERE TRAN_SER = '"+ tranSer +"' AND REF_NO = '"+ refNo +"' AND SITE_CODE = '"+ siteCode +"'"; + "WHERE TRAN_SER = '"+ tranSer +"' AND REF_NO = '"+ refNo +"' AND SITE_CODE = '"+ siteCode +"'";
stmt2 = conn.createStatement(); //stmt2 = conn.createStatement();
rs = stmt2.executeQuery(sql); pstmt1 = conn.prepareStatement(sql);
rs = pstmt1.executeQuery();
if (rs.next()) if (rs.next())
{ {
totAmtOld = rs.getDouble("TOT_AMT"); totAmtOld = rs.getDouble("TOT_AMT");
} }
rs.close(); rs.close();
rs = null;
pstmt1.close();
pstmt1 = null;
//rs.close();
amountDiff = totAmount - totAmtOld; amountDiff = totAmount - totAmtOld;
System.out.println("amountDiff = totAmount - totAmtOld : " + amountDiff); System.out.println("amountDiff = totAmount - totAmtOld : " + amountDiff);
if (totAmtOld < 0) if (totAmtOld < 0)
...@@ -229,7 +247,7 @@ conn = getConnection(); ...@@ -229,7 +247,7 @@ conn = getConnection();
drAmtNew = 0d; drAmtNew = 0d;
crAmtNew = totAmount; crAmtNew = totAmount;
} }
stmt2.close(); //stmt2.close();
drAmount = drAmtNew - drAmtOld; drAmount = drAmtNew - drAmtOld;
crAmount = crAmtNew - crAmtOld; crAmount = crAmtNew - crAmtOld;
System.out.println("drAmount = drAmtNew - drAmtOld : " + drAmount); System.out.println("drAmount = drAmtNew - drAmtOld : " + drAmount);
...@@ -244,13 +262,17 @@ conn = getConnection(); ...@@ -244,13 +262,17 @@ conn = getConnection();
String keyString = "",payblsTranID = ""; String keyString = "",payblsTranID = "";
sql = "SELECT KEY_STRING FROM TRANSETUP WHERE TRAN_WINDOW = 'T_PAYABLES'"; sql = "SELECT KEY_STRING FROM TRANSETUP WHERE TRAN_WINDOW = 'T_PAYABLES'";
stmt3 = conn.createStatement(); //stmt3 = conn.createStatement();
rs = stmt3.executeQuery(sql); pstmt3 = conn.prepareStatement(sql);
rs = pstmt3.executeQuery();
if(rs.next()) if(rs.next())
{ {
keyString = rs.getString("KEY_STRING"); keyString = rs.getString("KEY_STRING");
} }
rs.close(); rs.close();
rs = null;
pstmt3.close();
pstmt3 = null;
String XMLString = "<?xml version=\"1.0\"?>\r\n<Root>\r\n<header>"+ String XMLString = "<?xml version=\"1.0\"?>\r\n<Root>\r\n<header>"+
"\r\n</header><Detail1>"+ "\r\n</header><Detail1>"+
"\r\n<site_code>"+siteCode+"</site_code>\r\n<tran_date>"+tranDate+"</tran_date></Detail1></Root>"; "\r\n<site_code>"+siteCode+"</site_code>\r\n<tran_date>"+tranDate+"</tran_date></Detail1></Root>";
...@@ -303,10 +325,13 @@ conn = getConnection(); ...@@ -303,10 +325,13 @@ conn = getConnection();
pstmt.setTimestamp(26,new java.sql.Timestamp(System.currentTimeMillis())); pstmt.setTimestamp(26,new java.sql.Timestamp(System.currentTimeMillis()));
pstmt.executeUpdate(); pstmt.executeUpdate();
pstmt.close();
pstmt = null;
System.out.println("INSERT QUERY EXECUTED................................."); System.out.println("INSERT QUERY EXECUTED.................................");
}//try }//try
catch(SQLException se) catch(SQLException se)
{ {
se.printStackTrace();
System.out.println("SQLException [10][confirmReceivables][Excuting Query Failed]" + sqlIns + se.getMessage()); System.out.println("SQLException [10][confirmReceivables][Excuting Query Failed]" + sqlIns + se.getMessage());
try try
{ {
...@@ -333,7 +358,9 @@ conn = getConnection(); ...@@ -333,7 +358,9 @@ conn = getConnection();
{ {
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
stmt3.close(); //stmt3.close();
pstmt3.close();
pstmt3 = null;
} }
catch(Exception e) catch(Exception e)
...@@ -388,12 +415,15 @@ conn = getConnection(); ...@@ -388,12 +415,15 @@ conn = getConnection();
pstmt.setDouble(23,suppBillAmt); pstmt.setDouble(23,suppBillAmt);
System.out.println("Setting Twenty Four Fields ..........24"); System.out.println("Setting Twenty Four Fields ..........24");
updInstr = pstmt.executeUpdate(); updInstr = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
System.out.println("QUERY !!!!!!!!!------"+ sqlUpd); System.out.println("QUERY !!!!!!!!!------"+ sqlUpd);
System.out.println("QUERY EXECUTED::UPDATE MASTER .........:: "+ updInstr); System.out.println("QUERY EXECUTED::UPDATE MASTER .........:: "+ updInstr);
}//try }//try
catch(SQLException se) catch(SQLException se)
{ {
se.printStackTrace();
System.out.println("SQLException [10][confirmPayablesOpening][Excuting Query Failed]" + sqlUpd + se.getMessage()); System.out.println("SQLException [10][confirmPayablesOpening][Excuting Query Failed]" + sqlUpd + se.getMessage());
try try
{ {
...@@ -485,16 +515,21 @@ conn = getConnection(); ...@@ -485,16 +515,21 @@ conn = getConnection();
try try
{ {
sql = "SELECT CONTACT_CODE FROM "+table+" WHERE "+column+" = '"+sundryCode.trim()+"'"; sql = "SELECT CONTACT_CODE FROM "+table+" WHERE "+column+" = '"+sundryCode.trim()+"'";
stmtcc = conn.createStatement(); //stmtcc = conn.createStatement();
rscc = stmtcc.executeQuery(sql); pstmt3 = conn.prepareStatement(sql);
rscc = pstmt3.executeQuery();
if(rscc.next()) if(rscc.next())
{ {
contactCode = rscc.getString(1); contactCode = rscc.getString(1);
} }
rscc.close();
rscc = null;
pstmt3.close();
pstmt3 = null;
} }
catch(SQLException se) catch(SQLException se)
{ {
se.printStackTrace();
System.out.println("SQLException []:[PayablesOpeningConfEJB][Excuting Query Failed]" +sql+ se.getMessage()); System.out.println("SQLException []:[PayablesOpeningConfEJB][Excuting Query Failed]" +sql+ se.getMessage());
} }
sundrybalMap.put("contact_code",contactCode); sundrybalMap.put("contact_code",contactCode);
...@@ -550,16 +585,22 @@ conn = getConnection(); ...@@ -550,16 +585,22 @@ conn = getConnection();
System.out.println("RETURN FROM ACCTBAL ENTRIES"); System.out.println("RETURN FROM ACCTBAL ENTRIES");
//conn.commit(); //Gulzar 04-12-06 //conn.commit(); //Gulzar 04-12-06
}//while }//while
rsDtl.close();
rsDtl = null;
pstmt2.close();
pstmt2 = null;
try try
{ {
System.out.println("emp code:="+empCode); System.out.println("emp code:="+empCode);
update = "UPDATE PAYABLES_HDR SET CONFIRMED = 'Y', CONF_DATE = ? ,EMP_CODE__APRV = ? where TRAN_ID = ?"; update = "UPDATE PAYABLES_HDR SET CONFIRMED = 'Y', CONF_DATE = ? ,EMP_CODE__APRV = ? where TRAN_ID = ?";
System.out.println("Confirm update SQL ::"+ update); //System.out.println("Confirm update SQL ::"+ update);
pstmt = conn.prepareStatement(update); pstmt = conn.prepareStatement(update);
pstmt.setTimestamp(1,new java.sql.Timestamp(System.currentTimeMillis())); pstmt.setTimestamp(1,new java.sql.Timestamp(System.currentTimeMillis()));
pstmt.setString(2,empCode); pstmt.setString(2,empCode);
pstmt.setString(3,tranID); pstmt.setString(3,tranID);
updCnt = pstmt.executeUpdate(); updCnt = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
System.out.println("No of PAYABLES_HDR records updated ::*> "+updCnt); System.out.println("No of PAYABLES_HDR records updated ::*> "+updCnt);
if (updCnt == 1) if (updCnt == 1)
{ {
...@@ -642,10 +683,10 @@ conn = getConnection(); ...@@ -642,10 +683,10 @@ conn = getConnection();
rsDtl.close(); rsDtl.close();
rsDtl = null; rsDtl = null;
} }
if (stmt != null) if (pstmt != null)
{ {
stmt.close(); pstmt.close();
stmt = null; pstmt = null;
} }
if (conn != null) if (conn != null)
{ {
......
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