Distribution Issue wfValData migration

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

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

@@ -2260,7 +2260,1517 @@ public class DistIssueIC extends ValidatorEJB {
 		}
 		return valueXmlString.toString();
 	}
+	public String wfValData(String xmlString, String xmlString1, String xmlString2, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException
+	{
+		Document dom = null;
+		Document dom1 = null;
+		Document dom2 = null;
+		String errString = "";
+		try
+		{
+			if(xmlString != null && xmlString.trim().length() > 0)
+			   {
+				  dom =  genericUtility.parseString(xmlString);
+			   }
+			   if(xmlString1 != null && xmlString1.trim().length() > 0)
+			   {
+				   dom1 = genericUtility.parseString(xmlString1);
+			   }
+			   if(xmlString2 != null && xmlString2.trim().length() > 0)
+			   {
+				   dom2 = genericUtility.parseString(xmlString2);
+			   }
+			   errString = wfValData(dom,dom1,dom2,objContext,editFlag,xtraParams);
+			   System.out.println("retString:::"+errString);
+		}
+		catch(Exception e)
+		{	
+			errString = genericUtility.createErrorString(e);
+			e.printStackTrace();
+			throw new ITMException(e);
+		}
+		return(errString);
+	}
 	
+	public String wfValData(Document dom, Document dom1, Document dom2, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException
+	{
+		int ctr=0;
+		int childNodeListLength;
+		int currentFormNo = 0;
+		int cnt = 0;
+		NodeList parentNodeList = null;
+		NodeList parentNodeListTemp = null;
+		NodeList childNodeList = null;	
+		Node parentNode = null;
+		Node parentNodeTemp = null;
+		Node childNode = null;		
+		String siteCode = "";
+		String userId = "";
+		String sql="";
+		String errCode="";
+		String errorType = "";
+		String childNodeName = null;
+		String errString = "";
+		ArrayList<String> errList = new ArrayList<String>();
+		ArrayList<String> errFields = new ArrayList<String>();
+		Connection conn = null;
+		PreparedStatement pstmt = null ;
+		ResultSet rs = null;
+		String existFlag = "",projCodeOrd="",projCode="",siteCodeBil="",locCode="",tranDate="",availableYN="",chkDate="",expDate="",lotNo="",transitLoc="";
+		String distOrder = "",tranType="",distIss="",confirm="",status="",tranTypeParent="",tranTypeOrd="",tranTypeOrderParent="",tranTypeIssueParent="";
+		String site_code="",loginSiteCode="",mVal="",tranCode="",currCode="",shipmentId="",rdPermitNo="",siteDlv="",stateFrom="",stateTo="",permitReqd="",stanCd="";
+		String invStatAvailable="",invStat="",siteCodeMfg="",suppSour="",itemCode="",mfgDate="",track="",packCode="",checkIntegralQty="",lotSl="",stkOpt="";
+		java.util.Date chkDate1 = null, expDate1 = null;
+		String tranDateStr="";
+		int mminShelfLife=0,parentNodeListLength = 0;
+		String	lineNoDOrd="",lineNo="";
+		double rate=0.0,quantity=0.0,totQty=0.0,balQty=0.0,overShipPerc=0.0,qtyBrow=0.0,integralQty=0.0,modQty=0.0,stkQty=0.0,oldQty=0.0,qtyOrderAlt=0.0,rateAlt=0.0,batchSize=0.0,mBatchSize=0.0;
+	    Timestamp TranDate=null;
+		boolean stkExpFlag = false;
+		StringBuffer errStringXml = new StringBuffer("<?xml version = \"1.0\"?> \r\n <Root> <Errors>"); 
+		try
+		{
+			SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
+			conn = getConnection();
+			userId = getValueFromXTRA_PARAMS(xtraParams, "loginCode");
+			if (objContext != null && objContext.trim().length() > 0)
+			{
+				currentFormNo = Integer.parseInt(objContext);
+			}
+			
+			switch (currentFormNo)
+			{
+				
+				case 1:
+
+					parentNodeList = dom.getElementsByTagName("Detail1");
+					parentNode = parentNodeList.item(0);
+					childNodeList = parentNode.getChildNodes();
+					childNodeListLength = childNodeList.getLength();
+					for(ctr = 0; ctr < childNodeListLength; ctr ++)
+					{
+						childNode = childNodeList.item(ctr);
+						childNodeName = childNode.getNodeName();
+						if("dist_order".equalsIgnoreCase(childNodeName))
+						{
+							distOrder = checkNullAndTrim(genericUtility.getColumnValue("dist_order", dom)); 
+							tranType = checkNullAndTrim(genericUtility.getColumnValue("tran_type", dom)); 
+							distIss = checkNullAndTrim(genericUtility.getColumnValue("tran_id", dom)); 
+							
+								sql = "SELECT COUNT(*) FROM DISTORDER WHERE DIST_ORDER = ?";
+								pstmt = conn.prepareStatement(sql);
+								pstmt.setString(1, distOrder);
+								rs = pstmt.executeQuery();
+								if (rs.next())
+								{
+									cnt = rs.getInt(1);
+									
+								}
+								pstmt.close(); pstmt = null;
+								rs.close(); rs = null;
+								if (cnt == 0)
+								{
+									errCode = "VTDIST2";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+								else
+								{
+									sql = "select confirmed, status from distorder where dist_order = ?";
+									pstmt = conn.prepareStatement(sql);
+									pstmt.setString(1, distOrder);
+									rs = pstmt.executeQuery();
+									if (rs.next())
+									{
+										confirm = rs.getString("confirmed");
+										status = rs.getString("status");
+										
+									}
+									pstmt.close(); pstmt = null;
+									rs.close(); rs = null;
+									if(confirm != null  && !"Y".equalsIgnoreCase(confirm))
+									{
+										errCode = "VTDIST3";
+										errList.add(errCode);
+										errFields.add(childNodeName.toLowerCase());
+									}
+									else
+									{
+										if(status != null  && !"P".equalsIgnoreCase(status))
+										{	
+											sql = "select tran_type__parent from distorder_type where tran_type =  ?";
+											pstmt = conn.prepareStatement(sql);
+											pstmt.setString(1, tranType);
+											rs = pstmt.executeQuery();
+											if (rs.next())
+											{
+												tranTypeParent = checkNullAndTrim(rs.getString("tran_type__parent"));
+												
+												
+											}
+											pstmt.close(); pstmt = null;
+											rs.close(); rs = null;
+											if(tranTypeParent.equalsIgnoreCase(tranType))
+											{
+												errCode = "VTDIST20";
+												errList.add(errCode);
+												errFields.add(childNodeName.toLowerCase());
+											}
+										}
+									}
+									
+								}
+
+							
+							
+							sql = "Select count(*) From	 distord_iss Where  dist_order = ? and tran_id <> ? and confirmed = 'N'";
+							pstmt = conn.prepareStatement(sql);
+							pstmt.setString(1, distOrder);
+							pstmt.setString(2, distIss);
+							rs= pstmt.executeQuery();
+							if (rs.next())
+							{
+								if (rs.getInt(1) > 0)
+								{
+									errCode = "VTINVDO1";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+							}
+							if(pstmt != null)
+							{
+								pstmt.close(); 
+								pstmt = null;
+							}
+							if(rs != null)
+							{
+								rs.close();
+								rs = null;
+							}
+							
+							
+						}// end of dist_order if block 
+						else if(childNodeName.equalsIgnoreCase("tran_type"))
+						{    
+							distOrder = checkNullAndTrim(genericUtility.getColumnValue("dist_order", dom)); 
+							tranType = checkNullAndTrim(genericUtility.getColumnValue("tran_type", dom)); 
+							sql = "select count(*) from distorder_type where tran_type = ? ";
+							pstmt = conn.prepareStatement(sql);
+							pstmt.setString(1, tranType);
+							rs= pstmt.executeQuery();
+							if (rs.next())
+							{
+								cnt = rs.getInt(1);
+								
+							}
+							pstmt.close(); pstmt = null;
+							rs.close(); rs = null;
+							if (cnt == 0)
+							{
+								errCode = "VMIDOT";
+								errList.add(errCode);
+								errFields.add(childNodeName.toLowerCase());
+							}
+							sql = "select tran_type from distorder where dist_order = ? ";
+							pstmt = conn.prepareStatement(sql);
+							pstmt.setString(1, distOrder);
+							rs= pstmt.executeQuery();
+							if (rs.next())
+							{
+								tranTypeOrd = rs.getString("tran_type");
+								
+							}
+							pstmt.close(); pstmt = null;
+							rs.close(); rs = null;
+							sql = "select tran_type__parent from distorder_type where tran_type = ? ";
+							pstmt = conn.prepareStatement(sql);
+							pstmt.setString(1, tranTypeOrd);
+							rs= pstmt.executeQuery();
+							if (rs.next())
+							{
+								tranTypeOrderParent = rs.getString("tran_type__parent");
+								
+							}
+							pstmt.close(); pstmt = null;
+							rs.close(); rs = null;
+							sql = "select tran_type__parent from distorder_type where tran_type = ? ";
+							pstmt = conn.prepareStatement(sql);
+							pstmt.setString(1, tranType);
+							rs= pstmt.executeQuery();
+							if (rs.next())
+							{
+								tranTypeIssueParent = rs.getString("tran_type__parent");
+								
+							}
+							pstmt.close(); pstmt = null;
+							rs.close(); rs = null;
+							
+							if(!tranTypeOrderParent.equalsIgnoreCase(tranTypeIssueParent))
+							{
+								errCode = "VTCRET";
+								errList.add(errCode);
+								errFields.add(childNodeName.toLowerCase());
+							}
+						}// end of if block
+						else if (childNodeName.equalsIgnoreCase("tran_date"))
+						{
+							tranDateStr = checkNullAndTrim(genericUtility.getColumnValue("tran_date", dom));
+							siteCode = checkNullAndTrim(genericUtility.getColumnValue("site_code", dom));
+							System.out.println("@@@@ Tran Date[" + tranDateStr + "]");
+							TranDate = Timestamp.valueOf(genericUtility.getValidDateString(tranDateStr.toString(),genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat())+" 00:00:00.0");
+							System.out.println("Trandate is"+TranDate);
+							errCode = finCommon.nfCheckPeriod("DIS", TranDate,siteCode, conn);
+							System.out.println("Errorcode in TranDate"+errCode);
+							if (errCode != null && errCode.trim().length() > 0)
+							  {
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+							  }
+						}
+						else if(childNodeName.equalsIgnoreCase("site_code"))
+						{    
+							siteCode = genericUtility.getColumnValue("site_code", dom);
+							System.out.println("siteCode: " + siteCode);
+							
+								if (siteCode != null && siteCode.trim().length() > 0) {
+									if (!(isExist(conn, "site", "site_code", siteCode))) {
+										errCode = "VTSITE1";
+										errList.add(errCode);
+										errFields.add(childNodeName.toLowerCase());
+									}
+								}
+						}// end of if block for site_code
+						
+						
+						
+						else if("dist_route".equalsIgnoreCase(childNodeName))
+						{
+							mVal = checkNullAndTrim(genericUtility.getColumnValue("dist_route", dom)); 
+							if (mVal != null && mVal.trim().length() > 0) {
+								
+								sql = "select count(*) from distroute where dist_route  = ? ";
+								pstmt = conn.prepareStatement(sql);
+								pstmt.setString(1, mVal);
+								rs= pstmt.executeQuery();
+								if (rs.next())
+								{
+									cnt = rs.getInt(1);
+									
+								}
+								pstmt.close(); pstmt = null;
+								rs.close(); rs = null;
+								if (cnt == 0)
+								{
+									errCode = "VTDISTRT1";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+							}
+							
+							
+						}// end of if block 
+						else if ("site_code__dlv".equalsIgnoreCase(childNodeName)) 
+						{
+							mVal = checkNullAndTrim(genericUtility.getColumnValue("site_code__dlv", dom)); 
+							siteCode = checkNullAndTrim(genericUtility.getColumnValue("site_code", dom)); 
+							distOrder = checkNullAndTrim(genericUtility.getColumnValue("dist_order", dom)); 
+								
+								sql = "select count(*) from site where site_code  = ? ";
+								pstmt = conn.prepareStatement(sql);
+								pstmt.setString(1, mVal);
+								rs= pstmt.executeQuery();
+								if (rs.next())
+								{
+									cnt = rs.getInt(1);
+									
+								}
+								pstmt.close(); pstmt = null;
+								rs.close(); rs = null;
+								if (cnt == 0)
+								{
+									errCode = "VTSITE1";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+								else
+								{
+									errCode = gbfDistOrderSite( distOrder, siteCode, mVal, conn );
+									if (errCode != null && errCode.trim().length() > 0)
+									  {
+											errList.add(errCode);
+											errFields.add(childNodeName.toLowerCase());
+									  }
+								}
+							
+						}
+						else if ("tran_code".equalsIgnoreCase(childNodeName)) 
+						{
+							tranCode = checkNullAndTrim(genericUtility.getColumnValue("tran_code", dom)); 
+							if (tranCode != null && tranCode.trim().length() > 0) {								
+								sql = "select count(*) from transporter where tran_code  = ? ";
+								pstmt = conn.prepareStatement(sql);
+								pstmt.setString(1, tranCode);
+								rs= pstmt.executeQuery();
+								if (rs.next())
+								{
+									cnt = rs.getInt(1);
+									
+								}
+								pstmt.close(); pstmt = null;
+								rs.close(); rs = null;
+								if (cnt == 0)
+								{
+									errCode = "VTTRANCD1";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+								
+							}
+						}
+						else if ("loc_code__git".equalsIgnoreCase(childNodeName)) 
+						{
+							mVal = checkNullAndTrim(genericUtility.getColumnValue("loc_code__git", dom)); 
+														
+								sql = "select count(*) from location where loc_code  = ? ";
+								pstmt = conn.prepareStatement(sql);
+								pstmt.setString(1, mVal);
+								rs= pstmt.executeQuery();
+								if (rs.next())
+								{
+									cnt = rs.getInt(1);
+									
+								}
+								pstmt.close(); pstmt = null;
+								rs.close(); rs = null;
+								if (cnt == 0)
+								{
+									errCode = "VTLOC1";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+								
+						}
+						else if ("curr_code".equalsIgnoreCase(childNodeName)) 
+						{
+							currCode = checkNullAndTrim(genericUtility.getColumnValue("curr_code", dom)); 						
+								sql = "select count(*) from currency where curr_code  = ? ";
+								pstmt = conn.prepareStatement(sql);
+								pstmt.setString(1, currCode);
+								rs= pstmt.executeQuery();
+								if (rs.next())
+								{
+									cnt = rs.getInt(1);
+									
+								}
+								pstmt.close(); pstmt = null;
+								rs.close(); rs = null;
+								if (cnt == 0)
+								{
+									errCode = "VTCURRCD1";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+						}
+						else if ("shipment_id".equalsIgnoreCase(childNodeName)) 
+						{
+							shipmentId = checkNullAndTrim(genericUtility.getColumnValue("shipment_id", dom)); 
+							if (shipmentId != null && shipmentId.trim().length() > 0) {								
+								sql = "select count(1) from   shipment where  shipment_id  = ? and    confirmed = 'N' ";
+								pstmt = conn.prepareStatement(sql);
+								pstmt.setString(1, shipmentId);
+								rs= pstmt.executeQuery();
+								if (rs.next())
+								{
+									cnt = rs.getInt(1);
+									
+								}
+								pstmt.close(); pstmt = null;
+								rs.close(); rs = null;
+								if (cnt == 0)
+								{
+									errCode = "VTSHPID";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+								
+							}
+						}
+						else if ("rd_permit_no".equalsIgnoreCase(childNodeName)) 
+						{
+							rdPermitNo =checkNullAndTrim(genericUtility.getColumnValue("rd_permit_no", dom));
+							siteCode = checkNullAndTrim(genericUtility.getColumnValue("site_code", dom)); 
+							siteDlv = checkNullAndTrim(genericUtility.getColumnValue("site_code__dlv", dom));
+							distIss = checkNullAndTrim(genericUtility.getColumnValue("tran_id", dom)); 
+								sql = "select a.state_code,b.state_code from site a , site b where a.site_code = ? and b.site_code = ? ";
+								pstmt = conn.prepareStatement(sql);
+								pstmt.setString(1, siteCode);
+								pstmt.setString(2, siteDlv);
+								rs= pstmt.executeQuery();
+								if (rs.next())
+								{
+									stateFrom = checkNullAndTrim(rs.getString(1));
+									stateTo = checkNullAndTrim(rs.getString(2));
+									
+								}
+								pstmt.close(); pstmt = null;
+								rs.close(); rs = null;
+								if (!stateFrom.equalsIgnoreCase(stateTo))
+								{
+									sql = "select stan_code from site where site_code = ? ";
+									pstmt = conn.prepareStatement(sql);
+									pstmt.setString(1, siteDlv);
+									rs= pstmt.executeQuery();
+									if (rs.next())
+									{
+										stanCd = checkNullAndTrim(rs.getString("stan_code"));
+										
+										
+									}
+									pstmt.close(); pstmt = null;
+									rs.close(); rs = null;
+									sql = "select rd_permit_reqd from station where stan_code = ? ";
+									pstmt = conn.prepareStatement(sql);
+									pstmt.setString(1, stanCd);
+									rs= pstmt.executeQuery();
+									if (rs.next())
+									{
+										permitReqd = checkNullAndTrim(rs.getString(1));
+										
+									}
+									pstmt.close(); pstmt = null;
+									rs.close(); rs = null;
+									if ("Y".equalsIgnoreCase(permitReqd))
+									{
+										if(rdPermitNo.length()< 1)
+										{
+											errCode = "VTRDPT";
+											errList.add(errCode);
+											errFields.add(childNodeName.toLowerCase());
+										}
+										else
+										{
+											sql = "select count(*) from roadpermit where rd_permit_no = ? and status = 'O' and stan_code__to = ? ";
+											pstmt = conn.prepareStatement(sql);
+											pstmt.setString(1, rdPermitNo);
+											pstmt.setString(2, stanCd);
+											rs= pstmt.executeQuery();
+											if (rs.next())
+											{
+												cnt = rs.getInt(1);
+												
+											}
+											pstmt.close(); pstmt = null;
+											rs.close(); rs = null;
+											if (cnt == 0)
+											{
+												errCode = "VTRDPT1";
+												errList.add(errCode);
+												errFields.add(childNodeName.toLowerCase());
+											}
+											else
+											{
+												sql = "select count(*) from distord_iss where rd_permit_no = ? and site_code__dlv = ? and tran_id <> ? ";
+												pstmt = conn.prepareStatement(sql);
+												pstmt.setString(1, rdPermitNo);
+												pstmt.setString(2, siteDlv);
+												pstmt.setString(3, distIss);
+												rs= pstmt.executeQuery();
+												if (rs.next())
+												{
+													cnt = rs.getInt(1);
+													
+												}
+												pstmt.close(); pstmt = null;
+												rs.close(); rs = null;
+												if (cnt > 0)
+												{
+													errCode = "VTRDPT2";
+													errList.add(errCode);
+													errFields.add(childNodeName.toLowerCase());
+												}
+											}
+										}
+										
+									}
+								}
+								else if(rdPermitNo.length()> 0)
+								{
+									errCode = "VTRDPT1";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+								
+						}
+						else if ("proj_code".equalsIgnoreCase(childNodeName)) 
+						{
+							projCode = checkNullAndTrim(genericUtility.getColumnValue("proj_code", dom)); 
+							if (projCode != null && projCode.trim().length() > 0) {		
+								distOrder = checkNullAndTrim(genericUtility.getColumnValue("dist_order", dom)); 
+								sql = "select case when proj_code is null then ' ' else proj_code end from distorder where dist_order = ?";
+								pstmt = conn.prepareStatement(sql);
+								pstmt.setString(1, distOrder);
+								rs= pstmt.executeQuery();
+								if (rs.next())
+								{
+									projCodeOrd =checkNullAndTrim(rs.getString(1));
+									
+								}
+								pstmt.close(); pstmt = null;
+								rs.close(); rs = null;
+								if (projCodeOrd.trim().length() > 0) {		
+									if (!projCodeOrd.equalsIgnoreCase(projCode))
+									{
+										errCode = "VTPROMISMT";
+										errList.add(errCode);
+										errFields.add(childNodeName.toLowerCase());
+									}
+								}
+								sql = "select (case when proj_status is null then ' ' else proj_status end) from project where proj_code = ?";
+								pstmt = conn.prepareStatement(sql);
+								pstmt.setString(1, projCode);
+								rs= pstmt.executeQuery();
+								if (rs.next())
+								{
+									status =checkNullAndTrim(rs.getString(1));
+									
+								}
+								pstmt.close(); pstmt = null;
+								rs.close(); rs = null;
+								/*elseif get_sqlcode() = 100 then
+										errcode = "VMPROJCDX"*/
+								if (!"A".equalsIgnoreCase(status))
+								{
+									errCode = "VTPROJ2";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+							}
+						}
+						else if ("site_code__bil".equalsIgnoreCase(childNodeName)) 
+						{
+							siteCodeBil = checkNullAndTrim(genericUtility.getColumnValue("site_code__bil", dom)); 	
+							if (siteCodeBil != null && siteCodeBil.trim().length() > 0) {	
+								sql = "select count(*) from site where site_code = ? ";
+								pstmt = conn.prepareStatement(sql);
+								pstmt.setString(1, siteCodeBil);
+								rs= pstmt.executeQuery();
+								if (rs.next())
+								{
+									cnt = rs.getInt(1);
+									
+								}
+								pstmt.close(); pstmt = null;
+								rs.close(); rs = null;
+								if (cnt == 0)
+								{
+									errCode = "VTBILSITE";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+						    }
+						}
+						
+					}
+				break;
+				case 2:
+					parentNodeList = dom.getElementsByTagName("Detail2");
+					parentNode = parentNodeList.item(0);
+					childNodeList = parentNode.getChildNodes();
+					childNodeListLength = childNodeList.getLength();
+					System.out.println("@@@@@@@@@@@@childNodeListLength["+ childNodeListLength + "]");
+					for (ctr = 0; ctr < childNodeListLength; ctr++) 
+					{
+						childNode = childNodeList.item(ctr);
+						childNodeName = childNode.getNodeName();
+						if("dist_order".equalsIgnoreCase(childNodeName))
+						{ 
+							distOrder = checkNullAndTrim(genericUtility.getColumnValue("dist_order", dom)); 
+							distIss = checkNullAndTrim(genericUtility.getColumnValue("tran_id", dom)); 
+							tranType = checkNullAndTrim(genericUtility.getColumnValue("tran_type", dom1)); 
+							sql = "select tran_type__parent from distorder_type where tran_type =  ?";
+							pstmt = conn.prepareStatement(sql);
+							pstmt.setString(1, tranType);
+							rs = pstmt.executeQuery();
+							if (rs.next())
+							{
+								tranTypeParent = checkNullAndTrim(rs.getString("tran_type__parent"));
+								
+								
+							}
+							pstmt.close(); pstmt = null;
+							rs.close(); rs = null;
+							if(!tranTypeParent.equalsIgnoreCase(tranType))
+							{
+								sql = "SELECT COUNT(*) FROM DISTORDER WHERE DIST_ORDER = ? AND CONFIRMED = 'Y' ";
+								pstmt = conn.prepareStatement(sql);
+								pstmt.setString(1, distOrder);
+								rs = pstmt.executeQuery();
+								if (rs.next())
+								{
+									cnt = rs.getInt(1);
+									
+								}
+								pstmt.close(); pstmt = null;
+								rs.close(); rs = null;
+								
+							}
+							else
+							{
+								sql = "SELECT COUNT(*) FROM DISTORDER WHERE DIST_ORDER = ? AND CONFIRMED = 'Y'  AND STATUS = 'P' ";
+								pstmt = conn.prepareStatement(sql);
+								pstmt.setString(1, distOrder);
+								rs = pstmt.executeQuery();
+								if (rs.next())
+								{
+									cnt = rs.getInt(1);
+									
+								}
+								pstmt.close(); pstmt = null;
+								rs.close(); rs = null;
+							}
+							if (cnt == 0)
+							{
+								errCode = "VTDIST2";
+								errList.add(errCode);
+								errFields.add(childNodeName.toLowerCase());
+							}
+							else
+							{
+								siteCode = checkNullAndTrim(genericUtility.getColumnValue("site_code", dom1)); 
+								siteDlv = checkNullAndTrim(genericUtility.getColumnValue("site_code__dlv", dom1));
+								errCode = gbfDistOrderSite( distOrder, siteCode, siteDlv, conn );
+								if (errCode != null && errCode.trim().length() > 0)
+								  {
+										errList.add(errCode);
+										errFields.add(childNodeName.toLowerCase());
+								  }
+							}
+							tranType = checkNullAndTrim(genericUtility.getColumnValue("tran_type", dom1)); 
+							sql = "select tran_type from distorder where dist_order =  ?";
+							pstmt = conn.prepareStatement(sql);
+							pstmt.setString(1, distOrder);
+							rs = pstmt.executeQuery();
+							if (rs.next())
+							{
+								tranTypeOrd = checkNullAndTrim(rs.getString("tran_type"));
+								
+								
+							}
+							pstmt.close(); pstmt = null;
+							rs.close(); rs = null;
+							if(!tranTypeOrd.equalsIgnoreCase(tranType))
+							{
+								errCode = "VTIDOTT";
+								errList.add(errCode);
+								errFields.add(childNodeName.toLowerCase());
+							}
+							sql = "Select count(*) From	 distord_iss Where  dist_order = ? and tran_id <> ? and confirmed = 'N'";
+							pstmt = conn.prepareStatement(sql);
+							pstmt.setString(1, distOrder);
+							pstmt.setString(2, distIss);
+							rs= pstmt.executeQuery();
+							if (rs.next())
+							{
+								if (rs.getInt(1) > 0)
+								{
+									errCode = "VTINVDO1";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+							}
+							if(pstmt != null)
+							{
+								pstmt.close(); 
+								pstmt = null;
+							}
+							if(rs != null)
+							{
+								rs.close();
+								rs = null;
+							}
+							
+					}// end of if block 
+					else if("item_code".equalsIgnoreCase(childNodeName))
+						{
+							mVal = checkNullAndTrim(genericUtility.getColumnValue("item_code", dom)); 
+							locCode = checkNullAndTrim(genericUtility.getColumnValue("loc_code", dom)); 
+							siteCode = checkNullAndTrim(genericUtility.getColumnValue("site_code", dom1)); 
+							tranDate = checkNullAndTrim(genericUtility.getColumnValue("tran_date", dom1)); 
+							String transer =null;
+							transer = "D-ISS";
+							errCode = itmDBAccessEJB.isItem( siteCode, mVal, transer, conn );
+							if (errCode != null && errCode.trim().length() > 0)
+							{
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+						    }
+							sql = "select (case when min_shelf_life is null then 0 else min_shelf_life end) from item where item_code = ?";
+							pstmt = conn.prepareStatement(sql);
+							pstmt.setString(1, mVal);
+							rs= pstmt.executeQuery();
+							if (rs.next())
+							{
+								mminShelfLife =rs.getInt(1);
+								
+							}
+							pstmt.close(); pstmt = null;
+							rs.close(); rs = null;
+							availableYN = checkNullAndTrim(genericUtility.getColumnValue("available_yn", dom1)); 
+							String varValue = "",stkExpLoc = "";
+							
+							varValue = itmDBAccessEJB.getEnvDis("999999","NEAREXP_LOC",conn);
+							if(varValue != null && varValue.trim().length() > 0 && !(varValue.equalsIgnoreCase("NULLFOUND")))
+							{
+								stkExpLoc = varValue;
+							}
+							stkExpFlag = false;
+							String token = "";
+							StringTokenizer stToken = new StringTokenizer(stkExpLoc,",");
+							while(stToken.hasMoreTokens())
+							{
+								token = stToken.nextToken();
+								if(locCode.equalsIgnoreCase(token))
+								{
+									stkExpFlag = true;
+									break;
+								}
+							}
+							if(stkExpFlag == false){
+								if("Y".equalsIgnoreCase(availableYN))
+								{
+									if(mminShelfLife > 0)
+									{
+										chkDate = calcExpiry(tranDate,mminShelfLife);
+										chkDate1 = sdf.parse(chkDate);
+										expDate = genericUtility.getColumnValue("exp_date", dom); 
+										if(expDate != null)
+										{
+											expDate1 = sdf.parse(expDate);
+												System.out.println("expDate1 :"+expDate1);
+											if (chkDate1.compareTo(expDate1) > 0)
+												{
+													errCode = "VTSHELF01";
+													errList.add(errCode);
+													errFields.add(childNodeName.toLowerCase());
+												}
+											}	
+										
+									}
+								}
+							}
+							
+							lotNo = checkNullAndTrim(genericUtility.getColumnValue("lot_no", dom)); 
+							/*li_mth = Month(date(mtrandate))
+									if li_mth >=1 and li_mth <=3 then
+										ls_nxt_yr = '01-04-' + string(year(date(mtrandate)))					
+									else
+										ls_nxt_yr = '01-04-' + string(year(date(mtrandate))+1)
+									end if
+									ldt_nxt_yr = Datetime(Date(ls_nxt_yr))
+									select count(*) into :cnt from cenvat 
+									 where site_code = :msite_code  and item_code = :mVal and tran_date >= :ldt_nxt_yr 
+									 and   lot_no = :mlot_no and tran_type = 'C';
+									if get_sqlcode() < 0 then
+										errcode = 'DS000'+TRIM(STRING(SQLCA.SQLDBCODE)) + TRIM(SQLCA.SQLERRTEXT)
+									end if
+									if cnt > 0 then
+										errcode = "VTCENITM"
+									end if */ //pb code not migrated   
+						}// end of if block 
+						
+						else if("rate".equalsIgnoreCase(childNodeName))
+						{
+							rate = checkDoubleNull(genericUtility.getColumnValue("rate", dom)); 
+							if(rate < 0)
+							{
+								errCode = "VTRATE1";  
+								errList.add(errCode);
+								errFields.add(childNodeName.toLowerCase());
+							}
+						}// end of if block 
+						else if("rate__clg".equalsIgnoreCase(childNodeName))
+						{
+							rate = checkDoubleNull(genericUtility.getColumnValue("rate__clg", dom)); 
+							if(rate < 0)
+							{
+								errCode = "VTRATE1";  
+								errList.add(errCode);
+								errFields.add(childNodeName.toLowerCase());
+							}
+						}// end of if block 
+						else if("loc_code".equalsIgnoreCase(childNodeName))
+						{
+							locCode = checkNullAndTrim(genericUtility.getColumnValue("loc_code", dom)); 
+							sql = "SELECT COUNT(*) from location where loc_code = ? ";
+							pstmt = conn.prepareStatement(sql);
+							pstmt.setString(1, locCode);
+							rs = pstmt.executeQuery();
+							if (rs.next())
+							{
+								cnt = rs.getInt(1);
+								
+							}
+							pstmt.close(); pstmt = null;
+							rs.close(); rs = null;
+						
+							if (cnt == 0)
+							{
+								errCode = "VTLOC1";
+								errList.add(errCode);
+								errFields.add(childNodeName.toLowerCase());
+							}
+							else
+							{
+								transitLoc = checkNullAndTrim(genericUtility.getColumnValue("loc_code__git", dom1)); 
+								if(transitLoc.equalsIgnoreCase(locCode))
+								{
+									errCode = "VTTRANSIT";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+								else
+								{
+									availableYN = checkNullAndTrim(genericUtility.getColumnValue("available_yn", dom1)); 
+									sql = "select inv_stat from location where loc_code =  ?";
+									pstmt = conn.prepareStatement(sql);
+									pstmt.setString(1, locCode);
+									rs = pstmt.executeQuery();
+									if (rs.next())
+									{
+										invStat = checkNullAndTrim(rs.getString("inv_stat"));
+										
+										
+									}
+									pstmt.close(); pstmt = null;
+									rs.close(); rs = null;
+									sql = "select available from invstat where inv_stat =  ?";
+									pstmt = conn.prepareStatement(sql);
+									pstmt.setString(1, invStat);
+									rs = pstmt.executeQuery();
+									if (rs.next())
+									{
+										invStatAvailable = checkNullAndTrim(rs.getString("available"));
+										
+										
+									}
+									pstmt.close(); pstmt = null;
+									rs.close(); rs = null;
+									if(!invStatAvailable.equalsIgnoreCase(availableYN))
+									{
+										errCode = "VTAVAIL";
+										errList.add(errCode);
+										errFields.add(childNodeName.toLowerCase());
+									}
+								}
+							}
+							
+						}// end of if block 
+						else if("tax_class".equalsIgnoreCase(childNodeName))
+						{
+							mVal = checkNullAndTrim(genericUtility.getColumnValue("tax_class", dom)); 
+							if (mVal != null && mVal.trim().length() > 0)
+							{
+								sql = "Select Count(*) from taxclass where tax_class = ? ";
+								pstmt = conn.prepareStatement(sql);
+								pstmt.setString(1, mVal);
+								rs = pstmt.executeQuery();
+								if (rs.next())
+								{
+									cnt = rs.getInt(1);
+									
+								}
+								pstmt.close(); pstmt = null;
+								rs.close(); rs = null;
+							
+								if (cnt == 0)
+								{
+									errCode = "VTTCLASS1";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+						    }
+						}// end of if block
+						else if("tax_chap".equalsIgnoreCase(childNodeName))
+						{
+							mVal = checkNullAndTrim(genericUtility.getColumnValue("tax_chap", dom)); 
+							if (mVal != null && mVal.trim().length() > 0)
+							{
+								sql = "Select Count(*) from taxchap where tax_chap = ? ";
+								pstmt = conn.prepareStatement(sql);
+								pstmt.setString(1, mVal);
+								rs = pstmt.executeQuery();
+								if (rs.next())
+								{
+									cnt = rs.getInt(1);
+									
+								}
+								pstmt.close(); pstmt = null;
+								rs.close(); rs = null;
+							
+								if (cnt == 0)
+								{
+									errCode = "VTTCHAP1";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+						    }
+						}// end of if block
+						else if("tax_env".equalsIgnoreCase(childNodeName))
+						{
+							mVal = checkNullAndTrim(genericUtility.getColumnValue("tax_env", dom)); 
+							if (mVal != null && mVal.trim().length() > 0)
+							{
+								sql = "Select Count(*) from taxenv where tax_env = ? ";
+								pstmt = conn.prepareStatement(sql);
+								pstmt.setString(1, mVal);
+								rs = pstmt.executeQuery();
+								if (rs.next())
+								{
+									cnt = rs.getInt(1);
+									
+								}
+								pstmt.close(); pstmt = null;
+								rs.close(); rs = null;
+							
+								if (cnt == 0)
+								{
+									errCode = "VTTENV1";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+								else
+								{
+									tranDate = checkNullAndTrim(genericUtility.getColumnValue("tran_date", dom1)); 		
+									if( tranDate != null && tranDate.trim().length() > 0 )
+									{
+										TranDate = Timestamp.valueOf(genericUtility.getValidDateString(tranDate, genericUtility.getApplDateFormat(), genericUtility.getDBDateFormat()) + " 00:00:00.0");		
+									}
+									errCode = finCommon.checkTaxEnvStatus(mVal, TranDate, conn);
+									System.out.println("#### checkTaxEnvStatus::errCode["+errCode+"]");
+									if (errCode != null && errCode.trim().length() > 0)
+									{								
+										errList.add(errCode);
+										errFields.add(childNodeName.toLowerCase());
+									}	
+								}
+						    }
+						}// end of if block
+						else if("lot_no".equalsIgnoreCase(childNodeName))
+						{
+							lotNo = checkNullAndTrim(genericUtility.getColumnValue("lot_no", dom)); 
+							if (lotNo == null || lotNo.trim().length() == 0)
+							{
+									errCode = "VTDIST9";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+						    }
+						}// end of if block
+						else if("site_code__mfg".equalsIgnoreCase(childNodeName))
+						{
+							siteCodeMfg = checkNullAndTrim(genericUtility.getColumnValue("site_code__mfg", dom)); 
+							itemCode = checkNullAndTrim(genericUtility.getColumnValue("item_code", dom)); 
+							sql = "select (case when supp_sour is null  then 'M' else supp_sour end ) from item where item_code  =  ?";
+							pstmt = conn.prepareStatement(sql);
+							pstmt.setString(1, itemCode);
+							rs = pstmt.executeQuery();
+							if (rs.next())
+							{
+								suppSour = checkNullAndTrim(rs.getString(1));
+								
+								
+							}
+							pstmt.close(); pstmt = null;
+							rs.close(); rs = null;
+							if("M".equalsIgnoreCase(suppSour))
+							{
+								if (siteCodeMfg == null || siteCodeMfg.trim().length() == 0)
+								{
+									errCode = "VTSITEMFG1";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+							}
+						}// end of if block
+						else if("mfg_date".equalsIgnoreCase(childNodeName))
+						{
+							mfgDate = genericUtility.getColumnValue("mfg_date", dom); 
+							itemCode = checkNullAndTrim(genericUtility.getColumnValue("item_code", dom)); 
+							sql = "select (case when track_shelf_life is null then 'N' else track_shelf_life end ) from item where item_code  =  ?";
+							pstmt = conn.prepareStatement(sql);
+							pstmt.setString(1, itemCode);
+							rs = pstmt.executeQuery();
+							if (rs.next())
+							{
+								track = checkNullAndTrim(rs.getString(1));
+								
+								
+							}
+							pstmt.close(); pstmt = null;
+							rs.close(); rs = null;
+							if("Y".equalsIgnoreCase(track))
+							{
+								if (mfgDate == null || mfgDate.trim().length() == 0)
+								{
+									errCode = "VTMFGDATE3";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+							}
+						}// end of if block
+						else if("exp_date".equalsIgnoreCase(childNodeName))
+						{
+							expDate = genericUtility.getColumnValue("exp_date", dom); 
+							itemCode = checkNullAndTrim(genericUtility.getColumnValue("item_code", dom)); 
+							sql = "select (case when track_shelf_life is null then 'N' else track_shelf_life end ) from item where item_code  =  ?";
+							pstmt = conn.prepareStatement(sql);
+							pstmt.setString(1, itemCode);
+							rs = pstmt.executeQuery();
+							if (rs.next())
+							{
+								track = checkNullAndTrim(rs.getString(1));
+								
+							}
+							pstmt.close(); pstmt = null;
+							rs.close(); rs = null;
+							if("Y".equalsIgnoreCase(track))
+							{
+								if (expDate == null || expDate.trim().length() == 0)
+								{
+									errCode = "VTEXPDATE1";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+							}
+						}// end of if block
+						else if("quantity".equalsIgnoreCase(childNodeName))
+						{
+							distOrder = checkNullAndTrim(genericUtility.getColumnValue("dist_order", dom)); 
+							lineNoDOrd = checkNullAndTrim(genericUtility.getColumnValue("line_no_dist_order", dom)); 
+							quantity = checkDoubleNull(genericUtility.getColumnValue("quantity", dom)); 
+							distIss = checkNullAndTrim(genericUtility.getColumnValue("tran_id", dom));
+							if (distIss == null || distIss.trim().length() == 0)
+							{
+								distIss="@@";
+							}
+							lineNo = checkNullAndTrim(genericUtility.getColumnValue("line_no", dom)); 
+							tranType = checkNullAndTrim(genericUtility.getColumnValue("tran_type", dom1)); 
+							siteCode = checkNullAndTrim(genericUtility.getColumnValue("site_code", dom1)); 
+							packCode = checkNullAndTrim(genericUtility.getColumnValue("pack_code", dom));
+							lotNo = checkNullAndTrim(genericUtility.getColumnValue("lot_no", dom)); 
+							
+							sql = "select tran_type__parent from distorder_type where tran_type =  ?";
+							pstmt = conn.prepareStatement(sql);
+							pstmt.setString(1, tranType);
+							rs = pstmt.executeQuery();
+							if (rs.next())
+							{
+								tranTypeParent = checkNullAndTrim(rs.getString("tran_type__parent"));
+								
+								
+							}
+							pstmt.close(); pstmt = null;
+							rs.close(); rs = null;
+							sql = "select qty_confirm , over_ship_perc from   distorder_det where  dist_order =  ? and    line_no    = ?";
+							pstmt = conn.prepareStatement(sql);
+							pstmt.setString(1, distOrder);
+							pstmt.setString(2, lineNoDOrd);
+							rs = pstmt.executeQuery();
+							if (rs.next())
+							{
+								balQty = checkDoubleNull(rs.getString("qty_confirm"));
+								overShipPerc = checkDoubleNull(rs.getString("over_ship_perc"));
+								
+							}
+							pstmt.close(); pstmt = null;
+							rs.close(); rs = null;
+							sql = " select sum(case when quantity is null then 0 else quantity end) from distord_issdet "
+								+ " where dist_order = ? and line_no_dist_order = ? and tran_id <> ? ";
+							pstmt = conn.prepareStatement(sql);
+							pstmt.setString(1, distOrder);
+							pstmt.setString(2, lineNoDOrd);
+							pstmt.setString(3, distIss);
+							rs = pstmt.executeQuery();
+							if (rs.next())
+							{
+								totQty = checkDoubleNull(rs.getString(1));
+							
+							}
+							pstmt.close(); pstmt = null;
+							rs.close(); rs = null;
+							
+							totQty = totQty + quantity;
+							
+							qtyBrow=0;
+							parentNodeListTemp = dom2.getElementsByTagName("Detail2");
+							parentNodeListLength = parentNodeListTemp.getLength();
+							System.out.println("ParentNodeListLength ..........."+parentNodeListLength);
+							for (int selectedRow = 0; selectedRow < parentNodeListLength; selectedRow++)
+							{
+								parentNodeTemp = parentNodeListTemp.item(selectedRow);
+								String mlineNoDOrd=checkNullAndTrim(genericUtility.getColumnValueFromNode("line_no_dist_order", parentNodeTemp));
+								String mdistOrder=checkNullAndTrim(genericUtility.getColumnValueFromNode("dist_order", parentNodeTemp));
+								String mlineNo=checkNullAndTrim(genericUtility.getColumnValueFromNode("line_no", parentNodeTemp));
+								
+								if(lineNoDOrd.equalsIgnoreCase(mlineNoDOrd) &&	
+										mdistOrder.equalsIgnoreCase(distOrder) && 
+										!mlineNo.equalsIgnoreCase(lineNo)   )
+								{
+									qtyBrow=checkDoubleNull(genericUtility.getColumnValueFromNode("quantity", parentNodeTemp));
+									totQty = totQty + qtyBrow;
+								}
+								
+							}
+							
+							if(totQty > (balQty + ((balQty * overShipPerc)/100)) && tranTypeParent.equalsIgnoreCase(tranType) )
+							{
+								errCode = "VTDIST19";
+								errList.add(errCode);
+								errFields.add(childNodeName.toLowerCase());
+							}
+							
+							itemCode = checkNullAndTrim(genericUtility.getColumnValue("item_code", dom)); 
+							sql = "Select Count(1) from  item where  item_code = ? ";
+							pstmt = conn.prepareStatement(sql);
+							pstmt.setString(1, itemCode);
+							rs = pstmt.executeQuery();
+							if (rs.next())
+							{
+								cnt = rs.getInt(1);
+								
+							}
+							pstmt.close(); pstmt = null;
+							rs.close(); rs = null;
+						
+							if (cnt > 0)
+							{
+								sql = "Select case when Check_integral_qty is null then 'N' else Check_integral_qty end From distorder_type Where tran_type = ?  ";
+								pstmt = conn.prepareStatement(sql);
+								pstmt.setString(1, tranType);
+								rs = pstmt.executeQuery();
+								if (rs.next())
+								{
+									checkIntegralQty = rs.getString(1);
+									
+								}
+								pstmt.close(); pstmt = null;
+								rs.close(); rs = null;
+							}
+							if(!"N".equalsIgnoreCase(checkIntegralQty))
+							{
+								integralQty = getIntegralQty( siteCode, itemCode, lotNo, packCode, checkIntegralQty,conn);
+								if( integralQty > 0 )
+								{
+									sql = "Select mod(?,?) as mmOdQty from dual";
+									pstmt = conn.prepareStatement(sql);
+									pstmt.setDouble(1, quantity);
+									pstmt.setDouble(2, integralQty);
+									rs = pstmt.executeQuery();
+									if (rs.next()) {
+										modQty = rs.getDouble("mmOdQty");
+									}
+									rs.close();
+									rs = null;
+									pstmt.close();
+									pstmt = null;
+									
+									if( modQty > 0 )
+									{
+										errCode = "VTINTQTY";
+										errList.add(errCode);
+										errFields.add(childNodeName.toLowerCase());
+									}
+									
+								}//end if
+							}
+							if (errCode == null || errCode.trim().length() == 0)
+							{
+								if(!tranTypeParent.equalsIgnoreCase(tranType))
+								{
+									sql = "select sum(quantity) from distord_issdet where dist_order =  ? and line_no_dist_order = ? ";
+									pstmt = conn.prepareStatement(sql);
+									pstmt.setString(1, distOrder);
+									pstmt.setString(2, lineNoDOrd);
+									rs = pstmt.executeQuery();
+									if (rs.next())
+									{
+
+										totQty = rs.getDouble(1);
+									}
+									pstmt.close(); pstmt = null;
+									rs.close(); rs = null;
+									
+									if(quantity > totQty)
+									{
+										errCode = "VTIQTY";
+										errList.add(errCode);
+										errFields.add(childNodeName.toLowerCase());
+									}
+								}
+							}
+							if (errCode == null || errCode.trim().length() == 0)
+							{
+								lotSl = checkNullAndTrim(genericUtility.getColumnValue("lot_sl", dom)); 
+								locCode = checkNullAndTrim(genericUtility.getColumnValue("loc_code", dom)); 
+								availableYN = checkNullAndTrim(genericUtility.getColumnValue("available_yn", dom1)); 
+								sql = "select stk_opt from item where item_code =  ?";
+								pstmt = conn.prepareStatement(sql);
+								pstmt.setString(1, itemCode);
+								rs = pstmt.executeQuery();
+								if (rs.next())
+								{
+									stkOpt = checkNullAndTrim(rs.getString("stk_opt"));
+									
+									
+								}
+								pstmt.close(); pstmt = null;
+								rs.close(); rs = null;
+								if(!"0".equalsIgnoreCase(stkOpt))
+								{
+									if("Y".equalsIgnoreCase(availableYN))
+									{
+										sql = "select a.quantity - a.alloc_qty from stock a, invstat b, location c "
+												+ " where a.loc_code =c.loc_code "
+												+ " and b.inv_stat = c.inv_stat "
+												+ " and a.item_code = ?	"
+												+ " and a.site_code = ?"
+												+ " and a.loc_code = ? "
+												+ " and a.lot_no = ? "
+												+ " and a.lot_sl = ? "
+												+ " and b.available = ? "
+												+ " and not exists (select 1 from inv_restr i where i.inv_stat = b.inv_stat and i.ref_ser = 'D-ISS') ";
+										pstmt = conn.prepareStatement(sql);
+										pstmt.setString(1, itemCode);
+										pstmt.setString(2, siteCode);
+										pstmt.setString(3, locCode);
+										pstmt.setString(4, lotNo);
+										pstmt.setString(5, lotSl);
+										pstmt.setString(6, availableYN);
+										rs = pstmt.executeQuery();
+										if (rs.next())
+										{
+											stkQty = rs.getDouble(1);
+											
+										}
+										pstmt.close(); pstmt = null;
+										rs.close(); rs = null;
+									}
+									else
+									{
+										sql = "select a.quantity - a.alloc_qty from stock a, invstat b, location c "
+												+ " where a.loc_code =c.loc_code "
+												+ " and b.inv_stat = c.inv_stat "
+												+ " and a.item_code = ?	"
+												+ " and a.site_code = ?"
+												+ " and a.loc_code = ? "
+												+ " and a.lot_no = ? "
+												+ " and a.lot_sl = ? "
+												+ " and b.available = ? ";
+											
+										pstmt = conn.prepareStatement(sql);
+										pstmt.setString(1, itemCode);
+										pstmt.setString(2, siteCode);
+										pstmt.setString(3, locCode);
+										pstmt.setString(4, lotNo);
+										pstmt.setString(5, lotSl);
+										pstmt.setString(6, availableYN);
+										rs = pstmt.executeQuery();
+										if (rs.next())
+										{
+											stkQty = rs.getDouble(1);
+											
+										}
+										pstmt.close(); pstmt = null;
+										rs.close(); rs = null;
+									}
+									sql = " select sum(case when quantity is null then 0 else quantity end) from distord_issdet "
+										+ " where dist_order = ? and line_no_dist_order = ? ";
+									pstmt = conn.prepareStatement(sql);
+									pstmt.setString(1, distOrder);
+									pstmt.setString(2, lineNoDOrd);
+									rs = pstmt.executeQuery();
+									if (rs.next())
+									{
+										oldQty = rs.getDouble(1);
+										
+									}
+									pstmt.close(); pstmt = null;
+									rs.close(); rs = null;
+									
+									stkQty = stkQty + oldQty;
+									
+									if(stkQty < quantity)
+									{
+										errCode = "VTSTK5";
+										errList.add(errCode);
+										errFields.add(childNodeName.toLowerCase());
+									}
+								}
+							}
+						}// end of if block
+						else if("qty_order__alt".equalsIgnoreCase(childNodeName))
+						{
+							qtyOrderAlt = checkDoubleNull(genericUtility.getColumnValue("qty_order__alt", dom)); 
+							quantity = checkDoubleNull(genericUtility.getColumnValue("quantity", dom)); 
+							rate = checkDoubleNull(genericUtility.getColumnValue("rate", dom)); 
+							rateAlt = checkDoubleNull(genericUtility.getColumnValue("rate__alt", dom)); 
+							if(rateAlt != 0)
+							{
+								if((quantity * rate) !=(qtyOrderAlt * rateAlt))
+								{
+									errCode = "VTALTQTY";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+							}
+								
+								
+						}// end of if block
+						else if("batch_size".equalsIgnoreCase(childNodeName))
+						{
+							batchSize = checkDoubleNull(genericUtility.getColumnValue("batch_size", dom)); 
+							itemCode = checkNullAndTrim(genericUtility.getColumnValue("item_code", dom)); 
+							siteCode = checkNullAndTrim(genericUtility.getColumnValue("site_code", dom1)); 
+							tranDate = checkNullAndTrim(genericUtility.getColumnValue("tran_date", dom1)); 	
+							if( tranDate != null && tranDate.trim().length() > 0 )
+							{
+								TranDate = Timestamp.valueOf(genericUtility.getValidDateString(tranDate, genericUtility.getApplDateFormat(), genericUtility.getDBDateFormat()) + " 00:00:00.0");		
+							}
+							sql = "Select Count(*) from batchsize_aprv where item_code = ? "
+									+ " and 	site_code__mfg = ?"
+									+ " and 	eff_from   	  <= ? "
+									+ " and 	valid_upto 	  >= ?"
+									+ " and 	confirmed 	= 'Y' ";
+							pstmt = conn.prepareStatement(sql);
+							pstmt.setString(1, itemCode);
+							pstmt.setString(2, siteCode);
+							pstmt.setTimestamp(3, TranDate);
+							pstmt.setTimestamp(4, TranDate);
+							
+							rs = pstmt.executeQuery();
+							if (rs.next())
+							{
+								cnt = rs.getInt(1);
+								
+							}
+							pstmt.close(); pstmt = null;
+							rs.close(); rs = null;
+						
+							if (cnt > 0 && batchSize == 0)
+							{
+								errCode = "VMBATCHBLK";
+								errList.add(errCode);
+								errFields.add(childNodeName.toLowerCase());
+							}
+							if ( batchSize > 0)
+							{
+								sql = "select batch_size from batchsize_aprv where item_code = ? "
+										+ " and 	site_code__mfg = ?"
+										+ " and 	eff_from   	  <= ? "
+										+ " and 	valid_upto 	  >= ?"
+										+ " and 	confirmed 	= 'Y' ";
+								pstmt = conn.prepareStatement(sql);
+								pstmt.setString(1, itemCode);
+								pstmt.setString(2, siteCode);
+								pstmt.setTimestamp(3, TranDate);
+								pstmt.setTimestamp(4, TranDate);
+								rs = pstmt.executeQuery();
+								if (rs.next())
+								{
+									mBatchSize = rs.getDouble(1);
+									
+								}
+								pstmt.close(); pstmt = null;
+								rs.close(); rs = null;
+								if ( batchSize > mBatchSize)
+								{
+									errCode = "VTBTHSIZE";
+									errList.add(errCode);
+									errFields.add(childNodeName.toLowerCase());
+								}
+							}
+						}// end of if block
+						
+					}//end for loop
+					break;
+				
+			}// end of switch statement 			
+
+			int errListSize = errList.size();
+			cnt = 0;
+			String errFldName = null;
+			if ( errList != null && errListSize > 0 )
+			{
+				for (cnt = 0; cnt < errListSize; cnt++ )
+				{
+					errCode = errList.get(cnt);
+					errFldName = errFields.get(cnt);
+					System.out.println("errCode .........." + errCode);
+					errString = itmDBAccessEJB.getErrorString("", errCode, userId, "", conn);
+					errorType =  errorType( conn, errCode );
+					if ( errString.length() > 0)
+					{
+						String bifurErrString = errString.substring( errString.indexOf("<Errors>") + 8, errString.indexOf("<trace>"));
+						bifurErrString =bifurErrString+errString.substring( errString.indexOf("</trace>") + 8, errString.indexOf("</Errors>"));
+						errStringXml.append(bifurErrString);
+						System.out.println("errStringXml .........."+errStringXml);
+						errString = "";
+					}
+					if ( errorType.equalsIgnoreCase("E"))
+					{
+						break;
+					}
+				}
+				errList.clear();
+				errList = null;
+				errFields.clear();
+				errFields = null;
+
+				errStringXml.append("</Errors></Root>\r\n");
+			}
+			else
+			{
+				errStringXml = new StringBuffer( "" );
+			}	
+			errString = errStringXml.toString();
+
+		}// End of try
+		catch(Exception e)
+		{
+			e.printStackTrace();
+			errString = e.getMessage();
+			throw new ITMException(e);
+		}
+		finally
+		{
+			try
+			{
+				if(rs != null) 
+				{
+					rs.close();
+					rs = null;
+				}
+				if(pstmt != null) 
+				{
+					pstmt.close();
+					pstmt = null;
+				}
+				if(conn != null)
+				{
+					conn.close();
+					conn = null;
+				}
+				
+			} 
+			catch(Exception d)
+			{
+				d.printStackTrace();
+				throw new ITMException(d);
+			}
+		}
+		errString = errStringXml.toString();
+		System.out.println("testing : final errString : " + errString);
+		return errString;
+	}//end of validation
 	private String checkNull(String input) 
 	{
 		if(input == null)
@@ -2445,4 +3955,354 @@ public class DistIssueIC extends ValidatorEJB {
 		}
 		return input;
 	}
+	//Validation --------
+	private String isExist(String table, String field, String value, Connection conn) throws SQLException
+
+	{
+		String sql = "", retStr = "";
+		PreparedStatement pstmt = null;
+		ResultSet rs = null;
+		int cnt = 0;
+
+		sql = " SELECT COUNT(1) FROM " + table + " WHERE " + field + " = ? ";
+		pstmt = conn.prepareStatement(sql);
+		pstmt.setString(1, value);
+		rs = pstmt.executeQuery();
+		if (rs.next())
+		{
+			cnt = rs.getInt(1);
+		}
+		rs.close();
+		rs = null;
+		pstmt.close();
+		pstmt = null;
+		if (cnt > 0)
+		{
+			retStr = "TRUE";
+		}
+		if (cnt == 0)
+		{
+			retStr = "FALSE";
+		}
+		System.out.println("@@@@ isexist[" + value + "]:::[" + retStr + "]:::[" + cnt + "]");
+		return retStr;
+	}
+	private double checkDoubleNull(String str) {
+		if (str == null || str.trim().length() == 0) {
+			return 0.0;
+		} else {
+			return Double.parseDouble(str);
+		}
+	}
+	private int checkIntNull(String str) {
+		if (str == null || str.trim().length() == 0) {
+			return 0;
+		} else {
+			return Integer.parseInt(str);
+		}
+	}
+	
+	
+	private String errorType(Connection conn , String errorCode)
+	{
+		String msgType = "";
+		PreparedStatement pstmt = null ; 
+		ResultSet rs = null;
+		try
+		{			
+			String  sql = "SELECT MSG_TYPE FROM MESSAGES WHERE MSG_NO = ?";
+			pstmt = conn.prepareStatement(sql);			
+			pstmt.setString(1,errorCode);			
+			rs = pstmt.executeQuery();
+			while(rs.next())
+			{
+				msgType = rs.getString("MSG_TYPE");
+			}	
+			rs.close();
+			rs = null;
+			pstmt.close();
+			pstmt = null;
+		}
+		catch(Exception ex)
+		{
+			ex.printStackTrace();
+		}		
+		finally
+		{
+			try
+			{
+				if(rs != null)
+				{
+					rs.close();
+					rs = null;
+				}
+				if(pstmt != null)
+				{
+					pstmt.close();
+					pstmt = null;
+				}
+			}
+			catch(Exception e)
+			{
+				e.printStackTrace();
+			}
+		}		
+		return msgType;
+	}
+	public String checkNullAndTrim( String inputVal )
+	{
+		if ( inputVal == null )
+		{
+			inputVal = "";
+		}
+		else
+		{
+			inputVal = inputVal.trim();
+		}
+		return inputVal;
+	}
+
+	private boolean isExist(Connection conn, String tableName, String columnName, String value)
+			throws ITMException, RemoteException {
+		PreparedStatement pstmt = null;
+		ResultSet rs = null;
+		String sql = "";
+		boolean status = false;
+		try {
+			sql = "SELECT count(*) from " + tableName + " where " + columnName + "  = ? ";
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setString(1, value);
+			rs = pstmt.executeQuery();
+
+			if (rs.next()) {
+				if (rs.getBoolean(1)) {
+					status = true;
+				}
+			}
+			rs.close();
+			rs = null;
+			pstmt.close();
+			pstmt = null;
+		} catch (Exception e) {
+			System.out.println("Exception in isExist ");
+			e.printStackTrace();
+			throw new ITMException(e);
+		}
+		System.out.println("returning String from isExist ");
+		return status;
+	}
+	private String gbfDistOrderSite( String asDistOrder, String asSiteShip, String asSiteDlv, Connection conn ) throws Exception
+	{
+		String lsErrcode = null, lsSiteCodeShip = null, lsSiteCodeDlv = null;
+		PreparedStatement pstmt = null;
+		ResultSet rs = null;
+		String sql = null;
+		sql = "select site_code__ship ls_site_code__ship, site_code__dlv ls_site_code__dlv from distorder "
+			+" where dist_order = '" + asDistOrder + "'";
+
+		pstmt = conn.prepareStatement( sql );
+		rs = pstmt.executeQuery();
+		if( rs.next() )
+		{
+			lsSiteCodeShip = rs.getString( "ls_site_code__ship" );
+			lsSiteCodeDlv = rs.getString( "ls_site_code__dlv" );
+		}
+
+		rs.close();
+		rs = null;
+		pstmt.close();
+		pstmt = null;
+
+		if( !( lsSiteCodeShip.trim().equalsIgnoreCase( asSiteShip.trim() ) ) || !( lsSiteCodeDlv.equalsIgnoreCase( asSiteDlv.trim() ) ) )
+		{
+		  lsErrcode = "VTDIST10";
+		}
+		return lsErrcode;
+	}
+	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);
+				
+				cal.add(Calendar.MONTH,1);
+				cal.set(Calendar.DATE,0);
+				
+				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, Connection conn)
+	{
+		double integralQty = 0;
+		String sql = "";
+		ResultSet rs = null;
+		//Connection conn = null;
+		//ConnDriver connDriver = new ConnDriver();
+		PreparedStatement pstmt = null;
+		
+		try
+		{
+			//conn = connDriver.getConnectDB("DriverITM");
+	
+			
+			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);
+					pstmt = conn.prepareStatement( sql );
+					rs = pstmt.executeQuery();
+					if (rs.next())
+					{
+						integralQty = rs.getDouble(1);
+						//System.out.println("integralQty :"+integralQty);
+					}
+					rs.close();
+					rs = null;
+					pstmt.close();
+					pstmt = null;
+					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);
+						pstmt = conn.prepareStatement( sql );
+						rs = pstmt.executeQuery();
+						if (rs.next())
+						{
+							integralQty = rs.getDouble(1);
+							//System.out.println("integralQty :"+integralQty);
+						}
+						rs.close();
+						rs = null;
+						pstmt.close();
+						pstmt = null;
+						if (integralQty == 0)
+						{
+							sql = "SELECT REO_QTY FROM SITEITEM "
+								 +"WHERE SITE_CODE = '"+siteCode+"'"+" AND ITEM_CODE = '"+itemCode+"'";
+							System.out.println("sql :"+sql);	
+							pstmt = conn.prepareStatement( sql );
+							rs = pstmt.executeQuery();
+							if (rs.next())
+							{
+								integralQty = rs.getDouble(1);
+								//System.out.println("integralQty :"+integralQty);
+							}
+							rs.close();
+							rs = null;
+							pstmt.close();
+							pstmt = null;
+							if (integralQty == 0)
+							{
+								sql = "SELECT REO_QTY FROM ITEM "
+									 +"WHERE ITEM_CODE = '"+itemCode+"'";
+								System.out.println("sql :"+sql);	
+								pstmt = conn.prepareStatement( sql );
+								rs = pstmt.executeQuery();
+								if (rs.next())
+								{
+									integralQty = rs.getDouble(1);
+									//System.out.println("integralQty :"+integralQty);
+								}
+								rs.close();
+								rs = null;
+								pstmt.close();
+								pstmt = null;
+							}
+						}
+					}
+					
+				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);
+					pstmt = conn.prepareStatement( sql );
+					rs = pstmt.executeQuery();
+					if (rs.next())
+					{
+						integralQty = rs.getDouble(1);
+						//System.out.println("integralQty :"+integralQty);
+					}
+					rs.close();
+					rs = null;
+					pstmt.close();
+					pstmt = null;
+				break;
+				case 'I':
+					sql = "SELECT INTEGRAL_QTY FROM SITEITEM "
+								 +"WHERE SITE_CODE = '"+siteCode+"'"+" AND ITEM_CODE = '"+itemCode+"'";
+					System.out.println("sql :"+sql);	
+					pstmt = conn.prepareStatement( sql );
+					rs = pstmt.executeQuery();
+					if (rs.next())
+					{
+						integralQty = rs.getDouble(1);
+						//System.out.println("integralQty :"+integralQty);
+					}
+					rs.close();
+					rs = null;
+					pstmt.close();
+					pstmt = null;
+					if (integralQty == 0)
+					{
+						sql = "SELECT INTEGRAL_QTY FROM ITEM WHERE ITEM_CODE = '"+itemCode+"'";
+						System.out.println("sql :"+sql);
+						pstmt = conn.prepareStatement( sql );
+						rs = pstmt.executeQuery();
+						if (rs.next())
+						{
+							integralQty = rs.getDouble(1);
+							//System.out.println("integralQty :"+integralQty);
+						}
+						rs.close();
+						rs = null;
+						pstmt.close();
+						pstmt = null;
+					}
+					
+			}
+			
+			//conn.close();	
+		}
+		catch(Exception e)
+		{
+			System.out.println("the exception occurs in getIntegralQty :"+e);
+		}
+		System.out.println("integralQty :"+integralQty);
+		return integralQty;
+	}
 }