When user enter campaign no system release all work order associated with that...

When user enter campaign no system release all work order associated with that campaign no in work order release


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

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

@@ -78,6 +78,8 @@ public class WorkorderRelease extends ProcessEJB implements WorkorderReleaseLoca
 		PreparedStatement pstmtInsert = null;
 		ResultSet rs = null;
 		String workOrder = null;
+		String campgnNo=null;
+		//String workOrder1=null;
 		String retString = "" ;
 		String errString = "";
 		String errCode = "";
@@ -86,6 +88,9 @@ public class WorkorderRelease extends ProcessEJB implements WorkorderReleaseLoca
 		String chgUser = "";
 		String userId = null;
 		String chgTerm = "";
+		ArrayList workOrderList=new ArrayList();//added by priyanka
+		boolean result=false;
+		boolean updateFlag=false;
 	
 		String sql = null, mfgDateOn = "";
 
@@ -99,6 +104,7 @@ public class WorkorderRelease extends ProcessEJB implements WorkorderReleaseLoca
 		try
 		{
 		
+			System.out.println("Enter in process ======================");
 			connDriver = new ConnDriver();
 			conn = connDriver.getConnectDB( "DriverITM" );
 			conn.setAutoCommit( false );
@@ -109,14 +115,94 @@ public class WorkorderRelease extends ProcessEJB implements WorkorderReleaseLoca
 			userId = chgUser;
 
 			workOrder =	genericUtility.getColumnValue( "work_order", headerDom );
+			campgnNo =	genericUtility.getColumnValue( "campgn_no", headerDom );
+			System.out.println("workOrder========"+workOrder);
+			System.out.println("campgnNo========"+campgnNo);
 		
+			// added by priyanka as per manoj sharma instruction on 29/08/14
+			//validation : user is allow to enter either workorder no or campaign no 
+			//on process of campaign no,system release all the work order associated with that  Campaign No
+			 if((workOrder==null || workOrder.trim().length()==0) && (campgnNo==null|| campgnNo.trim().length()==0))
+			 {
+				errString = itmDBAccessEJB.getErrorString( "", "VTCMPWORD", userId );
+				System.out.println("@@@@@@@@@ errString@@@@@@@@" +errString);
+				return errString;				 
+			 }
+			
+			 if((workOrder!=null && workOrder.trim().length()>0 && campgnNo==null||campgnNo.trim().length()==0)||(campgnNo!=null && campgnNo.trim().length()>0 && workOrder==null||workOrder.trim().length()==0))
+			 {
+				System.out.println("Its Working");				
+			 }
 			 
-			if(workOrder == null || workOrder.trim().length()== 0)
+			 else if(workOrder!=null && workOrder.trim().length()>0 && campgnNo!=null && campgnNo.trim().length()>0)
 			 {
-				errString = itmDBAccessEJB.getErrorString( "", "VTWORDER1", userId );
+				errString = itmDBAccessEJB.getErrorString( "", "VTWORDCPNO", userId );
 				System.out.println("@@@@@@@@@ errString@@@@@@@@" +errString);
 				return errString;
 			 }
+			 
+			 if(workOrder!=null && workOrder.trim().length()>0)
+			 {
+				 if (!(isExist(conn, "workorder", "work_order", workOrder)))
+					{
+					    errString = itmDBAccessEJB.getErrorString( "", "VTWORDNO", userId );
+						System.out.println("@@@@@@@@@ errString@@@@@@@@" +errString);
+						return errString;
+					}				 
+			 }
+			 
+			if(campgnNo!=null && campgnNo.trim().length()>0)
+			 {
+				 if (!(isExist(conn, "workorder", "campgn_no", campgnNo)))
+					{
+					    errString = itmDBAccessEJB.getErrorString( "", "VTCMPGNO", userId );
+						System.out.println("@@@@@@@@@ errString@@@@@@@@" +errString);
+						return errString;
+					}				 
+			 }
+			
+			if(campgnNo!=null && campgnNo.trim().length()>0)
+			{
+				System.out.println("IF==========");
+				sql="select work_order from workorder where campgn_no= ? and status= 'F'";
+				pstmt = conn.prepareStatement( sql );
+				pstmt.setString(1,campgnNo);				
+				rs=pstmt.executeQuery();
+				while(rs.next())
+				{
+					workOrder=rs.getString("work_order");
+					System.out.println("Getting workorder against Campaign No==========="+workOrder);					
+					workOrderList.add(workOrder);
+					System.out.println("workOrderList Size============="+workOrderList.size());
+					System.out.println("workOrderList============="+workOrderList);		
+					result=true;
+					System.out.println("result==========="+result);
+					
+				}
+				rs.close();
+				rs = null;
+				pstmt.close();
+				pstmt = null;
+				
+			}
+			else
+			{
+				System.out.println("else==========");
+				
+				workOrder=genericUtility.getColumnValue( "work_order", headerDom );
+				workOrderList.add(workOrder);
+				System.out.println("Getting workorder==========="+workOrder);
+				result=false;
+				System.out.println("result==========="+result);
+				
+			}
+			
+			for(int i =0;i<workOrderList.size();i++)
+			{
+				workOrder=(String) workOrderList.get(i);
+				System.out.println("Total WorkOrder==================="+workOrder);
+			
+			
 				if ((CommonConstants.DB_NAME).equalsIgnoreCase("db2") || (CommonConstants.DB_NAME).equalsIgnoreCase("mysql") )
 				{
 					sql = "SELECT SITE_CODE, BOM_CODE, STATUS, ORDER_TYPE, "
@@ -209,7 +295,10 @@ public class WorkorderRelease extends ProcessEJB implements WorkorderReleaseLoca
 					if (count > 0 )
 					{
 						errString = itmDBAccessEJB.getErrorString("","VTWOEUNCF",userId);				
-					return errString;
+						//return errString;				 
+						System.out.println("before continue===========");
+						continue;
+					
 					}
 					//***************** TO BE MIGRATED LATER ******************************************
 					//Added by Sharon on 15-Feb-04 //This function will generate a PO if any item is subcontracted
@@ -405,8 +494,15 @@ public class WorkorderRelease extends ProcessEJB implements WorkorderReleaseLoca
 					pstmtInsert.setTimestamp(3,dueDate);
 					pstmtInsert.setString(4,workOrder);
 					count = pstmtInsert.executeUpdate();
+					if(count>0)
+					{
+						System.out.println(">>>>>>>>>>>>>>>>Count from update:"+count);
+						updateFlag=true;
+					}
 					pstmtInsert.close();
 					pstmtInsert =null;
+					
+				}			
 			}
 						
 		}    					
@@ -439,12 +535,17 @@ public class WorkorderRelease extends ProcessEJB implements WorkorderReleaseLoca
                      oracleConnection = null;
                  }*/
 				
-				if( errString == null || errString.trim().length() == 0 )
+				if( errString == null || errString.trim().length() == 0)
 				{
 					conn.commit();
 					System.out.println("Transaction Commit!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
 					errString =	itmDBAccessEJB.getErrorString( "", "VTCOMPL", userId );
 				}
+				else if(errString!=null && errString.trim().length()>0 && result==true && updateFlag==true)
+				{
+					System.out.println(">>>>>>>>>>>>>>>>>>>>If result is true ,commit");
+					conn.commit();
+				}
 				else
 				{
 					conn.rollback();
@@ -467,4 +568,40 @@ public class WorkorderRelease extends ProcessEJB implements WorkorderReleaseLoca
 	    return errString;
     }//END OF PROCESS
 	
+	
+
+	private boolean isExist(Connection conn, String tableName, String columnName, String value) throws ITMException, RemoteException
+	{
+		PreparedStatement pstmt = null;
+		ResultSet rs = null;
+		String sql = "";
+		boolean status = false;
+		try
+		{
+			sql = "SELECT count(*) from " + tableName + " where " + columnName + "  = ? ";
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setString(1, value);
+			rs = pstmt.executeQuery();
+
+			if (rs.next())
+			{
+				if (rs.getBoolean(1))
+				{
+					status = true;
+				}
+			}
+			rs.close();
+			rs = null;
+			pstmt.close();
+			pstmt = null;
+		} catch (Exception e)
+		{
+			System.out.println("Exception in isExist ");
+			e.printStackTrace();
+			throw new ITMException(e);
+		}
+		System.out.println("returning String from isExist ");
+		return status;
+	}
+
  } // END OF EJB 
\ No newline at end of file