Skip to content

B
business-java
Commit 06926414 authored by gahmad's avatar gahmad
Browse files
Options

changes from cust_code to site_code in validation method 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@91554 ce508802-f39f-4f6c-b175-0d175dae99d5
parent d40400a4
Hide whitespace changes
Inline Side-by-side
Showing with 648 additions and 645 deletions
webitm-dis/ibase/webitm/ejb/dis/InvHoldRelIC.java
View file @ 06926414
package ibase.webitm.ejb.dis;
import java.rmi.RemoteException;
import java.text.*;
import java.sql.*;
import org.w3c.dom.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.*;
import ibase.system.config.*;
import ibase.webitm.ejb.*;
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class InvHoldRelIC extends ValidatorEJB implements InvHoldRelICLocal , InvHoldRelICRemote // SessionBean
{
GenericUtility genericUtility = GenericUtility.getInstance();
/*public void ejbCreate() throws RemoteException, CreateException
{
System.out.println("EpaymentICEJB is in Process..........");
}
public void ejbRemove()
{
}
public void ejbActivate()
{
}
public void ejbPassivate()
{
}*/
public String wfValData() throws RemoteException,ITMException
{
return "";
}
public String itemChanged() throws RemoteException,ITMException
{
return "";
}
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 = null;
System.out.println("Validation Start..........");
try
{
System.out.println( "xmlString::: " + xmlString );
System.out.println( "xmlString1:::" + xmlString1 );
System.out.println( "xmlString2:::" + xmlString2 );
dom = parseString(xmlString);
dom1 = parseString(xmlString1);
if (xmlString2.length() > 0 )
{
dom2 = parseString(xmlString2);
}
errString = wfValData(dom,dom1,dom2,objContext,editFlag,xtraParams);
}
catch(Exception e)
{
System.out.println("Exception : EpaymentICEJB : wfValData(String xmlString) : ==>\n"+e.getMessage());
}
return (errString);
}
public String wfValData(Document dom, Document dom1,Document dom2, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException
{
String errString = " ";
NodeList parentNodeList = null;
NodeList childNodeList = null;
Node parentNode = null;
Node childNode = null;
int ctr = 0;
String childNodeName = null;
String errCode = null;
String userId = null;
int cnt = 0;
int currentFormNo = 0;
int childNodeListLength;
Connection conn = null;
PreparedStatement pstmt=null;
ResultSet rs = null;
String sql = null;
String tranIdHold = null;
String lineNo = null;
ConnDriver connDriver = new ConnDriver();
try
{
System.out.println( "wfValData called" );
conn = connDriver.getConnectDB("DriverITM");
userId = getValueFromXTRA_PARAMS(xtraParams,"loginCode");
getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode");
genericUtility = GenericUtility.getInstance();
if(objContext != null && objContext.length()>0)
{
currentFormNo = Integer.parseInt(objContext);
}
switch(currentFormNo)
{
case 1 :
System.out.println("VALIDATION FOR DETAIL [ 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" ) )
{
String siteCode = null;
siteCode = genericUtility.getColumnValue( "cust_code", dom, "1" );
if( siteCode != null )
{
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.start
/*
sql = " SELECT COUNT(*) FROM site WHERE site_code ='" + siteCode.trim() + "'";
System.out.println( " SQL FOR custCode ====> " + sql );
pstmt = conn.prepareStatement( sql );
rs = pstmt.executeQuery();
*/
sql = " SELECT COUNT(*) FROM site WHERE site_code = ?";
System.out.println( " SQL FOR custCode ====> " + sql );
pstmt = conn.prepareStatement( sql );
pstmt.setString(1,siteCode);
rs = pstmt.executeQuery();
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.end
cnt = 0;
if( rs.next() )
{
cnt = rs.getInt( 1 );
}
System.out.println(" COUNT =====> [" + cnt + "]");
if( cnt == 0 )
{
System.out.println(" ====> Site invalid or not found <==== ");
errCode = "VMINVSITE";
errString = getErrorString( "SITE_CODE", errCode, userId );
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
}
}
if ( childNodeName.equalsIgnoreCase( "emp_code__aprv" ) )
{
String empCode = null;
empCode = genericUtility.getColumnValue( "emp_code__aprv", dom, "1" );
if( empCode != null && empCode.length() > 0 )
{
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.start
/*
sql = " SELECT COUNT(*) FROM Employee WHERE emp_code ='" + empCode.trim() + "'";
System.out.println( " SQL FOR empCode ====> " + sql );
pstmt = conn.prepareStatement( sql );
rs = pstmt.executeQuery();
*/
sql = " SELECT COUNT(*) FROM Employee WHERE emp_code = ?";
System.out.println( " SQL FOR custCode ====> " + sql );
pstmt = conn.prepareStatement( sql );
pstmt.setString(1,empCode);
rs = pstmt.executeQuery();
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.end
cnt = 0;
if( rs.next() )
{
cnt = rs.getInt( 1 );
}
System.out.println(" COUNT =====> [" + cnt + "]");
if( cnt == 0 )
{
System.out.println(" ====> Employee invalid or not found <==== ");
errCode = "VMINVEMP";
errString = getErrorString( "EMP_CODE", errCode, userId );
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
}
}
} //END OF CASE1
break;
case 2 :
System.out.println("VALIDATION FOR DETAIL [ 2 ]..........");
parentNodeList = dom.getElementsByTagName("Detail2");
parentNode = parentNodeList.item(0);
childNodeList = parentNode.getChildNodes();
childNodeListLength = childNodeList.getLength();
for(ctr = 0; ctr < childNodeListLength; ctr++)
{
cnt = 0;
childNode = childNodeList.item(ctr);
childNodeName = childNode.getNodeName();
errCode = null;
if( childNodeName.equalsIgnoreCase( "tran_id__hold" ) || childNodeName.equalsIgnoreCase( "LINE_NO__HOLD" ) )
{
tranIdHold = genericUtility.getColumnValue( "tran_id__hold", dom, "2" );
lineNo = genericUtility.getColumnValue( "line_no__hold", dom, "2" );
if( tranIdHold != null && tranIdHold.length() > 0 )
{
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.start
/*
sql = "select count( 1 ) cnt from inv_hold_det where tran_id = '" + tranIdHold + "' ";
pstmt = conn.prepareStatement( sql );
rs = pstmt.executeQuery();
*/
sql = "select count( 1 ) cnt from inv_hold_det where tran_id = ?";
pstmt = conn.prepareStatement( sql );
pstmt.setString(1,tranIdHold);
rs = pstmt.executeQuery();
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.end
if( rs.next() )
{
cnt = rs.getInt( "cnt" );
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if( cnt == 0 )
{
errCode = "VTTRANINV";
}
if( errCode == null )
{
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.start
/*
sql = "select count( 1 ) cnt from inv_hold where tran_id = '" + tranIdHold + "' and confirmed = 'Y' ";
pstmt = conn.prepareStatement( sql );
rs = pstmt.executeQuery();
*/
sql = "select count( 1 ) cnt from inv_hold where tran_id = ? and confirmed = 'Y' ";
pstmt = conn.prepareStatement( sql );
pstmt.setString(1,tranIdHold);
rs = pstmt.executeQuery();
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.end
if( rs.next() )
{
cnt = rs.getInt( "cnt" );
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if( cnt == 0 )
{
errCode = "VTTRANUNC";
}
}
}
else
{
errCode = "VTTRANBLK";
}
if( errCode != null )
{
errString = getErrorString( "tran_id__hold", errCode, userId );
}else if( lineNo != null && lineNo.length() > 0 )
{
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.start
/*
sql = "select count( 1 ) cnt from inv_hold_det where tran_id = '" + tranIdHold + "' and line_no = " + lineNo;
pstmt = conn.prepareStatement( sql );
rs = pstmt.executeQuery();
*/
sql = "SELECT COUNT( 1 ) CNT FROM INV_HOLD_DET WHERE TRAN_ID = ? AND LINE_NO = ?";
pstmt = conn.prepareStatement( sql );
pstmt.setString(1,tranIdHold);
pstmt.setString(2,lineNo);
rs = pstmt.executeQuery();
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.end
if( rs.next() )
{
cnt = rs.getInt( "cnt" );
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if( cnt == 0 )
{
errCode = "VTLINEINV";
}
}
else
{
errCode = "VTLINEBLK";
}
if( errCode != null )
{
errString = getErrorString( "line_no__hold", errCode, userId );
}else if ( ( tranIdHold != null && tranIdHold.length() > 0 ) && ( lineNo != null && lineNo.length() > 0 ) )
{
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.start
/*
sql = "select count( 1 ) cnt from inv_hold_det where tran_id = '" + tranIdHold + "' and line_no = " + lineNo + " and HOLD_STATUS = 'R'";
pstmt = conn.prepareStatement( sql );
rs = pstmt.executeQuery();
*/
sql = "SELECT COUNT( 1 ) CNT FROM INV_HOLD_DET WHERE TRAN_ID = ? AND LINE_NO = ? AND HOLD_STATUS = 'R'";
pstmt = conn.prepareStatement( sql );
pstmt.setString(1,tranIdHold);
pstmt.setString(2,lineNo);
rs = pstmt.executeQuery();
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.end
if( rs.next() )
{
cnt = rs.getInt( "cnt" );
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if( cnt > 0 )
{
errCode = "VTTRNCNFED";
}
}
if( errCode != null )
{
errString = getErrorString( "line_no__hold", errCode, userId );
}
else
{
NodeList allLines = null;
NodeList allTranIds = null;
String tranIdH = null;
String lineNoH = null;
int recCnt = 0;
System.out.println( " tranIdHold, lineNoHold :: ( " + tranIdHold + ", " + lineNo + " )" );
allLines = dom2.getElementsByTagName("line_no__hold");
allTranIds = dom2.getElementsByTagName("tran_id__hold");
int noOfLines = allLines.getLength();
for( int idx = 0; idx < noOfLines ; idx++ )
{
if ( allTranIds.item( idx ).getFirstChild() != null )
{
tranIdH = ( allTranIds.item( idx ).getFirstChild() ).getNodeValue();
}
if ( allLines.item( idx ).getFirstChild() != null )
{
lineNoH = ( allLines.item( idx ).getFirstChild() ).getNodeValue();
}
System.out.println( " tranIdH :: ( " + tranIdH + ", " + lineNoH + " )" );
if( tranIdH.equals( tranIdHold ) && lineNoH.equals( lineNo ) )
{
recCnt++;
}
}
if( recCnt > 1 )
{
errCode = "VTDUPENTRY";
errString = getErrorString( "line_no__hold", errCode, userId );
}
}
}
}//END FOR OF CASE2
break;
}//END SWITCH
}//END TRY
catch(Exception e)
{
System.out.println("Exception ::" +e);
e.printStackTrace();
errString = e.getMessage();
}
finally
{
try
{
if(conn != null)
{
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
if( rs != null )
{
rs.close();
rs = null;
}
conn.close();
}
conn = null;
}
catch(Exception d)
{
d.printStackTrace();
}
System.out.println(" < ExprProcessIcEJB > CONNECTION IS CLOSED");
}
System.out.println("ErrString ::" + errString);
return errString;
}//END OF VALIDATION
public String itemChanged(String xmlString, String xmlString1,String xmlString2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException
{
Document dom = null;
Document dom1 = null;
Document dom2 = null;
String valueXmlString = null;
try
{
dom = parseString(xmlString);
System.out.println("xmlString" + xmlString);
dom1 = parseString(xmlString1);
System.out.println("xmlString1" + xmlString1);
if (xmlString2.length() > 0 )
{
System.out.println("xmlString2" + xmlString2);
dom2 = parseString("<Root>" + xmlString2+ "</Root>");
}
valueXmlString = itemChanged(dom,dom1,dom2,objContext,currentColumn,editFlag,xtraParams);
}
catch(Exception e)
{
System.out.println("Exception : [EpaymentICEJB][itemChanged(String,String)] :==>\n"+e.getMessage());
}
return valueXmlString;
}
public String itemChanged(Document dom, Document dom1,Document dom2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException
{
Connection conn = null;
ConnDriver connDriver = new ConnDriver();
PreparedStatement vPStmt = null;
ResultSet vRs = null;
String sql = null;
int currentFormNo = 0;
StringBuffer valueXmlString = new StringBuffer();
String columnValue = null;
NodeList parentNodeList = null;
Node parentNode = null;
Node childNode = null;
NodeList childNodeList = null;
String childNodeName = null;
int childNodeListLength = 0;
int ctr = 0;
String loginSite = null;
try
{
conn = connDriver.getConnectDB("DriverITM");
connDriver = null;
if(objContext != null && objContext.length()>0)
{
currentFormNo = Integer.parseInt(objContext);
}
loginSite = getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode");
System.out.println("[EpaymentICEJB] [itemChanged] :currentFormNo ....." +currentFormNo);
valueXmlString = new StringBuffer("<?xml version=\"1.0\"?><Root><header><editFlag>");
valueXmlString.append(editFlag).append("</editFlag></header>");
valueXmlString.append("<Detail1>");
System.out.println("Current Form No ["+currentFormNo+"]");
switch (currentFormNo)
{
case 1:
//SEARCHING THE DOM FOR THE INCOMING COLUMN VALUE START
parentNodeList = dom.getElementsByTagName("Detail1");
parentNode = parentNodeList.item(0);
childNodeList = parentNode.getChildNodes();
ctr = 0;
childNodeListLength = childNodeList.getLength();
do
{
childNode = childNodeList.item(ctr);
childNodeName = childNode.getNodeName();
if(childNodeName.equals(currentColumn))
{
if (childNode.getFirstChild() != null)
{
columnValue=childNode.getFirstChild().getNodeValue();
}
}
ctr++;
}while(ctr < childNodeListLength && !childNodeName.equals(currentColumn));
System.out.println("[" + currentColumn + "] ==> '" + columnValue + "'");
if (currentColumn.equals( "itm_default" ))
{
String siteDescription = null;
loginSite = getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode");
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.start
/*
sql = "select s.descr site_descr from site s "
+" where s.site_code = '" + loginSite + "'";
vPStmt = conn.prepareStatement( sql );
vRs = vPStmt.executeQuery();
*/
sql = "SELECT S.DESCR SITE_DESCR FROM SITE S WHERE S.SITE_CODE = ?";
vPStmt = conn.prepareStatement( sql );
vPStmt.setString(1,loginSite);
vRs = vPStmt.executeQuery();
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.end
if( vRs.next() )
{
siteDescription = vRs.getString( "site_descr" );
}
vRs.close();
vRs = null;
vPStmt.close();
vPStmt = null;
valueXmlString.append("<tran_date>").append("<![CDATA[" + getCurrdateAppFormat() + "]]>").append("</tran_date>");
valueXmlString.append("<confirmed>").append("<![CDATA[" + "N" + "]]>").append("</confirmed>");
valueXmlString.append("<site_code>").append("<![CDATA[" + loginSite + "]]>").append("</site_code>");
valueXmlString.append("<site_descr>").append("<![CDATA[" + ( siteDescription != null ? siteDescription : "" )+ "]]>").append("</site_descr>");
}
if (currentColumn.equals( "site_code" ))
{
//site bank
String vSql = null;
String siteDescr = null;
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.start
/*
vSql = "select descr from site where site_code = '" + ( columnValue != null ? columnValue.trim() : "" ) + "'";
vPStmt = conn.prepareStatement( vSql );
vRs = vPStmt.executeQuery();
*/
vSql = "select descr from site where site_code = ?";
vPStmt = conn.prepareStatement(vSql);
if(columnValue != null)
{
vPStmt.setString(1,columnValue);
}
else
{
vPStmt.setString(1,"");
}
vRs = vPStmt.executeQuery();
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.end
if( vRs.next() )
{
siteDescr = vRs.getString( "descr" );
}
vRs.close();
vRs = null;
vPStmt.close();
vPStmt = null;
//end getting site bank
valueXmlString.append("<site_descr>").append("<![CDATA[" + ( siteDescr != null ? siteDescr : "" )+ "]]>").append("</site_descr>");
}
valueXmlString.append("</Detail1>");
valueXmlString.append("</Root>");
}//END OF TRY
}
catch(Exception e)
{
System.out.println("Exception ::"+ e.getMessage());
e.printStackTrace();
}
finally
{
try
{
if ( vRs != null )
{
vRs.close();
vRs = null;
}
if ( vPStmt != null )
{
vPStmt.close();
vPStmt = null;
}
if ( conn != null )
{
conn.close();
conn = null;
}
}
catch(Exception e)
{
System.out.println("Exception ::" + e);
e.printStackTrace();
}
}
return valueXmlString.toString();
}//END OF ITEMCHANGE
private String getCurrdateAppFormat()
{
String s = "";
GenericUtility genericUtility = GenericUtility.getInstance();
try
{
java.util.Date date = null;
Timestamp timestamp = new Timestamp(System.currentTimeMillis());
System.out.println(genericUtility.getDBDateFormat());
SimpleDateFormat simpledateformat = new SimpleDateFormat(genericUtility.getDBDateFormat());
date = simpledateformat.parse(timestamp.toString());
timestamp = Timestamp.valueOf(simpledateformat.format(date).toString() + " 00:00:00.0");
s = (new SimpleDateFormat(genericUtility.getApplDateFormat())).format(timestamp).toString();
}
catch(Exception exception)
{
System.out.println("Exception in getCurrdateAppFormat " + exception.getMessage());
}
return s;
}
package ibase.webitm.ejb.dis;
import java.rmi.RemoteException;
import java.text.*;
import java.sql.*;
import org.w3c.dom.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.*;
import ibase.system.config.*;
import ibase.webitm.ejb.*;
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class InvHoldRelIC extends ValidatorEJB implements InvHoldRelICLocal , InvHoldRelICRemote // SessionBean
{
GenericUtility genericUtility = GenericUtility.getInstance();
/*public void ejbCreate() throws RemoteException, CreateException
{
System.out.println("EpaymentICEJB is in Process..........");
}
public void ejbRemove()
{
}
public void ejbActivate()
{
}
public void ejbPassivate()
{
}*/
public String wfValData() throws RemoteException,ITMException
{
return "";
}
public String itemChanged() throws RemoteException,ITMException
{
return "";
}
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 = null;
System.out.println("Validation Start..........");
try
{
System.out.println( "xmlString::: " + xmlString );
System.out.println( "xmlString1:::" + xmlString1 );
System.out.println( "xmlString2:::" + xmlString2 );
dom = parseString(xmlString);
dom1 = parseString(xmlString1);
if (xmlString2.length() > 0 )
{
dom2 = parseString(xmlString2);
}
errString = wfValData(dom,dom1,dom2,objContext,editFlag,xtraParams);
}
catch(Exception e)
{
System.out.println("Exception : EpaymentICEJB : wfValData(String xmlString) : ==>\n"+e.getMessage());
}
return (errString);
}
public String wfValData(Document dom, Document dom1,Document dom2, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException
{
String errString = " ";
NodeList parentNodeList = null;
NodeList childNodeList = null;
Node parentNode = null;
Node childNode = null;
int ctr = 0;
String childNodeName = null;
String errCode = null;
String userId = null;
int cnt = 0;
int currentFormNo = 0;
int childNodeListLength;
Connection conn = null;
PreparedStatement pstmt=null;
ResultSet rs = null;
String sql = null;
String tranIdHold = null;
String lineNo = null;
ConnDriver connDriver = new ConnDriver();
try
{
System.out.println( "wfValData called" );
conn = connDriver.getConnectDB("DriverITM");
userId = getValueFromXTRA_PARAMS(xtraParams,"loginCode");
getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode");
genericUtility = GenericUtility.getInstance();
if(objContext != null && objContext.length()>0)
{
currentFormNo = Integer.parseInt(objContext);
}
switch(currentFormNo)
{
case 1 :
System.out.println("VALIDATION FOR DETAIL [ 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" ) )
{
String siteCode = null;
//Commented and changed the "cust_code" to "site_code" - Gulzar - 02/12/11
//siteCode = genericUtility.getColumnValue( "cust_code", dom, "1" );
siteCode = genericUtility.getColumnValue( "site_code", dom, "1" );
//End changes by gulzar - 02/12/11
if( siteCode != null )
{
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.start
/*
sql = " SELECT COUNT(*) FROM site WHERE site_code ='" + siteCode.trim() + "'";
System.out.println( " SQL FOR custCode ====> " + sql );
pstmt = conn.prepareStatement( sql );
rs = pstmt.executeQuery();
*/
sql = " SELECT COUNT(*) FROM site WHERE site_code = ?";
System.out.println( " SQL FOR custCode ====> " + sql );
pstmt = conn.prepareStatement( sql );
pstmt.setString(1,siteCode);
rs = pstmt.executeQuery();
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.end
cnt = 0;
if( rs.next() )
{
cnt = rs.getInt( 1 );
}
System.out.println(" COUNT =====> [" + cnt + "]");
if( cnt == 0 )
{
System.out.println(" ====> Site invalid or not found <==== ");
errCode = "VMINVSITE";
errString = getErrorString( "SITE_CODE", errCode, userId );
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
}
}
if ( childNodeName.equalsIgnoreCase( "emp_code__aprv" ) )
{
String empCode = null;
empCode = genericUtility.getColumnValue( "emp_code__aprv", dom, "1" );
if( empCode != null && empCode.length() > 0 )
{
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.start
/*
sql = " SELECT COUNT(*) FROM Employee WHERE emp_code ='" + empCode.trim() + "'";
System.out.println( " SQL FOR empCode ====> " + sql );
pstmt = conn.prepareStatement( sql );
rs = pstmt.executeQuery();
*/
sql = " SELECT COUNT(*) FROM Employee WHERE emp_code = ?";
System.out.println( " SQL FOR custCode ====> " + sql );
pstmt = conn.prepareStatement( sql );
pstmt.setString(1,empCode);
rs = pstmt.executeQuery();
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.end
cnt = 0;
if( rs.next() )
{
cnt = rs.getInt( 1 );
}
System.out.println(" COUNT =====> [" + cnt + "]");
if( cnt == 0 )
{
System.out.println(" ====> Employee invalid or not found <==== ");
errCode = "VMINVEMP";
errString = getErrorString( "EMP_CODE", errCode, userId );
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
}
}
} //END OF CASE1
break;
case 2 :
System.out.println("VALIDATION FOR DETAIL [ 2 ]..........");
parentNodeList = dom.getElementsByTagName("Detail2");
parentNode = parentNodeList.item(0);
childNodeList = parentNode.getChildNodes();
childNodeListLength = childNodeList.getLength();
for(ctr = 0; ctr < childNodeListLength; ctr++)
{
cnt = 0;
childNode = childNodeList.item(ctr);
childNodeName = childNode.getNodeName();
errCode = null;
if( childNodeName.equalsIgnoreCase( "tran_id__hold" ) || childNodeName.equalsIgnoreCase( "LINE_NO__HOLD" ) )
{
tranIdHold = genericUtility.getColumnValue( "tran_id__hold", dom, "2" );
lineNo = genericUtility.getColumnValue( "line_no__hold", dom, "2" );
if( tranIdHold != null && tranIdHold.length() > 0 )
{
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.start
/*
sql = "select count( 1 ) cnt from inv_hold_det where tran_id = '" + tranIdHold + "' ";
pstmt = conn.prepareStatement( sql );
rs = pstmt.executeQuery();
*/
sql = "select count( 1 ) cnt from inv_hold_det where tran_id = ?";
pstmt = conn.prepareStatement( sql );
pstmt.setString(1,tranIdHold);
rs = pstmt.executeQuery();
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.end
if( rs.next() )
{
cnt = rs.getInt( "cnt" );
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if( cnt == 0 )
{
errCode = "VTTRANINV";
}
if( errCode == null )
{
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.start
/*
sql = "select count( 1 ) cnt from inv_hold where tran_id = '" + tranIdHold + "' and confirmed = 'Y' ";
pstmt = conn.prepareStatement( sql );
rs = pstmt.executeQuery();
*/
sql = "select count( 1 ) cnt from inv_hold where tran_id = ? and confirmed = 'Y' ";
pstmt = conn.prepareStatement( sql );
pstmt.setString(1,tranIdHold);
rs = pstmt.executeQuery();
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.end
if( rs.next() )
{
cnt = rs.getInt( "cnt" );
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if( cnt == 0 )
{
errCode = "VTTRANUNC";
}
}
}
else
{
errCode = "VTTRANBLK";
}
if( errCode != null )
{
errString = getErrorString( "tran_id__hold", errCode, userId );
}else if( lineNo != null && lineNo.length() > 0 )
{
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.start
/*
sql = "select count( 1 ) cnt from inv_hold_det where tran_id = '" + tranIdHold + "' and line_no = " + lineNo;
pstmt = conn.prepareStatement( sql );
rs = pstmt.executeQuery();
*/
sql = "SELECT COUNT( 1 ) CNT FROM INV_HOLD_DET WHERE TRAN_ID = ? AND LINE_NO = ?";
pstmt = conn.prepareStatement( sql );
pstmt.setString(1,tranIdHold);
pstmt.setString(2,lineNo);
rs = pstmt.executeQuery();
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.end
if( rs.next() )
{
cnt = rs.getInt( "cnt" );
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if( cnt == 0 )
{
errCode = "VTLINEINV";
}
}
else
{
errCode = "VTLINEBLK";
}
if( errCode != null )
{
errString = getErrorString( "line_no__hold", errCode, userId );
}else if ( ( tranIdHold != null && tranIdHold.length() > 0 ) && ( lineNo != null && lineNo.length() > 0 ) )
{
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.start
/*
sql = "select count( 1 ) cnt from inv_hold_det where tran_id = '" + tranIdHold + "' and line_no = " + lineNo + " and HOLD_STATUS = 'R'";
pstmt = conn.prepareStatement( sql );
rs = pstmt.executeQuery();
*/
sql = "SELECT COUNT( 1 ) CNT FROM INV_HOLD_DET WHERE TRAN_ID = ? AND LINE_NO = ? AND HOLD_STATUS = 'R'";
pstmt = conn.prepareStatement( sql );
pstmt.setString(1,tranIdHold);
pstmt.setString(2,lineNo);
rs = pstmt.executeQuery();
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.end
if( rs.next() )
{
cnt = rs.getInt( "cnt" );
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if( cnt > 0 )
{
errCode = "VTTRNCNFED";
}
}
if( errCode != null )
{
errString = getErrorString( "line_no__hold", errCode, userId );
}
else
{
NodeList allLines = null;
NodeList allTranIds = null;
String tranIdH = null;
String lineNoH = null;
int recCnt = 0;
System.out.println( " tranIdHold, lineNoHold :: ( " + tranIdHold + ", " + lineNo + " )" );
allLines = dom2.getElementsByTagName("line_no__hold");
allTranIds = dom2.getElementsByTagName("tran_id__hold");
int noOfLines = allLines.getLength();
for( int idx = 0; idx < noOfLines ; idx++ )
{
if ( allTranIds.item( idx ).getFirstChild() != null )
{
tranIdH = ( allTranIds.item( idx ).getFirstChild() ).getNodeValue();
}
if ( allLines.item( idx ).getFirstChild() != null )
{
lineNoH = ( allLines.item( idx ).getFirstChild() ).getNodeValue();
}
System.out.println( " tranIdH :: ( " + tranIdH + ", " + lineNoH + " )" );
if( tranIdH.equals( tranIdHold ) && lineNoH.equals( lineNo ) )
{
recCnt++;
}
}
if( recCnt > 1 )
{
errCode = "VTDUPENTRY";
errString = getErrorString( "line_no__hold", errCode, userId );
}
}
}
}//END FOR OF CASE2
break;
}//END SWITCH
}//END TRY
catch(Exception e)
{
System.out.println("Exception ::" +e);
e.printStackTrace();
errString = e.getMessage();
}
finally
{
try
{
if(conn != null)
{
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
if( rs != null )
{
rs.close();
rs = null;
}
conn.close();
}
conn = null;
}
catch(Exception d)
{
d.printStackTrace();
}
System.out.println(" < ExprProcessIcEJB > CONNECTION IS CLOSED");
}
System.out.println("ErrString ::" + errString);
return errString;
}//END OF VALIDATION
public String itemChanged(String xmlString, String xmlString1,String xmlString2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException
{
Document dom = null;
Document dom1 = null;
Document dom2 = null;
String valueXmlString = null;
try
{
dom = parseString(xmlString);
System.out.println("xmlString" + xmlString);
dom1 = parseString(xmlString1);
System.out.println("xmlString1" + xmlString1);
if (xmlString2.length() > 0 )
{
System.out.println("xmlString2" + xmlString2);
dom2 = parseString("<Root>" + xmlString2+ "</Root>");
}
valueXmlString = itemChanged(dom,dom1,dom2,objContext,currentColumn,editFlag,xtraParams);
}
catch(Exception e)
{
System.out.println("Exception : [EpaymentICEJB][itemChanged(String,String)] :==>\n"+e.getMessage());
}
return valueXmlString;
}
public String itemChanged(Document dom, Document dom1,Document dom2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException
{
Connection conn = null;
ConnDriver connDriver = new ConnDriver();
PreparedStatement vPStmt = null;
ResultSet vRs = null;
String sql = null;
int currentFormNo = 0;
StringBuffer valueXmlString = new StringBuffer();
String columnValue = null;
NodeList parentNodeList = null;
Node parentNode = null;
Node childNode = null;
NodeList childNodeList = null;
String childNodeName = null;
int childNodeListLength = 0;
int ctr = 0;
String loginSite = null;
try
{
conn = connDriver.getConnectDB("DriverITM");
connDriver = null;
if(objContext != null && objContext.length()>0)
{
currentFormNo = Integer.parseInt(objContext);
}
loginSite = getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode");
System.out.println("[EpaymentICEJB] [itemChanged] :currentFormNo ....." +currentFormNo);
valueXmlString = new StringBuffer("<?xml version=\"1.0\"?><Root><header><editFlag>");
valueXmlString.append(editFlag).append("</editFlag></header>");
valueXmlString.append("<Detail1>");
System.out.println("Current Form No ["+currentFormNo+"]");
switch (currentFormNo)
{
case 1:
//SEARCHING THE DOM FOR THE INCOMING COLUMN VALUE START
parentNodeList = dom.getElementsByTagName("Detail1");
parentNode = parentNodeList.item(0);
childNodeList = parentNode.getChildNodes();
ctr = 0;
childNodeListLength = childNodeList.getLength();
do
{
childNode = childNodeList.item(ctr);
childNodeName = childNode.getNodeName();
if(childNodeName.equals(currentColumn))
{
if (childNode.getFirstChild() != null)
{
columnValue=childNode.getFirstChild().getNodeValue();
}
}
ctr++;
}while(ctr < childNodeListLength && !childNodeName.equals(currentColumn));
System.out.println("[" + currentColumn + "] ==> '" + columnValue + "'");
if (currentColumn.equals( "itm_default" ))
{
String siteDescription = null;
loginSite = getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode");
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.start
/*
sql = "select s.descr site_descr from site s "
+" where s.site_code = '" + loginSite + "'";
vPStmt = conn.prepareStatement( sql );
vRs = vPStmt.executeQuery();
*/
sql = "SELECT S.DESCR SITE_DESCR FROM SITE S WHERE S.SITE_CODE = ?";
vPStmt = conn.prepareStatement( sql );
vPStmt.setString(1,loginSite);
vRs = vPStmt.executeQuery();
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.end
if( vRs.next() )
{
siteDescription = vRs.getString( "site_descr" );
}
vRs.close();
vRs = null;
vPStmt.close();
vPStmt = null;
valueXmlString.append("<tran_date>").append("<![CDATA[" + getCurrdateAppFormat() + "]]>").append("</tran_date>");
valueXmlString.append("<confirmed>").append("<![CDATA[" + "N" + "]]>").append("</confirmed>");
valueXmlString.append("<site_code>").append("<![CDATA[" + loginSite + "]]>").append("</site_code>");
valueXmlString.append("<site_descr>").append("<![CDATA[" + ( siteDescription != null ? siteDescription : "" )+ "]]>").append("</site_descr>");
}
if (currentColumn.equals( "site_code" ))
{
//site bank
String vSql = null;
String siteDescr = null;
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.start
/*
vSql = "select descr from site where site_code = '" + ( columnValue != null ? columnValue.trim() : "" ) + "'";
vPStmt = conn.prepareStatement( vSql );
vRs = vPStmt.executeQuery();
*/
vSql = "select descr from site where site_code = ?";
vPStmt = conn.prepareStatement(vSql);
if(columnValue != null)
{
vPStmt.setString(1,columnValue);
}
else
{
vPStmt.setString(1,"");
}
vRs = vPStmt.executeQuery();
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.end
if( vRs.next() )
{
siteDescr = vRs.getString( "descr" );
}
vRs.close();
vRs = null;
vPStmt.close();
vPStmt = null;
//end getting site bank
valueXmlString.append("<site_descr>").append("<![CDATA[" + ( siteDescr != null ? siteDescr : "" )+ "]]>").append("</site_descr>");
}
valueXmlString.append("</Detail1>");
valueXmlString.append("</Root>");
}//END OF TRY
}
catch(Exception e)
{
System.out.println("Exception ::"+ e.getMessage());
e.printStackTrace();
}
finally
{
try
{
if ( vRs != null )
{
vRs.close();
vRs = null;
}
if ( vPStmt != null )
{
vPStmt.close();
vPStmt = null;
}
if ( conn != null )
{
conn.close();
conn = null;
}
}
catch(Exception e)
{
System.out.println("Exception ::" + e);
e.printStackTrace();
}
}
return valueXmlString.toString();
}//END OF ITEMCHANGE
private String getCurrdateAppFormat()
{
String s = "";
GenericUtility genericUtility = GenericUtility.getInstance();
try
{
java.util.Date date = null;
Timestamp timestamp = new Timestamp(System.currentTimeMillis());
System.out.println(genericUtility.getDBDateFormat());
SimpleDateFormat simpledateformat = new SimpleDateFormat(genericUtility.getDBDateFormat());
date = simpledateformat.parse(timestamp.toString());
timestamp = Timestamp.valueOf(simpledateformat.format(date).toString() + " 00:00:00.0");
s = (new SimpleDateFormat(genericUtility.getApplDateFormat())).format(timestamp).toString();
}
catch(Exception exception)
{
System.out.println("Exception in getCurrdateAppFormat " + exception.getMessage());
}
return s;
}
}
\ 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