Updated changes for dwh_sales_sum insert schedular is created for it

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

webitm-dashboard/ibase/dashboard/fin/ejb/DWHCompleteEJB.java

@@ -612,6 +612,8 @@ public class DWHCompleteEJB extends ValidatorEJB
 		
 		PreparedStatement pstmt = null;
 		ResultSet rs = null;
+		PreparedStatement pstmt1 = null;
+		ResultSet rs1 = null;
 		Connection conn=null;
 
 		try 
@@ -624,20 +626,31 @@ public class DWHCompleteEJB extends ValidatorEJB
 			System.out.println("trans data array length :::: "+ transDataArray.length());
 			for(int i = 0, tansdata = transDataArray.length(); i < tansdata; i++) {
 				StringBuffer deleteSql = new StringBuffer();
+				StringBuffer selectSql = new StringBuffer();
 				JSONObject transDataObj = transDataArray.optJSONObject(i);
 				String refId =transDataObj.optString("ref_id");
 				String refSer =transDataObj.optString("ref_ser");
 				String refDate =transDataObj.optString("ref_date");
 				//refDate=genericUtility.getValidDateString(refDate, sourceDateFormat, targetDateFormat);
 				System.out.println("DWHCompleteEJB ==== Delete query for transaction of records in DWH_SALES_SUM [" +refId+"] refSer ["+refSer+"] refDate ["+refDate+"]");
-				deleteSql.append("DELETE FROM DWH_SALES_SUM WHERE TRAN_ID = '"+refId+"' AND DOC_DATE = TO_DATE('"+refDate+"','"+sourceDateFormat+"') AND  REF_SER ='"+refSer+"'");
-				System.out.println("delete sql ::::: "+deleteSql);
-				pstmt = conn.prepareStatement(deleteSql.toString());
+				selectSql.append("SELECT * FROM DWH_SALES_SUM WHERE TRAN_ID = '"+refId+"' AND DOC_DATE = TO_DATE('"+refDate+"','"+sourceDateFormat+"') AND  REF_SER ='"+refSer+"'");
+				pstmt = conn.prepareStatement(selectSql.toString());
 				rs    = pstmt.executeQuery();
+				if(rs.next()) {
+					System.out.println("Inside delete");
+					deleteSql.append("DELETE FROM DWH_SALES_SUM WHERE TRAN_ID = '"+refId+"' AND DOC_DATE = TO_DATE('"+refDate+"','"+sourceDateFormat+"') AND  REF_SER ='"+refSer+"'");
+					System.out.println("delete sql ::::: "+deleteSql);
+					pstmt1 = conn.prepareStatement(deleteSql.toString());
+					rs1    = pstmt1.executeQuery();
+					pstmt1.close();
+					rs1.close();
+					pstmt1 = null;
+					rs1 = null;				
+				}
 				pstmt.close();
 				rs.close();
 				pstmt = null;
-				rs = null;
+				rs = null;		
 
 			}
 			conn.commit();
@@ -662,6 +675,16 @@ public class DWHCompleteEJB extends ValidatorEJB
 					rs.close();
 					rs = null;
 				}
+				if( pstmt1 != null )
+				{
+					pstmt1.close();
+					pstmt1 = null;
+				}
+				if ( rs1 != null )
+				{
+					rs1.close();
+					rs1 = null;
+				}
 				if ( conn != null )
 				{
 					conn.close();