Skip to content

B
business-java
Commit 1c6d4ffd authored by rbhogale's avatar rbhogale
Browse files
Options

Changed by rohan on 12-02-13 for repanishment wave cancle 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@92676 ce508802-f39f-4f6c-b175-0d175dae99d5
parent a099e968
Show whitespace changes
Inline Side-by-side
Showing with 280 additions and 48 deletions
webitm-wms/ibase/webitm/ejb/wms/WaveCancelEJB.java
View file @ 1c6d4ffd
...@@ -344,9 +344,12 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -344,9 +344,12 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
{ {
replOrder = checkNull( rsPick.getString("REPL_ORDER") ); replOrder = checkNull( rsPick.getString("REPL_ORDER") );
replLineNo = checkNull( rsPick.getString("LINE_NO__REPL")); replLineNo = checkNull( rsPick.getString("LINE_NO__REPL"));
//Changed by Rohan on 07-02-13 to get original repanishment code.start
/*
//Changed by Rohan on 22-01-13 to cancle independent Repanishment.start //Changed by Rohan on 22-01-13 to cancle independent Repanishment.start
replOrdOrg = replOrder; replOrdOrg = replOrder;
replLineOrg = replLineNo; replLineOrg = replLineNo;
*/
//Changed by Rohan on 22-01-13 to cancle independent Repanishment.end //Changed by Rohan on 22-01-13 to cancle independent Repanishment.end
pickOrder = checkNull( rsPick.getString("PICK_ORDER") ); pickOrder = checkNull( rsPick.getString("PICK_ORDER") );
...@@ -357,6 +360,11 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -357,6 +360,11 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
replOrder = checkNull( rsPick.getString("REPL_ORDER") ); replOrder = checkNull( rsPick.getString("REPL_ORDER") );
replLineNo = checkNull( rsPick.getString("LINE_NO") ); replLineNo = checkNull( rsPick.getString("LINE_NO") );
} }
//Changed by Rohan on 07-02-13 to get original repanishment code.start
replOrdOrg = replOrder;
replLineOrg = replLineNo;
//Changed by Rohan on 07-02-13 to get original repanishment code.end
System.out.println("Original Repl Order"+replOrdOrg+"Original Repl line no"+replLineOrg); System.out.println("Original Repl Order"+replOrdOrg+"Original Repl line no"+replLineOrg);
System.out.println("LOCCode***"+locCode); System.out.println("LOCCode***"+locCode);
qtyStduom = quantity; qtyStduom = quantity;
...@@ -1122,8 +1130,13 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -1122,8 +1130,13 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
String sqlAct =""; String sqlAct ="";
String sqlDep =""; String sqlDep ="";
String replType = ""; String replType = "";
//Changed by Rohan on 07-02-13 for define variables.strat
String replOrdDep = "";
String replOrdDepLine = "";
int cnt = 0; int cnt = 0;
String sqlDep1 = "";
//Changed by Rohan on 11-02-13 for define variables
double shipperSize = 0.0;
PreparedStatement pstmt2 = null; PreparedStatement pstmt2 = null;
ResultSet rs2 = null; ResultSet rs2 = null;
...@@ -1146,7 +1159,7 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -1146,7 +1159,7 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
//Changed by Rohan on 22-01-13 to cancle independent Repanishment.start //Changed by Rohan on 22-01-13 to cancle independent Repanishment.start
//to check case to active Repanishment.start //to check case to active Repanishment.start
sqlAct = "SELECT ORDER_TYPE FROM REPL_ORD_HDR WHERE REPL_ORDER = ?"; sqlAct = "SELECT ORDER_TYPE FROM REPL_ORD_HDR WHERE REPL_ORDER = ? ";
pstmt2 = conn.prepareStatement(sqlAct); pstmt2 = conn.prepareStatement(sqlAct);
pstmt2.setString(1, replOrdOrg); pstmt2.setString(1, replOrdOrg);
rs2 = pstmt2.executeQuery(); rs2 = pstmt2.executeQuery();
...@@ -1164,14 +1177,16 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -1164,14 +1177,16 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
rs2.close(); rs2.close();
rs2 = null; rs2 = null;
} }
/*
System.out.println("replType&*&*"+replType); System.out.println("replType&*&*"+replType);
if("Q".equalsIgnoreCase(replType) || "J".equalsIgnoreCase(replType) || "C".equalsIgnoreCase(replType) || "K".equalsIgnoreCase(replType) || "M".equalsIgnoreCase(replType)) //if("Q".equalsIgnoreCase(replType) || "J".equalsIgnoreCase(replType) || "C".equalsIgnoreCase(replType) || "K".equalsIgnoreCase(replType) || "M".equalsIgnoreCase(replType))
if("Q".equalsIgnoreCase(replType) || "C".equalsIgnoreCase(replType) || "K".equalsIgnoreCase(replType) || "M".equalsIgnoreCase(replType))
{ {
if("Q".equalsIgnoreCase(replType) ) if("Q".equalsIgnoreCase(replType) )
{ {
sqlDep = "SELECT PICK_ORDER FROM REPL_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO = ?"; sqlDep = "SELECT PICK_ORDER FROM REPL_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO = ?";
} }
else if("J".equalsIgnoreCase(replType) || "C".equalsIgnoreCase(replType) || "M".equalsIgnoreCase(replType) || "K".equalsIgnoreCase(replType)) else if("C".equalsIgnoreCase(replType) || "M".equalsIgnoreCase(replType) || "K".equalsIgnoreCase(replType))
{ {
sqlDep = "SELECT REPL_ORDER FROM REPL_ORD_DET WHERE PICK_ORDER = ? AND LINE_NO__PICK = ? "; sqlDep = "SELECT REPL_ORDER FROM REPL_ORD_DET WHERE PICK_ORDER = ? AND LINE_NO__PICK = ? ";
} }
...@@ -1225,42 +1240,145 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -1225,42 +1240,145 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
rs1 = null; rs1 = null;
} }
} }
*/
//to check case to active Repanishment.start //to check case to active Repanishment.start
//if(!"Q".equalsIgnoreCase(replType) && "J".equalsIgnoreCase(replType)) //if(!"Q".equalsIgnoreCase(replType) && "J".equalsIgnoreCase(replType))
//else
//{
System.out.println("repl type***"+replType);
//to check PICK wave id and reference Repanishment WAVE_ID different.start
//sqlWave = "SELECT WAVE_ID FROM WAVE_TASK_DET WHERE REF_ID = ? ";
sqlWave = " SELECT D.WAVE_ID FROM WAVE_TASK_DET D,WAVE_TASK H WHERE D.REF_ID = ? "
+" AND D.WAVE_ID = H.WAVE_ID AND CASE WHEN CANCEL IS NULL THEN 'N' ELSE CANCEL END <> 'Y' ";
pstmt1 = conn.prepareStatement(sqlWave);
pstmt1.setString(1,replOrdOrg);
rs1 = pstmt1.executeQuery();
while(rs1.next())
{
waveIDCmp = rs1.getString("WAVE_ID");
System.out.println("waveIDCmp1111"+waveIDCmp+"Wave ID111"+waveID);
if(!waveIDCmp.trim().equalsIgnoreCase(waveID.trim()) && !"".equalsIgnoreCase(waveIDCmp))
{
isDepRepl = true;
break;
}
}
//to check PICK wave id and reference Repanishment WAVE_ID different.end
if(!isDepRepl)
{
System.out.println("@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@");
/*
if("Q".equalsIgnoreCase(replType))
{
sqlDep = "SELECT PICK_ORDER,LINE_NO__PICK FROM REPL_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO = ?";
}
else else
{ {
sqlDep = "SELECT REPL_ORDER,LINE_NO FROM REPL_ORD_DET WHERE PICK_ORDER = ? AND LINE_NO__PICK = ? ";
}
*/
sqlDep = "SELECT REPL_ORDER,LINE_NO FROM REPL_ORD_DET WHERE PICK_ORDER = ? AND LINE_NO__PICK = ? "
+" AND CASE WHEN CANCEL_MODE IS NULL THEN 'N' ELSE CANCEL_MODE END <> 'Y' ";
if(!"Q".equalsIgnoreCase(replType))
{
System.out.println("NOT QQQQQ");
//if dso-pnd,pnd-caspk repl dependent two pick in two wave IDS
sqlDep1 = "SELECT PICK_ORDER,LINE_NO FROM PICK_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO__REPL = ? AND PICK_ORDER <> ? ";
}
pstmt2 = conn.prepareStatement(sqlDep);
pstmt2.setString(1, replOrdOrg);
pstmt2.setString(2, replLineOrg);
/*if(!"Q".equalsIgnoreCase(replType) && !"J".equalsIgnoreCase(replType) && !"K".equalsIgnoreCase(replType) && !"I".equalsIgnoreCase(replType) )
{
pstmt2.setString(3, pickOrder);
}*/
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
//ordRepl = rs2.getString(1);
replOrdDep = checkNull(rs2.getString("REPL_ORDER"));
replOrdDepLine = checkNull(rs2.getString("LINE_NO"));
System.out.println("replOrdDep"+replOrdDep+"replOrdDepLine"+replOrdDepLine);
}
if(pstmt2 != null)
{
pstmt2.close();
pstmt2 = null;
}
if(rs2 != null)
{
rs2.close();
rs2 = null;
}
if("".equalsIgnoreCase(replOrdDep) && !"Q".equalsIgnoreCase(replType))
{
System.out.println("111111111111111111111111111111111");
pstmt2 = conn.prepareStatement(sqlDep1);
pstmt2.setString(1, replOrdOrg);
pstmt2.setString(2, replLineOrg);
pstmt2.setString(3, pickOrder);
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
//ordRepl = rs2.getString(1);
replOrdDep = checkNull(rs2.getString("PICK_ORDER"));
replOrdDepLine = checkNull(rs2.getString("LINE_NO"));
}
}
/*
sqlPick = "SELECT PICK_ORDER FROM PICK_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO__REPL = ? AND PICK_ORDER <> ?"; sqlPick = "SELECT PICK_ORDER FROM PICK_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO__REPL = ? AND PICK_ORDER <> ?";
pstmt = conn.prepareStatement(sqlPick); pstmt = conn.prepareStatement(sqlPick);
if(!"".equalsIgnoreCase(replOrdDep))
{
pstmt.setString(1, replOrdDep);
pstmt.setString(2, replOrdDepLine);
}
else
{
pstmt.setString(1, replOrdOrg); pstmt.setString(1, replOrdOrg);
pstmt.setString(2, replLineOrg); pstmt.setString(2, replLineOrg);
}
pstmt.setString(3, pickOrder); pstmt.setString(3, pickOrder);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
while(rs.next()) while(rs.next())
{ {
sqlWave = "SELECT WAVE_ID FROM WAVE_TASK_DET WHERE REF_ID = ?"; //sqlWave = "SELECT WAVE_ID FROM WAVE_TASK_DET WHERE REF_ID = ?";
//sqlWave = "SELECT H.WAVE_ID FROM WAVE_TASK_DET D,WAVE_TASK H " //sqlWave = "SELECT H.WAVE_ID FROM WAVE_TASK_DET D,WAVE_TASK H "
// + " WHERE D.REF_ID = ? AND D.WAVE_ID = H.WAVE_ID AND H.CANCEL <> 'Y'"; // + " WHERE D.REF_ID = ? AND D.WAVE_ID = H.WAVE_ID AND H.CANCEL <> 'Y'";
pstmt1 = conn.prepareStatement(sqlWave); //pstmt1 = conn.prepareStatement(sqlWave);
pstmt1.setString(1, rs.getString("PICK_ORDER")); */
System.out.println("PICK ORDRDRD====>"+ rs.getString("PICK_ORDER")); pstmt1.clearParameters();
waveIDCmp = "";
if(!"".equalsIgnoreCase(replOrdDep) && replOrdDep.trim().length() > 0)
{
pstmt1.setString(1, replOrdDep);
System.out.println("replOrdDep ORDRDRD====>"+ replOrdDep);
rs1 = pstmt1.executeQuery(); rs1 = pstmt1.executeQuery();
if(rs1.next()) while(rs1.next())
{ {
waveIDCmp = rs1.getString("WAVE_ID"); waveIDCmp = rs1.getString("WAVE_ID");
System.out.println("waveIDCmp"+waveIDCmp+"Wave ID"+waveID); System.out.println("waveIDCmp"+waveIDCmp+"Wave ID"+waveID);
}
System.out.println("waveIDCmp$$$$"+waveIDCmp);
if(!waveIDCmp.trim().equalsIgnoreCase(waveID.trim()) && !"".equalsIgnoreCase(waveIDCmp)) if(!waveIDCmp.trim().equalsIgnoreCase(waveID.trim()) && !"".equalsIgnoreCase(waveIDCmp))
{ {
System.out.println("NOT EQUALSS"); System.out.println("NOT EQUALSS");
isDepRepl = true; isDepRepl = true;
break; break;
} }
} }
} }
if(pstmt != null) /*if(pstmt != null)
{ {
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
...@@ -1274,16 +1392,17 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -1274,16 +1392,17 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
{ {
rs.close(); rs.close();
rs = null; rs = null;
} }*/
if(rs1 != null) if(rs1 != null)
{ {
rs1.close(); rs1.close();
rs1 = null; rs1 = null;
} }
}
if(isDepRepl) if(isDepRepl)
{ {
//Changed by Rohan on 22-01-13 to cancle independent Repanishment.end //Changed by Rohan on 22-01-13 to cancle independent Repanishment.end
System.out.println("#############################################");
if(confirm) if(confirm)
{ {
//if(!"C".equalsIgnoreCase(orderType)) //if(!"C".equalsIgnoreCase(orderType))
...@@ -1317,10 +1436,17 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -1317,10 +1436,17 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
replOrdChk = ""; replOrdChk = "";
replLineChk = ""; replLineChk = "";
//Changed by Rohan on 11-02-13 for reduce one case from actual qty
/*
getActualQty ="SELECT D.ACTUAL_QTY,L.INV_STAT,D.PICK_ORDER,D.LINE_NO__PICK FROM REPL_ORD_DET D,LOCATION L " getActualQty ="SELECT D.ACTUAL_QTY,L.INV_STAT,D.PICK_ORDER,D.LINE_NO__PICK FROM REPL_ORD_DET D,LOCATION L "
+" WHERE REPL_ORDER = ? AND LINE_NO = ? " +" WHERE REPL_ORDER = ? AND LINE_NO = ? "
+ " AND L.LOC_CODE = D.LOC_CODE "; + " AND L.LOC_CODE = D.LOC_CODE ";
*/
getActualQty ="SELECT D.ACTUAL_QTY,L.INV_STAT,D.PICK_ORDER,D.LINE_NO__PICK,I.SHIPPER_SIZE "
+" FROM REPL_ORD_DET D,LOCATION L,ITEM_LOT_PACKSIZE I "
+" WHERE REPL_ORDER = ? AND LINE_NO = ? "
+ " AND L.LOC_CODE = D.LOC_CODE AND I.ITEM_CODE = D.ITEM_CODE";
pstmt1 = conn.prepareStatement(getActualQty); pstmt1 = conn.prepareStatement(getActualQty);
pstmt1.setString(1, replOrder); pstmt1.setString(1, replOrder);
pstmt1.setString(2, lineNo); pstmt1.setString(2, lineNo);
...@@ -1331,6 +1457,8 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -1331,6 +1457,8 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
invS = rs1.getString("INV_STAT"); invS = rs1.getString("INV_STAT");
replOrdChk = rs1.getString("PICK_ORDER"); replOrdChk = rs1.getString("PICK_ORDER");
replLineChk = rs1.getString("LINE_NO__PICK"); replLineChk = rs1.getString("LINE_NO__PICK");
//Changed by Rohan on 11-02-13 for reduce one case from actual qty
shipperSize = rs1.getDouble("SHIPPER_SIZE");
} }
if(rs1 != null) if(rs1 != null)
{ {
...@@ -1390,7 +1518,9 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -1390,7 +1518,9 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
+" WHERE REPL_ORDER = ? AND LINE_NO = ?)"; +" WHERE REPL_ORDER = ? AND LINE_NO = ?)";
} }
pstmt1 = conn.prepareStatement(updateSql); pstmt1 = conn.prepareStatement(updateSql);
pstmt1.setDouble(1, actQty); //Changed by Rohan on 11-02-13 for reduce one case from actual qty
//pstmt1.setDouble(1, actQty);
pstmt1.setDouble(1, shipperSize);
if("".equalsIgnoreCase(replOrdChk) && invS.trim().equalsIgnoreCase(casePickLoc.trim())) if("".equalsIgnoreCase(replOrdChk) && invS.trim().equalsIgnoreCase(casePickLoc.trim()))
{ {
pstmt1.setString(2, replOrdChk); pstmt1.setString(2, replOrdChk);
...@@ -1480,6 +1610,11 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -1480,6 +1610,11 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
//Update dependent Repl //Update dependent Repl
updateCancelMode(replOrder,lineNo,"Y",conn); updateCancelMode(replOrder,lineNo,"Y",conn);
} }
else if("Q".equalsIgnoreCase(replType))
{
updateCancelMode(replOrdOrg,replLineOrg,"Q",conn);
}
} }
//Changed by Rohan on 22-01-13 to cancle independent Repanishment.end //Changed by Rohan on 22-01-13 to cancle independent Repanishment.end
...@@ -1541,6 +1676,8 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -1541,6 +1676,8 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
String sqlRepl=""; String sqlRepl="";
String replOrderCopy = ""; String replOrderCopy = "";
String lineNoPk = ""; String lineNoPk = "";
//Changed by Rohan on 11-02-13 for define variable
double shipperSize = 0.0;
boolean isUpdate = true; boolean isUpdate = true;
DistCommon discommon = new DistCommon(); DistCommon discommon = new DistCommon();
String casePickLoc = discommon.getDisparams("999999","CASE_PICK_INVSTAT",conn); String casePickLoc = discommon.getDisparams("999999","CASE_PICK_INVSTAT",conn);
...@@ -1615,10 +1752,15 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -1615,10 +1752,15 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
System.out.println("HASHMAPINING VALUES"+replHashMap.toString()); System.out.println("HASHMAPINING VALUES"+replHashMap.toString());
//Changed by Rohan on 11-02-13 for reduce one case from actual qty
/*
sqlRepl = " SELECT H.ORDER_TYPE,D.ACTUAL_QTY,D.PICK_ORDER FROM REPL_ORD_HDR H,REPL_ORD_DET D" sqlRepl = " SELECT H.ORDER_TYPE,D.ACTUAL_QTY,D.PICK_ORDER FROM REPL_ORD_HDR H,REPL_ORD_DET D"
+ " WHERE D.REPL_ORDER = ? AND LINE_NO = ? " + " WHERE D.REPL_ORDER = ? AND LINE_NO = ? "
+" AND H.REPL_ORDER = D.REPL_ORDER "; +" AND H.REPL_ORDER = D.REPL_ORDER ";*/
sqlRepl = " SELECT H.ORDER_TYPE,D.ACTUAL_QTY,D.PICK_ORDER,I.SHIPPER_SIZE" +
" FROM REPL_ORD_HDR H,REPL_ORD_DET D ,ITEM_LOT_PACKSIZE I"
+ " WHERE D.REPL_ORDER = ? AND LINE_NO = ? "
+" AND H.REPL_ORDER = D.REPL_ORDER AND I.ITEM_CODE = D.ITEM_CODE";
pstmt1 = conn.prepareStatement(sqlRepl); pstmt1 = conn.prepareStatement(sqlRepl);
pstmt1.setString(1, repl); pstmt1.setString(1, repl);
pstmt1.setString(2, lineRepl); pstmt1.setString(2, lineRepl);
...@@ -1628,6 +1770,8 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -1628,6 +1770,8 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
orderType = rs1.getString("ORDER_TYPE"); orderType = rs1.getString("ORDER_TYPE");
actQty = rs1.getDouble("ACTUAL_QTY"); actQty = rs1.getDouble("ACTUAL_QTY");
pick = checkNull(rs1.getString("PICK_ORDER")); pick = checkNull(rs1.getString("PICK_ORDER"));
//Changed by Rohan on 11-02-13 for reduce one case from actual qty
shipperSize = rs1.getDouble("SHIPPER_SIZE");
} }
if(rs1 != null) if(rs1 != null)
...@@ -1676,20 +1820,35 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -1676,20 +1820,35 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
{ {
if(invstatChk.trim().equalsIgnoreCase(psoLoc)) if(invstatChk.trim().equalsIgnoreCase(psoLoc))
{ {
/*
updateSql= " UPDATE REPL_ORD_DET SET ACTUAL_QTY = ACTUAL_QTY - ?" updateSql= " UPDATE REPL_ORD_DET SET ACTUAL_QTY = ACTUAL_QTY - ?"
+" WHERE (REPL_ORDER,LINE_NO) IN(SELECT PICK_ORDER,LINE_NO__PICK " +" WHERE (REPL_ORDER,LINE_NO) IN(SELECT PICK_ORDER,LINE_NO__PICK "
+" FROM REPL_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO = ? ) "; +" FROM REPL_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO = ? ) ";
*/
updateSql= " UPDATE REPL_ORD_DET SET ACTUAL_QTY = ACTUAL_QTY - ?"
+" WHERE (REPL_ORDER,LINE_NO) IN(SELECT PICK_ORDER,LINE_NO__PICK "
+" FROM REPL_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO = ? ) "
+" AND CASE WHEN CANCEL_MODE IS NULL THEN 'N' ELSE CANCEL_MODE END <> 'Y' ";
} }
else else
{ {
/*
updateSql= " UPDATE REPL_ORD_DET SET ACTUAL_QTY = ACTUAL_QTY - ?" updateSql= " UPDATE REPL_ORD_DET SET ACTUAL_QTY = ACTUAL_QTY - ?"
+" WHERE (REPL_ORDER,LINE_NO) IN(SELECT PICK_ORDER,LINE_NO__PICK " +" WHERE (REPL_ORDER,LINE_NO) IN(SELECT PICK_ORDER,LINE_NO__PICK "
+" FROM REPL_ORD_DET WHERE (REPL_ORDER,LINE_NO) " + +" FROM REPL_ORD_DET WHERE (REPL_ORDER,LINE_NO) " +
" IN (SELECT PICK_ORDER,LINE_NO__PICK FROM REPL_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO = ?)) "; " IN (SELECT PICK_ORDER,LINE_NO__PICK FROM REPL_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO = ?)) ";
*/
updateSql= " UPDATE REPL_ORD_DET SET ACTUAL_QTY = ACTUAL_QTY - ?"
+" WHERE (REPL_ORDER,LINE_NO) IN(SELECT PICK_ORDER,LINE_NO__PICK "
+" FROM REPL_ORD_DET WHERE (REPL_ORDER,LINE_NO) " +
" IN (SELECT PICK_ORDER,LINE_NO__PICK FROM REPL_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO = ?)) "
+" AND CASE WHEN CANCEL_MODE IS NULL THEN 'N' ELSE CANCEL_MODE END <> 'Y' ";
} }
pstmt1 = conn.prepareStatement(updateSql); pstmt1 = conn.prepareStatement(updateSql);
pstmt1.setDouble(1, actQty); //Changed by Rohan on 11-02-13 for reduce one case from actual qty
//pstmt1.setDouble(1, actQty);
pstmt1.setDouble(1,shipperSize);
pstmt1.setString(2, repl); pstmt1.setString(2, repl);
//pstmt1.setString(3, lineNo); //pstmt1.setString(3, lineNo);
pstmt1.setString(3, lineRepl); pstmt1.setString(3, lineRepl);
...@@ -1774,6 +1933,7 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -1774,6 +1933,7 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
String lineNoRepl = ""; String lineNoRepl = "";
String invStat = ""; String invStat = "";
String sqlPnd = ""; String sqlPnd = "";
double shipperSize = 0.0;
DistCommon discommon = new DistCommon(); DistCommon discommon = new DistCommon();
//String pndLoc = discommon.getDisparams("999999","PND_INVSTAT",conn); //String pndLoc = discommon.getDisparams("999999","PND_INVSTAT",conn);
...@@ -1787,10 +1947,16 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -1787,10 +1947,16 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
try try
{ {
//updateReplOrd= "UPDATE REPL_ORD_DET SET CANCEL_MODE = 'Y' WHERE REPL_ORDER = ? AND LINE_NO = ? " ; //updateReplOrd= "UPDATE REPL_ORD_DET SET CANCEL_MODE = 'Y' WHERE REPL_ORDER = ? AND LINE_NO = ? " ;
if(!"Q".equalsIgnoreCase(depRepl))
{
updateReplOrd= "UPDATE REPL_ORD_DET SET CANCEL_MODE = 'Y', ACTUAL_QTY = 0 WHERE REPL_ORDER = ? AND LINE_NO = ? " ; updateReplOrd= "UPDATE REPL_ORD_DET SET CANCEL_MODE = 'Y', ACTUAL_QTY = 0 WHERE REPL_ORDER = ? AND LINE_NO = ? " ;
pstmtUpadte = conn.prepareStatement(updateReplOrd); pstmtUpadte = conn.prepareStatement(updateReplOrd);
}
System.out.println("depRepl:::::"+depRepl); System.out.println("depRepl:::::"+depRepl);
//setting stock to dock repanishmnet cancel
if("N".equalsIgnoreCase(depRepl)) if("N".equalsIgnoreCase(depRepl))
{ /* { /*
updateReplOrd= "UPDATE REPL_ORD_DET SET CANCEL_MODE = 'Y' WHERE REPL_ORDER = ? AND LINE_NO = ? " ; updateReplOrd= "UPDATE REPL_ORD_DET SET CANCEL_MODE = 'Y' WHERE REPL_ORDER = ? AND LINE_NO = ? " ;
...@@ -1812,8 +1978,8 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -1812,8 +1978,8 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
rs = pstmtRepl.executeQuery(); rs = pstmtRepl.executeQuery();
if(rs.next()) if(rs.next())
{ {
replOrd = rs.getString("PICK_ORDER"); replOrd = checkNull(rs.getString("PICK_ORDER"));
lineNoRepl = rs.getString("LINE_NO__PICK"); lineNoRepl = checkNull(rs.getString("LINE_NO__PICK"));
} }
if(!"".equalsIgnoreCase(replOrd) && replOrd.trim().length() > 0) if(!"".equalsIgnoreCase(replOrd) && replOrd.trim().length() > 0)
{ {
...@@ -1849,11 +2015,11 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -1849,11 +2015,11 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
if(rs.next()) if(rs.next())
{ {
System.out.println("Inside case pick"); System.out.println("Inside case pick");
replOrd = rs.getString("PICK_ORDER"); replOrd = checkNull(rs.getString("PICK_ORDER"));
System.out.println("replOrd*8*"+replOrd); System.out.println("replOrd*8*"+replOrd);
lineNoRepl = rs.getString("LINE_NO__PICK"); lineNoRepl = checkNull(rs.getString("LINE_NO__PICK"));
System.out.println("lineNoRepl*8*"+lineNoRepl); System.out.println("lineNoRepl*8*"+lineNoRepl);
invStat = rs.getString("INV_STAT"); invStat = checkNull(rs.getString("INV_STAT"));
System.out.println("replOrd>>"+replOrd+"lineNoRepl:::::"+lineNoRepl+"invStat"+invStat); System.out.println("replOrd>>"+replOrd+"lineNoRepl:::::"+lineNoRepl+"invStat"+invStat);
} }
if(rs != null) if(rs != null)
...@@ -1878,9 +2044,9 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -1878,9 +2044,9 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
rs = pstmtRepl.executeQuery(); rs = pstmtRepl.executeQuery();
if(rs.next()) if(rs.next())
{ {
replOrd = rs.getString("REPL_ORDER"); replOrd = checkNull(rs.getString("REPL_ORDER"));
System.out.println("replOrd*8*"+replOrd); System.out.println("replOrd*8*"+replOrd);
lineNoRepl = rs.getString("LINE_NO"); lineNoRepl = checkNull(rs.getString("LINE_NO"));
} }
} }
if(!"".equalsIgnoreCase(replOrd.trim())) if(!"".equalsIgnoreCase(replOrd.trim()))
...@@ -1895,6 +2061,72 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca ...@@ -1895,6 +2061,72 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
} }
} }
} }
else if("Q".equalsIgnoreCase(depRepl))
{
sqlReplOrd = "SELECT L.INV_STAT,I.SHIPPER_SIZE FROM REPL_ORD_DET D,LOCATION L,ITEM_LOT_PACKSIZE I "
+" WHERE (REPL_ORDER,LINE_NO) IN (SELECT PICK_ORDER,LINE_NO__PICK "
+" FROM REPL_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO = ?) "
+ " AND D.LOC_CODE = L.LOC_CODE AND D.ITEM_CODE = I.ITEM_CODE ";
pstmtRepl = conn.prepareStatement(sqlReplOrd);
pstmtRepl.setString(1, replOrder);
pstmtRepl.setString(2, replLineNo);
rs = pstmtRepl.executeQuery();
if(rs.next())
{
invStat = checkNull(rs.getString("INV_STAT"));
shipperSize = rs.getDouble("SHIPPER_SIZE");
}
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmtRepl != null)
{
pstmtRepl.close();
pstmtRepl = null;
}
System.out.println("INVSTART"+invStat);
if(invStat.trim().equalsIgnoreCase(psoLoc))
{
/*updateReplOrd= " UPDATE REPL_ORD_DET SET ACTUAL_QTY = ACTUAL_QTY + ?"
+" WHERE (REPL_ORDER,LINE_NO) IN(SELECT PICK_ORDER,LINE_NO__PICK "
+" FROM REPL_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO = ? ) ";*/
updateReplOrd= " UPDATE REPL_ORD_DET SET ACTUAL_QTY = ACTUAL_QTY + ? "
+" WHERE (REPL_ORDER,LINE_NO) IN(SELECT PICK_ORDER,LINE_NO__PICK "
+" FROM REPL_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO = ? ) "
+" AND CASE WHEN CANCEL_MODE IS NULL THEN 'N' ELSE CANCEL_MODE END <> 'Y' ";
}
else
{
/*updateReplOrd= " UPDATE REPL_ORD_DET SET ACTUAL_QTY = ACTUAL_QTY + ?"
+" WHERE (REPL_ORDER,LINE_NO) IN(SELECT PICK_ORDER,LINE_NO__PICK "
+" FROM REPL_ORD_DET WHERE (REPL_ORDER,LINE_NO) " +
" IN (SELECT PICK_ORDER,LINE_NO__PICK FROM REPL_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO = ?)) ";*/
updateReplOrd= " UPDATE REPL_ORD_DET SET ACTUAL_QTY = ACTUAL_QTY + ?"
+" WHERE (REPL_ORDER,LINE_NO) IN(SELECT PICK_ORDER,LINE_NO__PICK "
+" FROM REPL_ORD_DET WHERE (REPL_ORDER,LINE_NO) " +
" IN (SELECT PICK_ORDER,LINE_NO__PICK FROM REPL_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO = ?)) "
+" AND CASE WHEN CANCEL_MODE IS NULL THEN 'N' ELSE CANCEL_MODE END <> 'Y' ";
}
pstmtUpadte = conn.prepareStatement(updateReplOrd);
pstmtUpadte.setDouble(1,shipperSize);
pstmtUpadte.setString(2, replOrder);
pstmtUpadte.setString(3, replLineNo);
pstmtUpadte.executeUpdate();
if(pstmtUpadte != null)
{
pstmtUpadte.close();
pstmtUpadte = null;
}
}
} }
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