Skip to content

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

Sarita : Committed on 04 JUNE 2019 

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@202943 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 2b79c702
Hide whitespace changes
Inline Side-by-side
Showing with 295 additions and 0 deletions
webitm-adm/ibase/webitm/ejb/adm/EmployeeServicePrdAmdCanc.java 0 → 100644
View file @ 122c0698
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;
}
}
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