updated new post save

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

webitm-dis/ibase/webitm/ejb/dis/DistIssWizPostSave.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;
+
+@javax.ejb.Stateless
+public class DistIssWizPostSave extends ValidatorEJB implements DistIssWizPostSaveLocal,DistIssWizPostSaveRemote
+{
+	public String postSave(String xmlString,String editFlag,String tranId,  String xtraParams,Connection conn) throws RemoteException,ITMException
+	{
+
+		System.out.println(">>>>>>>>>>>>>>CONNECTION"+conn);
+		System.out.println("------------  postSave method called-----------------tranId : "+ tranId);		
+		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 d" + xmlString);
+			}
+			
+			tranId = GenericUtility.getInstance().getColumnValue("tran_id",dom);
+
+			System.out.println("------------  postSave method called-----------------tranId from dom: "+ tranId);
+			
+			conn = null;
+			ConnDriver connDriver = new ConnDriver();
+			conn = connDriver.getConnectDB("DriverITM");
+			connDriver= null;
+			errString = postSave(dom,tranId,editFlag,xtraParams,conn);
+
+
+		}
+		catch(Exception e)
+		{
+			System.out.println("Exception :  : 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 data1 ---------------:"+dom);
+		String sql = "", error = "";
+		double quantity = 0, grossWeight = 0, tareWeight = 0, netWeight = 0, noArt = 0;
+		int cnt1 = 0;
+		String lotSl="",locCode="";
+		int cnt = 0;
+
+		
+		GenericUtility genericUtility = GenericUtility.getInstance();
+		PreparedStatement pstmt = null,pstmt1 = null;
+		String lotsl = "",siteCode="";
+		boolean isLocalConn = false;
+		double allQty=0;
+		ResultSet rs = null,rs1 = null;		
+		double amount = 0,netAmount=0,discAmount=0,taxAmount=0;	//net_amt =amount+tax_amt-disc_amt
+	    String shipmentId = "";
+		
+		try
+		{
+			
+
+			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 "
+					+"	amount = quantity * rate , "
+					+"	disc_amt = quantity * rate * discount/100 ,  " 
+					+ "	net_amt = quantity * rate  + tax_amt - (quantity * rate * discount/100 )  "
+					+ " where  tran_id = ? ";
+			pstmt= conn.prepareStatement(sql);
+			//System.out.println("First sql ["+ sql + "] tranId [" + tranId + "]");
+			pstmt.setString( 1, tranId );
+			pstmt.executeUpdate();
+			//conn.commit();
+			pstmt.close();
+			pstmt = null;		
+
+			sql = "select sum(amount), sum(net_amt),sum(disc_amt),sum(tax_amt),sum(no_art) , sum(gross_weight) ,sum (tare_weight) , sum(net_weight )  "
+					+ " from distord_issdet where tran_id = ? ";
+			pstmt= conn.prepareStatement(sql);
+			//System.out.println("Second sql ["+sql + "]");
+			pstmt.setString( 1, tranId );
+			rs = pstmt.executeQuery();
+			if (rs.next())
+			{
+				amount = rs.getDouble(1);
+				netAmount = rs.getDouble(2);
+				discAmount = rs.getDouble(3);
+				taxAmount = rs.getDouble(4);
+				noArt = rs.getDouble(5);
+				//added by kunal on 06/AUG/13
+				grossWeight = rs.getDouble(6);
+				tareWeight = rs.getDouble(7);
+				netWeight = rs.getDouble(8);
+			}
+			rs.close();
+			rs = null;
+			pstmt.close();
+			pstmt = null;
+
+			//added by kunal on 06/AUG/13 
+			sql = "select shipment_id  from  distord_iss where tran_id = ? ";
+			pstmt= conn.prepareStatement(sql);
+			pstmt.setString( 1, tranId );
+			rs = pstmt.executeQuery();
+			if (rs.next())
+			{
+				shipmentId = rs.getString(1);
+			}
+			rs.close();
+			rs = null;
+			pstmt.close();
+			pstmt = null;
+
+			if(shipmentId != null && shipmentId.trim().length() > 0)
+			{
+				grossWeight = 0;
+				tareWeight = 0;
+				netWeight = 0;
+			}
+
+
+			sql = " update distord_iss  set "
+					+ " amount = ?, net_amt = ?, discount = ? , tax_amt = ? , no_art = ? ,gross_weight = ? , tare_weight = ? , net_weight = ? "
+					+ "  where  tran_id = ? " ;
+			pstmt= conn.prepareStatement( sql );
+			//System.out.println("Fourth sql ["+sql + "]");
+
+			pstmt.setDouble( 1, amount );
+			pstmt.setDouble( 2, netAmount );
+			pstmt.setDouble( 3, discAmount );
+			pstmt.setDouble( 4, taxAmount );
+			pstmt.setDouble( 5, noArt );
+			pstmt.setDouble( 6, grossWeight );////added by kunal on 06/AUG/13
+			pstmt.setDouble( 7, tareWeight );//added by kunal on 06/AUG/13
+			pstmt.setDouble( 8, netWeight );//added by kunal on 06/AUG/13
+			pstmt.setString( 9, tranId );			
+			pstmt.executeUpdate();
+			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();
+				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();
+				if(conn != null)
+				{
+					conn.close();	
+				}
+
+				if(rs != null)
+					rs.close();
+
+				pstmt = null;
+				rs = null;
+			} catch (SQLException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+				error=e.getMessage();
+			}		
+		}
+
+		return error;
+
+	}
+
+}

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

+package ibase.webitm.ejb.dis;
+
+import ibase.webitm.ejb.*;
+
+import java.rmi.RemoteException;
+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 DistIssWizPostSaveLocal extends ValidatorLocal//, EJBObject
+{
+	public String postSave(String xmlString,String editFlag,String tranId,  String xtraParams,Connection conn) throws RemoteException,ITMException;
+	public String postSave(Document dom,String tranId,String editflag,String xtraParams,Connection conn);
+
+}

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

+package ibase.webitm.ejb.dis;
+
+import ibase.webitm.ejb.*;
+
+import java.rmi.RemoteException;
+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 DistIssWizPostSaveRemote extends ValidatorRemote//, EJBObject
+{
+	public String postSave(String xmlString,String editFlag,String tranId,  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