Change user Allocation

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@96241 ce508802-f39f-4f6c-b175-0d175dae99d5

webitm-dis/ibase/webitm/ejb/dis/ChgUserAlloc.java

+
+package ibase.webitm.ejb.dis;
+
+import ibase.system.config.ConnDriver;
+import ibase.webitm.ejb.ValidatorEJB;
+import ibase.webitm.utility.GenericUtility;
+import ibase.webitm.utility.ITMException;
+
+import java.rmi.RemoteException;
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.text.NumberFormat;
+
+import javax.ejb.Stateless;
+
+import org.w3c.dom.Document;
+import org.w3c.dom.Node;
+import org.w3c.dom.NodeList;
+
+@Stateless
+public class ChgUserAlloc extends ValidatorEJB implements ChgUserAllocLocal, ChgUserAllocRemote {
+
+	GenericUtility genericUtility = GenericUtility.getInstance();
+	String userId = null;
+	String chgUser = null;
+	String chgTerm = null;
+	NumberFormat nf = null;
+	boolean isError=false;
+
+
+
+	public ChgUserAlloc() 
+	{
+		System.out.println("^^^^^^^ inside ChgUserAlloc Wizard ^^^^^^^");
+	}
+
+	public String wfValData(String xmlString, String xmlString1, String xmlString2, String objContext, String editFlag, String xtraParams) throws RemoteException, ITMException {
+		System.out.println("^^^^^^^ inside ChgUserAlloc Wizard >^^^^^^^");
+		Document dom = null;
+		Document dom1 = null;
+		Document dom2 = null;
+		String errString = "";
+
+		NodeList parentNodeList = null;
+		NodeList childNodeList = null;
+		Node parentNode = null;
+		Node childNode = null;
+		String childNodeName = "";
+
+		try {
+			dom = parseString(xmlString);
+			dom1 = parseString(xmlString1);
+			if (xmlString2.trim().length() > 0) 
+			{
+				dom2 = parseString("<Root>" + xmlString2 + "</Root>");
+			}
+			if (objContext != null && Integer.parseInt(objContext) == 1) 
+			{
+				parentNodeList = dom2.getElementsByTagName("Header0");
+				parentNode = parentNodeList.item(1);
+				childNodeList = parentNode.getChildNodes();
+				for (int x = 0; x < childNodeList.getLength(); x++) 
+				{
+					childNode = childNodeList.item(x);
+					childNodeName = childNode.getNodeName();
+					if (childNodeName.equalsIgnoreCase("Detail1")) 
+					{
+						errString = wfValData(dom, dom1, dom2, "1", editFlag, xtraParams);
+						if (errString != null && errString.trim().length() > 0)
+							break;
+					} else if (childNodeName.equalsIgnoreCase("Detail2")) 
+					{
+						errString = wfValData(dom, dom1, dom2, "2", editFlag, xtraParams);
+						break;
+					}
+				}
+			} else 
+			{
+				errString = wfValData(dom, dom1, dom2, objContext, editFlag, xtraParams);
+			}
+		} catch (Exception e) {
+			System.out.println("Exception : Inside ChgUserAlloc wfValData Method ..> " + e.getMessage());
+			throw new ITMException(e);
+		}
+		return (errString);
+	}
+
+	public String wfValData(Document dom, Document dom1, Document dom2, String objContext, String editFlag, String xtraParams) throws RemoteException, ITMException {
+		System.out.println("^^^^^^^ inside ChgUserAlloc wfValData >^^^^^^^");
+		GenericUtility genericUtility;
+		NodeList parentNodeList = null;
+		NodeList childNodeList = null;
+		Node parentNode = null;
+		Node childNode = null;
+		int ctr = 0, currentFormNo = 0, childNodeListLength = 0, cnt = 0;
+		String childNodeName = null;
+		String errString = "";
+		String errCode = "";
+		Connection conn = null;
+		String userId = "";
+		PreparedStatement pstmt = null ;
+		ResultSet rs = null;
+		String sql = "";
+
+		String distOrderNo = "", chguser = "";
+		try {
+
+			System.out.println("editFlag>>>>wf"+editFlag);
+			System.out.println("xtraParams>>>wf"+xtraParams);
+
+
+			ConnDriver connDriver = new ConnDriver();
+			conn = connDriver.getConnectDB("DriverITM");
+			conn.setAutoCommit(false);
+			connDriver = null;
+			userId = getValueFromXTRA_PARAMS(xtraParams, "loginCode");
+			genericUtility = GenericUtility.getInstance();
+			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("dist_order"))
+					{
+
+						distOrderNo = genericUtility.getColumnValue("dist_order",dom);
+
+						if (distOrderNo == null || distOrderNo.trim().length() == 0)
+						{
+							errCode = "DISISSNULL";
+							errString = getErrorString("dist_order",errCode,userId);
+							break;
+						}
+						else
+						{
+
+							sql = "select count(1) from distorder where dist_order = ?";
+							pstmt=conn.prepareStatement(sql);
+							pstmt.setString(1,distOrderNo);
+							rs = pstmt.executeQuery();
+							if(rs.next())
+							{
+								cnt = rs.getInt(1);
+							}
+							pstmt.close();
+							rs.close();
+							pstmt = null;
+							rs = null;
+							if(cnt == 0)
+							{
+								errCode = "DISNOTEX";
+								errString = getErrorString("dist_order",errCode,userId);
+								break;
+							}
+						}
+
+					}
+				}
+				break;
+			case 2:
+				System.out.println("DOM>>>> Elements>>["+genericUtility.serializeDom(dom).toString()+"]");
+				System.out.println("DOM1>> Elements>>["+genericUtility.serializeDom(dom1).toString()+"]");
+				System.out.println("DOM2>> Elements>>["+genericUtility.serializeDom(dom2).toString()+"]");	
+
+				parentNodeList = dom2.getElementsByTagName("Detail2");
+				parentNode = parentNodeList.item(0);
+				System.out.println("parentNode >>>{"+parentNode+"}");
+				childNodeList = parentNode.getChildNodes();
+				childNodeListLength = childNodeList.getLength();
+
+
+				for(ctr = 0; ctr < childNodeListLength; ctr++)
+				{
+					childNode = childNodeList.item(ctr);
+					childNodeName = childNode.getNodeName();
+
+					if(childNodeName.equalsIgnoreCase("code"))
+					{
+
+						chguser = genericUtility.getColumnValue("code",dom);
+
+						if (distOrderNo == null || distOrderNo.trim().length() == 0)
+						{
+							errCode = "USERNULL";
+							errString = getErrorString("code",errCode,userId);
+							break;
+						}
+						else
+						{
+
+							sql = "select count(1) from users where code = ?";
+							pstmt=conn.prepareStatement(sql);
+							pstmt.setString(1,chguser);
+							rs = pstmt.executeQuery();
+							if(rs.next())
+							{
+								cnt = rs.getInt(1);
+							}
+							pstmt.close();
+							rs.close();
+							pstmt = null;
+							rs = null;
+							if(cnt == 0)
+							{
+								errCode = "USERNOTEXT";
+								errString = getErrorString("code",errCode,userId);
+								break;
+							}
+						}
+
+					}
+				}
+				break;
+			}
+		} catch (Exception e) {
+			e.printStackTrace();			
+			errString = e.getMessage();
+			try {
+				conn.rollback();				
+			} catch (Exception d) {
+				d.printStackTrace();
+			}
+			throw new ITMException(e);
+		} finally {
+			try {
+				if (conn != null) {
+					conn.close();
+				}
+				conn = null;
+			} catch (Exception d) {
+				d.printStackTrace();
+			}
+		}
+		return errString;
+	}
+
+	public String itemChanged(String xmlString, String xmlString1, String xmlString2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException, ITMException {
+		Document dom = null;
+		Document dom1 = null;
+		Document dom2 = null;
+		String valueXmlString = "";
+		try {
+			System.out.println("currentColumn"+currentColumn);
+			System.out.println("editFlag"+editFlag);
+			System.out.println("xtraParams"+xtraParams);
+
+
+			System.out.println("xmlString111>>"+xmlString);
+			System.out.println("xmlString222>>"+xmlString1);
+			System.out.println("xmlString333>>"+xmlString2);
+			dom = parseString(xmlString);
+			dom1 = parseString(xmlString1);
+			if (xmlString2.trim().length() > 0) {
+				dom2 = parseString(xmlString2);
+			}
+			valueXmlString = itemChanged(dom, dom1, dom2, objContext, currentColumn, editFlag, xtraParams);
+		} catch (Exception e) {
+			System.out.println("Exception : [itemChanged(String,String)] :==>\n" + e.getMessage());
+			throw new ITMException(e);
+		}
+		return valueXmlString;
+	}
+
+
+	public String itemChanged(Document dom, Document dom1, Document dom2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException, ITMException {
+
+		StringBuffer valueXmlString = null;
+		int currentFormNo = 0;
+		Connection conn = null;
+		PreparedStatement pstmt = null;
+		ResultSet rs = null;
+		GenericUtility genericUtility = GenericUtility.getInstance();
+		ConnDriver connDriver = new ConnDriver();
+		System.out.println("DOM111 Elements>>>********************************["+genericUtility.serializeDom(dom).toString()+"]");
+		System.out.println("DOM222 Elements>>>********************************["+genericUtility.serializeDom(dom1).toString()+"]");
+		System.out.println("DOM322 Elements>>>********************************["+genericUtility.serializeDom(dom2).toString()+"]");
+		String sql="";
+		String distOrderNo = "";
+
+		try
+		{   
+			conn = connDriver.getConnectDB("DriverITM");
+			conn.setAutoCommit(false);
+			connDriver = null;
+			userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "userId");
+
+			chgUser = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode");
+			chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "termId");
+
+			if (objContext != null && objContext.trim().length() > 0) {
+				currentFormNo = Integer.parseInt(objContext);
+			}
+			System.out.println("FORM NO IS"+currentFormNo);
+			valueXmlString = new StringBuffer("<?xml version = \"1.0\"?> <Root> <header> <editFlag>");
+			valueXmlString.append(editFlag).append("</editFlag> </header>");
+			userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode");
+			System.out.println("lot sl in begin from dom ...>>>>>>.."+genericUtility.getColumnValue("lot_sl",dom)+"lot sl from dom1 ...>>>>>>.."+genericUtility.getColumnValue("lot_sl",dom1)+"lot sl from dom2 ...>>>>>>.."+genericUtility.getColumnValue("lot_sl",dom2));
+			switch (currentFormNo) {
+
+			case 1 :
+				break;
+
+			case 2 : 
+				System.out.println("DOM2 Elements["+genericUtility.serializeDom(dom2).toString()+"]");
+
+			
+
+				distOrderNo = genericUtility.getColumnValue("dist_order", dom1);
+				
+					if(currentColumn.trim().equalsIgnoreCase("itm_default"))
+					{
+						
+						
+						sql =   "select chg_user from distord_iss where dist_order = ? and confirmed = 'N'";
+
+						pstmt = conn.prepareStatement(sql);
+						pstmt.setString(1, distOrderNo);
+						rs = pstmt.executeQuery();
+						if(rs.next())
+						{
+
+							valueXmlString.append("<Detail2  domID='1' objContext = '"+currentFormNo+"' selected=\"Y\">\r\n");
+							valueXmlString.append("<attribute selected=\"Y\" updateFlag=\"E\" status=\"O\" pkNames=\"\"/>\r\n");
+							valueXmlString.append("<chg_user><![CDATA["+(rs.getString("chg_user")==null?"":rs.getString("chg_user").trim())+"]]></chg_user>");
+							valueXmlString.append("</Detail2>");
+						}
+						pstmt.close();
+						rs.close();
+						pstmt = null;
+						rs = null;
+					}
+				break;
+			case 3 : 
+				
+				break;
+			}
+
+/*			if(("lot_sl".equalsIgnoreCase(currentColumn)))
+			{
+				System.out.println("CHK VAL");
+				String currDomStr = genericUtility.serializeDom(dom);
+				System.out.println("currDomStr[" + currDomStr + "]");
+				StringBuffer valueXmlStr = new StringBuffer(currDomStr);
+				System.out.println("@@@@@@@@@@@ after serialize : valueXmlStr ["+valueXmlStr+"]");
+				StringBuffer valueXmlString1 = new StringBuffer("<?xml version=\"1.0\"?><Root><header><editFlag>");
+				valueXmlString1.append(editFlag).append("</editFlag></header>");
+				valueXmlString1.append(valueXmlStr);
+				valueXmlString = valueXmlString1;
+			}
+*/
+			valueXmlString.append("</Root>"); 
+		}
+		catch(Exception e) 
+		{
+			e.printStackTrace();
+			System.out.println("Exception ::"+ e.getMessage()); 
+			try {
+				conn.rollback();				
+			} catch (Exception d) {
+				d.printStackTrace();
+			}
+			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 getDetails(String mSiteCode,int mLineNoDist,String mDistOrder,String lsTranType,Connection conn)throws RemoteException,ITMException
+	{//this method will return xml data
+		String mTaxClass=null,mTaxChap=null,mTaxEnv = null;
+		String lsUnitAlt = null,lsUnit = null,lsPackInstr =null;
+		double mQty= 0,lcQty= 0,mRate = 0,mDiscount =0;
+
+		String sql = null,lsTranTypeParent ="";
+		ResultSet rs = null,rs1 =null;
+		PreparedStatement pstmt = null,pstmt1 =null;
+		StringBuffer detail2hdr = new StringBuffer("");
+		try
+		{
+			sql="select item_code,((case when qty_confirm is null then 0 else qty_confirm end) - "
+					+" (case when qty_shipped is null then 0 else qty_shipped end))	as qty,"
+					+" ((case when qty_shipped is null then 0 else qty_shipped end) - "
+					+" (case when qty_return is null then 0 else qty_return end)) as lcqty,"
+					+" tax_class,tax_chap,tax_env,case when rate is null then 0 else rate end as rate,"
+					+" case when discount is null then 0 else discount end as discount,	"
+					+" rate__clg  ,UNIT__ALT ,UNIT,CONV__QTY__ALT,pack_instr "
+					+" from 	distorder_det "
+					+" where dist_order = '"+mDistOrder+"'  "
+					+" and 	line_no    = "+mLineNoDist+"" 
+					+ " AND   CASE WHEN STATUS IS NULL THEN 'O' ELSE STATUS END<>'C' ";//Added by manoj dtd 24/12/2013 to exclude closed line"
+
+			//System.out.println("[DistIssueItemChangeEJB] sql=>"+sql);
+
+			pstmt   = conn.prepareStatement(sql);
+			//	pstmt.setString(1,mDistOrder);
+			//pstmt.setInt(2,mLineNoDist);
+			rs = pstmt.executeQuery();
+			if(rs.next())
+			{
+				//mItemCode = rs.getString("item_code")==null?"":rs.getString("item_code");
+				mQty = rs.getDouble("qty");
+				lcQty = rs.getDouble("lcqty");
+				mTaxClass = rs.getString("tax_class")==null?"":rs.getString("tax_class");
+				mTaxChap = rs.getString("tax_chap")==null?"":rs.getString("tax_chap");
+				mTaxEnv = rs.getString("tax_env")==null?"":rs.getString("tax_env");
+				mRate = rs.getDouble("rate");
+				mDiscount = rs.getDouble("discount");
+				lsUnitAlt = rs.getString("UNIT__ALT")==null?"":rs.getString("UNIT__ALT");
+				lsPackInstr = rs.getString("pack_instr")==null?"":rs.getString("pack_instr");
+
+				if(lsUnitAlt.trim().length() == 0)
+				{
+					lsUnitAlt = lsUnit;
+				}
+
+			//	detail2hdr.append("<item_code><![CDATA["+mItemCode+"]]></item_code>");
+				detail2hdr.append("<unit><![CDATA["+lsUnit+"]]></unit>");
+				detail2hdr.append("<unit__alt><![CDATA["+lsUnitAlt+"]]></unit__alt>");
+				detail2hdr.append("<pack_instr><![CDATA["+lsPackInstr+"]]></pack_instr>");
+
+
+				sql=" select tran_type__parent "
+						+" from	distorder_type where  tran_type = '"+lsTranType+"' ";
+				//System.out.println("[DistIssueItemChangeEJB] sql=>"+sql);
+				pstmt1= conn.prepareStatement(sql);
+				rs1 = pstmt1.executeQuery();
+				if(rs1.next())
+				{
+					lsTranTypeParent = rs1.getString("tran_type__parent") == null ? "": rs1.getString("tran_type__parent").trim();
+				}
+				rs1.close();
+				rs1 = null;
+				pstmt1.close();
+				pstmt1 = null;
+
+				if(! lsTranTypeParent.equalsIgnoreCase(lsTranType.trim()))
+				{
+				//	detail2hdr.append("<quantity>"+lcQty+"</quantity>");
+					detail2hdr.append("<qty_order__alt>"+lcQty+"</qty_order__alt>");
+					//lcQty = lcQty;
+				}
+				else
+				{
+				//	detail2hdr.append("<quantity>"+mQty+"</quantity>");
+					detail2hdr.append("<qty_order__alt>"+mQty+"</qty_order__alt>");
+					lcQty = mQty;
+				}
+				detail2hdr.append("<tax_class><![CDATA["+mTaxClass+"]]></tax_class>");
+				detail2hdr.append("<tax_chap><![CDATA["+mTaxChap+"]]></tax_chap>");
+				detail2hdr.append("<tax_env><![CDATA["+mTaxEnv+"]]></tax_env>");
+				detail2hdr.append("<rate>"+mRate+"</rate>");
+				detail2hdr.append("<discount>"+mDiscount+"</discount>");
+				//System.out.println("[CreateDistIssue] xml return ==>"+detail2hdr.toString());
+			}
+			rs.close();
+			rs = null;
+			pstmt.close();
+			pstmt = null;
+
+		}
+		catch(Exception e)
+		{
+			e.printStackTrace();
+		}
+		System.out.println("chandni inside detail::"+detail2hdr.toString());
+		return detail2hdr.toString();
+	}*/
+	
+/*	private static String getAbsString( String str )
+	{
+		return ( str == null || str.trim().length() == 0 || "null".equalsIgnoreCase( str.trim() ) ? "" : str.trim() );
+	}*/
+
+/*	private static void setNodeValue( Document dom, String nodeName, String nodeVal ) throws Exception
+	{
+		Node tempNode = dom.getElementsByTagName( nodeName ).item(0);
+
+		if( tempNode != null )
+		{
+			if( tempNode.getFirstChild() == null )
+			{
+				CDATASection cDataSection = dom.createCDATASection( nodeVal );
+				tempNode.appendChild( cDataSection );
+			}
+			else
+			{
+				tempNode.getFirstChild().setNodeValue(nodeVal);
+			}
+		}
+		tempNode = null;
+	}*/
+
+
+	
+/*	public String getFormatedValue(double actVal,int prec)throws RemoteException//This method is added by nisar on 11/23/2007
+	{//this method is used to return double with appropriate precison
+		NumberFormat numberFormat = NumberFormat.getIntegerInstance ();
+		Double DoubleValue = new Double (actVal);
+		numberFormat.setMaximumFractionDigits(prec);
+		String strValue = numberFormat.format(DoubleValue);
+		//System.out.println(strValue);
+		strValue = strValue.replaceAll(",","");
+		return strValue;
+	}*/
+	/*private String getCurrdateAppFormat()
+	{
+		String s = "";
+		GenericUtility genericUtility = GenericUtility.getInstance();
+		try
+		{
+			java.util.Date date = null;
+			Timestamp timestamp = new Timestamp(System.currentTimeMillis());
+			//System.out.println(genericUtility.getDBDateFormat());
+
+			SimpleDateFormat simpledateformat = new SimpleDateFormat(genericUtility.getDBDateFormat());
+			date = simpledateformat.parse(timestamp.toString());
+			timestamp = Timestamp.valueOf(simpledateformat.format(date).toString() + " 00:00:00.0");
+			s = (new SimpleDateFormat(genericUtility.getApplDateFormat())).format(timestamp).toString();
+		}
+		catch(Exception exception)
+		{
+			//System.out.println("Exception in [MPSOrder] getCurrdateAppFormat " + exception.getMessage());
+		}
+		return s;
+	}*/
+	
+	/*private String calcExpiry(String tranDate, int months)
+	{
+		java.util.Date expDate = new java.util.Date();
+		java.util.Date retDate = new java.util.Date();
+		String retStrInDate = "";
+		//System.out.println("tranDate :"+tranDate+"\nmonths :"+months);
+		try
+		{
+			GenericUtility genericUtility = GenericUtility.getInstance();
+			SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
+			if (months > 0)
+			{
+				Calendar  cal = Calendar.getInstance();
+				expDate = sdf.parse(tranDate);
+				//System.out.println("expDate :"+expDate);
+				cal.setTime(expDate);
+				cal.add(Calendar.MONTH,months);
+				//for last day of the month
+				cal.add(Calendar.MONTH,1);
+				cal.set(Calendar.DATE,0);
+				//sets zero to get the last day of the given date
+				retDate = cal.getTime();
+				retStrInDate = sdf.format(retDate);
+			}
+			else
+			{
+				retStrInDate = tranDate;
+			}
+		}
+		catch(Exception e)
+		{
+			//System.out.println("The Exception occurs in calcExpiry :"+e);
+		}
+		//System.out.println("retStrInDate :"+retStrInDate);
+		return retStrInDate;
+	}*/
+/*	private double getIntegralQty(String siteCode, String itemCode, String lotNo, String packCode, String checkIntegralQty)
+	{
+		double integralQty = 0;
+		String sql = "";
+		ResultSet rs = null;
+		Connection conn = null;
+		ConnDriver connDriver = new ConnDriver();
+		Statement stmt = null;
+		try
+		{
+			conn = connDriver.getConnectDB("DriverITM");
+			stmt = conn.createStatement();
+			char type = checkIntegralQty.charAt(0);
+			//System.out.println("type==>"+type);
+			switch (type)
+			{
+			case 'S':
+				sql ="SELECT CASE WHEN SHIPPER_SIZE IS NULL THEN 0 ELSE SHIPPER_SIZE END "
+						+"FROM ITEM_LOT_PACKSIZE "
+						+"WHERE ITEM_CODE = '"+itemCode+"' "
+						+"AND LOT_NO__FROM <= '"+lotNo+"' "
+						+"AND LOT_NO__TO   >= '"+lotNo+"' ";
+				System.out.println("sql :"+sql);
+				rs = stmt.executeQuery(sql);
+				if (rs.next())
+				{
+					integralQty = rs.getDouble(1);
+					//System.out.println("integralQty :"+integralQty);
+				}
+				if (integralQty == 0)
+				{
+					sql = "SELECT CASE WHEN CAPACITY IS NULL THEN 0 ELSE CAPACITY END "
+							+"FROM PACKING WHERE PACK_CODE = '"+packCode+"'";
+					System.out.println("sql :"+sql);
+					rs = stmt.executeQuery(sql);
+					if (rs.next())
+					{
+						integralQty = rs.getDouble(1);
+						//System.out.println("integralQty :"+integralQty);
+					}
+					if (integralQty == 0)
+					{
+						sql = "SELECT REO_QTY FROM SITEITEM "
+								+"WHERE SITE_CODE = '"+siteCode+"'"+" AND ITEM_CODE = '"+itemCode+"'";
+						System.out.println("sql :"+sql);	
+						rs = stmt.executeQuery(sql);
+						if (rs.next())
+						{
+							integralQty = rs.getDouble(1);
+							//System.out.println("integralQty :"+integralQty);
+						}
+						if (integralQty == 0)
+						{
+							sql = "SELECT REO_QTY FROM ITEM "
+									+"WHERE ITEM_CODE = '"+itemCode+"'";
+							System.out.println("sql :"+sql);	
+							rs = stmt.executeQuery(sql);
+							if (rs.next())
+							{
+								integralQty = rs.getDouble(1);
+								//System.out.println("integralQty :"+integralQty);
+							}
+						}
+					}
+				}
+
+				break;
+			case 'P':
+				sql = "SELECT CASE WHEN CAPACITY IS NULL THEN 0 ELSE CAPACITY END "
+						+"FROM PACKING WHERE PACK_CODE = '"+packCode+"'";
+				System.out.println("sql :"+sql);
+				rs = stmt.executeQuery(sql);
+				if (rs.next())
+				{
+					integralQty = rs.getDouble(1);
+					//System.out.println("integralQty :"+integralQty);
+				}
+
+				break;
+			case 'I':
+				sql = "SELECT INTEGRAL_QTY FROM SITEITEM "
+						+"WHERE SITE_CODE = '"+siteCode+"'"+" AND ITEM_CODE = '"+itemCode+"'";
+				System.out.println("sql :"+sql);	
+				rs = stmt.executeQuery(sql);
+				if (rs.next())
+				{
+					integralQty = rs.getDouble(1);
+					//System.out.println("integralQty :"+integralQty);
+				}
+				if (integralQty == 0)
+				{
+					sql = "SELECT INTEGRAL_QTY FROM ITEM WHERE ITEM_CODE = '"+itemCode+"'";
+					System.out.println("sql :"+sql);
+					rs = stmt.executeQuery(sql);
+					if (rs.next())
+					{
+						integralQty = rs.getDouble(1);
+						//System.out.println("integralQty :"+integralQty);
+					}
+				}
+
+			}
+			 sql ="SELECT CASE WHEN SHIPPER_SIZE IS NULL THEN 0 ELSE SHIPPER_SIZE END "
+				+"FROM ITEM_LOT_PACKSIZE "
+				+"WHERE ITEM_CODE = '"+itemCode+"' "
+				+"AND LOT_NO__FROM <= '"+lotNo+"' "
+				+"AND LOT_NO__TO   >= '"+lotNo+"' ";
+			System.out.println("sql :"+sql);
+			rs = stmt.executeQuery(sql);
+			if (rs.next())
+			{
+				integralQty = rs.getDouble(1);
+				System.out.println("integralQty :"+integralQty);
+			}
+			if (integralQty == 0)
+			{
+				sql = "SELECT CASE WHEN CAPACITY IS NULL THEN 0 ELSE CAPACITY END "
+					 +"FROM PACKING WHERE PACK_CODE = '"+packCode+"'";
+				System.out.println("sql :"+sql);
+				rs = stmt.executeQuery(sql);
+				if (rs.next())
+				{
+					integralQty = rs.getDouble(1);
+					System.out.println("integralQty :"+integralQty);
+				}
+				if (integralQty == 0)
+				{
+					sql = "SELECT INTEGRAL_QTY FROM SITEITEM "
+						 +"WHERE SITE_CODE = '"+siteCode+"'"+" AND ITEM_CODE = '"+itemCode+"'";
+					System.out.println("sql :"+sql);	
+					rs = stmt.executeQuery(sql);
+					if (rs.next())
+					{
+						integralQty = rs.getDouble(1);
+						System.out.println("integralQty :"+integralQty);
+					}
+					if (integralQty == 0)
+					{
+						sql = "SELECT INTEGRAL_QTY FROM ITEM WHERE ITEM_CODE = '"+itemCode+"'";
+						System.out.println("sql :"+sql);
+						rs = stmt.executeQuery(sql);
+						if (rs.next())
+						{
+							 integralQty = rs.getDouble(1);
+							System.out.println("integralQty :"+integralQty);
+						}
+					}
+				}
+			} 
+			conn.close();	
+		}
+		catch(Exception e)
+		{
+			System.out.println("the exception occurs in getIntegralQty :"+e);
+		}
+		System.out.println("integralQty :"+integralQty);
+		return integralQty;
+	}*/
+
+/*	private int getNoArt(String siteCode, String custCode, String itemCode, String packCode, double qty, char type, double shipperQty, double integralQty1)
+	{
+		String sql = "";
+		ResultSet rs = null;
+		Connection conn = null;
+		ConnDriver connDriver = new ConnDriver();
+		Statement stmt = null;
+		double reoQty = 0d, capacity = 0d, integralQty = 0d, mod = 0d, noArt3 = 0d;
+		double noArt = 0, noArt1 = 0, noArt2 = 0; 
+		try
+		{
+			conn = connDriver.getConnectDB("DriverITM");
+			stmt = conn.createStatement();
+			System.out.println("type :"+type);
+			switch (type)
+			{
+			case 'S':
+				sql = "SELECT CASE WHEN CAPACITY IS NULL THEN 0 ELSE CAPACITY END " 
+						+"FROM PACKING WHERE PACK_CODE = '"+packCode+"'";
+				rs = stmt.executeQuery(sql);
+				if (rs.next())
+				{
+					capacity = rs.getDouble(1);
+					//System.out.println("capacity :"+capacity);
+				}
+				else
+				{
+					capacity = 0;
+				}
+				sql = "SELECT REO_QTY FROM SITEITEM WHERE SITE_CODE = '"+siteCode+"' " 
+						+"AND ITEM_CODE = '"+itemCode+"'";
+				System.out.println("sql :"+sql);
+				rs = stmt.executeQuery(sql);
+				if (rs.next())
+				{
+					reoQty = rs.getDouble(1);
+					//System.out.println("reoQty :"+reoQty);
+				}
+				if( reoQty == 0 )
+				{
+					sql = "SELECT REO_QTY FROM ITEM WHERE ITEM_CODE = '"+itemCode+"'";
+					System.out.println("sql :"+sql);
+					rs = stmt.executeQuery(sql);
+					if (rs.next())
+					{
+						reoQty = rs.getDouble(1);
+						//System.out.println("reoQty :"+reoQty);
+					}
+				}
+				if (reoQty == 0)
+				{
+					reoQty = 0;
+				}
+				if (capacity > 0)
+				{
+					shipperQty = capacity;
+					//System.out.println("shipperQty :"+shipperQty);
+				}
+				else
+				{
+					shipperQty = reoQty;
+					//System.out.println("shipperQty :"+shipperQty);
+				}
+				System.out.println("shipperQty :"+shipperQty);
+				if (shipperQty > 0)
+				{
+					mod = qty%shipperQty;
+					System.out.println("mod :"+mod);
+					noArt = (qty - mod) / shipperQty;
+				}
+				//System.out.println("noArt :"+noArt);
+				break;
+			case 'I':
+				sql = "SELECT INTEGRAL_QTY FROM CUSTOMERITEM "
+						+"WHERE CUST_CODE = '"+custCode+"'"+" AND ITEM_CODE = '"+itemCode+"'";
+				System.out.println("sql :"+sql);
+				rs = stmt.executeQuery(sql);
+				if (rs.next())
+				{
+					integralQty = rs.getDouble(1);
+					//System.out.println("integralQty :"+integralQty);
+				}
+				if (integralQty == 0)
+				{
+					sql = "SELECT INTEGRAL_QTY FROM SITEITEM "
+							+"WHERE SITE_CODE = '"+siteCode+"'"+" AND ITEM_CODE = '"+itemCode+"'";
+					System.out.println("sql :"+sql);
+					rs = stmt.executeQuery(sql);
+					if (rs.next())
+					{
+						integralQty = rs.getDouble(1);
+						//System.out.println("integralQty :"+integralQty);
+					}
+					if (integralQty == 0)
+					{
+						sql = "SELECT INTEGRAL_QTY FROM ITEM WHERE ITEM_CODE = '"+itemCode+"'";
+						System.out.println("sql :"+sql);
+						rs = stmt.executeQuery(sql);
+						if (rs.next())
+						{
+							integralQty = rs.getDouble(1);
+							//System.out.println("integralQty :"+integralQty);
+						}
+					}
+				}
+				if (integralQty > 0)
+				{
+					mod = qty%integralQty;
+					System.out.println("mod :"+mod);
+					noArt = (qty - mod) / integralQty;
+					//System.out.println("noArt :"+noArt);
+				}
+				break;
+			case 'B' :
+				sql = "SELECT CASE WHEN CAPACITY IS NULL THEN 0 ELSE CAPACITY END " 
+						+"FROM PACKING WHERE PACK_CODE = '"+packCode+"'";
+				System.out.println("sql :"+sql);
+				rs = stmt.executeQuery(sql);
+				if (rs.next())
+				{
+					capacity = rs.getDouble(1);
+					//System.out.println("capacity :"+capacity);
+				}
+				else
+				{
+					capacity = 0;
+				}
+				sql = "SELECT REO_QTY FROM SITEITEM WHERE SITE_CODE = '"+siteCode+"' " 
+						+"AND ITEM_CODE = '"+itemCode+"'";
+				System.out.println("sql :"+sql);
+				rs = stmt.executeQuery(sql);
+				if (rs.next())
+				{
+					reoQty = rs.getDouble(1);
+					//System.out.println("reoQty :"+reoQty);
+				}
+				if( reoQty == 0 )
+				{
+					sql = "SELECT REO_QTY FROM ITEM WHERE ITEM_CODE = '"+itemCode+"'";
+					System.out.println("sql :"+sql);
+					rs = stmt.executeQuery(sql);
+					if (rs.next())
+					{
+						reoQty = rs.getDouble(1);
+						//System.out.println("reoQty :"+reoQty);
+					}
+				}
+				if (capacity > 0)
+				{
+					shipperQty = capacity;
+					//System.out.println("shipperQty :"+shipperQty);
+				}
+				else
+				{
+					shipperQty = reoQty;
+					//System.out.println("shipperQty :"+shipperQty);
+				}
+				if (shipperQty > 0)
+				{
+					mod = (qty % shipperQty);
+					noArt1 = (qty - mod) / shipperQty;
+				}
+				sql = "SELECT INTEGRAL_QTY FROM CUSTOMERITEM "
+						+"WHERE CUST_CODE = '"+custCode+"' "
+						+"AND ITEM_CODE = '"+itemCode+"'";
+				System.out.println("sql :"+sql);
+				rs = stmt.executeQuery(sql);
+				if (rs.next())
+				{
+					integralQty = rs.getDouble(1);
+					//System.out.println("integralQty :"+integralQty);
+				}
+				if (integralQty == 0)
+				{
+					sql ="SELECT INTEGRAL_QTY FROM SITEITEM "
+							+"WHERE SITE_CODE = '"+siteCode+"' " 
+							+"AND ITEM_CODE = '"+itemCode+"'";
+					System.out.println("sql :"+sql);
+					rs = stmt.executeQuery(sql);
+					if (rs.next())
+					{
+						integralQty = rs.getDouble(1);
+						//System.out.println("integralQty :"+integralQty);
+					}
+					if(integralQty == 0)
+					{
+						sql = "SELECT INTEGRAL_QTY FROM ITEM WHERE ITEM_CODE = '"+itemCode+"'";
+						System.out.println("sql :"+sql);
+						rs = stmt.executeQuery(sql);
+						if (rs.next())
+						{
+							integralQty = rs.getDouble(1);
+							//System.out.println("integralQty :"+integralQty);
+						}
+					}
+				}
+				double remainder1 = 0d;
+				if (integralQty > 0)
+				{
+					remainder1 = mod % integralQty;
+					System.out.println("remainder1 :"+remainder1);
+					noArt3 =(mod - remainder1) / integralQty;
+					noArt2 = (int)noArt3;
+				}
+				if (noArt2 > 0)
+				{
+					noArt2 = 1;
+				}
+				noArt  = noArt1 + noArt2;
+				System.out.println("noArt :"+noArt);
+			}
+			conn.close();
+			if (noArt == 0)
+			{
+				noArt = 0;
+			}
+		}
+		catch(Exception e)
+		{
+			System.out.println("Exception occures in getNoArt :"+e);
+		}
+		System.out.println("(int)noArt :"+(int)noArt);
+		return (int)noArt;
+	}*/
+}

webitm-dis/ibase/webitm/ejb/dis/ChgUserAllocLocal.java

+package ibase.webitm.ejb.dis;
+
+
+import java.rmi.RemoteException;
+import org.w3c.dom.*;
+
+import ibase.webitm.ejb.ValidatorLocal;
+import ibase.webitm.utility.ITMException;
+import javax.ejb.Local; 
+
+@Local 
+public interface ChgUserAllocLocal 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;
+		
+}
\ No newline at end of file

