Commit 83fc0c88 authored by cpatil's avatar cpatil

for qc transfer migration


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@93826 ce508802-f39f-4f6c-b175-0d175dae99d5
parent b28713d3
package ibase.webitm.ejb.mfg;
import java.rmi.RemoteException;
import ibase.system.config.ConnDriver;
import ibase.webitm.ejb.*;
import ibase.webitm.ejb.dis.StockUpdate;
import ibase.webitm.ejb.sys.CreateRCPXML;
import org.w3c.dom.*;
import java.sql.*;
import java.text.SimpleDateFormat;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException;
import javax.ejb.Stateless;
import java.util.Calendar;
import java.util.HashMap;
@Stateless
public class QCTransferConf extends ActionHandlerEJB implements
QCTransferConfLocal, QCTransferConfRemote
{
public String actionHandler() throws RemoteException, ITMException
{
return "";
}
public String actionHandler(String actionType, String xmlString,
String objContext, String xtraParams) throws RemoteException,
ITMException
{
System.out.println("item actionHandler(...) called............");
String str = "";
System.out.println("actionType---" + actionType);
System.out.println("xmlString---" + xmlString);
System.out.println("objContext---" + objContext);
System.out.println("xtraParams---" + xtraParams);
return str;
}
public String confirm(String tranId, String xtraParams, String forcedFlag)
throws RemoteException, ITMException
{
System.out.println("QCTransferConf confirm called..............");
String confirmed = "";
String sql = "";
Connection conn = null;
PreparedStatement pstmt = null;
ITMDBAccessEJB itmDBAccessEJB = null;
String errString = "",errCode="";
ResultSet rs = null;
//int recCnt = 0, cnt = 0;
ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
try
{
itmDBAccessEJB = new ITMDBAccessEJB();
ConnDriver connDriver = null;
connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
if (errString == null || errString.trim().length() == 0)
{
//if ( tranIdFr.equalsIgnoreCase(tranIdTo) )
//{
// tranId = tranIdFr;
//}
if (tranId != null && tranId.trim().length() > 0)
{
sql = " select confirmed from qc_transfer where tran_id = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if (rs.next())
{
confirmed = rs.getString(1);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if ("Y".equalsIgnoreCase(confirmed))
{
errCode = "QCTRFCONF"; //'QC Transfer Already Confirmed'
errString = itmDBAccessLocal.getErrorString("",errCode,"");
}
else
{
errCode = gbf_confirm_qctransfer(tranId,1, xtraParams,conn);
System.out.println("@@@@ gbf_confirm_qctransfer::errCode["+errCode+"]");
if( errCode != null && errCode.trim().length() > 0 )
{
errString = itmDBAccessLocal.getErrorString("",errCode,"");
}
}
}
if (errString == null || errString.trim().length() == 0)
{
errCode = "VTCONFIRM";
errString = itmDBAccessLocal.getErrorString("",errCode,"");
return errString;
}
} // end if errstrng
} catch (Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if (errString != null && errString.trim().length() > 0 && !("VTCONFIRM".equalsIgnoreCase(errCode)))
{
conn.rollback();
System.out.println("@@@@ Transaction rollback...["+errString+"]::errCode["+errCode+"]");
conn.close();
conn = null;
}
else
{
conn.commit(); // test
System.out.println("@@@@ Transaction commit....["+errString+"]::errCode["+errCode+"]");
conn.close();
conn = null;
}
}
catch (Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
}
return errString;
}
private String gbf_confirm_qctransfer(String tranId, int i, String xtraParams, Connection conn)
throws RemoteException, ITMException
{
PreparedStatement pstmt = null, pstmtSql = null;
ResultSet rs = null, rs1 = null,rs3 = null;
int cnt = 0,updCnt=0;
String retString = "", sql = "", errCode = "";
Timestamp sysDate = null, tranDate = null;
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
String confirmed="",qorderNo="",siteCode="",toLoc="",lotSl="",lotNo="",porcpNo="",fromLoc="",itemCode="";
String status="",ediOption="",dataStr = "";
double qty=0,qcQty=0,stkGrossWt=0,stkTareWt=0,stkNetWt=0,qtyPerArt=0,grossWtPerArt=0,tareWtPerArt=0,stockQty=0;
HashMap stockUpd = new HashMap();
try
{
StockUpdate stockUpdate = new StockUpdate();
System.out.println("@@@@@@@@@@@@@@@ gbf_confirm_qctransfer method called next..............");
Calendar currentDate = Calendar.getInstance();
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
String sysDateStr = sdf.format(currentDate.getTime());
System.out.println("Now the date is :=> " + sysDateStr);
sysDate= Timestamp.valueOf(genericUtility.getValidDateString(sysDateStr, genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat()) + " 00:00:00.0");
sql = " Select confirmed, qorder_no, tran_date ,site_code,loc_code__trf,quantity,lot_sl,lot_no,porcp_no," +
" loc_code,item_code" +
" from qc_transfer where tran_id = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if (rs.next())
{
confirmed = rs.getString("confirmed");
qorderNo= rs.getString("qorder_no");
tranDate= rs.getTimestamp("tran_date");
siteCode= rs.getString("site_code");
toLoc= rs.getString("loc_code__trf");
qty= rs.getDouble("quantity");
lotSl= rs.getString("lot_sl");
lotNo= rs.getString("lot_no");
porcpNo= rs.getString("porcp_no");
fromLoc= rs.getString("loc_code");
itemCode= rs.getString("item_code");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
sql = " Select status,Quantity from qc_order where qorder_no = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, qorderNo);
rs = pstmt.executeQuery();
if (rs.next())
{
cnt++;
status = rs.getString("status");
qcQty= rs.getDouble("Quantity");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if ( cnt == 0)
{
errCode = "QCTRFORD"; //'QC order is not found'
return errCode;
}
else if("C".equalsIgnoreCase(status))
{
errCode = "QCTRFORD"; //'QC order is CONFIRMED cannot Transfer Quantity'
return errCode;
}
if( errCode == null || errCode.trim().length() == 0 )
{
sql = " Select quantity from qc_order where qorder_no = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, qorderNo);
rs = pstmt.executeQuery();
if (rs.next())
{
cnt++;
qcQty= rs.getDouble("Quantity");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if(qcQty < qty )
{
errCode = "QCTRFQTY"; //'QC Transfer quantity more then QC Order Quantity'
return errCode;
}
}
if ( errCode == null || errCode.trim().length() == 0 )
{
cnt=0;
sql = " Select item_ser,mfg_date,exp_date,retest_date,site_code__mfg,potency_perc,pack_code,inv_stat," +
" unit,gross_weight,tare_weight, net_weight,pack_instr,dimension,rate,rate__oh,acct_code__inv," +
" cctr_code__inv,acct_code__oh,cctr_code__oh,supp_code__mfg,grade,gross_rate,conv__qty_stduom," +
" unit__alt,batch_no,no_art,qty_per_art,gross_wt_per_art,tare_wt_per_art,quantity " +
" from Stock" +
" Where item_code = ? and site_code = ? and loc_code = ? and lot_no = ? and lot_Sl = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, itemCode);
pstmt.setString(2, siteCode);
pstmt.setString(3, fromLoc);
pstmt.setString(4, lotNo);
pstmt.setString(5, lotSl);
rs = pstmt.executeQuery();
if (rs.next())
{
cnt++;
stockUpd.put("item_ser",rs.getString("item_ser"));
stockUpd.put("mfg_date", rs.getTimestamp("mfg_date"));
stockUpd.put("exp_date", rs.getTimestamp("exp_date"));
stockUpd.put("retest_date", rs.getTimestamp("retest_date"));
stockUpd.put("site_code__mfg", rs.getString("site_code__mfg"));
stockUpd.put("potency_perc", rs.getString("potency_perc"));
stockUpd.put("pack_code", rs.getString("pack_code"));
stockUpd.put("inv_stat", rs.getString("inv_stat"));
stockUpd.put("unit", rs.getString("unit"));
stkGrossWt = rs.getDouble("gross_weight"); //pending
stkTareWt = rs.getDouble("tare_weight"); //pending
stkNetWt = rs.getDouble("net_weight"); //pending
stockUpd.put("pack_instr", rs.getString("pack_instr"));
stockUpd.put("dimension", rs.getString("dimension"));
stockUpd.put("rate", rs.getString("rate"));
stockUpd.put("rate_oh", rs.getString("rate__oh"));
stockUpd.put("acct_code_inv", rs.getString("acct_code__inv"));
stockUpd.put("cctr_code_inv", rs.getString("cctr_code__inv"));
stockUpd.put("acct_code_oh", rs.getString("acct_code__oh"));
stockUpd.put("cctr_code_oh", rs.getString("cctr_code__oh"));
stockUpd.put("supp_code__mfg", rs.getString("supp_code__mfg"));
stockUpd.put("grade", rs.getString("grade"));
stockUpd.put("gross_rate", rs.getString("gross_rate"));
stockUpd.put("conv__qty_stduom", rs.getString("conv__qty_stduom"));
stockUpd.put("unit__alt", rs.getString("unit__alt"));
stockUpd.put("batch_no", rs.getString("batch_no"));
stockUpd.put("no_art", rs.getString("no_art"));
qtyPerArt = rs.getDouble("qty_per_art"); //pending
grossWtPerArt = rs.getDouble("gross_wt_per_art"); //pending
tareWtPerArt = rs.getDouble("tare_wt_per_art"); //pending
stockQty = rs.getDouble("quantity");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if( cnt == 0 )
{
errCode = "QCTRFSTK"; //'Item Not Found in Stock...'
System.out.println("@@@@@@@@@@@@ [QCTRFSTK]");
return errCode;
}//End if
if( errCode == null || errCode.trim().length() == 0 )
{
sql = " Select unit From item where item_code = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,itemCode);
rs = pstmt.executeQuery();
if(rs.next())
{
stockUpd.put("unit", rs.getString("unit"));
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
sql = " Select inv_stat from location Where loc_code = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,fromLoc);
rs = pstmt.executeQuery();
if(rs.next())
{
stockUpd.put("inv_stat", rs.getString("inv_stat"));
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
stockUpd.put("tran_type", "I");
stockUpd.put("tran_ser","QC-TRF" );
stockUpd.put("tranid",tranId ); //pending
stockUpd.put("item_code", itemCode);
stockUpd.put("site_code", siteCode);
stockUpd.put("loc_code", fromLoc );
stockUpd.put("lot_no",lotNo );
stockUpd.put("lot_sl",lotSl );
stockUpd.put("tran_date", tranDate);
stockUpd.put("quantity",qty );
stockUpd.put("qty_stduom",qty );
if ( qtyPerArt == 0 ) //isnull(lc_qtyperart) or lc_qtyperart = 0 then
{
qtyPerArt = 1;
}
stockUpd.put("no_art",Math.ceil(Double.parseDouble(stockUpd.get("qty_stduom").toString())/qtyPerArt));
if(stockQty != 0 )
{
stockUpd.put("net_weight",stkNetWt / stockQty * Double.parseDouble( stockUpd.get("qty_stduom").toString()));
stockUpd.put("tare_weight", tareWtPerArt * Double.parseDouble(stockUpd.get("no_art").toString()));
stockUpd.put("gross_weight", ( Double.parseDouble(stockUpd.get("net_weight").toString()) + Double.parseDouble(stockUpd.get("tare_weight").toString())) );
}//end if
// ls_errcode = nvo_dis.gbf_update_stock(lstr_stkupd)
errCode = stockUpdate.updateStock(stockUpd,xtraParams, conn);
if(errCode !=null && errCode.trim().length() >0) //if(retString !=null && retString.trim().length() >0)
{
return errCode;
}
}//end if
if( errCode == null || errCode.trim().length() == 0 )
{
sql = " Select inv_stat from location Where loc_code = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,toLoc);
rs = pstmt.executeQuery();
if(rs.next())
{
stockUpd.put("inv_stat", rs.getString("inv_stat"));
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
stockUpd.put("tran_type", "R");
stockUpd.put("loc_code", toLoc );
if ( qtyPerArt == 0 )
{
qtyPerArt = 1;
}
stockUpd.put("no_art", Math.ceil( Double.parseDouble(stockUpd.get("qty_stduom").toString()) / qtyPerArt));
if ( stockQty != 0 )
{
stockUpd.put("net_weight",stkNetWt / stockQty * Double.parseDouble(stockUpd.get("qty_stduom").toString()));
stockUpd.put("tare_weight", tareWtPerArt * Double.parseDouble(stockUpd.get("no_art").toString()));
stockUpd.put("gross_weight", ( Double.parseDouble(stockUpd.get("net_weight").toString()) + Double.parseDouble(stockUpd.get("tare_weight").toString())));
}//end if
//ls_errcode = nvo_dis.gbf_update_stock(lstr_stkupd)
errCode = stockUpdate.updateStock(stockUpd,xtraParams, conn);
if(errCode !=null && errCode.trim().length() >0) //if(retString !=null && retString.trim().length() >0)
{
return errCode;
}
} //End if
} //End if
if (errCode == null || errCode.trim().length() == 0 )
{ //if gs_run_mode = 'I' then
if ( qcQty > qty )
{
sql = " Update qc_order set quantity = (quantity - ? ) where qorder_no = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setDouble(1, qty);
pstmt.setString(2, qorderNo);
updCnt = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
}
else
{
sql = " Update qc_order set quantity = (quantity - ? ), status = 'C' where qorder_no = ? " ;
pstmt = conn.prepareStatement(sql);
pstmt.setDouble(1, qty);
pstmt.setString(2, qorderNo);
updCnt = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
} //end if
if (updCnt == 0) // get_sqlcode() <> 0 then
{
errCode = "QCTRFUPDT"; //'Unable to confirm QC Transfer ' + sqlca.sqlerrtext
return errCode;
} //End if
// Update to qc_order_lot table if it QC is split into to different lots
if( errCode == null || errCode.trim().length() == 0 )
{
sql = " update qc_order_lots set quantity = (quantity - ? ) " +
" where qc_order = ? and lot_no = ? and lot_sl = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setDouble(1, qty);
pstmt.setString(2, qorderNo);
pstmt.setString(3, lotNo);
pstmt.setString(4, lotSl);
updCnt = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
if( updCnt == 0 )
{
errCode = "QCTRFUPDT"; //'Unable to confirm QC Transfer ' + sqlca.sqlerrtext
return errCode;
}//End if
} //end if
// update po receipt as accept on external approval
if(( errCode == null || errCode.trim().length() == 0 ) && ( porcpNo != null && porcpNo.trim().length() == 0 ))
{
sql = " select count(1) from porcp where tran_id = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,porcpNo);
rs = pstmt.executeQuery();
if(rs.next())
{
cnt = rs.getInt(1);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if( cnt==1 ) // ll_count = 1 then
{
sql = " update porcp set ACCEPT_CRITERIA = 'E' where tran_id = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, qorderNo);
updCnt = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
if( updCnt == 0 ) // get_sqlcode() <> 0 then
{
System.out.println("@@@@@@@@@@@@ no record");
}//end if
} //end if
} //end if
if( errCode == null || errCode.trim().length() == 0 )
{
sql = " Update qc_transfer Set confirmed = 'Y', conf_date = ? Where tran_id = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setTimestamp(1, sysDate );
pstmt.setString(2, tranId);
updCnt = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
/////
if( updCnt == 0 ) //get_sqlcode() <> 0 then
{
errCode = "QCTRFUPDT"; //'Unable to confirm QC Transfer ' + sqlca.sqlerrtext
return errCode;
}//End if
} //end if
sql = "select edi_option from transetup where tran_window = 'w_qc_transfer' ";
pstmtSql = conn.prepareStatement(sql);
rs = pstmtSql.executeQuery();
if (rs.next()) {
ediOption = rs.getString("EDI_OPTION");
}
rs.close();
rs = null;
pstmtSql.close();
pstmtSql = null;
System.out.println("@@@@@@@@@@@@@@@ ediOption called next..............");
if ("2".equals(ediOption))
{
CreateRCPXML createRCPXML = new CreateRCPXML("w_qc_transfer","tran_id");
dataStr = createRCPXML.getTranXML(tranId, conn);
System.out.println("dataStr =[ " + dataStr + "]");
Document ediDataDom = genericUtility.parseString(dataStr);
E12CreateBatchLoadEjb e12CreateBatchLoad = new E12CreateBatchLoadEjb();
retString = e12CreateBatchLoad.createBatchLoad(ediDataDom,
"w_qc_transfer", "2", xtraParams, conn);
createRCPXML = null;
e12CreateBatchLoad = null;
if (retString != null && "SUCCESS".equals(retString))
{
System.out.println("retString from batchload = ["
+ retString + "]");
}
}
else {
CreateRCPXML createRCPXML = new CreateRCPXML("w_qc_transfer","tran_id");
dataStr = createRCPXML.getTranXML(tranId, conn);
System.out.println("dataStr =[ " + dataStr + "]");
Document ediDataDom = genericUtility.parseString(dataStr);
E12CreateBatchLoadEjb e12CreateBatchLoad = new E12CreateBatchLoadEjb();
retString = e12CreateBatchLoad.createBatchLoad(ediDataDom,"w_qc_transfer", ediOption, xtraParams, conn);
createRCPXML = null;
e12CreateBatchLoad = null;
if (retString != null && "SUCCESS".equals(retString))
{
System.out.println("retString from batchload = ["+ retString + "]");
}
}
System.out.println("@@@@@@@@@@@@@@@ ediOption called end..............");
} //End if
} // end try
catch (Exception e)
{
e.printStackTrace();
System.out.println("Exception ::" + e.getMessage());
throw new ITMException(e);
}
return errCode;
}
/*
private String checkNull(String string)
{
if (string == null)
{
string = "";
}
return string;
}
*/
}
\ No newline at end of file
package ibase.webitm.ejb.mfg;
import java.rmi.RemoteException;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.ITMException;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface QCTransferConfLocal extends ActionHandlerLocal
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException,ITMException;
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.mfg;
import java.rmi.RemoteException;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.ITMException;
import javax.ejb.Remote; // added for ejb3
@Remote // added for ejb3
public interface QCTransferConfRemote extends ActionHandlerRemote
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException,ITMException;
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.mfg;
import ibase.system.config.ConnDriver;
import ibase.webitm.ejb.ValidatorEJB;
//import ibase.webitm.ejb.fin.FinCommon;
//import ibase.webitm.ejb.mfg.MfgCommon;
//import ibase.webitm.ejb.mfg.WorkOrderAmd;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException;
import java.text.SimpleDateFormat;
import java.util.*;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.w3c.dom.Document;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import javax.ejb.Stateless;
import java.sql.Timestamp;
@Stateless
public class QCTransferIC extends ValidatorEJB implements QCTransferICLocal, QCTransferICRemote
{
GenericUtility genericUtility = GenericUtility.getInstance();
//method for validation
public String wfValData(String xmlString, String xmlString1, String xmlString2, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException
{
String errString = "";
System.out.println("wfValdata() called for QCTransferIC");
Document dom = null;
Document dom1 = null;
Document dom2 = null;
try
{
if (xmlString != null && xmlString.trim().length() > 0 )
{
dom = parseString(xmlString);
}
if (xmlString1 != null && xmlString1.trim().length() > 0 )
{
dom1 = parseString(xmlString1);
}
if (xmlString2 != null && xmlString2.trim().length() > 0 )
{
dom2 = parseString(xmlString2);
}
errString = wfValData(dom, dom1, dom2, objContext, editFlag, xtraParams);
}
catch(Exception e)
{
throw new ITMException(e);
}
return(errString);
}
public String wfValData(Document dom, Document dom1, Document dom2, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException
{
String childNodeName = null;
String errString = "";
String errCode = "";
String userId = "";
String sql = "";
String errorType = "";
int cnt = 0;
int ctr=0;
int childNodeListLength;
NodeList parentNodeList = null;
NodeList childNodeList = null;
Node parentNode = null;
Node childNode = null;
ArrayList<String> errList = new ArrayList<String>();
ArrayList<String> errFields = new ArrayList<String>();
Connection conn = null;
PreparedStatement pstmt = null ;
ResultSet rs = null;
ConnDriver connDriver = new ConnDriver();
StringBuffer errStringXml = new StringBuffer("<?xml version = \"1.0\"?> \r\n <Root> <Errors>");
int currentFormNo =0,recCnt=0;
int noOfParent=0,ctr1=0;
double maxQty=0,minQty = 0 ;
String tranDateStr="",qorderNo="",refNo="",tranId="",itemCode="",locCode="",lotNo="",lotSl="",siteCode="";
String status="",porcpNo="",porcpLineNo="",qcLocCode="",minQtyStr="",available="",keyFlag="";
Timestamp date2=null,tranDate=null ;
try
{
System.out.println("@@@@@@@@ wfvaldata called");
conn = connDriver.getConnectDB("DriverITM");
connDriver = null;
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("tran_id"))
{
tranId = checkNull(genericUtility.getColumnValue("tran_id", dom));
System.out.println("@@@@ tran_id validation ");
keyFlag = setDescription("key_flag", "transetup", "tran_window", "w_qc_transfer", conn);
System.out.println("@@@@ tran_id ["+tranId+"]:::::keyFlag["+keyFlag+"]");
if( tranId != null && tranId.length() > 0 && "M".equalsIgnoreCase(keyFlag))
{
sql = " Select count(1) from qc_transfer where tran_id = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,tranId);
rs = pstmt.executeQuery();
if(rs.next())
{
cnt = rs.getInt(1);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("@@@@ cnt["+cnt+"]");
if( cnt > 0 )
{
errCode = "VMTRANIDEX";
errList.add(errCode);
errFields.add(childNodeName.toLowerCase());
}
}
}
if(childNodeName.equalsIgnoreCase("tran_date"))
{
tranDateStr = checkNull(genericUtility.getColumnValue("tran_date", dom));
qorderNo = checkNull(genericUtility.getColumnValue("qorder_no", dom));
System.out.println("@@@@ tranDate ["+tranDateStr+"]:::qorderNo["+qorderNo+"]");
if( qorderNo != null && qorderNo.length() > 0 )
{
sql = " Select qorder_date from qc_order" +
" where qorder_no = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,qorderNo);
rs = pstmt.executeQuery();
if(rs.next())
{
date2 = rs.getTimestamp("qorder_date");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if( tranDateStr != null && tranDateStr.length() > 0 )
{
tranDate= Timestamp.valueOf(genericUtility.getValidDateString(tranDateStr, genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat()) + " 00:00:00.0");
}
System.out.println("@@@@ tranDate ["+tranDate+"]:::qorder_date["+date2+"]");
if( tranDate.before(date2))
{
errCode = "QCTRFDATE";
//ls_errcode = 'QCTRFDATE~t' + 'QC Transfer Date cannot be less then QC Order Date'
errList.add(errCode);
errFields.add(childNodeName.toLowerCase());
}
}
}
if(childNodeName.equalsIgnoreCase("qorder_no"))
{
cnt = 0;
tranId = checkNull(genericUtility.getColumnValue("tran_id", dom));
qorderNo = checkNull(genericUtility.getColumnValue("qorder_no", dom));
itemCode = checkNull( genericUtility.getColumnValue("item_code", dom));
locCode = checkNull( genericUtility.getColumnValue("loc_code", dom));
lotNo = checkNull( genericUtility.getColumnValue("lot_no", dom));
lotSl = checkNull( genericUtility.getColumnValue("lot_sl", dom));
siteCode = checkNull( genericUtility.getColumnValue("site_code", dom));
if ( qorderNo == null )
{
qorderNo = " ";
}
if ( lotNo == null )
{
lotNo = " ";
}
if ( locCode == null )
{
locCode = " ";
}
sql = " Select count(1) from qc_order " +
" Where qorder_no <> ? " +
" and site_code = ? " +
" and item_code = ? " +
" and lot_no = ? " +
" and loc_code = ? " +
" and status = 'U' ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,qorderNo);
pstmt.setString(2,siteCode);
pstmt.setString(3,itemCode);
pstmt.setString(4,lotNo);
pstmt.setString(5,locCode);
rs = pstmt.executeQuery();
if(rs.next())
{
cnt = rs.getInt(1);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("@@@@@@@@9 cnt["+cnt+"]:::tranId["+tranId+"]");
if( cnt > 0 )
{
errCode = "VTINVQN1";
errList.add(errCode);
errFields.add(childNodeName.toLowerCase());
}
System.out.println("@@@@@@@@ tranId["+tranId+"]");
if ( tranId == null )
{
tranId = " ";
}
sql = " Select count(1) from qc_transfer " +
" Where qorder_no = ? and confirmed = 'N' and tran_id <> ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,qorderNo);
pstmt.setString(2,tranId);
rs = pstmt.executeQuery();
if(rs.next())
{
cnt = rs.getInt(1);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("@@@@@@@@8 cnt["+cnt+"]");
if( cnt > 0 )
{
System.out.println("@@@@@@@@@111QCTRFUCONF:cnt["+cnt+"]");
errCode = "QCTRFUCONF";
errList.add(errCode);
errFields.add(childNodeName.toLowerCase());
}
// if gs_runmode <> 'B' then
if( errCode== null || errCode.trim().length() == 0 )
{
cnt=0;
sql = " Select status , porcp_no, porcp_line_no from qc_order " +
" where qorder_no = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,qorderNo);
rs = pstmt.executeQuery();
if(rs.next())
{
cnt++;
status = rs.getString("status");
porcpNo = rs.getString("porcp_no");
porcpLineNo = rs.getString("porcp_line_no");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if ( cnt == 0 )
{
// ls_errcode = 'QCTRFORD~t' + 'QC order is not found';
errCode = "QCTRFORD";
errList.add(errCode);
errFields.add(childNodeName.toLowerCase());
}
else if("C".equalsIgnoreCase(status))
{
errCode = "QCTRF0001";
errList.add(errCode);
errFields.add(childNodeName.toLowerCase());
// ls_errcode = 'QCTRF0001~t' + 'QC order is Confirmed. You cannot do transfer for QC order no: ' + ls_qorder_no
}
}
if ( errCode== null || errCode.trim().length() == 0 )
{
refNo = checkNull(genericUtility.getColumnValue("porcp_no", dom));
if (( lotSl != null && lotSl.trim().length() > 0 ) && (refNo != null && refNo.trim().length()>0))
{
// ls_errcode = gf_chk_pck_dtl(ls_sitecode,ls_itemcode,ls_loc,ls_lotno,ls_qorderno,ls_ref_no,ls_lot_sl)
errCode = gf_chk_pck_dtl(siteCode,itemCode,locCode,lotNo,qorderNo,refNo,lotSl,conn);
if( errCode != null && errCode.trim().length() > 0 )
{
System.out.println("@@@@@ errCode["+errCode+"]");
errList.add(errCode);
errFields.add(childNodeName.toLowerCase());
}
}
}
}
if(childNodeName.equalsIgnoreCase("lot_sl"))
{
porcpNo = checkNull(genericUtility.getColumnValue("porcp_no", dom));
itemCode = checkNull( genericUtility.getColumnValue("item_code", dom));
siteCode = checkNull( genericUtility.getColumnValue("site_code", dom));
qcLocCode = genericUtility.getColumnValue("loc_code", dom);
lotNo = genericUtility.getColumnValue("lot_no", dom);
lotSl = genericUtility.getColumnValue("lot_sl", dom);
if( lotSl == null || lotSl.trim().length() == 0 )
{
errCode = "QCTRFLOTSL"; //'Invalid Lot Sl Please enter Lot Sl'
errList.add(errCode);
errFields.add(childNodeName.toLowerCase());
}
if( errCode.length() == 0 )
{
sql = " Select Quantity from stock" +
" Where item_code = ? and site_code = ? " +
" and loc_code = ? and lot_no = ? " +
" and lot_sl = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,itemCode);
pstmt.setString(2,siteCode);
pstmt.setString(3,qcLocCode);
pstmt.setString(4,lotNo);
pstmt.setString(5,lotSl);
rs = pstmt.executeQuery();
if(rs.next())
{
maxQty = rs.getDouble("Quantity");
cnt++;
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
//If isnull(lc_maxqty) then lc_maxqty = 0
if ( cnt == 0)
{
errCode = "VTQTY51";
errList.add(errCode);
errFields.add(childNodeName.toLowerCase());
}
}
}
if( childNodeName.equalsIgnoreCase("quantity"))
{
itemCode = checkNull( genericUtility.getColumnValue("item_code", dom));
siteCode = checkNull( genericUtility.getColumnValue("site_code", dom));
qcLocCode = genericUtility.getColumnValue("loc_code", dom);
lotNo = genericUtility.getColumnValue("lot_no", dom);
lotSl = genericUtility.getColumnValue("lot_sl", dom);
sql = " Select Quantity from stock" +
" Where item_code = ? and site_code = ? " +
" and loc_code = ? and lot_no = ? " +
" and lot_sl = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,itemCode);
pstmt.setString(2,siteCode);
pstmt.setString(3,qcLocCode);
pstmt.setString(4,lotNo);
pstmt.setString(5,lotSl);
rs = pstmt.executeQuery();
if(rs.next())
{
maxQty = rs.getDouble("quantity");
cnt++;
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if ( cnt == 0)
{
errCode = "VTQTY51";
errList.add(errCode);
errFields.add(childNodeName.toLowerCase());
}
//If isnull(lc_maxqty) then lc_maxqty = 0
if( errCode == null || errCode.trim().length() == 0 )
{
minQtyStr = genericUtility.getColumnValue("quantity", dom);
minQty = minQtyStr==null ? 0:Double.parseDouble(minQtyStr);
if( minQty > maxQty )
{
errCode = "QCTRFQTY"; // 'QC Transfer Quantity cannot be more then Stock Quantity ' + string(lc_maxqty)
errList.add(errCode);
errFields.add(childNodeName.toLowerCase());
}
}
}
if(childNodeName.equalsIgnoreCase("loc_code__trf"))
{
qcLocCode = genericUtility.getColumnValue("loc_code", dom);
locCode = genericUtility.getColumnValue("loc_code__trf", dom);
if( locCode != null)
{
sql = " Select Available from location a, invstat b " +
" Where a.loc_code = ? and a.inv_stat = b.inv_stat ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,locCode);
rs = pstmt.executeQuery();
if(rs.next())
{
available = rs.getString("available");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
}
if(!("N".equalsIgnoreCase(available)))
{
errCode = "QCTRFLOC"; //"Invalid location, location should not be usable"
errList.add(errCode);
errFields.add(childNodeName.toLowerCase());
}
if( errCode == null || errCode.trim().length()==0 )
{
if( qcLocCode.trim().equalsIgnoreCase(locCode.trim()))
{
errCode = "QCTRFLOC"; //'From and To Location Should be different'
errList.add(errCode);
errFields.add(childNodeName.toLowerCase());
}
}
}
} // end for
break; // case 1 end
}
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 = getErrorString(errFldName, errCode, userId);
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);
errString = "";
}
if(errorType.equalsIgnoreCase("E"))
{
break;
}
}
errList.clear();
errList = null;
errFields.clear();
errFields = null;
errStringXml.append("</Errors> </Root> \r\n");
}
else
{
errStringXml = new StringBuffer("");
}
}
catch(Exception e)
{
e.printStackTrace();
errString = e.getMessage();
throw new ITMException(e);
}
finally
{
try
{
if(conn != null)
{
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
conn.close();
}
conn = null;
}
catch(Exception d)
{
d.printStackTrace();
throw new ITMException(d);
}
}
errString = errStringXml.toString();
return errString;
}//end of validation
private String gf_chk_pck_dtl(String siteCode, String itemCode,
String locCode, String lotNo, String qorderNo, String refNo,
String lotSl,Connection conn) throws SQLException
{
String sql = "",errCode="";
PreparedStatement pstmt = null;
ResultSet rs = null ;
int cnt=0;
String conf="";
double noArt=0;
sql = " select no_art from stock " +
" where item_code = ? and site_code = ? and loc_code = ? " +
" and lot_no = ? and lot_sl = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,itemCode);
pstmt.setString(2,siteCode);
pstmt.setString(3,locCode);
pstmt.setString(4,lotNo);
pstmt.setString(5,lotSl);
rs = pstmt.executeQuery();
if(rs.next())
{
noArt = rs.getInt("no_art");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("@@@@@@ noArt["+noArt+"]");
if ( noArt > 1 )
{
sql = " select confirmed from inv_pack_rcp,inv_pack " +
" where inv_pack_rcp.tran_id = inv_pack.tran_id " +
" and inv_pack_rcp.order_no = inv_pack.order_no " +
" and inv_pack_rcp.order_no = ? " +
" and inv_pack_rcp.item_code = ? " +
" and inv_pack_rcp.loc_code = ? " +
" and inv_pack_rcp.lot_no = ? " +
" and inv_pack_rcp.lot_sl = ? " +
" and case when inv_pack.status is null then 'U' else inv_pack.status end <> 'X' ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,refNo);
pstmt.setString(2,itemCode);
pstmt.setString(3,locCode);
pstmt.setString(4,lotNo);
pstmt.setString(5,lotSl);
rs = pstmt.executeQuery();
if(rs.next())
{
cnt++;
conf = rs.getString("confirmed");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("@@@@@@ cnt["+cnt+"]::::conf:["+conf+"]");
if( cnt == 0 )
{
errCode = "VTNOPCKLST";
return errCode;
}
if(!("Y".equalsIgnoreCase(conf) ))
{
errCode = "VTPKNOCF";
return errCode;
}
}
return errCode;
}
// method for item change
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;
System.out.println("itemChanged() called for QCTransferIC");
String valueXmlString = "";
try
{
if(xmlString != null && xmlString.trim().length() > 0)
{
dom = parseString(xmlString);
}
if(xmlString1 != null && xmlString1.trim().length() > 0)
{
dom1 = parseString(xmlString1);
}
if(xmlString2 != null && xmlString2.trim().length() > 0)
{
dom2 = parseString(xmlString2);
}
valueXmlString = itemChanged(dom, dom1, dom2, objContext, currentColumn, editFlag, xtraParams);
}
catch(Exception e)
{
System.out.println("Exception : [QCTransferIC][itemChanged( String, String )] :==>\n" + e.getMessage());
}
return valueXmlString;
}
// method for item change
public String itemChanged(Document dom, Document dom1, Document dom2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException, ITMException
{
String childNodeName = null;
String sql = "";
StringBuffer valueXmlString = new StringBuffer();
int ctr = 0;
NodeList parentNodeList = null;
NodeList childNodeList = null;
Node parentNode = null;
Node childNode = null;
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null ;
GenericUtility genericUtility = GenericUtility.getInstance();
ConnDriver connDriver = new ConnDriver();
int currentFormNo =0;
String columnValue="",itemCode="",itemDescr="";
String siteDescr="",qorderNo="",loginSiteCode="",locCode="",porcpNo="",lotSl="",batchNo="",siteCode="",lotNo="";
String locDescr="",locCodeTrf="";
double quantity=0;
try
{
Calendar currentDate = Calendar.getInstance();
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
String sysDate = sdf.format(currentDate.getTime());
System.out.println("Now the date is :=> " + sysDate);
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
connDriver = null;
if(objContext != null && objContext.trim().length()>0)
{
currentFormNo = Integer.parseInt(objContext.trim());
}
valueXmlString = new StringBuffer("<?xml version = \"1.0\"?> <Root> <header> <editFlag>");
valueXmlString.append(editFlag).append("</editFlag> </header>");
System.out.println("**********ITEMCHANGE FOR CASE"+currentFormNo+"**************");
switch(currentFormNo)
{
case 1 :
parentNodeList = dom.getElementsByTagName("Detail1");
parentNode = parentNodeList.item(0);
childNodeList = parentNode.getChildNodes();
ctr = 0;
valueXmlString.append("<Detail1>");
int childNodeListLength = childNodeList.getLength();
do
{
childNode = childNodeList.item(ctr);
childNodeName = childNode.getNodeName();
if(childNodeName.equals(currentColumn))
{
if (childNode.getFirstChild()!= null)
{
columnValue = childNode.getFirstChild().getNodeValue().trim();
}
}
ctr++;
}
while(ctr < childNodeListLength && !childNodeName.equals(currentColumn));
System.out.println("[" + currentColumn + "] ==> '" + columnValue + "'");
if(currentColumn.trim().equalsIgnoreCase("itm_default"))
{
System.out.println("@@@@@@@@ itm_default called @@@@@@@@");
loginSiteCode = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginSiteCode" );
System.out.println("@@@@@@@@loginSiteCode["+loginSiteCode+"]");
valueXmlString.append("<tran_date>").append("<![CDATA["+sysDate+"]]>").append("</tran_date>");
valueXmlString.append("<site_code>").append("<![CDATA["+loginSiteCode+"]]>").append("</site_code>");
siteDescr = setDescription("descr","site","site_code", loginSiteCode, conn);
valueXmlString.append("<site_descr>").append("<![CDATA["+siteDescr+"]]>").append("</site_descr>");
}
else if(currentColumn.trim().equalsIgnoreCase("qorder_no"))
{
System.out.println("@@@@@@@@ qorder_no called @@@@@@@@");
qorderNo = checkNull(genericUtility.getColumnValue("qorder_no", dom));
sql = " Select quantity, item_code, loc_code, porcp_no, lot_no, lot_sl, batch_no, site_code" +
" from qc_order where qorder_no = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, qorderNo);
rs = pstmt.executeQuery();
if(rs.next())
{
quantity = rs.getDouble("quantity");
itemCode = checkNull( rs.getString("item_code"));
locCode = checkNull( rs.getString("loc_code"));
porcpNo = checkNull( rs.getString("porcp_no"));
lotNo = checkNull( rs.getString("lot_no"));
lotSl = checkNull( rs.getString("lot_sl"));
batchNo = checkNull( rs.getString("batch_no"));
siteCode = checkNull( rs.getString("site_code"));
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
valueXmlString.append("<quantity__o>").append("<![CDATA["+quantity+"]]>").append("</quantity__o>");
valueXmlString.append("<item_code>").append("<![CDATA["+itemCode+"]]>").append("</item_code>");
valueXmlString.append("<loc_code>").append("<![CDATA["+locCode+"]]>").append("</loc_code>");
valueXmlString.append("<porcp_no>").append("<![CDATA["+porcpNo+"]]>").append("</porcp_no>");
valueXmlString.append("<lot_no>").append("<![CDATA["+lotNo+"]]>").append("</lot_no>");
valueXmlString.append("<lot_sl>").append("<![CDATA["+lotSl+"]]>").append("</lot_sl>");
valueXmlString.append("<site_code>").append("<![CDATA["+siteCode+"]]>").append("</site_code>");
valueXmlString.append("<batch_no>").append("<![CDATA["+batchNo+"]]>").append("</batch_no>");
if( locCode != null && locCode.trim().length() > 0 )
{
locDescr = setDescription("descr","location","loc_code", locCode, conn);
valueXmlString.append("<location_descr>").append("<![CDATA["+locDescr+"]]>").append("</location_descr>");
}
if( itemCode != null && itemCode.trim().length() > 0 )
{
itemDescr = setDescription("descr","item","item_Code", itemCode, conn);
valueXmlString.append("<item_descr>").append("<![CDATA["+itemDescr+"]]>").append("</item_descr>");
}
}
else if(currentColumn.trim().equalsIgnoreCase("lot_sl"))
{
System.out.println("@@@@@@@@ lot_sl called @@@@@@@@");
qorderNo = checkNull(genericUtility.getColumnValue("qorder_no", dom));
if( qorderNo != null && qorderNo.trim().length() > 0 )
{
locCode = setDescription("loc_code","qc_order","qorder_no", qorderNo, conn);
}
if ( locCode == null || locCode.trim().length() > 0 )
{
lotSl = genericUtility.getColumnValue("lot_sl", dom);
lotNo = genericUtility.getColumnValue("lot_no", dom);
siteCode = checkNull(genericUtility.getColumnValue("site_code", dom));
itemCode = checkNull(genericUtility.getColumnValue("item_code", dom));
sql = " select loc_code from stock " +
" where item_code = ? and lot_no = ? and lot_sl = ? and site_code = ? and quantity > 0 ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, itemCode);
pstmt.setString(2, lotNo);
pstmt.setString(3, lotSl);
pstmt.setString(4, siteCode);
rs = pstmt.executeQuery();
if(rs.next())
{
locCode = checkNull( rs.getString("loc_code"));
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if( locCode != null && locCode.trim().length() > 0 )
{
valueXmlString.append("<loc_code>").append("<![CDATA["+locCode+"]]>").append("</loc_code>");
}
}
}
else if(currentColumn.trim().equalsIgnoreCase("loc_code__trf"))
{
System.out.println("@@@@@@@@ loc_code__trf called @@@@@@@@");
locCodeTrf = checkNull(genericUtility.getColumnValue("loc_code__trf", dom));
if ( locCodeTrf.trim().length() < 8 )
{
locCodeTrf = locCodeTrf + " ";
locCodeTrf = locCodeTrf.substring(0, 8);
}
locDescr = setDescription("descr", "location", "loc_code", locCodeTrf , conn);
valueXmlString.append("<location_transfer>").append("<![CDATA["+locDescr+"]]>").append("</location_transfer>");
}
valueXmlString.append("</Detail1>");
break;
} // case 1 end
valueXmlString.append("</Root>");
}
catch(Exception e)
{
e.printStackTrace();
System.out.println("Exception ::"+ e.getMessage());
throw new ITMException(e);
}
finally
{
try
{
if(conn != null)
{
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
conn.close();
}
conn = null;
}
catch(Exception d)
{
d.printStackTrace();
}
}
return valueXmlString.toString();
}
private String setDescription(String descrCol, String table,String field, String value,Connection conn) throws SQLException
{
PreparedStatement pstmt = null;
ResultSet rs = null ;
String sql="",descr="";
System.out.println("@@@@@@@@table["+table+"]:::field["+field+"]::value["+value+"]");
sql = "select "+ descrCol +" from "+ table +" where " + field + " = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, value);
rs = pstmt.executeQuery();
if(rs.next())
{
descr = checkNull( rs.getString(1));
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.print("========>::descr["+descr+"]");
return descr;
}
private String checkNull(String input)
{
if(input == null)
{
input = "";
}
return input;
}
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 = checkNull( rs.getString("MSG_TYPE"));
}
}
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;
}
}
package ibase.webitm.ejb.mfg;
import java.rmi.RemoteException;
import org.w3c.dom.*;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.ITMException;
import javax.ejb.Local;
@Local
public interface QCTransferICLocal extends ValidatorLocal
{
public String wfValData(String xmlString, String xmlString1, String xmlString2, 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;
public String itemChanged(String xmlString, String xmlString1, String xmlString2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException;
public String itemChanged(Document dom, Document dom1, Document dom2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.mfg;
import java.rmi.RemoteException;
import org.w3c.dom.*;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.ITMException;
import javax.ejb.Remote;
@Remote
public interface QCTransferICRemote extends ValidatorRemote
{
public String wfValData(String xmlString, String xmlString1, String xmlString2, 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;
public String itemChanged(String xmlString, String xmlString1, String xmlString2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException;
public String itemChanged(Document dom, Document dom1, Document dom2, String objContext, String currentColumn, String editFlag, 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