Skip to content

B
business-java
Commit 73cc4678 authored by rbhogale's avatar rbhogale
Browse files
Options

Changed by Rohan on 30-01-13 for Repanishment Cancle 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@92609 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 07340eb2
Show whitespace changes
Inline Side-by-side
Showing with 497 additions and 153 deletions
webitm-wms/ibase/webitm/ejb/wms/WaveCancelEJB.java
View file @ 73cc4678
......@@ -156,6 +156,10 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
String lineNoRepl = "";
String sqlWave = "";
String refSeries = "";
//Changed by Rohan on 22-01-13 to cancle independent Repanishment.start
String replOrdOrg = "";
String replLineOrg = "";
//Changed by Rohan on 22-01-13 to cancle independent Repanishment.end
PreparedStatement pstmtTask = null;
ResultSet rsTask = null;
PreparedStatement pstmtInv = null;
......@@ -326,10 +330,24 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
saleOrder = checkNull( rsPick.getString("SALE_ORDER") );
lineNoSord = checkNull( rsPick.getString("LINE_NO__SORD") );
//Changed by Rohan on 22-01-13 to cancle independent Repanishment.start
/*
if(!refSer.trim().equalsIgnoreCase("S-DOC") && !refSer.equalsIgnoreCase("RP-PND") && !refSer.equalsIgnoreCase("RP-PSO"))
{
replOrdOrg = checkNull( rsPick.getString("REPL_ORDER") );
replLineOrg = checkNull( rsPick.getString("LINE_NO__REPL") );
}
//Changed by Rohan on 22-01-13 to cancle independent Repanishment.end
*/
if(!refSer.trim().equalsIgnoreCase("S-DOC") && !refSer.equalsIgnoreCase("RP-PND") && !refSer.equalsIgnoreCase("RP-PSO"))
{
replOrder = checkNull( rsPick.getString("REPL_ORDER") );
replLineNo = checkNull( rsPick.getString("LINE_NO__REPL") );
replLineNo = checkNull( rsPick.getString("LINE_NO__REPL"));
//Changed by Rohan on 22-01-13 to cancle independent Repanishment.start
replOrdOrg = replOrder;
replLineOrg = replLineNo;
//Changed by Rohan on 22-01-13 to cancle independent Repanishment.end
pickOrder = checkNull( rsPick.getString("PICK_ORDER") );
pickLineNo = checkNull( rsPick.getString("LINE_NO") );
......@@ -339,7 +357,7 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
replOrder = checkNull( rsPick.getString("REPL_ORDER") );
replLineNo = checkNull( rsPick.getString("LINE_NO") );
}
System.out.println("Original Repl Order"+replOrdOrg+"Original Repl line no"+replLineOrg);
System.out.println("LOCCode***"+locCode);
qtyStduom = quantity;
......@@ -362,7 +380,9 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
if("Y".equalsIgnoreCase(confirm))
{
//to update actual quantity in replanishment
updateRecord = updateReplanishment(replOrder,replLineNo,pickOrder,pickLineNo,quantity,true,conn);//test1sucess
//Changed by Rohan on 22-01-13 to cancle independent Repanishment
//updateRecord = updateReplanishment(replOrder,replLineNo,pickOrder,pickLineNo,quantity,true,conn);
updateRecord = updateReplanishment(replOrder,replLineNo,pickOrder,pickLineNo,quantity,true,waveID,replOrdOrg,replLineOrg,conn);
if(updateRecord > 0)
{
......@@ -462,14 +482,26 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
//to update actual quantity in replanishment
//Test
//Changed by Rohan on 03/12/11 not update repanishment in case of stock to dock
//updateRecord = updateReplanishment(replOrder,replLineNo,pickOrder,pickLineNo,quantity,true,conn);
//Changed by Rohan on 28-Jan-13 for not update actual qty in case of stock to dock
//if(!refSer.trim().equalsIgnoreCase("S-DOC") || !refSer.equalsIgnoreCase("RP-PND") || !refSer.equalsIgnoreCase("RP-PSO"))
System.out.println("REFSERIEEEEEEEEEE"+refSer);
if(!refSer.trim().equalsIgnoreCase("S-DOC") && !refSer.equalsIgnoreCase("RP-PND") && !refSer.equalsIgnoreCase("RP-PSO"))
{
updateRecord = updateReplanishment(replOrder,replLineNo,pickOrder,pickLineNo,quantity,true,conn);
//Changed by Rohan on 22-01-13 to cancle independent Repanishment
//updateRecord = updateReplanishment(replOrder,replLineNo,pickOrder,pickLineNo,quantity,true,conn);
System.out.println("*#$S#$#$#$#$#$#$#$#$#$#$#$#$#$");
updateRecord = updateReplanishment(replOrder,replLineNo,pickOrder,pickLineNo,quantity,true,waveID,replOrdOrg,replLineOrg,conn);
}
//Changed by Rohan on 03/12/11 not update repanishment in case of stock to dock.end
//Changed by Rohan on 30-01-13 to set wave cancel mode Y in case of stock to dock.start
else
{
System.out.println("Cancle Repl"+replOrder+"replLineNo"+replLineNo);
updateCancelMode(replOrder, replLineNo,"N",conn);
}
//Changed by Rohan on 30-01-13 to set wave cancel mode Y in case of stock to dock.start
if(updateRecord > 0)
{
System.out.println("Replenishment updated with actual quantity "+quantity+" For replenishment oder :"+replOrder +" and line no :"+replLineNo);
......@@ -510,9 +542,18 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
//if(!refSer.trim().equalsIgnoreCase("S-DOC") || !refSer.equalsIgnoreCase("RP-PND") || !refSer.equalsIgnoreCase("RP-PSO"))
if(!refSer.trim().equalsIgnoreCase("S-DOC") && !refSer.equalsIgnoreCase("RP-PND") && !refSer.equalsIgnoreCase("RP-PSO"))
{
updateRecord = updateReplanishment(replOrder,replLineNo,pickOrder,pickLineNo,quantity,false,conn);
//Changed by Rohan on 22-01-13 to cancle independent Repanishment
//updateRecord = updateReplanishment(replOrder,replLineNo,pickOrder,pickLineNo,quantity,false,conn);
updateRecord = updateReplanishment(replOrder,replLineNo,pickOrder,pickLineNo,quantity,false,waveID,replOrdOrg,replLineOrg,conn);
}
//Changed by Rohan on 03/12/11 not update repanishment in case of stock to dock.start
//Changed by Rohan on 30-01-13 to set wave cancel mode Y in case of stock to dock.start
else
{
System.out.println("Cancle Repl1"+replOrder+"replLineNo"+replLineNo);
updateCancelMode(replOrder, replLineNo,"N",conn);
}
//Changed by Rohan on 30-01-13 to set wave cancel mode Y in case of stock to dock.start
//Changed by Rohan on 03/12/11 not update repanishment in case of stock to dock.end
//Changed by Rohan on 03/12/11 not update repanishment in case of stock to dock.start
......@@ -562,9 +603,18 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
//if(!refSer.trim().equalsIgnoreCase("S-DOC") || !refSer.equalsIgnoreCase("RP-PND") || !refSer.equalsIgnoreCase("RP-PSO"))
if(!refSer.trim().equalsIgnoreCase("S-DOC") && !refSer.equalsIgnoreCase("RP-PND") && !refSer.equalsIgnoreCase("RP-PSO"))
{
updateRecord = updateReplanishment(replPickOrder,replPickLineNo,pickOrder,pickLineNo,quantity,false,conn);
//Changed by Rohan on 22-01-13 to cancle independent Repanishment
//updateRecord = updateReplanishment(replPickOrder,replPickLineNo,pickOrder,pickLineNo,quantity,false,conn);
updateRecord = updateReplanishment(replPickOrder,replPickLineNo,pickOrder,pickLineNo,quantity,false,waveID,replOrdOrg,replLineOrg,conn);
}
//Changed by Rohan on 03/12/11 not update repanishment in case of stock to dock.end
//Changed by Rohan on 30-01-13 to set wave cancel mode Y in case of stock to dock.start
else
{
System.out.println("Cancle Repl2"+replPickOrder+"replLineNo"+replPickLineNo);
updateCancelMode(replPickOrder, replPickLineNo,"N",conn);
}
//Changed by Rohan on 30-01-13 to set wave cancel mode Y in case of stock to dock.end
if(updateRecord > 0)
{
System.out.println("Replenishment updated with actual quantity "+quantity+" For replenishment oder :"+replPickOrder +" and line no :"+replPickLineNo);
......@@ -1040,8 +1090,9 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
}
return tempList;
}
public int updateReplanishment(String replOrder,String lineNo,String pickOrder,String lineNoPick,double quantity,boolean confirm,Connection conn)throws Exception
//Changed by Rohan on 22-01-13 to cancle independent Repanishment
//public int updateReplanishment(String replOrder,String lineNo,String pickOrder,String lineNoPick,double quantity,boolean confirm,Connection conn)throws Exception
public int updateReplanishment(String replOrder,String lineNo,String pickOrder,String lineNoPick,double quantity,boolean confirm,String waveID,String replOrdOrg,String replLineOrg,Connection conn)throws Exception
{
PreparedStatement pstmt = null;
......@@ -1063,6 +1114,21 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
String invS = "";
String replOrdChk = "";
String replLineChk = "";
String ordRepl = "";
//Changed by Rohan on 22-01-13 to cancle independent Repanishment.start
String sqlPick ="";
String sqlWave ="";
String waveIDCmp = "";
String sqlAct ="";
String sqlDep ="";
String replType = "";
int cnt = 0;
PreparedStatement pstmt2 = null;
ResultSet rs2 = null;
boolean isDepRepl = false;
//Changed by Rohan on 22-01-13 to cancle independent Repanishment.end
DistCommon discommon = new DistCommon();
String casePickLoc = discommon.getDisparams("999999","CASE_PICK_INVSTAT",conn);
String activePickLoc = discommon.getDisparams("999999","ACTIVE_PICK_INVSTAT",conn);
......@@ -1075,6 +1141,149 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
int count = 0;
try
{
System.out.println("replOrdOrg===---->"+replOrdOrg+"replLineOrg%%%%"+replLineOrg);
//Changed by Rohan on 22-01-13 to cancle independent Repanishment.start
//to check case to active Repanishment.start
sqlAct = "SELECT ORDER_TYPE FROM REPL_ORD_HDR WHERE REPL_ORDER = ?";
pstmt2 = conn.prepareStatement(sqlAct);
pstmt2.setString(1, replOrdOrg);
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
replType = rs2.getString("ORDER_TYPE");
}
if(pstmt2 != null)
{
pstmt2.close();
pstmt2 = null;
}
if(rs2 != null)
{
rs2.close();
rs2 = null;
}
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) )
{
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))
{
sqlDep = "SELECT REPL_ORDER FROM REPL_ORD_DET WHERE PICK_ORDER = ? AND LINE_NO__PICK = ? ";
}
pstmt2 = conn.prepareStatement(sqlDep);
pstmt2.setString(1, replOrdOrg);
pstmt2.setString(2, replLineOrg);
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
ordRepl = rs2.getString(1);
}
if(pstmt2 != null)
{
pstmt2.close();
pstmt2 = null;
}
if(rs2 != null)
{
rs2.close();
rs2 = null;
}
//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'";
sqlWave = "SELECT WAVE_ID FROM WAVE_TASK_DET WHERE REF_ID = ?";
pstmt1 = conn.prepareStatement(sqlWave);
pstmt1.setString(1, ordRepl);
System.out.println("ordRepl===>"+ ordRepl);
rs1 = pstmt1.executeQuery();
if(rs1.next())
{
waveIDCmp = rs1.getString("WAVE_ID");
System.out.println("waveIDCmp::::::"+waveIDCmp+"Wave ID:::"+waveID);
}
if(!waveIDCmp.trim().equalsIgnoreCase(waveID.trim()) && !"".equalsIgnoreCase(waveIDCmp))
{
System.out.println("NOT EQUALSS:::::::::");
isDepRepl = true;
}
if(pstmt1 != null)
{
pstmt1.close();
pstmt1 = null;
}
if(rs1 != null)
{
rs1.close();
rs1 = null;
}
}
//to check case to active Repanishment.start
//if(!"Q".equalsIgnoreCase(replType) && "J".equalsIgnoreCase(replType))
else
{
sqlPick = "SELECT PICK_ORDER FROM PICK_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO__REPL = ? AND PICK_ORDER <> ?";
pstmt = conn.prepareStatement(sqlPick);
pstmt.setString(1, replOrdOrg);
pstmt.setString(2, replLineOrg);
pstmt.setString(3, pickOrder);
rs = pstmt.executeQuery();
while(rs.next())
{
sqlWave = "SELECT WAVE_ID FROM WAVE_TASK_DET WHERE REF_ID = ?";
//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'";
pstmt1 = conn.prepareStatement(sqlWave);
pstmt1.setString(1, rs.getString("PICK_ORDER"));
System.out.println("PICK ORDRDRD====>"+ rs.getString("PICK_ORDER"));
rs1 = pstmt1.executeQuery();
if(rs1.next())
{
waveIDCmp = rs1.getString("WAVE_ID");
System.out.println("waveIDCmp"+waveIDCmp+"Wave ID"+waveID);
}
System.out.println("waveIDCmp$$$$"+waveIDCmp);
if(!waveIDCmp.trim().equalsIgnoreCase(waveID.trim()) && !"".equalsIgnoreCase(waveIDCmp))
{
System.out.println("NOT EQUALSS");
isDepRepl = true;
break;
}
}
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(pstmt1 != null)
{
pstmt1.close();
pstmt1 = null;
}
if(rs != null)
{
rs.close();
rs = null;
}
if(rs1 != null)
{
rs1.close();
rs1 = null;
}
if(isDepRepl)
{
//Changed by Rohan on 22-01-13 to cancle independent Repanishment.end
if(confirm)
{
//if(!"C".equalsIgnoreCase(orderType))
......@@ -1246,6 +1455,33 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
pstmt.setString(2, replOrder);
pstmt.setString(3, lineNo);
count = pstmt.executeUpdate();
//Changed by Rohan on 22-01-13 to cancle independent Repanishment.start
}
else
{
System.out.println("Enter in else Repanishment)*)*()*");
sql= "UPDATE REPL_ORD_DET SET ACTUAL_QTY = 0,CANCEL_MODE = 'Y'" +
" WHERE REPL_ORDER = ? AND LINE_NO = ?" ;
pstmt = conn.prepareStatement(sql);
if("Q".equalsIgnoreCase(replType))
{
pstmt.setString(1, replOrdOrg);
pstmt.setString(2, replLineOrg);
}
else
{
pstmt.setString(1, replOrder);
pstmt.setString(2, lineNo);
}
count = pstmt.executeUpdate();
if(!"Q".equalsIgnoreCase(replType) )
{
//Update dependent Repl
updateCancelMode(replOrder,lineNo,"Y",conn);
}
}
//Changed by Rohan on 22-01-13 to cancle independent Repanishment.end
}
catch(Exception e)
......@@ -1529,5 +1765,113 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
return tempReplList;
}
//Changed by Rohan on 30-01-13 to set cancle mode Y in case of stock to dock.start
private void updateCancelMode(String replOrder ,String replLineNo,String depRepl,Connection conn) throws Exception
{
String sqlReplOrd = "";
String updateReplOrd = "";
String replOrd = "";
String lineNoRepl = "";
PreparedStatement pstmtRepl = null;
PreparedStatement pstmtUpadte = null;
ResultSet rs = null;
try
{
updateReplOrd= "UPDATE REPL_ORD_DET SET CANCEL_MODE = 'Y' WHERE REPL_ORDER = ? AND LINE_NO = ? " ;
pstmtUpadte = conn.prepareStatement(updateReplOrd);
System.out.println("depRepl:::::"+depRepl);
if("N".equalsIgnoreCase(depRepl))
{ /*
updateReplOrd= "UPDATE REPL_ORD_DET SET CANCEL_MODE = 'Y' WHERE REPL_ORDER = ? AND LINE_NO = ? " ;
pstmtUpadte = conn.prepareStatement(updateReplOrd);
*/
pstmtUpadte.clearParameters();
pstmtUpadte.setString(1, replOrder);
pstmtUpadte.setString(2, replLineNo);
int cntUpdte = pstmtUpadte.executeUpdate();
if(cntUpdte > 0)
{
System.out.println("Repanishment Cancle for "+replOrder+" and Repl line no "+replLineNo);
}
sqlReplOrd = "SELECT PICK_ORDER,LINE_NO__PICK FROM REPL_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO = ? ";
pstmtRepl = conn.prepareStatement(sqlReplOrd);
pstmtRepl.setString(1, replOrder);
pstmtRepl.setString(2, replLineNo);
rs = pstmtRepl.executeQuery();
if(rs.next())
{
replOrd = rs.getString("PICK_ORDER");
lineNoRepl = rs.getString("LINE_NO__PICK");
}
if(!"".equalsIgnoreCase(replOrd) && replOrd.trim().length() > 0)
{
pstmtUpadte.clearParameters();
pstmtUpadte.setString(1, replOrd);
pstmtUpadte.setString(2, lineNoRepl);
int cntUpdte1 = pstmtUpadte.executeUpdate();
if(cntUpdte1 > 0)
{
System.out.println("Repanishment Cancle for "+replOrd+" and Repl line no "+lineNoRepl);
}
}
}
else if("Y".equalsIgnoreCase(depRepl))
{
sqlReplOrd = "SELECT REPL_ORDER,LINE_NO FROM REPL_ORD_DET WHERE PICK_ORDER = ? AND LINE_NO__PICK = ? ";
pstmtRepl = conn.prepareStatement(sqlReplOrd);
pstmtRepl.setString(1, replOrder);
pstmtRepl.setString(2, replLineNo);
rs = pstmtRepl.executeQuery();
if(rs.next())
{
System.out.println("Inside case pick");
replOrd = rs.getString("REPL_ORDER");
System.out.println("replOrd*8*"+replOrd);
lineNoRepl = rs.getString("LINE_NO");
System.out.println("lineNoRepl*8*"+lineNoRepl);
}
if(!"".equalsIgnoreCase(replOrd.trim()))
{
pstmtUpadte.clearParameters();
pstmtUpadte.setString(1, replOrd);
pstmtUpadte.setString(2, lineNoRepl);
int cntUpdte1 = pstmtUpadte.executeUpdate();
if(cntUpdte1 > 0)
{
System.out.println("Repanishment Cancle for "+replOrd+" and Repl line no "+lineNoRepl);
}
}
}
}
catch(Exception e)
{
throw new ITMException(e);
}
finally
{
if(pstmtRepl != null)
{
pstmtRepl.close();
pstmtRepl = null;
}
if(pstmtUpadte != null)
{
pstmtUpadte.close();
pstmtUpadte = null;
}
if(rs != null)
{
rs.close();
rs = null;
}
}
}
//Changed by Rohan on 30-01-13 to set cancle mode Y in case of stock to dock.end
}
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