Commit 8788c2b3 authored by piyush's avatar piyush

Merged empleaveic (existing) , admcommon (existing) , empleaveconf (new)...

Merged empleaveic (existing) , admcommon (existing) , empleaveconf (new) components as pb code of validation and confirmation migrated in java


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@106465 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 608b6648
This diff is collapsed.
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.Connection;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local;
@Local
public interface BondRecoveryConfirmLocal extends ActionHandlerLocal
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
public String confirm( String tranId, String xtraParams, String forcedFlag, Connection conn) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.Connection;
import ibase.webitm.ejb.ActionHandlerLocal;
import ibase.webitm.utility.ITMException;
import javax.ejb.Local;
@Local
public interface EmpLeaveConfLocal extends ActionHandlerLocal
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
public String confirm( String tranId, String xtraParams, String forcedFlag, Connection conn) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.Connection;
import javax.ejb.Remote;
import ibase.webitm.ejb.ActionHandlerRemote;
import ibase.webitm.utility.ITMException;
@Remote
public interface BondRecoveryConfirmRemote extends ActionHandlerRemote
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
public String confirm( String tranId, String xtraParams, String forcedFlag, Connection conn) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.adm.adv;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import java.sql.Connection;
import javax.ejb.Remote;
@Remote
public interface EmpLeaveConfRemote
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
public String confirm( String tranId, String xtraParams, String forcedFlag, Connection conn) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.*;
import org.w3c.dom.*;
import javax.ejb.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.GenericUtility;
import ibase.system.config.*;
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class AppraisalAct extends ActionHandlerEJB implements AppraisalActLocal,AppraisalActRemote //SessionBean
{
/*public void ejbCreate() throws RemoteException, CreateException
{
}
public void ejbRemove()
{
}
public void ejbActivate()
{
}
public void ejbPassivate()
{
}*/
public String actionHandler() throws RemoteException,ITMException
{
return "";
}
public String actionHandler(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException,ITMException
{
System.out.println("AppraisalActEJB calling.........");
Document dom = null;
Document dom1 = null;
String resString = null;
try
{
if(xmlString != null && xmlString.trim().length()!=0)
{
System.out.println("XML String :"+xmlString);
dom = GenericUtility.getInstance().parseString(xmlString);
}
System.out.println("objContext :"+objContext+"\n ActionType:"+actionType);
if (objContext.equals("2"))
{
if (actionType.equalsIgnoreCase("Default"))
{
resString = actionDefaultDet2(dom,objContext,xtraParams);
}
}
if (objContext.equals("3"))
{
if (actionType.equalsIgnoreCase("Default"))
{
resString = actionDefaultDet3(dom,objContext,xtraParams);
}
}
}
catch(Exception e)
{
System.out.println("Exception :AppraisalActEJB :actionHandler(String xmlString):" + e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
System.out.println("returning from action[Default] actionHandler"+resString);
return resString;
}
private String actionDefaultDet3(Document dom, String objContext, String xtraParams) throws SQLException,Exception
{
Statement stmt = null;
Connection conn = null;
ResultSet rs = null;
String sql = "", apprTableNo = "", apprNo = "";
StringBuffer valueXmlString = new StringBuffer("<?xml version=\"1.0\"?>\r\n<Root>\r\n");
ConnDriver connDriver = new ConnDriver();
if (dom != null)
{
try
{
conn = connDriver.getConnectDB("DriverITM");
stmt = conn.createStatement();
apprTableNo = GenericUtility.getInstance().getColumnValue("appr_tblno",dom);
apprNo = GenericUtility.getInstance().getColumnValue("appr_no",dom);
System.out.println("apprTableNo :"+apprTableNo+" apprNo :"+apprNo);
sql = "SELECT "
+"APPRAISAL_SPEC_TABLE.APPR_SPEC, "
+"APPRAISAL_SPEC.SPEC_DETAILS, "
+"APPRAISAL_SPEC_TABLE.MIN_RATING, "
+"APPRAISAL_SPEC_TABLE.MAX_RATING, "
+"APPRAISAL_SPEC_TABLE.OVERALL_PERC "
+"FROM APPRAISAL_SPEC_TABLE, APPRAISAL_SPEC "
+"WHERE APPRAISAL_SPEC_TABLE.APPR_SPEC = APPRAISAL_SPEC.APPR_SPEC "
+"AND APPRAISAL_SPEC_TABLE.APPR_TBLNO = '"+apprTableNo+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
if (rs.next())
{
valueXmlString.append("<Detail>\r\n");
valueXmlString.append("<appr_no>").append("<![CDATA[").append(apprNo).append("]]>").append("</appr_no>\r\n");
valueXmlString.append("<appr_spec>").append("<![CDATA[").append((rs.getString(1) == null) ? "":rs.getString(1)).append("]]>").append("</appr_spec>\r\n");
valueXmlString.append("<spec_details>").append("<![CDATA[").append((rs.getString(2)== null) ? "":rs.getString(2)).append("]]>").append("</spec_details>\r\n");
valueXmlString.append("<min_rating>").append("<![CDATA[").append((rs.getString(3) == null) ? "":rs.getString(3)).append("]]>").append("</min_rating>\r\n");
valueXmlString.append("<max_rating>").append("<![CDATA[").append((rs.getString(4) == null) ? "":rs.getString(4)).append("]]>").append("</max_rating>\r\n");
valueXmlString.append("<overall_perc>").append("<![CDATA[").append((rs.getString(5) == null) ? "":rs.getString(5)).append("]]>").append("</overall_perc>\r\n");
valueXmlString.append("</Detail>\r\n");
}
}
catch(SQLException e)
{
System.out.println("Exception : AppraisalActEJB : actionStock " +e.getMessage());
throw(e);
}
catch(Exception e)
{
System.out.println("Exception : AppraisalActEJB : actionHandler :(Document dom)" +e.getMessage());
throw(e);
}
finally
{
try
{
if (conn != null)
{
conn.close();
conn = null;
}
}catch(Exception e){}
}
}
valueXmlString.append("</Root>\r\n");
System.out.println("valueXmlString.toString() "+valueXmlString.toString());
return valueXmlString.toString();
}
private String actionDefaultDet2(Document dom, String objContext, String xtraParams) throws SQLException ,Exception
{
Statement stmt = null;
Connection conn = null;
ResultSet rs = null;
String sql = "", empCode = "", apprNo = "", apprNo1 = "";
StringBuffer valueXmlString = new StringBuffer("<?xml version=\"1.0\"?>\r\n<Root>\r\n");
ConnDriver connDriver = new ConnDriver();
if (dom != null)
{
try
{
conn = connDriver.getConnectDB("DriverITM");
stmt = conn.createStatement();
empCode = GenericUtility.getInstance().getColumnValue("emp_code",dom);
apprNo = GenericUtility.getInstance().getColumnValue("appr_no",dom);
System.out.println("empCode :"+empCode+" apprNo :"+apprNo);
sql = "SELECT APPR_NO FROM APPRAISAL "
+"WHERE EMP_CODE = '"+empCode+"'"+" ORDER BY APPR_DATE DESC";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
while (rs.next())
{
apprNo1 = rs.getString(1);
if (apprNo.equals(apprNo1))
{
apprNo1 = rs.getString(1);
}
else
{
break;
}
}
System.out.println("apprNo1 :"+apprNo1);
sql = "SELECT LINE_NO,KRA_NEXT FROM APPR_KRANEXT "
+"WHERE APPR_NO = '"+apprNo1+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
while (rs.next())
{
valueXmlString.append("<Detail>\r\n");
valueXmlString.append("<appr_no>").append("<![CDATA[").append(apprNo).append("]]>").append("</appr_no>\r\n");
valueXmlString.append("<line_no>").append("<![CDATA[").append(rs.getString(1)).append("]]>").append("</line_no>\r\n");
valueXmlString.append("<kra_prev>").append("<![CDATA[").append(rs.getString(2)).append("]]>").append("</kra_prev>\r\n");
valueXmlString.append("</Detail>\r\n");
}
}
catch(SQLException e)
{
System.out.println("Exception : AppraisalActEJB : actionStock " +e.getMessage());
throw(e);
}
catch(Exception e)
{
System.out.println("Exception : AppraisalActEJB : actionHandler :(Document dom)" +e.getMessage());
throw(e);
}
finally
{
try
{
if (conn != null)
{
conn.close();
conn = null;
}
}catch(Exception e){}
}
}
valueXmlString.append("</Root>\r\n");
System.out.println("valueXmlString.toString() "+valueXmlString.toString());
return valueXmlString.toString();
}
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface AppraisalActLocal extends ActionHandlerLocal //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String actionType, String xmlString, String xmlString1, String objContext, String xtraParams) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerRemote;
import javax.ejb.Remote; // added for ejb3
@Remote // added for ejb3
public interface AppraisalActRemote extends ActionHandlerRemote //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String actionType, String xmlString, String xmlString1, String objContext, String xtraParams) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.GenericUtility;
import ibase.system.config.ConnDriver;
import java.sql.*;
import java.text.SimpleDateFormat;
import java.rmi.RemoteException;
import javax.ejb.Stateless;
@Stateless
public class BondRecoveryConfirm extends ActionHandlerEJB implements BondRecoveryConfirmLocal,BondRecoveryConfirmRemote
{
String loginEmpCode="";
int updcnt1=0;
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
String retString = "";
try
{
Connection conn=null;
retString = confirm( tranId, xtraParams, forcedFlag, conn);
}
catch(Exception e)
{
System.out.println("Exception :BondRecoveryConfirm :confirm():" + e.getMessage() + ":");
retString = GenericUtility.getInstance().createErrorString(e);
e.printStackTrace();
}
return retString;
}
public String confirm( String tranId, String xtraParams, String forcedFlag, Connection conn)
{
System.out.println("--------------confirm method of BondRecoveryConfirm -------------");
ResultSet rs=null;
PreparedStatement pstmt = null;
conn=null;
ITMDBAccessEJB itmdbAccess=new ITMDBAccessEJB();
String sql="",confirmed="",errString="",empcode="",retString="";
double recAmtAct=0.0,empBondReco=0.0;
int updCnt=0;
try
{
loginEmpCode = GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode");
ConnDriver connDriver=new ConnDriver();
conn=connDriver.getConnectDB("DriverValidator");
conn.setAutoCommit(false);
sql = "SELECT emp_code,CONFIRMED FROM BOND_RECOVERY WHERE TRAN_ID = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if( rs.next() )
{
confirmed =rs.getString("CONFIRMED")==null ? "":rs.getString("CONFIRMED");
empcode=rs.getString(1);
}
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
if ( rs != null )
{
rs.close();
rs = null;
}
if( confirmed != null && confirmed.equalsIgnoreCase("Y") )
{
errString = itmdbAccess.getErrorString("", "AEBCONF", "", "", conn);
return errString;
}
else
{
sql="select bond_amt__reco from employee where emp_code = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, empcode);
rs = pstmt.executeQuery();
if(rs.next()) empBondReco=rs.getDouble(1);
pstmt.close();rs.close();
pstmt = null;rs=null;
sql="select emp_code,recovery_amt__act from bond_recovery where tran_id = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if(rs.next()) recAmtAct=rs.getDouble(2);
System.out.println("Recovery amt actual : "+recAmtAct);
sql="update employee set BOND_AMT__RECO = ? where emp_code = ?";
pstmt = conn.prepareStatement( sql );
pstmt.setDouble(1,recAmtAct+empBondReco);
pstmt.setString(2,empcode);
updCnt = pstmt.executeUpdate();
System.out.println("recAmtAct+empBondReco "+(recAmtAct+empBondReco));
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
if ( rs != null )
{
rs.close();
rs = null;
}
updcnt1 =updateConfirm(conn,tranId);
System.out.println("UPDATE COUNT --updCnt-->>"+updCnt+" updcnt1 -->>"+updcnt1);
if (updCnt > 0 && updcnt1 >0 )
{
retString=new ITMDBAccessEJB().getErrorString("", "VCONFSUC", "", "", conn);
conn.commit();
System.out.println("confirmed,empCodeAprv, BOND_AMT__RECO columns are updated successfully.......row(s) updated :"+updCnt);
}else
{
retString=new ITMDBAccessEJB().getErrorString("", "VCONFUSUC", "", "", conn);
conn.rollback();
}
}
}
catch(Exception e)
{
try
{
conn.rollback();
}
catch (Exception e1)
{
}
e.printStackTrace();
System.out.println("Exception ::"+e.getMessage());
}
finally
{
try
{
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (conn!=null)
{
conn.close();
conn=null;
}
}
catch(Exception e)
{
System.out.println(e.getMessage());
e.printStackTrace();
}
}
System.out.println("Returning Result ::"+retString);
return retString;
}
public int updateConfirm(Connection conn,String tranId)
{
System.out.println("in updateConfirm method -------->>>");
int count=0;
String sql = "UPDATE BOND_RECOVERY SET CONFIRMED = ?,CONF_DATE = ?,EMP_CODE__APRV = ? WHERE TRAN_ID = ?";
PreparedStatement pstmt1=null;
try
{
pstmt1 = conn.prepareStatement( sql );
pstmt1.setString(1, "Y");
pstmt1.setTimestamp(2, this.getCurrdateAppFormat());
pstmt1.setString(3, loginEmpCode);
pstmt1.setString(4, tranId);
count = pstmt1.executeUpdate();
System.out.println("confirm updated -------->>>>>>>>>updCount :"+count);
}
catch(Exception e)
{
try
{
conn.rollback();
}
catch(Exception e1)
{
e1.printStackTrace();
}
e.printStackTrace();
}
try
{
if(pstmt1 != null)
{
pstmt1.close();
pstmt1 = null;
}
}
catch(Exception e)
{
System.out.println(e.getMessage());
e.printStackTrace();
}
return count;
}
private java.sql.Timestamp getCurrdateAppFormat()
{
GenericUtility genericUtility = GenericUtility.getInstance();
Timestamp timestamp = null;
try
{
java.util.Date date = null;
timestamp = new Timestamp(System.currentTimeMillis());
SimpleDateFormat simpledateformat = new SimpleDateFormat(genericUtility.getDBDateFormat());
date = simpledateformat.parse(timestamp.toString());
timestamp = Timestamp.valueOf(simpledateformat.format(date).toString() + " 00:00:00.0");
}
catch(Exception exception)
{
System.out.println("Exception in [EmpBondDefConfirm] getCurrdateAppFormat " + exception.getMessage());
}
return timestamp;
}
}
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.*;
import javax.ejb.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.GenericUtility;
import ibase.system.config.*;
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class EmpAddChgCnc extends ActionHandlerEJB implements EmpAddChgCncLocal,EmpAddChgCncRemote //SessionBean
{
/*public void ejbCreate() throws RemoteException, CreateException
{
}
public void ejbRemove()
{
}
public void ejbActivate()
{
}
public void ejbPassivate()
{
}*/
public String actionHandler() throws RemoteException,ITMException
{
return "";
}
public String actionHandler(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
String retString = null;
GenericUtility genericUtility = GenericUtility.getInstance();
try
{
retString = actionCancel(tranId, xtraParams, forcedFlag);
}
catch(Exception e)
{
System.out.println("Exception :EmpAddChgCncEJB :actionHandler :" + e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
System.out.println("returning String from EmpAddChgCncEJB :actionHandler :"+retString);
return retString;
}
private String actionCancel(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
String sql = "", empCodeAprove = "", loginEmpCode = "", errCode = "", errString = "", confirmed = "", updSql = "";
Connection conn = null;
Statement stmt = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
int updCnt = 0;
java.sql.Date currDate = null;
ConnDriver connDriver = new ConnDriver();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance();
try
{
conn = connDriver.getConnectDB("DriverITM");
stmt = conn.createStatement();
System.out.println("Tran ID : "+ tranId);
sql = "SELECT CONFIRMED FROM EMPLOYEE_ADD_CHANGE WHERE TRAN_ID = '"+tranId+"' ";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
if (rs.next())
{
confirmed = rs.getString(1);
}
System.out.println();
loginEmpCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode");
System.out.println("confirmed :"+confirmed+"loginEmpCode :"+loginEmpCode);
if (confirmed != null && confirmed.equals("N"))
{
empCodeAprove = loginEmpCode;
updSql = "UPDATE EMPLOYEE_ADD_CHANGE SET CONFIRMED = ?, "
+"CONF_DATE = ? , "
+"EMP_CODE__APRV = ? "
+"WHERE TRAN_ID = ?";
pstmt = conn.prepareStatement(updSql);
pstmt.setString(1,"X");
pstmt.setDate(2,new java.sql.Date(System.currentTimeMillis()));
pstmt.setString(3,empCodeAprove);
pstmt.setString(4,tranId);
updCnt = pstmt.executeUpdate();
if (updCnt > 0)
{
errCode = "VTSUCC";
}
}
else if(confirmed != null && confirmed.equals("Y"))
{
errCode = "VTMCONF1";
}
else if(confirmed != null && confirmed.equals("X"))
{
errCode = "VTMCANL1";
}
if (errCode != null && errCode.trim().length() > 0)
{
System.out.println("EmpAddChgCnc:errCode:"+errCode);
errString = itmDBAccessEJB.getErrorString("",errCode,"","",conn);
}
}
catch (SQLException sqx)
{
System.out.println("The sqlException occure in EmpAddChgCncEJB :"+sqx);
throw new ITMException(sqx);
}
catch (Exception e)
{
System.out.println("The Exception occure in EmpAddChgCncEJB :"+e);
throw new ITMException(e);
}
finally
{
try
{
if (conn!=null)
{
conn.close();
conn = null;
}
if (stmt != null)
{
stmt.close();
stmt = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (rs != null)
{
rs.close();
rs = null;
}
}
catch (Exception e)
{
System.out.println("Exception in finally: " + e);
}
}
return errString;
}
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface EmpAddChgCncLocal extends ActionHandlerLocal //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerRemote;
import javax.ejb.Remote; // added for ejb3
@Remote // added for ejb3
public interface EmpAddChgCncRemote extends ActionHandlerRemote //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.GenericUtility;
import ibase.system.config.ConnDriver;
import java.sql.*;
import java.text.SimpleDateFormat;
import java.rmi.RemoteException;
import javax.ejb.Stateless;
@Stateless
public class EmpBondDefConfirm extends ActionHandlerEJB implements EmpBondDefConfirmLocal,EmpBondDefConfirmRemote
{
String loginEmpCode="";
int updcnt1=0;
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
String retString = "";
try
{
Connection conn=null;
retString = confirm( tranId, xtraParams, forcedFlag, conn);
}
catch(Exception e)
{
System.out.println("Exception :EmpBondDefConfirm :confirm():" + e.getMessage() + ":");
retString = GenericUtility.getInstance().createErrorString(e);
e.printStackTrace();
}
return retString;
}
public String confirm( String tranId, String xtraParams, String forcedFlag, Connection conn)
{
System.out.println("--------------confirm method of EmpBondDefConfirm ------------- ");
ResultSet rs = null;
PreparedStatement pstmt = null;
conn = null;
ITMDBAccessEJB itmdbAccess=new ITMDBAccessEJB();
String retString = "",errString="";
String sql = "",empcode="",confirmed="";
double bondamt=0.0;
int lineno=0,bondprd=0,updCnt=0;
try
{
loginEmpCode = GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode");
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverValidator");
conn.setAutoCommit(false);
sql = "SELECT CONFIRMED FROM EMPLOYEE_BOND_DEF WHERE TRAN_ID = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if( rs.next() )
{
confirmed =rs.getString("CONFIRMED")==null ? "":rs.getString("CONFIRMED");
}
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
if ( rs != null )
{
rs.close();
rs = null;
}
if( confirmed != null && confirmed.equalsIgnoreCase("Y") )
{
errString = itmdbAccess.getErrorString("", "AEBCONF", "", "", conn);
return errString;
}
sql="select ed.tran_id,e.emp_code,ed.line_no,ed.bond_amt,ed.bond_prd from employee_bond_def_det ed,employee_bond_def e "+
" where ed.tran_id=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
sql="update employee_bond set bond_amt = ?,bond_prd = ? where line_no = ? and emp_code = ?";
pstmt = conn.prepareStatement( sql );
while(rs.next())
{
lineno=rs.getInt("line_no");
bondamt=rs.getInt("bond_amt");
bondprd=rs.getInt("bond_prd");
empcode=rs.getString("emp_code");
pstmt.setDouble(1, bondamt);
pstmt.setInt(2, bondprd);
pstmt.setInt(3, lineno);
pstmt.setString(4,empcode);
updCnt = pstmt.executeUpdate();
}
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
if ( rs != null )
{
rs.close();
rs = null;
}
updcnt1 =updateConfirm(conn,tranId);
System.out.println("UPDATE COUNT --updCnt-->>"+updCnt+" updcnt1 -->>"+updcnt1);
if (updCnt > 0 && updcnt1 >0 )
{
retString=new ITMDBAccessEJB().getErrorString("", "VCONFSUC", "", "", conn);
conn.commit();
System.out.println("Bond amount and bond period updated successfully.......");
}else
{
retString=new ITMDBAccessEJB().getErrorString("", "VCONFUSUC", "", "", conn);
conn.rollback();
System.out.println("Not Updated Bond amount and bond period........");
}
}
catch(Exception e)
{
try
{
conn.rollback();
}
catch (Exception e1)
{
}
e.printStackTrace();
System.out.println("Exception ::"+e.getMessage());
}
finally
{
try
{
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (conn!=null)
{
conn.close();
conn=null;
}
}
catch(Exception e)
{
System.out.println(e.getMessage());
e.printStackTrace();
}
}
System.out.println("Returning Result ::"+retString);
return retString;
}
public int updateConfirm(Connection conn,String tranId)
{
PreparedStatement pstmt1=null;
int count=0;
String sql = "UPDATE EMPLOYEE_BOND_DEF SET CONFIRMED = ? ,CONF_DATE = ?,EMP_CODE__APRV=? WHERE TRAN_ID = ?";
try
{
pstmt1 = conn.prepareStatement( sql );
pstmt1.setString(1, "Y");
pstmt1.setTimestamp(2, this.getCurrdateAppFormat());
pstmt1.setString(3, loginEmpCode);
pstmt1.setString(4, tranId);
count = pstmt1.executeUpdate();
System.out.println("confirm updated -------->>>>>>>>>updCount :"+count);
}
catch(Exception e)
{
try
{
conn.rollback();
}
catch(Exception e1)
{
e1.printStackTrace();
}
e.printStackTrace();
}
try
{
if(pstmt1 != null)
{
pstmt1.close();
pstmt1 = null;
}
}
catch(Exception e)
{
System.out.println(e.getMessage());
e.printStackTrace();
}
return count;
}
private java.sql.Timestamp getCurrdateAppFormat()
{
GenericUtility genericUtility = GenericUtility.getInstance();
Timestamp timestamp = null;
try
{
java.util.Date date = null;
timestamp = new Timestamp(System.currentTimeMillis());
SimpleDateFormat simpledateformat = new SimpleDateFormat(genericUtility.getDBDateFormat());
date = simpledateformat.parse(timestamp.toString());
timestamp = Timestamp.valueOf(simpledateformat.format(date).toString() + " 00:00:00.0");
}
catch(Exception exception)
{
System.out.println("Exception in [EmpBondDefConfirm] getCurrdateAppFormat " + exception.getMessage());
}
return timestamp;
}
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.Connection;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local;
@Local
public interface EmpBondDefConfirmLocal extends ActionHandlerLocal
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
public String confirm( String tranId, String xtraParams, String forcedFlag, Connection conn) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.adm.adv;
import java.sql.Connection;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerRemote;// added for ejb3
import javax.ejb.Remote; // added for ejb3
@Remote
public interface EmpBondDefConfirmRemote extends ActionHandlerRemote
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
public String confirm( String tranId, String xtraParams, String forcedFlag, Connection conn) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.HashSet;
import java.util.Set;
import javax.ejb.Stateless;
import org.w3c.dom.Document;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import ibase.system.config.ConnDriver;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.ejb.ActionHandlerEJB;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.utility.ITMException;
@Stateless
public class EmpBondDefault extends ActionHandlerEJB implements EmpBondDefaultLocal,EmpBondDefaultRemote
{
public String actionHandler(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException, ITMException
{
Document dom = null;
GenericUtility genericUtility = GenericUtility.getInstance();
String retString = "";
try
{
dom = genericUtility.parseString(xmlString);
retString = actionHandler(actionType, dom, objContext, xtraParams);
}
catch (Exception ex)
{
System.out.println("in catch");
ex.printStackTrace();
throw new ITMException(ex);
}
return retString;
}
private String actionHandler(String actionType, Document dom, String objContext, String xtraParams) throws ITMException
{
String sql = "", childNodeName = "";
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
ConnDriver connDriver = new ConnDriver();
NodeList parentNodeList = null, childNodeList = null;
Node parentNode = null, childNode = null;
int bondAmt=0,bondPrd=0;
GenericUtility genericUtility;
StringBuffer valueXmlBuff;
String retString = "",empcode="", userId = "";
ValidatorEJB validatorEJB;
String emp="";
int lineNo=0;
try
{
validatorEJB = new ValidatorEJB();
userId = validatorEJB.getValueFromXTRA_PARAMS(xtraParams, "loginCode");
valueXmlBuff = new StringBuffer();
genericUtility = GenericUtility.getInstance();
empcode =genericUtility.getColumnValue("emp_code",dom);
valueXmlBuff.append("<?xml version=\"1.0\"?>\r\n");
valueXmlBuff.append("<Root>\r\n");
parentNodeList = dom.getElementsByTagName("Detail1");
//loginEmpCode = GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode");
for (int i = 0; i < parentNodeList.getLength(); i++)
{
parentNode = parentNodeList.item(i);
childNodeList = parentNode.getChildNodes();
for (int j = 0; j < childNodeList.getLength(); j++)
{
childNode = childNodeList.item(j);
childNodeName = childNode.getNodeName();
}
}
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
connDriver = null;
sql="select e.line_no,e.bond_prd,e.bond_amt from employee_bond e where e.emp_code=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, empcode);
rs = pstmt.executeQuery();
while (rs.next())
{
// lineNo++;
lineNo=rs.getInt("LINE_NO");
bondAmt = rs.getInt("BOND_AMT");
bondPrd = rs.getInt("BOND_PRD");
valueXmlBuff.append("<Detail>\r\n");
valueXmlBuff.append("<line_no>").append("<![CDATA["+lineNo+"]]>").append("</line_no>");
valueXmlBuff.append("<bond_amt__curr>").append("<![CDATA["+bondAmt+"]]>").append("</bond_amt__curr>");
valueXmlBuff.append("<bond_prd__curr>").append("<![CDATA["+bondPrd+"]]>").append("</bond_prd__curr>");
valueXmlBuff.append("<bond_amt>").append("<![CDATA["+bondAmt+"]]>").append("</bond_amt>");
valueXmlBuff.append("<bond_prd>").append("<![CDATA["+bondPrd+"]]>").append("</bond_prd>");
valueXmlBuff.append("</Detail>\r\n");
System.out.println("------->>>>Line no :"+lineNo+" Bond Amt :"+bondAmt+" bond period : "+bondPrd);
}
pstmt.close();
pstmt = null;
rs.close();
rs = null;
valueXmlBuff.append("</Root>\r\n");
retString = valueXmlBuff.toString();
System.out.println("Return String ..in deafault EJB ----------->>>>>>>>>>> \n" + retString);
return retString;
}
catch (Exception e)
{
System.out.println("Exception : TrainingDefault : actionHandler " + e.getMessage());
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if (conn != null)
{
conn.close();
conn = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
}
catch (Exception e)
{
e.printStackTrace();
}
}
//return retString;
}
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import javax.ejb.Remote;
import ibase.webitm.ejb.ActionHandlerLocal;
import ibase.webitm.ejb.ActionHandlerRemote;
import ibase.webitm.utility.ITMException;
public interface EmpBondDefaultLocal extends ActionHandlerLocal
{
public String actionHandler(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException, ITMException;
}
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import javax.ejb.Remote;
import ibase.webitm.ejb.ActionHandlerRemote;
import ibase.webitm.utility.ITMException;
@Remote
public interface EmpBondDefaultRemote extends ActionHandlerRemote
{
public String actionHandler(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException, ITMException;
}
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.*;
import javax.ejb.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.GenericUtility;
import ibase.system.config.*;
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class EmpLoanSanctionAprv extends ActionHandlerEJB implements EmpLoanSanctionAprvLocal,EmpLoanSanctionAprvRemote //SessionBean
{
/*public void ejbCreate() throws RemoteException, CreateException
{
}
public void ejbRemove()
{
}
public void ejbActivate()
{
}
public void ejbPassivate()
{
}
*/
public String actionHandler() throws RemoteException,ITMException
{
return "";
}
public String actionHandler(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
String retString = null;
try
{
retString = actionApprove(tranId, xtraParams, forcedFlag);
}
catch(Exception e)
{
System.out.println("Exception :EmpLoanSanctionAprvEJB :actionHandler :" + e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
System.out.println("returning String from EmpLoanSanctionAprvEJB :actionHandler :"+retString);
return retString;
}
private String actionApprove(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
String updSql = "", sql = "", empCode = "", errCode = "", errString = "", empCodeApprove = "", schemeNo = "", status = "";
Connection conn = null;
Statement stmt = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
int updCnt = 0, count = 0;
java.sql.Date currDate = null;
ConnDriver connDriver = new ConnDriver();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance();
try
{
conn = connDriver.getConnectDB("DriverITM");
stmt = conn.createStatement();
System.out.println("Sanction No :: "+tranId);
sql = "SELECT EMP_CODE,EMP_CODE__APRV,SCHEME_NO,STATUS "
+"FROM EMPLOAN_SANCTION WHERE SANCTION_NO = '"+tranId+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
if (rs.next())
{
empCode = rs.getString(1);
empCodeApprove = rs.getString(2);
schemeNo = rs.getString(3);
status = rs.getString(4);
}
System.out.println("empCode :"+empCode+" empCodeApprove :"+empCodeApprove+" scheme No :"+schemeNo+" status :"+status);
if (!status.equals("R"))
{
errCode = "VTMCONF1";
}
else
{
sql = "SELECT COUNT(*) FROM EMPLOAN_SANCTION "
+"WHERE EMP_CODE = '"+empCode+"' "
+"AND SCHEME_NO = '"+schemeNo+"' "
+"AND STATUS = 'A' AND SANCTION_BAL > 0";
rs = stmt.executeQuery(sql);
if (rs.next())
{
count = rs.getInt(1);
}
System.out.println("count :"+count);
if (count > 0)
{
errCode = "VTLOANSAN2";
}
if (errCode != null && errCode.trim().length() == 0)
{
updSql = "UPDATE EMPLOAN_SANCTION SET STATUS = ?, "
+"APRV_DATE = ? "
+"WHERE SANCTION_NO = ? ";
pstmt = conn.prepareStatement(updSql);
pstmt.setString(1,"A");
pstmt.setDate(2,new java.sql.Date(System.currentTimeMillis()));
pstmt.setString(3,tranId);
updCnt = pstmt.executeUpdate();
if (updCnt > 0)
{
errCode = "VTMCONF2";
conn.commit();
}
}
}
if (errCode != null && errCode.trim().length() > 0)
{
errString = itmDBAccessEJB.getErrorString("",errCode,"","",conn);
}
}
catch (SQLException sqx)
{
System.out.println("The sqlException occure EmpLoanSanctionAprvEJB in :"+sqx);
throw new ITMException(sqx);
}
catch (Exception e)
{
System.out.println("The Exception occure in EmpLoanSanctionAprvEJB :"+e);
throw new ITMException(e);
}
finally
{
try
{
if (conn!=null)
{
conn.close();
conn = null;
}
if (stmt != null)
{
stmt.close();
stmt = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (rs != null)
{
rs.close();
rs = null;
}
}
catch (Exception e)
{
System.out.println("Exception in finally: " + e);
}
}
return errString;
}
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface EmpLoanSanctionAprvLocal extends ActionHandlerLocal //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerRemote;
import javax.ejb.Remote; // added for ejb3
@Remote // added for ejb3
public interface EmpLoanSanctionAprvRemote extends ActionHandlerRemote //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
\ No newline at end of file
/*
Developed by : Hatim Laxmidhar
Started On : 07/01/2006
Purpose : Cancel Button
Window : w_emp_separation
*/
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.*;
import javax.ejb.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.GenericUtility;
import ibase.system.config.*;
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class EmpSeparationCnc extends ActionHandlerEJB implements EmpSeparationCncLocal,EmpSeparationCncRemote //SessionBean
{
/*public void ejbCreate() throws RemoteException, CreateException
{
}
public void ejbRemove()
{
}
public void ejbActivate()
{
}
public void ejbPassivate()
{
}
*/
public String actionHandler() throws RemoteException,ITMException
{
return "";
}
public String actionHandler(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
String retString = null;
GenericUtility genericUtility = GenericUtility.getInstance();
try
{
retString = actionCancel(tranId, xtraParams, forcedFlag);
}
catch(Exception e)
{
System.out.println("Exception :EmpSeparationCncEJB :actionHandler :" + e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
System.out.println("returning String from EmpSeparationCncEJB :actionHandler :"+retString);
return retString;
}
private String actionCancel(String tranId, String xtraParams, String forcedFlag) throws Exception
{
String status = "", sql = "";
String errCode = "", errString = "";
String empCode = "";
String resiDateStr = "";
java.sql.Date resiDate = null;
String loginCode = "";
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
ConnDriver connDriver = new ConnDriver();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance();
int cnt = 0;
try
{
conn = connDriver.getConnectDB("DriverITM");
System.out.println("########### Inside EmpSeparationCncEJB[actionCancel] ###########");
System.out.println("Tran ID : "+ tranId);
resiDateStr = tranId.substring(tranId.indexOf(":")+1);
System.out.println("resiDateStr : " + resiDateStr);
resiDateStr = genericUtility.getValidDateString(resiDateStr, "dd/MM/yy", "yyyy-MM-dd");
resiDate = java.sql.Date.valueOf(resiDateStr);
empCode = tranId.substring(0,tranId.indexOf(":"));
System.out.println("empCode : " + empCode);
sql = "SELECT STATUS FROM SEPARATION WHERE EMP_CODE = ? AND RESI_DATE = ?";
System.out.println("sql :\n" + sql +"\n");
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,empCode);
pstmt.setDate(2,resiDate);
rs = pstmt.executeQuery();
pstmt.clearParameters();
if (rs.next())
{
status = rs.getString(1);
}
System.out.println("Status :"+status);
if (!status.equalsIgnoreCase("C"))
{
sql = "UPDATE SEPARATION SET STATUS = 'X' WHERE EMP_CODE = ? AND RESI_DATE = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,empCode);
pstmt.setDate(2,resiDate);
cnt = pstmt.executeUpdate();
if (cnt > 0)
{
errCode = "VTCANC1";
}
}
else
{
errCode = "VTRCONF1";
}
}
catch (Exception e)
{
System.out.println("The Exception occure in EmpSeparationCncEJB :"+e);
throw e;
}
finally
{
errString = itmDBAccessEJB.getErrorString("",errCode,"","",conn);
try
{
if (conn!=null)
{
conn.close();
conn = null;
}
}
catch (Exception e)
{
System.out.println("Exception in finally: " + e);
}
}
return errString;
}
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface EmpSeparationCncLocal extends ActionHandlerLocal //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerRemote;
import javax.ejb.Remote; // added for ejb3
@Remote // added for ejb3
public interface EmpSeparationCncRemote extends ActionHandlerRemote //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
//import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface FullFinalActLocal extends ActionHandlerLocal //, EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
//import ibase.webitm.utility.ITMException;
import javax.ejb.Remote; // added for ejb3
import ibase.webitm.ejb.ActionHandlerRemote;
@Remote // added for ejb3
public interface FullFinalActRemote extends ActionHandlerRemote //, EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException,ITMException;
}
\ No newline at end of file
/*
Developed by : Hatim Laxmidhar
Started On : 07/01/2006
Purpose : Cancel Button
Window : w_loan_opening
*/
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.*;
import javax.ejb.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import ibase.system.config.*;
import ibase.webitm.utility.GenericUtility;
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class LoanOpeningCnc extends ActionHandlerEJB implements LoanOpeningCncLocal,LoanOpeningCncRemote //SessionBean
{
/*public void ejbCreate() throws RemoteException, CreateException
{
}
public void ejbRemove()
{
}
public void ejbActivate()
{
}
public void ejbPassivate()
{
}*/
public String actionHandler() throws RemoteException,ITMException
{
return "";
}
public String actionHandler(String loanNo, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
String retString = null;
GenericUtility genericUtility = GenericUtility.getInstance();
try
{
retString = actionCancel(loanNo, xtraParams, forcedFlag);
}
catch(Exception e)
{
System.out.println("Exception :LoanOpeningCncEJB :actionHandler :" + e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
System.out.println("returning String from LoanOpeningCncEJB :actionHandler :"+retString);
return retString;
}
private String actionCancel(String loanNo, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
String status = "", sql = "";
String errCode = "", errString = "";
String loginCode = "";
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
ConnDriver connDriver = new ConnDriver();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance();
int cnt = 0;
try
{
conn = connDriver.getConnectDB("DriverITM");
stmt = conn.createStatement();
System.out.println("########### Inside LoanOpeningCncEJB[actionCancel] ###########");
System.out.println("Loan No : "+ loanNo);
sql = "SELECT STATUS FROM LOANS WHERE LOAN_NO = '" + loanNo + "'";
System.out.println("sql :\n" + sql +"\n");
rs = stmt.executeQuery(sql);
if (rs.next())
{
status = rs.getString(1);
}
System.out.println("Status :"+status);
if (status.equalsIgnoreCase("U"))
{
loginCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode");
if (loginCode == null || loginCode.trim().length() == 0)
{
errCode = "EMPAPRV";
}
else
{
stmt = conn.createStatement();
cnt = stmt.executeUpdate("UPDATE LOANS SET STATUS = 'X' WHERE LOAN_NO = '" + loanNo + "'");
if (cnt > 0)
{
errCode = "VTCANC1";
}
}
}
else
{
errCode = "VTRCONF1";
}
}
catch (SQLException sqx)
{
System.out.println("The sqlException occure in LoanOpeningCncEJB :"+sqx);
throw new ITMException(sqx);
}
catch (Exception e)
{
System.out.println("The Exception occure in LoanOpeningCncEJB :"+e);
throw new ITMException(e);
}
finally
{
errString = itmDBAccessEJB.getErrorString("",errCode,"","",conn);
try
{
if (conn!=null)
{
conn.close();
conn = null;
}
}
catch (Exception e)
{
System.out.println("Exception in finally: " + e);
}
}
return errString;
}
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface LoanOpeningCncLocal extends ActionHandlerLocal //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerRemote;
import javax.ejb.Remote; // added for ejb3
@Remote // added for ejb3
public interface LoanOpeningCncRemote extends ActionHandlerRemote //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
\ No newline at end of file
/*
Developed by : Hatim Laxmidhar
Started On : 07/01/2006
Purpose : Cancel Button
Window : w_loanschedule
*/
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.*;
import javax.ejb.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import ibase.system.config.*;
import ibase.webitm.utility.GenericUtility;
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class LoanscheduleCnc extends ActionHandlerEJB implements LoanscheduleCncLocal,LoanscheduleCncRemote // SessionBean
{
/*public void ejbCreate() throws RemoteException, CreateException
{
}
public void ejbRemove()
{
}
public void ejbActivate()
{
}
public void ejbPassivate()
{
}*/
public String actionHandler() throws RemoteException,ITMException
{
return "";
}
public String actionHandler(String loanNo, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
String retString = null;
GenericUtility genericUtility = GenericUtility.getInstance();
try
{
retString = actionCancel(loanNo, xtraParams, forcedFlag);
}
catch(Exception e)
{
System.out.println("Exception :LoanscheduleCncEJB :actionHandler :" + e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
System.out.println("returning String from LoanscheduleCncEJB :actionHandler :"+retString);
return retString;
}
private String actionCancel(String loanNo, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
String status = "", sql = "";
String errCode = "", errString = "";
String loginCode = "";
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
ConnDriver connDriver = new ConnDriver();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance();
int cnt = 0;
try
{
conn = connDriver.getConnectDB("DriverITM");
stmt = conn.createStatement();
System.out.println("########### Inside LoanscheduleCncEJB[actionCancel] ###########");
System.out.println("Loan No: "+ loanNo);
sql = "SELECT STATUS FROM LOANS WHERE LOAN_NO = '" + loanNo + "'";
System.out.println("sql :\n" + sql +"\n");
rs = stmt.executeQuery(sql);
if (rs.next())
{
status = rs.getString(1);
}
System.out.println("Status :"+status);
if (status.equalsIgnoreCase("U"))
{
loginCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode");
if (loginCode == null || loginCode.trim().length() == 0)
{
errCode = "EMPAPRV";
}
else
{
stmt = conn.createStatement();
cnt = stmt.executeUpdate("UPDATE LOANS SET STATUS = 'X' WHERE LOAN_NO = '" + loanNo + "'");
if (cnt > 0)
{
errCode = "VTCANC1";
}
}
}
else
{
errCode = "VTRCONF1";
}
}
catch (SQLException sqx)
{
System.out.println("The sqlException occure in LoanscheduleCncEJB :"+sqx);
throw new ITMException(sqx);
}
catch (Exception e)
{
System.out.println("The Exception occure in LoanscheduleCncEJB :"+e);
throw new ITMException(e);
}
finally
{
errString = itmDBAccessEJB.getErrorString("",errCode,"","",conn);
try
{
if (conn!=null)
{
conn.close();
conn = null;
}
}
catch (Exception e)
{
System.out.println("Exception in finally: " + e);
}
}
return errString;
}
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface LoanscheduleCncLocal extends ActionHandlerLocal //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerRemote;
import javax.ejb.Remote; // added for ejb3
@Remote // added for ejb3
public interface LoanscheduleCncRemote extends ActionHandlerRemote //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface LoanscheduleStDednLocal extends ActionHandlerLocal //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerRemote;
import javax.ejb.Remote; // added for ejb3
@Remote // added for ejb3
public interface LoanscheduleStDednRemote extends ActionHandlerRemote //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
\ No newline at end of file
/********************************************************
Title : LogWriter
Date Of Creation : 27/11/07
Name of Developer : Nisar S. Khatib
Description : How to use Log writer
1. Set Log on by using method setLogOn(true);
2. Use write() or writeException() method to write errorstring or exception resp.
3. Set log off by using method setLogOn(false);
********************************************************/
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.util.*;
import java.util.Date;
import java.text.*;
import java.sql.*;
import java.io.*;
public class LogWriter
{
FileWriter fw = null;
int count = 0;
String logFileName = null;
public void setNameOfLog(String logFileName)
{
this.logFileName = logFileName;
System.out.println("Log File Name========================>"+logFileName);
}
public void write(String s)
{//this method write string to trace file
try
{
count++;
fw.write(count+" : "+s+"\r\n");
fw.flush();
}
catch(Exception e)
{
e.printStackTrace();
}
}
public void writeException(Exception e1)
{//this method write exceptions to trace file
try
{
count++;
fw.write(count+" : "+e1+"\r\n");
fw.flush();
}
catch(Exception e)
{
e.printStackTrace();
}
}
public void setLogOn(boolean status)
{//this method set trace or log on if status is true
try
{
if(status)
{
boolean retain = (new File("C:\\JTrace")).exists();
if(!retain)
{
retain =(new File("C:\\JTrace")).mkdirs();
}
fw=new FileWriter("C:\\JTrace\\"+logFileName+".log");
System.out.println("========================Name of Log File : C:\\JTrace\\"+logFileName+".log=====================");
fw.write("<<<<<<<<<<<<<<<<<<<<<<<<Trace Created On : "+new java.sql.Timestamp(System.currentTimeMillis())+">>>>>>>>>>>>>>>>>>>>>>>>>>\r\n");
}
else
{
fw.close();
}
}
catch(Exception e)
{
e.printStackTrace();
}
}
//==============end of code====================================
public String getFormatedValue(double actVal,int prec)throws RemoteException
{//this method is used to return double with appropriate precison
NumberFormat numberFormat = NumberFormat.getIntegerInstance ();
Double DoubleValue = new Double (actVal);
numberFormat.setMaximumFractionDigits(prec);
String strValue = numberFormat.format(DoubleValue);
System.out.println(strValue);
strValue = strValue.replaceAll(",","");
return strValue;
}
public static void main(String[] args)
{
System.out.println("Hello World!");
}
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.*;
import javax.ejb.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import ibase.system.config.*;
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class PayrVoucherHld extends ActionHandlerEJB implements PayrVoucherHldLocal,PayrVoucherHldRemote //SessionBean
{
/*public void ejbCreate() throws RemoteException, CreateException
{
}
public void ejbRemove()
{
}
public void ejbActivate()
{
}
public void ejbPassivate()
{
}*/
public String actionHandler() throws RemoteException,ITMException
{
return "";
}
public String actionHandler(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
System.out.println("PayrVoucherHldEJB is called");
String retString = null;
try
{
retString = actionHold(tranID,xtraParams);
}
catch(Exception e)
{
System.out.println("Exception :PayrVoucherHldEJB :actionHandler:" + e.getMessage() + ":");
throw new ITMException(e);
}
return retString;
}
private String actionHold(String tranId ,String xtraParams)throws ITMException
{
Connection conn = null;
Statement stmt = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
String sql = "", updSql = "", errCode = "", errString = "", confirm = "", hold = "";
double totalAmt = 0d, adjAmt = 0d, holdAmt = 0d;
int updateCnt = 0;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
ConnDriver connDriver = new ConnDriver();
try
{
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
connDriver = null;
stmt = conn.createStatement();
System.out.println("TranId ::"+tranId);
sql = "SELECT CONFIRMED,HOLD FROM PAYR_VOUCHER WHERE TRAN_ID = '"+tranId+"'";
System.out.println("sql ::"+sql);
rs = stmt.executeQuery(sql);
if (rs.next())
{
confirm = rs.getString(1);
System.out.println("confirm ::"+confirm);
hold = rs.getString(2);
System.out.println("hold ::"+hold);
}
rs.close();
rs = null;
if (confirm.equals("Y"))
{
sql = "SELECT TOT_AMT, ADJ_AMT, HOLD_AMT FROM MISC_PAYABLES "
+"WHERE TRAN_SER = 'P-VOUC' AND REF_NO = '"+tranId+"'";
System.out.println("sql ::"+sql);
rs = stmt.executeQuery(sql);
if (rs.next())
{
totalAmt = rs.getDouble(1);
System.out.println("totalAmt ::"+totalAmt);
adjAmt = rs.getDouble(2);
System.out.println("adjAmt ::"+adjAmt);
holdAmt = rs.getDouble(3);
System.out.println("holdAmt ::"+holdAmt);
}
rs.close();
rs = null;
if ((totalAmt - adjAmt) == 0)
{
errCode = "VTBAL2"; // already paid off
}
else if(adjAmt != 0 && adjAmt != totalAmt)
{
errCode = "VTBAL2"; // partly paid off
}
else if (hold.equals("N") || hold.equals(""))
{
updSql = "UPDATE MISC_PAYABLES SET HOLD_AMT = TOT_AMT "
+"WHERE TRAN_SER = ? AND REF_NO = ? ";
System.out.println("updSql ::"+updSql);
pstmt = conn.prepareStatement(updSql);
pstmt.setString(1,"P-VOUC");
pstmt.setString(2,tranId);
updateCnt = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
System.out.println("updateCnt ::"+updateCnt);
updSql ="UPDATE PAYR_VOUCHER SET HOLD = 'Y' WHERE TRAN_ID = ? ";
System.out.println("updSql ::"+updSql);
pstmt = conn.prepareStatement(updSql);
pstmt.setString(1,tranId);
updateCnt = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
System.out.println("updateCnt ::"+updateCnt);
if (updateCnt > 0)
{
errCode = "VTHOLD2";
}
}// end hold else
}//end confirm if
else
{
if (hold == null || hold.equals("N"))
{
updSql = "UPDATE PAYR_VOUCHER SET HOLD = 'Y' WHERE TRAN_ID = ? ";
System.out.println("updSql ::"+updSql);
pstmt = conn.prepareStatement(updSql);
pstmt.setString(1,tranId);
updateCnt = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
System.out.println("updateCnt ::"+updateCnt);
if (updateCnt > 0)
{
errCode = "VTHOLD2";
}
}//end hold if
}//end confirm else
if ("VTHOLD2".equals(errCode))
{
conn.commit();
}
else
{
conn.rollback();
}
if (errCode != null && errCode.trim().length() > 0)
{
System.out.println("PayrVoucherHldEJB:errCode:"+errCode);
errString = itmDBAccessEJB.getErrorString("",errCode,"","",conn);
}
}// try end
catch(SQLException sqx)
{
System.out.println("Exception :PayrVoucherHldEJB :" + sqx.getMessage() + ":");
throw new ITMException(sqx);
}
catch(Exception e)
{
System.out.println("Exception :PayrVoucherHldEJB :" + e.getMessage() + ":");
throw new ITMException(e);
}
finally
{
try
{
System.out.println("Closing Connection.....");
if (stmt != null)
{
stmt.close();
stmt = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (conn != null)
{
conn.close();
conn = null;
}
}catch(Exception e){}
}
return errString;
}
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface PayrVoucherHldLocal extends ActionHandlerLocal //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerRemote;
import javax.ejb.Remote; // added for ejb3
@Remote // added for ejb3
public interface PayrVoucherHldRemote extends ActionHandlerRemote //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.*;
import javax.ejb.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import ibase.system.config.*;
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class PayrVoucherRls extends ActionHandlerEJB implements PayrVoucherRlsLocal,PayrVoucherRlsRemote // SessionBean
{
/*public void ejbCreate() throws RemoteException, CreateException
{
}
public void ejbRemove()
{
}
public void ejbActivate()
{
}
public void ejbPassivate()
{
}*/
public String actionHandler() throws RemoteException,ITMException
{
return "";
}
public String actionHandler(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
System.out.println("PayrVoucherRlsEJB is called");
String retString = null;
try
{
retString = actionRelease(tranID,xtraParams);
}
catch(Exception e)
{
System.out.println("Exception :PayrVoucherRlsEJB :actionHandler:" + e.getMessage() + ":");
throw new ITMException(e);
}
return retString;
}
private String actionRelease(String tranId ,String xtraParams)throws ITMException
{
Connection conn = null;
Statement stmt = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
String sql = "", updSql = "", errCode = "", errString = "", confirm = "", hold = "";
double totalAmt = 0d, adjAmt = 0d, holdAmt = 0d;
int updateCnt = 0;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
ConnDriver connDriver = new ConnDriver();
try
{
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
connDriver = null;
stmt = conn.createStatement();
System.out.println("TranId ::"+tranId);
sql = "SELECT CONFIRMED,HOLD FROM PAYR_VOUCHER WHERE TRAN_ID = '"+tranId+"'";
System.out.println("sql ::"+sql);
rs = stmt.executeQuery(sql);
if (rs.next())
{
confirm = rs.getString(1);
System.out.println("confirm ::"+confirm);
hold = rs.getString(2);
System.out.println("hold ::"+hold);
}
rs.close();
rs = null;
if (hold.equals(""))
{
errCode = "VTHLDNLL";
}
if (confirm.equals("Y"))
{
sql = "SELECT TOT_AMT, ADJ_AMT, HOLD_AMT FROM MISC_PAYABLES "
+"WHERE TRAN_SER = 'P-VOUC' AND REF_NO = '"+tranId+"'";
System.out.println("sql ::"+sql);
rs = stmt.executeQuery(sql);
if (rs.next())
{
totalAmt = rs.getDouble(1);
System.out.println("totalAmt ::"+totalAmt);
adjAmt = rs.getDouble(2);
System.out.println("adjAmt ::"+adjAmt);
holdAmt = rs.getDouble(3);
System.out.println("holdAmt ::"+holdAmt);
}
rs.close();
rs = null;
if ((totalAmt - adjAmt) == 0)
{
errCode = "VTBAL2"; // already paid off
}
else if(adjAmt != 0 && adjAmt != totalAmt)
{
errCode = "VTBAL2"; // partly paid off
}
else if (hold.equals("Y"))
{
updSql = "UPDATE MISC_PAYABLES SET HOLD_AMT = 0 WHERE TRAN_SER = ? AND REF_NO = ?";
System.out.println("updSql ::"+updSql);
pstmt = conn.prepareStatement(updSql);
pstmt.setString(1,"P-VOUC");
pstmt.setString(2,tranId);
updateCnt = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
System.out.println("updateCnt ::"+updateCnt);
updSql ="UPDATE PAYR_VOUCHER SET HOLD = 'N' WHERE TRAN_ID = ? ";
System.out.println("updSql ::"+updSql);
pstmt = conn.prepareStatement(updSql);
pstmt.setString(1,tranId);
updateCnt = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
System.out.println("updateCnt ::"+updateCnt);
if (updateCnt > 0)
{
errCode = "VTHOLD1";
}
}// end hold else
}//end confirm if
else
{
if (hold.equals("Y"))
{
updSql = "UPDATE PAYR_VOUCHER SET HOLD = 'N' WHERE TRAN_ID = ? ";
System.out.println("updSql ::"+updSql);
pstmt = conn.prepareStatement(updSql);
pstmt.setString(1,tranId);
updateCnt = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
System.out.println("updateCnt ::"+updateCnt);
if (updateCnt > 0)
{
errCode = "VTHOLD1";
}
}//end hold if
}//end confirm else
if ("VTHOLD1".equals(errCode))
{
conn.commit();
}
else
{
conn.rollback();
}
if (errCode != null && errCode.trim().length() > 0)
{
System.out.println("PayrVoucherRlsEJB:errCode:"+errCode);
errString = itmDBAccessEJB.getErrorString("",errCode,"","",conn);
}
}// try end
catch(SQLException sqx)
{
System.out.println("Exception :PayrVoucherRlsEJB :" + sqx.getMessage() + ":");
throw new ITMException(sqx);
}
catch(Exception e)
{
System.out.println("Exception :PayrVoucherRlsEJB :" + e.getMessage() + ":");
throw new ITMException(e);
}
finally
{
try
{
System.out.println("Closing Connection.....");
if (stmt != null)
{
stmt.close();
stmt = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (conn != null)
{
conn.close();
conn = null;
}
}catch(Exception e){}
}
return errString;
}
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface PayrVoucherRlsLocal extends ActionHandlerLocal //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerRemote;
import javax.ejb.Remote; // added for ejb3
@Remote // added for ejb3
public interface PayrVoucherRlsRemote extends ActionHandlerRemote //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.lang.String;
import java.sql.*;
import org.w3c.dom.*;
import javax.ejb.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.GenericUtility;
import ibase.system.config.*;
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class TourAct extends ActionHandlerEJB implements TourActLocal ,TourActRemote //SessionBean
{
/*public void ejbCreate() throws RemoteException, CreateException
{
}
public void ejbRemove()
{
}
public void ejbActivate()
{
}
public void ejbPassivate()
{
}*/
public String actionHandler() throws RemoteException,ITMException
{
return "";
}
public String actionHandler(String actionType, String xmlString, String xmlString1, String objContext, String xtraParams) throws RemoteException,ITMException
{
System.out.println("TourActEJB called");
Document dom = null;
Document dom1 = null;
String resString = null;
try
{
GenericUtility genericUtility = GenericUtility.getInstance();
if(xmlString != null && xmlString.trim().length()!=0)
{
System.out.println("XML String :"+xmlString);
dom = genericUtility.parseString(xmlString);
}
if(xmlString1 != null && xmlString1.trim().length()!=0)
{
System.out.println("XML String1 :"+xmlString1);
dom1 = genericUtility.parseString(xmlString1);
}
System.out.println("actionType:"+actionType);
if (actionType.equalsIgnoreCase("From Plan"))
{
resString = actionFromPlan(dom,dom1,objContext,xtraParams);
}
}
catch(Exception e)
{
System.out.println("Exception :TourActEJB :actionHandler(String xmlString):" + e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
System.out.println("returning from action[Stock] actionHandler"+resString);
return (resString);
}
private String actionFromPlan(Document dom,Document dom1, String objContext, String xtraParams) throws RemoteException , ITMException
{
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
String sql = "", planId = "";
StringBuffer valueXmlString = new StringBuffer("<?xml version=\"1.0\"?>\r\n<Root>\r\n");
GenericUtility genericUtility = GenericUtility.getInstance();
ConnDriver connDriver = new ConnDriver();
try
{
conn = connDriver.getConnectDB("DriverITM");
stmt = conn.createStatement();
planId = genericUtility.getColumnValue("plan_id",dom1);
System.out.println("planId :"+planId);
sql = "SELECT LINE_NO FROM TOURPLANDET WHERE PLAN_ID = '"+planId+"'"+" ORDER BY LINE_NO";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
while (rs.next())
{
valueXmlString.append("<Detail>\r\n");
valueXmlString.append("<line_no__plan>").append("<![CDATA[").append(rs.getString(1)).append("]]>").append("</line_no__plan>\r\n");
valueXmlString.append("</Detail>\r\n");
}
valueXmlString.append("</Root>\r\n");
}
catch(SQLException e)
{
System.out.println("Exception : TourActEJB : actionStock " +e.getMessage());
throw new ITMException(e);
}
catch(Exception e)
{
System.out.println("Exception : TourActEJB : actionHandler :(Document dom)" +e.getMessage());
throw new ITMException(e);
}
finally
{
try{
conn.close();
conn = null;
}catch(Exception e){}
}
System.out.println("valueXmlString.toString() "+valueXmlString.toString());
return valueXmlString.toString();
}
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface TourActLocal extends ActionHandlerLocal //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String actionType, String xmlString, String xmlString1, String objContext, String xtraParams) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerRemote;
import javax.ejb.Remote; // added for ejb3
@Remote // added for ejb3
public interface TourActRemote extends ActionHandlerRemote //,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String actionType, String xmlString, String xmlString1, String objContext, String xtraParams) throws RemoteException,ITMException;
}
\ No newline at end of file
/*
Developed by : Hatim Laxmidhar
Started On : 06/01/2006
Purpose : Confirm Button
Window : w_trainexec
*/
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.*;
import javax.ejb.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import ibase.system.config.*;
import ibase.webitm.utility.GenericUtility;
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class TrainexecCnf extends ActionHandlerEJB implements TrainexecCnfLocal,TrainexecCnfRemote //SessionBean
{
/*public void ejbCreate() throws RemoteException, CreateException
{
}
public void ejbRemove()
{
}
public void ejbActivate()
{
}
public void ejbPassivate()
{
}*/
public String confirm() throws RemoteException,ITMException
{
return "";
}
public String confirm(String trainNo, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
String retString = "";
try
{
System.out.println("=========================================================");
System.out.println("Train No :"+ trainNo);
retString = actionConfirm(trainNo, xtraParams, forcedFlag);
}
catch(Exception e)
{
System.out.println("Exception :TrainexecCnfEJB :actionHandler :" + e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
return retString;
}
private String actionConfirm(String trainNo, String xtraParams, String forcedFlag) throws RemoteException,ITMException, SQLException
{
String errCode = "", errString = "";
String confirmed = "", sql="";
String batchNo = "", startPrd= "";
String trainCode = "", loginCode = "";
java.sql.Date startDate = null;
Connection conn= null;
Statement stmt = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
ConnDriver connDriver = new ConnDriver();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance();
int cnt = 0;
try
{
batchNo = trainNo.substring(trainNo.indexOf(":")+1);
trainNo = trainNo.substring(0,trainNo.indexOf(":"));
System.out.println("Batch No :"+ batchNo);
System.out.println("Train No :"+ trainNo);
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
//INTO :LS_CONFIRMED, :LS_TRAIN_CODE, :LD_START
sql = "SELECT CONFIRM, TRAIN_CODE , START_DATE " +
"FROM TRAINEXEC " +
"WHERE TRAIN_NO = '"+ trainNo +"'" +
"AND BATCH_NO = '"+ batchNo +"'";
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery(sql);
if (rs.next())
{
confirmed = rs.getString(1);
trainCode = rs.getString(2);
startDate = rs.getDate(3);
}
if (confirmed.trim().equalsIgnoreCase("N"))
{
loginCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode");
sql = "UPDATE TRAINEXEC SET CONFIRM = 'Y'," +
" EMP_CODE__CONF = '"+ loginCode + "', CONFIRM_DATE = ?" +
" WHERE TRAIN_NO = '"+ trainNo + "'" +
" AND BATCH_NO = '"+ batchNo + "'" ;
pstmt = conn.prepareStatement(sql);
pstmt.setDate(1, new java.sql.Date(System.currentTimeMillis()));
cnt = pstmt.executeUpdate();
if (cnt <= 0)
{
errCode = "";
errString = itmDBAccessEJB.getErrorString("",errCode,"","",conn);
return errString;
}
sql = "SELECT CODE FROM PERIOD WHERE ? BETWEEN FR_DATE AND TO_DATE";
pstmt.clearParameters();
pstmt = conn.prepareStatement(sql);
pstmt.setDate(1,startDate);
rs = pstmt.executeQuery();
if (rs.next())
{
startPrd = rs.getString(1);
}
sql = "SELECT COMM_CATG, EMP_CODE " +
"FROM TRAINEMP " +
"WHERE TRAIN_NO = '" + trainNo + "'" +
"AND BATCH_NO = '" + batchNo + "'" ;
stmt = conn.createStatement();
rs = stmt.executeQuery(sql);
sql = "UPDATE TRAINNEED " +
"SET STATUS = 'U'," +
"STATUS_DATE = ?," +
"TRAIN_NO = ?," +
"BATCH_NO = ?," +
"COMM_CATG = ? " +
"WHERE EMP_CODE = ? " +
"AND TRAIN_CODE = ? " +
"AND NVL(STATUS,'P') = 'P' " +
"AND PRD_CODE__FR <= ?";
pstmt = conn.prepareStatement(sql);
while (rs.next())
{
pstmt.clearParameters();
pstmt.setDate(1,new java.sql.Date(System.currentTimeMillis()));
pstmt.setString(2, trainNo);
pstmt.setString(3, batchNo);
pstmt.setString(4, rs.getString(1));
pstmt.setString(5, rs.getString(2));
pstmt.setString(6, trainCode);
pstmt.setString(7, startPrd);
cnt += pstmt.executeUpdate();
}
if (cnt > 0)
{
errCode = "VTMCONF2";
conn.commit();
}
else
{
errCode = "VTRCONF1";
conn.rollback();
}
}
else
{
errCode = "VTRCONF1";
}
}
catch (SQLException sqx)
{
conn.rollback();
System.out.println("The sqlException occure in TrainexecCnfEJB :"+sqx);
throw new ITMException(sqx);
}
catch (Exception e)
{
conn.rollback();
System.out.println("The Exception occure in TrainExecCnfEJB :"+e);
throw new ITMException(e);
}
finally
{
errString = itmDBAccessEJB.getErrorString("",errCode,"","",conn);
try
{
if (conn!=null)
{
conn.close();
conn = null;
}
}
catch (Exception e)
{
System.out.println(e);
}
}
System.out.println("returning String from TrainexecCnfEJB :actionConfirm :" + errString);
return errString;
}
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface TrainexecCnfLocal extends ActionHandlerLocal //,EJBObject
{
public String confirm() throws RemoteException,ITMException;
public String confirm(String trainNo, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerRemote;
import javax.ejb.Remote; // added for ejb3
@Remote // added for ejb3
public interface TrainexecCnfRemote extends ActionHandlerRemote //,EJBObject
{
public String confirm() throws RemoteException,ITMException;
public String confirm(String trainNo, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
\ No newline at end of file
/*
Window Name : w_weekoff_creation
Button name : Weekly off
Auther : Gulzar
*/
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.*;
import org.w3c.dom.*;
import javax.ejb.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.GenericUtility;
import ibase.system.config.*;
import java.util.Calendar;
import java.text.SimpleDateFormat;
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class WeekOffCreationPrc extends ProcessEJB implements WeekOffCreationPrcLocal,WeekOffCreationPrcRemote // SessionBean
{
/*public void ejbCreate() throws RemoteException, CreateException
{
}
public void ejbRemove()
{
}
public void ejbActivate()
{
}
public void ejbPassivate()
{
}
public String process() throws RemoteException,ITMException
{
return "";
}*/
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException
{
System.out.println("WeekOffCreationPrcEJB called.............!");
Document dom = null,dom1 = null;
String resString = null;
try
{
if(xmlString != null && xmlString.trim().length() > 0)
{
System.out.println("XML String :"+xmlString);
GenericUtility genericUtility = GenericUtility.getInstance();
dom = genericUtility.parseString(xmlString);
}
resString = process(dom,dom1,windowName,xtraParams);
}
catch(Exception e)
{
System.out.println("Exception :WeekOffCreationPrcEJB : process(String xmlString):" + e.getMessage() + ":");
throw new ITMException(e);
}
System.out.println("returning from Process "+resString);
return resString;
}
public String process(Document dom,Document dom1,String windowName,String xtraParams) throws RemoteException,ITMException
{
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
PreparedStatement pstmt = null;
String fromDt= "",toDt = "",rotate = "",offDay = "", offFor = "", retString = "", holTblNo = "";
String chgTerm = "", chgUser = "", insSql = "", errCode = "", userId = "";
int dayNo = 0, noOfDays = 0, minDays = 0, maxDays = 0, weeklyOffDay = 0, insCnt = 0, count = 0;
java.util.Date fromDate = null, weeklyOffDate = null, toDate = null;
GenericUtility genericUtility = GenericUtility.getInstance();
try
{
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
fromDt = genericUtility.getColumnValue("from_date",dom);
toDt = genericUtility.getColumnValue("to_date",dom);
rotate = genericUtility.getColumnValue("rotate",dom);
offDay = genericUtility.getColumnValue("off_day",dom);
offFor = genericUtility.getColumnValue("off_for",dom);
holTblNo = genericUtility.getColumnValue("hol_tblno",dom);
System.out.println("fromDt From Dom........:: " + fromDt);
System.out.println("toDt From Dom..........:: " + toDt);
System.out.println("rotate From Dom........:: " + rotate);
System.out.println("offDay From Dom........:: " + offDay);
System.out.println("offFor From Dom........:: " + offFor);
System.out.println("holTblNo From Dom......:: " + holTblNo);
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
fromDate = sdf.parse(fromDt);
toDate = sdf.parse(toDt);
weeklyOffDate = fromDate;
weeklyOffDay = Integer.parseInt(offDay);
if (rotate.equals("N"))
{
noOfDays = 7;
if (offFor.equals("A"))
{
minDays = 1;
maxDays = 31;
}
else if (offFor.equals("F"))
{
minDays = 1;
maxDays = 7;
}
else if (offFor.equals("S"))
{
minDays = 8;
maxDays = 14;
}
else if (offFor.equals("T"))
{
minDays = 15;
maxDays = 21;
}
else if (offFor.equals("O"))
{
minDays = 22;
maxDays = 28;
}
else if (offFor.equals("I"))
{
minDays = 29;
maxDays = 31;
}
}
else if (rotate.equals("Y"))
{
minDays = 1;
maxDays = 31;
noOfDays = 8;
}
dayNo = getDayNumber(fromDate);
System.out.println("dayNo Returned From [getDayNumber()] :: "+ dayNo);
while (weeklyOffDay != dayNo)
{
weeklyOffDate = sdf.parse(getRelativeDate(weeklyOffDate, 1));
dayNo = getDayNumber(weeklyOffDate);
}
insSql = "INSERT INTO HOLIDAY(HOL_TBLNO,HOL_DATE,DESCR,CHG_DATE,CHG_USER,CHG_TERM,NO_DAYS,HOL_TYPE ) " +
" VALUES (?,?,'WEEKLY OFF',?,?,?,1,'W')";
pstmt = conn.prepareStatement(insSql);
while (weeklyOffDate.compareTo(toDate) <= 0)
{
if (getDay(weeklyOffDate) >= minDays && getDay(weeklyOffDate) <= maxDays)
{
pstmt.setString(1,holTblNo);
pstmt.setTimestamp(2,java.sql.Timestamp.valueOf(genericUtility.getValidDateTimeString(sdf.format(weeklyOffDate),genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat())));
pstmt.setTimestamp(3,new java.sql.Timestamp(System.currentTimeMillis()));
pstmt.setString(4,genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode"));
pstmt.setString(5,genericUtility.getValueFromXTRA_PARAMS(xtraParams,"termId"));
insCnt = pstmt.executeUpdate();
if (insCnt == 1)
{
System.out.println("Inserted Into HOLIDAY Successfully....[insCnt]:: " + insCnt);
count++;
}
else
{
errCode = "DS000";
System.out.println("Inserted Into HOLIDAY Failed.......! [errCode] :: " + errCode);
break;
}
pstmt.clearParameters();
}
weeklyOffDate = sdf.parse(getRelativeDate(weeklyOffDate, noOfDays));
}
System.out.println("count....:: " + count);
if (errCode.trim().length() > 0)
{
System.out.println("Rolling Back The Changes.......! " + errCode);
conn.rollback();
}
else
{
errCode = "VPSUCC1";
System.out.println("Commiting The Changes.......! " + errCode);
conn.commit();
}
userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"userId");
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
retString = itmDBAccessEJB.getErrorString("",errCode,userId);
}
catch(SQLException se)
{
System.out.println("Exception : WeekOffCreationPrcEJB : process()" +se.getMessage());
try
{
conn.rollback();
}
catch(Exception se1){}
throw new ITMException(se);
}
catch(Exception e)
{
System.out.println("Exception :WeekOffCreationPrcEJB :process():"+e.getMessage());
try
{
conn.rollback();
}
catch(Exception e1){}
throw new ITMException(e);
}
finally
{
try
{
System.out.println("Closing Database Connection......");
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (conn != null)
{
conn.close();
conn = null;
}
}catch(Exception se){}
}
return retString;
}
private int getDayNumber(java.util.Date fromDate)
{
int noOfDays = 0;
try
{
Calendar calObj = Calendar.getInstance();
calObj.setTime(fromDate);
noOfDays = calObj.get(calObj.DAY_OF_WEEK);
}
catch(Exception e)
{
System.out.println("Exception : " + e);
}
System.out.println("noOfDays In [getDayNumber()] :: " + noOfDays);
return noOfDays;
}
private int getDay(java.util.Date fromDate)
{
int noOfDays = 0;
try
{
Calendar calObj = Calendar.getInstance();
calObj.setTime(fromDate);
noOfDays = calObj.get(calObj.DAY_OF_MONTH);
}
catch(Exception e)
{
System.out.println("Exception : " + e);
}
System.out.println("noOfDays In [getDay()] :: " + noOfDays);
return noOfDays;
}
private String getRelativeDate(java.util.Date effDate, int no)
{
String relativeDate ="";
try
{
SimpleDateFormat sdf = new SimpleDateFormat(GenericUtility.getInstance().getApplDateFormat());
Calendar calObject = Calendar.getInstance();
calObject.setTime(effDate);
calObject.add(calObject.DATE,no);
effDate = calObject.getTime();
relativeDate = sdf.format(effDate);
}
catch(Exception e)
{
System.out.println("Exception :[AdmCommon][function::getRelativeDate()] :==>\n"+e.getMessage());
e.printStackTrace();
}
System.out.println(" relativeDate In [getRelativeDate()]:: " +relativeDate);
return relativeDate;
}
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import org.w3c.dom.*;
import ibase.webitm.utility.ITMException;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface WeekOffCreationPrcLocal extends ibase.webitm.ejb.ProcessLocal //,EJBObject
{
public String process() throws RemoteException,ITMException;
public String process(Document dom, Document dom2, String windowName, String xtraParams) throws RemoteException,ITMException;
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import org.w3c.dom.*;
import ibase.webitm.utility.ITMException;
import javax.ejb.Remote; // added for ejb3
@Remote // added for ejb3
public interface WeekOffCreationPrcRemote extends ibase.webitm.ejb.ProcessRemote //,EJBObject
{
public String process() throws RemoteException,ITMException;
public String process(Document dom, Document dom2, String windowName, String xtraParams) throws RemoteException,ITMException;
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException;
}
\ No newline at end of file
/**
*
*/
/**
* @author unibase
*
*/
package ibase.webitm.ejb.adm.adv;
\ No newline at end of file
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