PB code commented and migrated to java on submit

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

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

@@ -32,22 +32,35 @@ public class CustStockGWTConf extends ActionHandlerEJB implements CustStockGWTCo
 	public String submit(String tranId, String xtraParams, String forcedFlag)throws RemoteException, ITMException
 	{
 		System.out.println(">>>>>>>>>>>>>>>>>>CustStockGWTConf submit called>>>>>>>>>>>>>>>>>>>");
-		String sql = "",status="",confirmed="";
+		String sql = "",status="",confirmed="",sql1="",sql2="";
 		Connection conn = null;
 		PreparedStatement pstmt = null;
+		PreparedStatement pstmt1 = null;
+		PreparedStatement pstmt2 = null;
 		String errString = null;
 		ResultSet rs = null;
+		ResultSet rs1 = null;
+		ResultSet rs2 = null;
 		String methodName = "";
 		String compName = "";
 		String retString = "";
 		String serviceCode = "";
 		String serviceURI = "";
 		String actionURI = "";
-		int cnt = 0;
+		String missingInserted="",transitUpdate="",loginEmpCode="";
+		String transitFlag="",siteCode="",custCode="",totclValue="",totSalesValue="",tranType="",stockMode="";
+		String lineNo="",invoiceId="",itemCode="";
+		double transitQty=0.0,invoiceQty=0.0,clStock=0.0;
+		int cnt = 0,cnfCnt=0;
+		Timestamp currDate = null,tranDate=null;
 		ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
+		E12GenericUtility genericUtility= new  E12GenericUtility();
 		try
 		{
-
+			loginEmpCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode");
+			SimpleDateFormat sdf1 = new SimpleDateFormat(genericUtility.getDBDateFormat());
+			currDate =  java.sql.Timestamp.valueOf(sdf1.format(new java.util.Date()).toString() + " 00:00:00.0");
+			System.out.println("currDate>>>>"+currDate);
 			ConnDriver connDriver = null;
 			connDriver = new ConnDriver();
 			conn = connDriver.getConnectDB("DriverITM");
@@ -56,7 +69,7 @@ public class CustStockGWTConf extends ActionHandlerEJB implements CustStockGWTCo
 			if (tranId != null && tranId.trim().length() > 0)
 			{
 				System.out.println("tranId>>>["+tranId+"]");
-				sql = "	select status,confirmed from  cust_stock where tran_id = ? ";
+				sql = "	select status,confirmed,missing_inserted, transit_update from  cust_stock where tran_id = ? ";
 				pstmt = conn.prepareStatement(sql);
 				pstmt.setString(1, tranId);
 				rs = pstmt.executeQuery();
@@ -64,6 +77,8 @@ public class CustStockGWTConf extends ActionHandlerEJB implements CustStockGWTCo
 				{
 					status = rs.getString("status");
 					confirmed = rs.getString("confirmed");
+					missingInserted = rs.getString("missing_inserted");
+					transitUpdate = rs.getString("transit_update");
 				}
 				rs.close();
 				rs = null;
@@ -72,6 +87,164 @@ public class CustStockGWTConf extends ActionHandlerEJB implements CustStockGWTCo
 				System.out.println("status>>>>>>>>"+status);
 				if(!"Y".equalsIgnoreCase(confirmed) && !"S".equalsIgnoreCase(status))
 				{
+					//start added by chandrashekar on 31-dec-2015
+					
+					if(!"Y".equalsIgnoreCase(missingInserted))
+					{
+						errString = itmDBAccessLocal.getErrorString("", "VTMISSITEM", "");
+						return errString;
+					}
+					
+					if(transitUpdate == null || transitUpdate.trim().length()==0 || "N".equalsIgnoreCase(transitUpdate))
+					{
+						sql = "	select transit_flag, site_code, cust_code, tran_date, tot_cl_value, tot_sales_value,tran_type" +
+								" from  cust_stock where tran_id = ? ";
+						pstmt = conn.prepareStatement(sql);
+						pstmt.setString(1, tranId);
+						rs = pstmt.executeQuery();
+						if (rs.next()) 
+						{
+							transitFlag = rs.getString("transit_flag");
+							siteCode = rs.getString("site_code");
+							custCode = rs.getString("cust_code");
+							tranDate = rs.getTimestamp("tran_date");
+							totclValue = rs.getString("tot_cl_value");
+							totSalesValue = rs.getString("tot_sales_value");
+							tranType = rs.getString("tran_type");
+						}
+						rs.close();
+						rs = null;
+						pstmt.close();
+						pstmt = null;	
+						
+						sql = " SELECT VAR_VALUE FROM DISPARM WHERE PRD_CODE = '999999' AND VAR_NAME = 'CUST_STOCK_MODE'";
+						pstmt = conn.prepareStatement(sql);
+						rs = pstmt.executeQuery();
+						if (rs.next())
+						{
+							stockMode = checkNull(rs.getString("VAR_VALUE"));
+							System.out.println("stockMode :" + stockMode);
+						}
+						rs.close();
+						rs = null;
+						pstmt.close();
+						pstmt = null;
+						if(stockMode == null || "NULLFOUND".equalsIgnoreCase(stockMode)|| stockMode.trim().length()==0)
+						{
+							stockMode="S";
+						}
+						if(transitFlag == null || transitFlag.trim().length()==0)
+						{
+							transitFlag="N";
+						}
+						if("S".equalsIgnoreCase(tranType))
+						{
+							sql = "Select line_no, item_code, transit_qty, cl_stock, sales,op_stock, purc_rcp," +
+									" adj_qty, purc_ret, adhoc_repl_qty, unit	" +
+									"From cust_stock_det Where tran_id = ? " +
+									"and case when transit_qty is null then 0 else transit_qty end = 0";
+							pstmt = conn.prepareStatement(sql);
+							pstmt.setString(1, tranId);
+							rs = pstmt.executeQuery();
+							while (rs.next()) 
+							{
+								lineNo = rs.getString("line_no");
+								clStock = rs.getDouble("cl_stock");
+								transitQty = rs.getDouble("transit_qty");
+								itemCode = rs.getString("item_code");
+								
+								System.out.println("itemcode@@@@@@>>"+itemCode);
+								sql1 = "update cust_stock_det set original_cl_stock = ? "
+										+ "where tran_id 	= ? and 	line_no	= ?";
+								pstmt1 = conn.prepareStatement(sql1);
+								pstmt1.setDouble(1, clStock);
+								pstmt1.setString(2, tranId);
+								pstmt1.setString(3, lineNo);
+								cnt = pstmt1.executeUpdate();
+								pstmt1.close();
+								pstmt1 = null;
+
+								if (transitQty == 0)
+								{
+									sql1 = "Select invoice_id From cust_stock_inv Where tran_id = ? and dlv_flg = 'N'";
+									pstmt1 = conn.prepareStatement(sql1);
+									pstmt1.setString(1, tranId);
+									rs1 = pstmt1.executeQuery();
+									while (rs1.next())
+									{
+										invoiceId = checkNull(rs1.getString("invoice_id"));
+										System.out.println("invoiceId :" + invoiceId);
+
+										sql2 = "Select sum(quantity__stduom) as invoice_qty From 	 " 
+										+ "invdet	Where  invoice_id = ? " + "and 	 item_code  = ? ";
+										pstmt2 = conn.prepareStatement(sql2);
+										pstmt2.setString(1, invoiceId);
+										pstmt2.setString(2, itemCode);
+										rs2 = pstmt2.executeQuery();
+										if (rs2.next())
+										{
+											invoiceQty = rs2.getDouble("invoice_qty");
+											System.out.println("invoiceQty :" + invoiceQty);
+										}
+										rs2.close();
+										rs2 = null;
+										pstmt2.close();
+										pstmt2 = null;
+
+										transitQty = transitQty + invoiceQty;
+									}// invoice loop
+									rs1.close();
+									rs1 = null;
+									pstmt1.close();
+									pstmt1 = null;
+								}
+								if (transitQty != 0)
+								{
+									sql = "update cust_stock_det set transit_qty 	=  ? " 
+											+ " where tran_id 	= ?	" 
+											+ " and	line_no = ? ";
+									pstmt1 = conn.prepareStatement(sql);
+									pstmt1.setDouble(1, transitQty);
+									pstmt1.setString(2, tranId);
+									pstmt1.setString(3, lineNo);
+									cnt = pstmt1.executeUpdate();
+									pstmt1.close();
+									pstmt1 = null;
+								}
+
+							}//cust_stock_det loop
+							rs.close();
+							rs = null;
+							pstmt.close();
+							pstmt = null;
+							
+							sql = "update cust_stock	set transit_upd_flag  = 'Y'	where tran_id = ? ";
+							pstmt1 = conn.prepareStatement(sql);
+							pstmt1.setString(1, tranId);
+							cnt = pstmt1.executeUpdate();
+							pstmt1.close();
+							pstmt1 = null;
+							
+						}
+						
+					}
+					sql = " update cust_stock set confirmed = 'Y', conf_date = ?, emp_code__aprv = ?,status = 'S' " +
+							" where tran_id = ? ";
+					pstmt = conn.prepareStatement(sql);
+					pstmt.setTimestamp(1, currDate);
+					pstmt.setString(2, loginEmpCode);
+					pstmt.setString(3, tranId);
+					cnfCnt = pstmt.executeUpdate();
+					pstmt.close();
+					pstmt = null;
+					if (cnfCnt>0) 
+					{	
+						conn.commit();
+						errString = itmDBAccessLocal.getErrorString("", "VTSUBM1", "");
+					}
+					//End added by chandrashekar on 31-dec-2015
+					/*
+					
 					methodName = "gbf_post";
 					actionURI = "http://NvoServiceurl.org/" + methodName;
 
@@ -130,7 +303,7 @@ public class CustStockGWTConf extends ActionHandlerEJB implements CustStockGWTCo
 							conn.commit();
 
 						}
-					}
+					}*///commented by chandrashekar on 04-01-2016
 				}else
 				{
 					errString = itmDBAccessLocal.getErrorString("", "VTINVSUB2", "");
@@ -293,5 +466,12 @@ public class CustStockGWTConf extends ActionHandlerEJB implements CustStockGWTCo
 		return errString;
 
 	}
-
+	private String checkNull(String input)	
+	{
+		if (input == null)
+		{
+			input="";
+		}
+		return input;
+	}
 }
\ No newline at end of file