Update stock after checking channelpartner condition

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

webitm-dis/ibase/webitm/ejb/dis/adv/PoRcpConf.java

@@ -886,7 +886,7 @@ public class PoRcpConf extends ActionHandlerEJB implements PoRcpConfLocal,
 		PreparedStatement pstmtUpd = null;
 		String retString = "";
 		PreparedStatement pstmtItemLotPack = null;
-		ResultSet rs = null, rs1 = null;
+		ResultSet rs = null, rs1 = null,rs2  = null;
 		ResultSet rsItemLotPack = null;
 		String sql = "";
 		java.sql.Timestamp tranDate = null;
@@ -922,7 +922,7 @@ public class PoRcpConf extends ActionHandlerEJB implements PoRcpConfLocal,
 		ArrayList itemLockList = null, tempList = null;
 		HashMap lockCodeWiseMap = new HashMap(), tempMap = null;
 		String lockGroup = "", lockCode = "", tempLockGroup = "", tempLockCode = "", qcReqd = "N", tempTranId = "";
-
+		String locCodeGit="";
 		try {
 			DistCommon distCommon = new DistCommon();
 			ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
@@ -1060,7 +1060,9 @@ public class PoRcpConf extends ActionHandlerEJB implements PoRcpConfLocal,
 					+ " from porcpdet Where tran_id = ? ";
 			pstmt = conn.prepareStatement(sql);
 			pstmt.setString(1, tranId);
+			
 			rs = pstmt.executeQuery();
+			
 			while (rs.next()) {
 				lineNo = rs.getString("line_no");
 				itemCode = rs.getString("item_code");
@@ -1635,8 +1637,48 @@ public class PoRcpConf extends ActionHandlerEJB implements PoRcpConfLocal,
 					if (errString != null && errString.indexOf("Error") != -1) {
 						break;
 					}
+					
 					System.out.println("Going in git");
-					if (channelPartner == "Y" && disLink == "E")
+				
+					sql = "Select channel_partner, dis_link From site_supplier "
+							+ " Where  site_code = ? " + " And supp_code = ? ";
+					pstmt2 = conn.prepareStatement(sql);
+					pstmt2.setString(1, siteRcp);
+					pstmt2.setString(2, suppCode);
+					rs2 = pstmt2.executeQuery();
+					if (rs2.next()) {
+						channelPartner = rs2.getString("channel_partner");
+						disLink = rs2.getString("dis_link");
+						pstmt2.close();
+						pstmt2 = null;
+						rs2.close();
+						rs2 = null;
+					} else {
+						pstmt2.close();
+						pstmt2 = null;
+						rs2.close();
+						rs2 = null;
+						sql = "Select channel_partner, dis_link From supplier "
+								+ " Where  supp_code = ? ";
+						pstmt2 = conn.prepareStatement(sql);
+						pstmt2.setString(1, suppCode);
+						rs2 = pstmt.executeQuery();
+						if (rs2.next()) {
+							channelPartner = rs2.getString("channel_partner");
+							disLink = rs2.getString("dis_link");
+						}
+						pstmt2.close();
+						pstmt2 = null;
+						rs2.close();
+						rs2 = null;
+					}
+					
+					System.out.println("Channel Partner "+channelPartner);
+					System.out.println("DisLink "+disLink);
+					
+
+					
+					if (channelPartner.equalsIgnoreCase("Y") && disLink.equalsIgnoreCase("E"))
 					{
 						System.out.println("Entered in channel Partner loop");
 
@@ -1645,50 +1687,39 @@ public class PoRcpConf extends ActionHandlerEJB implements PoRcpConfLocal,
 								+ " And   var_name='TRANSIT_LOC'";
 
 						pstmt2 = conn.prepareStatement(sql);
-						pstmt2.setString(1, prdCode);
-						pstmt2.setString(2, varName);
-						rs = pstmt2.executeQuery();
-						if (rs.next()) {
-
-							varValue = checkNull(rs.getString("var_value"));
-							System.out.print("VarName" + varName);
-							System.out.println("VarValue" + varValue);
-						}
-						if (varValue == null) {
-							retString = itmDBAccessLocal.getErrorString("",
-									"DS000", "");
-							return retString;
+						rs2 = pstmt2.executeQuery();
+						if (rs2.next()) {
+
+							locCodeGit = checkNull(rs2.getString("var_value"));
+							
+							System.out.println("VarValue" + locCodeGit);
 						}
+						
 						pstmt2.close();
 						pstmt2 = null;
-						rs.close();
-						rs = null;
+						rs2.close();
+						rs2 = null;
 					
 
 					sql = "Select inv_stat from location"
 							+ " Where loc_code = ?";
 
 					pstmt2 = conn.prepareStatement(sql);
-					pstmt2.setString(1, invStat);
-					if (rs.next()) {
-
-						locCode = checkNull(rs.getString("loc_code"));
-						System.out.print("locCode" + locCode);
-					} else {
+					
+					pstmt2.setString(1,locCodeGit);
+					rs2 = pstmt2.executeQuery();
+					if (rs2.next()) {
 
-						if (locCode == null) {
-							retString = itmDBAccessLocal.getErrorString("",
-									"DS000", "");
-							return retString;
-						}
-					}
+						invStat = (rs2.getString("inv_stat"));
+						System.out.print("invstat" + invStat);
+					} 
 					pstmt2.close();
 					pstmt2 = null;
-					rs.close();
-					rs = null;
+					rs2.close();
+					rs2 = null;
 
 					stkUpdMap.put("inv_stat", (invStat));
-					stkUpdMap.put("loc_code", (locCode));
+					stkUpdMap.put("loc_code", (locCodeGit));
 					stkUpdMap.put("tran_type", "I");
 					stkUpd = new StockUpdate();
 					errString = stkUpd.updateStock(stkUpdMap, xtraParams, conn);
@@ -1700,50 +1731,42 @@ public class PoRcpConf extends ActionHandlerEJB implements PoRcpConfLocal,
 
 					pstmt2 = conn.prepareStatement(sql);
 					pstmt2.setString(1, itemCode);
-					pstmt2.setString(2, siteCode);
-					pstmt2.setString(3, locCode);
+					pstmt2.setString(2, siteRcp);
+					pstmt2.setString(3, locCodeGit);
 					pstmt2.setString(4, lotNo);
 					pstmt2.setString(5, lotSl);
-					rs = pstmt2.executeQuery();
-					if (rs.next()) {
+					rs2 = pstmt2.executeQuery();
+					if (rs2.next()) {
 						System.out.print("ItemCode" + itemCode);
-						System.out.print("SiteCode" + siteCode);
-						lcholdQty = (rs.getDouble("hold_qty"));
-					} else {
-
-						if (lcholdQty == 0) {
-
-							retString = itmDBAccessLocal.getErrorString("",
-									"DS000", "");
-							return retString;
-						}
-					}
+						System.out.print("SiteCode" + siteRcp);
+						lcholdQty = (rs2.getDouble("hold_qty"));
+					} 
 					pstmt2.close();
 					pstmt2 = null;
-					rs.close();
-					rs = null;
+					rs2.close();
+					rs2 = null;
 
-					if (retString.isEmpty() || retString.trim().length() == 0
-							|| lcholdQty > 0) {
-						sql = "update stock set  hold_qty = ?(case when hold_qty is null "
-								+ "then 0 else hold_qtyb end)+? "
+					if (lcholdQty > 0) 
+					{
+						
+						sql = "update stock set  hold_qty =(case when hold_qty is null "
+								+ "then 0 else hold_qty end)-? "
 								+ " Where item_code  =?"
 								+ "And site_code    = ?"
 								+ " And loc_code = ? "
-								+ "And lot_no = ? And lot_sl= ? ;";
+								+ "And lot_no = ? And lot_sl= ?";
 
 						pstmtUpd = conn.prepareStatement(sql);
-						pstmtUpd.setString(1, itemCode);
-						pstmtUpd.setString(2, siteCode);
-						pstmtUpd.setString(3, locCode);
+						pstmtUpd.setDouble(1, lcholdQty);
+						pstmtUpd.setString(2, itemCode);
+						pstmtUpd.setString(3, siteRcp);
+						pstmtUpd.setString(4, locCodeGit);
+						pstmtUpd.setString(5, lotNo);
+						pstmtUpd.setString(6, lotSl);
 						updCnt = pstmtUpd.executeUpdate();
 						System.out.print("HoldQty Updated" + lcholdQty);
 						
 
-						if (updCnt != 1) {
-							errString = itmDBAccessLocal.getErrorString("",
-									"DS000", "");
-						}
 						pstmtUpd.close();
 						pstmtUpd = null;
 
@@ -1862,6 +1885,7 @@ public class PoRcpConf extends ActionHandlerEJB implements PoRcpConfLocal,
 						sql = "select count(1) from porddet where purc_order =  ? And (case when status is null then ' ' else status end) <> 'C' ";
 						pstmt1 = conn.prepareStatement(sql);
 						pstmt1.setString(1, purcOrder);
+						System.out.print("in count loop");
 						rs1 = pstmt1.executeQuery();
 						if (rs1.next()) {
 							count = rs1.getInt(1);
@@ -1876,6 +1900,7 @@ public class PoRcpConf extends ActionHandlerEJB implements PoRcpConfLocal,
 							pstmtUpd = conn.prepareStatement(sql);
 							pstmtUpd.setString(1, purcOrder);
 							updCnt = pstmtUpd.executeUpdate();
+							System.out.println("in update");
 							if (updCnt != 1) {
 								errString = itmDBAccessLocal.getErrorString("",
 										"DS000NR", "");// Added by chandrashekar
@@ -1889,6 +1914,7 @@ public class PoRcpConf extends ActionHandlerEJB implements PoRcpConfLocal,
 
 				// Added by Jasmina-28/11/08- EO89SUN002,
 				// site is eou than update the qty used in ct3form table.
+				System.out.println("outside update");
 				if ("Y".equals(EOU) && "N".equals(dutyPaid)) {
 
 					sql = "select a.status as status , b.line_no as line_no, (case when b.quantity is null then 0 else b.quantity end) quantity, "