Request ID -D15DSUN015

Porder Post save for cross update expression


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

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

+package ibase.webitm.ejb.dis;
+import org.w3c.dom.Document;
+
+
+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 javax.ejb.Stateless;
+
+@Stateless
+public class POrderPostSave extends ValidatorEJB implements POrderPostSaveLocal,POrderPostSaveRemote {
+	public String postSave(String xmlString,String tranId,String editFlag, String xtraParams,Connection conn) throws RemoteException,ITMException
+	{
+
+		System.out.println("------------ postSave method called-----------------POrderPostSave : ");
+		System.out.println("tranId111--->>["+tranId+"]");
+		System.out.println("xml String--->>["+xmlString+"]");
+		Document dom = null;
+		String errString="";
+		
+		try
+		{
+			if (xmlString != null && xmlString.trim().length() > 0)
+			{
+				dom = parseString(xmlString);				
+				errString = postSave(dom,tranId,xtraParams,conn);
+			}
+			
+		}
+		catch(Exception e)
+		{
+			System.out.println("Exception : POrderPostSave.java : postSave : ==>\n"+e.getMessage());
+			throw new ITMException(e);
+		}		
+		return errString;
+	}
+	public String postSave(Document dom,String tranId,String xtraParams,Connection conn)
+	{
+		System.out.println("in PorderPostSave postSave tran_id---->>["+tranId+"]");
+		ResultSet rs=null,rs1=null;
+		PreparedStatement pstmt=null,pstmt1=null;
+		String sql="",sql1="",errorString="",frtType = "";
+		double quantityStduom = 0,rateStduom=0,discount=0,taxAmt=0,taxAmtHdr=0,totAmtHdr=0,
+				quantity =0,frtRate = 0,frtAmtFixed =0,totAmtDet=0,ordAmtHdr=0,frtAmt = 0,frtAmtQty=0;
+		int count=0,lineNo=0;
+		try{
+			GenericUtility genericUtility = GenericUtility.getInstance();	
+			tranId = GenericUtility.getInstance().getColumnValue("purc_order",dom);
+			System.out.println("purc_order--->>["+tranId+"]");
+			sql = "Select Quantity__Stduom,Rate__Stduom,Discount,Tax_Amt,line_no from porddet where purc_order = ?";
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setString(1,tranId);
+			rs = pstmt.executeQuery();
+			while(rs.next())
+			{
+				quantityStduom=rs.getDouble(1);
+				rateStduom =rs.getDouble(2);
+				discount = rs.getDouble(3);
+				taxAmt = rs.getDouble(4);
+				lineNo = rs.getInt(5);
+				
+				System.out.println("QuantityStduom>>>>>>> [" +quantityStduom +"]");
+				System.out.println("Rate_Stduom>>>>>>>>>>>> [" + rateStduom +"]");
+				System.out.println("Discount >>>>>>>>>>>>>>>>>> [" + discount +"]");
+				System.out.println("TaxAmt>>>>>>>>>>>>>>>>> [" +taxAmt +"]" );
+						
+				totAmtDet= (quantityStduom * rateStduom)-((quantityStduom * rateStduom * discount)/100) + taxAmt;
+				System.out.println("totamtdet>>>>>>>>>>>>>>>>> [" +totAmtDet +"]" );
+				sql1 ="update porddet set tot_amt = ? where purc_order = ? and line_no = ?";
+				pstmt1 =conn.prepareStatement(sql1);
+				pstmt1.setDouble(1,totAmtDet);
+				pstmt1.setString(2,tranId);
+				pstmt1.setInt(3,lineNo);
+				count = pstmt1.executeUpdate();
+				
+				
+			}
+			if (pstmt != null)
+			{
+		    	pstmt.close();
+				pstmt=null;
+			 }
+			if(pstmt1 != null)
+			{
+				pstmt1.close();
+				pstmt1 = null;
+			}
+				if (rs !=null)
+			{
+				rs.close();
+				rs=null;
+			}
+			
+			sql = "select sum(tax_amt),sum(tot_amt),sum(quantity) from porddet where purc_order =? ";
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setString(1, tranId);
+			rs = pstmt.executeQuery();
+			while(rs.next())
+			{
+				taxAmtHdr = rs.getDouble(1);
+				totAmtHdr = rs.getDouble(2);
+				quantity = 	rs.getDouble(3);
+			}
+			
+			System.out.println("taxAMthdr>>>>>>>>>>>>>>>>>>> " + taxAmtHdr);
+			System.out.println("TotalAmtheader!!!!!!!!!!!!!! " + totAmtHdr );
+			System.out.println("Quantity@@@@@@@@@@@@@@@@@@@  " + quantity);
+			
+			ordAmtHdr = totAmtHdr - taxAmtHdr;
+			
+			/*sql1 ="select frt_rate,frt_type ,frt_amt__fixed from porder where purc_order = ?";
+			pstmt1 = conn.prepareStatement(sql1);
+			pstmt1.setString(1, tranId);
+			rs1 = pstmt1.executeQuery();
+			if(rs1.next())
+			{
+				frtRate = rs1.getDouble(1);
+				frtType = checkNull(rs1.getString(2));
+				frtAmtFixed = rs1.getDouble(3);
+			}*/
+			
+			if (pstmt != null)
+			{
+		    	pstmt.close();
+				pstmt=null;
+			 }
+			/*if(pstmt1 != null)
+			{
+				pstmt1.close();
+				pstmt1 = null;
+			}*/
+				if (rs !=null)
+			{
+				rs.close();
+				rs=null;
+			}
+			/*if(frtType.equalsIgnoreCase("Q"))
+			{
+				frtAmtQty = frtRate * quantity;
+			}
+			else
+			{
+			frtAmtQty = 0;	
+			}
+			System.out.println("frtrate>>>>>>>>>>>>>>>>>>> " + frtRate);
+			System.out.println("frtType!!!!!!!!!!!!!! " + frtType );
+			System.out.println("frtAmtFixed@@@@@@@@@@@@@@@@@@@  " + frtAmtFixed);
+			System.out.println("frtAmtQty@@@@@@@@@@@@@@@@@@@  " + frtAmtQty);
+			
+			frtAmt = frtAmtFixed + frtAmtQty;
+			System.out.println("frtAmtQty@@@@@@@@@@@@@@@@@@@  " + frtAmt);*/
+			if(count > 0)
+			{
+			sql = "update porder set tax_amt = ?,tot_amt = ?,ord_amt = ? where purc_order = ? ";
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setDouble(1, taxAmtHdr);
+			pstmt.setDouble(2, totAmtHdr);
+			pstmt.setDouble(3, ordAmtHdr);
+			/*pstmt.setDouble(4, frtAmtQty);
+			pstmt.setDouble(5, frtAmt);*/
+			pstmt.setString(4, tranId);
+			count = pstmt.executeUpdate();
+			System.out.println("post count---->>["+count+"]");
+			if (pstmt != null)
+			{
+		    	pstmt.close();
+				pstmt=null;
+			 }
+			if(count >0 ){
+				conn.commit();
+			}
+			}
+			
+			
+				
+			else{
+				conn.rollback();
+			}
+		}
+			catch(Exception e){
+				System.out.println("Exception : POrderPostSave -->["+e.getMessage()+"]");
+				e.printStackTrace();
+				try{
+				conn.rollback();
+				}catch(Exception e1){
+					System.out.println("Exception while rollbacking transaction....");
+					e1.printStackTrace();
+				}
+			}
+		
+		
+		return errorString;
+	}
+	
+	
+		
+}
+	
+
+

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

+package ibase.webitm.ejb.dis;
+
+import ibase.webitm.ejb.ValidatorLocal;
+import ibase.webitm.utility.ITMException;
+
+import java.rmi.RemoteException;
+import java.sql.Connection;
+
+import javax.ejb.Local;
+
+@Local
+public interface POrderPostSaveLocal extends ValidatorLocal {
+	public String postSave(String xmlString,String tranId,String editFlag, String xtraParams,Connection conn) throws RemoteException,ITMException;
+
+}

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

+package ibase.webitm.ejb.dis;
+
+import java.rmi.RemoteException;
+import java.sql.Connection;
+
+import javax.ejb.Remote;
+
+import ibase.webitm.ejb.ValidatorRemote;
+import ibase.webitm.utility.ITMException;
+@Remote
+public interface POrderPostSaveRemote extends ValidatorRemote {
+	public String postSave(String xmlString,String tranId,String editFlag, String xtraParams,Connection conn) throws RemoteException,ITMException;
+}