Skip to content

B
business-java
Commit 6f62db90 authored by manohar's avatar manohar
Browse files
Options

update of alloc_flag in sorder 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@91730 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 12ab7f7c
Hide whitespace changes
Inline Side-by-side
Showing with 544 additions and 0 deletions
webitm-dis/ibase/webitm/ejb/dis/adv/StockAllocPrc.java 0 → 100755
View file @ 6f62db90
/********************************************************
Title : StockAllocPrc
Date : 04/12/2011
Developer: Dipak Chattar
********************************************************/
package ibase.webitm.ejb.dis.adv;
import ibase.system.config.ConnDriver;
import ibase.webitm.ejb.ActionHandlerEJB;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.dis.InvAllocTraceBean;
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 java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.HashMap;
import javax.ejb.Stateless;
@Stateless
public class StockAllocPrc extends ActionHandlerEJB implements StockAllocPrcLocal, StockAllocPrcRemote//SessionBean {
{
public String confirm(String tranId,String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
String sql = "";
String confirm = "";
String errString = "" ;
ConnDriver connDriver = null;
ITMDBAccessEJB itmDBAccessEJB = null;
try
{
itmDBAccessEJB = new ITMDBAccessEJB();
connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
connDriver = null;
conn.setAutoCommit(false);
sql = "select confirmed,site_code from sord_alloc where tran_id = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,tranId);
rs = pstmt.executeQuery();
if(rs.next())
{
confirm = rs.getString("confirmed");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if(confirm != null && "Y".equalsIgnoreCase(confirm))
{
System.out.println("The Selected transaction is already confirmed");
errString = itmDBAccessEJB.getErrorString("","VTMCONF1","");
return errString;
}
else
{
errString = this.sorderAllocate(tranId,xtraParams,conn);
if(errString != null && errString.trim().length() > 0)
{
return errString;
}
}
} //end of try
catch(Exception e)
{
System.out.println("Exception ::"+e.getMessage());
throw new ITMException(e);
}
finally
{
try
{
if(errString != null && errString.trim().length() > 0)
{
if(errString.indexOf("CONFSUCCES") > -1)
{
conn.commit();
}
else
{
conn.rollback();
}
}
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
conn.close();
conn = null;
}
catch(Exception e)
{
System.out.println("Exception : "+e);e.printStackTrace();
throw new ITMException(e);
}
}
return errString;
} //end of confirm method
private String sorderAllocate( String tranId, String xtraParams, Connection conn )throws RemoteException,ITMException
{
System.out.println("updateSOrder calling ..............");
String getDataSql = null;
String saleOrder = null;
String sorditemSql=null;
String itemCodeOrd = null ;
String unitStd = null ;
String lotSl= null;
String lotNo = null;
String locCode = null;
String unit = null;
String grade = null;
String siteCodeMfg =null;
String itemRef = null;
String lineNoSord = null;
String itemCode = null;
String siteCode = null;
String expLev = null;
String updateSorditem = null;
String sordAllocSql = null;
String insertSql = null;
String updateSql= null;
String updateSql1= null;
String empCode = "";
String dateNow ="";
String errString = "";
int count1 = 0 ;
int count2 = 0 ;
double qtyToBeAllocated = 0d;
double quantity =0;
double convQtyStduom = 0 ;
double quantityStduom = 0 ;
double pendingQuantity = 0;
java.sql.Date expDate = new java.sql.Date(System.currentTimeMillis());
java.sql.Date mfgDate = new java.sql.Date(System.currentTimeMillis());
java.sql.Date dateAlloc= new java.sql.Date(System.currentTimeMillis());
PreparedStatement pstmt = null;
PreparedStatement pSordAllocDet = null;
PreparedStatement pSelSordItem = null;
PreparedStatement pUpdSordItem = null;
PreparedStatement pSelSordAlloc = null;
PreparedStatement pUpdSordAlloc = null;
PreparedStatement pInsSordAlloc = null;
ResultSet rs = null ;
ResultSet rsTemp = null;
ITMDBAccessEJB itmDBAccessEJB = null;
InvAllocTraceBean invAllocTrace = new InvAllocTraceBean();
GenericUtility genericUtility = GenericUtility.getInstance();
HashMap strAllocate = null;
try
{
String dbDateFormat = genericUtility.getDBDateFormat();
String applDateFormat = genericUtility.getApplDateFormat();
itmDBAccessEJB = new ITMDBAccessEJB();
java.util.Date currDate1 = new java.util.Date();
SimpleDateFormat sdf = new SimpleDateFormat(applDateFormat);
String currDateStr = sdf.format(currDate1);
java.sql.Timestamp tranDate = java.sql.Timestamp.valueOf(genericUtility.getValidDateString( currDateStr , applDateFormat, dbDateFormat ) + " 00:00:00.0") ;
sorditemSql = "SELECT ITEM_CODE,ITEM_CODE__ORD,UNIT, ITEM_REF"
//+" QUANTITY - QTY_DESP PENDING_QUANTITY "
+" FROM SORDITEM WHERE SALE_ORDER = ? "
+" AND LINE_NO = ? "
+" AND EXP_LEV = ? ";
//System.out.println("sorditemSql:::"+sorditemSql);
pSelSordItem = conn.prepareStatement(sorditemSql);
updateSorditem ="UPDATE SORDITEM SET QTY_ALLOC = CASE WHEN QTY_ALLOC IS NULL THEN 0 ELSE QTY_ALLOC END + ? "
+" WHERE SALE_ORDER = ? "
+" AND LINE_NO = ? "
+" AND EXP_LEV = ? ";
pUpdSordItem = conn.prepareStatement(updateSorditem);
sordAllocSql = "SELECT COUNT(1) FROM SORDALLOC "
+ " WHERE SALE_ORDER = ? "
+ " AND LINE_NO = ? "
+ " AND EXP_LEV = ? "
+ " AND ITEM_CODE__ORD = ? "
+ " AND ITEM_CODE = ? "
+ " AND LOT_NO = ? "
+ " AND LOT_SL = ? "
+ " AND LOC_CODE = ? " ;
pSelSordAlloc = conn.prepareStatement(sordAllocSql);
updateSql = "UPDATE SORDALLOC SET QTY_ALLOC = QTY_ALLOC + ? "
+ " WHERE SALE_ORDER = ? "
+ " AND LINE_NO = ? "
+ " AND EXP_LEV = ? "
+ " AND ITEM_CODE__ORD = ? "
+ " AND ITEM_CODE = ? "
+ " AND LOT_NO = ? "
+ " AND LOT_SL = ? "
+ " AND LOC_CODE = ? " ;
pUpdSordAlloc = conn.prepareStatement(updateSql);
insertSql ="INSERT INTO SORDALLOC (SALE_ORDER,LINE_NO,EXP_LEV,ITEM_CODE__ORD,SITE_CODE ,"
+"ITEM_CODE,QUANTITY ,LOT_NO, LOT_SL, LOC_CODE, UNIT, QTY_ALLOC,"
+"ITEM_REF, DATE_ALLOC, STATUS,ITEM_GRADE, EXP_DATE, ALLOC_MODE, "
+" CONV__QTY_STDUOM, UNIT__STD, QUANTITY__STDUOM, "
+"MFG_DATE, SITE_CODE__MFG ) "
+"VALUES ( ?, ? , ? , ? , ? , ? , ? , ? , ? , ? , ? , ? ,"
+" ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? ) " ;
pInsSordAlloc = conn.prepareStatement(insertSql);
getDataSql = "select d.line_no ,d.sale_order ,d.line_no__sord ,d.item_code , "
+" d.loc_code ,d.lot_no ,d.lot_sl ,d.quantity ,d.dealloc_qty,d.site_code, "
+" d.exp_lev,d.pending_qty "
+" from sord_alloc_det d "
+" where d.tran_id = ? "
+" order by line_no asc ";
pSordAllocDet = conn.prepareStatement(getDataSql);
pSordAllocDet.setString(1,tranId);
rs = pSordAllocDet.executeQuery();
System.out.println("tranId------"+ tranId);
int updCount = 0;
while(rs.next())
{
System.out.println( "INSIDE WHILE LOOP.............");
//SALE_ORDER
saleOrder = rs.getString(2);
//LINE_NO__SlineNoSordORD
lineNoSord = rs.getString(3);
lineNoSord = " " + lineNoSord.trim();
lineNoSord = lineNoSord.substring( lineNoSord.length()-3 );
System.out.println("lineNoSord =["+lineNoSord+"]");
//ITEM_CODE
itemCode = rs.getString(4);
//LOC_CODE
locCode = rs.getString(5);
//LOT_NO
lotNo = rs.getString(6);
//LOT_SL
lotSl = rs.getString(7);
//QUANTITY
quantity = rs.getDouble(8);
//SITE_CODE
siteCode = rs.getString(10);
//EXP_LEV
expLev = rs.getString(11);
pendingQuantity = rs.getDouble(12);
qtyToBeAllocated = quantity;
System.out.print("Allocatio Qty = " + qtyToBeAllocated);
if (qtyToBeAllocated > 0)
{
strAllocate = new HashMap();
strAllocate.put("tran_date",tranDate);
strAllocate.put("ref_ser","S-ALC");
strAllocate.put("ref_id",saleOrder);
strAllocate.put("ref_line", "" + lineNoSord);
strAllocate.put("site_code",siteCode);
strAllocate.put("item_code",itemCode);
strAllocate.put("loc_code",locCode);
strAllocate.put("lot_no",lotNo);
strAllocate.put("lot_sl",lotSl);
strAllocate.put("alloc_qty",new Double(qtyToBeAllocated));
strAllocate.put("chg_user",GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams,"loginCode"));
strAllocate.put("chg_term",GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams,"termId"));
strAllocate.put("chg_win","W_SORDALLOC");
errString = invAllocTrace.updateInvallocTrace(strAllocate, conn);
System.out.println("errString ::: " + errString);
if (errString != null && errString.trim().length() > 0 )
{
break;
}
strAllocate = null;
//Selecting ITEM_CODE,ITEM_CODE__ORD,UNIT, ITEM_REF from SORDITEM TABLE
pSelSordItem.setString(1, saleOrder);
pSelSordItem.setString(2, lineNoSord);
pSelSordItem.setString(3, expLev);
rsTemp = pSelSordItem.executeQuery();
pSelSordItem.clearParameters();
if (rsTemp.next())
{
//ITEM_CODE
itemCode = rsTemp.getString(1);
System.out.println("itemCode::::"+ itemCode);
//ITEM_CODE__ORD
itemCodeOrd = rsTemp.getString(2);
//UNIT
unitStd = rsTemp.getString(3);
//ITEM_REF
itemRef = rsTemp.getString(4);
//PENDING_QUANTITY
}
rsTemp.close(); rsTemp = null;
//Updating the alloc quantity in SORDITEM TABLE
pUpdSordItem.setDouble(1, qtyToBeAllocated );
pUpdSordItem.setString(2, saleOrder);
pUpdSordItem.setString(3, lineNoSord);
pUpdSordItem.setString(4, expLev);
updCount = pUpdSordItem.executeUpdate();
pUpdSordItem.clearParameters();
if ( updCount > 0 )
{
System.out.println("UPDATE SUCCESS FOR SORDITEM....>>>>>>>>");
}
//new Double(qtyToBeAllocated).toString()
//Counting the records in SORDALLOC TABLE
pSelSordAlloc.setString(1, saleOrder);
pSelSordAlloc.setString(2, lineNoSord);
pSelSordAlloc.setString(3, expLev);
pSelSordAlloc.setString(4, itemCodeOrd);
pSelSordAlloc.setString(5, itemCode);
pSelSordAlloc.setString(6, lotNo);
pSelSordAlloc.setString(7, lotSl);
pSelSordAlloc.setString(8, locCode);
rsTemp = pSelSordAlloc.executeQuery();
pSelSordAlloc.clearParameters();
int count = 0 ;
if (rsTemp.next())
{
count = rsTemp.getInt(1);
}
rsTemp.close(); rsTemp = null;
if (count > 0 )
{
//Updating the alloc quantity in SORDALLOC TABLE
pUpdSordAlloc.setDouble(1, qtyToBeAllocated );
pUpdSordAlloc.setString(2, saleOrder);
pUpdSordAlloc.setString(3, lineNoSord);
pUpdSordAlloc.setString(4, expLev);
pUpdSordAlloc.setString(5, itemCodeOrd);
pUpdSordAlloc.setString(6, itemCode);
pUpdSordAlloc.setString(7, lotNo);
pUpdSordAlloc.setString(8, lotSl);
pUpdSordAlloc.setString(9, locCode);
updCount = pUpdSordAlloc.executeUpdate();
pUpdSordAlloc.clearParameters();
if ( updCount > 0 )
{
System.out.println("UPDATE SUCCESS FOR SORDALLOC....");
}
}
else
{
//Inserting the records into SORDALLOC TABLE
//SALE_ORDER
pInsSordAlloc.setString(1, saleOrder);
System.out.println("saleOrder------->"+saleOrder);
//LINE_NO
pInsSordAlloc.setString(2, lineNoSord);
System.out.println("lineNo------->"+lineNoSord);
//EXP_LEV
pInsSordAlloc.setString(3, expLev);
System.out.println("EXP_LEV------->"+expLev);
//ITEM_CODE__ORD
pInsSordAlloc.setString(4, itemCodeOrd);
System.out.println("item_code__ord------->"+itemCodeOrd);
//SITE_CODE
pInsSordAlloc.setString(5, siteCode);
System.out.println("siteCode------->"+siteCode);
//ITEM_CODE
pInsSordAlloc.setString(6, itemCode);
System.out.println("itemCode------->"+itemCode);
//QUANTITY***** set pending qty
pInsSordAlloc.setDouble(7, pendingQuantity);
System.out.println("pendingQuantity------->"+pendingQuantity);
//LOT_NO
pInsSordAlloc.setString(8, lotNo);
System.out.println("lotNo------->"+lotNo);
//LOT_SL
pInsSordAlloc.setString(9, lotSl);
System.out.println("lotSl------->"+lotSl);
//LOC_CODE
pInsSordAlloc.setString(10, locCode);
System.out.println("locCode------->"+locCode);
//UNIT
pInsSordAlloc.setString(11, unit);
System.out.println("unit------->"+unit);
//QTY_ALLOC
pInsSordAlloc.setDouble(12, qtyToBeAllocated);
System.out.println("lotQtyToBeAllocated------->" +qtyToBeAllocated);
//ITEM_REF
pInsSordAlloc.setString(13,itemRef);
System.out.println("itemRef------->"+itemRef);
//DATE_ALLOC
pInsSordAlloc.setDate(14,dateAlloc);
System.out.println("dateAlloc------->"+dateAlloc);
//STATUS
pInsSordAlloc.setString(15,"P");
System.out.println("status------->P");
//ITEM_GRADE
pInsSordAlloc.setString(16,grade);
System.out.println("grade------->"+grade);
//EXP_DATE
pInsSordAlloc.setDate(17,expDate);
System.out.println("expDate------->"+expDate);
//ALLOC_MODE
pInsSordAlloc.setString(18,"M");
//CONV__QTY_STDUOM
pInsSordAlloc.setDouble(19,convQtyStduom);
System.out.println("convQtyStduom------->"+convQtyStduom);
//UNIT__STD
pInsSordAlloc.setString(20,unitStd);
System.out.println("unitStd------->"+unitStd);
quantityStduom = convQtyStduom * qtyToBeAllocated ;
//QUANTITY__STDUOM
pInsSordAlloc.setDouble(21,quantityStduom);
System.out.println("quantityStduom------->"+quantityStduom);
//MFG_DATE
pInsSordAlloc.setDate(22,mfgDate);
System.out.println("mfgDate------->"+mfgDate);
//SITE_CODE__MFG
pInsSordAlloc.setString(23,siteCodeMfg);
System.out.println("siteCodeMfg------->"+siteCodeMfg);
//QTY_DESP
int insCnt = 0;
insCnt = pInsSordAlloc.executeUpdate();
pInsSordAlloc.clearParameters();
if ( insCnt > 0 )
{
System.out.println("insertion success ...............>>>>>>>>");
}
}//end else
}//end of if(qtyToBeAllocated > 0)
}//end of while
rs.close(); rs = null;
pSordAllocDet.clearParameters();
pSordAllocDet.close(); pSordAllocDet = null;
saleOrder
updateSql = "UPDATE sorder SET alloc_flag = 'M'WHERE sale_order = ? ";
pstmt = conn.prepareStatement(updateSql);
pstmt.setString(1,saleOrder);
updCount = pstmt.executeUpdate();
pstmt.close(); pstmt = null;
empCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode");
Calendar currentDate = Calendar.getInstance();
SimpleDateFormat simpleDateFormat = new SimpleDateFormat(genericUtility.getApplDateFormat());
dateNow = simpleDateFormat.format(currentDate.getTime());
java.sql.Timestamp confDate = java.sql.Timestamp.valueOf(genericUtility.getValidDateString( dateNow , genericUtility.getApplDateFormat(), genericUtility.getDBDateFormat() ) + " 00:00:00.0") ;
updateSql = "UPDATE SORD_ALLOC SET CONFIRMED = 'Y', emp_code__aprv = ?, conf_date = ? WHERE TRAN_ID = ? ";
pstmt = conn.prepareStatement(updateSql);
pstmt.setString(1,empCode);
pstmt.setTimestamp(2,confDate);
pstmt.setString(3,tranId);
updCount = pstmt.executeUpdate();
pstmt.close(); pstmt = null;
if( updCount > 0 )
{
errString = itmDBAccessEJB.getErrorString("","CONFSUCCES","");
return errString;
}
}
catch(SQLException se)
{
System.out.println("SQLException :" + se);
se.printStackTrace();
errString = se.getMessage();
return errString;
}
catch(Exception e)
{
System.out.println("Exception :" + e);
errString = e.getMessage();
e.printStackTrace();
try
{
conn.rollback();
}
catch(Exception e1)
{
e = e1;
}
return errString ;
}
finally
{
try
{
if(conn != null)
{
if(pSordAllocDet != null)
{
pSordAllocDet.close();
pSordAllocDet = null;
}
if(pInsSordAlloc != null)
{
pInsSordAlloc.close();
pInsSordAlloc = null;
}
}
}
catch(Exception e)
{
errString = e.getMessage();
e.printStackTrace();
return errString ;
}
return errString;
}
}// end of sorderAllocate
}
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