ArrearsDeletePrc.java - file committed given by Piyush sir

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

webitm-adm/src/ibase/webitm/ejb/adm/adv/ArrearsDeletePrc.java

@@ -102,6 +102,7 @@ public class ArrearsDeletePrc extends ProcessEJB implements ArrearsDeletePrcRemo
 		String deleteSql = "", sqlPrd = "";
 		Timestamp frDate = null, toDate = null;
 		PreparedStatement pStmt1 =  null;
+		PreparedStatement pstmt3 =  null; // Modified on 16/10/2019
 		ITMDBAccessEJB itmdbAccessEJB = new ITMDBAccessEJB();
 		try
 		{
@@ -148,6 +149,12 @@ public class ArrearsDeletePrc extends ProcessEJB implements ArrearsDeletePrcRemo
 			{
 				prcGrpTo = "ZZZ";
 			}
+
+			// Modified on 16/10/2019.Start
+			String delPayArrSql = "DELETE FROM PAYARR_TO_PROC WHERE EMP_CODE = ? AND PRD_CODE = ? AND PRD_CODE__ACC IS NULL AND STATUS = 'U' AND PROC_TYPE IN ('PY','AR')";
+			pstmt3 =  con.prepareStatement(delPayArrSql);
+			// Modified on 16/10/2019.End
+
 			//Modified By Poonam B[25-SEP-2019][START]
 			type = E12GenericUtility.checkNull(genericUtility.getColumnValue("type", headerDom));
 			System.out.println("type ===>" +type);
@@ -166,8 +173,13 @@ public class ArrearsDeletePrc extends ProcessEJB implements ArrearsDeletePrcRemo
 				sql.append(" AND ( ARREARS.PRD_CODE <= ? ) AND ( ARREARS.EMP_CODE >= ? ) AND");
 				sql.append("(ARREARS.EMP_CODE <= ?) AND ( ARREARS.SITE_CODE__PAY >= ?) AND (ARREARS.SITE_CODE__PAY <= ?) AND (EMPLOYEE.PROC_GROUP >= ?) AND  ");
 				sql.append("( EMPLOYEE.PROC_GROUP <= ?) AND  ( ARREARS.PRD_CODE__ACC = ? ) AND  ( ARREARS.VOUCHER_NO IS NULL ) AND (CASE WHEN ARREARS.CONFIRMED IS NULL THEN 'N' ELSE ARREARS.CONFIRMED END != 'Y'))");
-				
+
+				// Modified on 16/10/2019.Start
+				/*
 				deleteSql="DELETE FROM ARREARS WHERE PRD_CODE=? AND EMP_CODE=? AND PRD_CODE__ACC=?  AND ( PAYROLL.VOUCHER_NO IS NULL ) AND (CASE WHEN PAYROLL.CONFIRMED IS NULL THEN 'N' ELSE PAYROLL.CONFIRMED END != 'Y')";
+				*/
+				deleteSql="DELETE FROM ARREARS WHERE PRD_CODE=? AND EMP_CODE=? AND PRD_CODE__ACC=?  AND ( ARREARS.VOUCHER_NO IS NULL ) AND (CASE WHEN ARREARS.CONFIRMED IS NULL THEN 'N' ELSE ARREARS.CONFIRMED END != 'Y')";
+				// Modified on 16/10/2019.End
 				
 			}else {
 				sql.append("SELECT PAYROLL.PRD_CODE,PAYROLL.EMP_CODE,PAYROLL.SITE_CODE__PAY,EMPLOYEE.PROC_GROUP FROM PAYROLL,EMPLOYEE");
@@ -219,24 +231,37 @@ public class ArrearsDeletePrc extends ProcessEJB implements ArrearsDeletePrcRemo
 				
 				if(count > 0)
 				{
-					pstmt2.setString(1, prdCode);
-					rs1 = pstmt2.executeQuery();
-					if(rs1.next())
+					// Modified on 16/10/2019.Start
+					if ("PY".equalsIgnoreCase(type))
 					{
-						frDate = rs1.getTimestamp("FR_DATE");
-						toDate = rs1.getTimestamp("TO_DATE");
+						pstmt3.setString(1, prdCode);
+						pstmt3.setString(2, empCode);
+						int count2 = pStmt3.executeUpdate();
+						pStmt3.clearParameters();
+						System.out.println("Payarrtoproc deleted in case of payroll: " +count2);
 					}
-					if(rs1!=null)
+					else
 					{
-						rs1.close();
-						rs1= null;
-					}
-					pstmt2.clearParameters();
-					errString = payarrToProcUpdation( prdCode, prdCode, empCode, empCode, type,  "w_arrears_deletion",  chgTerm , "",0.0,frDate,toDate, xtraParams,  con);
-					if (errString != null && errString.trim().length() > 0)
-					{
-						errorString = itmdbAccessEJB.getErrorString("", errString, userId, "", con);
-						return errString;
+					// Modified on 16/10/2019.End
+						pstmt2.setString(1, prdCode);
+						rs1 = pstmt2.executeQuery();
+						if(rs1.next())
+						{
+							frDate = rs1.getTimestamp("FR_DATE");
+							toDate = rs1.getTimestamp("TO_DATE");
+						}
+						if(rs1!=null)
+						{
+							rs1.close();
+							rs1= null;
+						}
+						pstmt2.clearParameters();
+						errString = payarrToProcUpdation( prdCode, prdCode, empCode, empCode, type,  "w_arrears_deletion",  chgTerm , "",0.0,frDate,toDate, xtraParams,  con);
+						if (errString != null && errString.trim().length() > 0)
+						{
+							errorString = itmdbAccessEJB.getErrorString("", errString, userId, "", con);
+							return errString;
+						}
 					}
 					isSuccess = true;
 					System.out.println("payarrToProcUpdation() successfully executed" +errString);
@@ -266,6 +291,13 @@ public class ArrearsDeletePrc extends ProcessEJB implements ArrearsDeletePrcRemo
 			}
 			//Added By Poonam B[25-SEP-2019][END]
 
+			// Modified on 16/10/2019.Start
+			if(pStmt3 !=null)
+			{
+				pStmt3.close();
+				pStmt3 = null;
+			}
+			// Modified on 16/10/2019.End
 			if(isSuccess)
 			{
 				con.commit();