Skip to content

B
business-java
Commit 235cbef3 authored by rtiwari's avatar rtiwari
Browse files
Options

add source received from sun (Sankara)on 06/DEC/13 for Issue Tracker No-303 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@93953 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 4da10088
Hide whitespace changes
Inline Side-by-side
Showing with 594 additions and 593 deletions
webitm-wms/ibase/webitm/ejb/wms/PickOrderPrc.java
View file @ 235cbef3
package ibase.webitm.ejb.wms; package ibase.webitm.ejb.wms;
import ibase.system.config.ConnDriver; import ibase.system.config.ConnDriver;
import ibase.webitm.ejb.ITMDBAccessEJB; import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ProcessEJB; import ibase.webitm.ejb.ProcessEJB;
import ibase.webitm.ejb.dis.DistCommon; import ibase.webitm.ejb.dis.DistCommon;
import ibase.webitm.utility.GenericUtility; import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException; import ibase.webitm.utility.ITMException;
import java.net.URL; import java.net.URL;
import java.rmi.RemoteException; import java.rmi.RemoteException;
import java.sql.Connection; import java.sql.Connection;
import java.sql.PreparedStatement; import java.sql.PreparedStatement;
import java.sql.ResultSet; import java.sql.ResultSet;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.Calendar; import java.util.Calendar;
import java.util.Date; import java.util.Date;
import java.util.HashMap; import java.util.HashMap;
import java.util.Iterator; import java.util.Iterator;
import java.util.Set; import java.util.Set;
import java.util.ArrayList; import java.util.ArrayList;
import org.w3c.dom.Document; import org.w3c.dom.Document;
import org.w3c.dom.Node; import org.w3c.dom.Node;
import org.w3c.dom.NodeList; import org.w3c.dom.NodeList;
import com.adsionline.ADSIShippingWS.ADSIShippingLocator; import com.adsionline.ADSIShippingWS.ADSIShippingLocator;
import com.adsionline.ADSIShippingWS.ADSIShippingSoap; import com.adsionline.ADSIShippingWS.ADSIShippingSoap;
import com.adsionline.ADSIShippingWS.StringDictionaryReturn; import com.adsionline.ADSIShippingWS.StringDictionaryReturn;
@javax.ejb.Stateless @javax.ejb.Stateless
public class PickOrderPrc extends ProcessEJB implements PickOrderPrcLocal,PickOrderPrcRemote public class PickOrderPrc extends ProcessEJB implements PickOrderPrcLocal,PickOrderPrcRemote
{ {
public String getData(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException public String getData(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException
{ {
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
System.out.println("INSIDE GET DATA"); System.out.println("INSIDE GET DATA");
String rtrStr = ""; String rtrStr = "";
Document headerDom = null; Document headerDom = null;
Document detailDom = null; Document detailDom = null;
System.out.println("getData(xmlString,xmlString2,windowName,xtraParams CALLED..."+ xmlString); System.out.println("getData(xmlString,xmlString2,windowName,xtraParams CALLED..."+ xmlString);
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);
headerDom = genericUtility.parseString(xmlString); headerDom = genericUtility.parseString(xmlString);
} }
if(xmlString2 != null && xmlString2.trim().length()!=0) if(xmlString2 != null && xmlString2.trim().length()!=0)
{ {
System.out.println("XML String :"+xmlString2); System.out.println("XML String :"+xmlString2);
detailDom = genericUtility.parseString(xmlString2); detailDom = genericUtility.parseString(xmlString2);
} }
rtrStr = getData(headerDom, detailDom, windowName, xtraParams); rtrStr = getData(headerDom, detailDom, windowName, xtraParams);
} }
catch (Exception e) catch (Exception e)
{ {
System.out.println("Exception :PickOrderPrcEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":"); System.out.println("Exception :PickOrderPrcEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":");
rtrStr = e.getMessage(); rtrStr = e.getMessage();
} }
return rtrStr; return rtrStr;
} }
public String getData(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException public String getData(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException
{ {
String fromDate = ""; String fromDate = "";
String toDate=""; String toDate="";
String waveId = ""; String waveId = "";
String saleOrder = ""; String saleOrder = "";
String pickOrder = ""; String pickOrder = "";
String assingTo = ""; String assingTo = "";
String status = ""; String status = "";
String ptcn = ""; String ptcn = "";
String pickOrderFrom = ""; String pickOrderFrom = "";
String pickOrderTo = ""; String pickOrderTo = "";
String orderDate = ""; String orderDate = "";
String errCode = ""; String errCode = "";
String errString = ""; String errString = "";
//changed by sankara on 28/09/13 for getting repl_order start. //changed by sankara on 28/09/13 for getting repl_order start.
String pickreplStatus = ""; String pickreplStatus = "";
String sql = ""; String sql = "";
int count = 0; int count = 0;
//changed by sankara on 28/09/13 for getting repl_order end. //changed by sankara on 28/09/13 for getting repl_order end.
PreparedStatement pstmt=null; PreparedStatement pstmt=null;
String getDataSql=null; String getDataSql=null;
String resultString = ""; String resultString = "";
Connection conn = null; Connection conn = null;
ResultSet rs=null; ResultSet rs=null;
boolean rsflag=false; boolean rsflag=false;
java.sql.Timestamp dateFr = null; java.sql.Timestamp dateFr = null;
java.sql.Timestamp dateTo = null; java.sql.Timestamp dateTo = null;
StringBuffer valueXmlString=new StringBuffer(); StringBuffer valueXmlString=new StringBuffer();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB(); ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
valueXmlString = new StringBuffer( "<?xml version='1.0' encoding='UTF-8'?>\r\n<DocumentRoot>\r\n<description>Datawindow Root</description>\r\n<group0>\r\n" + valueXmlString = new StringBuffer( "<?xml version='1.0' encoding='UTF-8'?>\r\n<DocumentRoot>\r\n<description>Datawindow Root</description>\r\n<group0>\r\n" +
"<description>Group0 description</description>\r\n<Header0>\r\n<description>Header0 members</description>\r\n"); "<description>Group0 description</description>\r\n<Header0>\r\n<description>Header0 members</description>\r\n");
try try
{ {
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
ConnDriver connDriver = new ConnDriver(); ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM"); conn = connDriver.getConnectDB("DriverITM");
connDriver = null; connDriver = null;
String userId = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginCode" ); String userId = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginCode" );
pickOrderFrom = checkNull(genericUtility.getColumnValue("pick_order_from",headerDom)); pickOrderFrom = checkNull(genericUtility.getColumnValue("pick_order_from",headerDom));
System.out.println("PICKORDERFROM==="+pickOrderFrom); System.out.println("PICKORDERFROM==="+pickOrderFrom);
pickOrderTo = checkNull(genericUtility.getColumnValue("pick_order_to",headerDom)); pickOrderTo = checkNull(genericUtility.getColumnValue("pick_order_to",headerDom));
System.out.println("PICKORDERTO==="+pickOrderTo); System.out.println("PICKORDERTO==="+pickOrderTo);
fromDate = checkNull(genericUtility.getColumnValue("from_date",headerDom)); fromDate = checkNull(genericUtility.getColumnValue("from_date",headerDom));
System.out.println("FROMDATE==="+fromDate); System.out.println("FROMDATE==="+fromDate);
toDate = checkNull(genericUtility.getColumnValue("to_date",headerDom)); toDate = checkNull(genericUtility.getColumnValue("to_date",headerDom));
System.out.println("TODATE==="+toDate); System.out.println("TODATE==="+toDate);
//changed by sankara on 28/09/13 for getting unconfirmed repl_orders start. //changed by sankara on 28/09/13 for getting unconfirmed repl_orders start.
pickreplStatus = checkNull(genericUtility.getColumnValue("status",headerDom)); pickreplStatus = checkNull(genericUtility.getColumnValue("status",headerDom));
System.out.println("PICKREPLSTATUS==="+pickreplStatus); System.out.println("PICKREPLSTATUS==="+pickreplStatus);
//changed by sankara on 28/09/13 for getting unconfirmed repl_orders end. //changed by sankara on 28/09/13 for getting unconfirmed repl_orders end.
System.out.println("headerDom:"+headerDom); System.out.println("headerDom:"+headerDom);
System.out.println("detailDom:"+detailDom); System.out.println("detailDom:"+detailDom);
System.out.println("windowName:"+windowName); System.out.println("windowName:"+windowName);
System.out.println("xtraParams:"+xtraParams); System.out.println("xtraParams:"+xtraParams);
if ( fromDate == null || fromDate.trim().length() == 0 ) if ( fromDate == null || fromDate.trim().length() == 0 )
{ {
errCode = "VPFROMBTBK"; errCode = "VPFROMBTBK";
errString = itmDBAccessEJB.getErrorString("","VPFROMBTBK",userId); errString = itmDBAccessEJB.getErrorString("","VPFROMBTBK",userId);
return errString; return errString;
} }
fromDate = genericUtility.getValidDateString(fromDate, genericUtility.getApplDateFormat(), genericUtility.getDBDateFormat()); fromDate = genericUtility.getValidDateString(fromDate, genericUtility.getApplDateFormat(), genericUtility.getDBDateFormat());
System.out.println("FROMDATE==="+fromDate); System.out.println("FROMDATE==="+fromDate);
dateFr = java.sql.Timestamp.valueOf(fromDate + " 00:00:00"); dateFr = java.sql.Timestamp.valueOf(fromDate + " 00:00:00");
if ( toDate == null || toDate.trim().length() == 0 ) if ( toDate == null || toDate.trim().length() == 0 )
{ {
errCode = "VPTODADTBK"; errCode = "VPTODADTBK";
errString = itmDBAccessEJB.getErrorString("","VPTODADTBK",userId); errString = itmDBAccessEJB.getErrorString("","VPTODADTBK",userId);
return errString; return errString;
} }
toDate = genericUtility.getValidDateString(toDate, genericUtility.getApplDateFormat(), genericUtility.getDBDateFormat()); toDate = genericUtility.getValidDateString(toDate, genericUtility.getApplDateFormat(), genericUtility.getDBDateFormat());
System.out.println("TODATE==="+toDate); System.out.println("TODATE==="+toDate);
dateTo = java.sql.Timestamp.valueOf(toDate + " 00:00:00"); dateTo = java.sql.Timestamp.valueOf(toDate + " 00:00:00");
int i = toDate.compareTo(fromDate); int i = toDate.compareTo(fromDate);
System.out.println("DATEVALIDATE==="+i); System.out.println("DATEVALIDATE==="+i);
orderDate = Integer.toString(i); orderDate = Integer.toString(i);
if(orderDate.contains("-")) if(orderDate.contains("-"))
{ {
errCode = "VPINVLDATE"; errCode = "VPINVLDATE";
errString = itmDBAccessEJB.getErrorString("","VPINVLDATE",userId); errString = itmDBAccessEJB.getErrorString("","VPINVLDATE",userId);
return errString; return errString;
} }
//changed by sankara on 28/09/13 for getting unconfirmed repl_orders start. //changed by sankara on 28/09/13 for getting unconfirmed repl_orders start.
if ( pickreplStatus == null || pickreplStatus.trim().length() == 0 ) if ( pickreplStatus == null || pickreplStatus.trim().length() == 0 )
{ {
System.out.println("PICKREPLSTATUS="+pickreplStatus); System.out.println("PICKREPLSTATUS="+pickreplStatus);
errCode = "VPBLKSTAUS"; errCode = "VPBLKSTAUS";
errString = itmDBAccessEJB.getErrorString("","VPBLKSTAUS",userId); errString = itmDBAccessEJB.getErrorString("","VPBLKSTAUS",userId);
return errString; return errString;
} }
else if(pickreplStatus != null || pickreplStatus.trim().length() != 0) else if(pickreplStatus != null || pickreplStatus.trim().length() != 0)
{ {
sql = " SELECT COUNT(*) FROM GENCODES WHERE FLD_NAME = 'STATUS' AND MOD_NAME = 'W_PICK_ASSIGNTO' AND FLD_VALUE = ? "; sql = " SELECT COUNT(*) FROM GENCODES WHERE FLD_NAME = 'STATUS' AND MOD_NAME = 'W_PICK_ASSIGNTO' AND FLD_VALUE = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1,pickreplStatus); pstmt.setString(1,pickreplStatus);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if(rs.next()) if(rs.next())
{ {
count = rs.getInt(1); count = rs.getInt(1);
} }
if(count == 0) if(count == 0)
{ {
errCode = "VPINVSTAUS"; errCode = "VPINVSTAUS";
errString = itmDBAccessEJB.getErrorString("","VPINVSTAUS",userId); errString = itmDBAccessEJB.getErrorString("","VPINVSTAUS",userId);
return errString; return errString;
} }
rs.close(); rs.close();
rs = null; rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
} }
/* getDataSql = " SELECT DISTINCT P.PICK_ORDER, P.SALE_ORDER, P.WAVE_ID, WD.PTCN, P.ASSIGN_TO, P.STATUS " + /* getDataSql = " SELECT DISTINCT P.PICK_ORDER, P.SALE_ORDER, P.WAVE_ID, WD.PTCN, P.ASSIGN_TO, P.STATUS " +
" FROM PICK_ORD_HDR P, WAVE_TASK W, WAVE_TASK_DET WD, PICK_ISS_HDR PH, PICK_ORD_DET PT " + " FROM PICK_ORD_HDR P, WAVE_TASK W, WAVE_TASK_DET WD, PICK_ISS_HDR PH, PICK_ORD_DET PT " +
" WHERE P.PICK_ORDER = WD.REF_ID AND P.PICK_ORDER = PT.PICK_ORDER AND P.WAVE_ID = W.WAVE_ID " + " WHERE P.PICK_ORDER = WD.REF_ID AND P.PICK_ORDER = PT.PICK_ORDER AND P.WAVE_ID = W.WAVE_ID " +
// changed by sankara on 05-sep-13 for getting pick order start. // changed by sankara on 05-sep-13 for getting pick order start.
//"AND P.WAVE_ID = WD.WAVE_ID AND P.PICK_ORDER = PH.PICK_ORDER AND WD.STATUS = 'N' AND W.CANCEL = 'N' " + //"AND P.WAVE_ID = WD.WAVE_ID AND P.PICK_ORDER = PH.PICK_ORDER AND WD.STATUS = 'N' AND W.CANCEL = 'N' " +
// "AND PH.CONFIRMED = 'N' AND P.PICK_ORDER BETWEEN ? AND ? AND P.ORDER_DATE BETWEEN ? AND ? " ; // "AND PH.CONFIRMED = 'N' AND P.PICK_ORDER BETWEEN ? AND ? AND P.ORDER_DATE BETWEEN ? AND ? " ;
"AND P.WAVE_ID = WD.WAVE_ID AND WD.STATUS = 'N' AND W.CANCEL = 'N' " + "AND P.WAVE_ID = WD.WAVE_ID AND WD.STATUS = 'N' AND W.CANCEL = 'N' " +
"AND ( PH.CONFIRMED = 'N' OR PH.PICK_ORDER IS NULL ) AND P.PICK_ORDER BETWEEN ? AND ? AND P.ORDER_DATE BETWEEN ? AND ? " ; "AND ( PH.CONFIRMED = 'N' OR PH.PICK_ORDER IS NULL ) AND P.PICK_ORDER BETWEEN ? AND ? AND P.ORDER_DATE BETWEEN ? AND ? " ;
// changed by sankara on 05-sep-13 for getting pick order end. */ // changed by sankara on 05-sep-13 for getting pick order end. */
if( pickreplStatus.trim().equalsIgnoreCase("P") ) if( pickreplStatus.trim().equalsIgnoreCase("P") )
{ {
getDataSql = " SELECT DISTINCT P.PICK_ORDER, P.SALE_ORDER, P.WAVE_ID, WD.PTCN, P.ASSIGN_TO, P.STATUS " + getDataSql = " SELECT DISTINCT P.PICK_ORDER, P.SALE_ORDER, P.WAVE_ID, WD.PTCN, P.ASSIGN_TO, P.STATUS " +
" FROM PICK_ORD_HDR P, WAVE_TASK W, WAVE_TASK_DET WD, PICK_ISS_HDR PH, PICK_ORD_DET PT " + " FROM PICK_ORD_HDR P, WAVE_TASK W, WAVE_TASK_DET WD, PICK_ISS_HDR PH, PICK_ORD_DET PT " +
" WHERE P.PICK_ORDER = WD.REF_ID AND P.PICK_ORDER = PT.PICK_ORDER AND P.WAVE_ID = W.WAVE_ID " + " WHERE P.PICK_ORDER = WD.REF_ID AND P.PICK_ORDER = PT.PICK_ORDER AND P.WAVE_ID = W.WAVE_ID " +
" AND P.WAVE_ID = WD.WAVE_ID AND WD.STATUS = 'N' AND W.CANCEL = 'N' " + " AND P.WAVE_ID = WD.WAVE_ID AND WD.STATUS = 'N' AND W.CANCEL = 'N' " +
" AND ( PH.CONFIRMED = 'N' OR PH.PICK_ORDER IS NULL ) AND P.PICK_ORDER BETWEEN ? AND ? AND P.ORDER_DATE BETWEEN ? AND ? " ; " AND ( PH.CONFIRMED = 'N' OR PH.PICK_ORDER IS NULL ) AND P.PICK_ORDER BETWEEN ? AND ? AND P.ORDER_DATE BETWEEN ? AND ? " ;
} }
else else
{ {
getDataSql = " SELECT DISTINCT R.REPL_ORDER, R.SALE_ORDER, R.WAVE_ID, WD.PTCN, R.ASSIGN_TO, WD.WAVE_STATUS " + getDataSql = " SELECT DISTINCT R.REPL_ORDER, R.SALE_ORDER, R.WAVE_ID, WD.PTCN, R.ASSIGN_TO, WD.WAVE_STATUS " +
" FROM REPL_ORD_HDR R, WAVE_TASK W, WAVE_TASK_DET WD, REPL_ISS_HDR RH, REPL_ORD_DET RT " + " FROM REPL_ORD_HDR R, WAVE_TASK W, WAVE_TASK_DET WD, REPL_ISS_HDR RH, REPL_ORD_DET RT " +
" WHERE R.REPL_ORDER = WD.REF_ID AND R.REPL_ORDER = RT.REPL_ORDER AND R.WAVE_ID = W.WAVE_ID " + " WHERE R.REPL_ORDER = WD.REF_ID AND R.REPL_ORDER = RT.REPL_ORDER AND R.WAVE_ID = W.WAVE_ID " +
" AND R.WAVE_ID = WD.WAVE_ID AND WD.STATUS = 'N' AND W.CANCEL = 'N' AND ( RT.CANCEL_MODE='N' OR RT.CANCEL_MODE IS NULL ) " + " AND R.WAVE_ID = WD.WAVE_ID AND WD.STATUS = 'N' AND W.CANCEL = 'N' AND ( RT.CANCEL_MODE='N' OR RT.CANCEL_MODE IS NULL ) " +
" AND ( RH.CONFIRMED = 'N' OR RH.REPL_ORDER IS NULL ) AND R.REPL_ORDER BETWEEN ? AND ? AND R.ORDER_DATE BETWEEN ? AND ? " ; " AND ( RH.CONFIRMED = 'N' OR RH.REPL_ORDER IS NULL ) AND R.REPL_ORDER BETWEEN ? AND ? AND R.ORDER_DATE BETWEEN ? AND ? " ;
} }
//changed by sankara on 28/09/13 for getting unconfirmed repl_orders end. //changed by sankara on 28/09/13 for getting unconfirmed repl_orders end.
System.out.println("**************getDataSql="+getDataSql); System.out.println("**************getDataSql="+getDataSql);
pstmt = conn.prepareStatement(getDataSql); pstmt = conn.prepareStatement(getDataSql);
pstmt.setString(1,pickOrderFrom); pstmt.setString(1,pickOrderFrom);
pstmt.setString(2,pickOrderTo); pstmt.setString(2,pickOrderTo);
pstmt.setTimestamp(3,dateFr); pstmt.setTimestamp(3,dateFr);
pstmt.setTimestamp(4,dateTo); pstmt.setTimestamp(4,dateTo);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
rsflag=false; rsflag=false;
while(rs.next()) while(rs.next())
{ {
rsflag=true; rsflag=true;
valueXmlString.append( "<Detail2>\r\n" ); valueXmlString.append( "<Detail2>\r\n" );
pickOrder = checkNull(rs.getString(1)); pickOrder = checkNull(rs.getString(1));
saleOrder = checkNull(rs.getString(2)); saleOrder = checkNull(rs.getString(2));
waveId = checkNull(rs.getString(3)); waveId = checkNull(rs.getString(3));
ptcn = checkNull(rs.getString(4)); ptcn = checkNull(rs.getString(4));
assingTo = checkNull(rs.getString(5)); assingTo = checkNull(rs.getString(5));
status = checkNull(rs.getString(6)); status = checkNull(rs.getString(6));
valueXmlString.append( "<pick_order><![CDATA[" ).append(pickOrder).append( "]]></pick_order>\r\n" ); valueXmlString.append( "<pick_order><![CDATA[" ).append(pickOrder).append( "]]></pick_order>\r\n" );
valueXmlString.append( "<sale_order><![CDATA[" ).append (saleOrder).append( "]]></sale_order>\r\n" ); valueXmlString.append( "<sale_order><![CDATA[" ).append (saleOrder).append( "]]></sale_order>\r\n" );
valueXmlString.append( "<wave_id><![CDATA[" ).append( waveId ).append( "]]></wave_id>\r\n" ); valueXmlString.append( "<wave_id><![CDATA[" ).append( waveId ).append( "]]></wave_id>\r\n" );
valueXmlString.append( "<ptcn><![CDATA[" ).append(ptcn).append( "]]></ptcn>\r\n" ); valueXmlString.append( "<ptcn><![CDATA[" ).append(ptcn).append( "]]></ptcn>\r\n" );
valueXmlString.append( "<assign_to><![CDATA[" ).append(assingTo).append( "]]></assign_to>\r\n" ); valueXmlString.append( "<assign_to><![CDATA[" ).append(assingTo).append( "]]></assign_to>\r\n" );
valueXmlString.append( "<status><![CDATA[" ).append(status).append( "]]></status>\r\n" ); //changed by sankara on 06/12/13 for getting unconfirmed repl_orders
//changed by sankara on 28/09/13 for getting unconfirmed repl_orders start. //valueXmlString.append( "<status><![CDATA[" ).append(status).append( "]]></status>\r\n" );
valueXmlString.append( "<pick_repl_status><![CDATA[" ).append(pickreplStatus).append( "]]></pick_repl_status>\r\n" ); //changed by sankara on 28/09/13 for getting unconfirmed repl_orders start.
//changed by sankara on 28/09/13 for getting unconfirmed repl_orders end. valueXmlString.append( "<pick_repl_status><![CDATA[" ).append(pickreplStatus).append( "]]></pick_repl_status>\r\n" );
valueXmlString.append("\n"); //changed by sankara on 28/09/13 for getting unconfirmed repl_orders end.
valueXmlString.append( "</Detail2>\r\n" ); valueXmlString.append("\n");
} valueXmlString.append( "</Detail2>\r\n" );
valueXmlString.append( "</Header0>\r\n</group0>\r\n</DocumentRoot>\r\n" ); }
resultString=valueXmlString.toString(); valueXmlString.append( "</Header0>\r\n</group0>\r\n</DocumentRoot>\r\n" );
resultString=valueXmlString.toString();
if(rsflag == false)
{ if(rsflag == false)
errCode = "VPINVLDATA"; {
errString = itmDBAccessEJB.getErrorString("","VPINVLDATA",userId); errCode = "VPINVLDATA";
return errString; errString = itmDBAccessEJB.getErrorString("","VPINVLDATA",userId);
} return errString;
rs.close(); }
rs = null; rs.close();
pstmt.close(); rs = null;
pstmt = null; pstmt.close();
} pstmt = null;
catch(Exception e) }
{ catch(Exception e)
System.out.println("Exception occured while getData()"); {
e.printStackTrace(); System.out.println("Exception occured while getData()");
} e.printStackTrace();
finally }
{ finally
try {
{ try
if(conn != null) {
{ if(conn != null)
if(rs != null) {
{ if(rs != null)
rs.close(); {
rs = null; rs.close();
} rs = null;
if(pstmt != null) }
{ if(pstmt != null)
pstmt.close(); {
pstmt = null; pstmt.close();
} pstmt = null;
conn.close(); }
} conn.close();
conn = null; }
} conn = null;
catch(Exception ex) }
{ catch(Exception ex)
System.out.println("Exception occured while getData()"); {
ex.printStackTrace(); System.out.println("Exception occured while getData()");
} ex.printStackTrace();
} }
return resultString; }
} //get data method closed return resultString;
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException } //get data method closed
{ public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException
String retStr = ""; {
Document detailDom = null; String retStr = "";
Document headerDom = null; Document detailDom = null;
Document headerDom = null;
GenericUtility genericUtility = GenericUtility.getInstance();
System.out.println("***Testing Process Method***"); GenericUtility genericUtility = GenericUtility.getInstance();
System.out.println("below genericUtility--------------->>>>>>>>>"); System.out.println("***Testing Process Method***");
try System.out.println("below genericUtility--------------->>>>>>>>>");
{ try
if(xmlString != null && xmlString.trim().length()!=0) {
{ if(xmlString != null && xmlString.trim().length()!=0)
headerDom = genericUtility.parseString(xmlString); {
System.out.println("headerDom" + headerDom); headerDom = genericUtility.parseString(xmlString);
} System.out.println("headerDom" + headerDom);
if(xmlString2 != null && xmlString2.trim().length()!=0) }
{ if(xmlString2 != null && xmlString2.trim().length()!=0)
detailDom = genericUtility.parseString(xmlString2); {
System.out.println("detailDom" + detailDom); detailDom = genericUtility.parseString(xmlString2);
} System.out.println("detailDom" + detailDom);
retStr = process(headerDom, detailDom, windowName, xtraParams); }
} retStr = process(headerDom, detailDom, windowName, xtraParams);
catch (Exception e) }
{ catch (Exception e)
System.out.println("Exception :PickOrderPrcEJB :process(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":"); {
e.printStackTrace(); System.out.println("Exception :PickOrderPrcEJB :process(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":");
retStr = e.getMessage(); e.printStackTrace();
throw new ITMException(e); retStr = e.getMessage();
} throw new ITMException(e);
return retStr; }
} return retStr;
public String process(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException }
{ public String process(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException
Connection conn = null; {
ResultSet rs = null; Connection conn = null;
NodeList childNodeList = null; ResultSet rs = null;
Node parentNode = null; NodeList childNodeList = null;
Node childNode = null; Node parentNode = null;
PreparedStatement pstmt = null; Node childNode = null;
String updateSql = null; PreparedStatement pstmt = null;
String sql = null; String updateSql = null;
int parentNodeListLength = 0; String sql = null;
int childNodeListLength = 0; int parentNodeListLength = 0;
NodeList parentNodeList = null; int childNodeListLength = 0;
String childNodeName = null; NodeList parentNodeList = null;
String ptcn = ""; String childNodeName = null;
String waveId = ""; String ptcn = "";
String pickOrder = ""; String waveId = "";
String saleOrder = ""; String pickOrder = "";
String status = ""; String saleOrder = "";
String assignTo = ""; String status = "";
int count = 0; String assignTo = "";
int totalCount = 0; int count = 0;
int pickIssCount = 0; int totalCount = 0;
String errCode = ""; int pickIssCount = 0;
String errString = ""; String errCode = "";
boolean isError = false; String errString = "";
GenericUtility genericUtility = GenericUtility.getInstance(); boolean isError = false;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB(); GenericUtility genericUtility = GenericUtility.getInstance();
//changed by sankara on 28/09/13 for getting unconfirmed repl_orders. ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
String pickreplStatus = ""; //changed by sankara on 28/09/13 for getting unconfirmed repl_orders.
try String pickreplStatus = "";
{ try
String userId = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginCode" ); {
ConnDriver connDriver = new ConnDriver(); String userId = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginCode" );
conn = connDriver.getConnectDB("DriverITM"); ConnDriver connDriver = new ConnDriver();
connDriver = null; conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false); connDriver = null;
System.out.println("headerDom:"+headerDom); conn.setAutoCommit(false);
System.out.println("detailDom:"+detailDom); System.out.println("headerDom:"+headerDom);
System.out.println("windowName:"+windowName); System.out.println("detailDom:"+detailDom);
System.out.println("xtraParams:"+xtraParams); System.out.println("windowName:"+windowName);
System.out.println("xtraParams:"+xtraParams);
parentNodeList = detailDom.getElementsByTagName("Detail2");
parentNodeListLength = parentNodeList.getLength(); parentNodeList = detailDom.getElementsByTagName("Detail2");
for (int selectedRow = 0; selectedRow < parentNodeListLength; selectedRow++) parentNodeListLength = parentNodeList.getLength();
{ for (int selectedRow = 0; selectedRow < parentNodeListLength; selectedRow++)
parentNode = parentNodeList.item(selectedRow); {
childNodeList = parentNode.getChildNodes(); parentNode = parentNodeList.item(selectedRow);
childNodeListLength = childNodeList.getLength(); childNodeList = parentNode.getChildNodes();
System.out.println("childNodeListLength---->>> "+ childNodeListLength); childNodeListLength = childNodeList.getLength();
System.out.println("childNodeListLength---->>> "+ childNodeListLength);
for (int childRow = 0; childRow < childNodeListLength; childRow++)
{ for (int childRow = 0; childRow < childNodeListLength; childRow++)
childNode = childNodeList.item(childRow); {
childNodeName = childNode.getNodeName(); childNode = childNodeList.item(childRow);
System.out.println("childNodeName---->>> "+ childNodeName); childNodeName = childNode.getNodeName();
System.out.println("childNodeName---->>> "+ childNodeName);
if("pick_order".equalsIgnoreCase(childNodeName))
{ if("pick_order".equalsIgnoreCase(childNodeName))
if ( childNode != null && childNode.getFirstChild() != null ) {
{ if ( childNode != null && childNode.getFirstChild() != null )
pickOrder = checkNull(childNode.getFirstChild().getNodeValue()); {
} pickOrder = checkNull(childNode.getFirstChild().getNodeValue());
} }
else if("sale_order".equalsIgnoreCase(childNodeName)) }
{ else if("sale_order".equalsIgnoreCase(childNodeName))
if ( childNode != null && childNode.getFirstChild() != null ) {
{ if ( childNode != null && childNode.getFirstChild() != null )
saleOrder = checkNull(childNode.getFirstChild().getNodeValue()); {
} saleOrder = checkNull(childNode.getFirstChild().getNodeValue());
} }
else if("wave_id".equalsIgnoreCase(childNodeName)) }
{ else if("wave_id".equalsIgnoreCase(childNodeName))
if ( childNode != null && childNode.getFirstChild() != null ) {
{ if ( childNode != null && childNode.getFirstChild() != null )
waveId = checkNull(childNode.getFirstChild().getNodeValue()); {
} waveId = checkNull(childNode.getFirstChild().getNodeValue());
} }
else if("ptcn".equalsIgnoreCase(childNodeName)) }
{ else if("ptcn".equalsIgnoreCase(childNodeName))
if ( childNode != null && childNode.getFirstChild() != null ) {
{ if ( childNode != null && childNode.getFirstChild() != null )
ptcn = checkNull(childNode.getFirstChild().getNodeValue()); {
} ptcn = checkNull(childNode.getFirstChild().getNodeValue());
} }
else if("assign_to".equalsIgnoreCase(childNodeName)) }
{ else if("assign_to".equalsIgnoreCase(childNodeName))
{
if ( childNode != null && childNode.getFirstChild() != null )
{ if ( childNode != null && childNode.getFirstChild() != null )
assignTo = (childNode.getFirstChild().getNodeValue()); {
System.out.println("assignTo="+assignTo); assignTo = (childNode.getFirstChild().getNodeValue());
} System.out.println("assignTo="+assignTo);
if( assignTo.trim() == null || assignTo.trim().length() == 0 ) }
{ if( assignTo.trim() == null || assignTo.trim().length() == 0 )
errString = itmDBAccessEJB.getErrorString("","VPBLKUSRCD",userId); {
return errString; errString = itmDBAccessEJB.getErrorString("","VPBLKUSRCD",userId);
} return errString;
else if ( assignTo != null && assignTo.trim().length() != 0 ) }
{ else if ( assignTo != null && assignTo.trim().length() != 0 )
System.out.println("assignTo==="+assignTo); {
sql = " SELECT COUNT(*) FROM USERS WHERE CODE = ? "; System.out.println("assignTo==="+assignTo);
pstmt = conn.prepareStatement(sql); sql = " SELECT COUNT(*) FROM USERS WHERE CODE = ? ";
pstmt.setString(1,assignTo.trim()); pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery(); pstmt.setString(1,assignTo.trim());
if(rs.next()) rs = pstmt.executeQuery();
{ if(rs.next())
count = rs.getInt(1); {
} count = rs.getInt(1);
if(count == 0) }
{ if(count == 0)
errCode = "VPINVUSRCD"; {
errString = itmDBAccessEJB.getErrorString("","VPINVUSRCD",userId); errCode = "VPINVUSRCD";
return errString; errString = itmDBAccessEJB.getErrorString("","VPINVUSRCD",userId);
} return errString;
rs.close(); }
rs = null; rs.close();
pstmt.close(); rs = null;
pstmt = null; pstmt.close();
} pstmt = null;
}
// Changed by sankara on 07-09-13 for checking spaces start..
/* else // Changed by sankara on 07-09-13 for checking spaces start..
{ /* else
errString = itmDBAccessEJB.getErrorString("","VPBLKUSRCD",userId); {
return errString; errString = itmDBAccessEJB.getErrorString("","VPBLKUSRCD",userId);
} */ return errString;
} */
// Changed by sankara on 07-09-13 for checking spaces end..
} // Changed by sankara on 07-09-13 for checking spaces end..
else if("status".equalsIgnoreCase(childNodeName)) }
{ else if("status".equalsIgnoreCase(childNodeName))
if ( childNode != null && childNode.getFirstChild() != null ) {
{ if ( childNode != null && childNode.getFirstChild() != null )
status = checkNull(childNode.getFirstChild().getNodeValue()); {
} status = checkNull(childNode.getFirstChild().getNodeValue());
} }
//changed by sankara on 28/09/13 for getting unconfirmed repl_orders start. }
else if("pick_repl_status".equalsIgnoreCase(childNodeName)) //changed by sankara on 28/09/13 for getting unconfirmed repl_orders start.
{ else if("pick_repl_status".equalsIgnoreCase(childNodeName))
if ( childNode != null && childNode.getFirstChild() != null ) {
{ if ( childNode != null && childNode.getFirstChild() != null )
pickreplStatus = checkNull(childNode.getFirstChild().getNodeValue()); {
} pickreplStatus = checkNull(childNode.getFirstChild().getNodeValue());
} }
//changed by sankara on 28/09/13 for getting unconfirmed repl_orders end. }
} //changed by sankara on 28/09/13 for getting unconfirmed repl_orders end.
System.out.println(" WAVEID=["+waveId+"] PTCN=["+ptcn+"] SALEORDER=["+saleOrder+"] PICKORDER=["+pickOrder+"] ASSIGNTO=["+assignTo+"] PICKREPLSTATUS=["+pickreplStatus+"] "); }
//changed by sankara on 28/09/13 for getting unconfirmed pick orders System.out.println(" WAVEID=["+waveId+"] PTCN=["+ptcn+"] SALEORDER=["+saleOrder+"] PICKORDER=["+pickOrder+"] ASSIGNTO=["+assignTo+"] PICKREPLSTATUS=["+pickreplStatus+"] ");
//if ( pickOrder != null && pickOrder.trim().length() != 0 ) //changed by sankara on 28/09/13 for getting unconfirmed pick orders
if ( pickOrder != null && pickOrder.trim().length() != 0 && pickreplStatus.trim().equalsIgnoreCase("P")) //if ( pickOrder != null && pickOrder.trim().length() != 0 )
{ if ( pickOrder != null && pickOrder.trim().length() != 0 && pickreplStatus.trim().equalsIgnoreCase("P"))
System.out.println("PICKORDER===="+pickOrder); {
updateSql= " UPDATE PICK_ORD_HDR SET ASSIGN_TO = ? WHERE PICK_ORDER = ? "; System.out.println("PICKORDER===="+pickOrder);
pstmt = conn.prepareStatement(updateSql); updateSql= " UPDATE PICK_ORD_HDR SET ASSIGN_TO = ? WHERE PICK_ORDER = ? ";
pstmt.setString(1,assignTo); pstmt = conn.prepareStatement(updateSql);
pstmt.setString(2,pickOrder); pstmt.setString(1,assignTo);
count = pstmt.executeUpdate(); pstmt.setString(2,pickOrder);
pstmt.close(); count = pstmt.executeUpdate();
pstmt = null; pstmt.close();
pstmt = null;
updateSql= " UPDATE PICK_ISS_HDR SET CHG_USER = ? WHERE PICK_ORDER = ? ";
pstmt = conn.prepareStatement(updateSql); updateSql= " UPDATE PICK_ISS_HDR SET CHG_USER = ? WHERE PICK_ORDER = ? ";
pstmt.setString(1,assignTo); pstmt = conn.prepareStatement(updateSql);
pstmt.setString(2,pickOrder); pstmt.setString(1,assignTo);
pickIssCount = pstmt.executeUpdate(); pstmt.setString(2,pickOrder);
pstmt.close(); pickIssCount = pstmt.executeUpdate();
pstmt = null; pstmt.close();
} pstmt = null;
//changed by sankara on 28/09/13 for getting unconfirmed repl orders start. }
if ( pickOrder != null && pickOrder.trim().length() != 0 && pickreplStatus.trim().equalsIgnoreCase("R")) //changed by sankara on 28/09/13 for getting unconfirmed repl orders start.
{ if ( pickOrder != null && pickOrder.trim().length() != 0 && pickreplStatus.trim().equalsIgnoreCase("R"))
System.out.println("REPLORDER===="+pickOrder); {
updateSql= " UPDATE REPL_ORD_HDR SET ASSIGN_TO = ? WHERE REPL_ORDER = ? "; System.out.println("REPLORDER===="+pickOrder);
pstmt = conn.prepareStatement(updateSql); updateSql= " UPDATE REPL_ORD_HDR SET ASSIGN_TO = ? WHERE REPL_ORDER = ? ";
pstmt.setString(1,assignTo); pstmt = conn.prepareStatement(updateSql);
pstmt.setString(2,pickOrder); pstmt.setString(1,assignTo);
pickIssCount = pstmt.executeUpdate(); pstmt.setString(2,pickOrder);
pstmt.close(); pickIssCount = pstmt.executeUpdate();
pstmt = null; pstmt.close();
pstmt = null;
updateSql= " UPDATE REPL_ISS_HDR SET CHG_USER = ? WHERE REPL_ORDER = ? ";
pstmt = conn.prepareStatement(updateSql); updateSql= " UPDATE REPL_ISS_HDR SET CHG_USER = ? WHERE REPL_ORDER = ? ";
pstmt.setString(1,assignTo); pstmt = conn.prepareStatement(updateSql);
pstmt.setString(2,pickOrder); pstmt.setString(1,assignTo);
pickIssCount = pstmt.executeUpdate(); pstmt.setString(2,pickOrder);
pstmt.close(); pickIssCount = pstmt.executeUpdate();
pstmt = null; pstmt.close();
} pstmt = null;
//changed by sankara on 28/09/13 for getting unconfirmed repl orders end. }
totalCount = pickIssCount+count; //changed by sankara on 28/09/13 for getting unconfirmed repl orders end.
} totalCount = pickIssCount+count;
if( totalCount > 0 ) }
{ if( totalCount > 0 )
System.out.println("totalCount--->"+totalCount); {
errCode = "VPPRCESFUL"; System.out.println("totalCount--->"+totalCount);
errString = itmDBAccessEJB.getErrorString("","VPPRCESFUL",userId); errCode = "VPPRCESFUL";
} errString = itmDBAccessEJB.getErrorString("","VPPRCESFUL",userId);
else }
{ else
System.out.println("Updated Rows Count in Pick Ord Hdr and Pick Iss Hdr"+totalCount); {
} System.out.println("Updated Rows Count in Pick Ord Hdr and Pick Iss Hdr"+totalCount);
}
}
catch (Exception e) }
{ catch (Exception e)
isError = true; {
try isError = true;
{ try
conn.rollback(); {
} conn.rollback();
catch (Exception e1) }
{ catch (Exception e1)
System.out.println("Gem Message="+e.getCause()); {
System.out.println("Complete Message="+e.getMessage()); System.out.println("Gem Message="+e.getCause());
e1.printStackTrace(); System.out.println("Complete Message="+e.getMessage());
} e1.printStackTrace();
e.printStackTrace(); }
System.out.println("******Exception"+e.getMessage()); e.printStackTrace();
} System.out.println("******Exception"+e.getMessage());
finally }
{ finally
try {
{ try
if(!isError) {
{ if(!isError)
conn.commit(); {
} conn.commit();
else }
{ else
conn.rollback(); {
} conn.rollback();
if(conn != null) }
{ if(conn != null)
if(rs != null) {
{ if(rs != null)
rs.close(); {
rs = null; rs.close();
} rs = null;
if(pstmt != null) }
{ if(pstmt != null)
pstmt.close(); {
pstmt = null; pstmt.close();
} pstmt = null;
conn.close(); }
} conn.close();
conn = null; }
} conn = null;
catch (Exception ex) }
{ catch (Exception ex)
isError = true; {
System.out.println("Exception is "+ex.getMessage()); isError = true;
} System.out.println("Exception is "+ex.getMessage());
} }
return errString; }
} //process method return errString;
} //process method
private String checkNull( String input )
{ private String checkNull( String input )
if( input == null ) {
{ if( input == null )
input = ""; {
} input = "";
else }
{ else
input = input.trim(); {
} input = input.trim();
return input; }
} return input;
}
} // class closed
} // class closed
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