Changed by Rohan on 23-10-12 for wave cancellation process

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@92039 ce508802-f39f-4f6c-b175-0d175dae99d5

webitm-wms/ibase/webitm/ejb/wms/WaveCancelEJB.java

@@ -28,7 +28,7 @@ import javax.naming.InitialContext;
 @Stateless 
 public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLocal, WaveCancelEJBRemote 
 {
-	
+	HashMap<String,String> replHashMap = new HashMap<String,String>();
     /**
 	 * The public method is used for confirming the service complaint transaction
 	 * Returns confirmation message on successfull confirm otherwise returns error message
@@ -304,6 +304,7 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
 							 "EXP_LEV,SALE_ORDER,LINE_NO__SORD,REPL_ORDER,LINE_NO__REPL,PICK_ORDER,LINE_NO FROM PICK_ORD_DET WHERE PICK_ORDER = ? ";
 						pstmtSql = conn.prepareStatement(pickDet);
 					}
+					replHashMap.clear();
 					
 					pstmtSql.setString(1, refId);
 					rsPick = pstmtSql.executeQuery();
@@ -1257,6 +1258,7 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
 	    String sqlRepl="";
 	    String replOrderCopy = "";
 	    String lineNoPk = "";
+	    boolean isUpdate = true;
 	    DistCommon discommon = new DistCommon();
 	    String casePickLoc  = discommon.getDisparams("999999","CASE_PICK_INVSTAT",conn);
 	    String activePickLoc  = discommon.getDisparams("999999","ACTIVE_PICK_INVSTAT",conn);
@@ -1307,6 +1309,31 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
 			System.out.println("invStat LOCATION_______"+invStat);
 			if(invStat.trim().equalsIgnoreCase(activePickLoc))
 			{
+				System.out.println("Original hashmap"+replHashMap.toString());
+				if(replHashMap.containsKey(repl))
+				{
+					String repLine = replHashMap.get(repl);
+					System.out.println("Enter Here-------->"+repLine+"repl"+lineRepl);
+					if(!repLine.equalsIgnoreCase(lineRepl))
+					{
+						replHashMap.put(repl,lineRepl);
+						System.out.println("HashMap after add"+replHashMap.toString());
+					}
+					else
+					{
+						isUpdate = false;
+						System.out.println("IS HASHMAP FLASE");
+					}
+				}
+				else
+				{
+					replHashMap.put(repl,lineRepl);
+					System.out.println("HashMap else case"+replHashMap.toString());
+				}
+					
+				
+				System.out.println("HASHMAPINING VALUES"+replHashMap.toString());
+					
 				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 = ? "
 						+" AND H.REPL_ORDER = D.REPL_ORDER ";
@@ -1335,6 +1362,7 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
 				
 				if("Q".equalsIgnoreCase(orderType.trim()))
 				{
+					
 					sqlOrderType = "SELECT L.INV_STAT FROM REPL_ORD_DET D,LOCATION L "
 							     +" WHERE (REPL_ORDER,LINE_NO) IN (SELECT PICK_ORDER,LINE_NO__PICK "
 								  +" FROM REPL_ORD_DET WHERE REPL_ORDER = ? AND LINE_NO = ?) "
@@ -1360,33 +1388,36 @@ public class WaveCancelEJB extends ActionHandlerEJB implements WaveCancelEJBLoca
 					}
 					System.out.println("INVSTART"+invstatChk);
 					//if("".equalsIgnoreCase(pick) && "".equalsIgnoreCase(invstatChk.trim()))
-					if(!"".equalsIgnoreCase(pick) && !"".equalsIgnoreCase(invstatChk.trim()))
-					{	
-						if(invstatChk.trim().equalsIgnoreCase(psoLoc))
+					if(isUpdate)
+					{
+						if(!"".equalsIgnoreCase(pick) && !"".equalsIgnoreCase(invstatChk.trim()))
 						{	
-							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 = ? ) ";
-						}
-						else 
-						{
-							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 = ?)) ";
-
-						}
-						pstmt1 =  conn.prepareStatement(updateSql);
-						pstmt1.setDouble(1, actQty);
-						pstmt1.setString(2, repl);
-						//pstmt1.setString(3, lineNo);
-						pstmt1.setString(3, lineRepl);
-						
-						pstmt1.executeUpdate();
-						if(pstmt1 != null)
-						{
-							pstmt1.close();
-							pstmt1 = null;
+							if(invstatChk.trim().equalsIgnoreCase(psoLoc))
+							{	
+								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 = ? ) ";
+							}
+							else 
+							{
+								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 = ?)) ";
+	
+							}
+							pstmt1 =  conn.prepareStatement(updateSql);
+							pstmt1.setDouble(1, actQty);
+							pstmt1.setString(2, repl);
+							//pstmt1.setString(3, lineNo);
+							pstmt1.setString(3, lineRepl);
+							
+							pstmt1.executeUpdate();
+							if(pstmt1 != null)
+							{
+								pstmt1.close();
+								pstmt1 = null;
+							}
 						}
 					}
 					/*