webitm-dis/ibase/webitm/ejb/dis/ChgUserAllocPostSave.java

+package ibase.webitm.ejb.dis;
+
+import ibase.system.config.ConnDriver;
+import ibase.webitm.ejb.ValidatorEJB;
+import ibase.webitm.utility.GenericUtility;
+import ibase.webitm.utility.ITMException;
+
+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.NodeList;
+
+@javax.ejb.Stateless
+public class ChgUserAllocPostSave extends ValidatorEJB implements ChgUserAllocPostSaveLocal,ChgUserAllocPostSaveRemote{
+	
+	boolean isLocalConn = false;
+	
+	public String postSave(String xmlString,String editFlag,String tranId,  String xtraParams,Connection conn) throws RemoteException,ITMException
+	{
+
+		System.out.println(">>>>>>>>>>>>>>CONNECTION"+conn);
+		System.out.println("------------ DisIssDelWizPostSave postSave method called-----------------");		
+		Document dom = null;
+		String errString="";
+        
+		GenericUtility genericUtility = GenericUtility.getInstance();
+		try
+		{
+			if(xmlString != null && xmlString.trim().length()!=0)
+			{
+				dom = genericUtility.parseString(xmlString); 
+				System.out.println("xmlString  *===> " + xmlString);
+			}
+			
+			//conn = null;
+			if(conn==null){
+				
+				ConnDriver connDriver = new ConnDriver();
+				conn = connDriver.getConnectDB("DriverITM");
+				//connDriver= null;
+				conn.setAutoCommit(false);
+				isLocalConn = true;
+			}
+			errString = postSave(dom,tranId,editFlag,xtraParams,conn);
+
+
+		}
+		catch(Exception e)
+		{
+			System.out.println("Exception : DisIssDelWizPostSave : postSave : ==>\n"+e.getMessage());
+			throw new ITMException(e);
+		}		
+		return errString;
+	}
+
+	public String postSave(Document dom,String tranId,String editflag,String xtraParams,Connection conn)
+	{
+		System.out.println("post save dom arg  --------------- > "+dom);
+		String sql = "", error = "";
+		String distOrder="", chgTerm = "", chgUserNew = "";
+		int cnt = 0;
+		
+		NodeList parentNodeList = null;
+		int ctr=0;
+		int detailListLength = 0;
+
+		System.out.println("tranId in postSave dom ----> "+tranId);
+		
+		PreparedStatement pstmt = null;
+		ResultSet rs=null;
+		try
+		{
+			chgTerm = GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams, "chgTerm");
+			//chgUser = GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams, "loginCode");
+			
+			parentNodeList = dom.getElementsByTagName("Detail2");
+			System.out.println("parentNodeList length >>>>>>>>>>>>>>>>>>>>> "+parentNodeList.getLength());
+			detailListLength = parentNodeList.getLength();
+			for(ctr = 0; ctr < detailListLength; ctr++)
+			{
+				distOrder = GenericUtility.getInstance().getColumnValue("dist_order",dom);
+				chgUserNew = GenericUtility.getInstance().getColumnValue("code",dom);
+				
+				System.out.println("dist_order in DOM --->>" +distOrder);
+				System.out.println("chgUserNew in DOM --->>" +chgUserNew);
+						
+					sql = "update distord_iss set chg_user = ?, chg_term = ?, chg_date = sysdate where dist_order = ? and confirmed = 'N'";
+					pstmt = conn.prepareStatement(sql);
+					pstmt.setString(1, chgUserNew);
+					pstmt.setString(2, chgTerm);
+					pstmt.setString(3, distOrder);
+					cnt = pstmt.executeUpdate();
+					
+					if(pstmt != null){
+						pstmt.close();
+						pstmt = null;
+					}
+					
+					System.out.println(">>>>>>>successfully deleted record ChgUserAllocPostSave cnt = :" + cnt);
+			}	 
+			
+			conn.commit();
+			System.out.println(">>>>>>> commit executed ");
+
+		}catch(Exception e)
+		{
+			try {
+				System.out.println(">>>>>>>>>>>>In catch Before rollback>>>");
+				conn.rollback();
+				System.out.println(">>>>>>>>>>>>rollback  issued >>>");
+			} catch (SQLException e1) {
+				// TODO Auto-generated catch block
+				e1.printStackTrace();
+				error=e1.getMessage();
+			}
+			System.out.println("Exception ::"+e);
+			e.printStackTrace();
+			error=e.getMessage();
+
+		}	
+		finally
+		{
+			try {
+				System.out.println(">>>>>>>>>>>>In finally Before Commit>>>");
+				
+				if(pstmt != null){
+					pstmt.close();
+					pstmt = null;
+				}
+
+				if(rs != null){
+					rs.close();
+					rs = null;
+				}
+				
+				if(isLocalConn){
+					
+					if(conn != null)
+					{
+						conn.close();	
+						conn = null;
+						isLocalConn = false;
+					}
+				}
+				
+			} catch (SQLException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+				error=e.getMessage();
+			}		
+		}
+
+		return error;
+
+	}
+}

