Commit daacb97c authored by cpatil's avatar cpatil

*** empty log message ***


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@91776 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 41fcb566
......@@ -20,6 +20,7 @@ import java.lang.*;
import java.io.*;
import java.rmi.RemoteException;
import java.sql.*;
import javax.ejb.*;
import java.text.*;
import java.util.*;
......@@ -32,7 +33,7 @@ public class InvHoldGen
public String generateHoldTrans( String lockCode, String refID, String refSer, String siteCode, ArrayList stockList, String xtraParams, Connection conn )throws RemoteException,ITMException
{
String sql = "";
String sql = "",sqlIn="";
String confirmed = "";
String itemCode = "";
String locCode = "";
......@@ -42,15 +43,15 @@ public class InvHoldGen
String chgTerm = "";
String retString = "";
String tranId = "";
java.sql.Timestamp chgDate = null,currDate = null;
int lineNo = 0;
java.sql.Timestamp chgDate = null,currDate = null,currDate2 = null;
int lineNo = 0,stdDays=0;
boolean isError = false;
PreparedStatement pstmtHold = null;
PreparedStatement pstmtHold = null,pstmtIn=null;
PreparedStatement pstmtHolddet = null;
PreparedStatement pstmtSel = null;
ResultSet rsSel = null;
ResultSet rsSel = null,rsIn=null;
java.util.Date date = null;
......@@ -66,7 +67,7 @@ public class InvHoldGen
pstmtHold = conn.prepareStatement(holdInsertSql);
String holddetInsertSql = "INSERT INTO INV_HOLD_DET(TRAN_ID,LINE_NO,ITEM_CODE,SITE_CODE,LOC_CODE,LOT_NO,LOT_SL,HOLD_STATUS) VALUES(?,?,?,?,?,?,?,?)";
String holddetInsertSql = "INSERT INTO INV_HOLD_DET(TRAN_ID,LINE_NO,ITEM_CODE,SITE_CODE,LOC_CODE,LOT_NO,LOT_SL,HOLD_STATUS,SCH_REL_DATE) VALUES(?,?,?,?,?,?,?,?,?)";
pstmtHolddet = conn.prepareStatement(holddetInsertSql);
GenericUtility genericUtility = GenericUtility.getInstance();
......@@ -148,6 +149,31 @@ public class InvHoldGen
{
lotSl = (String)dataMap.get("lot_sl");
}
//add by cpatil start on 28-07-12 as per manoharan sir
sqlIn="select std_days from inv_lock where lock_code = ?";
pstmtIn = conn.prepareStatement(sql);
pstmtIn.setString(1,lockCode);
rsIn = pstmtIn.executeQuery();
if(rsIn.next())
{
stdDays = rsIn.getInt("std_days");
}
rsIn.close();
rsIn= null;
pstmtIn.close();
pstmtIn=null;
Calendar c = Calendar.getInstance();
c.setTime(currDate);
c.add(Calendar.DATE, stdDays);
currDate2 = new Timestamp(c.getTimeInMillis());
//add by cpatil on 28-07-12 end
pstmtHolddet.setString( 1, tranId );
pstmtHolddet.setInt( 2, lineNo );
pstmtHolddet.setString( 3, itemCode );
......@@ -156,6 +182,7 @@ public class InvHoldGen
pstmtHolddet.setString( 6, lotNo );
pstmtHolddet.setString( 7, lotSl );
pstmtHolddet.setString( 8, "H" );
pstmtHolddet.setTimestamp( 9, currDate2 ); //add by cpatil on 28-07-12 as per manoharan sir
pstmtHolddet.addBatch();
pstmtHolddet.clearParameters();
dataMap.clear();
......
......@@ -73,16 +73,16 @@ public class InvHoldIC extends ValidatorEJB implements InvHoldICLocal , InvHoldI
Node childNode = null;
int ctr = 0;
String childNodeName = null;
String errCode = null;
String userId = null;
int cnt = 0;
int cnt = 0,quantity=0;
int currentFormNo = 0;
int childNodeListLength;
Connection conn = null;
PreparedStatement pstmt=null;
ResultSet rs = null;
String sql = null;
PreparedStatement pstmt=null,pstmtQuant=null;
ResultSet rs = null,rsQuant=null;
String sql = null,sqlQuant=null;
String tranDateStr = null;
......@@ -145,6 +145,8 @@ public class InvHoldIC extends ValidatorEJB implements InvHoldICLocal , InvHoldI
pstmt.close();
pstmt = null;
}
}
if ( childNodeName.equalsIgnoreCase( "emp_code__aprv" ) )
......@@ -230,10 +232,9 @@ public class InvHoldIC extends ValidatorEJB implements InvHoldICLocal , InvHoldI
lockCode = genericUtility.getColumnValue( "lock_code", dom, "1" );
if(lockCode == null)//checking for null
{
errString = getErrorString("lock_code","NULLLOCKCD",userId);
break;
// errString = getErrorString("lock_code","NULLLOCKCD",userId); //commented by cpatil on 1/08/12 as per manoharan sir
// break;
}
else //To check exist in INV_LOCK master
{
sql = "SELECT COUNT(*) COUNT FROM INV_LOCK WHERE LOCK_CODE = ? " ;
......@@ -328,6 +329,76 @@ public class InvHoldIC extends ValidatorEJB implements InvHoldICLocal , InvHoldI
pstmt.close();
pstmt = null;
//added by cpatil start on 01/08/12 as per manoharan sir
String siteCode = genericUtility.getColumnValue( "site_code", dom, "2" );
String locCode = genericUtility.getColumnValue( "loc_code", dom, "2" );
String lotNo = genericUtility.getColumnValue( "lot_no", dom, "2" );
String lotSl = genericUtility.getColumnValue( "lot_sl", dom, "2" );
int i=2;
//System.out.println("@@@@@@::siteCode:["+siteCode+"]::locCode["+locCode+"]::lotNo:["+lotNo+"]::lotSl:["+lotSl+"]");
sqlQuant="select sum(quantity) from stock where item_code= ? ";
if( siteCode!=null )
{
sqlQuant = sqlQuant + " and site_code = ?";
}
if( locCode!=null )
{
sqlQuant = sqlQuant + " and loc_code = ?";
}
if( lotNo !=null )
{
sqlQuant = sqlQuant + " and lot_no = ?";
}
if( lotSl!=null )
{
sqlQuant = sqlQuant + " and lot_sl = ?";
}
pstmtQuant = conn.prepareStatement( sqlQuant );
pstmtQuant.setString(1,itemCode);
if( siteCode!=null )
{
pstmtQuant.setString(i,siteCode);
i++;
}
if( locCode!=null )
{
pstmtQuant.setString(i,locCode);
i++;
}
if( lotNo !=null )
{
pstmtQuant.setString(i,lotNo);
i++;
}
if( lotSl!=null )
{
pstmtQuant.setString(i,lotSl);
}
rsQuant = pstmtQuant.executeQuery();
if( rsQuant.next() )
{
quantity = rsQuant.getInt( 1 );
}
rsQuant.close();
rsQuant = null;
pstmtQuant.close();
pstmtQuant = null;
if(quantity == 0)
{
errString = getErrorString( "item_code", "VTINQTY09" , userId );
}
// cpatil end
}
else
{
......@@ -381,7 +452,7 @@ public class InvHoldIC extends ValidatorEJB implements InvHoldICLocal , InvHoldI
{
if(lineNoSlPrsnt)
{
errString = getErrorString( "SITE_CODE", "NULLSITECD" , userId );
// errString = getErrorString( "SITE_CODE", "NULLSITECD" , userId ); //commented by cpatil on 01/08/12 as per manoharan sir
}
}
//changed by Dharmesh on 12-08-2011 [WM1ESUN004] to validate null site code if Line No is present.end
......@@ -389,8 +460,11 @@ public class InvHoldIC extends ValidatorEJB implements InvHoldICLocal , InvHoldI
else if( childNodeName.equalsIgnoreCase( "loc_code" ) )
{
String locCode = null;
locCode = genericUtility.getColumnValue( "loc_code", dom, "2" );
if( locCode != null )
{
//Changed by Dharmesh on 09/08/11 [WM1ESUN004] to bind variable dynamically instead of statically.start
......@@ -423,14 +497,17 @@ public class InvHoldIC extends ValidatorEJB implements InvHoldICLocal , InvHoldI
pstmt.close();
pstmt = null;
}
//changed by Dharmesh on 12-08-2011 [WM1ESUN004] to validate null location code if Line No is present.start
else
{
if(lineNoSlPrsnt)
{
errString = getErrorString( "LOC_CODE", "NULLLOCCD" , userId );
// errString = getErrorString( "LOC_CODE", "NULLLOCCD" , userId ); // commented by cpatil on 01/08/12 as per manoharan sir
}
}
//changed by Dharmesh on 12-08-2011 [WM1ESUN004] to validate null location code if Line No is present.end
......@@ -446,7 +523,7 @@ public class InvHoldIC extends ValidatorEJB implements InvHoldICLocal , InvHoldI
{
if( lotNo == null )
{
errString = getErrorString( "LOT_NO", "NULLLOTNO", userId );
// errString = getErrorString( "LOT_NO", "NULLLOTNO", userId ); //commented by cpatil on 01/08/12 as per manoharan sir
}
}
}
......@@ -459,7 +536,7 @@ public class InvHoldIC extends ValidatorEJB implements InvHoldICLocal , InvHoldI
{
if( lotSl == null )
{
errString = getErrorString( "LOT_SL", "NULLLOTSL", userId );
// errString = getErrorString( "LOT_SL", "NULLLOTSL", userId ); //commented by cpatil on 01/08/12 as per manoharan sir
}
}
}
......@@ -515,7 +592,8 @@ public class InvHoldIC extends ValidatorEJB implements InvHoldICLocal , InvHoldI
System.out.println("Exception ::" +e);
e.printStackTrace();
errCode = "VALEXCEP";
errString = getErrorString( "", errCode, userId );
errString = getErrorString( "", errCode, userId );
throw new ITMException(e);
}
finally
{
......@@ -571,6 +649,7 @@ public class InvHoldIC extends ValidatorEJB implements InvHoldICLocal , InvHoldI
catch(Exception e)
{
System.out.println("Exception : [EpaymentICEJB][itemChanged(String,String)] :==>\n"+e.getMessage());
throw new ITMException(e);
}
return valueXmlString;
}
......@@ -908,6 +987,7 @@ public class InvHoldIC extends ValidatorEJB implements InvHoldICLocal , InvHoldI
{
System.out.println("Exception ::" + e);
e.printStackTrace();
throw new ITMException(e);
}
}
return valueXmlString.toString();
......
package ibase.webitm.ejb.dis;
import java.rmi.RemoteException;
import java.sql.*;
import org.w3c.dom.*;
import ibase.utility.CommonConstants;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.*;
import ibase.system.config.*;
import java.text.SimpleDateFormat;
import javax.ejb.Stateless; // added for ejb3
@Stateless
public class InvHoldRelGen extends ProcessEJB implements InvHoldRelGenLocal, InvHoldRelGenRemote
{
DistCommon distCommonObj = new DistCommon();
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
@Override
public String process() throws RemoteException,ITMException
{
return "";
}
//getData Method
@Override
public String getData(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException
{
String rtrStr = "";
Document headerDom = null;
Document detailDom = null;
try
{
if(xmlString != null && xmlString.trim().length()!=0)
{
System.out.println("XML String :"+xmlString);
headerDom = genericUtility.parseString(xmlString);
}
if(xmlString2 != null && xmlString2.trim().length()!=0)
{
System.out.println("XML String :"+xmlString2);
detailDom = genericUtility.parseString(xmlString2);
}
rtrStr = getData(headerDom, detailDom, windowName, xtraParams);
}
catch (Exception e)
{
System.out.println("Exception :InvHoldRelGenEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":");
rtrStr = e.getMessage();
throw new ITMException(e);
}
return rtrStr;
}//END OF GETDATA(1)
public String blanknull(String s)
{
if(s==null)
return " ";
else
return s;
}
@Override
public String getData(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException
{
String errCode = "";
String errString = "";
String getDataSql= "" ;
String resultString = "";
ResultSet rs1 = null;
PreparedStatement pstmt = null;
StringBuffer retTabSepStrBuff = new StringBuffer();
int cnt=0,count=0;
String sql="";
String tranIdFrom = "",tranIdTo="",refIdFrom="",refIdTo="",autoConfirmed="",schRelDateFromstr="",schRelDateTostr="";
Timestamp schRelDateFrom=null,schRelDateTo=null;
ConnDriver connDriver = new ConnDriver();
Connection conn= null;
try
{
if(conn==null)
{
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
}
DatabaseMetaData dbmd = conn.getMetaData();
System.out.println("DriverName["+dbmd.getDriverName() + "]");
System.out.println("DriverURI["+dbmd.getURL() + "]");
System.out.println("DriverUSER["+dbmd.getUserName() +"]");
System.out.println("InvHoldRelGen : getData() Method Called");
tranIdFrom = genericUtility.getColumnValue("tran_id__from",headerDom);
tranIdTo = genericUtility.getColumnValue("tran_id__to",headerDom);
schRelDateFromstr = genericUtility.getColumnValue("sch_rel_date__from",headerDom);
schRelDateTostr = genericUtility.getColumnValue("sch_rel_date__to",headerDom);
refIdFrom = genericUtility.getColumnValue("ref_id__from",headerDom);
refIdTo = genericUtility.getColumnValue("ref_id__to",headerDom);
autoConfirmed = genericUtility.getColumnValue("auto_confirmed",headerDom);
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
schRelDateFrom= Timestamp.valueOf(genericUtility.getValidDateString(schRelDateFromstr, genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat()) + " 00:00:00.0");
schRelDateTo= Timestamp.valueOf(genericUtility.getValidDateString(schRelDateTostr, genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat()) + " 00:00:00.0");
System.out.println("schRelDateFrom : ["+schRelDateFrom+"]:::schRelDateTo:["+schRelDateTo+"]");
System.out.println("tranIdFrom=>"+tranIdFrom);
System.out.println("tranIdTo=>"+tranIdTo);
System.out.println("refIdFrom =>"+refIdFrom);
System.out.println("refIdTo =>"+refIdTo);
System.out.println("autoConfirmed =>"+autoConfirmed);
if ( tranIdFrom == null || tranIdFrom.trim().length() == 0 )
{
System.out.println("tran id from is Null...");
errString = itmDBAccessEJB.getErrorString("","VMTRIDFRNU","","",conn);
return errString;
}
else
{
sql = "select count(1) from inv_hold_det where tran_id ='" + tranIdFrom + "'";
pstmt = conn.prepareStatement(sql);
rs1 = pstmt.executeQuery();
if (rs1.next())
{
cnt = rs1.getInt(1);
}
pstmt.close();
rs1.close();
pstmt = null;
rs1 = null;
if (cnt == 0)
{
errString = itmDBAccessEJB.getErrorString("","TRIDFRINV","","",conn);
return errString;
}
}
if ( tranIdTo == null || tranIdTo.trim().length() == 0 )
{
System.out.println("tran id to is Null...");
errString = itmDBAccessEJB.getErrorString("","VMTRIDTONU","","",conn);
return errString;
}
else
{
sql = "select count(1) from inv_hold_det where tran_id ='" + tranIdTo + "'";
pstmt = conn.prepareStatement(sql);
rs1 = pstmt.executeQuery();
if (rs1.next())
{
cnt = rs1.getInt(1);
}
pstmt.close();
rs1.close();
pstmt = null;
rs1 = null;
if (cnt == 0)
{
errString = itmDBAccessEJB.getErrorString("","TRIDTOINV","","",conn);
return errString;
}
}
if ( schRelDateFrom == null )
{
System.out.println("schedule release date from is Null...");
errString = itmDBAccessEJB.getErrorString("","VMSCDTFRNU","","",conn);
return errString;
}
else
{
if(schRelDateTo != null)
{
if(schRelDateFrom.after(schRelDateTo))
{
errString = itmDBAccessEJB.getErrorString("","SCDATEFRINV","","",conn);
return errString;
}
}
}
if ( schRelDateTo == null )
{
System.out.println("schedule release date to is Null...");
errString = itmDBAccessEJB.getErrorString("","VMSCDTTONU","","",conn);
return errString;
}
else
{
if(schRelDateTo != null)
{
if(schRelDateTo.before(schRelDateFrom))
{
errString = itmDBAccessEJB.getErrorString("","SCDATETOINV","","",conn);
return errString;
}
}
}
if ( refIdFrom == null )
{
refIdFrom="0";
//System.out.println("ref id from is Null...");
//errString = itmDBAccessEJB.getErrorString("","VMRFIDFRNU","","",conn);
//return errString;
}
else
{
/*
sql = "select count(1) from inv_hold where ref_id ='" + refIdFrom + "'";
pstmt = conn.prepareStatement(sql);
rs1 = pstmt.executeQuery();
if (rs1.next())
{
cnt = rs1.getInt(1);
}
pstmt.close();
rs1.close();
pstmt = null;
rs1 = null;
if (cnt == 0)
{
errString = itmDBAccessEJB.getErrorString("","REFIDFRINV","","",conn);
return errString;
}
*/
}
if ( refIdTo == null )
{
refIdTo="0";
//System.out.println("ref id to is Null...");
//errString = itmDBAccessEJB.getErrorString("","VMRFIDTONU","","",conn);
//return errString;
}
else
{
/*
sql = "select count(1) from inv_hold where ref_id ='" + refIdTo + "'";
pstmt = conn.prepareStatement(sql);
rs1 = pstmt.executeQuery();
if (rs1.next())
{
cnt = rs1.getInt(1);
}
pstmt.close();
rs1.close();
pstmt = null;
rs1 = null;
if (cnt == 0)
{
errString = itmDBAccessEJB.getErrorString("","REFIDTOINV","","",conn);
return errString;
}
*/
}
/*
if ( autoConfirmed == null )
{
System.out.println("auto Confirmed is Null...");
errString = itmDBAccessEJB.getErrorString("","VMAUTCONNU","","",conn);
return errString;
}
*/
getDataSql= " select ihd.tran_id,ihd.line_no,ihd.line_no_sl," +
" case when ihd.hold_status is null then 'H' else ihd.hold_status end as hold_status ," +
" ihd.item_code,ihd.loc_code,ihd.site_code,ihd.status_date,ihd.reas_code,ihd.sch_rel_date," +
" ih.ref_id,ih.confirmed from inv_hold_det ihd,inv_hold ih where ( ihd.tran_id = ih.tran_id )" +
" and ( ihd.tran_id >= ? and ihd.tran_id <= ? ) and ( ihd.sch_rel_date between ? and ? )" +
" and (ih.ref_id >= ? and ih.ref_id <= ? ) ";
System.out.println("Sql Fired :::::"+getDataSql.trim().length());
if (getDataSql.trim().length()>0)
{
System.out.println("Sql Fired :::::"+getDataSql);
pstmt = conn.prepareStatement(getDataSql);
pstmt.setString(1,tranIdFrom);
pstmt.setString(2,tranIdTo);
pstmt.setTimestamp(3,schRelDateFrom);
pstmt.setTimestamp(4,schRelDateTo);
pstmt.setString(5,refIdFrom);
pstmt.setString(6,refIdTo);
System.out.println("QUERY IS IN PROCESS..........");
rs1 = pstmt.executeQuery();
System.out.println("QUERY PROCESS FINISED.......");
while(rs1.next())
{
//tran_id
retTabSepStrBuff.append((rs1.getString(1)==null?" ":rs1.getString(1))).append("\t");
//line_no
retTabSepStrBuff.append((rs1.getString(2)==null?" ":rs1.getString(2))).append("\t");
//line_no_sl
retTabSepStrBuff.append((rs1.getString(3)==null?" ":rs1.getString(3))).append("\t");
//hold_status
if(rs1.getString(4)!=null)
{
retTabSepStrBuff.append((rs1.getString(4)==null?" ":rs1.getString(4))).append("\t");
}
else
{
retTabSepStrBuff.append("H").append("\t");
}
//item_code
retTabSepStrBuff.append((rs1.getString(5)==null?" ":rs1.getString(5))).append("\t");
//loc_code
retTabSepStrBuff.append((rs1.getString(6)==null?" ":rs1.getString(6))).append("\t");
//site_code
retTabSepStrBuff.append((rs1.getString(7)==null?" ":rs1.getString(7))).append("\t");
//status_date
if(rs1.getTimestamp(8)!=null)
{
retTabSepStrBuff.append(this.genericUtility.getValidDateString(rs1.getTimestamp(8).toString(),this.genericUtility.getDBDateFormat(),this.genericUtility.getApplDateFormat())).append("\t");
}
else
{
retTabSepStrBuff.append(" ").append("\t");
}
//reas_code
retTabSepStrBuff.append((rs1.getString(9)==null?" ":rs1.getString(9))).append("\t");
//sch_rel_date
if(rs1.getTimestamp(10)!=null)
{
retTabSepStrBuff.append(this.genericUtility.getValidDateString(rs1.getTimestamp(10).toString(),this.genericUtility.getDBDateFormat(),this.genericUtility.getApplDateFormat())).append("\t");
}
else
{
retTabSepStrBuff.append(" ").append("\t");
}
//ref_id
retTabSepStrBuff.append((rs1.getString(11)==null?" ":rs1.getString(11))).append("\t");
//confirmed
retTabSepStrBuff.append((rs1.getString(12)==null?" ":rs1.getString(12))).append("\t");
retTabSepStrBuff.append("\n");
count++;
System.out.println("#####Counter:["+count+"]");
}//END WHILE
rs1.close();
pstmt.close();
rs1=null;
pstmt=null;
if (count == 0 )
{
errString = itmDBAccessEJB.getErrorString("","VTNOREC1","","",conn);
}
}
else
{
System.out.println("Sql:::::is Null ::::::::::::::");
errString = itmDBAccessEJB.getErrorString("","VTNOREC1","","",conn);
}
System.out.println("retTabSepStrBuff:::["+retTabSepStrBuff.toString()+"]");
} //end of try
catch (SQLException e)
{
e.printStackTrace();
System.out.println("SQLException :InvHoldRelGenEJB :getData(Document headerDom, Document detailDom, String windowName, String xtraParams):" + e.getMessage() + ":");
throw new ITMException(e);
}
catch (Exception e)
{
e.printStackTrace();
System.out.println("Exception :InvHoldRelGenEJB :getData(Document headerDom, Document detailDom, String windowName, String xtraParams):" + e.getMessage() + ":");
throw new ITMException(e);
}
finally
{
try
{
conn.close();
conn = null;
}
catch(Exception e)
{
errString = e.getMessage();
e.printStackTrace();
throw new ITMException(e);
}
}
if (getDataSql.trim().length()>0 && count > 0)
{
return retTabSepStrBuff.toString();
}
else
{
errString = itmDBAccessEJB.getErrorString("","VTNOREC1","","",conn);
return errString;
}
}
@Override
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException
{
Document detailDom = null;
Document headerDom = null;
GenericUtility genericUtility = GenericUtility.getInstance();
String retStr = "";
Connection conn=null;
try
{
ConnDriver connDriver = new ConnDriver();
//Connection conn= null;
if(conn==null)
{
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
}
//DatabaseMetaData dbmd = conn.getMetaData();
System.out.println("xmlString[process]::::::::::;;;"+xmlString);
System.out.println("xmlString2[process]::::::::::;;;"+xmlString2);
System.out.println("windowName[process]::::::::::;;;"+windowName);
System.out.println("xtraParams[process]:::::::::;;;"+xtraParams);
}
catch(Exception e)
{
System.out.println(e.getMessage());
}
try
{
if(xmlString != null && xmlString.trim().length()!=0)
{
headerDom = genericUtility.parseString(xmlString);
System.out.println("headerDom" + headerDom);
}
if(xmlString2 != null && xmlString2.trim().length()!=0)
{
detailDom = genericUtility.parseString(xmlString2);
System.out.println("detailDom" + detailDom);
}
retStr = process(xmlString, xmlString2, windowName, xtraParams,conn);
}
catch (Exception e)
{
System.out.println("Exception :InvHoldRelGenEJB :process(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":");
retStr = e.getMessage();
e.printStackTrace();
throw new ITMException(e);
}
return retStr;
}//END OF PROCESS (1)
public String process(String xmlString, String xmlString2, String windowName, String xtraParams,Connection conn) throws RemoteException,ITMException
{
GenericUtility genericUtility = GenericUtility.getInstance();
String retStr = "",tranId="",sql="",errString="",lockCode="",holdStatus="";//xmlString="",
ResultSet rs = null;
PreparedStatement pstmt = null;
ConnDriver connDriver = new ConnDriver();
//Connection conn= null;
int cnt=0,updCnt=0,ctr=0,count=0;
String invHoldRelSql = "",invHoldRelDetSql;
PreparedStatement pRelHdr = null;
PreparedStatement pRelDet = null;
java.sql.Timestamp chgDate = null,currDate = null;
Date date = null;
String chgTerm = "",autoConfirmed="";
String userId = "",siteCode="",confirmed="",empCode="",tranIdGenerate="",lineNo="",remark="",tranIdRel="",lineNoRel="";
Document dom = null,headerDom=null,detailDom=null;
ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
try
{
System.out.println("method : process(xmlString, xmlString2, windowName, xtraParams,conn) called");
if(xmlString != null && xmlString.trim().length()!=0)
{
System.out.println("xmlString[process]::::::::::;;;"+xmlString);
System.out.println("xmlString2[process]::::::::::;;;"+xmlString2);
headerDom = genericUtility.parseString(xmlString);
detailDom= genericUtility.parseString(xmlString2);
//System.out.println("::::::headerDom :::::[" + headerDom+"]");
tranId = genericUtility.getColumnValue("tran_id",detailDom);
autoConfirmed = genericUtility.getColumnValue("auto_confirmed",headerDom);
System.out.println("tranId:["+tranId+"]:::::autoConfirmed:["+autoConfirmed+"]");
//System.out.println("INV_HOLD_REL sql ");
invHoldRelSql = "INSERT INTO INV_HOLD_REL(TRAN_ID, TRAN_DATE, SITE_CODE, REMARKS, CONFIRMED, EMP_CODE__APRV,CHG_USER ,CHG_DATE, CHG_TERM) VALUES(?,?,?,?,?,?,?,?,?)";
pRelHdr = conn.prepareStatement(invHoldRelSql);
//System.out.println("INV_HOLD_REL_DET sql ");
invHoldRelDetSql = "INSERT INTO INV_HOLD_REL_DET(TRAN_ID, LINE_NO, TRAN_ID__HOLD, LINE_NO__HOLD, REMARKS) VALUES(?,?,?,?,?)";
pRelDet = conn.prepareStatement(invHoldRelDetSql);
currDate = new java.sql.Timestamp(System.currentTimeMillis());
userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode");
chgTerm = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "chgTerm" );
siteCode = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "site_code" );
confirmed = "N";
empCode = "";
SimpleDateFormat sdfAppl = new SimpleDateFormat(genericUtility.getApplDateFormat());
String currDateStr = sdfAppl.format(currDate);
tranIdGenerate = generateTranId( "w_inv_hold_rel", siteCode, currDateStr, conn );
pRelHdr.setString( 1, tranIdGenerate );
pRelHdr.setTimestamp( 2, currDate );
pRelHdr.setString( 3, siteCode );
pRelHdr.setString( 4, " " );
pRelHdr.setString( 5, confirmed );
pRelHdr.setString( 6, empCode );
pRelHdr.setString( 7, userId );
pRelHdr.setTimestamp( 8, currDate );
pRelHdr.setString( 9, chgTerm );
updCnt = pRelHdr.executeUpdate();
pRelHdr.clearParameters();
if( updCnt > 0 )
{
System.out.println( updCnt + "INV_HOLD_REL rows inserted successfully" );
}
lineNo = genericUtility.getColumnValue("line_no",detailDom);
sql = "select count(*) from inv_hold_det where tran_id = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if( rs.next() )
{
count = rs.getInt(1);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if(count != 0)
{
ctr++;
sql = "select tran_id, line_no from inv_hold_det where tran_id = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if( rs.next() )
{
tranIdRel = rs.getString("tran_id");
lineNoRel = rs.getString("line_no");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
pRelDet.setString( 1, tranIdGenerate );
pRelDet.setString( 2,lineNo);
pRelDet.setString( 3, tranIdRel );
pRelDet.setString( 4, lineNoRel );
pRelDet.setString( 5, remark );
pRelDet.addBatch();
//updCnt = pRelDet.executeUpdate();
pRelDet.clearParameters();
if( updCnt > 0 )
{
System.out.println( updCnt + " INV_HOLD_REL_DET rows updated successfully" );
}
}
pRelDet.executeBatch();
pRelDet.clearBatch();
if("Y".equalsIgnoreCase(autoConfirmed))
{
sql = "update inv_hold set confirmed = 'Y', conf_date = ? where tran_id = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setTimestamp(1,currDate);
pstmt.setString(2,tranId);
int rowcnt = pstmt.executeUpdate();
if(rowcnt == 0)
{
errString = itmDBAccessLocal.getErrorString("","VTMCONF9","");
return errString;
}
else
{
System.out.println("inv_hold transaction confirm succesfully........");
}
pstmt.close();
pstmt = null;
}
}
if(pRelHdr != null)
{
pRelHdr.close();
pRelHdr = null;
}
if(pRelDet != null)
{
pRelDet.close();
pRelDet = null;
}
}
catch (Exception e)
{
System.out.println("Exception :InvHoldRelGenEJB :process(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":");
errString = e.getMessage();
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if(conn != null)
{
conn.close();
conn = null;
}
}
catch(Exception ex)
{
ex.printStackTrace();
}
}
return retStr;
}
private String generateTranId( String windowName, String siteCode, String tranDateStr, Connection conn )throws ITMException
{
PreparedStatement pstmt = null;
ResultSet rs = null;
String selSql = "";
String tranId = "";
String tranSer = "";
String keyString = "";
String keyCol = "";
String xmlValues = "";
String paySiteCode = "";
String effectiveDate = "";
java.sql.Date effDate = null;
try
{
System.out.println("generateTranId() called");
selSql = "SELECT KEY_STRING, TRAN_ID_COL, REF_SER FROM TRANSETUP WHERE TRAN_WINDOW = ? ";
//System.out.println("selSql :"+selSql);
pstmt = conn.prepareStatement(selSql);
pstmt.setString( 1, windowName );
rs = pstmt.executeQuery();
if (rs.next())
{
keyString = rs.getString("KEY_STRING");
keyCol = rs.getString("TRAN_ID_COL");
tranSer = rs.getString("REF_SER");
}
rs.close();rs = null;
pstmt.close();pstmt = null;
System.out.println("keyString :"+keyString);
System.out.println("keyCol :"+keyCol);
System.out.println("tranSer :"+tranSer);
xmlValues ="<?xml version=\"1.0\" encoding=\"utf-8\"?><Root>";
xmlValues = xmlValues + "<Header></Header>";
xmlValues = xmlValues + "<Detail1>";
xmlValues = xmlValues + "<tran_id></tran_id>";
xmlValues = xmlValues + "<site_code>" + siteCode + "</site_code>";
xmlValues = xmlValues + "<tran_date>" + tranDateStr + "</tran_date>";
xmlValues = xmlValues + "</Detail1></Root>";
System.out.println("xmlValues :["+xmlValues+"]");
TransIDGenerator tg = new TransIDGenerator(xmlValues, "BASE", CommonConstants.DB_NAME);
tranId = tg.generateTranSeqID(tranSer, keyCol, keyString, conn);
System.out.println("tranId :"+tranId);
}
catch (SQLException ex)
{
System.out.println("Exception ::" +selSql+ ex.getMessage() + ":");
ex.printStackTrace();
throw new ITMException(ex);
}
catch (Exception e)
{
System.out.println("Exception ::" + e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
}
catch(Exception e)
{
//errString = e.getMessage();
e.printStackTrace();
throw new ITMException(e);
}
}
return tranId;
}
}
package ibase.webitm.ejb.dis;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import org.w3c.dom.*;
import ibase.webitm.utility.ITMException;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface InvHoldRelGenLocal extends ibase.webitm.ejb.ProcessLocal
{
@Override
public String process() throws RemoteException,ITMException;
@Override
public String process(Document dom, Document dom2, String windowName, String xtraParams) throws RemoteException,ITMException;
@Override
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException;
@Override
public String getData(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException;
@Override
public String getData(Document dom, Document dom2, String windowNamem, String xtraParams) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.dis;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import org.w3c.dom.*;
import ibase.webitm.utility.ITMException;
import javax.ejb.Remote; // added for ejb3
@Remote // added for ejb3
public interface InvHoldRelGenRemote extends ibase.webitm.ejb.ProcessRemote
{
@Override
public String process() throws RemoteException,ITMException;
@Override
public String process(Document dom, Document dom2, String windowName, String xtraParams) throws RemoteException,ITMException;
@Override
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException;
@Override
public String getData(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException;
@Override
public String getData(Document dom, Document dom2, String windowNamem, String xtraParams) throws RemoteException,ITMException;
}
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