updated same version as 1.2

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

webitm-dis/ibase/webitm/ejb/dis/DissIssuePosSave.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 ibase.webitm.utility.GenericUtility;
+import java.sql.DriverManager;
 import java.sql.PreparedStatement;
+import java.sql.Statement;
 import java.sql.ResultSet;
+import java.sql.Connection;
 import java.sql.SQLException;
-
+import java.sql.*;
+import javax.ejb.*;
+import ibase.webitm.ejb.*;
+import org.w3c.dom.*;
+import ibase.webitm.utility.ITMException;
+import ibase.utility.CommonConstants;
+import org.w3c.dom.*; 
+import javax.xml.parsers.*;
+import ibase.webitm.utility.*;
+import ibase.system.config.*;
+import javax.naming.InitialContext;
+import ibase.webitm.utility.ITMException;
+import ibase.webitm.utility.GenericUtility;
+import java.io.File;
+import ibase.system.config.ConnDriver;
 import javax.ejb.Stateless; 
 
 
@@ -35,90 +47,13 @@ public class DissIssuePosSave extends ValidatorEJB implements   DissIssuePosSave
 	{
 		String sql = "",shipmentId = "";
 		GenericUtility genericUtility = GenericUtility.getInstance();
-		PreparedStatement pstmt = null,pstmt1 = null;
-		String lotsl = "",siteCode="";
-		boolean isLocalConn = false;
-		double quantity = 0,allQty=0;
-		ResultSet rs = null,rs1 = null;		
+		PreparedStatement pstmt = null;
+		ResultSet rs = null;		
 		double amount = 0,netAmount=0,discAmount=0,taxAmount=0,noArt = 0;	//net_amt =amount+tax_amt-disc_amt
 		double grossWeight = 0 ,tareWeight = 0 , netWeight = 0;
 		try
 		{
-			
-				
-			conn = null;
-			
-			if(conn == null){
-				
-				ConnDriver connDriver = new ConnDriver();
-				conn = connDriver.getConnectDB("DriverITM");
-				connDriver= null;
-				isLocalConn = true;
 			conn.setAutoCommit(false);
-			}
-
-			sql = "select lot_sl from distord_issdet where tran_id = ? ";
-			pstmt= conn.prepareStatement(sql);
-			//System.out.println("Second sql ["+sql + "]");
-			pstmt.setString( 1, tranId );
-			rs = pstmt.executeQuery();
-			while(rs.next())
-			{
-				lotsl = rs.getString(1) == null ? "":rs.getString(1);
-				
-				sql = "select quantity,site_code__mfg from distord_issdet where tran_id = ? and lot_sl = ?";
-				pstmt1= conn.prepareStatement(sql);
-				//System.out.println("Second sql ["+sql + "]");
-				pstmt1.setString( 1, tranId );
-				pstmt1.setString( 2, lotsl );
-				rs1 = pstmt1.executeQuery();
-				if(rs1.next())
-				{
-					quantity = rs1.getDouble("quantity");
-					siteCode = rs1.getString("site_code__mfg") == null ? "":rs1.getString("site_code__mfg");
-				}
-				rs1.close();
-				rs1 = null;
-				pstmt1.close();
-				pstmt1 = null;
-				
-				
-				sql = "select ALLOC_QTY from stock WHERE site_code = ? AND LOT_SL = ? AND QUANTITY > 0";
-				pstmt1= conn.prepareStatement(sql);
-				//System.out.println("Second sql ["+sql + "]");
-				pstmt1.setString( 1, siteCode);
-				pstmt1.setString( 2, lotsl);
-				rs1 = pstmt1.executeQuery();
-				if(rs1.next())
-				{
-					allQty = rs1.getDouble(1);
-				}
-				rs1.close();
-				rs1 = null;
-				pstmt1.close();
-				pstmt1 = null;
-				
-				if(allQty > 0)
-				{
-					quantity = allQty + quantity;
-				}
-				
-				sql = "UPDATE stock SET ALLOC_QTY = ? WHERE site_code = ? AND LOT_SL = ? AND QUANTITY > 0";
-				pstmt1= conn.prepareStatement(sql);
-				//System.out.println("First sql ["+ sql + "] tranId [" + tranId + "]");
-				pstmt1.setDouble( 1, quantity);
-				pstmt1.setString( 2, siteCode);
-				pstmt1.setString( 3, lotsl);
-				pstmt1.executeUpdate();
-				//conn.commit();
-				pstmt1.close();
-				pstmt1 = null;		
-				
-			}
-			rs.close();
-			rs = null;
-			pstmt.close();
-			pstmt = null;
 
 
 			sql = "update distord_issdet  set "
@@ -130,7 +65,6 @@ public class DissIssuePosSave extends ValidatorEJB implements   DissIssuePosSave
 			//System.out.println("First sql ["+ sql + "] tranId [" + tranId + "]");
 			pstmt.setString( 1, tranId );
 			pstmt.executeUpdate();
-			//conn.commit();
 			pstmt.close();
 			pstmt = null;		
 
@@ -198,48 +132,18 @@ public class DissIssuePosSave extends ValidatorEJB implements   DissIssuePosSave
 			pstmt.close();
 			pstmt = null;
 
-			//conn.commit();
-
 		}
 		catch(Exception e)
 		{
-			
-			try {
-				System.out.println(">>>>>>>>>>>>In catch Before rollback>>>");
-				conn.rollback();
-			} catch (SQLException e1) {
-				// TODO Auto-generated catch block
-				e1.printStackTrace();
-				
-			}
-			
 			e.printStackTrace();
 			throw new ITMException(e);
-			
 		}
 		finally
 		{
 			try
 			{
-				if(rs!=null){
-					rs.close();
-					rs = null;
-				}
-			
-				if(pstmt != null){
-					pstmt.close();
+				if(pstmt != null)pstmt.close();
 				pstmt = null;
-				}
-				
-				if(isLocalConn){
-					if(conn != null)
-					{
-						conn.commit();
-						conn.close();	
-						conn = null;
-					}
-					
-				}
 			}catch(Exception d)
 			{
 				d.printStackTrace();