webitm-dis/ibase/webitm/ejb/dis/ChgUserAllocPostSaveLocal.java

+package ibase.webitm.ejb.dis;
+import ibase.webitm.ejb.*;
+
+import java.rmi.RemoteException;
+//import javax.ejb.EJBObject;
+import java.sql.Connection;
+
+import ibase.webitm.utility.ITMException;
+import javax.ejb.Local; // added for ejb3
+
+import org.w3c.dom.Document;
+
+@Local // added for ejb3
+
+public interface ChgUserAllocPostSaveLocal extends ValidatorLocal//, EJBObject
+{
+	public String postSave(String xmlString,String tranId,String editFlag, String xtraParams,Connection conn) throws RemoteException,ITMException;
+	public String postSave(Document dom,String tranId,String editflag,String xtraParams,Connection conn);
+
+}
\ No newline at end of file

webitm-dis/ibase/webitm/ejb/dis/ChgUserAllocPostSaveRemote.java

+package ibase.webitm.ejb.dis;
+
+import ibase.webitm.ejb.*;
+
+import java.rmi.RemoteException;
+//import javax.ejb.EJBObject;
+import java.sql.Connection;
+
+import ibase.webitm.utility.ITMException;
+import javax.ejb.Remote; // added for ejb3
+
+import org.w3c.dom.Document;
+
+@Remote // added for ejb3
+
+public interface ChgUserAllocPostSaveRemote extends ValidatorRemote//, EJBObject
+{
+	public String postSave(String xmlString,String tranId,String editFlag, String xtraParams,Connection conn) throws RemoteException,ITMException;
+	public String postSave(Document dom,String tranId,String editflag,String xtraParams,Connection conn);
+
+}
\ No newline at end of file

webitm-dis/ibase/webitm/ejb/dis/ChgUserAllocRemote.java

+package ibase.webitm.ejb.dis;
+
+import java.rmi.RemoteException;
+import org.w3c.dom.*;
+
+import ibase.webitm.ejb.ValidatorRemote;
+import ibase.webitm.utility.ITMException;
+import javax.ejb.Remote;
+
+@Remote 
+public interface ChgUserAllocRemote 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;
+			
+
+}
\ No newline at end of file