Skip to content

B
business-java
Commit b2afc2bd authored by kmandhre's avatar kmandhre
Browse files
Options

cross update implement 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@93349 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 316f1dc2
Hide whitespace changes
Inline Side-by-side
Showing with 188 additions and 71 deletions
webitm-dis/ibase/webitm/ejb/dis/DespatchPos.java
View file @ b2afc2bd
......@@ -39,7 +39,7 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
return "";
}
public String postSaveRec(String xmlString1,String domId,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException
public String postSaveRec(String xmlString1,String domId,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException
{
Document dom = null;
String retString = "";
......@@ -52,7 +52,7 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
executepostSaveRec(dom,domId,objContext,editFlag,xtraParams,conn);
}
}
catch(Exception e)
catch(Exception e)
{
System.out.println("Exception :DespatchPosEJB ::" + e.getMessage() + ":");
e.printStackTrace();
......@@ -60,7 +60,7 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
}
return "";
}
private String executepostSaveRec(Document dom, String domID,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException
{
Statement stmt = null, stmt1 = null;
......@@ -81,6 +81,7 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
int detailListLength = 0,currDetailListLength = 0;
String qtyStduomStr = "",updateStatus = "",nodeName = "",tranId = "";
Connection conn1 = null;
try
{
stmt = conn.createStatement();
......@@ -90,17 +91,17 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
currDate = new java.sql.Date(System.currentTimeMillis());
tranDate = new java.sql.Date(System.currentTimeMillis());
System.out.println("\n CurrDate :"+currDate+"\n TranDate :"+tranDate);
hdrDom = dom.getElementsByTagName("Detail1");
siteCode = GenericUtility.getInstance().getColumnValueFromNode("site_code",hdrDom.item(0));
tranId = GenericUtility.getInstance().getColumnValueFromNode("desp_id",hdrDom.item(0));
System.out.println("Site Code :: "+siteCode);
System.out.println("Tran ID :: "+tranId);
currDetail = getCurrentDetailFromDom(dom,domID);
updateStatus = getCurrentUpdateFlag(currDetail);
System.out.println("DomID :: "+domID+"\n Update Status ::"+updateStatus);
if (currDetail != null && !updateStatus.equalsIgnoreCase("D"))
{
itemCode = GenericUtility.getInstance().getColumnValueFromNode("item_code",currDetail);
......@@ -119,11 +120,11 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
lineNoSord = lineNoSord.substring(lineNoSord.length()-3);
qtyStduom = Double.parseDouble(qtyStduomStr);
sql = "SELECT CASE WHEN RATE IS NULL THEN 0 ELSE RATE END "
+"FROM STOCK WHERE ITEM_CODE = '"+itemCode+"' "
+"AND SITE_CODE = '"+siteCode+"' "
+"AND LOC_CODE = '"+locCode+"' "
+"AND LOT_NO = '"+lotNo+"' "
+"AND LOT_SL = '"+lotSl+"'";
+"FROM STOCK WHERE ITEM_CODE = '"+itemCode+"' "
+"AND SITE_CODE = '"+siteCode+"' "
+"AND LOC_CODE = '"+locCode+"' "
+"AND LOT_NO = '"+lotNo+"' "
+"AND LOT_SL = '"+lotSl+"'";
System.out.println("sql :"+sql);
rs1 = stmt1.executeQuery(sql);
if (rs1.next())
......@@ -152,15 +153,15 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
updateCnt = pstmt.executeUpdate();
System.out.println("updateCnt in despatchDet :"+updateCnt);
pstmt.clearParameters();
*///End Commented Gulzar - 12/11/07
*///End Commented Gulzar - 12/11/07
//Added By Gulzar - 12/11/07
sql = "UPDATE DESPATCHDET SET COST_RATE = ? "
+"WHERE DESP_ID = '"+tranId+"' "
+"AND ITEM_CODE = '"+itemCode+"' "
+"AND LINE_NO = '"+lineNo+"' "
+"AND LOC_CODE = '"+locCode+"' "
+"AND LOT_NO = '"+lotNo+"' "
+"AND LOT_SL = '"+lotSl+"' ";
+"WHERE DESP_ID = '"+tranId+"' "
+"AND ITEM_CODE = '"+itemCode+"' "
+"AND LINE_NO = '"+lineNo+"' "
+"AND LOC_CODE = '"+locCode+"' "
+"AND LOT_NO = '"+lotNo+"' "
+"AND LOT_SL = '"+lotSl+"' ";
System.out.println("update sql is :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setDouble(1,rate);
......@@ -176,7 +177,7 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
+"AND LOC_CODE = '"+locCode+"' "
+"AND LOT_NO = '"+lotNo+"' "
+"AND LOT_SL = '"+lotSl+"' ";
//+"AND ALLOC_MODE = 'M' ";//Manual allocation. //Commented Jiten 10/10/06, It should check for both 'A' and 'M'.
//+"AND ALLOC_MODE = 'M' ";//Manual allocation. //Commented Jiten 10/10/06, It should check for both 'A' and 'M'.
System.out.println("Select sql :"+sql);
stmt1 = conn.createStatement();
rs2 = stmt1.executeQuery(sql);
......@@ -186,7 +187,7 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
qtyAlloc = rs2.getDouble(1);
System.out.println("qtyAlloc :"+qtyAlloc);
}
*/
*/
if (!rs2.next())
{
sql = "SELECT CUST_CODE,LOC_GROUP FROM SORDER WHERE SALE_ORDER ='"+sordNo+"' ";
......@@ -202,11 +203,11 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
if (locGroup == null || locGroup.trim().length() == 0)
{
sql = "SELECT A.EXP_DATE, A.GRADE, A.MFG_DATE, A.SITE_CODE__MFG "
+"FROM STOCK A WHERE A.ITEM_CODE = '"+itemCode+"' "
+"AND A.SITE_CODE = '"+siteCode+"' "
+"AND A.LOC_CODE = '"+locCode+"' "
+"AND A.LOT_NO = '"+lotNo+"' "
+"AND A.LOT_SL = '"+lotSl+"'" ;
+"FROM STOCK A WHERE A.ITEM_CODE = '"+itemCode+"' "
+"AND A.SITE_CODE = '"+siteCode+"' "
+"AND A.LOC_CODE = '"+locCode+"' "
+"AND A.LOT_NO = '"+lotNo+"' "
+"AND A.LOT_SL = '"+lotSl+"'" ;
System.out.println("sql :"+sql);
rs4 = stmt1.executeQuery(sql);
if (rs4.next())
......@@ -224,14 +225,14 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
else
{
sql = "SELECT A.EXP_DATE, A.GRADE, A.MFG_DATE, A.SITE_CODE__MFG "
+"FROM STOCK A, LOCATION B "
+"WHERE A.LOC_CODE = B.LOC_CODE "
+"AND B.LOC_GROUP = '"+locGroup+"' "
+"AND A.ITEM_CODE = '"+itemCode+"' "
+"AND A.SITE_CODE = '"+siteCode+"' "
+"AND A.LOC_CODE = '"+locCode+"' "
+"AND A.LOT_NO = '"+lotNo+"' "
+"AND A.LOT_SL = '"+lotSl+"'";
+"FROM STOCK A, LOCATION B "
+"WHERE A.LOC_CODE = B.LOC_CODE "
+"AND B.LOC_GROUP = '"+locGroup+"' "
+"AND A.ITEM_CODE = '"+itemCode+"' "
+"AND A.SITE_CODE = '"+siteCode+"' "
+"AND A.LOC_CODE = '"+locCode+"' "
+"AND A.LOT_NO = '"+lotNo+"' "
+"AND A.LOT_SL = '"+lotSl+"'";
System.out.println("sql :"+sql);
rs4 = stmt1.executeQuery(sql);
if (rs4.next())
......@@ -247,8 +248,8 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
}
}//end else
sql = "SELECT UNIT__STD, CONV__QTY_STDUOM FROM SORDDET "
+"WHERE SALE_ORDER = '"+sordNo+"' "
+"AND LINE_NO = '"+lineNoSord+"'";
+"WHERE SALE_ORDER = '"+sordNo+"' "
+"AND LINE_NO = '"+lineNoSord+"'";
System.out.println("sql :"+sql);
rs5 = stmt1.executeQuery(sql);
if (rs5.next())
......@@ -259,10 +260,10 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
System.out.println("convQtyStdUom :"+convQtyStdUom);
}
sqlInsert = "INSERT INTO SORDALLOC (SALE_ORDER, LINE_NO, EXP_LEV, ITEM_CODE__ORD ,ITEM_CODE, "
+"LOT_NO, LOT_SL, LOC_CODE, ITEM_REF, QUANTITY, UNIT, QTY_ALLOC, DATE_ALLOC, STATUS, "
+"ALLOC_MODE, SITE_CODE ,ITEM_GRADE, EXP_DATE, MFG_DATE, SITE_CODE__MFG, UNIT__STD, "
+"CONV__QTY_STDUOM, QUANTITY__STDUOM )"
+"values(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
+"LOT_NO, LOT_SL, LOC_CODE, ITEM_REF, QUANTITY, UNIT, QTY_ALLOC, DATE_ALLOC, STATUS, "
+"ALLOC_MODE, SITE_CODE ,ITEM_GRADE, EXP_DATE, MFG_DATE, SITE_CODE__MFG, UNIT__STD, "
+"CONV__QTY_STDUOM, QUANTITY__STDUOM )"
+"values(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
System.out.println("Insert sql from DespatchPostSaveEJB :"+sqlInsert);
pstmt = conn.prepareStatement(sqlInsert);
pstmt.setString(1,sordNo);
......@@ -291,7 +292,7 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
updateCnt = pstmt.executeUpdate();
System.out.println("Inserted the no of records : updateCnt :"+updateCnt);
pstmt.clearParameters();
/*strAllocate.put("tran_date",tranDate);
strAllocate.put("ref_ser","S-DSP");
strAllocate.put("ref_id",tranId);
......@@ -357,16 +358,16 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
long lineNoSOAlloc = 0;
double pendingDeallocQty = 0,allocQty = 0,deAllocQty = 0;
sql = "SELECT B.TRAN_ID, B.LINE_NO, (B.QUANTITY - B.DEALLOC_QTY), B.QUANTITY, B.DEALLOC_QTY "+
"FROM SORD_ALLOC A, SORD_ALLOC_DET B "+
"WHERE A.TRAN_ID = B.TRAN_ID "+
"AND A.CUST_CODE = ? "+
"AND A.SITE_CODE = ? "+
"AND A.SALE_ORDER IS NULL "+
"AND B.ITEM_CODE = ? "+
"AND B.LOC_CODE = ? "+
"AND B.LOT_NO = ? "+
"AND B.LOT_SL = ? "+
"AND B.QUANTITY - B.DEALLOC_QTY > 0 ";
"FROM SORD_ALLOC A, SORD_ALLOC_DET B "+
"WHERE A.TRAN_ID = B.TRAN_ID "+
"AND A.CUST_CODE = ? "+
"AND A.SITE_CODE = ? "+
"AND A.SALE_ORDER IS NULL "+
"AND B.ITEM_CODE = ? "+
"AND B.LOC_CODE = ? "+
"AND B.LOT_NO = ? "+
"AND B.LOT_SL = ? "+
"AND B.QUANTITY - B.DEALLOC_QTY > 0 ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,custCode);
pstmt.setString(2,siteCode);
......@@ -406,9 +407,9 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
qtyUpdate = qtyStduom - oldQty;
}
sql = "UPDATE SORD_ALLOC_DET "+
"SET DEALLOC_QTY = DEALLOC_QTY + ? "+
"WHERE TRAN_ID = ? "+
"AND LINE_NO = ? ";
"SET DEALLOC_QTY = DEALLOC_QTY + ? "+
"WHERE TRAN_ID = ? "+
"AND LINE_NO = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setDouble(1,qtyUpdate);
pstmt.setString(2,tranIdSOAlloc);
......@@ -437,15 +438,15 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
{
System.out.println("distStkUpd.UpdAllocTrace(hashMap) : Sucessuful!");
}*/
InvAllocTraceBean invBean = new InvAllocTraceBean();
String errString = invBean.updateInvallocTrace(strAllocate,conn);
if(errString == null && errString.trim().length() == 0){
System.out.println("distStkUpd.UpdAllocTrace(hashMap) : Sucessuful!");
}
InvAllocTraceBean invBean = new InvAllocTraceBean();
String errString = invBean.updateInvallocTrace(strAllocate,conn);
if(errString == null && errString.trim().length() == 0){
System.out.println("distStkUpd.UpdAllocTrace(hashMap) : Sucessuful!");
}
sqlUpdate = "UPDATE SORDITEM SET QTY_ALLOC = QTY_ALLOC + ? "
+"WHERE SALE_ORDER = ? "
+"AND LINE_NO = ? "
+"AND EXP_LEV = ? ";
+"WHERE SALE_ORDER = ? "
+"AND LINE_NO = ? "
+"AND EXP_LEV = ? ";
System.out.println("Update sql :"+sqlUpdate);
pstmt = conn.prepareStatement(sqlUpdate);
pstmt.setDouble(1,qtyStduom);
......@@ -456,6 +457,7 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
System.out.println("Updated the no of records : updateCnt :"+updateCnt);
pstmt.clearParameters();
}
}//try end
catch (SQLException sqx)
{
......@@ -483,7 +485,7 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
pstmt.close();
pstmt = null;
}
}
catch(Exception e)
{
......@@ -494,6 +496,117 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
}
return "";
}
//postSave() added by kunal on 11/07/13 FOR cross update
public String postSave(String winName,String editFlag,String tranId, String xtraParams,Connection conn) throws RemoteException,ITMException
{
String sql = "",saleOrder = "";
int lineNo = 0;
double grossWeight = 0,tareWeight = 0,netWeight = 0,noAart = 0,offinvAmt = 0,billbackAmt = 0 ;
double quantityStduom = 0 ,rateStduom = 0,offinvAmtDet = 0,taxAmtDet = 0 ,discount = 0,totAmt = 0,amount = 0;
//GenericUtility genericUtility = GenericUtility.getInstance();
PreparedStatement pstmt = null,pstmt1 = null;
ResultSet rs = null,rs1 = null;
//System.out.println("tranId="+tranId+" xtraParams="+xtraParams);
try
{
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.setString( 1, tranId );
rs1 = pstmt1.executeQuery();
while (rs1.next())
{
saleOrder = rs1.getString("sord_no");
lineNo = rs1.getInt("line_no__sord");
quantityStduom = rs1.getDouble("quantity__stduom");
rateStduom = rs1.getDouble("rate__stduom");
offinvAmtDet = rs1.getDouble("disc_schem_offinv_amt");
taxAmtDet = rs1.getDouble("tax_amt");
sql = " select discount from sorddet where sale_order = ? and line_no = ? ";
pstmt= conn.prepareStatement(sql);
pstmt.setString( 1, saleOrder );
pstmt.setInt( 2, lineNo );
rs = pstmt.executeQuery();
if (rs.next())
{
discount = rs.getDouble("discount");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
//[(quantity__stduom*rate__stduom)-((quantity__stduom*rate__stduom*discount)/100)-disc_schem_offinv_amt+tax_amt]
amount = (quantityStduom*rateStduom) - ((quantityStduom*rateStduom*discount)/100) - offinvAmtDet + taxAmtDet;
System.out.println("amount="+amount);
totAmt = totAmt + amount;
}
rs1.close();
rs1 = null;
pstmt1.close();
pstmt1 = null;
System.out.println("tot amt = "+totAmt);
sql = "select sum(gross_weight),sum(tare_weight) ,sum(nett_weight) ,sum(no_art) ,sum(disc_schem_offinv_amt) ,sum(disc_schem_billback_amt) "
+" from despatchdet where desp_id = ? ";
pstmt= conn.prepareStatement(sql);
pstmt.setString( 1, tranId );
rs = pstmt.executeQuery();
if (rs.next())
{
grossWeight = rs.getDouble(1);
tareWeight = rs.getDouble(2);
netWeight = rs.getDouble(3);
noAart = rs.getDouble(4);
offinvAmt = rs.getDouble(5);
billbackAmt = rs.getDouble(6);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("sum ="+grossWeight+" "+tareWeight+" "+netWeight+" "+noAart+" "+offinvAmt+" "+billbackAmt);
sql = " update despatch set gross_weight = ? , tare_weight = ?,nett_weight = ?,no_art = ?, "
+" disc_offinv_amt_det = ?, disc_billback_amt_det = ? ,tot_value = ? where desp_id = ? " ;
pstmt= conn.prepareStatement( sql );
pstmt.setDouble( 1, grossWeight );
pstmt.setDouble( 2, tareWeight );
pstmt.setDouble( 3, netWeight );
pstmt.setDouble( 4, noAart );
pstmt.setDouble( 5, offinvAmt );
pstmt.setDouble( 6, billbackAmt );
pstmt.setDouble( 7, totAmt );
pstmt.setString( 8, tranId );
pstmt.executeUpdate();
pstmt.close();
pstmt = null;
}
catch(Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if(pstmt != null)pstmt.close();
pstmt = null;
}catch(Exception d)
{
d.printStackTrace();
throw new ITMException(d);
}
}
return "";
}
private Node getCurrentDetailFromDom(Document dom,String domId)
{
......@@ -557,23 +670,23 @@ public class DespatchPos extends ValidatorEJB implements DespatchPosLocal, Despa
return comp;
}*/
private DistStkUpdLocal getComponent(String componentName)throws Exception
{
{
DistStkUpdLocal comp = null;
try
{
try
{
System.out.println("Looking For Component.... :: " + componentName);
AppConnectParm appConnect = new AppConnectParm();
java.util.Properties p = appConnect.getProperty();
InitialContext ctx = new InitialContext(p);
comp = (DistStkUpdLocal)ctx.lookup("ibase/DistStkUpd/local"); // for ejb3
comp = (DistStkUpdLocal)ctx.lookup("ibase/DistStkUpd/local"); // for ejb3
//comp = distStkUpdHome.create();
System.out.println(componentName+" Found.....");
}
catch(Exception e)
{
}
catch(Exception e)
{
throw e;
}
}
return comp;
}
}
\ No newline at end of file
webitm-dis/ibase/webitm/ejb/dis/DespatchPosLocal.java
View file @ b2afc2bd
......@@ -16,4 +16,6 @@ public interface DespatchPosLocal extends ValidatorLocal
{
public String postSaveRec()throws RemoteException,ITMException;
public String postSaveRec(String xmlString1,String domID,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException;
//added by kunal on 09/007/13
public String postSave(String winName,String editFlag,String tranId, String xtraParams,Connection conn) throws RemoteException,ITMException;
}
\ No newline at end of file
webitm-dis/ibase/webitm/ejb/dis/DespatchPosRemote.java
View file @ b2afc2bd
......@@ -14,4 +14,6 @@ public interface DespatchPosRemote extends ValidatorRemote
{
public String postSaveRec()throws RemoteException,ITMException;
public String postSaveRec(String xmlString1,String domID,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException;
//added by kunal on 09/007/13
public String postSave(String winName,String editFlag,String tranId, String xtraParams,Connection conn) throws RemoteException,ITMException;
}
\ No newline at end of file
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