Skip to content

B
business-java
Commit 9f0c9200 authored by dpawar's avatar dpawar
Browse files
Options

result set close 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@97165 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 3ab5f18c
Hide whitespace changes
Inline Side-by-side
Showing with 491 additions and 475 deletions
webitm-wms/ibase/webitm/ejb/wms/MultiplePtcnWizConf.java
View file @ 9f0c9200
......@@ -62,11 +62,11 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
PreparedStatement pstmtUpdPickOrdDet =null;
String sql = "",errorString = "",confirmed = "";
String itemCode = "",siteCode = "",locCode = "",lotNo = "",lotSl = "",locCodeTo = "",saleOrder = "",
lineNoSord = "",replOrder = "",pickType = "",dExpLev = "",remarks = "",dimension = "";
lineNoSord = "",replOrder = "",pickType = "",dExpLev = "",remarks = "",dimension = "";
String acctCodeDr = "",cctrCodeDr = "",packCode = "",siteCodeMfg = "",stagingLoc = "",
packInstr = "",suppCodeMfg = "",unitAlt = "",batchNo = "",unit = "",grade = "",
expLev = "",itemCodeOrd = "",itemRef = "",status = "",itemGrade = "",waveId = "",retString = "",
allocMode = "",reasCode = "",unitStd = "",sSQL = "",updateSql = "",ptcn = "",refSer = "";
packInstr = "",suppCodeMfg = "",unitAlt = "",batchNo = "",unit = "",grade = "",
expLev = "",itemCodeOrd = "",itemRef = "",status = "",itemGrade = "",waveId = "",retString = "",
allocMode = "",reasCode = "",unitStd = "",sSQL = "",updateSql = "",ptcn = "",refSer = "";
int lineNoOrd= 0,lineNo= 0,updCnt = 0,rowsCount = 0;
double quantity = 0,noArt =0,stkGrossRate = 0,convQtyStduom = 0,batchSize = 0,holdQuantity = 0,stkRate = 0;
double shipperSize = 0, itemGrossWeight = 0, caseGrossWeight = 0, itemNetWeight = 0, caseNetWeight = 0,
......@@ -74,7 +74,7 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
isError = false;
boolean isUpdatehdr= false;
java.sql.Timestamp expDate = null,currDate = null, mfgDate = null,restestDate = null,dateAlloc = null;
HashMap updateRowMap = new HashMap();
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccess = new ITMDBAccessEJB();
......@@ -96,7 +96,7 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
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") ;
confirmed = checkNull(getColumnDescr(conn, "confirmed", "multi_pick_iss", "tran_id", tranId));
System.out.println("confirmed----->>["+confirmed+"]");
confirmed = confirmed.length() == 0 ? "N" :confirmed;
......@@ -112,7 +112,7 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
System.out.println("stagingLoc------>>["+stagingLoc+"]");
stkUpdate = new StockUpdate();
invAllocTrace = new InvAllocTraceBean();
sql = "select acct_code__inv, cctr_code__inv, "
+ "exp_date, pack_code, mfg_date, site_code__mfg, "
+ "pack_instr, supp_code__mfg, retest_date, rate, "
......@@ -123,7 +123,7 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
+ "and loc_code = ? "
+ "and lot_no = ? "
+ "and lot_sl = ? ";
pstmtStock = conn.prepareStatement(sql);
sql = "SELECT H.WAVE_ID WAVE_ID,R.PTCN PTCN,R.TRAN_ID,R.LINE_NO LINE_NO, R.ITEM_CODE ITEM_CODE, R.SITE_CODE SITE_CODE, "
......@@ -177,7 +177,7 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
caseGrossWeight = (Double) itmVolumeMap.get("CASE_GROSS_WEIGHT");
itemNetWeight = (Double) itmVolumeMap.get("ITEM_NET_WEIGHT");
caseNetWeight = (Double) itmVolumeMap.get("CASE_NET_WEIGHT");
dataMap.put("wave_id", waveId);
dataMap.put("ptcn", ptcn);
dataMap.put("item_code", itemCode);
......@@ -185,7 +185,7 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
dataMap.put("lot_no", lotNo);
dataMap.put("lot_sl", lotSl);
dataMap.put("quantity", ""+quantity);
dataMap.put("sale_order", saleOrder);
dataMap.put("line_no__sord", lineNoSord);
dataMap.put("line_no", ""+lineNo);
......@@ -203,7 +203,7 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
lineNo = rs.getInt( "LINE_NO" );
pstmtStock.setString(1,itemCode);
pstmtStock.setString(2,siteCode);
pstmtStock.setString(3,locCode);
......@@ -260,10 +260,8 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
updateRowMap.put("cctr_code_inv",cctrCodeDr);
updateRowMap.put("rate",Double.toString(stkRate));
updateRowMap.put("gross_rate",Double.toString(stkGrossRate));
updateRowMap.put("tran_id", tranId );
// 17/10/11 manoharan
updateRowMap.put("line_no", "" + lineNo );
// end 17/10/11 manoharan
updateRowMap.put("tran_id", tranId );
updateRowMap.put("line_no", "" + lineNo );
updateRowMap.put("tran_date", tranDate );
updateRowMap.put("tran_type","ID");
......@@ -284,7 +282,7 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
updateRowMap.put("unit__alt", unitAlt);
updateRowMap.put("batch_no", batchNo);
updateRowMap.put("batch_size", ""+batchSize);
System.out.println("quantity---->>["+quantity+" shipperSize--->>["+shipperSize+"]");
if(quantity < shipperSize || shipperSize == 0)
{
......@@ -294,7 +292,7 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
{
noArt = Math.floor((quantity) / shipperSize) ;
}
dataMap.put("no_art", ""+noArt);
updateRowMap.put("no_art", noArt);
......@@ -342,7 +340,7 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
strAllocate.put("chg_win","w_multi_pick_iss");
errorString = invAllocTrace.updateInvallocTrace(strAllocate, conn);
System.out.println("errorString after updateInvallocTrace----->["+errorString+"]");
// To check the sordalloc allocated quantity > quantity then insert new record deducte quantity from old location.
sql = " SELECT EXP_LEV, ITEM_CODE__ORD, "
+ " ITEM_REF, UNIT, DATE_ALLOC, STATUS, ITEM_GRADE, EXP_DATE, ALLOC_MODE, SITE_CODE, "
......@@ -353,475 +351,474 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
+ " AND LOT_NO = ? "
+ " AND LOT_SL = ? "
+ " AND QTY_ALLOC > 0";
pstmt1 = conn.prepareStatement(sql);
pstmt1.setString(1, saleOrder);
pstmt1.setString(2, lineNoSord);
pstmt1.setString(3, itemCode);
pstmt1.setString(4, locCode);
pstmt1.setString(5, lotNo);
pstmt1.setString(6, lotSl);
rs1 = pstmt1.executeQuery();
if( rs1.next())
pstmt1 = conn.prepareStatement(sql);
pstmt1.setString(1, saleOrder);
pstmt1.setString(2, lineNoSord);
pstmt1.setString(3, itemCode);
pstmt1.setString(4, locCode);
pstmt1.setString(5, lotNo);
pstmt1.setString(6, lotSl);
rs1 = pstmt1.executeQuery();
if( rs1.next())
{
System.out.println("Inside the Query the Exp level["+expLev+"]");
expLev = rs1.getString( "EXP_LEV" );
System.out.println("Inside the Query the Exp level["+expLev+"]");
if (expLev == null || expLev.trim().length() == 0)
{
expLev = dExpLev;
}
if (expLev == null || expLev.trim().length() == 0)
{
expLev = " ";
}
itemCodeOrd = rs1.getString( "ITEM_CODE__ORD" );
itemRef = rs1.getString( "ITEM_REF" );
unit = rs1.getString( "UNIT" );
status = rs1.getString( "STATUS" );
itemGrade = rs1.getString( "ITEM_GRADE" );
allocMode = rs1.getString( "ALLOC_MODE" );
siteCode = rs1.getString( "SITE_CODE" );
siteCodeMfg = rs1.getString( "SITE_CODE__MFG" );
reasCode = rs1.getString( "REAS_CODE" );
unitStd = rs1.getString( "UNIT__STD" );
convQtyStduom = rs1.getDouble( "CONV__QTY_STDUOM" );
dateAlloc = rs1.getTimestamp("DATE_ALLOC");
expDate = rs1.getTimestamp("EXP_DATE");
mfgDate = rs1.getTimestamp("MFG_DATE");
qtyOrd = rs1.getDouble( "QUANTITY" );
sordAllocQty = rs1.getDouble( "QTY_ALLOC" );
}
else
{
isError = true;
errorString = itmDBAccess.getErrorString("","RECNOTSORA","");
return errorString;
}
rs1.close();
rs1 = null;
pstmt1.close();
pstmt1 = null;
sSQL = "SELECT COUNT(*) AS COUNT FROM SORDALLOC WHERE "
+ " SALE_ORDER = ? AND LINE_NO = ? "
+ " AND ITEM_CODE = ? "
+ " AND LOC_CODE = ? "
+ " AND LOT_NO = ? "
+ " AND LOT_SL = ? ";
int count = 0;
System.out.println("sordAllocQty---->>["+sordAllocQty+" quantity--->["+quantity+"]");
if(sordAllocQty > quantity)
{
System.out.println("sordAllocQty in greater.................");
updateSql = "UPDATE SORDALLOC SET QTY_ALLOC = QTY_ALLOC - ? ,QUANTITY__STDUOM = QUANTITY__STDUOM - ?, WAVE_FLAG = 'Y' "
+ " WHERE SALE_ORDER = ? AND LINE_NO = ? "
+ " AND ITEM_CODE = ? "
+ " AND LOC_CODE = ? "
+ " AND LOT_NO = ? "
+ " AND LOT_SL = ? "
+ " AND QTY_ALLOC > 0";
pstmtUpd = conn.prepareStatement(updateSql);
pstmtUpd.setDouble(1, quantity);
//Changed by sumit on 10/09/13 setting
pstmtUpd.setDouble(2, quantity * convQtyStduom);
pstmtUpd.setString(3, saleOrder);
pstmtUpd.setString(4, lineNoSord);
pstmtUpd.setString(5, itemCode);
pstmtUpd.setString(6, locCode);
pstmtUpd.setString(7, lotNo);
pstmtUpd.setString(8, lotSl);
updCnt = pstmtUpd.executeUpdate();
if(pstmtUpd !=null)
{
pstmtUpd.close();
pstmtUpd=null;
}
System.out.println(" sordalloc updated updCnt [" + updCnt + "]");
if (expLev == null || expLev.trim().length() == 0)
{
System.out.println("Check1l["+expLev+"]");
expLev = dExpLev;
}
System.out.println("Finally the Exp level["+expLev+"]");
pstmtSord = conn.prepareStatement(sSQL);
pstmtSord.setString(1, saleOrder);
pstmtSord.setString(2, lineNoSord);
pstmtSord.setString(3, itemCode);
pstmtSord.setString(4, stagingLoc);
pstmtSord.setString(5, lotNo);
pstmtSord.setString(6, lotSl);
rsSord = pstmtSord.executeQuery();
if(rsSord.next())
{
count = rsSord.getInt(1);
}
System.out.println("count SORDALLOC@@------>>["+count+"]");
if(count > 0)
{
System.out.println(" sordalloc If alrady exist Location Update Inside grater updCnt1st [" + updCnt + "]");
//updateSql = "UPDATE SORDALLOC SET QTY_ALLOC = QTY_ALLOC + ? ,QUANTITY__STDUOM = QUANTITY__STDUOM + ?"
updateSql = "UPDATE SORDALLOC SET QTY_ALLOC = QTY_ALLOC + ? ,QUANTITY__STDUOM = QUANTITY__STDUOM + ?, WAVE_FLAG = 'Y' "
+ " WHERE SALE_ORDER = ? AND LINE_NO = ? "
+ " AND ITEM_CODE = ? "
+ " AND LOC_CODE = ? "
+ " AND LOT_NO = ? "
+ " AND LOT_SL = ? "
+ " AND QTY_ALLOC > 0";
pstmtUpd = conn.prepareStatement(updateSql);
pstmtUpd.setDouble(1, quantity);
pstmtUpd.setDouble(2, quantity);
pstmtUpd.setString(3, saleOrder);
pstmtUpd.setString(4, lineNoSord);
pstmtUpd.setString(5, itemCode);
pstmtUpd.setString(6, stagingLoc);
pstmtUpd.setString(7, lotNo);
pstmtUpd.setString(8, lotSl);
updCnt = pstmtUpd.executeUpdate();
if(pstmtUpd !=null)
{
System.out.println("Inside the Query the Exp level["+expLev+"]");
expLev = rs1.getString( "EXP_LEV" );
System.out.println("Inside the Query the Exp level["+expLev+"]");
if (expLev == null || expLev.trim().length() == 0)
{
expLev = dExpLev;
}
if (expLev == null || expLev.trim().length() == 0)
{
expLev = " ";
}
itemCodeOrd = rs1.getString( "ITEM_CODE__ORD" );
itemRef = rs1.getString( "ITEM_REF" );
unit = rs1.getString( "UNIT" );
status = rs1.getString( "STATUS" );
itemGrade = rs1.getString( "ITEM_GRADE" );
allocMode = rs1.getString( "ALLOC_MODE" );
siteCode = rs1.getString( "SITE_CODE" );
siteCodeMfg = rs1.getString( "SITE_CODE__MFG" );
reasCode = rs1.getString( "REAS_CODE" );
unitStd = rs1.getString( "UNIT__STD" );
convQtyStduom = rs1.getDouble( "CONV__QTY_STDUOM" );
dateAlloc = rs1.getTimestamp("DATE_ALLOC");
expDate = rs1.getTimestamp("EXP_DATE");
mfgDate = rs1.getTimestamp("MFG_DATE");
qtyOrd = rs1.getDouble( "QUANTITY" );
sordAllocQty = rs1.getDouble( "QTY_ALLOC" );
pstmtUpd.close();
pstmtUpd=null;
}
else
System.out.println(" sordalloc If alrady exist Location Update Inside grater updCnt2nd [" + updCnt + "]");
}
else
{
System.out.println("--------insert record in SORDALLOC table--------------");
updateSql = "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, ITEM_GRADE, EXP_DATE, ALLOC_MODE, SITE_CODE, "
+ " CONV__QTY_STDUOM, UNIT__STD, QUANTITY__STDUOM, MFG_DATE, SITE_CODE__MFG, "
+ " REAS_CODE, WAVE_FLAG ) "
+ " VALUES (?, ?, ?, ?, "
+ " ?, ?, ? , ?, ?, ?, ?, "
+ " ?,?, ?, ?, ?, ?, ?, "
+ " ?, ?, ? , ?, ?, ?, ? ) ";
pstmtUpd = conn.prepareStatement(updateSql);
pstmtUpd.setString(1, saleOrder);
pstmtUpd.setString(2, lineNoSord);
pstmtUpd.setString(3, expLev);
pstmtUpd.setString(4, itemCodeOrd);
pstmtUpd.setString(5, itemCode);
pstmtUpd.setString(6, lotNo);
pstmtUpd.setString(7, lotSl);
pstmtUpd.setString(8, stagingLoc);
pstmtUpd.setString(9, itemRef);
pstmtUpd.setDouble(10, qtyOrd);
pstmtUpd.setString(11, unit);
pstmtUpd.setDouble(12, quantity);
pstmtUpd.setTimestamp(13, dateAlloc);
pstmtUpd.setString(14, status);
pstmtUpd.setString(15, itemGrade);
pstmtUpd.setTimestamp(16, expDate);
pstmtUpd.setString(17, allocMode);
pstmtUpd.setString(18, siteCode);
pstmtUpd.setDouble(19, convQtyStduom );
pstmtUpd.setString(20, unitStd);
pstmtUpd.setDouble(21, quantity * convQtyStduom);
pstmtUpd.setTimestamp(22, mfgDate );
pstmtUpd.setString(23, siteCodeMfg);
pstmtUpd.setString(24, reasCode);
pstmtUpd.setString(25, "Y");
updCnt = pstmtUpd.executeUpdate();
System.out.println(" INSERT in sordalloc updCnt [" + updCnt + "]");
if(pstmtUpd != null)
{
isError = true;
errorString = itmDBAccess.getErrorString("","RECNOTSORA","");
return errorString;
pstmtUpd.close();
pstmtUpd=null;
}
rs1.close();
rs1 = null;
pstmt1.close();
pstmt1 = null;
sSQL = "SELECT COUNT(*) AS COUNT FROM SORDALLOC WHERE "
+ " SALE_ORDER = ? AND LINE_NO = ? "
}
}
else
{
System.out.println("sordAllocQty in lesser.................");
pstmtSord = conn.prepareStatement(sSQL);
pstmtSord.setString(1, saleOrder);
pstmtSord.setString(2, lineNoSord);
pstmtSord.setString(3, itemCode);
pstmtSord.setString(4, stagingLoc);
pstmtSord.setString(5, lotNo);
pstmtSord.setString(6, lotSl);
rsSord = pstmtSord.executeQuery();
if(rsSord.next())
{
count = rsSord.getInt(1);
}
System.out.println("count SORDALLOC--->>"+count);
if(count > 0)
{
//updateSql = "UPDATE SORDALLOC SET QTY_ALLOC = QTY_ALLOC - ? " //LOC_CODE = ? ,LOT_SL = ? "
updateSql = "UPDATE SORDALLOC SET QTY_ALLOC = QTY_ALLOC - ?, WAVE_FLAG = 'Y' "
+ " WHERE SALE_ORDER = ? AND LINE_NO = ? "
+ " AND ITEM_CODE = ? "
+ " AND LOC_CODE = ? "
+ " AND LOT_NO = ? "
+ " AND LOT_SL = ? ";
int count = 0;
System.out.println("sordAllocQty---->>["+sordAllocQty+" quantity--->["+quantity+"]");
if(sordAllocQty > quantity)
+ " AND LOT_SL = ? "
+ " AND QTY_ALLOC > 0";
pstmtUpd = conn.prepareStatement(updateSql);
pstmtUpd.setDouble(1, quantity);
pstmtUpd.setString(2, saleOrder);
pstmtUpd.setString(3, lineNoSord);
pstmtUpd.setString(4, itemCode);
pstmtUpd.setString(5, locCode);
pstmtUpd.setString(6, lotNo);
pstmtUpd.setString(7, lotSl);
updCnt = pstmtUpd.executeUpdate();
System.out.println(" sordalloc If alrady exist Location Update updCnt1st [" + updCnt + "]");
if(pstmtUpd !=null)
{
System.out.println("sordAllocQty in greater.................");
updateSql = "UPDATE SORDALLOC SET QTY_ALLOC = QTY_ALLOC - ? ,QUANTITY__STDUOM = QUANTITY__STDUOM - ?, WAVE_FLAG = 'Y' "
pstmtUpd.close();
pstmtUpd=null;
}
//updateSql = "UPDATE SORDALLOC SET QTY_ALLOC = QTY_ALLOC + ? ,QUANTITY__STDUOM = QUANTITY__STDUOM + ?"
updateSql = "UPDATE SORDALLOC SET QTY_ALLOC = QTY_ALLOC + ? ,QUANTITY__STDUOM = QUANTITY__STDUOM + ?, WAVE_FLAG = 'Y' "
+ " WHERE SALE_ORDER = ? AND LINE_NO = ? "
+ " AND ITEM_CODE = ? "
+ " AND LOC_CODE = ? "
+ " AND LOT_NO = ? "
+ " AND LOT_SL = ? "
+ " AND QTY_ALLOC > 0";
pstmtUpd = conn.prepareStatement(updateSql);
pstmtUpd.setDouble(1, quantity);
//Changed by sumit on 10/09/13 setting
pstmtUpd.setDouble(2, quantity * convQtyStduom);
pstmtUpd.setString(3, saleOrder);
pstmtUpd.setString(4, lineNoSord);
pstmtUpd.setString(5, itemCode);
pstmtUpd.setString(6, locCode);
pstmtUpd.setString(7, lotNo);
pstmtUpd.setString(8, lotSl);
updCnt = pstmtUpd.executeUpdate();
if(pstmtUpd !=null)
{
pstmtUpd.close();
pstmtUpd=null;
}
System.out.println(" sordalloc updated updCnt [" + updCnt + "]");
if (expLev == null || expLev.trim().length() == 0)
{
System.out.println("Check1l["+expLev+"]");
expLev = dExpLev;
}
System.out.println("Finally the Exp level["+expLev+"]");
pstmtSord = conn.prepareStatement(sSQL);
pstmtSord.setString(1, saleOrder);
pstmtSord.setString(2, lineNoSord);
pstmtSord.setString(3, itemCode);
pstmtSord.setString(4, stagingLoc);
pstmtSord.setString(5, lotNo);
pstmtSord.setString(6, lotSl);
rsSord = pstmtSord.executeQuery();
if(rsSord.next())
{
count = rsSord.getInt(1);
}
System.out.println("count SORDALLOC@@------>>["+count+"]");
if(count > 0)
{
System.out.println(" sordalloc If alrady exist Location Update Inside grater updCnt1st [" + updCnt + "]");
//updateSql = "UPDATE SORDALLOC SET QTY_ALLOC = QTY_ALLOC + ? ,QUANTITY__STDUOM = QUANTITY__STDUOM + ?"
updateSql = "UPDATE SORDALLOC SET QTY_ALLOC = QTY_ALLOC + ? ,QUANTITY__STDUOM = QUANTITY__STDUOM + ?, WAVE_FLAG = 'Y' "
+ " WHERE SALE_ORDER = ? AND LINE_NO = ? "
+ " AND ITEM_CODE = ? "
+ " AND LOC_CODE = ? "
+ " AND LOT_NO = ? "
+ " AND LOT_SL = ? "
+ " AND QTY_ALLOC > 0";
pstmtUpd = conn.prepareStatement(updateSql);
pstmtUpd.setDouble(1, quantity);
pstmtUpd.setDouble(2, quantity);
pstmtUpd.setString(3, saleOrder);
pstmtUpd.setString(4, lineNoSord);
pstmtUpd.setString(5, itemCode);
pstmtUpd.setString(6, stagingLoc);
pstmtUpd.setString(7, lotNo);
pstmtUpd.setString(8, lotSl);
updCnt = pstmtUpd.executeUpdate();
if(pstmtUpd !=null)
{
pstmtUpd.close();
pstmtUpd=null;
}
System.out.println(" sordalloc If alrady exist Location Update Inside grater updCnt2nd [" + updCnt + "]");
}
else
{
System.out.println("--------insert record in SORDALLOC table--------------");
updateSql = "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, ITEM_GRADE, EXP_DATE, ALLOC_MODE, SITE_CODE, "
+ " CONV__QTY_STDUOM, UNIT__STD, QUANTITY__STDUOM, MFG_DATE, SITE_CODE__MFG, "
+ " REAS_CODE, WAVE_FLAG ) "
+ " VALUES (?, ?, ?, ?, "
+ " ?, ?, ? , ?, ?, ?, ?, "
+ " ?,?, ?, ?, ?, ?, ?, "
+ " ?, ?, ? , ?, ?, ?, ? ) ";
pstmtUpd = conn.prepareStatement(updateSql);
pstmtUpd.setString(1, saleOrder);
pstmtUpd.setString(2, lineNoSord);
pstmtUpd.setString(3, expLev);
pstmtUpd.setString(4, itemCodeOrd);
pstmtUpd.setString(5, itemCode);
pstmtUpd.setString(6, lotNo);
pstmtUpd.setString(7, lotSl);
pstmtUpd.setString(8, stagingLoc);
pstmtUpd.setString(9, itemRef);
pstmtUpd.setDouble(10, qtyOrd);
pstmtUpd.setString(11, unit);
pstmtUpd.setDouble(12, quantity);
pstmtUpd.setTimestamp(13, dateAlloc);
pstmtUpd.setString(14, status);
pstmtUpd.setString(15, itemGrade);
pstmtUpd.setTimestamp(16, expDate);
pstmtUpd.setString(17, allocMode);
pstmtUpd.setString(18, siteCode);
pstmtUpd.setDouble(19, convQtyStduom );
pstmtUpd.setString(20, unitStd);
pstmtUpd.setDouble(21, quantity * convQtyStduom);
pstmtUpd.setTimestamp(22, mfgDate );
pstmtUpd.setString(23, siteCodeMfg);
pstmtUpd.setString(24, reasCode);
pstmtUpd.setString(25, "Y");
updCnt = pstmtUpd.executeUpdate();
System.out.println(" INSERT in sordalloc updCnt [" + updCnt + "]");
if(pstmtUpd != null)
{
pstmtUpd.close();
pstmtUpd=null;
}
}
}
else
{
System.out.println("sordAllocQty in lesser.................");
pstmtSord = conn.prepareStatement(sSQL);
pstmtSord.setString(1, saleOrder);
pstmtSord.setString(2, lineNoSord);
pstmtSord.setString(3, itemCode);
pstmtSord.setString(4, stagingLoc);
pstmtSord.setString(5, lotNo);
pstmtSord.setString(6, lotSl);
rsSord = pstmtSord.executeQuery();
if(rsSord.next())
{
count = rsSord.getInt(1);
}
System.out.println("count SORDALLOC--->>"+count);
if(count > 0)
{
//updateSql = "UPDATE SORDALLOC SET QTY_ALLOC = QTY_ALLOC - ? " //LOC_CODE = ? ,LOT_SL = ? "
updateSql = "UPDATE SORDALLOC SET QTY_ALLOC = QTY_ALLOC - ?, WAVE_FLAG = 'Y' "
+ " WHERE SALE_ORDER = ? AND LINE_NO = ? "
+ " AND ITEM_CODE = ? "
+ " AND LOC_CODE = ? "
+ " AND LOT_NO = ? "
+ " AND LOT_SL = ? "
+ " AND QTY_ALLOC > 0";
pstmtUpd = conn.prepareStatement(updateSql);
pstmtUpd.setDouble(1, quantity);
pstmtUpd.setString(2, saleOrder);
pstmtUpd.setString(3, lineNoSord);
pstmtUpd.setString(4, itemCode);
pstmtUpd.setString(5, locCode);
pstmtUpd.setString(6, lotNo);
pstmtUpd.setString(7, lotSl);
updCnt = pstmtUpd.executeUpdate();
System.out.println(" sordalloc If alrady exist Location Update updCnt1st [" + updCnt + "]");
if(pstmtUpd !=null)
{
pstmtUpd.close();
pstmtUpd=null;
}
//updateSql = "UPDATE SORDALLOC SET QTY_ALLOC = QTY_ALLOC + ? ,QUANTITY__STDUOM = QUANTITY__STDUOM + ?"
updateSql = "UPDATE SORDALLOC SET QTY_ALLOC = QTY_ALLOC + ? ,QUANTITY__STDUOM = QUANTITY__STDUOM + ?, WAVE_FLAG = 'Y' "
+ " WHERE SALE_ORDER = ? AND LINE_NO = ? "
+ " AND ITEM_CODE = ? "
+ " AND LOC_CODE = ? "
+ " AND LOT_NO = ? "
+ " AND LOT_SL = ? "
+ " AND QTY_ALLOC > 0";
pstmtUpd = conn.prepareStatement(updateSql);
pstmtUpd.setDouble(1, quantity);
pstmtUpd.setDouble(2, quantity);
pstmtUpd.setString(3, saleOrder);
pstmtUpd.setString(4, lineNoSord);
pstmtUpd.setString(5, itemCode);
pstmtUpd.setString(6, stagingLoc);
pstmtUpd.setString(7, lotNo);
pstmtUpd.setString(8, lotSl);
updCnt = pstmtUpd.executeUpdate();
System.out.println(" sordalloc If alrady exist Location Update updCnt2nd [" + updCnt + "]");
if(pstmtUpd != null)
{
pstmtUpd.close();
pstmtUpd=null;
}
}
else
{
//updateSql = "UPDATE SORDALLOC SET LOC_CODE = ? "
updateSql = "UPDATE SORDALLOC SET LOC_CODE = ?, WAVE_FLAG = 'Y' "
+ " WHERE SALE_ORDER = ? AND LINE_NO = ? "
+ " AND ITEM_CODE = ? "
+ " AND LOC_CODE = ? "
+ " AND LOT_NO = ? "
+ " AND LOT_SL = ? "
+ " AND QTY_ALLOC > 0";
pstmtUpd = conn.prepareStatement(updateSql);
pstmtUpd.setString(1, stagingLoc);
pstmtUpd.setString(2, saleOrder);
pstmtUpd.setString(3, lineNoSord);
pstmtUpd.setString(4, itemCode);
pstmtUpd.setString(5, locCode);
pstmtUpd.setString(6, lotNo);
pstmtUpd.setString(7, lotSl);
updCnt = pstmtUpd.executeUpdate();
if(pstmtUpd !=null)
{
pstmtUpd.close();
pstmtUpd=null;
}
}
System.out.println(" sordalloc Update updCnt [" + updCnt + "]");
}
if(rsSord != null)
{
rsSord.close();
rsSord=null;
}
if(pstmtSord != null)
{
pstmtSord.close();
pstmtSord=null;
}
String updatePickOrdSql = "UPDATE PICK_ORD_DET SET STATUS = ? "
+ " WHERE PICK_ORDER = ? AND LINE_NO = ? ";
pstmtUpdPickOrdDet = conn.prepareStatement(updatePickOrdSql);
pstmtUpdPickOrdDet.setString(1, "C");
pstmtUpdPickOrdDet.setString(2, replOrder);
pstmtUpdPickOrdDet.setInt(3, lineNoOrd);
int updCntPickOrdDet = pstmtUpdPickOrdDet.executeUpdate();
if(updCntPickOrdDet > 0)
{
isUpdatehdr = updatePickOrderHeader(replOrder,conn);
}
if(pstmtUpdPickOrdDet != null)
{
pstmtUpdPickOrdDet.close();
pstmtUpdPickOrdDet=null;
}
updatePickOrdSql = "UPDATE MULTI_PICK_ISS_DET SET LOC_CODE = ? "
+ " WHERE TRAN_ID = ? AND LINE_NO = ? ";
pstmtUpdPickOrdDet = conn.prepareStatement(updatePickOrdSql);
pstmtUpdPickOrdDet.setString(1, stagingLoc);
pstmtUpdPickOrdDet.setString(2, tranId);
pstmtUpdPickOrdDet.setInt(3, lineNo);
updCntPickOrdDet = pstmtUpdPickOrdDet.executeUpdate();
if(updCntPickOrdDet > 0)
pstmtUpd = conn.prepareStatement(updateSql);
pstmtUpd.setDouble(1, quantity);
pstmtUpd.setDouble(2, quantity);
pstmtUpd.setString(3, saleOrder);
pstmtUpd.setString(4, lineNoSord);
pstmtUpd.setString(5, itemCode);
pstmtUpd.setString(6, stagingLoc);
pstmtUpd.setString(7, lotNo);
pstmtUpd.setString(8, lotSl);
updCnt = pstmtUpd.executeUpdate();
System.out.println(" sordalloc If alrady exist Location Update updCnt2nd [" + updCnt + "]");
if(pstmtUpd != null)
{
isUpdatehdr = updatePickOrderHeader(replOrder,conn);
pstmtUpd.close();
pstmtUpd=null;
}
if(pstmtUpdPickOrdDet != null)
}
else
{
//updateSql = "UPDATE SORDALLOC SET LOC_CODE = ? "
updateSql = "UPDATE SORDALLOC SET LOC_CODE = ?, WAVE_FLAG = 'Y' "
+ " WHERE SALE_ORDER = ? AND LINE_NO = ? "
+ " AND ITEM_CODE = ? "
+ " AND LOC_CODE = ? "
+ " AND LOT_NO = ? "
+ " AND LOT_SL = ? "
+ " AND QTY_ALLOC > 0";
pstmtUpd = conn.prepareStatement(updateSql);
pstmtUpd.setString(1, stagingLoc);
pstmtUpd.setString(2, saleOrder);
pstmtUpd.setString(3, lineNoSord);
pstmtUpd.setString(4, itemCode);
pstmtUpd.setString(5, locCode);
pstmtUpd.setString(6, lotNo);
pstmtUpd.setString(7, lotSl);
updCnt = pstmtUpd.executeUpdate();
if(pstmtUpd !=null)
{
pstmtUpdPickOrdDet.close();
pstmtUpdPickOrdDet=null;
pstmtUpd.close();
pstmtUpd=null;
}
String str = insertPickIssHdrDet(dataMap, conn);
System.out.println("Return from insertPickIssHdrDet------->>["+str+"]");
str = insertPackHdrDet(dataMap,conn);
System.out.println("Return from insertPackHdrDet------->>["+str+"]");
if(isUpdatehdr)
{
sql = "SELECT REF_SER,PTCN FROM WAVE_TASK_DET WHERE REF_ID = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,replOrder);
rs = pstmt.executeQuery();
if( rs.next() )
{
refSer = rs.getString("ref_ser");
refSer = refSer == null?"":refSer;
ptcn = rs.getString("ptcn");
ptcn = ptcn == null?"":ptcn;
}
System.out.println(" ref_ser ["+refSer+"]");
rs.close();rs = null;
pstmt.close();pstmt = null;
if(!("A".equalsIgnoreCase(pickType)) && !"P-PICK".equalsIgnoreCase(refSer) && !"A-PICK".equalsIgnoreCase(refSer) )
{
//update wave_status of wave_task_det, same time of updating status 'Y'
updateSql = "UPDATE WAVE_TASK_DET SET STATUS = 'Y', WAVE_STATUS = 'V' WHERE REF_ID = ? ";
pstmt = conn.prepareStatement(updateSql);
pstmt.setString(1, replOrder);
updCnt = pstmt.executeUpdate();
if( updCnt > 0 )
{
System.out.println( updCnt + " rows updated successfully" );
}
pstmt.close();pstmt = null;
}
sql = " SELECT * FROM PICK_ORD_HDR WHERE PICK_ORDER = ? AND PICK_TYPE = 'M' ";
pstmt1 = conn.prepareStatement(sql);
pstmt1.setString(1, replOrder);
rs1 = pstmt1.executeQuery();
if( rs1.next())
{
updateSql = "UPDATE WAVE_TASK_DET SET WAVE_STATUS = 'C' WHERE REF_SER = 'M-PACK'" +
" AND WAVE_ID = ? AND SALE_ORDER = ? ";
pstmt2 = conn.prepareStatement(updateSql);
pstmt2.setString(1, rs1.getString("WAVE_ID"));
pstmt2.setString(2, rs1.getString("SALE_ORDER"));
updCnt = pstmt2.executeUpdate();
if( updCnt > 0 )
{
System.out.println( updCnt + " M-PACK rows updated successfully" );
}
pstmt2.close();pstmt2 = null;
}
rs1.close(); rs1 = null;
pstmt1.close(); pstmt1 = null;
updCnt= 0;
// Checking whether all task are done for particular wave_id and sale order
updCnt = waveStatusUpdate(replOrder, conn);
if( updCnt > 0)
{
System.out.println( updCnt + " row of wave_status updated successfully" );
}
sql = "UPDATE SORDER SET SHIP_STATUS = ? WHERE SALE_ORDER = ?";
pstmtSord = conn.prepareStatement(sql);
int updateSorder = 0;
pstmtSord.setString(1, "P");
pstmtSord.setString(2, saleOrder);
updateSorder = pstmtSord.executeUpdate();
if(updateSorder > 0)
{
System.out.println(" SORDER UPDATE COUNT ["+updateSorder+"]");
}
pstmtSord.clearParameters();
if(pstmtSord != null)
{
pstmtSord.close();
pstmtSord = null;
}
System.out.println("Header updated successfully");
ConsolidatToDoc conToDoc = new ConsolidatToDoc();
retString = conToDoc.process(ptcn, conn,xtraParams);
if (retString != null && retString.trim().length() > 0 )
{
isError = true;
return retString;
}
System.out.println("ret string :"+retString);
}
System.out.println(" sordalloc Update updCnt [" + updCnt + "]");
}
if(rsSord != null)
{
rsSord.close();
rsSord=null;
}
if(pstmtSord != null)
{
pstmtSord.close();
pstmtSord=null;
}
String updatePickOrdSql = "UPDATE PICK_ORD_DET SET STATUS = ? "
+ " WHERE PICK_ORDER = ? AND LINE_NO = ? ";
pstmtUpdPickOrdDet = conn.prepareStatement(updatePickOrdSql);
pstmtUpdPickOrdDet.setString(1, "C");
pstmtUpdPickOrdDet.setString(2, replOrder);
pstmtUpdPickOrdDet.setInt(3, lineNoOrd);
int updCntPickOrdDet = pstmtUpdPickOrdDet.executeUpdate();
if(updCntPickOrdDet > 0)
{
isUpdatehdr = updatePickOrderHeader(replOrder,conn);
}
if(pstmtUpdPickOrdDet != null)
{
pstmtUpdPickOrdDet.close();
pstmtUpdPickOrdDet=null;
}
updatePickOrdSql = "UPDATE MULTI_PICK_ISS_DET SET LOC_CODE = ? "
+ " WHERE TRAN_ID = ? AND LINE_NO = ? ";
pstmtUpdPickOrdDet = conn.prepareStatement(updatePickOrdSql);
pstmtUpdPickOrdDet.setString(1, stagingLoc);
pstmtUpdPickOrdDet.setString(2, tranId);
pstmtUpdPickOrdDet.setInt(3, lineNo);
updCntPickOrdDet = pstmtUpdPickOrdDet.executeUpdate();
if(updCntPickOrdDet > 0)
{
isUpdatehdr = updatePickOrderHeader(replOrder,conn);
}
if(pstmtUpdPickOrdDet != null)
{
pstmtUpdPickOrdDet.close();
pstmtUpdPickOrdDet=null;
}
String str = insertPickIssHdrDet(dataMap, conn);
System.out.println("Return from insertPickIssHdrDet------->>["+str+"]");
str = insertPackHdrDet(dataMap,conn);
System.out.println("Return from insertPackHdrDet------->>["+str+"]");
if(isUpdatehdr)
{
sql = "SELECT REF_SER,PTCN FROM WAVE_TASK_DET WHERE REF_ID = ?";
pstmt1 = conn.prepareStatement(sql);
pstmt1.setString(1,replOrder);
rs1 = pstmt.executeQuery();
if( rs1.next() )
{
refSer = rs1.getString("ref_ser");
refSer = refSer == null?"":refSer;
ptcn = rs1.getString("ptcn");
ptcn = ptcn == null?"":ptcn;
}
System.out.println(" ref_ser ["+refSer+"]");
rs1.close();rs1 = null;
pstmt1.close();pstmt1 = null;
if(!("A".equalsIgnoreCase(pickType)) && !"P-PICK".equalsIgnoreCase(refSer) && !"A-PICK".equalsIgnoreCase(refSer) )
{
//update wave_status of wave_task_det, same time of updating status 'Y'
updateSql = "UPDATE WAVE_TASK_DET SET STATUS = 'Y', WAVE_STATUS = 'V' WHERE REF_ID = ? ";
pstmt = conn.prepareStatement(updateSql);
pstmt.setString(1, replOrder);
updCnt = pstmt.executeUpdate();
if( updCnt > 0 )
{
System.out.println( updCnt + " rows updated successfully" );
}
pstmt.close();pstmt = null;
}
sql = " SELECT * FROM PICK_ORD_HDR WHERE PICK_ORDER = ? AND PICK_TYPE = 'M' ";
pstmt1 = conn.prepareStatement(sql);
pstmt1.setString(1, replOrder);
rs1 = pstmt1.executeQuery();
if( rs1.next())
{
updateSql = "UPDATE WAVE_TASK_DET SET WAVE_STATUS = 'C' WHERE REF_SER = 'M-PACK'" +
" AND WAVE_ID = ? AND SALE_ORDER = ? ";
pstmt2 = conn.prepareStatement(updateSql);
pstmt2.setString(1, rs1.getString("WAVE_ID"));
pstmt2.setString(2, rs1.getString("SALE_ORDER"));
updCnt = pstmt2.executeUpdate();
if( updCnt > 0 )
{
System.out.println( updCnt + " M-PACK rows updated successfully" );
}
pstmt2.close();pstmt2 = null;
}
rs1.close(); rs1 = null;
pstmt1.close(); pstmt1 = null;
updCnt= 0;
// Checking whether all task are done for particular wave_id and sale order
updCnt = waveStatusUpdate(replOrder, conn);
if( updCnt > 0)
{
System.out.println( updCnt + " row of wave_status updated successfully" );
}
sql = "UPDATE SORDER SET SHIP_STATUS = ? WHERE SALE_ORDER = ?";
pstmtSord = conn.prepareStatement(sql);
int updateSorder = 0;
pstmtSord.setString(1, "P");
pstmtSord.setString(2, saleOrder);
updateSorder = pstmtSord.executeUpdate();
if(updateSorder > 0)
{
System.out.println(" SORDER UPDATE COUNT ["+updateSorder+"]");
}
pstmtSord.clearParameters();
if(pstmtSord != null)
{
pstmtSord.close();
pstmtSord = null;
}
System.out.println("Header updated successfully");
/*ConsolidatToDoc conToDoc = new ConsolidatToDoc();
retString = conToDoc.process(ptcn, conn,xtraParams);
if (retString != null && retString.trim().length() > 0 )
{
isError = true;
return retString;
}*/
System.out.println("ret string :"+retString);
}
} //end while
if(rs != null)
{
rs.close();
......@@ -837,13 +834,13 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
pstmtStock.close();
pstmtStock = null;
}
if (errorString != null && errorString.trim().length() > 0 )
{
isError = true;
return errorString;
}
updateSql = "UPDATE MULTI_PICK_ISS SET CONFIRMED = 'Y', CONF_DATE = ?, EMP_CODE__USER = ?"
+ " WHERE TRAN_ID = ? ";
pstmt = conn.prepareStatement(updateSql);
......@@ -859,12 +856,12 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
}
pstmt.close();
pstmt = null;
}//end else of confirmed cndition
}
catch(Exception e)
{
......@@ -872,9 +869,24 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
e.printStackTrace();
throw new Exception (e);
}
finally
{
if(isError)
{
conn.rollback();
}
else
{
conn.commit();
}
if(conn != null)
{
conn.close();
conn = null;
}
}
return errorString;
}
private String insertPickIssHdrDet(HashMap<String,String>issueDataMap,Connection conn) throws Exception
{
......@@ -1002,6 +1014,7 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
}
catch(Exception e)
{
isError = true;
throw e;
}
return "Error";
......@@ -1164,6 +1177,7 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
}
catch(Exception e)
{
isError = true;
throw e;
}
if(successCnt > 1)
......@@ -1311,6 +1325,7 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
}
catch(Exception e)
{
isError = true;
e.printStackTrace();
throw new ITMException(e);
}
......@@ -1465,6 +1480,7 @@ public class MultiplePtcnWizConf extends ActionHandlerEJB implements MultiplePtc
}
catch(Exception e)
{
isError = true;
e.printStackTrace();
throw new ITMException(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