Skip to content

B
business-java
Commit dd3a1c9d authored by ssalve's avatar ssalve
Browse files
Options

Sarita : Deleted Component as it was in adm.adv package on 05 JULY 19 

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@203006 ce508802-f39f-4f6c-b175-0d175dae99d5
parent d7c36c6d
Show whitespace changes
Inline Side-by-side
Showing with 0 additions and 564 deletions
webitm-adm/ibase/webitm/ejb/adm/EmployeeServicePrdAmdCanc.java deleted 100644 → 0
View file @ d7c36c6d
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Timestamp;
import javax.ejb.Stateless;
import ibase.utility.E12GenericUtility;
import ibase.webitm.ejb.ActionHandlerEJB;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.utility.ITMException;
@Stateless
public class EmployeeServicePrdAmdCanc extends ActionHandlerEJB implements EmployeeServicePrdAmdCancLocal,EmployeeServicePrdAmdCancRemote {
String loginEmpCode = "";
ITMDBAccessEJB itmdbAccess=new ITMDBAccessEJB();
E12GenericUtility genericUtility = new E12GenericUtility();
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
String retString = "";
Connection conn = null;
try
{
conn = getConnection();
retString = confirm( tranId, xtraParams, forcedFlag, conn);
System.out.println("confirm --["+retString+"]");
if(retString == null || retString.trim().length() == 0)
{
System.out.println("commit --["+retString+"]");
conn.commit();
retString = itmdbAccess.getErrorString("", "VTEMPSPA12", "", "", conn);//Transaction successfully cancelled.
return retString;
}
else
{
conn.rollback();
}
}
catch(Exception e)
{
System.out.println("Exception :EmployeeServicePrdAmdCanc :confirm():" + e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if(conn != null)
{
conn.close();
conn = null;
}
}
catch (Exception e) {
e.printStackTrace();
throw new ITMException(e);
}
}
return retString;
}
public String confirm( String tranId, String xtraParams, String forcedFlag,Connection conn ) throws RemoteException,ITMException
{
System.out.println("EmployeeServicePrdAmdCanc Called........");
ResultSet rs = null;
PreparedStatement pstmt = null;
String errString = "",sql = "",status = "",empCode = "";
int cnt = 0;
int cancelCnt = 0;
String confirmed = "";
int amendNO = 0,amendNoMax = 0;
Timestamp relDate = null;
boolean isLocal = false;
String canceled = "";
int retAgeO = 0;
Timestamp retDateO = null;
try
{
loginEmpCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode");
System.out.println("loginEmpCode::::::"+loginEmpCode);
if( conn == null)
{
conn = getConnection();
System.out.println("Connection before isLocal:::::::"+conn);
isLocal = true;
conn.setAutoCommit(false);
}
sql = "select status,relieve_date from employee where emp_code = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, empCode);
rs = pstmt.executeQuery();
if(rs.next())
{
status = checkNull(rs.getString("status"));
relDate = rs.getTimestamp("relieve_date");
}
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if("S".equalsIgnoreCase(status))
{
errString = itmdbAccess.getErrorString("", "VTEMPSPA01", "", "", conn);//Employee is separated from organization.
return errString;
}
if(relDate != null)
{
errString = itmdbAccess.getErrorString("", "VTEMPSPA02", "", "", conn);//Employee will relieved soon.
return errString;
}
//Mdified by Sarita S. on [28/06/2019][Start]
//sql = "select CANCELED,EMP_CODE,CONFIRMED,RETIREMENT_AGE_O,RETIREMENT_DATE_O,AMENDMENT_NO from EMP_SERVICEPRD_AMD WHERE TRAN_ID = ? ";
sql = "select CANCELLED,EMP_CODE,CONFIRMED,RETIREMENT_AGE_O,RETIREMENT_DATE_O,AMENDMENT_NO from EMP_SERVICEPRD_AMD WHERE TRAN_ID = ? ";
//Mdified by Sarita S. on [28/06/2019][End]
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if(rs.next())
{
empCode = rs.getString("EMP_CODE");
//Mdified by Sarita S. on [28/06/2019][Start]
//canceled = rs.getString("CANCELED");
canceled = rs.getString("CANCELLED");
//Mdified by Sarita S. on [28/06/2019][End]
confirmed = rs.getString("CONFIRMED");
retAgeO = rs.getInt("RETIREMENT_AGE_O");
retDateO = rs.getTimestamp("RETIREMENT_DATE_O");
amendNO = rs.getInt("AMENDMENT_NO");
}
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
if ( rs != null )
{
rs.close();
rs = null;
}
if("Y".equalsIgnoreCase(canceled))
{
errString = itmdbAccess.getErrorString("", "VTEMPSPA07", "", "", conn);//selected transaction already been canceled.
return errString;
}
System.out.println("confirmed---["+confirmed+"]");
if("N".equalsIgnoreCase(confirmed))
{
//Mdified by Sarita S. on [28/06/2019][Start]
//sql = "UPDATE EMP_SERVICEPRD_AMD set CANCELED = 'Y',CANC_DATE = ?,EMP_CODE__CANC = ? WHERE TRAN_ID = ? AND AMENDMENT_NO = ?";
sql = "UPDATE EMP_SERVICEPRD_AMD set CANCELLED = 'Y',CANC_DATE = ?,EMP_CODE__CANC = ? WHERE TRAN_ID = ? AND AMENDMENT_NO = ?";
//Mdified by Sarita S. on [28/06/2019][End]
pstmt = conn.prepareStatement(sql);
pstmt.setTimestamp(1, new Timestamp(System.currentTimeMillis()));
pstmt.setString(2,loginEmpCode);
pstmt.setString(3, tranId);
pstmt.setInt(4, amendNO);
cancelCnt = pstmt.executeUpdate();
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
System.out.println("cancelCnt11---["+cancelCnt+"]");
}
else if ("Y".equalsIgnoreCase(confirmed))
{
System.out.println("2656568---["+cancelCnt+"]");
//Mdified by Sarita S. on [28/06/2019][Start]
//sql = "SELECT MAX(AMENDMENT_NO) AS AMDNO FROM EMP_SERVICEPRD_AMD WHERE EMP_CODE = ? AND CANCELED NOT IN ('Y') ";CANCELLED
sql = "SELECT MAX(AMENDMENT_NO) AS AMDNO FROM EMP_SERVICEPRD_AMD WHERE EMP_CODE = ? AND CANCELLED NOT IN ('Y') ";
//Mdified by Sarita S. on [28/06/2019][End]
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, empCode);
rs = pstmt.executeQuery();
if(rs.next())
{
amendNoMax = rs.getInt("AMDNO");
}
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
if ( rs != null )
{
rs.close();
rs = null;
}
System.out.println("amendNoMax--["+amendNoMax+"]amendNO--["+amendNO+"]");
if(amendNoMax == amendNO)
{
System.out.println("Success");
//Mdified by Sarita S. on [28/06/2019][Start]
//sql = "UPDATE EMP_SERVICEPRD_AMD set CANCELED = 'Y',CANC_DATE = ?,EMP_CODE__CANC = ? WHERE TRAN_ID = ? AND AMENDMENT_NO = ?";
sql = "UPDATE EMP_SERVICEPRD_AMD set CANCELLED = 'Y',CANC_DATE = ?,EMP_CODE__CANC = ? WHERE TRAN_ID = ? AND AMENDMENT_NO = ?";
//Mdified by Sarita S. on [28/06/2019][End]
pstmt = conn.prepareStatement(sql);
pstmt.setTimestamp(1, new Timestamp(System.currentTimeMillis()));
pstmt.setString(2,loginEmpCode);
pstmt.setString(3, tranId);
pstmt.setInt(4, amendNO);
cancelCnt = pstmt.executeUpdate();
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
System.out.println("EMP_SERVICEPRD_AMD--["+cancelCnt+"]");
sql = "UPDATE EMPLOYEE SET RETIREMENT_AGE = ?,RETIREMENT_DATE = ? WHERE emp_code = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setInt(1, retAgeO);
pstmt.setTimestamp(2,retDateO);
pstmt.setString(3,empCode);
int crt = pstmt.executeUpdate();
System.out.println("row update into EMPLOYEE ="+crt);
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
}
}
else
{
System.out.println("failure");
errString = itmdbAccess.getErrorString("", "VTEMPSPA11", "", "", conn);//Selected transaction can't cancelled.
return errString;
}
if(isLocal && errString == null || errString.trim().length() == 0 )
{
conn.commit();
}
}
catch(Exception e)
{
e.printStackTrace();
System.out.println("Exception ::"+e.getMessage());
throw new ITMException(e);
}
finally
{
try
{
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (isLocal && conn!=null)
{
conn.close();
conn=null;
}
}
catch(Exception e)
{
System.out.println(e.getMessage());
e.printStackTrace();
throw new ITMException(e);
}
}
System.out.println("Returning Result ::"+errString);
return errString;
}
private String checkNull(String input)
{
if (input == null)
{
input = "";
}
else
{
input = input.trim();
}
return input;
}
}
webitm-adm/ibase/webitm/ejb/adm/EmployeeServicePrdAmdConf.java deleted 100644 → 0
View file @ d7c36c6d
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Timestamp;
import javax.ejb.Stateless;
import ibase.utility.E12GenericUtility;
import ibase.webitm.ejb.ActionHandlerEJB;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException;
@Stateless
public class EmployeeServicePrdAmdConf extends ActionHandlerEJB implements EmployeeServicePrdAmdConfLocal,EmployeeServicePrdAmdConfRemote
{
ITMDBAccessEJB itmdbAccess=new ITMDBAccessEJB();
String loginEmpCode = "";
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
String retString = "";
Connection conn = null;
try
{
conn=getConnection();
retString = confirm( tranId, xtraParams, forcedFlag, conn);
if(retString == null || retString.trim().length() == 0)
{
conn.commit();
retString = itmdbAccess.getErrorString("", "VTEMPSPA09", "", "", conn);//Transaction successfully completed.
return retString;
}
else
{
conn.rollback();
}
}
catch(Exception e)
{
System.out.println("Exception :EmployeeServicePrdAmdConf :confirm():" + e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if(conn != null)
{
conn.close();
conn = null;
}
}
catch (Exception e) {
e.printStackTrace();
}
}
return retString;
}
public String confirm( String tranId, String xtraParams, String forcedFlag,Connection conn ) throws RemoteException,ITMException
{
System.out.println("EmployeeServicePrdAmdConf Called........");
String errString = "",sql = "",confirmed = "",empCode = "",status = "",cancelled = "";
int cnt = 0,retAgeN = 0;
ResultSet rs = null;
PreparedStatement pstmt = null;
Timestamp relDate = null,retDateN = null;
boolean isLocal = false;
int amdNo = 0;
try
{
E12GenericUtility genericUtility = new E12GenericUtility();
loginEmpCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode");
if( conn == null)
{
conn = getConnection();
isLocal = true;
conn.setAutoCommit(false);
}
//Mdified by Sarita S. on [28/06/2019][Start]
//sql = "SELECT EMP_CODE,CONFIRMED,AMENDMENT_NO,CANCELED,RETIREMENT_AGE_N,RETIREMENT_DATE_N FROM EMP_SERVICEPRD_AMD WHERE TRAN_ID = ?";
sql = "SELECT EMP_CODE,CONFIRMED,AMENDMENT_NO,CANCELLED,RETIREMENT_AGE_N,RETIREMENT_DATE_N FROM EMP_SERVICEPRD_AMD WHERE TRAN_ID = ?";
//Mdified by Sarita S. on [28/06/2019][End]
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if( rs.next() )
{
empCode = checkNull(rs.getString("EMP_CODE"));
confirmed = checkNull(rs.getString("CONFIRMED"));
amdNo = rs.getInt("AMENDMENT_NO");
//Mdified by Sarita S. on [28/06/2019][Start]
//cancelled = checkNull(rs.getString("CANCELED"));
cancelled = checkNull(rs.getString("CANCELLED"));
//Mdified by Sarita S. on [28/06/2019][End]
retAgeN = rs.getInt("RETIREMENT_AGE_N");
retDateN = rs.getTimestamp("RETIREMENT_DATE_N");
}
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
if ( rs != null )
{
rs.close();
rs = null;
}
//Modified by Rohini T. on [14/06/2019][Start]
if("Y".equalsIgnoreCase(cancelled))
//if( confirmed != null && "Y".equalsIgnoreCase(confirmed) )
//Modified by Rohini T. on [14/06/2019][End]
{
errString = itmdbAccess.getErrorString("", "VTEMPSPA07", "", "", conn);//This transaction has already been canceled.
return errString;
}
//Modified by Rohini T. on [14/06/2019][Start]
//else if("Y".equalsIgnoreCase(cancelled))
else if ( confirmed != null && "Y".equalsIgnoreCase(confirmed) )
//Modified by Rohini T. on [14/06/2019][End]
{
errString = itmdbAccess.getErrorString("", "VTEMPSPA05", "", "", conn);//This transaction which you are trying to access is already confirmed, you canot edit or confirm it again.
return errString;
}
else
{
sql = "select status,relieve_date from employee where emp_code = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, empCode);
rs = pstmt.executeQuery();
if(rs.next())
{
status = checkNull(rs.getString("status"));
relDate = rs.getTimestamp("relieve_date");
}
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if("S".equalsIgnoreCase(status))
{
errString = itmdbAccess.getErrorString("", "VTEMPSPA01", "", "", conn);//Employee is separated from organization.
return errString;
}
if(relDate != null)
{
errString = itmdbAccess.getErrorString("", "VTEMPSPA02", "", "", conn);//Employee will relieved soon.
return errString;
}
//Mdified by Sarita S. on [28/06/2019][Start]
//sql = "SELECT COUNT(*) as count FROM EMP_SERVICEPRD_AMD WHERE EMP_CODE = ? AND TRAN_ID <> ? AND CONFIRMED = 'N' AND AMENDMENT_NO < ? AND CANCELED = 'N'";
sql = "SELECT COUNT(*) as count FROM EMP_SERVICEPRD_AMD WHERE EMP_CODE = ? AND TRAN_ID <> ? AND CONFIRMED = 'N' AND AMENDMENT_NO < ? AND CANCELLED = 'N'";
//Mdified by Sarita S. on [28/06/2019][End]
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, empCode);
pstmt.setString(2, tranId);
pstmt.setInt(3, amdNo);
rs = pstmt.executeQuery();
if(rs.next())
{
cnt = rs.getInt("count");
}
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
if ( rs != null )
{
rs.close();
rs = null;
}
if(cnt > 0)
{
errString = itmdbAccess.getErrorString("", "VTEMPSPA06", "", "", conn);//Unconfirmed record already present in system.
return errString;
}
}
if(errString == null || errString.trim().length() == 0 )
{
sql = " UPDATE EMP_SERVICEPRD_AMD SET CONFIRMED = 'Y', CONF_DATE = ?, EMP_CODE__CONF = ? WHERE TRAN_ID = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setTimestamp(1, new Timestamp(System.currentTimeMillis()));
pstmt.setString(2,loginEmpCode);
pstmt.setString(3,tranId);
int i = pstmt.executeUpdate();
System.out.println("row update into EMP_SERVICEPRD_AMD ="+i);
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
sql = "UPDATE EMPLOYEE SET RETIREMENT_AGE = ?,RETIREMENT_DATE = ? WHERE emp_code = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setInt(1, retAgeN);
pstmt.setTimestamp(2,retDateN);
pstmt.setString(3,empCode);
int crt = pstmt.executeUpdate();
System.out.println("row update into EMPLOYEE ="+crt);
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
}
if(isLocal && errString == null || errString.trim().length() == 0 )
{
conn.commit();
}
}
catch(Exception e)
{
e.printStackTrace();
System.out.println("Exception ::"+e.getMessage());
throw new ITMException(e);
}
finally
{
try
{
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (isLocal && conn!=null)
{
conn.close();
conn=null;
}
}
catch(Exception e)
{
System.out.println(e.getMessage());
e.printStackTrace();
throw new ITMException(e);
}
}
System.out.println("Returning Result ::"+errString);
return errString;
}
private String checkNull(String input)
{
if (input == null)
{
input = "";
} else
{
input = input.trim();
}
return input;
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment