Commit cdb64f98 authored by dpawar's avatar dpawar

update alloc qty in stock


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@96233 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 5207e10c
...@@ -3,6 +3,7 @@ package ibase.webitm.ejb.dis; ...@@ -3,6 +3,7 @@ package ibase.webitm.ejb.dis;
import java.rmi.RemoteException; import java.rmi.RemoteException;
import java.util.*; import java.util.*;
import java.sql.*; import java.sql.*;
import org.w3c.dom.*; import org.w3c.dom.*;
import javax.ejb.*; import javax.ejb.*;
...@@ -12,6 +13,7 @@ import ibase.webitm.utility.ITMException; ...@@ -12,6 +13,7 @@ import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.GenericUtility; import ibase.webitm.utility.GenericUtility;
import ibase.system.config.*; import ibase.system.config.*;
import ibase.webitm.ejb.*; import ibase.webitm.ejb.*;
import javax.ejb.Stateless; // added for ejb3 import javax.ejb.Stateless; // added for ejb3
...@@ -500,9 +502,10 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa ...@@ -500,9 +502,10 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
public String postSave(String winName,String editFlag,String tranId, String xtraParams,Connection conn) throws RemoteException,ITMException public String postSave(String winName,String editFlag,String tranId, String xtraParams,Connection conn) throws RemoteException,ITMException
{ {
String sql = "",saleOrder = ""; System.out.println("--------------my postSave called.............................."+tranId);
String sql = "",saleOrder = "",lotsl="",siteCode="";
int lineNo = 0; int lineNo = 0;
double grossWeight = 0,tareWeight = 0,netWeight = 0,noAart = 0,offinvAmt = 0,billbackAmt = 0 ; double grossWeight = 0,tareWeight = 0,netWeight = 0,noAart = 0,offinvAmt = 0,billbackAmt = 0,quantity=0 ;
double quantityStduom = 0 ,rateStduom = 0,offinvAmtDet = 0,taxAmtDet = 0 ,discount = 0,totAmt = 0,amount = 0; double quantityStduom = 0 ,rateStduom = 0,offinvAmtDet = 0,taxAmtDet = 0 ,discount = 0,totAmt = 0,amount = 0;
//GenericUtility genericUtility = GenericUtility.getInstance(); //GenericUtility genericUtility = GenericUtility.getInstance();
PreparedStatement pstmt = null,pstmt1 = null; PreparedStatement pstmt = null,pstmt1 = null;
...@@ -511,6 +514,17 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa ...@@ -511,6 +514,17 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
//System.out.println("tranId="+tranId+" xtraParams="+xtraParams); //System.out.println("tranId="+tranId+" xtraParams="+xtraParams);
try try
{ {
if(conn!=null){
System.out.println("Connection not null.................1234");
}
conn=null;
System.out.println("connection is null..............");
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
connDriver=null;
sql = " select sord_no,line_no__sord ,quantity__stduom,rate__stduom ,disc_schem_offinv_amt,tax_amt from despatchdet where desp_id = ? "; sql = " select sord_no,line_no__sord ,quantity__stduom,rate__stduom ,disc_schem_offinv_amt,tax_amt from despatchdet where desp_id = ? ";
pstmt1= conn.prepareStatement(sql); pstmt1= conn.prepareStatement(sql);
...@@ -586,6 +600,53 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa ...@@ -586,6 +600,53 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
pstmt.executeUpdate(); pstmt.executeUpdate();
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
//new add
sql = "select lot_sl from despatchdet where desp_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 from despatchdet where desp_id = ? and lot_sl = ?";
pstmt= conn.prepareStatement(sql);
//System.out.println("Second sql ["+sql + "]");
pstmt.setString( 1, tranId );
pstmt.setString( 2, lotsl );
rs = pstmt.executeQuery();
if(rs.next())
{
quantity = rs.getDouble("quantity");
siteCode = rs.getString("site_code") == null ? "":rs.getString("site_code");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
sql = "UPDATE stock SET ALLOC_QTY = ? WHERE site_code = ? AND LOT_SL = ? AND QUANTITY > 0;";
pstmt= conn.prepareStatement(sql);
//System.out.println("First sql ["+ sql + "] tranId [" + tranId + "]");
pstmt.setDouble( 1, quantity);
pstmt.setString( 2, siteCode);
pstmt.setString( 3, lotsl);
pstmt.executeUpdate();
conn.commit();
pstmt.close();
pstmt = null;
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
//new add end
} }
catch(Exception e) catch(Exception e)
{ {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment