Skip to content

B
business-java
Commit 244e7cf7 authored by jshinde's avatar jshinde
Browse files
Options

Request ID:W15HSUN003 ,pallet request with stock details . 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@99431 ce508802-f39f-4f6c-b175-0d175dae99d5
parent e57e33b2
Hide whitespace changes
Inline Side-by-side
Showing with 549 additions and 463 deletions
webitm-wms/ibase/webitm/ejb/wms/PalletReqConf.java
View file @ 244e7cf7
/**
* Purpose:Create transaction screen Pallet Request, Request ID: W15GSUN001
*/
package ibase.webitm.ejb.wms; package ibase.webitm.ejb.wms;
import ibase.utility.CommonConstants; import ibase.system.config.ConnDriver;
import ibase.webitm.utility.*; import ibase.webitm.ejb.ActionHandlerEJB;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.wms.CommonWmsUtil; import ibase.webitm.utility.wms.CommonWmsUtil;
import ibase.system.config.*; import java.io.PrintStream;
import ibase.webitm.ejb.*;
import java.rmi.RemoteException; import java.rmi.RemoteException;
import java.util.*; import java.sql.Connection;
import java.util.Date; import java.sql.PreparedStatement;
import java.text.*; import java.sql.ResultSet;
import java.sql.*; import java.sql.Timestamp;
import java.text.SimpleDateFormat;
import javax.ejb.*; import java.util.ArrayList;
import ibase.webitm.ejb.MasterStatefulLocal; import java.util.HashMap;
import javax.naming.InitialContext; import javax.ejb.Stateless;
@Stateless @Stateless
public class PalletReqConf extends ActionHandlerEJB implements PalletReqConfLocal, PalletReqConfRemote public class PalletReqConf extends ActionHandlerEJB
implements PalletReqConfLocal, PalletReqConfRemote
{ {
String loginEmpCode = ""; String loginEmpCode = "";
String confDateStr = ""; String confDateStr = "";
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
/** public String confirm(String tranID, String xtraParams, String forcedFlag)
* The public function is used to confirm a transaction corresponding to the tran id it takes as an argument throws RemoteException, ITMException
* @param : tranId {
* @param : xtraParams String retString = "";
*/ Connection conn = null;
public String confirm(String tranID,String xtraParams, String forcedFlag) throws RemoteException,ITMException ConnDriver connDriver = new ConnDriver();
{ boolean isConn = true;
String retString = ""; try
Connection conn = null; {
ConnDriver connDriver = new ConnDriver(); conn = connDriver.getConnectDB("DriverITM");
boolean isConn= true; conn.setAutoCommit(false);
try connDriver = null;
{
conn = connDriver.getConnectDB("DriverITM"); retString = confirm(tranID, xtraParams, forcedFlag, conn, isConn);
conn.setAutoCommit(false);
connDriver = null; if ((retString == null) && (retString.length() < 0))
{
retString = this.confirm( tranID,xtraParams, forcedFlag ,conn ,isConn); throw new Exception("Exception while calling confirm for tran Id:[" + tranID + "]");
}
if ( retString == null && retString.length() < 0 ) }
{ catch (Exception exception)
throw new Exception("Exception while calling confirm for tran Id:["+tranID+"]"); {
} System.out.println("Exception in [PalletReqConf] " + exception.getMessage());
} }
catch(Exception exception) return retString;
{ }
System.out.println("Exception in [PalletReqConf] " + exception.getMessage());
} public String confirm(String tranId, String xtraParams, String forcedFlag, Connection conn, boolean conStat) throws RemoteException, ITMException
return retString; {
} System.out.println("PalletReqConf Called........");
public String confirm( String tranId, String xtraParams, String forcedFlag, Connection conn, boolean conStat ) throws RemoteException,ITMException boolean isError = false;
{ String confirmed = "";
System.out.println("PalletReqConf Called........"); String sql = "";
ResultSet rs = null; ResultSet rs1 = null;
boolean isError = false; PreparedStatement pstmt = null; PreparedStatement pstmt1 = null;
String confirmed = ""; String errString = ""; Timestamp tranDate = null;
String sql = ""; String palletNo = ""; String palletStatus = "F";
ResultSet rs = null,rs1 = null; String lineNo = ""; String itemCode = ""; String lotNo = ""; String lotSl = ""; String noArt = ""; String quantity = "";
PreparedStatement pstmt = null,pstmt1 = null; String empCodeAprv = ""; String siteCode = "";
String errString = ""; Timestamp tranDate = null; String loginSite = ""; String qtyPerArt = ""; String refSer = "PRS";
String palletNo = "",palletStatus="F"; String descr = ""; String unit = ""; String itemType = ""; String mfgDate = ""; String expiryDate = "";
String lineNo = "",itemCode="",lotNo="",lotSl="",noArt="",quantity="" ; ArrayList palletList = new ArrayList();
String empCodeAprv="",siteCode =""; ArrayList lineList = new ArrayList();
String loginSite="",qtyPerArt="",refSer="PRS"; int cntPal = 0;
String descr="",unit="",itemType="",mfgDate="",expiryDate=""; ITMDBAccessEJB itmdbAccess = new ITMDBAccessEJB();
ArrayList<String> palletList = new ArrayList(); ArrayList interfaceArrList = new ArrayList();
ArrayList<String> lineList = new ArrayList(); Timestamp today = new Timestamp(System.currentTimeMillis());
int count , cntPal = 0; CommonWmsUtil commonWmsUtility = CommonWmsUtil.getInstance();
ITMDBAccessEJB itmdbAccess = new ITMDBAccessEJB(); try
ArrayList interfaceArrList = new ArrayList(); {
Timestamp today = new Timestamp(System.currentTimeMillis()); System.out.println(" tranId [" + tranId + "]");
CommonWmsUtil commonWmsUtility = CommonWmsUtil.getInstance(); System.out.println(" force flag [" + forcedFlag + "]");
System.out.println(" xtraParams --> [" + xtraParams + "]");
try
{ empCodeAprv = this.genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode");
System.out.println(" tranId ["+tranId+"]"); siteCode = this.genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginSite");
System.out.println(" force flag ["+forcedFlag+"]"); System.out.println(" site code [" + siteCode + "]");
System.out.println(" xtraParams --> ["+xtraParams+"]"); SimpleDateFormat sdf = new SimpleDateFormat(this.genericUtility.getDBDateTimeFormat());
java.util.Date confDate = new java.util.Date();
empCodeAprv = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginEmpCode"); this.confDateStr = sdf.format(confDate);
siteCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginSite");
System.out.println(" site code ["+siteCode+"]"); sql = "SELECT CONFIRMED FROM PALLET_REQ_HDR WHERE TRAN_ID=?";
SimpleDateFormat sdf = new SimpleDateFormat( genericUtility.getDBDateTimeFormat()); pstmt = conn.prepareStatement(sql);
Date confDate = new Date(); pstmt.setString(1, tranId);
confDateStr = sdf.format(confDate); rs = pstmt.executeQuery();
if (rs.next())
sql="SELECT CONFIRMED FROM PALLET_REQ_HDR WHERE TRAN_ID=?"; {
pstmt = conn.prepareStatement(sql); confirmed = checkNullAndTrim(rs.getString("CONFIRMED"));
pstmt.setString(1, tranId); System.out.println("CONFIRMED >>>>>>>" + confirmed);
rs = pstmt.executeQuery(); }
if(rs.next()) rs.close();
{ pstmt.close();
confirmed = checkNullAndTrim(rs.getString("CONFIRMED")); String str1;
System.out.println("CONFIRMED >>>>>>>" +confirmed); if ((confirmed != null) && (confirmed.equalsIgnoreCase("Y")))
} {
rs.close(); System.out.println("error" + errString);
pstmt.close(); errString = itmdbAccess.getErrorString("", "VMTRANSCOF", "", "",
conn);
if (confirmed != null && confirmed.equalsIgnoreCase("Y")) str1 = errString;
{ int count;
System.out.println("error" +errString); return str1;
errString = itmdbAccess.getErrorString("", "VMTRANSCOF", "", "", }
conn);// if already confirm then show error
return errString; sql = "SELECT COUNT(1) FROM PALLET_REQ_DET WHERE TRAN_ID=?";
} pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
sql="SELECT COUNT(1) FROM PALLET_REQ_DET WHERE TRAN_ID=?"; rs = pstmt.executeQuery();
pstmt = conn.prepareStatement(sql); if (rs.next())
pstmt.setString(1,tranId ); {
rs=pstmt.executeQuery(); cntPal = rs.getInt(1);
if(rs.next()) System.out.println("pallet_count---" + cntPal);
{ }
cntPal = rs.getInt(1); if (pstmt != null)
System.out.println("pallet_count---" +cntPal); {
} pstmt.close();
if(pstmt != null) pstmt = null;
{ }
pstmt.close(); if (rs != null)
pstmt = null; {
} rs.close();
if(rs != null) rs = null;
{ }
rs.close(); if (cntPal == 0)
rs = null; {
} System.out.println("palletno cannot be blank for confirm");
if(cntPal == 0) errString = itmdbAccess.getErrorString("", "VMPALLETCF", "", "", conn);
{ str1 = errString;
System.out.println("palletno cannot be blank for confirm"); int count;
errString = itmdbAccess.getErrorString("","VMPALLETCF","","",conn); return str1;
return errString; }
} sql = "UPDATE PALLET_REQ_HDR SET CONFIRMED=? ,CONF_DATE=? ,EMP_CODE__APRV=? WHERE TRAN_ID=?";
sql = "UPDATE PALLET_REQ_HDR SET CONFIRMED=? ,CONF_DATE=? ,EMP_CODE__APRV=? WHERE TRAN_ID=?"; System.out.println("pallet_req_hdr [" + this.confDateStr + "]");
System.out.println("pallet_req_hdr ["+confDateStr+"]"); pstmt = conn.prepareStatement(sql);
pstmt = conn.prepareStatement(sql); pstmt.setString(1, "Y");
pstmt.setString(1, "Y"); pstmt.setDate(2, new java.sql.Date(System.currentTimeMillis()));
pstmt.setDate(2, new java.sql.Date(System.currentTimeMillis())); pstmt.setString(3, empCodeAprv);
pstmt.setString(3, empCodeAprv); pstmt.setString(4, tranId);
pstmt.setString(4, tranId); int count = pstmt.executeUpdate();
count = pstmt.executeUpdate(); if (count > 0)
if( count > 0 ) {
{ System.out.println(" count --> [" + count + "]");
System.out.println(" count --> ["+count+"]"); }
} if (pstmt != null)
if( pstmt != null ) {
{ pstmt.close();
pstmt.close(); pstmt = null;
pstmt = null; }
}
sql = "SELECT D.PALLET_NO ,D.LINE_NO,D.ITEM_CODE,D.LOT_NO,D.LOT_SL,D.NO_ART,D.QUANTITY FROM PALLET_REQ_DET D WHERE TRAN_ID=?";
/*sql="SELECT TRAN_DATE FROM PALLET_REQ_HDR WHERE TRAN_ID=?";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId); pstmt.setString(1, tranId);
rs=pstmt.executeQuery(); rs = pstmt.executeQuery();
if(rs.next()) while (rs.next())
{ {
tranDate = rs.getTimestamp("TRAN_DATE"); for (int i = 0; i < palletList.size(); i++)
System.out.println("tranDate" +tranDate); {
} System.out.println("palletarray" + (String)palletList.get(i));
rs.close(); }
pstmt.close();*/ for (int i = 0; i < lineList.size(); i++)
{
//Changed for pallet request with stock details [Start]Request Id:W15HSUN003 System.out.println("linearray" + (String)lineList.get(i));
//sql="SELECT PALLET_NO ,LINE_NO FROM PALLET_REQ_DET WHERE TRAN_ID=?"; }
sql = "SELECT D.PALLET_NO ,D.LINE_NO,D.ITEM_CODE,D.LOT_NO,D.LOT_SL,D.NO_ART,D.QUANTITY " + palletNo = checkNullAndTrim(rs.getString("PALLET_NO"));
"FROM PALLET_REQ_DET D WHERE TRAN_ID=?"; itemCode = checkNullAndTrim(rs.getString("ITEM_CODE"));
//Changed for pallet request with stock details [End]Request Id:W15HSUN003 lotNo = checkNullAndTrim(rs.getString("LOT_NO"));
pstmt = conn.prepareStatement(sql); lotSl = checkNullAndTrim(rs.getString("LOT_SL"));
pstmt.setString(1,tranId ); noArt = checkNullAndTrim(rs.getString("NO_ART"));
rs=pstmt.executeQuery(); quantity = checkNullAndTrim(rs.getString("QUANTITY"));
while(rs.next()) lineNo = checkNullAndTrim(rs.getString("LINE_NO"));
{
for(int i=0;i<palletList.size();i++) if ((itemCode != null) && (itemCode.length() > 0))
{ {
System.out.println("palletarray"+palletList.get(i)); sql = "SELECT S.QTY_PER_ART,I.DESCR ,S.UNIT,I.ITEM_TYPE ,S.MFG_DATE,S.EXP_DATE FROM STOCK S ,ITEM I WHERE S.SITE_CODE=? AND S.LOC_CODE IN (?,?) AND S.ITEM_CODE= ? AND S.LOT_NO= ? AND S.LOT_SL= ? AND S.ITEM_CODE=I.ITEM_CODE";
}
for(int i=0;i<lineList.size();i++) pstmt1 = conn.prepareStatement(sql);
{ pstmt1.setString(1, siteCode);
System.out.println("linearray"+lineList.get(i)); pstmt1.setString(2, palletNo);
} pstmt1.setString(3, palletNo + "Q");
pstmt1.setString(4, itemCode);
palletNo = checkNullAndTrim(rs.getString("PALLET_NO")); pstmt1.setString(5, lotNo);
itemCode = checkNullAndTrim(rs.getString("ITEM_CODE")); pstmt1.setString(6, lotSl);
lotNo = checkNullAndTrim(rs.getString("LOT_NO"));
lotSl = checkNullAndTrim(rs.getString("LOT_SL")); rs1 = pstmt1.executeQuery();
noArt = checkNullAndTrim(rs.getString("NO_ART")); if (rs1.next())
quantity = checkNullAndTrim(rs.getString("QUANTITY")); {
lineNo = checkNullAndTrim(rs.getString("LINE_NO")); qtyPerArt = checkNullAndTrim(rs1.getString("QTY_PER_ART"));
descr = checkNullAndTrim(rs1.getString("DESCR"));
// lineNo = " " + lineNo; unit = checkNullAndTrim(rs1.getString("UNIT"));
// lineNo = lineNo.substring( lineNo.length()-3 ); itemType = checkNullAndTrim(rs1.getString("ITEM_TYPE"));
mfgDate = checkNullAndTrim(rs1.getString("MFG_DATE"));
if(itemCode!= null && itemCode.length() > 0) expiryDate = checkNullAndTrim(rs1.getString("EXP_DATE"));
{ palletStatus = CommonWmsUtil.getFullOrPrtialPalletOut(palletNo, refSer, tranId, siteCode, conn);
/*sql="SELECT S.QTY_PER_ART FROM STOCK S WHERE S.SITE_CODE=?" System.out.println("palletStatus for PRS" + palletStatus);
+" AND S.LOC_CODE = ?" HashMap hm = new HashMap();
+" AND S.ITEM_CODE=?" hm.put("ITEM_CODE", itemCode);
+" AND S.LOT_NO=? " hm.put("REF_ID", tranId);
+" AND S.LOT_SL=?";*/ hm.put("REF_SER", refSer);
hm.put("TRAN_DATE", checkNullAndTrim(String.valueOf(today)));
sql="SELECT S.QTY_PER_ART,I.DESCR ,S.UNIT,I.ITEM_TYPE ,S.MFG_DATE,S.EXP_DATE " + hm.put("QTY_PER_ART", qtyPerArt);
"FROM STOCK S ,ITEM I WHERE S.SITE_CODE=? AND S.LOC_CODE IN (?,?) " + hm.put("LOT_NO", lotNo);
"AND S.ITEM_CODE= ? AND S.LOT_NO= ? " + hm.put("LOT_SL", lotSl);
"AND S.LOT_SL= ? AND S.ITEM_CODE=I.ITEM_CODE"; hm.put("QUANTITY", noArt);
hm.put("TOTAL_QTY", quantity);
pstmt1 = conn.prepareStatement(sql); hm.put("PALLET_NO", palletNo);
pstmt1.setString(1, siteCode); hm.put("LINE_NO", lineNo);
pstmt1.setString(2, palletNo); hm.put("DESCR", descr);
pstmt1.setString(3, palletNo+"Q"); hm.put("UNIT", unit);
pstmt1.setString(4, itemCode); hm.put("ITEM_TYPE", itemType);
pstmt1.setString(5, lotNo); hm.put("FAMILY_GRP", "");
pstmt1.setString(6, lotSl); hm.put("TRAN_ID", "");
hm.put("IN_OUT", "O");
rs1 = pstmt1.executeQuery(); hm.put("EXP_DATE", expiryDate);
if(rs1.next()) hm.put("MFG_DATE", mfgDate);
{ hm.put("PALLET_STATUS", palletStatus);
qtyPerArt = checkNullAndTrim(rs1.getString("QTY_PER_ART")); hm.put("MSG_STAT", "N");
descr= checkNullAndTrim(rs1.getString("DESCR")); hm.put("LOCK_STAT", "");
unit = checkNullAndTrim(rs1.getString("UNIT")); hm.put("ERR_COD", "");
itemType = checkNullAndTrim(rs1.getString("ITEM_TYPE")); hm.put("ERR_DESC", "");
mfgDate = checkNullAndTrim(rs1.getString("MFG_DATE")); hm.put("QC_TYPE", "");
expiryDate = checkNullAndTrim(rs1.getString("EXP_DATE")); hm.put("TRANS_DT_ACK", "");
palletStatus=commonWmsUtility.getFullOrPrtialPalletOut(palletNo,refSer,tranId,siteCode, conn) ; hm.put("STRO_PREF", "");
System.out.println("palletStatus for PRS"+palletStatus);
HashMap hm = new HashMap(); interfaceArrList.add(hm);
hm.put("ITEM_CODE", itemCode); System.out.println("interfacearraylist" + interfaceArrList.size());
hm.put("REF_ID", tranId); }
hm.put("REF_SER", refSer); rs1.close();
hm.put("TRAN_DATE", checkNullAndTrim(String.valueOf(today))); pstmt1.close();
hm.put("QTY_PER_ART", qtyPerArt); }
hm.put("LOT_NO", lotNo); else
hm.put("LOT_SL", lotSl); {
hm.put("QUANTITY", noArt); HashMap hm = new HashMap();
hm.put("TOTAL_QTY", quantity); hm.put("REF_ID", tranId);
hm.put("PALLET_NO", palletNo); hm.put("REF_SER", "PR");
hm.put("LINE_NO", lineNo); hm.put("TRAN_DATE", checkNullAndTrim(String.valueOf(today)));
hm.put("DESCR", descr); hm.put("PALLET_NO", palletNo);
hm.put("UNIT", unit); hm.put("LINE_NO", lineNo);
hm.put("ITEM_TYPE", itemType); hm.put("DESCR", "");
hm.put("FAMILY_GRP", ""); hm.put("UNIT", "");
hm.put("TRAN_ID", ""); hm.put("ITEM_TYPE", "");
hm.put("IN_OUT", "O"); hm.put("FAMILY_GRP", "");
hm.put("EXP_DATE", expiryDate); hm.put("TRAN_ID", "");
hm.put("MFG_DATE", mfgDate); hm.put("IN_OUT", "O");
hm.put("PALLET_STATUS", palletStatus); hm.put("EXP_DATE", "");
hm.put("MSG_STAT", "N"); hm.put("MFG_DATE", "");
hm.put("LOCK_STAT", ""); hm.put("PALLET_STATUS", palletStatus);
hm.put("ERR_COD", ""); hm.put("MSG_STAT", "N");
hm.put("ERR_DESC", ""); hm.put("LOCK_STAT", "");
hm.put("QC_TYPE", ""); hm.put("ERR_COD", "");
hm.put("TRANS_DT_ACK",""); hm.put("ERR_DESC", "");
hm.put("STRO_PREF", ""); hm.put("QC_TYPE", "");
hm.put("TRANS_DT_ACK", "");
interfaceArrList.add(hm); hm.put("STRO_PREF", "");
System.out.println("interfacearraylist"+interfaceArrList.size());
} interfaceArrList.add(hm);
rs1.close(); System.out.println("interfacearraylist" + interfaceArrList.size());
pstmt1.close(); }
} }
else rs.close();
{ pstmt.close();
HashMap hm = new HashMap(); commonWmsUtility.updateAwmsInterface(interfaceArrList, siteCode, conn);
hm.put("REF_ID", tranId);
hm.put("REF_SER", "PR"); System.out.println("Inserted into SWMS TO AWMS table ::::::::: ");
hm.put("TRAN_DATE", checkNullAndTrim(String.valueOf(today))); }
hm.put("PALLET_NO", palletNo); catch (Exception e)
hm.put("LINE_NO", lineNo); {
hm.put("DESCR", ""); isError = true;
hm.put("UNIT", ""); e.printStackTrace();
hm.put("ITEM_TYPE", ""); throw new ITMException(e);
hm.put("FAMILY_GRP", ""); }
hm.put("TRAN_ID", ""); finally
hm.put("IN_OUT", "O"); {
hm.put("EXP_DATE", ""); try
hm.put("MFG_DATE", ""); {
hm.put("PALLET_STATUS", palletStatus); System.out.println("is error in finally" + isError);
hm.put("MSG_STAT", "N"); if (isError)
hm.put("LOCK_STAT", ""); {
hm.put("ERR_COD", ""); conn.rollback();
hm.put("ERR_DESC", ""); }
hm.put("QC_TYPE", ""); else
hm.put("TRANS_DT_ACK",""); {
hm.put("STRO_PREF", ""); conn.commit();
errString = itmdbAccess.getErrorString("", "VMTRANSACN", "", "", conn);
interfaceArrList.add(hm); }
System.out.println("interfacearraylist"+interfaceArrList.size()); if (conn != null)
} {
} conn.close();
rs.close(); conn = null;
pstmt.close(); }
commonWmsUtility.updateAwmsInterface(interfaceArrList,siteCode,conn); }
catch (Exception e)
System.out.println("Inserted into SWMS TO AWMS table ::::::::: "); {
e.printStackTrace();
}//try block end throw new ITMException(e);
catch (Exception e) }
{ }
isError = true; try
e.printStackTrace(); {
throw new ITMException(e); int count;
} System.out.println("is error in finally" + isError);
finally if (isError)
{ {
try conn.rollback();
{ }
System.out.println("is error in finally"+isError); else
if(isError) {
{ conn.commit();
conn.rollback(); errString = itmdbAccess.getErrorString("", "VMTRANSACN", "", "", conn);
} }
else if (conn != null)
{ {
conn.commit(); conn.close();
errString = itmdbAccess.getErrorString("","VMTRANSACN","","",conn); //Transaction Confirm. conn = null;
} }
if (conn != null ) }
{ catch (Exception e)
conn.close(); {
conn = null; e.printStackTrace();
} throw new ITMException(e);
} }
catch (Exception e)
{ return errString;
e.printStackTrace(); }
throw new ITMException(e);
} private String checkNullAndTrim(String inputVal)
} {
return errString; if (inputVal == null)
} {
inputVal = "";
private String checkNullAndTrim( String inputVal ) }
{ else
if ( inputVal == null ) {
{ inputVal = inputVal.trim();
inputVal = ""; }
} return inputVal;
else }
{ }
inputVal = inputVal.trim(); \ No newline at end of file
}
return inputVal;
}
}
webitm-wms/ibase/webitm/ejb/wms/PalletReqExpiryAct.java
View file @ 244e7cf7
/**
* Purpose:Create transaction screen Pallet Request, Request ID: W15GSUN001
* Purpose:Create Pallet Request with stock details ,Request ID: W15HSUN003
*/
package ibase.webitm.ejb.wms; package ibase.webitm.ejb.wms;
import ibase.webitm.utility.*; import ibase.system.config.ConnDriver;
import ibase.webitm.utility.wms.CommonWmsUtil; import ibase.webitm.ejb.ActionHandlerEJB;
import ibase.system.config.*; import ibase.webitm.utility.GenericUtility;
import ibase.webitm.ejb.*; import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.dis.*;
import ibase.webitm.ejb.fin.*;
import java.io.PrintStream; import java.io.PrintStream;
import java.rmi.RemoteException; import java.rmi.RemoteException;
import java.util.*; import java.sql.Connection;
import java.util.Date; import java.sql.PreparedStatement;
import java.text.*; import java.sql.ResultSet;
import java.sql.*; import java.sql.SQLException;
import javax.ejb.Stateless;
import javax.ejb.*;
import ibase.webitm.ejb.MasterStatefulLocal;
import javax.naming.InitialContext;
import org.w3c.dom.Document; import org.w3c.dom.Document;
@Stateless @Stateless
public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExpiryActLocal , PalletReqExpiryActRemote public class PalletReqExpiryAct extends ActionHandlerEJB
implements PalletReqExpiryActLocal, PalletReqExpiryActRemote
{ {
/**stockExpiry public String actionHandler(String actionType, String xmlString, String xmlString1, String objContext, String xtraParams)
* The public function is used to confirm a transaction corresponding to the tran id it takes as an argument throws RemoteException, ITMException
* @param : tranId
* @param : xtraParams
* @throws Exception
*/
public String actionHandler(String actionType, String xmlString,String xmlString1, String objContext, String xtraParams)
throws RemoteException, ITMException
{ {
Document dom = null; Document dom = null;
Document dom1 = null; Document dom1 = null;
String retString = ""; String retString = "";
System.out.println("actionHandler:" +actionType); System.out.println("actionHandler:" + actionType);
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
try { try {
if (xmlString != null && xmlString.trim().length() != 0) if ((xmlString != null) && (xmlString.trim().length() != 0))
{ {
System.out.println("XML String :" + xmlString); System.out.println("XML String :" + xmlString);
dom = genericUtility.parseString(xmlString); dom = genericUtility.parseString(xmlString);
} }
if (xmlString1 != null && xmlString1.trim().length() != 0) if ((xmlString1 != null) && (xmlString1.trim().length() != 0))
{ {
System.out.println("XML String1 :" + xmlString1); System.out.println("XML String1 :" + xmlString1);
dom1 = genericUtility.parseString(xmlString1); dom1 = genericUtility.parseString(xmlString1);
} }
if (actionType.equalsIgnoreCase("EXPIRY")) if (actionType.equalsIgnoreCase("EXPIRY"))
{ {
retString=stockExpiry( dom, dom1, "" , null,false ); retString = stockExpiry(dom, dom1, "", null, false);
} }
if (actionType.equalsIgnoreCase("NEXPIRY")) if (actionType.equalsIgnoreCase("NEXPIRY"))
{ {
retString=stockNearExpiry( dom, dom1, "" , null,false ); retString = stockNearExpiry(dom, dom1, "", null, false);
} }
if (actionType.equalsIgnoreCase("DEFAULT")) if (actionType.equalsIgnoreCase("DEFAULT"))
{ {
retString=defaultData( dom, dom1, "" , null,false ); retString = defaultData(dom, dom1, "", null, false);
} }
System.out.println("actionType:" + actionType + ":"); System.out.println("actionType:" + actionType + ":");
//loginSite = checkNull(genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginSiteCode" )); }
} catch (Exception e) catch (Exception e)
{ {
System.out.println("Exception :PalletReqExpiryAct :actionHandler(String xmlString):" + e.getMessage() + ":"); System.out.println("Exception :PalletReqExpiryAct :actionHandler(String xmlString):" + e.getMessage() + ":");
e.printStackTrace(); e.printStackTrace();
...@@ -75,18 +60,20 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp ...@@ -75,18 +60,20 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp
return retString; return retString;
} }
public String stockExpiry( Document dom,Document dom1, String forcedFlag , Connection conn, boolean conStat ) throws Exception public String stockExpiry(Document dom, Document dom1, String forcedFlag, Connection conn, boolean conStat) throws Exception
{ {
String sql = "",palletNo = "",itemCode="",lotNo="",lotSl="",quantity="",noArt="",siteCode=""; String sql = ""; String palletNo = ""; String itemCode = ""; String lotNo = ""; String lotSl = ""; String quantity = ""; String noArt = ""; String siteCode = "";
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
ResultSet rs = null; ResultSet rs = null;
String locCode = "" ,status = ""; String locCode = ""; String status = "";
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
ConnDriver connDriver = new ConnDriver(); ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM"); conn = connDriver.getConnectDB("DriverITM");
StringBuffer xmlString = new StringBuffer("<Root>"); StringBuffer xmlString = new StringBuffer("<Root>");
try try
{ {
siteCode = checkNullAndTrim(genericUtility.getColumnValue("site_code", dom1));
siteCode = checkNullAndTrim(genericUtility.getColumnValue("site_code",dom1)); siteCode = checkNullAndTrim(genericUtility.getColumnValue("site_code",dom1));
//sql = " SELECT D.LOC_CODE AS PALLET_NO ,D.ITEM_CODE,D.SITE_CODE,D.LOT_NO,D.LOT_SL" + " FROM INV_HOLD_DET D,INV_HOLD I ,LOCATION L WHERE D.LOC_CODE=L.LOC_CODE AND I.TRAN_ID = D.TRAN_ID AND D.HOLD_STATUS != ?" + " AND I.LOCK_CODE = ?" + "AND L.INV_STAT=? AND D.SITE_CODE= ?";//EXP_LOCK //sql = " SELECT D.LOC_CODE AS PALLET_NO ,D.ITEM_CODE,D.SITE_CODE,D.LOT_NO,D.LOT_SL" + " FROM INV_HOLD_DET D,INV_HOLD I ,LOCATION L WHERE D.LOC_CODE=L.LOC_CODE AND I.TRAN_ID = D.TRAN_ID AND D.HOLD_STATUS != ?" + " AND I.LOCK_CODE = ?" + "AND L.INV_STAT=? AND D.SITE_CODE= ?";//EXP_LOCK
//sql="SELECT DISTINCT (S.LOC_CODE) AS PALLET_NO ,S.ITEM_CODE, S.LOT_NO,S.LOT_SL,S.QUANTITY," + //sql="SELECT DISTINCT (S.LOC_CODE) AS PALLET_NO ,S.ITEM_CODE, S.LOT_NO,S.LOT_SL,S.QUANTITY," +
...@@ -110,7 +97,7 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp ...@@ -110,7 +97,7 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp
"AND A.IN_OUT= ? AND A.PALLET_NO=S.LOC_CODE AND A.ITEM_CODE=S.ITEM_CODE " + "AND A.IN_OUT= ? AND A.PALLET_NO=S.LOC_CODE AND A.ITEM_CODE=S.ITEM_CODE " +
"AND A.LOT_NO=S.LOT_NO AND A.LOT_SL=S.LOT_SL AND A.PALLET_STATUS= ? AND S.QUANTITY > 0 AND S.QTY_PER_ART > 0 AND S.NO_ART > 0";//EXP_LOCK "AND A.LOT_NO=S.LOT_NO AND A.LOT_SL=S.LOT_SL AND A.PALLET_STATUS= ? AND S.QUANTITY > 0 AND S.QTY_PER_ART > 0 AND S.NO_ART > 0";//EXP_LOCK
*/ */
sql="SELECT DISTINCT (S.LOC_CODE) AS PALLET_NO ,S.ITEM_CODE, S.LOT_NO,S.LOT_SL,S.QUANTITY, "+ /*sql="SELECT DISTINCT (S.LOC_CODE) AS PALLET_NO ,S.ITEM_CODE, S.LOT_NO,S.LOT_SL,S.QUANTITY, "+
"S.NO_ART FROM INV_HOLD_DET D,INV_HOLD I , LOCATION L ,STOCK S ,SWMS_TO_AWMS A "+ "S.NO_ART FROM INV_HOLD_DET D,INV_HOLD I , LOCATION L ,STOCK S ,SWMS_TO_AWMS A "+
"WHERE S.ITEM_CODE = D.ITEM_CODE AND S.LOC_CODE = D.LOC_CODE AND S.LOT_NO = D.LOT_NO " + "WHERE S.ITEM_CODE = D.ITEM_CODE AND S.LOC_CODE = D.LOC_CODE AND S.LOT_NO = D.LOT_NO " +
"AND S.LOT_SL = D.LOT_SL AND S.SITE_CODE = D.SITE_CODE AND D.LOC_CODE=L.LOC_CODE " + "AND S.LOT_SL = D.LOT_SL AND S.SITE_CODE = D.SITE_CODE AND D.LOC_CODE=L.LOC_CODE " +
...@@ -126,7 +113,24 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp ...@@ -126,7 +113,24 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp
" AND I.LOCK_CODE = ? AND L.INV_STAT= ? AND S.SITE_CODE= ? " + " AND I.LOCK_CODE = ? AND L.INV_STAT= ? AND S.SITE_CODE= ? " +
"AND A.IN_OUT= ? AND A.PALLET_NO=S.LOC_CODE AND A.ITEM_CODE=S.ITEM_CODE " + "AND A.IN_OUT= ? AND A.PALLET_NO=S.LOC_CODE AND A.ITEM_CODE=S.ITEM_CODE " +
"AND A.LOT_NO=S.LOT_NO AND A.LOT_SL=S.LOT_SL AND A.PALLET_STATUS= ? AND S.QUANTITY > 0 AND S.QTY_PER_ART > 0 AND S.NO_ART > 0"; "AND A.LOT_NO=S.LOT_NO AND A.LOT_SL=S.LOT_SL AND A.PALLET_STATUS= ? AND S.QUANTITY > 0 AND S.QTY_PER_ART > 0 AND S.NO_ART > 0";
*/
sql = "SELECT S.LOC_CODE AS PALLET_NO ,S.ITEM_CODE, S.LOT_NO,S.LOT_SL,S.QUANTITY, S.NO_ART FROM " +
" INV_HOLD_DET D,INV_HOLD I , LOCATION L ,STOCK S ,SWMS_TO_AWMS A WHERE S.ITEM_CODE = D.ITEM_CODE " +
" AND S.LOC_CODE = D.LOC_CODE AND S.LOT_NO = D.LOT_NO AND S.LOT_SL = D.LOT_SL AND S.SITE_CODE = D.SITE_CODE " +
"AND D.LOC_CODE=L.LOC_CODE AND I.TRAN_ID = D.TRAN_ID AND L.LOC_CODE=S.LOC_CODE AND D.HOLD_STATUS != ? " +
" AND I.LOCK_CODE = ? AND L.INV_STAT= ? AND S.SITE_CODE= ? AND A.IN_OUT= ? AND A.PALLET_NO=TRIM(S.LOC_CODE) " +
"AND A.ITEM_CODE=S.ITEM_CODE AND A.LOT_NO=S.LOT_NO AND A.LOT_SL=S.LOT_SL AND A.PALLET_STATUS= ? AND" +
" FN_CHK_PRS(S.LOC_CODE) = 0 AND S.QUANTITY>0 AND S.NO_ART >0 AND S.QTY_PER_ART >0 " +
"UNION ALL" +
" SELECT SUBSTR(S.LOC_CODE,1,INSTR(S.LOC_CODE,'Q')-1) ,S.ITEM_CODE, S.LOT_NO,S.LOT_SL,S.QUANTITY, S.NO_ART " +
" FROM INV_HOLD_DET D,INV_HOLD I , LOCATION L ,STOCK S ,SWMS_TO_AWMS A WHERE S.ITEM_CODE = D.ITEM_CODE " +
" AND S.LOC_CODE = D.LOC_CODE AND S.LOT_NO = D.LOT_NO AND S.LOT_SL = D.LOT_SL AND S.SITE_CODE = D.SITE_CODE " +
"AND D.LOC_CODE=L.LOC_CODE AND I.TRAN_ID = D.TRAN_ID AND L.LOC_CODE=S.LOC_CODE AND D.HOLD_STATUS != ? " +
" AND I.LOCK_CODE = ? AND L.INV_STAT= ? AND S.SITE_CODE= ? AND A.IN_OUT= ? AND A.PALLET_NO=TRIM(S.LOC_CODE) AND " +
"A.ITEM_CODE=S.ITEM_CODE AND A.LOT_NO=S.LOT_NO AND A.LOT_SL=S.LOT_SL AND A.PALLET_STATUS= ? AND " +
" FN_CHK_PRS(SUBSTR(S.LOC_CODE,1,INSTR(S.LOC_CODE,'Q')-1)) = 0 AND S.QUANTITY>0 AND S.NO_ART >0 AND S.QTY_PER_ART >0";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, "R"); pstmt.setString(1, "R");
pstmt.setString(2, "EXP_LOCK"); pstmt.setString(2, "EXP_LOCK");
...@@ -142,8 +146,8 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp ...@@ -142,8 +146,8 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp
pstmt.setString(12, "P"); pstmt.setString(12, "P");
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
while(rs.next()) while (rs.next())
{ {
palletNo = checkNullAndTrim(rs.getString("PALLET_NO")); palletNo = checkNullAndTrim(rs.getString("PALLET_NO"));
itemCode = checkNullAndTrim(rs.getString("ITEM_CODE")); itemCode = checkNullAndTrim(rs.getString("ITEM_CODE"));
lotNo = checkNullAndTrim(rs.getString("LOT_NO")); lotNo = checkNullAndTrim(rs.getString("LOT_NO"));
...@@ -165,45 +169,43 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp ...@@ -165,45 +169,43 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp
rs.close(); rs.close();
pstmt.close(); pstmt.close();
} }
catch (SQLException sqx) catch (SQLException sqx)
{ {
System.out.println("The sqlException occure in PalletReqExpiryAct :" + sqx); System.out.println("The sqlException occure in PalletReqExpiryAct :" + sqx);
throw new ITMException(sqx); throw new ITMException(sqx);
} }
catch (Exception e) catch (Exception e)
{ {
System.out.println("The Exception occure in PalletReqExpiryAct :" + e); System.out.println("The Exception occure in PalletReqExpiryAct :" + e);
throw new ITMException(e); throw new ITMException(e);
} }
finally finally
{ {
try try
{ {
conn.close(); conn.close();
conn = null; conn = null;
} catch (Exception e) }
{ catch (Exception localException1) {
} }
} }
return xmlString.toString(); return xmlString.toString();
} }
public String stockNearExpiry( Document dom,Document dom1, String forcedFlag , Connection conn, boolean conStat ) throws Exception public String stockNearExpiry(Document dom, Document dom1, String forcedFlag, Connection conn, boolean conStat) throws Exception
{ {
String locCode="", status="",palletNo = "",itemCode="",lotNo="",lotSl="",quantity="",noArt="",sql="",siteCode=""; String locCode = ""; String status = ""; String palletNo = ""; String itemCode = ""; String lotNo = ""; String lotSl = ""; String quantity = ""; String noArt = ""; String sql = ""; String siteCode = "";
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
StringBuffer xmlString = new StringBuffer("<Root>"); StringBuffer xmlString = new StringBuffer("<Root>");
ConnDriver connDriver = new ConnDriver(); ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM"); conn = connDriver.getConnectDB("DriverITM");
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
ResultSet rs = null; ResultSet rs = null;
try try
{ {
siteCode = checkNullAndTrim(genericUtility.getColumnValue("site_code",dom1)); siteCode = checkNullAndTrim(genericUtility.getColumnValue("site_code", dom1));
//String sql = " SELECT D.LOC_CODE AS PALLET_NO ,D.ITEM_CODE,D.SITE_CODE,D.LOT_NO,D.LOT_SL" + " FROM INV_HOLD_DET D,INV_HOLD I ,LOCATION L WHERE D.LOC_CODE=L.LOC_CODE AND I.TRAN_ID = D.TRAN_ID AND D.HOLD_STATUS != ?" + " AND I.LOCK_CODE = ?" + "AND L.INV_STAT=? AND D.SITE_CODE= ?";//NEXP_LOCK
//String sql="SELECT DISTINCT (S.LOC_CODE) AS PALLET_NO ,S.ITEM_CODE, S.LOT_NO,S.LOT_SL,S.QUANTITY,S.NO_ART FROM INV_HOLD_DET D,INV_HOLD I , LOCATION L ,STOCK S WHERE D.LOC_CODE=L.LOC_CODE AND I.TRAN_ID = D.TRAN_ID AND L.LOC_CODE=S.LOC_CODE AND D.HOLD_STATUS != ? AND I.LOCK_CODE = ? AND L.INV_STAT=? AND S.SITE_CODE= ? AND S.QUANTITY>0";//NEXP_LOCK
/*sql="SELECT S.LOC_CODE AS PALLET_NO ,S.ITEM_CODE, S.LOT_NO,S.LOT_SL,S.QUANTITY," + /*sql="SELECT S.LOC_CODE AS PALLET_NO ,S.ITEM_CODE, S.LOT_NO,S.LOT_SL,S.QUANTITY," +
"S.NO_ART FROM INV_HOLD_DET D,INV_HOLD I , LOCATION L ,STOCK S WHERE S.ITEM_CODE = D.ITEM_CODE" + "S.NO_ART FROM INV_HOLD_DET D,INV_HOLD I , LOCATION L ,STOCK S WHERE S.ITEM_CODE = D.ITEM_CODE" +
" AND S.LOC_CODE = D.LOC_CODE AND S.LOT_NO = D.LOT_NO AND S.LOT_SL = D.LOT_SL " + " AND S.LOC_CODE = D.LOC_CODE AND S.LOT_NO = D.LOT_NO AND S.LOT_SL = D.LOT_SL " +
...@@ -221,7 +223,7 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp ...@@ -221,7 +223,7 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp
"AND A.IN_OUT= ? AND A.PALLET_NO=S.LOC_CODE AND A.ITEM_CODE=S.ITEM_CODE " + "AND A.IN_OUT= ? AND A.PALLET_NO=S.LOC_CODE AND A.ITEM_CODE=S.ITEM_CODE " +
"AND A.LOT_NO=S.LOT_NO AND A.LOT_SL=S.LOT_SL AND A.PALLET_STATUS= ? AND S.QUANTITY > 0 AND S.QTY_PER_ART > 0 AND S.NO_ART > 0";//NEXP_LOCK "AND A.LOT_NO=S.LOT_NO AND A.LOT_SL=S.LOT_SL AND A.PALLET_STATUS= ? AND S.QUANTITY > 0 AND S.QTY_PER_ART > 0 AND S.NO_ART > 0";//NEXP_LOCK
*/ */
/*
sql="SELECT DISTINCT (S.LOC_CODE) AS PALLET_NO ,S.ITEM_CODE, S.LOT_NO,S.LOT_SL,S.QUANTITY, "+ sql="SELECT DISTINCT (S.LOC_CODE) AS PALLET_NO ,S.ITEM_CODE, S.LOT_NO,S.LOT_SL,S.QUANTITY, "+
"S.NO_ART FROM INV_HOLD_DET D,INV_HOLD I , LOCATION L ,STOCK S ,SWMS_TO_AWMS A "+ "S.NO_ART FROM INV_HOLD_DET D,INV_HOLD I , LOCATION L ,STOCK S ,SWMS_TO_AWMS A "+
"WHERE S.ITEM_CODE = D.ITEM_CODE AND S.LOC_CODE = D.LOC_CODE AND S.LOT_NO = D.LOT_NO " + "WHERE S.ITEM_CODE = D.ITEM_CODE AND S.LOC_CODE = D.LOC_CODE AND S.LOT_NO = D.LOT_NO " +
...@@ -238,6 +240,26 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp ...@@ -238,6 +240,26 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp
" AND I.LOCK_CODE = ? AND L.INV_STAT= ? AND S.SITE_CODE= ? " + " AND I.LOCK_CODE = ? AND L.INV_STAT= ? AND S.SITE_CODE= ? " +
"AND A.IN_OUT= ? AND A.PALLET_NO=S.LOC_CODE AND A.ITEM_CODE=S.ITEM_CODE " + "AND A.IN_OUT= ? AND A.PALLET_NO=S.LOC_CODE AND A.ITEM_CODE=S.ITEM_CODE " +
"AND A.LOT_NO=S.LOT_NO AND A.LOT_SL=S.LOT_SL AND A.PALLET_STATUS= ? AND S.QUANTITY > 0 AND S.QTY_PER_ART > 0 AND S.NO_ART > 0"; "AND A.LOT_NO=S.LOT_NO AND A.LOT_SL=S.LOT_SL AND A.PALLET_STATUS= ? AND S.QUANTITY > 0 AND S.QTY_PER_ART > 0 AND S.NO_ART > 0";
*/
sql = "SELECT S.LOC_CODE AS PALLET_NO ,S.ITEM_CODE, S.LOT_NO,S.LOT_SL,S.QUANTITY, S.NO_ART FROM " +
"INV_HOLD_DET D,INV_HOLD I , LOCATION L ,STOCK S ,SWMS_TO_AWMS A WHERE S.ITEM_CODE = D.ITEM_CODE " +
" AND S.LOC_CODE = D.LOC_CODE AND S.LOT_NO = D.LOT_NO AND S.LOT_SL = D.LOT_SL AND S.SITE_CODE = D.SITE_CODE AND" +
" D.LOC_CODE=L.LOC_CODE AND I.TRAN_ID = D.TRAN_ID AND L.LOC_CODE=S.LOC_CODE AND D.HOLD_STATUS != ? " +
"AND I.LOCK_CODE = ? AND L.INV_STAT= ? AND S.SITE_CODE= ? AND A.IN_OUT= ? AND A.PALLET_NO=TRIM(S.LOC_CODE) " +
"AND A.ITEM_CODE=S.ITEM_CODE AND A.LOT_NO=S.LOT_NO AND A.LOT_SL=S.LOT_SL AND A.PALLET_STATUS= ? " +
"AND FN_CHK_PRS(S.LOC_CODE) = 0 AND S.QUANTITY>0 AND S.NO_ART >0 AND S.QTY_PER_ART >0 " +
"UNION ALL SELECT SUBSTR(S.LOC_CODE,1,INSTR(S.LOC_CODE,'Q')-1) ,S.ITEM_CODE, S.LOT_NO,S.LOT_SL,S.QUANTITY," +
" S.NO_ART FROM INV_HOLD_DET D,INV_HOLD I , LOCATION L ,STOCK S ,SWMS_TO_AWMS A WHERE " +
" S.ITEM_CODE = D.ITEM_CODE AND S.LOC_CODE = D.LOC_CODE AND S.LOT_NO = D.LOT_NO AND S.LOT_SL = D.LOT_SL " +
"AND S.SITE_CODE = D.SITE_CODE AND D.LOC_CODE=L.LOC_CODE AND I.TRAN_ID = D.TRAN_ID AND " +
"L.LOC_CODE=S.LOC_CODE AND D.HOLD_STATUS != ? AND I.LOCK_CODE = ? AND L.INV_STAT= ? AND" +
" S.SITE_CODE= ? AND A.IN_OUT= ? AND A.PALLET_NO=TRIM(S.LOC_CODE) AND A.ITEM_CODE=S.ITEM_CODE AND " +
"A.LOT_NO=S.LOT_NO AND A.LOT_SL=S.LOT_SL AND A.PALLET_STATUS= ? AND " +
" FN_CHK_PRS(SUBSTR(S.LOC_CODE,1,INSTR(S.LOC_CODE,'Q')-1)) = 0 AND S.QUANTITY>0 " +
"AND S.NO_ART >0 AND S.QTY_PER_ART >0";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, "R"); pstmt.setString(1, "R");
pstmt.setString(2, "NEXP_LOCK"); pstmt.setString(2, "NEXP_LOCK");
...@@ -252,8 +274,8 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp ...@@ -252,8 +274,8 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp
pstmt.setString(11, "S"); pstmt.setString(11, "S");
pstmt.setString(12, "P"); pstmt.setString(12, "P");
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
while(rs.next()) while (rs.next())
{ {
palletNo = checkNullAndTrim(rs.getString("PALLET_NO")); palletNo = checkNullAndTrim(rs.getString("PALLET_NO"));
itemCode = checkNullAndTrim(rs.getString("ITEM_CODE")); itemCode = checkNullAndTrim(rs.getString("ITEM_CODE"));
lotNo = checkNullAndTrim(rs.getString("LOT_NO")); lotNo = checkNullAndTrim(rs.getString("LOT_NO"));
...@@ -275,60 +297,71 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp ...@@ -275,60 +297,71 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp
rs.close(); rs.close();
pstmt.close(); pstmt.close();
} }
catch (SQLException sqx) catch (SQLException sqx)
{ {
System.out.println("The sqlException occure in PalletReqExpiryAct :" + sqx); System.out.println("The sqlException occure in PalletReqExpiryAct :" + sqx);
throw new ITMException(sqx); throw new ITMException(sqx);
} }
catch (Exception e) catch (Exception e)
{ {
System.out.println("The Exception occure in PalletReqExpiryAct :" + e); System.out.println("The Exception occure in PalletReqExpiryAct :" + e);
throw new ITMException(e); throw new ITMException(e);
} }
finally finally
{ {
try try
{ {
conn.close(); conn.close();
conn = null; conn = null;
} }
catch (Exception e) catch (Exception localException1)
{ {
} }
} }
return xmlString.toString(); return xmlString.toString();
} }
//Changed for pallet request with stock detail [Start]Request Id:W15HSUN003
public String defaultData( Document dom,Document dom1, String forcedFlag , Connection conn, boolean conStat ) throws Exception public String defaultData(Document dom, Document dom1, String forcedFlag, Connection conn, boolean conStat) throws Exception
{ {
String locCode="", status="",palletNo = "",itemCode="",lotNo="",lotSl="",quantity="",noArt="",siteCode="",sql=""; String locCode = ""; String status = ""; String palletNo = ""; String itemCode = ""; String lotNo = ""; String lotSl = ""; String quantity = ""; String noArt = ""; String siteCode = ""; String sql = "";
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
StringBuffer xmlString = new StringBuffer("<Root>"); StringBuffer xmlString = new StringBuffer("<Root>");
ConnDriver connDriver = new ConnDriver(); ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM"); conn = connDriver.getConnectDB("DriverITM");
try try
{ {
siteCode = checkNullAndTrim(genericUtility.getColumnValue("site_code",dom1)); siteCode = checkNullAndTrim(genericUtility.getColumnValue("site_code", dom1));
/*sql = " SELECT DISTINCT (S.LOC_CODE) AS PALLET_NO,S.ITEM_CODE,S.LOT_NO,S.LOT_SL,S.QUANTITY," + /*sql = " SELECT DISTINCT (S.LOC_CODE) AS PALLET_NO,S.ITEM_CODE,S.LOT_NO,S.LOT_SL,S.QUANTITY," +
"S.NO_ART FROM STOCK S ,LOCATION L WHERE L.INV_STAT=? AND S.SITE_CODE=? " + "S.NO_ART FROM STOCK S ,LOCATION L WHERE L.INV_STAT=? AND S.SITE_CODE=? " +
"AND S.LOC_CODE=L.LOC_CODE AND S.QUANTITY>0 "; "AND S.LOC_CODE=L.LOC_CODE AND S.QUANTITY>0 ";
*/ */
sql="SELECT DISTINCT S.LOC_CODE AS PALLET_NO,S.ITEM_CODE,S.LOT_NO,S.LOT_SL,S.QUANTITY, S.NO_ART FROM STOCK S " + /*sql="SELECT DISTINCT S.LOC_CODE AS PALLET_NO,S.ITEM_CODE,S.LOT_NO,S.LOT_SL,S.QUANTITY, S.NO_ART FROM STOCK S " +
"WHERE S.INV_STAT = ? AND S.SITE_CODE= ? AND S.QUANTITY > 0 AND S.QTY_PER_ART > 0 AND S.NO_ART > 0" + "WHERE S.INV_STAT = ? AND S.SITE_CODE= ? AND S.QUANTITY > 0 AND S.QTY_PER_ART > 0 AND S.NO_ART > 0" +
"UNION ALL " + "UNION ALL " +
"SELECT DISTINCT SUBSTR(S.LOC_CODE,1,INSTR(S.LOC_CODE,'Q')-1),S.ITEM_CODE,S.LOT_NO,S.LOT_SL,S.QUANTITY, S.NO_ART FROM STOCK S WHERE " + "SELECT DISTINCT SUBSTR(S.LOC_CODE,1,INSTR(S.LOC_CODE,'Q')-1),S.ITEM_CODE,S.LOT_NO,S.LOT_SL,S.QUANTITY, S.NO_ART FROM STOCK S WHERE " +
"S.INV_STAT = ? AND S.SITE_CODE= ? AND S.QUANTITY > 0 AND S.QTY_PER_ART > 0 AND S.NO_ART > 0"; "S.INV_STAT = ? AND S.SITE_CODE= ? AND S.QUANTITY > 0 AND S.QTY_PER_ART > 0 AND S.NO_ART > 0";
*/
sql = "SELECT S.LOC_CODE AS PALLET_NO,S.ITEM_CODE,S.LOT_NO,S.LOT_SL,S.QUANTITY, S.NO_ART FROM STOCK S " +
"WHERE S.INV_STAT = ? AND S.SITE_CODE= ? AND S.QTY_PER_ART > 0 AND S.QUANTITY >0 AND S.NO_ART >0 " +
" and FN_CHK_PRS(S.LOC_CODE) = 0 UNION ALL SELECT SUBSTR(S.LOC_CODE,1,INSTR(S.LOC_CODE,'Q')-1),S.ITEM_CODE," +
"S.LOT_NO,S.LOT_SL,S.QUANTITY, S.NO_ART FROM STOCK S WHERE S.INV_STAT = ? AND S.SITE_CODE= ? " +
" AND S.QTY_PER_ART > 0 AND S.QUANTITY>0 AND S.NO_ART >0 and " +
"FN_CHK_PRS(SUBSTR(S.LOC_CODE,1,INSTR(S.LOC_CODE,'Q')-1)) = 0";
PreparedStatement pstmt = conn.prepareStatement(sql); PreparedStatement pstmt = conn.prepareStatement(sql);
pstmt.setString(1, "AWMS"); pstmt.setString(1, "AWMS");
pstmt.setString(2, siteCode); pstmt.setString(2, siteCode);
pstmt.setString(3, "AWMSQ"); pstmt.setString(3, "AWMSQ");
pstmt.setString(4, siteCode); pstmt.setString(4, siteCode);
ResultSet rs = pstmt.executeQuery(); ResultSet rs = pstmt.executeQuery();
while(rs.next()) while (rs.next())
{ {
palletNo = checkNullAndTrim(rs.getString("PALLET_NO")); palletNo = checkNullAndTrim(rs.getString("PALLET_NO"));
itemCode = checkNullAndTrim(rs.getString("ITEM_CODE")); itemCode = checkNullAndTrim(rs.getString("ITEM_CODE"));
lotNo = checkNullAndTrim(rs.getString("LOT_NO")); lotNo = checkNullAndTrim(rs.getString("LOT_NO"));
...@@ -350,42 +383,42 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp ...@@ -350,42 +383,42 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp
rs.close(); rs.close();
pstmt.close(); pstmt.close();
} }
catch (SQLException sqx) catch (SQLException sqx)
{ {
System.out.println("The sqlException occure in PalletReqExpiryAct :" + sqx); System.out.println("The sqlException occure in PalletReqExpiryAct :" + sqx);
throw new ITMException(sqx); throw new ITMException(sqx);
} }
catch (Exception e) catch (Exception e)
{ {
System.out.println("The Exception occure in PalletReqExpiryAct :" + e); System.out.println("The Exception occure in PalletReqExpiryAct :" + e);
throw new ITMException(e); throw new ITMException(e);
} }
finally finally
{ {
try try
{ {
conn.close(); conn.close();
conn = null; conn = null;
} }
catch (Exception e) catch (Exception localException1)
{ {
} }
} }
return xmlString.toString(); return xmlString.toString();
} }
//Changed for pallet request with stock detail [End]Request Id:W15HSUN003
private String checkNull( String input ) private String checkNull(String input)
{ {
if ( input == null ) if (input == null)
{ {
input = ""; input = "";
} }
return input.trim(); return input.trim();
} }
private String checkNullAndTrim( String inputVal ) private String checkNullAndTrim(String inputVal)
{ {
if ( inputVal == null ) if (inputVal == null)
{ {
inputVal = ""; inputVal = "";
} }
...@@ -395,6 +428,4 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp ...@@ -395,6 +428,4 @@ public class PalletReqExpiryAct extends ActionHandlerEJB implements PalletReqExp
} }
return inputVal; return inputVal;
} }
} }
\ No newline at end of file
webitm-wms/ibase/webitm/ejb/wms/PalletReqIC.java
View file @ 244e7cf7
...@@ -108,7 +108,7 @@ public class PalletReqIC extends ValidatorEJB implements PalletReqICLocal, Palle ...@@ -108,7 +108,7 @@ public class PalletReqIC extends ValidatorEJB implements PalletReqICLocal, Palle
GenericUtility genericUtility; GenericUtility genericUtility;
String remarks="",addUser="",addTerm="",addDate="",chgUser="",chgTerm="",chgDate="",descr="" , sql1=""; String remarks="",addUser="",addTerm="",addDate="",chgUser="",chgTerm="",chgDate="",descr="" , sql1="";
int lotSlcnt=0,lotNocnt=0,itemCodecnt=0,locCodecnt=0,itemCodecntQ=0,lotNocntQ=0,lotSlcntQ=0; int lotSlcnt=0,lotNocnt=0,itemCodecnt=0,locCodecnt=0,itemCodecntQ=0,lotNocntQ=0,lotSlcntQ=0;
double quantity=0,noArt=0,qtyPerArt,noArtQuot=0,noArtRem =0 , notArt = 0; double quantity=0,noArt=0,qtyPerArt,noArtQuot=0,noArtRem =0 , notArt = 0,palTcnt=0;
int locCount = 0; int locCount = 0;
String quantityStr="",noArtStr=""; String quantityStr="",noArtStr="";
ResultSet rs= null ,rsQ = null; ResultSet rs= null ,rsQ = null;
...@@ -131,7 +131,7 @@ public class PalletReqIC extends ValidatorEJB implements PalletReqICLocal, Palle ...@@ -131,7 +131,7 @@ public class PalletReqIC extends ValidatorEJB implements PalletReqICLocal, Palle
genericUtility = GenericUtility.getInstance(); genericUtility = GenericUtility.getInstance();
System.out.println("xtraParam----->>["+xtraParams+"]"); System.out.println("xtraParam----->>["+xtraParams+"]");
loginSite = checkNull(genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginSiteCode" )); loginSite = checkNull(genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginSiteCode" ));
ConnDriver connDriver = new ConnDriver(); ConnDriver connDriver = new ConnDriver();
...@@ -290,23 +290,16 @@ public class PalletReqIC extends ValidatorEJB implements PalletReqICLocal, Palle ...@@ -290,23 +290,16 @@ public class PalletReqIC extends ValidatorEJB implements PalletReqICLocal, Palle
} }
else else
{ {
sql = "SELECT COUNT(1) FROM LOCATION WHERE INV_STAT IN (?,?) AND LOC_CODE IN (?,?) AND SITE_CODE=?"; sql = "SELECT COUNT(1) FROM LOCATION WHERE INV_STAT = ? AND LOC_CODE =? AND SITE_CODE=?";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, "AWMS"); pstmt.setString(1, "AWMS");
pstmt.setString(2, "AWMSQ"); //pstmt.setString(2, "AWMSQ");
pstmt.setString(3, palletNo); pstmt.setString(2, palletNo);
pstmt.setString(4, palletNo+"Q"); //pstmt.setString(4, palletNo+"Q");
pstmt.setString(5, loginSite); pstmt.setString(3, loginSite);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if(rs.next()) if(rs.next()){ cntLoc = rs.getInt(1);}
{ if(pstmt != null){pstmt.close();pstmt = null;}
cntLoc = rs.getInt(1);
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(rs != null) if(rs != null)
{ {
rs.close(); rs.close();
...@@ -314,15 +307,67 @@ public class PalletReqIC extends ValidatorEJB implements PalletReqICLocal, Palle ...@@ -314,15 +307,67 @@ public class PalletReqIC extends ValidatorEJB implements PalletReqICLocal, Palle
} }
if(cntLoc == 0) if(cntLoc == 0)
{ {
sqlQ = "SELECT COUNT(1) FROM LOCATION WHERE INV_STAT = ? AND LOC_CODE =? AND SITE_CODE=?";
pstmtQ = conn.prepareStatement(sqlQ);
pstmtQ.setString(1, "AWMSQ");
pstmtQ.setString(2, palletNo+"Q");
pstmtQ.setString(3, loginSite);
rsQ = pstmtQ.executeQuery();
if(rsQ.next())
{
palcntQ = rsQ.getInt(1);
System.out.println("AWMSQ PALLET" +palletNo+"Q");
if(palcntQ==0)
{
System.out.println("awmsQ pallet count" +palcntQ);
errCode = "VMPALLEEXT";//pallet quantity should be more than zero
errList.add( errCode );
errFields.add( childNodeName.toLowerCase() );
break;
}
}
if(pstmtQ != null)
{
pstmtQ.close();
pstmtQ = null;
}
if(rsQ != null)
{
rsQ.close();
rsQ = null;
}
errCode = "VMPALLEEXT";//pallet no should be in LOCATION MASTER errCode = "VMPALLEEXT";//pallet no should be in LOCATION MASTER
errList.add( errCode ); errList.add( errCode );
errFields.add( childNodeName.toLowerCase() ); errFields.add( childNodeName.toLowerCase() );
break; break;
} }
//Changed for pallet request with stock details [Start]Request Id:W15HSUN003 //Changed for pallet request with stock details [Start]Request Id:W15HSUN003
if("pallet_req_stk".equalsIgnoreCase(objName))
if ("pallet_req_stk".equalsIgnoreCase(objName))
{ {
if(isRecordExist(dom2)) sql = "select fn_chk_prs(trim(?)) from dual ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, palletNo);
rs = pstmt.executeQuery();
if (rs.next())
{
palTcnt = rs.getInt(1);
}
if (pstmt != null) { pstmt.close(); pstmt = null; }
if (rs != null) { rs.close(); rs = null; }
if (palTcnt > 0)
{
System.out.println("PRESENT IN SWMS FOR DETAILS" + palTcnt);
errCode = "VMPALDEPEX";
errList.add(errCode);
errFields.add(childNodeName.toLowerCase());
break;
}
else if(isRecordExist(dom2))
{ {
System.out.println("pallet detail exist"); System.out.println("pallet detail exist");
errCode = "VMPALDETEX";//pallet details already exits errCode = "VMPALDETEX";//pallet details already exits
...@@ -334,6 +379,26 @@ public class PalletReqIC extends ValidatorEJB implements PalletReqICLocal, Palle ...@@ -334,6 +379,26 @@ public class PalletReqIC extends ValidatorEJB implements PalletReqICLocal, Palle
//Changed for pallet request with stock details [End]Request Id:W15HSUN003 //Changed for pallet request with stock details [End]Request Id:W15HSUN003
else else
{ {
sql = "select fn_chk_prs(trim(?)) from dual ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, palletNo);
rs = pstmt.executeQuery();
if (rs.next())
{
palTcnt = rs.getInt(1);
}
if (pstmt != null) { pstmt.close(); pstmt = null; }
if (rs != null) { rs.close(); rs = null; }
if (palTcnt > 0)
{
System.out.println("PRESENT IN SWMS" + palTcnt);
errCode = "VMPALDCOEX";
errList.add(errCode);
errFields.add(childNodeName.toLowerCase());
break;
}
//System.out.println("IN PALLET REQUEST EDIT FLAG"); //System.out.println("IN PALLET REQUEST EDIT FLAG");
palletList = checkDuplicaterecord(dom2); palletList = checkDuplicaterecord(dom2);
Set s = new HashSet(palletList); Set s = new HashSet(palletList);
...@@ -784,8 +849,8 @@ public class PalletReqIC extends ValidatorEJB implements PalletReqICLocal, Palle ...@@ -784,8 +849,8 @@ public class PalletReqIC extends ValidatorEJB implements PalletReqICLocal, Palle
quantity = Double.parseDouble(quantityStr); quantity = Double.parseDouble(quantityStr);
System.out.println("quantity from dom>>>>>>>" +quantity); System.out.println("quantity from dom>>>>>>>" +quantity);
System.out.println("quantityStr from dom>>>>>>>" +quantityStr); System.out.println("quantityStr from dom>>>>>>>" +quantityStr);
if(quantity == 0 ) if(quantity == 0 )
{ {
...@@ -1224,7 +1289,7 @@ public class PalletReqIC extends ValidatorEJB implements PalletReqICLocal, Palle ...@@ -1224,7 +1289,7 @@ public class PalletReqIC extends ValidatorEJB implements PalletReqICLocal, Palle
} }
else else
{ {
valueXmlString.append( "<quantity><![CDATA[" ).append( 0 ).append( "]]></quantity>\r\n" ); valueXmlString.append( "<quantity><![CDATA[" ).append( 0 ).append( "]]></quantity>\r\n" );
valueXmlString.append( "<no_art><![CDATA[" ).append( 0 ).append( "]]></no_art>\r\n" ); valueXmlString.append( "<no_art><![CDATA[" ).append( 0 ).append( "]]></no_art>\r\n" );
} }
......
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