updated

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

webitm-mfg/ibase/webitm/ejb/mfg/WoTransferPrc.java

@@ -13,6 +13,8 @@ import ibase.webitm.utility.GenericUtility;
 import ibase.webitm.utility.ITMException;
 import ibase.webitm.utility.TransIDGenerator;
 
+import java.io.File;
+import java.io.FileWriter;
 import java.rmi.RemoteException;
 import java.sql.Connection;
 import java.sql.PreparedStatement;
@@ -122,7 +124,7 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
 
 		try
 		{
-			System.out.println("WoTransferPrc getData called :: ::");
+			System.out.println("WoTransferPrc getData 5-4-0-36 called :: ::");
 			ConnDriver connDriver = new ConnDriver();
 			conn = connDriver.getConnectDB("DriverITM");
 			connDriver = null;
@@ -144,7 +146,7 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
 			}
 			if(worder != null && worder.trim().length()  > 0)
 			{
-				sql = "select count(*) from workorder where work_order = ?  and status not in ('F') ";
+				sql = "select count(*) from workorder where work_order = ?  and status  in ('R') ";
 				pstmt = conn.prepareStatement(sql);
 				pstmt.setString(1,worder);
 			    rs = pstmt.executeQuery();
@@ -1070,6 +1072,12 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
 					String tranIdForIssue = arrayForTranId[1].substring(0,endIndex);
 					System.out.println("-tranIdForIssue-"+tranIdForIssue);
 					
+					StockTransferConf stconf = new StockTransferConf();
+					retString = stconf.confirm(tranIdForIssue,xtraParams,"");
+					System.out.println("retString from StockTransferConf  :: @:: "+retString);//CONFSUCC
+					if(retString.indexOf("CONFSUCC") > -1)
+					{ 
+							
 							stockMap.put("item_code", itemCode);
 							stockMap.put("site_code", siteCode);
 							stockMap.put("loc_code", locCodeFr);
@@ -1098,14 +1106,14 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
 								pstmt.close();
 							pstmt = null;
 		
-//					//if(invStatLocCodeTo.trim().equalsIgnoreCase(locCodeTo.trim()) && invStatLocCodeTo.trim().equalsIgnoreCase(partialGrlLoc.trim()))
-//					{
-//						stockMap.put("no_art", allocQty);
-//					}
-//					else
-//					{
+		//					//if(invStatLocCodeTo.trim().equalsIgnoreCase(locCodeTo.trim()) && invStatLocCodeTo.trim().equalsIgnoreCase(partialGrlLoc.trim()))
+		//					{
+		//						stockMap.put("no_art", allocQty);
+		//					}
+		//					else
+		//					{
 								stockMap.put("no_art", noArt);
-//					}
+		//					}
 		
 							stockMap.put("tran_ser", "XFRX");
 							stockMap.put("acct_code__cr",acctCodeInv1);
@@ -1211,12 +1219,13 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
 							stockMap.clear();
 							if(isError == false)
 							{
+								retString = "CONFSUCC";
 								System.out.println(" STOCK ALLOCATED SUCCESSFULL");
-						StockTransferConf stconf = new StockTransferConf();
-						retString = stconf.confirm(tranIdForIssue,xtraParams,"");
-						System.out.println("retString from confirmStocktrans  :: @:: "+retString);//CONFSUCC
-						if(retString.indexOf("CONFSUCC") > -1)
-						{ 
+		//						StockTransferConf stconf = new StockTransferConf();
+		//						retString = stconf.confirm(tranIdForIssue,xtraParams,"");
+		//						System.out.println("retString from confirmStocktrans  :: @:: "+retString);//CONFSUCC
+		//						if(retString.indexOf("CONFSUCC") > -1)
+		//						{ 
 									int count = 0,recIn=0 ;
 									sql = " select count(*) from inv_alloc_det where tran_id = ? and item_code  = ? and lot_no = ? and lot_sl = ? and loc_code =  ? and site_code = ? ";
 									pstmt = connOne.prepareStatement(sql);
@@ -1361,6 +1370,7 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
 											pstmt.close();
 										pstmt = null;
 									}
+								//	}
 								}
 						}
 		}
@@ -1470,8 +1480,12 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
 		ArrayList retValue = new ArrayList();
 		HashMap hashMap = null;
 		HashMap tempMap = null ;
+	//	Connection conn1 = null;
 		try
 		{
+			//ConnDriver connDriver = new ConnDriver();
+		//	conn1 = connDriver.getConnectDB("DriverITM");
+			//connDriver = null;
 			String dbDateFormat = genericUtility.getDBDateFormat();
 			String applDateFormat = genericUtility.getApplDateFormat();//--
 			SimpleDateFormat sdfD = new SimpleDateFormat(applDateFormat);//--
@@ -1598,7 +1612,7 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
 				stockMap.put("quantity", ""+stockQty);
 				stockMap.put("qty_stduom", ""+stockQty);
 				//stock update for tran type = "I"
-				errString = updateStock( stockMap, xtraParams, conn ); //updateStock called only once's
+				errString = updateStock( stockMap, xtraParams, conn ); //updateStock ALLOC_QTY 
 				System.out.println("stock update FOR I ....."+errString);
 				if ( errString != null && errString.trim().length() > 0 )
 				{
@@ -1634,7 +1648,7 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
 						do  //iterate rs for deallcation 
 						{
 							splitQty = 0;
-						    refSer = checkNull(rs.getString( "ref_ser" )) ;
+						    refSer = checkNull(rs.getString( "ref_ser" ));
 							refId = checkNull(rs.getString( "ref_id" ));
 						//	//refLine = rs.getInt("ref_line");
 							refLine = Integer.parseInt( checkNull(rs.getString("ref_line")).trim().length() == 0 ?"0":rs.getString("ref_line").trim()) ;
@@ -1673,8 +1687,9 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
 							hashMap.put("alloc_qty",new Double(quantity)); 
 							hashMap.put("chg_user",GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams,"loginCode"));
 							hashMap.put("chg_term",GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams,"termId"));
-							errString = invAllocTrace.updateInvallocTrace(hashMap, conn);
-							System.out.println("updateInvallocTrace 2....."+errString);
+					//		errString = invAllocTrace.updateInvallocTrace(hashMap, conn);  // COMMENTED FOR USE EXISTING METHOD 
+							errString = updateInvallocTrace(hashMap, conn);
+							System.out.println("updateInvallocTrace 2.LOCAL...."+errString);
 							if ( errString != null && errString.trim().length() > 0 )
 							{
 								retValue.add("Error");
@@ -1683,6 +1698,12 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
 							}
 							else  
 							{
+//								if(conn1 != null)
+//								{
+//									conn1.commit();
+//									conn1.close();
+//									conn = null;
+//								}
 								System.out.println("DeAlloc updateInvallocTrace(HashMap, Connection) : Sucessuful!");
 								System.out.println("refSer:::::"+refSer);
 								if("S-ORD".equalsIgnoreCase(refSer.trim())) //sale order
@@ -2521,7 +2542,6 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
 					}
 				}
 			}
-
 			rs.close();
 			rs = null;
 			if(pstmt != null)
@@ -5667,4 +5687,333 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
         System.out.println("Returning Value from adjustStkValue : "+errString);
         return errString;
     }
+	public String updateInvallocTrace(HashMap invallocTraceMap, Connection conn) throws ITMException,Exception
+	{
+
+		String fileDest = "";
+		double tempAllocQty = 0;
+		try
+		{
+			//changes by gulzar on 12/12/2011 to write the log file in jboss log location  
+			//f = new FileWriter("invalloc.log", true); 
+			fileDest = CommonConstants.JBOSSHOME + File.separator + "server" + File.separator + "default" + File.separator + "log" + File.separator + "invalloc.log";
+			//f = new FileWriter( fileDest, true); 
+		}
+		catch(Exception e)
+		{
+			System.out.println(e.getMessage());
+		//	writeException(e, fileDest );
+		}
+		String errString = "";
+		String errCode = "" ;
+		String sql = null ;
+		String sqlUpdate = null ;
+		String keyStringQuery = null ;
+		CommonConstants commonConstants = new CommonConstants();
+		String refSer = (String)invallocTraceMap.get("ref_ser");
+		String refId = (String)invallocTraceMap.get("ref_id");
+		String refLine = (String)invallocTraceMap.get("ref_line");
+		String siteCode = (String)invallocTraceMap.get("site_code");
+		String itemCode = (String)invallocTraceMap.get("item_code");
+		String locCode = (String)invallocTraceMap.get("loc_code");
+		String lotNo = (String)invallocTraceMap.get("lot_no");
+		String lotSl = (String)invallocTraceMap.get("lot_sl");
+		double allocQty = ((Double)invallocTraceMap.get("alloc_qty")).doubleValue();
+		String chgUser = (String)invallocTraceMap.get("chg_user");
+	    String chgTerm = (String)invallocTraceMap.get("chg_term");
+	    String chgWin = (String)invallocTraceMap.get("chg_win");
+	    if(lotNo == null)
+		lotNo = " ";
+		if(lotSl == null)
+		lotSl = " ";
+
+		//Changed by gulzar on 12/12/2011
+		if ( chgUser == null || chgUser.trim().length() == 0 )
+		{
+			chgUser = "SYSTEM";
+		}
+		if ( chgTerm == null || chgTerm.trim().length() == 0 )
+		{
+			chgTerm = "SYSTEM";
+		}
+		//End changes by gulzar on 12/12/2011
+	    
+		java.sql.Date chgDate = new java.sql.Date(System.currentTimeMillis());
+		java.sql.Date tranDate = new java.sql.Date(System.currentTimeMillis());
+		PreparedStatement pstmt = null ;
+		ResultSet rSet = null, rs = null ;
+		Statement stmt = null ;
+		String tranId = null ;
+	   
+	    try
+	    {
+	    	keyStringQuery = "SELECT KEY_STRING, TRAN_ID_COL, REF_SER FROM TRANSETUP WHERE UPPER(TRAN_WINDOW) = 'T_ALLOCTRACE'";
+	    	System.out.println("keyStringQuery--------->>"+keyStringQuery);
+	 
+			stmt = conn.createStatement();
+			rSet = stmt.executeQuery(keyStringQuery);
+			System.out.println("keyString :"+rSet.toString());
+			String tranSer1 = "";
+			String keyString = "";
+			String keyCol = "";
+			if (rSet.next())
+			{
+				keyString = rSet.getString(1);
+				keyCol = rSet.getString(2);
+				tranSer1 = rSet.getString(3);				
+			}
+			rSet.close();
+			stmt.close();
+			rSet = null;
+			stmt = null;
+			// 31/10/13 manoharan locking to be done before allocation
+			if (CommonConstants.DB_NAME.equalsIgnoreCase("DB2") || CommonConstants.DB_NAME.equalsIgnoreCase("MYSQL") ){
+				sql =" select alloc_qty from stock where item_code = ?"
+			  	+" and site_code = ?" 
+				+" and loc_code  = ?" 
+				+" and lot_no = ?"
+				+"and lot_sl = ? for update ";
+			}
+			else if (CommonConstants.DB_NAME.equalsIgnoreCase("MSSQL")){
+				sql =" select alloc_qty from stock (updlock) where item_code = ?"
+			  	+" and site_code = ?" 
+				+" and loc_code  = ?" 
+				+" and lot_no = ?"
+				+"and lot_sl = ?  ";
+			}
+			else
+			{
+				sql =" select alloc_qty from stock where item_code = ?"
+			  	+" and site_code = ?" 
+				+" and loc_code  = ?" 
+				+" and lot_no = ?"
+				+"and lot_sl = ? for update nowait ";
+				
+			}
+			
+            pstmt = conn.prepareStatement(sql);
+			pstmt.setString(1,itemCode);
+			pstmt.setString(2,siteCode);
+			pstmt.setString(3,locCode);
+			pstmt.setString(4,lotNo);
+			pstmt.setString(5,lotSl);
+			
+			rs = pstmt.executeQuery();
+			if(rs.next())
+			{
+				tempAllocQty = rs.getDouble(1);
+			}
+			else
+			{
+				errString = "VTLCKERR";
+			}
+			pstmt.close();
+			rs.close();
+			if (errString != null && errString.trim().length() > 0)
+			{
+				return errString;
+			}
+
+				
+			// end 
+			
+		//	f.write(keyString + " " + keyCol + " " + tranSer1+ "\r\n");
+			System.out.println("keyString :"+ keyString);
+			System.out.println("keyCol :"+ keyCol);
+			System.out.println("tranSer1 :"+ tranSer1);
+			String xmlValues = "";
+			String tranDateStr = getCurrdateAppFormat(); //added by rajendra on 17/04/09 for tran date
+			xmlValues ="<?xml version=\"1.0\" encoding=\"utf-8\"?><Root>";
+			xmlValues = xmlValues + "<Header></Header>";
+			xmlValues = xmlValues + "<Detail1>";
+			xmlValues = xmlValues +	"<tran_id></tran_id>";
+			xmlValues = xmlValues + "<site_code>" + siteCode + "</site_code>";
+			xmlValues = xmlValues + "<tran_date>" + tranDateStr + "</tran_date>"; //added by rajendra on 17/04/09
+			xmlValues = xmlValues +"</Detail1></Root>";
+			System.out.println("xmlValues  :["+xmlValues+"]");
+			TransIDGenerator tg = new TransIDGenerator(xmlValues, "BASE", commonConstants.DB_NAME);
+			tranId = tg.generateTranSeqID(tranSer1, keyCol, keyString, conn);
+		//	f.write("trace tran id ... " +tranId + "\r\n");
+			System.out.println("tranId :"+tranId);
+		
+			sql = "INSERT INTO INVALLOC_TRACE (TRAN_ID, TRAN_DATE, REF_SER, REF_ID,"
+				+"REF_LINE,ITEM_CODE, SITE_CODE, LOC_CODE,LOT_NO, LOT_SL, ALLOC_QTY, CHG_WIN," 
+				+"CHG_USER, CHG_TERM, CHG_DATE )VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
+				
+			pstmt = conn.prepareStatement(sql);
+		
+			System.out.println("trans id="+ tranId);
+			System.out.println("tranDate="+ tranDate);
+			System.out.println("refSer="+ refSer);
+			System.out.println("refId="+ refId);
+			System.out.println("refLine="+ refLine);
+			System.out.println("itemCode="+ itemCode);
+			System.out.println("siteCodeShip="+ siteCode);
+			System.out.println("locCode="+ locCode);
+			System.out.println("lotNo="+ lotNo);
+			System.out.println("LOT_SL="+ lotSl);
+			System.out.println("ALLOC_QTY="+ allocQty);
+			System.out.println("chgWin="+ chgWin);
+			System.out.println("chgUser="+ chgUser);
+			System.out.println("chgTerm="+ chgTerm);
+			System.out.println("chgDate="+ chgDate);
+//			f.write("trans id="+ tranId+"\n");
+//			f.write("tranDate="+ tranDate+"\n");
+//			f.write("refSer="+ refSer+"\n");
+//			f.write("refId="+ refId+"\n");
+//			f.write("refLine="+ refLine+"\n");
+//			f.write("itemCode="+ itemCode+"\n");
+//			f.write("locCode="+ locCode+"\n");
+//			f.write("lotNo="+ lotNo+"\n");
+//			f.write("lotSl="+ lotSl+"\n");
+//			f.write("ALLOC_QTY="+ allocQty+"\n");
+			
+			
+		
+			pstmt.setString(1,tranId);
+			pstmt.setDate(2,tranDate);
+			pstmt.setString(3,refSer);
+			pstmt.setString(4,refId);
+			pstmt.setString(5,refLine);
+			pstmt.setString(6,itemCode );
+			pstmt.setString(7,siteCode);
+			pstmt.setString(8,locCode);
+			pstmt.setString(9,lotNo );
+			pstmt.setString(10,lotSl);
+			pstmt.setDouble(11,allocQty);
+			pstmt.setString(12,chgWin);
+			pstmt.setString(13,chgUser);
+			pstmt.setString(14,chgTerm);
+			pstmt.setDate(15,chgDate);
+			pstmt.executeUpdate();
+			
+			//added by msalam on 281209 start
+			pstmt.close();
+			pstmt = null;
+			//added by msalam on 281209 end
+			System.out.println("insertion of sql inside updateInvallocTrace success on date "+ chgDate);
+			
+			System.out.println("Allocate trace Updated...............................");
+		
+			sqlUpdate = "UPDATE STOCK SET ALLOC_QTY =(CASE WHEN ALLOC_QTY IS NULL THEN 0 ELSE ALLOC_QTY END) + ? "
+					  +"WHERE ITEM_CODE = '"+itemCode+"' AND SITE_CODE = '"+ siteCode+"' AND LOC_CODE ='"+locCode+"'  AND LOT_NO = '"+lotNo+"' AND LOT_SL = '"+lotSl+"'";
+			pstmt = conn.prepareStatement(sqlUpdate);
+			pstmt.setDouble(1,allocQty) ;
+			
+				System.out.println("sqlUpdate "+ sqlUpdate);
+				int i = pstmt.executeUpdate() ;
+				pstmt.close();
+				pstmt = null;
+
+				System.out.println("Records updated "+ i);
+//				if(i>0)
+//				{
+//					f.write("sqlUpdate="+ sqlUpdate+"\n"+"Stock update success fully........................."+i+"\n");
+//				}
+//				else
+//				{
+//					throw new ITMException(new Exception("Unable to update stock for [" + sqlUpdate + "]"));
+//				}
+					
+//			}
+			System.out.println("Updated End.") ;
+//			f.write("Updated End..........");
+		}
+		catch(SQLException e)
+		{
+		//	f.write("TRANSATION ROLL BACK IN updateInvallocTrace"+"\n");
+			try{conn.rollback();}catch(Exception ee2){}
+			//writeException(e, fileDest);
+			System.out.println("SQLException :updateInvallocTrace : "  + sqlUpdate + "\n" +e.getMessage());
+			System.out.println("ALLOC_QTY : " + allocQty);
+			System.out.println("ITEM_CODE : " + itemCode);
+			System.out.println("SITE_CODE : " + siteCode);
+			System.out.println("LOC_CODE : " + locCode);
+			System.out.println("LOT_NO : " + lotNo);
+			System.out.println("LOT_SL : " + lotSl);
+			errString = e.getMessage();
+			e.printStackTrace();
+			//return errString;
+			throw new ITMException(e);
+					
+		}
+		catch(Exception e)
+		{
+			//writeException(e, fileDest);
+			System.out.println("Exception :updateInvallocTrace :"  + sqlUpdate + "\n" +e.getMessage());
+			errString = e.getMessage();
+			e.printStackTrace();
+			try
+			{
+			//	f.write("TRANSATION ROLL BACK IN updateInvallocTrace"+"\n");
+				try{conn.rollback();}catch(Exception ee2){}
+			
+			}
+			catch(Exception e1)
+			{
+			//	writeException(e, fileDest);
+				errString = e1.getMessage();
+				e = e1;				
+			}
+			//return errString;	
+			throw new ITMException(e);
+		}
+		finally
+		{
+			try
+			{
+		//		f.close();
+				if(conn != null)
+				{	
+					if(pstmt != null)
+					{
+						pstmt.close();
+						pstmt = null;
+					}
+					if(stmt != null)
+					{
+						stmt.close();
+						stmt = null;
+					}
+				//	conn.close();
+				//	conn = null;
+				}
+			}
+			catch(Exception e)
+			{
+				try{
+					conn.rollback();
+				//f.write("TRANSATION ROLL BACK IN updateInvallocTrace"+"\n");
+				}catch(Exception ee2){}
+				errString = e.getMessage(); 
+				e.printStackTrace();
+				//writeException(e, fileDest);
+				return errString;	
+			}
+			//return errString;	
+		}
+		return errString;
+	
+	}
+	private String getCurrdateAppFormat()
+	{
+        String s = "";
+        GenericUtility genericUtility = GenericUtility.getInstance();
+        try
+        {
+            java.util.Date date = null;
+            Timestamp timestamp = new Timestamp(System.currentTimeMillis());
+            System.out.println(genericUtility.getDBDateFormat());
+
+            SimpleDateFormat simpledateformat = new SimpleDateFormat(genericUtility.getDBDateFormat());
+            date = simpledateformat.parse(timestamp.toString());
+            timestamp = Timestamp.valueOf(simpledateformat.format(date).toString() + " 00:00:00.0");
+            s = (new SimpleDateFormat(genericUtility.getApplDateFormat())).format(timestamp).toString();
+        }
+        catch(Exception exception)
+        {
+            System.out.println("Exception in  getCurrdateAppFormat " + exception.getMessage());
+        }
+        return s;
+    }
 }
\ No newline at end of file