Commit e70d7a3f authored by ngadkari's avatar ngadkari

site code blank allow

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@200866 ce508802-f39f-4f6c-b175-0d175dae99d5
parent dfb5a665
package ibase.webitm.ejb.fin;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Timestamp;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;
import javax.ejb.Stateless;
import org.w3c.dom.CDATASection;
import org.w3c.dom.Document;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import ibase.system.config.ConnDriver;
import ibase.utility.E12GenericUtility;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.utility.ITMException;
@Stateless
public class BankReconPrcIC extends ValidatorEJB
{
E12GenericUtility genericUtility = new E12GenericUtility();
FinCommon finCommon = new FinCommon();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
private String checkNull(String input)
{
return input == null ? "" : input;
}
public String wfValData(String xmlString, String xmlString1, String xmlString2, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException
{
Document dom = null;
Document dom1 = null;
Document dom2 = null;
String errString = "";
try
{
if(xmlString != null && xmlString.trim().length() > 0)
{
dom = genericUtility.parseString(xmlString);
}
if(xmlString1 != null && xmlString1.trim().length() > 0)
{
dom1 = genericUtility.parseString(xmlString1);
}
if(xmlString2 != null && xmlString2.trim().length() > 0)
{
dom2 = genericUtility.parseString(xmlString2);
}
errString = wfValData(dom,dom1,dom2,objContext,editFlag,xtraParams);
System.out.println("retString:::"+errString);
}
catch(Exception e)
{
errString = genericUtility.createErrorString(e);
e.printStackTrace();
throw new ITMException(e);
}
return(errString);
}
public String wfValData(Document dom, Document dom1, Document dom2, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException
{
int ctr=0;
int childNodeListLength;
int currentFormNo = 0;
int cnt = 0;
NodeList parentNodeList = null;
NodeList childNodeList = null;
Node parentNode = null;
Node childNode = null;
String siteCode = "";
String userId = "";
String sql="";
String errCode="";
String errorType = "";
String childNodeName = null;
String errString = "";
ArrayList<String> errList = new ArrayList<String>();
ArrayList<String> errFields = new ArrayList<String>();
Connection conn = null;
PreparedStatement pstmt = null ;
ResultSet rs = null;
String existFlag = "";
String bankCode = "",site_code="";
int count=0;
StringBuffer errStringXml = new StringBuffer("<?xml version = \"1.0\"?> \r\n <Root> <Errors>");
try
{
SimpleDateFormat sdf1= new SimpleDateFormat(genericUtility.getDBDateFormat());
conn = getConnection();
userId = getValueFromXTRA_PARAMS(xtraParams, "loginCode");
if (objContext != null && objContext.trim().length() > 0)
{
currentFormNo = Integer.parseInt(objContext);
}
switch (currentFormNo)
{
case 1:
parentNodeList = dom.getElementsByTagName("Detail1");
parentNode = parentNodeList.item(0);
childNodeList = parentNode.getChildNodes();
childNodeListLength = childNodeList.getLength();
for(ctr = 0; ctr < childNodeListLength; ctr ++)
{
childNode = childNodeList.item(ctr);
childNodeName = childNode.getNodeName();
if(childNodeName.equalsIgnoreCase("site_code"))
{
siteCode = genericUtility.getColumnValue("site_code", dom);
System.out.println("siteCode: " + siteCode);
if (siteCode != null && siteCode.trim().length() > 0) {
sql = "select count(1) from site where site_code = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,siteCode);
rs = pstmt.executeQuery();
if(rs.next())
{
count = rs.getInt(1);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if (count==0) {
errCode = "VMSITE1";
errList.add(errCode);
errFields.add(childNodeName.toLowerCase());
}
}
}// end of if block for site_code
else if (childNodeName.equalsIgnoreCase("bank_code"))
{
bankCode = checkNull(genericUtility.getColumnValue("bank_code", dom));
sql = "select count(1) from bank where bank_code = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,bankCode);
rs = pstmt.executeQuery();
if(rs.next())
{
count = rs.getInt(1);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if (count== 0)
{
errCode = "VMBANK0";
errList.add(errCode);
errFields.add(childNodeName.toLowerCase());
}
}
}
break;
}// end of switch statement
int errListSize = errList.size();
cnt = 0;
String errFldName = null;
if ( errList != null && errListSize > 0 )
{
for (cnt = 0; cnt < errListSize; cnt++ )
{
errCode = errList.get(cnt);
errFldName = errFields.get(cnt);
System.out.println("errCode .........." + errCode);
errString = itmDBAccessEJB.getErrorString("", errCode, userId, "", conn);
errorType = errorType( conn, errCode );
if ( errString.length() > 0)
{
String bifurErrString = errString.substring( errString.indexOf("<Errors>") + 8, errString.indexOf("<trace>"));
bifurErrString =bifurErrString+errString.substring( errString.indexOf("</trace>") + 8, errString.indexOf("</Errors>"));
errStringXml.append(bifurErrString);
System.out.println("errStringXml .........."+errStringXml);
errString = "";
}
if ( errorType.equalsIgnoreCase("E"))
{
break;
}
}
errList.clear();
errList = null;
errFields.clear();
errFields = null;
errStringXml.append("</Errors></Root>\r\n");
}
else
{
errStringXml = new StringBuffer( "" );
}
errString = errStringXml.toString();
}// End of try
catch(Exception e)
{
e.printStackTrace();
errString = e.getMessage();
throw new ITMException(e);
}
finally
{
try
{
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(conn != null)
{
conn.close();
conn = null;
}
}
catch(Exception d)
{
d.printStackTrace();
throw new ITMException(d);
}
}
errString = errStringXml.toString();
System.out.println("testing : final errString : " + errString);
return errString;
}//end of validation
public String checkNullAndTrim( String inputVal )
{
if ( inputVal == null )
{
inputVal = "";
}
else
{
inputVal = inputVal.trim();
}
return inputVal;
}
private String errorType(Connection conn , String errorCode)
{
String msgType = "";
PreparedStatement pstmt = null ;
ResultSet rs = null;
try
{
String sql = "SELECT MSG_TYPE FROM MESSAGES WHERE MSG_NO = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,errorCode);
rs = pstmt.executeQuery();
while(rs.next())
{
msgType = rs.getString("MSG_TYPE");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
}
catch(Exception ex)
{
ex.printStackTrace();
}
finally
{
try
{
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
}
catch(Exception e)
{
e.printStackTrace();
}
}
return msgType;
}
}
......@@ -129,7 +129,7 @@ conn = getConnection();
{
parentNodeList = headerDom.getElementsByTagName("Detail1");
parentNodeListLength = parentNodeList.getLength();
for (int selectedRow = 0; selectedRow < parentNodeListLength; selectedRow++)
/*for (int selectedRow = 0; selectedRow < parentNodeListLength; selectedRow++)
{
parentNode = parentNodeList.item(selectedRow);
childNodeList = parentNode.getChildNodes();
......@@ -141,7 +141,7 @@ conn = getConnection();
childNodeName = childNode.getNodeName();
if (childNodeName.equals("site_code"))
{
siteCode = (childNode.getFirstChild().getNodeValue()).trim();
siteCode = (childNode.getFirstChild().getNodeValue()) == null || (childNode.getFirstChild().getNodeValue()).trim().length()==0 ? " " : (childNode.getFirstChild().getNodeValue());// removed trim() by nandkumar gadkari on 16/05/19
System.out.println("siteCode::::::::::: "+ siteCode);
}
if (childNodeName.equals("bank_code"))
......@@ -150,7 +150,12 @@ conn = getConnection();
System.out.println("bankCode:::::::: "+ bankCode);
}
}
}
}*/// commented by nandkumar gadkari on 16/05/19
//and added by nandkumar
siteCode= genericUtility.getColumnValue("site_code", headerDom);
System.out.println("siteCode::::::::::: "+ siteCode);
bankCode= genericUtility.getColumnValue("bank_code", headerDom);
System.out.println("bankCode:::::::: "+ bankCode);
itmDBAccessEJB = new ITMDBAccessEJB();
ConnDriver conndriver = new ConnDriver();
//Changes and Commented By Bhushan on 06-06-2016 :START
......@@ -243,8 +248,12 @@ conn = getConnection();
//sql = " SELECT REF_NO,SUM(AMOUNT),SUM(AMT_ADJ) from bank_statement where site_code ='"+siteCode.trim()+"' and bank_code ='"+bankCode.trim()+"' and ( STATUS ='P' OR STATUS ='E' OR STATUS IS NULL ) GROUP BY ref_no ";
sql = " SELECT REF_NO,SUM(AMOUNT),SUM(AMT_ADJ) "
+ " from bank_statement "
+ " where site_code = ? "
+ " and bank_code = ? "
+ " where ";
if(siteCode !=null && siteCode.trim().length()> 0)//conditon added by nandkumar gadkari on 16/05/19 for blank site code
{
sql = sql + " site_code = ? and ";
}
sql= sql + " bank_code = ? "
+ "and REF_NO IS NOT NULL" //Add By Ajay Jadhav on 07/05/18
+ " and ( STATUS ='P' OR STATUS ='E' OR STATUS IS NULL ) GROUP BY ref_no ";
System.out.println("query executed(bank_statement):::"+sql);
......@@ -252,9 +261,16 @@ conn = getConnection();
{
pstmt = conn.prepareStatement(sql);
//conditon added by nandkumar gadkari on 16/05/19 for blank site code
if(siteCode !=null && siteCode.trim().length()> 0)
{
pstmt.setString(1,siteCode.trim());
pstmt.setString(2,bankCode.trim());
}
else
{
pstmt.setString(1,bankCode.trim());
}
//pstmt.setString(1,siteCode.trim());
//pstmt.setString(2,siteCode.trim());
rs = pstmt.executeQuery();
......@@ -290,8 +306,13 @@ conn = getConnection();
{
sql = " SELECT REF_NO,SUM(AMOUNT),SUM(AMT_ADJ) "
+ " from banktran_log "
+ " where site_code = ? "
+ " and bank_code = ? "
+ " where ";
//conditon added by nandkumar gadkari on 16/05/19 for blank site code
if(siteCode !=null && siteCode.trim().length()> 0)
{
sql =sql + " site_code = ? and ";
}
sql = sql + " bank_code = ? "
+"and REF_NO IS NOT NULL "//Add by Ajay Jadhav on 07/05/18
+ " and ( STATUS ='P' OR STATUS ='E' OR STATUS IS NULL ) GROUP BY ref_no ";
//End Changes - Gulzar - 16/01/09 (FI8PHE023)
......@@ -302,16 +323,29 @@ conn = getConnection();
//Entry_batch_no is checked to bank statement and updated the status according to it.
sql = " SELECT ENTRY_BATCH_NO as REF_NO,SUM(AMOUNT),SUM(AMT_ADJ) "
+ " from banktran_log "
+ " where site_code = ? "
+ " and bank_code = ? "
+ " where ";
//conditon added by nandkumar gadkari on 16/05/19 for blank site code
if(siteCode !=null && siteCode.trim().length()> 0)
{
sql =sql + " site_code = ? and ";
}
sql = sql + " bank_code = ? "
+"and ENTRY_BATCH_NO IS NOT NULL "//Add by Ajay Jadhav on 07/05/18
+ " and ( STATUS ='P' OR STATUS ='E' OR STATUS IS NULL ) GROUP BY ENTRY_BATCH_NO ";
}
System.out.println("query executed(banktran_log):::"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,siteCode.trim());
pstmt.setString(2,bankCode.trim());
//conditon added by nandkumar gadkari on 16/05/19 for blank site code
if(siteCode !=null && siteCode.trim().length()> 0)
{
pstmt.setString(1,siteCode.trim());
pstmt.setString(2,bankCode.trim());
}
else
{
pstmt.setString(1,bankCode.trim());
}
rs = pstmt.executeQuery();
while(rs.next())
{
......@@ -377,12 +411,28 @@ conn = getConnection();
refnoTemp = (String)vrefNo.get(refCounter);
//**************** status <> "R"
sqlBS = " SELECT TRAN_ID,AMOUNT,AMT_ADJ,STATUS from bank_statement"
+ " where site_code = ? and bank_code = ? "
+ " where " ;
//conditon added by nandkumar gadkari on 16/05/19 for blank site code
if(siteCode !=null && siteCode.trim().length()> 0)
{
sqlBS=sqlBS + "site_code = ? and ";
}
sqlBS=sqlBS + " bank_code = ? "
+ "and REF_NO = ? AND status <> 'R' order by tran_id ";
pstmt = conn.prepareStatement(sqlBS);
pstmt.setString(1,siteCode.trim());
pstmt.setString(2,bankCode.trim());
//conditon added by nandkumar gadkari on 16/05/19 for blank site code
if(siteCode !=null && siteCode.trim().length()> 0)
{
pstmt.setString(1,siteCode.trim());
pstmt.setString(2,bankCode.trim());
pstmt.setString(3,refnoTemp);
}
else
{
pstmt.setString(1,bankCode.trim());
pstmt.setString(2,refnoTemp);
}
rs = pstmt.executeQuery();
while(rs.next())
{
......@@ -398,19 +448,40 @@ conn = getConnection();
if(refOrBat.equals("R"))
{
sqlBT = " SELECT TRAN_ID,AMOUNT,AMT_ADJ,STATUS from banktran_log "
+ "where site_code = ? and bank_code = ? and REF_NO = ? "
+ "where ";
//conditon added by nandkumar gadkari on 16/05/19 for blank site code
if(siteCode !=null && siteCode.trim().length()> 0)
{
sqlBT=sqlBT + "site_code = ? and ";
}
sqlBT=sqlBT + " bank_code = ? and REF_NO = ? "
+ "and status <>'R' order by tran_id ";
}
else
{
sqlBT = " SELECT TRAN_ID,AMOUNT,AMT_ADJ,STATUS from banktran_log "
+ "where site_code = ? and bank_code = ? and ENTRY_BATCH_NO = ? "
+ "where ";
//conditon added by nandkumar gadkari on 16/05/19 for blank site code
if(siteCode !=null && siteCode.trim().length()> 0)
{
sqlBT=sqlBT + "site_code = ? and ";
}
sqlBT=sqlBT + " bank_code = ? and ENTRY_BATCH_NO = ? "
+ "and status <>'R' order by tran_id ";
}
pstmt1 = conn.prepareStatement(sqlBT);
pstmt1.setString(1,siteCode.trim());
pstmt1.setString(2,bankCode.trim());
pstmt1.setString(3,refnoTemp);
//conditon added by nandkumar gadkari on 16/05/19 for blank site code
if(siteCode !=null && siteCode.trim().length()> 0)
{
pstmt1.setString(1,siteCode.trim());
pstmt1.setString(2,bankCode.trim());
pstmt1.setString(3,refnoTemp);
}
else
{
pstmt1.setString(1,bankCode.trim());
pstmt1.setString(2,refnoTemp);
}
rs1 = pstmt1.executeQuery();
while(rs1.next())
{
......
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