Commit 987aecae authored by pjain's avatar pjain

MERGED BY VENKAT ADD COPY BUTTON POINTS AND PFNUMBER SOURCE FILES ON 02-04-2014


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@94482 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 3a05ef31
package ibase.webitm.ejb.adm;
import ibase.webitm.utility.*;
//import ibase.utility.CommonConstants;
import ibase.system.config.*;
//import java.text.*;
import java.util.*;
//import javax.xml.parsers.*;
import javax.ejb.*;
//import javax.naming.InitialContext;
import java.io.*;
import java.util.Calendar;
import java.util.Date;
import java.sql.*;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.rmi.RemoteException;
import org.w3c.dom.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.ejb.*;
import javax.ejb.Stateless; // added for ejb3
import javax.swing.JOptionPane;
//public class SReturnPrsEJB extends ValidatorEJB implements SessionBean
@Stateless // added for ejb3
public class CopyCadreAdParamPrs extends ValidatorEJB implements CopyCadreAdParamPrsLocal, CopyCadreAdParamPrsRemote
{
public String preSaveRec() throws RemoteException, ITMException
{
return "";
}
public String preSaveRec(String xmlString1, String domId, String objContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{
System.out.println("@@@@@@@@********* CopyCadreADParamPrs Called *******@@@@@@@@");
Document dom = null;
String errString = "";
//ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
try
{
if (xmlString1 != null && xmlString1.trim().length() > 0)
{
dom = GenericUtility.getInstance().parseString(xmlString1);
errString = executepreSaveRec(dom,domId,objContext,editFlag,xtraParams,conn);
if (errString == null || errString.trim().length() == 0)
{
//errString = itmDBAccessLocal.getErrorString("","VTMCONF2","");
}
else
{
conn.rollback();
//errString = itmDBAccessLocal.getErrorString("","VMPROCUSG","");
}
}
}
catch(Exception e)
{
System.out.println("Exception :CopyPayParamPrs :preSaveRec(): " + e.getMessage()+ ":");
e.printStackTrace();
throw new ITMException(e);
}
return errString;
}
private String executepreSaveRec(Document dom, String domID, String ObjContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{
//Connection conn = null;
PreparedStatement pstmt = null,pstmt1 = null,pstmtInser = null;
ResultSet rs = null ,rs1 = null;
String pay_table = "",new_pay_table="";
String sql = "",sql1 = "",sqlInser;
String chgUser = "",chgTerm = "" ;
String cadre_code="",new_cadre_code="";
String ad_code="",type="";
String prop_yn="";
String exp_date=null,eff_date=null;
System.out.println("@@@@@@@@@@@@@@@@@@@@2 TEST");
double amount=0.0,min_basic=0.0,max_basic=0.0;
double min_amt=0.0,max_amt=0.0;
int cnt = 0,updCnt = 0;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
String errString = "";
boolean insertFlag=false;
try
{
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
pay_table = genericUtility.getColumnValue("pay_table",dom);
//varName = genericUtility.getColumnValue("var_name",dom);
new_pay_table = genericUtility.getColumnValue("new_pay_table",dom);
new_cadre_code = genericUtility.getColumnValue("new_cadre_code",dom);
String currAppdate ="";
java.sql.Timestamp currDate = null;
Object date = null;
currDate =new java.sql.Timestamp(System.currentTimeMillis()) ;
System.out.println(genericUtility.getDBDateFormat());
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getDBDateFormat());
date = sdf.parse(currDate.toString());
currDate = java.sql.Timestamp.valueOf(sdf.format(date).toString() + " 00:00:00.0");
currAppdate = new SimpleDateFormat(genericUtility.getApplDateFormat()).format(currDate).toString();
chgUser = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_user");
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_term");
if( pay_table == null || pay_table.trim().length() ==0 )
{
//errString = itmDBAccessEJB.getErrorString("","PRDCODNULL","");
//return errString;
}
else if( new_pay_table == null || new_pay_table.trim().length() == 0 )
{
errString = itmDBAccessEJB.getErrorString("","NEWPAYTBL","");
return errString;
}
else if( new_pay_table != null && new_pay_table.trim().length() > 0 )
{
/*if( new_pay_table.trim().length() > 5 )
{
errString = itmDBAccessEJB.getErrorString("","NEWSITEINV","");
return errString;
}*/
/*else if(checkValidity(new_pay_table, "pay_table", "site", conn)<=0){
insertFlag=true;
errString = itmDBAccessEJB.getErrorString("","NEWSITNEXI","");
return errString;
}*/
}
/*ME if( pay_table != null && pay_table != null && new_pay_table.trim().length() > 0 && pay_table.trim().length() > 0 )
{
//sql = " SELECT var_name,var_type,var_value,descr,var_subs FROM payrparm WHERE prd_code = ? "; // and var_name = ?";
sql="SELECT * FROM PAYTABLE WHERE PAY_TABLE=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,new_pay_table);
rs = pstmt.executeQuery();
if(rs.next()){
}else{
errString = itmDBAccessEJB.getErrorString("","NEWPAYNO","");
return errString;
}*/
if(new_pay_table!=null && checkValidity(new_pay_table, "pay_table", "PAYTABLE", conn)<=0){
//insertFlag=true;
errString = itmDBAccessEJB.getErrorString("","NEWPAYNO","");
return errString;
}
if( new_cadre_code!=null && checkValidity(new_cadre_code, "CADRE_CODE", "CADRE", conn)<=0){
//insertFlag=true;
errString = itmDBAccessEJB.getErrorString("","CCNOEXIST","");
return errString;
}
System.out.println("BEFORE PAYTABLE CADRE CHECK ............");
System.out.println("----------- pay_table : "+pay_table+" grade_code : "+cadre_code);
sql = "SELECT * FROM CADRE_AD WHERE PAY_TABLE=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,pay_table);
//pstmt.setString(2,varName);
rs = pstmt.executeQuery();
while(rs.next())
{
cadre_code = rs.getString("cadre_code");
ad_code =rs.getString("ad_code");
eff_date= rs.getString("eff_date");
exp_date=rs.getString("exp_date");
java.sql.Timestamp expDateChg = null;
expDateChg=getTimestamp(exp_date);
type=rs.getString("type");
amount=rs.getDouble("amount");
min_basic=rs.getDouble("min_basic");
max_basic=rs.getDouble("max_basic");
min_amt=rs.getDouble("min_amt");
max_amt=rs.getDouble("max_amt");
prop_yn=rs.getString("prop_yn");
//sql1 = "SELECT count(*) FROM payrparm WHERE prd_code = ? and var_name = ? ";
sql1 ="SELECT count(*) FROM CADRE_AD WHERE PAY_TABLE = ? and CADRE_CODE=? and AD_CODE=? and EFF_DATE=?";
pstmt1 = conn.prepareStatement(sql1);
if(new_pay_table != null && new_pay_table.trim().length() > 0 && new_cadre_code==null){
//if only new pay table enters then copy data from paytable and against CADRE code into new paytable
System.out.println("COUNT CONDTION 1");
pstmt1.setString(1, new_pay_table);
pstmt1.setString(2, cadre_code);
}else if(new_pay_table == null && new_cadre_code!=null && new_cadre_code.trim().length() > 0){
//if only new CADRECODE enters then copy data from paytable and against CADRE code into exiting paytable with new gradecode
System.out.println("COUNT CONDTION 2");
pstmt1.setString(1, pay_table);
pstmt1.setString(2, new_cadre_code);
} else if(new_pay_table != null && new_pay_table.trim().length() > 0 && new_cadre_code!=null && new_cadre_code.trim().length() > 0){
//if both new PAYTABLE and CADRECODE enters then copy data from paytable and against CADRE code into new paytable and new gradecode
System.out.println("COUNT CONDTION 3");
pstmt1.setString(1, new_pay_table);
pstmt1.setString(2, new_cadre_code);
} else if(new_pay_table == null && new_cadre_code==null ){
// validation
System.out.println("NEW CADRE CODE AND PAYTABLE BOTH ARE EMPTY.........");
errString = itmDBAccessEJB.getErrorString("","PAYCCTBL","");
return errString;
}
//pstmt1.setString(1, new_pay_table);
//pstmt1.setString(2, cadre_code);
pstmt1.setString(3, ad_code);
java.sql.Timestamp effDateChg = null;
effDateChg=getTimestamp(eff_date);
pstmt1.setTimestamp(4, effDateChg);
rs1 = pstmt1.executeQuery();
if(rs1.next())
{
cnt = rs1.getInt(1);
}
rs1.close();
rs1 = null;
pstmt1.close();
pstmt1 = null;
System.out.println("@@@@@:::cnt:["+cnt+"]");
if(cnt == 0)
{
sqlInser = "INSERT INTO CADRE_AD (pay_table, cadre_code, ad_code, eff_date, exp_date, type, amount, min_basic, max_basic, min_amt, max_amt,prop_yn,chg_date,chg_user,chg_term) "
+" VALUES (?,?,?, ?,?,?, ?,?,?, ?,?,?,?,?,?) ";
pstmtInser = conn.prepareStatement(sqlInser);
if(new_pay_table != null && new_pay_table.trim().length() > 0 && new_cadre_code==null ){
//if only new pay table enters then copy data from paytable and against CADRE code into new paytable
System.out.println("INSERT CONDTION 1");
pstmtInser.setString(1, new_pay_table);
pstmtInser.setString(2, cadre_code);
}else if(new_pay_table == null && new_cadre_code!=null && new_cadre_code.trim().length() > 0){
//if only new gradecode enters then copy data from paytable and against CADRE code into exiting paytable with new gradecode
System.out.println("INSERT CONDTION 2");
pstmtInser.setString(1, pay_table);
pstmtInser.setString(2, new_cadre_code);
} else if(new_pay_table != null && new_pay_table.trim().length() > 0 && new_cadre_code!=null && new_cadre_code.trim().length() > 0){
//if both new gradecode and gradecode enters then copy data from paytable and against CADRE code into new paytable and new gradecode
System.out.println("INSERT CONDTION 3");
pstmtInser.setString(1, new_pay_table);
pstmtInser.setString(2, new_cadre_code);
}
//pstmtInser.setString(1,new_pay_table);ME
//pstmtInser.setString(2, cadre_code);ME
pstmtInser.setString(3, ad_code);
pstmtInser.setTimestamp(4,effDateChg);
pstmtInser.setTimestamp(5,expDateChg);
pstmtInser.setString(6, type);
pstmtInser.setDouble(7,amount);
pstmtInser.setDouble(8,min_basic);
pstmtInser.setDouble(9,max_basic);
pstmtInser.setDouble(10,min_amt);
pstmtInser.setDouble(11,max_amt);
pstmtInser.setString(12, prop_yn);
pstmtInser.setTimestamp( 13, currDate);
pstmtInser.setString(14, chgUser);
pstmtInser.setString(15, chgTerm);
System.out.println("@@@@@@@@@@@@@@ BEFORE INSERT "+new_pay_table);
updCnt = pstmtInser.executeUpdate();
pstmtInser.close();
pstmtInser=null;
if(updCnt > 0 )
{
conn.commit();
System.out.println("@@@@@ Record inserted for table no["+new_pay_table +"]:::::::: @@@@@");
}
}
else
{
System.out.println("@@@@@ :::::Record already exist for PeriodCode["+new_pay_table +"]::varName["+ cadre_code +"] :::::: @@@@@");
//errString = itmDBAccessLocal.getErrorString("","VMDUPREC1","");
// errString = itmDBAccessEJB.getErrorString("","NEWPAYAA","");
}
}
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
//valueXmlString.append("</Root>\r\n");
} // end of try
catch(Exception e)
{
try
{
conn.rollback();
}
catch(Exception ex)
{
throw new ITMException(ex);
}
throw new ITMException(e);
}
finally
{
try
{
conn.close();
conn = null;
}
catch(Exception e)
{
throw new ITMException(e);
}
}
return errString ;
}
public String getDD_MM_YYYY_format(String str) throws Exception{
DateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
Date date;
String dd_mm_yyyy="";
date = (Date)formatter.parse(str);
System.out.println("DDMMYYYY="+date);
SimpleDateFormat format = new SimpleDateFormat("dd-MMM-yyyy");
dd_mm_yyyy=format.format(date);
//String orcleFormat= oracleFormatDate(dd_mm_yyyy);
System.out.println("orcleFormat dd-mm-yyyy=="+dd_mm_yyyy);
return dd_mm_yyyy;
}
public Timestamp getTimestamp(String str) throws Exception{
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss.S");
java.util.Date date = sdf.parse(str);
java.sql.Timestamp timestamp = new java.sql.Timestamp(date.getTime());
//System.out.println("====="+timestamp);
return timestamp;
}
public int checkValidity(String retrival, String column_name, String table_name, Connection from_site_conn) throws SQLException{
boolean flag=false;
PreparedStatement pstmt=null;
ResultSet rs=null;
String Query="";
Connection conn=null;
int count=0;
Connection localConnection =null;
try{
conn = from_site_conn;
Query="select count("+column_name+") from "+table_name+" where "+column_name+"='"+retrival+"'";
System.out.println("====QUERY=="+Query);
pstmt=conn.prepareStatement(Query);
rs=pstmt.executeQuery(Query);
if(rs.next()){
count=rs.getInt(1);
}
}catch(Exception e){
e.printStackTrace();
}finally{
if(pstmt!=null){
pstmt.close();
pstmt=null;
}
if(rs!=null){
rs.close();
rs=null;
}
}
System.out.println("count="+count);
return count;
}
}
/* This file is Cteated it incorporate the Pre Save logic from Window
* Gulzar 08/09/06
*/
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.ValidatorLocal;
import ibase.webitm.utility.ITMException;
import java.sql.Connection;
import javax.ejb.Local; // added for ejb3
//public interface SReturnPrs extends ValidatorLocal, EJBObject
@Local // added for ejb3
public interface CopyCadreAdParamPrsLocal extends ValidatorLocal
{
public String preSaveRec()throws RemoteException,ITMException;
public String preSaveRec(String xmlString1,String domID,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException;
}
\ No newline at end of file
/* This file is Cteated it incorporate the Pre Save logic from Window
* Gulzar 08/09/06
*/
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.ValidatorRemote;
import ibase.webitm.utility.ITMException;
import java.sql.Connection;
import javax.ejb.Remote; // added for ejb3
//public interface SReturnPrs extends ValidatorRemote, EJBObject
@Remote // added for ejb3
public interface CopyCadreAdParamPrsRemote extends ValidatorRemote
{
public String preSaveRec()throws RemoteException,ITMException;
public String preSaveRec(String xmlString1,String domID,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm;
import ibase.webitm.utility.*;
//import ibase.utility.CommonConstants;
import ibase.system.config.*;
//import java.text.*;
import java.util.*;
//import javax.xml.parsers.*;
import javax.ejb.*;
//import javax.naming.InitialContext;
import java.io.*;
import java.util.Calendar;
import java.util.Date;
import java.sql.*;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.rmi.RemoteException;
import org.w3c.dom.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.ejb.*;
import javax.ejb.Stateless; // added for ejb3
//public class SReturnPrsEJB extends ValidatorEJB implements SessionBean
@Stateless // added for ejb3
public class CopyCadreMthadParamPrs extends ValidatorEJB implements CopyCadreMthadParamPrsLocal, CopyCadreMthadParamPrsRemote
{
public String preSaveRec() throws RemoteException, ITMException
{
return "";
}
public String preSaveRec(String xmlString1, String domId, String objContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{
System.out.println("@@@@@@@@********* CopyCadreMTHADParamPrs Called *******@@@@@@@@");
Document dom = null;
String errString = "";
//ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
try
{
if (xmlString1 != null && xmlString1.trim().length() > 0)
{
dom = GenericUtility.getInstance().parseString(xmlString1);
errString = executepreSaveRec(dom,domId,objContext,editFlag,xtraParams,conn);
if (errString == null || errString.trim().length() == 0)
{
//errString = itmDBAccessLocal.getErrorString("","VTMCONF2","");
}
else
{
conn.rollback();
//errString = itmDBAccessLocal.getErrorString("","VMPROCUSG","");
}
}
}
catch(Exception e)
{
System.out.println("Exception :CopyPayParamPrs :preSaveRec(): " + e.getMessage()+ ":");
e.printStackTrace();
throw new ITMException(e);
}
return errString;
}
private String executepreSaveRec(Document dom, String domID, String ObjContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{
//Connection conn = null;
PreparedStatement pstmt = null,pstmt1 = null,pstmtInser = null;
ResultSet rs = null ,rs1 = null;
String pay_table = "",new_pay_table="";
String sql = "",sql1 = "",sqlInser;
String chgUser = "",chgTerm = "" ;
String cadre_code="",new_cadre_code="";
String month_code="",new_month_code="";
String ad_code="",type="";
String prop_yn="";
String exp_date=null,eff_date=null;
System.out.println("@@@@@@@@@@@@@@@@@@@@2 TEST");
double amount=0.0,min_basic=0.0,max_basic=0.0;
double min_amt=0.0,max_amt=0.0;
int cnt = 0,updCnt = 0;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
String errString = "";
boolean insertFlag=false;
try
{
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
pay_table = genericUtility.getColumnValue("pay_table",dom);
//varName = genericUtility.getColumnValue("var_name",dom);
new_pay_table = genericUtility.getColumnValue("new_pay_table",dom);
new_cadre_code = genericUtility.getColumnValue("new_cadre_code",dom);
new_month_code = genericUtility.getColumnValue("new_month_code",dom);
String currAppdate ="";
java.sql.Timestamp currDate = null;
Object date = null;
currDate =new java.sql.Timestamp(System.currentTimeMillis()) ;
System.out.println(genericUtility.getDBDateFormat());
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getDBDateFormat());
date = sdf.parse(currDate.toString());
currDate = java.sql.Timestamp.valueOf(sdf.format(date).toString() + " 00:00:00.0");
currAppdate = new SimpleDateFormat(genericUtility.getApplDateFormat()).format(currDate).toString();
chgUser = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_user");
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_term");
if( pay_table == null || pay_table.trim().length() ==0 )
{
//errString = itmDBAccessEJB.getErrorString("","PRDCODNULL","");
//return errString;
}
else if( new_pay_table == null || new_pay_table.trim().length() == 0 )
{
errString = itmDBAccessEJB.getErrorString("","NEWPAYTBL","");
return errString;
}
else if( new_cadre_code == null || new_cadre_code.trim().length() == 0 )
{
errString = itmDBAccessEJB.getErrorString("","NEWCCNEMP","");
return errString;
}
else if( new_month_code == null || new_month_code.trim().length() == 0 )
{
errString = itmDBAccessEJB.getErrorString("","NEWMCNEMP","");
return errString;
}
else if( new_pay_table != null && new_pay_table.trim().length() > 0 )
{
/*if( new_pay_table.trim().length() > 5 )
{
errString = itmDBAccessEJB.getErrorString("","NEWSITEINV","");
return errString;
}*/
/*else if(checkValidity(new_pay_table, "pay_table", "site", conn)<=0){
insertFlag=true;
errString = itmDBAccessEJB.getErrorString("","NEWSITNEXI","");
return errString;
}*/
}
if(new_pay_table!=null && checkValidity(new_pay_table, "pay_table", "PAYTABLE", conn)<=0){
//insertFlag=true;
errString = itmDBAccessEJB.getErrorString("","NEWPAYNO","");
return errString;
}
if( new_cadre_code!=null && checkValidity(new_cadre_code, "CADRE_CODE", "CADRE", conn)<=0){
//insertFlag=true;
errString = itmDBAccessEJB.getErrorString("","CCNOEXIST","");
return errString;
}
if( new_month_code!=null ){
//insertFlag=true;
if(Integer.parseInt(new_month_code) <= 0 || Integer.parseInt(new_month_code) > 12){
errString = itmDBAccessEJB.getErrorString("","MNCNOEXIST","");
return errString;
}
}
/*if( pay_table != null && pay_table != null && new_pay_table.trim().length() > 0 && pay_table.trim().length() > 0 )
{
//sql = " SELECT var_name,var_type,var_value,descr,var_subs FROM payrparm WHERE prd_code = ? "; // and var_name = ?";
sql="SELECT * FROM PAYTABLE WHERE PAY_TABLE=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,new_pay_table);
rs = pstmt.executeQuery();
if(rs.next()){
}else{
errString = itmDBAccessEJB.getErrorString("","NEWPAYNO","");//New Pay table not available
return errString;
} */
sql = "SELECT * FROM CADRE_MTHAD WHERE PAY_TABLE=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,pay_table);
//pstmt.setString(2,varName);
rs = pstmt.executeQuery();
while(rs.next())
{
cadre_code = rs.getString("cadre_code");
month_code=rs.getString("month_code");
ad_code =rs.getString("ad_code");
eff_date= rs.getString("eff_date");
exp_date=rs.getString("exp_date");
java.sql.Timestamp expDateChg = null;
expDateChg=getTimestamp(exp_date);
type=rs.getString("type");
amount=rs.getDouble("amount");
min_basic=rs.getDouble("min_basic");
max_basic=rs.getDouble("max_basic");
min_amt=rs.getDouble("min_amt");
max_amt=rs.getDouble("max_amt");
prop_yn=rs.getString("prop_yn");
//sql1 = "SELECT count(*) FROM payrparm WHERE prd_code = ? and var_name = ? ";
sql1 ="SELECT count(*) FROM CADRE_MTHAD WHERE PAY_TABLE = ? and CADRE_CODE=? and MONTH_CODE=? and AD_CODE=? and EFF_DATE=?";
pstmt1 = conn.prepareStatement(sql1);
pstmt1.setString(1, new_pay_table);
pstmt1.setString(2, new_cadre_code);
pstmt1.setString(3, new_month_code);
pstmt1.setString(4, ad_code);
java.sql.Timestamp effDateChg = null;
effDateChg=getTimestamp(eff_date);
pstmt1.setTimestamp(5, effDateChg);
rs1 = pstmt1.executeQuery();
if(rs1.next())
{
cnt = rs1.getInt(1);
}
rs1.close();
rs1 = null;
pstmt1.close();
pstmt1 = null;
System.out.println("@@@@@:::cnt:["+cnt+"]");
if(cnt == 0)
{
sqlInser = "INSERT INTO CADRE_MTHAD (pay_table, cadre_code,month_code, ad_code, eff_date, exp_date, type, amount, min_basic, max_basic, min_amt, max_amt,prop_yn,chg_date,chg_user,chg_term) "
+" VALUES (?,?,?, ?,?,?, ?,?,?, ?,?,?,?,?,?,?) ";
pstmtInser = conn.prepareStatement(sqlInser);
pstmtInser.setString(1, new_pay_table);
pstmtInser.setString(2, new_cadre_code);
pstmtInser.setString(3, new_month_code);
pstmtInser.setString(4, ad_code);
pstmtInser.setTimestamp(5,effDateChg);
pstmtInser.setTimestamp(6,expDateChg);
pstmtInser.setString(7, type);
pstmtInser.setDouble(8,amount);
pstmtInser.setDouble(9,min_basic);
pstmtInser.setDouble(10,max_basic);
pstmtInser.setDouble(11,min_amt);
pstmtInser.setDouble(12,max_amt);
pstmtInser.setString(13, prop_yn);
pstmtInser.setTimestamp( 14, currDate);
pstmtInser.setString(15, chgUser);
pstmtInser.setString(16, chgTerm);
System.out.println("@@@@@@@@@@@@@@ BEFORE INSERT "+new_pay_table);
updCnt = pstmtInser.executeUpdate();
pstmtInser.close();
pstmtInser=null;
if(updCnt > 0 )
{
conn.commit();
System.out.println("@@@@@ Record inserted for table no["+new_pay_table +"]:::::::: @@@@@");
}
}
else
{
System.out.println("@@@@@ :::::Record already exist for PeriodCode["+new_pay_table +"]::varName["+ new_cadre_code +"] ::varName["+ new_month_code +"] :::::: @@@@@");
//errString = itmDBAccessLocal.getErrorString("","VMDUPREC1","");
//errString = itmDBAccessEJB.getErrorString("","NEWPAYAA","");
}
}
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
//valueXmlString.append("</Root>\r\n");
} // end of try
catch(Exception e)
{
try
{
conn.rollback();
}
catch(Exception ex)
{
throw new ITMException(ex);
}
throw new ITMException(e);
}
finally
{
try
{
conn.close();
conn = null;
}
catch(Exception e)
{
throw new ITMException(e);
}
}
return errString ;
}
public String getDD_MM_YYYY_format(String str) throws Exception{
DateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
Date date;
String dd_mm_yyyy="";
date = (Date)formatter.parse(str);
System.out.println("DDMMYYYY="+date);
SimpleDateFormat format = new SimpleDateFormat("dd-MMM-yyyy");
dd_mm_yyyy=format.format(date);
//String orcleFormat= oracleFormatDate(dd_mm_yyyy);
System.out.println("orcleFormat dd-mm-yyyy=="+dd_mm_yyyy);
return dd_mm_yyyy;
}
public Timestamp getTimestamp(String str) throws Exception{
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss.S");
java.util.Date date = sdf.parse(str);
java.sql.Timestamp timestamp = new java.sql.Timestamp(date.getTime());
//System.out.println("====="+timestamp);
return timestamp;
}
public int checkValidity(String retrival, String column_name, String table_name, Connection from_site_conn) throws SQLException{
boolean flag=false;
PreparedStatement pstmt=null;
ResultSet rs=null;
String Query="";
Connection conn=null;
int count=0;
Connection localConnection =null;
try{
conn = from_site_conn;
Query="select count("+column_name+") from "+table_name+" where "+column_name+"='"+retrival+"'";
System.out.println("====QUERY=="+Query);
pstmt=conn.prepareStatement(Query);
rs=pstmt.executeQuery(Query);
if(rs.next()){
count=rs.getInt(1);
}
}catch(Exception e){
e.printStackTrace();
}finally{
if(pstmt!=null){
pstmt.close();
pstmt=null;
}
if(rs!=null){
rs.close();
rs=null;
}
}
System.out.println("count="+count);
return count;
}
}
/* This file is Cteated it incorporate the Pre Save logic from Window
* Gulzar 08/09/06
*/
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.ValidatorLocal;
import ibase.webitm.utility.ITMException;
import java.sql.Connection;
import javax.ejb.Local; // added for ejb3
//public interface SReturnPrs extends ValidatorLocal, EJBObject
@Local // added for ejb3
public interface CopyCadreMthadParamPrsLocal extends ValidatorLocal
{
public String preSaveRec()throws RemoteException,ITMException;
public String preSaveRec(String xmlString1,String domID,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException;
}
\ No newline at end of file
/* This file is Cteated it incorporate the Pre Save logic from Window
* Gulzar 08/09/06
*/
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.ValidatorRemote;
import ibase.webitm.utility.ITMException;
import java.sql.Connection;
import javax.ejb.Remote; // added for ejb3
//public interface SReturnPrs extends ValidatorRemote, EJBObject
@Remote // added for ejb3
public interface CopyCadreMthadParamPrsRemote extends ValidatorRemote
{
public String preSaveRec()throws RemoteException,ITMException;
public String preSaveRec(String xmlString1,String domID,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm;
import ibase.webitm.utility.*;
//import ibase.utility.CommonConstants;
import ibase.system.config.*;
//import java.text.*;
import java.util.*;
//import javax.xml.parsers.*;
import javax.ejb.*;
//import javax.naming.InitialContext;
import java.io.*;
import java.util.Calendar;
import java.util.Date;
import java.sql.*;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.rmi.RemoteException;
import org.w3c.dom.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.ejb.*;
import javax.ejb.Stateless; // added for ejb3
//public class SReturnPrsEJB extends ValidatorEJB implements SessionBean
@Stateless // added for ejb3
public class CopyCadrePerkParamPrs extends ValidatorEJB implements CopyCadrePerkParamPrsLocal, CopyCadrePerkParamPrsRemote
{
public String preSaveRec() throws RemoteException, ITMException
{
return "";
}
public String preSaveRec(String xmlString1, String domId, String objContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{
System.out.println("@@@@@@@@********* CopyCadrePERKParamPrs Called *******@@@@@@@@");
Document dom = null;
String errString = "";
//ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
try
{
if (xmlString1 != null && xmlString1.trim().length() > 0)
{
dom = GenericUtility.getInstance().parseString(xmlString1);
errString = executepreSaveRec(dom,domId,objContext,editFlag,xtraParams,conn);
if (errString == null || errString.trim().length() == 0)
{
//errString = itmDBAccessLocal.getErrorString("","VTMCONF2","");
}
else
{
conn.rollback();
//errString = itmDBAccessLocal.getErrorString("","VMPROCUSG","");
}
}
}
catch(Exception e)
{
System.out.println("Exception :CopyPayParamPrs :preSaveRec(): " + e.getMessage()+ ":");
e.printStackTrace();
throw new ITMException(e);
}
return errString;
}
private String executepreSaveRec(Document dom, String domID, String ObjContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{
//Connection conn = null;
PreparedStatement pstmt = null,pstmt1 = null,pstmtInser = null;
ResultSet rs = null ,rs1 = null;
String pay_table = "",new_pay_table="";
String sql = "",sql1 = "",sqlInser;
String chgUser = "",chgTerm = "" ;
String cadre_code="",new_cadre_code="";
String ad_code="",type="";
String prop_yn="";
String exp_date=null,eff_date=null,month_code="";
String ad_code_main="" ;
double cycle_time=0.0,cycle_start=0.0,cycle_end=0.0,validity_period=0.0;
String last_proc_for="",next_proc_date="";
System.out.println("@@@@@@@@@@@@@@@@@@@@2 TEST");
double amount=0.0,min_basic=0.0,max_basic=0.0;
double min_amt=0.0,max_amt=0.0;
int cnt = 0,updCnt = 0;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
String errString = "";
boolean insertFlag=false;
try
{
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
pay_table = genericUtility.getColumnValue("pay_table",dom);
//varName = genericUtility.getColumnValue("var_name",dom);
new_pay_table = genericUtility.getColumnValue("new_pay_table",dom);
new_cadre_code = genericUtility.getColumnValue("new_cadre_code",dom);
String currAppdate ="";
java.sql.Timestamp currDate = null;
Object date = null;
currDate =new java.sql.Timestamp(System.currentTimeMillis()) ;
System.out.println(genericUtility.getDBDateFormat());
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getDBDateFormat());
date = sdf.parse(currDate.toString());
currDate = java.sql.Timestamp.valueOf(sdf.format(date).toString() + " 00:00:00.0");
currAppdate = new SimpleDateFormat(genericUtility.getApplDateFormat()).format(currDate).toString();
chgUser = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_user");
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_term");
if( pay_table == null || pay_table.trim().length() ==0 )
{
//errString = itmDBAccessEJB.getErrorString("","PRDCODNULL","");
//return errString;
}
else if( new_pay_table == null || new_pay_table.trim().length() == 0 )
{
//------PAY TABLE NOT LEAVE EMPTY
errString = itmDBAccessEJB.getErrorString("","NEWPAYTBL","");
return errString;
}
else if( new_pay_table != null && new_pay_table.trim().length() > 0 )
{
/*if( new_pay_table.trim().length() > 5 )
{
errString = itmDBAccessEJB.getErrorString("","NEWSITEINV","");
return errString;
}*/
/*else if(checkValidity(new_pay_table, "pay_table", "site", conn)<=0){
insertFlag=true;
errString = itmDBAccessEJB.getErrorString("","NEWSITNEXI","");
return errString;
}*/
}
/*ME if( pay_table != null && pay_table != null && new_pay_table.trim().length() > 0 && pay_table.trim().length() > 0 )
{
//sql = " SELECT var_name,var_type,var_value,descr,var_subs FROM payrparm WHERE prd_code = ? "; // and var_name = ?";
sql="SELECT * FROM PAYTABLE WHERE PAY_TABLE=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,new_pay_table);
rs = pstmt.executeQuery();
if(rs.next()){
}else{
errString = itmDBAccessEJB.getErrorString("","NEWPAYNO","");//New Pay table not available
return errString;
} */
if(new_pay_table!=null && checkValidity(new_pay_table, "pay_table", "PAYTABLE", conn)<=0){
//insertFlag=true;
errString = itmDBAccessEJB.getErrorString("","NEWPAYNO","");
return errString;
}
if( new_cadre_code!=null && checkValidity(new_cadre_code, "CADRE_CODE", "CADRE", conn)<=0){
//insertFlag=true;
errString = itmDBAccessEJB.getErrorString("","CCNOEXIST","");
return errString;
}
System.out.println("BEFORE PAYTABLE CADRE CHECK ............");
System.out.println("----------- pay_table : "+pay_table+" grade_code : "+cadre_code);
sql = "SELECT * FROM CADRE_PERK WHERE PAY_TABLE=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,pay_table);
//pstmt.setString(2,varName);
rs = pstmt.executeQuery();
while(rs.next())
{
cadre_code = rs.getString("cadre_code");
ad_code_main =rs.getString("ad_code__main");
ad_code =rs.getString("ad_code");
eff_date= rs.getString("eff_date");
exp_date=rs.getString("exp_date");
java.sql.Timestamp expDateChg = null;
expDateChg=getTimestamp(exp_date);
type=rs.getString("type");
amount=rs.getDouble("amount");
cycle_time=rs.getDouble("cycle_time");
cycle_start=rs.getDouble("cycle_start");
cycle_end=rs.getDouble("cycle_end");
last_proc_for=rs.getString("last_proc_for");
java.sql.Timestamp last_proc_forChg = null;
last_proc_forChg=getTimestamp(last_proc_for);
next_proc_date=rs.getString("next_proc_date");
java.sql.Timestamp next_proc_dateChg = null;
next_proc_dateChg=getTimestamp(next_proc_date);
validity_period=rs.getDouble("validity_period");
//sql1 = "SELECT count(*) FROM CADRE_PERK WHERE prd_code = ? and var_name = ? ";
sql1 ="SELECT count(*) FROM CADRE_PERK WHERE PAY_TABLE = ? and CADRE_CODE=? and AD_CODE=? and AD_CODE__MAIN=? and EFF_DATE=?";
pstmt1 = conn.prepareStatement(sql1);
if(new_pay_table != null && new_pay_table.trim().length() > 0 && new_cadre_code==null){
//if only new pay table enters then copy data from paytable and against CADRE code into new paytable
System.out.println("COUNT CONDTION 1");
pstmt1.setString(1, new_pay_table);
pstmt1.setString(2, cadre_code);
}else if(new_pay_table == null && new_cadre_code!=null && new_cadre_code.trim().length() > 0){
//if only new gradecode enters then copy data from paytable and against CADRE code into exiting paytable with new gradecode
System.out.println("COUNT CONDTION 2");
pstmt1.setString(1, pay_table);
pstmt1.setString(2, new_cadre_code);
} else if(new_pay_table != null && new_pay_table.trim().length() > 0 && new_cadre_code!=null && new_cadre_code.trim().length() > 0){
//if both new gradecode and gradecode enters then copy data from paytable and against CADRE code into new paytable and new gradecode
System.out.println("COUNT CONDTION 3");
pstmt1.setString(1, new_pay_table);
pstmt1.setString(2, new_cadre_code);
} else if(new_pay_table == null && new_cadre_code==null ){
// validation
System.out.println("NEW CADRE CODE AND PAYTABLE BOTH ARE EMPTY.........");
errString = itmDBAccessEJB.getErrorString("","PAYCCTBL","");
return errString;
}
//pstmt1.setString(1, new_pay_table);ME
//pstmt1.setString(2, cadre_code);ME
pstmt1.setString(3, ad_code);
pstmt1.setString(4, ad_code_main);
java.sql.Timestamp effDateChg = null;
effDateChg=getTimestamp(eff_date);
pstmt1.setTimestamp(5, effDateChg);
rs1 = pstmt1.executeQuery();
if(rs1.next())
{
cnt = rs1.getInt(1);
}
rs1.close();
rs1 = null;
pstmt1.close();
pstmt1 = null;
System.out.println("@@@@@:::cnt:["+cnt+"]");
if(cnt == 0)
{
sqlInser = "INSERT INTO CADRE_PERK (pay_table, cadre_code, ad_code,ad_code__main, eff_date, exp_date, type, amount, cycle_time, cycle_start, cycle_end, last_proc_for,next_proc_date,chg_date,chg_user,chg_term,validity_period) "
+" VALUES (?,?,?, ?,?,?, ?,?,?, ?,?,?,?,?,?,?,?) ";
pstmtInser = conn.prepareStatement(sqlInser);
if(new_pay_table != null && new_pay_table.trim().length() > 0 && new_cadre_code==null ){
//if only new pay table enters then copy data from paytable and against CADRE code into new paytable
System.out.println("INSERT CONDTION 1");
pstmtInser.setString(1, new_pay_table);
pstmtInser.setString(2, cadre_code);
}else if(new_pay_table == null && new_cadre_code!=null && new_cadre_code.trim().length() > 0){
//if only new gradecode enters then copy data from paytable and against CADRE code into exiting paytable with new gradecode
System.out.println("INSERT CONDTION 2");
pstmtInser.setString(1, pay_table);
pstmtInser.setString(2, new_cadre_code);
} else if(new_pay_table != null && new_pay_table.trim().length() > 0 && new_cadre_code!=null && new_cadre_code.trim().length() > 0){
//if both new gradecode and gradecode enters then copy data from paytable and against CADRE code into new paytable and new gradecode
System.out.println("INSERT CONDTION 3");
pstmtInser.setString(1, new_pay_table);
pstmtInser.setString(2, new_cadre_code);
}
//pstmtInser.setString(1,new_pay_table);me
//pstmtInser.setString(2, cadre_code);me
pstmtInser.setString(3, ad_code);
pstmtInser.setString(4, ad_code_main);
pstmtInser.setTimestamp(5,effDateChg);
pstmtInser.setTimestamp(6,expDateChg);
pstmtInser.setString(7, type);
pstmtInser.setDouble(8,amount);
pstmtInser.setDouble(9,cycle_time);
pstmtInser.setDouble(10,cycle_start);
pstmtInser.setDouble(11,cycle_end);
pstmtInser.setTimestamp(12,last_proc_forChg);
pstmtInser.setTimestamp(13, next_proc_dateChg);
pstmtInser.setTimestamp( 14, currDate);
pstmtInser.setString(15, chgUser);
pstmtInser.setString(16, chgTerm);
pstmtInser.setDouble(17,validity_period);
System.out.println("@@@@@@@@@@@@@@ BEFORE INSERT "+new_pay_table);
updCnt = pstmtInser.executeUpdate();
pstmtInser.close();
pstmtInser=null;
if(updCnt > 0 )
{
conn.commit();
System.out.println("@@@@@ Record inserted for table no["+new_pay_table +"]:::::::: @@@@@");
}
}
else
{
System.out.println("@@@@@ :::::Record already exist for PeriodCode["+new_pay_table +"]::varName["+ cadre_code +"] :::::: @@@@@");
//errString = itmDBAccessLocal.getErrorString("","VMDUPREC1","");
// errString = itmDBAccessEJB.getErrorString("","NEWPAYAA","");
}
}
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
//valueXmlString.append("</Root>\r\n");
} // end of try
catch(Exception e)
{
try
{
conn.rollback();
}
catch(Exception ex)
{
throw new ITMException(ex);
}
throw new ITMException(e);
}
finally
{
try
{
conn.close();
conn = null;
}
catch(Exception e)
{
throw new ITMException(e);
}
}
return errString ;
}
public String getDD_MM_YYYY_format(String str) throws Exception{
DateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
Date date;
String dd_mm_yyyy="";
date = (Date)formatter.parse(str);
System.out.println("DDMMYYYY="+date);
SimpleDateFormat format = new SimpleDateFormat("dd-MMM-yyyy");
dd_mm_yyyy=format.format(date);
//String orcleFormat= oracleFormatDate(dd_mm_yyyy);
System.out.println("orcleFormat dd-mm-yyyy=="+dd_mm_yyyy);
return dd_mm_yyyy;
}
public Timestamp getTimestamp(String str) throws Exception{
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss.S");
java.util.Date date = sdf.parse(str);
java.sql.Timestamp timestamp = new java.sql.Timestamp(date.getTime());
//System.out.println("====="+timestamp);
return timestamp;
}
public int checkValidity(String retrival, String column_name, String table_name, Connection from_site_conn) throws SQLException{
boolean flag=false;
PreparedStatement pstmt=null;
ResultSet rs=null;
String Query="";
Connection conn=null;
int count=0;
Connection localConnection =null;
try{
conn = from_site_conn;
Query="select count("+column_name+") from "+table_name+" where "+column_name+"='"+retrival+"'";
System.out.println("====QUERY=="+Query);
pstmt=conn.prepareStatement(Query);
rs=pstmt.executeQuery(Query);
if(rs.next()){
count=rs.getInt(1);
}
}catch(Exception e){
e.printStackTrace();
}finally{
if(pstmt!=null){
pstmt.close();
pstmt=null;
}
if(rs!=null){
rs.close();
rs=null;
}
}
System.out.println("count="+count);
return count;
}
}
/* This file is Cteated it incorporate the Pre Save logic from Window
* Gulzar 08/09/06
*/
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.ValidatorLocal;
import ibase.webitm.utility.ITMException;
import java.sql.Connection;
import javax.ejb.Local; // added for ejb3
//public interface SReturnPrs extends ValidatorLocal, EJBObject
@Local // added for ejb3
public interface CopyCadrePerkParamPrsLocal extends ValidatorLocal
{
public String preSaveRec()throws RemoteException,ITMException;
public String preSaveRec(String xmlString1,String domID,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException;
}
\ No newline at end of file
/* This file is Cteated it incorporate the Pre Save logic from Window
* Gulzar 08/09/06
*/
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.ValidatorRemote;
import ibase.webitm.utility.ITMException;
import java.sql.Connection;
import javax.ejb.Remote; // added for ejb3
//public interface SReturnPrs extends ValidatorRemote, EJBObject
@Remote // added for ejb3
public interface CopyCadrePerkParamPrsRemote extends ValidatorRemote
{
public String preSaveRec()throws RemoteException,ITMException;
public String preSaveRec(String xmlString1,String domID,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm;
import ibase.webitm.utility.*;
//import ibase.utility.CommonConstants;
import ibase.system.config.*;
//import java.text.*;
import java.util.*;
//import javax.xml.parsers.*;
import javax.ejb.*;
//import javax.naming.InitialContext;
import java.io.*;
import java.util.Calendar;
import java.util.Date;
import java.sql.*;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.rmi.RemoteException;
import org.w3c.dom.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.ejb.*;
import javax.ejb.Stateless; // added for ejb3
//public class SReturnPrsEJB extends ValidatorEJB implements SessionBean
@Stateless // added for ejb3
public class CopyGradeAdParamPrs extends ValidatorEJB implements CopyGradeAdParamPrsLocal, CopyGradeAdParamPrsRemote
{
public String preSaveRec() throws RemoteException, ITMException
{
return "";
}
public String preSaveRec(String xmlString1, String domId, String objContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{
System.out.println("@@@@@@@@********* CopyGradeOtParamPrs Called *******@@@@@@@@");
Document dom = null;
String errString = "";
//ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
try
{
if (xmlString1 != null && xmlString1.trim().length() > 0)
{
dom = GenericUtility.getInstance().parseString(xmlString1);
errString = executepreSaveRec(dom,domId,objContext,editFlag,xtraParams,conn);
if (errString == null || errString.trim().length() == 0)
{
//errString = itmDBAccessLocal.getErrorString("","VTMCONF2","");
}
else
{
conn.rollback();
//errString = itmDBAccessLocal.getErrorString("","VMPROCUSG","");
}
}
}
catch(Exception e)
{
System.out.println("Exception :CopyPayParamPrs :preSaveRec(): " + e.getMessage()+ ":");
e.printStackTrace();
throw new ITMException(e);
}
return errString;
}
private String executepreSaveRec(Document dom, String domID, String ObjContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{
//Connection conn = null;
PreparedStatement pstmt = null,pstmt1 = null,pstmtInser = null;
ResultSet rs = null ,rs1 = null;
String pay_table = "",new_pay_table="";
String sql = "",sql1 = "",sqlInser;
String chgUser = "",chgTerm = "",descr = "";
String grade_code="",new_grade_code="";
String limit_type="";
String ad_code="",type="";
String prop_yn="";
String exp_date=null,eff_date=null;
double min_minutes=0.0;
double limit_hrs=0.0;
double amount=0.0,min_basic=0.0,max_basic=0.0;
double min_amt=0.0,max_amt=0.0;
int cnt = 0,updCnt = 0;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
String errString = "";
boolean insertFlag=false;
try
{
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
pay_table = genericUtility.getColumnValue("pay_table",dom);
//varName = genericUtility.getColumnValue("var_name",dom);
new_pay_table = genericUtility.getColumnValue("new_pay_table",dom);
new_grade_code = genericUtility.getColumnValue("new_grade_code",dom);
String currAppdate ="";
java.sql.Timestamp currDate = null;
Object date = null;
currDate =new java.sql.Timestamp(System.currentTimeMillis()) ;
System.out.println(genericUtility.getDBDateFormat());
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getDBDateFormat());
date = sdf.parse(currDate.toString());
currDate = java.sql.Timestamp.valueOf(sdf.format(date).toString() + " 00:00:00.0");
currAppdate = new SimpleDateFormat(genericUtility.getApplDateFormat()).format(currDate).toString();
chgUser = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_user");
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_term");
if( pay_table == null || pay_table.trim().length() ==0 )
{
//errString = itmDBAccessEJB.getErrorString("","PRDCODNULL","");
//return errString;
}
else if( new_pay_table == null || new_pay_table.trim().length() == 0 )
{
errString = itmDBAccessEJB.getErrorString("","NEWPAYTBL","");
return errString;
}
else if( new_pay_table != null && new_pay_table.trim().length() > 0 )
{
/* if( new_pay_table.trim().length() > 5 )
{
errString = itmDBAccessEJB.getErrorString("","NEWSITEINV","");
return errString;
}*/
/*else if(checkValidity(new_pay_table, "pay_table", "site", conn)<=0){
insertFlag=true;
errString = itmDBAccessEJB.getErrorString("","NEWSITNEXI","");
return errString;
}*/
}
if(new_pay_table!=null && checkValidity(new_pay_table, "pay_table", "PAYTABLE", conn)<=0){
//insertFlag=true;
errString = itmDBAccessEJB.getErrorString("","NEWPAYNO","");
return errString;
}
if( new_grade_code!=null && checkValidity(new_grade_code, "GRADE_CODE", "GRADE", conn)<=0){
//insertFlag=true;
errString = itmDBAccessEJB.getErrorString("","GCNOEXIST","");
return errString;
}
/*MEif( pay_table != null && pay_table != null && new_pay_table.trim().length() > 0 && pay_table.trim().length() > 0 )
{
//sql = " SELECT var_name,var_type,var_value,descr,var_subs FROM payrparm WHERE prd_code = ? "; // and var_name = ?";
sql="SELECT * FROM PAYTABLE WHERE PAY_TABLE=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,new_pay_table);
rs = pstmt.executeQuery();
if(rs.next()){
}else{
errString = itmDBAccessEJB.getErrorString("","NEWPAYNO","");
return errString;
}*/
System.out.println("BEFORE PAYTABLE GRADE_AD CHECK ............");
System.out.println("----------- pay_table : "+pay_table+" grade_code : "+grade_code);
sql = "SELECT * FROM GRADE_AD WHERE PAY_TABLE=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,pay_table);
//pstmt.setString(2,varName);
rs = pstmt.executeQuery();
while(rs.next())
{
grade_code = rs.getString("grade_code");
ad_code =rs.getString("ad_code");
eff_date= rs.getString("eff_date");
exp_date=rs.getString("exp_date");
java.sql.Timestamp expDateChg = null;
expDateChg=getTimestamp(exp_date);
type=rs.getString("type");
amount=rs.getDouble("amount");
min_basic=rs.getDouble("min_basic");
max_basic=rs.getDouble("max_basic");
min_amt=rs.getDouble("min_amt");
max_amt=rs.getDouble("max_amt");
prop_yn=rs.getString("prop_yn");
System.out.println("IN LOOP");
//sql1 = "SELECT count(*) FROM payrparm WHERE prd_code = ? and var_name = ? ";
sql1 ="SELECT count(*) FROM GRADE_AD WHERE PAY_TABLE = ? and GRADE_CODE=? and AD_CODE=? and EFF_DATE=?";
pstmt1 = conn.prepareStatement(sql1);
if(new_pay_table != null && new_pay_table.trim().length() > 0 && new_grade_code==null){
//if only new pay table enters then copy data from paytable and against grade code into new paytable
System.out.println("COUNT CONDTION 1");
pstmt1.setString(1, new_pay_table);
pstmt1.setString(2, grade_code);
}else if(new_pay_table == null && new_grade_code!=null && new_grade_code.trim().length() > 0){
//if only new gradecode enters then copy data from paytable and against grade code into exiting paytable with new gradecode
System.out.println("COUNT CONDTION 2");
pstmt1.setString(1, pay_table);
pstmt1.setString(2, new_grade_code);
} else if(new_pay_table != null && new_pay_table.trim().length() > 0 && new_grade_code!=null && new_grade_code.trim().length() > 0){
//if both new gradecode and gradecode enters then copy data from paytable and against grade code into new paytable and new gradecode
System.out.println("COUNT CONDTION 3");
pstmt1.setString(1, new_pay_table);
pstmt1.setString(2, new_grade_code);
} else if(new_pay_table == null && new_grade_code==null ){
// validation
System.out.println("NEW GRADE CODE AND PAYTABLE BOTH ARE EMPTY.........");
errString = itmDBAccessEJB.getErrorString("","PAYGRTBL","");
return errString;
}
pstmt1.setString(3, ad_code);
java.sql.Timestamp effDateChg = null;
effDateChg=getTimestamp(eff_date);
pstmt1.setTimestamp(4, effDateChg);
rs1 = pstmt1.executeQuery();
if(rs1.next())
{
cnt = rs1.getInt(1);
}
rs1.close();
rs1 = null;
pstmt1.close();
pstmt1 = null;
System.out.println("@@@@@:::cnt:["+cnt+"]");
if(cnt == 0)
{
sqlInser = "INSERT INTO GRADE_AD (pay_table, grade_code, ad_code, eff_date, exp_date, type, amount, min_basic, max_basic, min_amt, max_amt,prop_yn,chg_date,chg_user,chg_term) "
+" VALUES (?,?,?, ?,?,?, ?,?,?, ?,?,?,?,?,?) ";
pstmtInser = conn.prepareStatement(sqlInser);
if(new_pay_table != null && new_pay_table.trim().length() > 0 && new_grade_code==null ){
//if only new pay table enters then copy data from paytable and against grade code into new paytable
System.out.println("INSERT CONDTION 1");
pstmtInser.setString(1, new_pay_table);
pstmtInser.setString(2, grade_code);
}else if(new_pay_table == null && new_grade_code!=null && new_grade_code.trim().length() > 0){
//if only new gradecode enters then copy data from paytable and against grade code into exiting paytable with new gradecode
System.out.println("INSERT CONDTION 2");
pstmtInser.setString(1, pay_table);
pstmtInser.setString(2, new_grade_code);
} else if(new_pay_table != null && new_pay_table.trim().length() > 0 && new_grade_code!=null && new_grade_code.trim().length() > 0){
//if both new gradecode and gradecode enters then copy data from paytable and against grade code into new paytable and new gradecode
System.out.println("INSERT CONDTION 3");
pstmtInser.setString(1, new_pay_table);
pstmtInser.setString(2, new_grade_code);
}
//pstmtInser.setString(1,new_pay_table);me
//pstmtInser.setString(2, grade_code);me
pstmtInser.setString(3, ad_code);
pstmtInser.setTimestamp(4,effDateChg);
pstmtInser.setTimestamp(5,expDateChg);
pstmtInser.setString(6, type);
pstmtInser.setDouble(7,amount);
pstmtInser.setDouble(8,min_basic);
pstmtInser.setDouble(9,max_basic);
pstmtInser.setDouble(10,min_amt);
pstmtInser.setDouble(11,max_amt);
pstmtInser.setString(12, prop_yn);
pstmtInser.setTimestamp( 13, currDate);
pstmtInser.setString(14, chgUser);
pstmtInser.setString(15, chgTerm);
updCnt = pstmtInser.executeUpdate();
pstmtInser.close();
pstmtInser=null;
if(updCnt > 0 )
{
conn.commit();
System.out.println("@@@@@ Record inserted for table no["+new_pay_table +"]:::::::: @@@@@");
}
}
else
{
System.out.println("@@@@@ :::::Record already exist for PeriodCode["+new_pay_table +"]::varName["+ new_pay_table +"] :::::: @@@@@");
//errString = itmDBAccessLocal.getErrorString("","VMDUPREC1","");
//ME errString = itmDBAccessEJB.getErrorString("","NEWPAYAA","");
}
}
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
//}
//valueXmlString.append("</Root>\r\n");
} // end of try
catch(Exception e)
{
try
{
conn.rollback();
}
catch(Exception ex)
{
throw new ITMException(ex);
}
throw new ITMException(e);
}
finally
{
try
{
conn.close();
conn = null;
}
catch(Exception e)
{
throw new ITMException(e);
}
}
return errString ;
}
public String getDD_MM_YYYY_format(String str) throws Exception{
DateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
Date date;
String dd_mm_yyyy="";
date = (Date)formatter.parse(str);
System.out.println("DDMMYYYY="+date);
SimpleDateFormat format = new SimpleDateFormat("dd-MMM-yyyy");
dd_mm_yyyy=format.format(date);
//String orcleFormat= oracleFormatDate(dd_mm_yyyy);
System.out.println("orcleFormat dd-mm-yyyy=="+dd_mm_yyyy);
return dd_mm_yyyy;
}
public Timestamp getTimestamp(String str) throws Exception{
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss.S");
java.util.Date date = sdf.parse(str);
java.sql.Timestamp timestamp = new java.sql.Timestamp(date.getTime());
//System.out.println("====="+timestamp);
return timestamp;
}
public int checkValidity(String retrival, String column_name, String table_name, Connection from_site_conn) throws SQLException{
boolean flag=false;
PreparedStatement pstmt=null;
ResultSet rs=null;
String Query="";
Connection conn=null;
int count=0;
Connection localConnection =null;
try{
conn = from_site_conn;
Query="select count("+column_name+") from "+table_name+" where "+column_name+"='"+retrival+"'";
System.out.println("====QUERY=="+Query);
pstmt=conn.prepareStatement(Query);
rs=pstmt.executeQuery(Query);
if(rs.next()){
count=rs.getInt(1);
}
}catch(Exception e){
e.printStackTrace();
}finally{
if(pstmt!=null){
pstmt.close();
pstmt=null;
}
if(rs!=null){
rs.close();
rs=null;
}
}
System.out.println("count="+count);
return count;
}
}
/* This file is Cteated it incorporate the Pre Save logic from Window
* Gulzar 08/09/06
*/
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.ValidatorLocal;
import ibase.webitm.utility.ITMException;
import java.sql.Connection;
import javax.ejb.Local; // added for ejb3
//public interface SReturnPrs extends ValidatorLocal, EJBObject
@Local // added for ejb3
public interface CopyGradeAdParamPrsLocal extends ValidatorLocal
{
public String preSaveRec()throws RemoteException,ITMException;
public String preSaveRec(String xmlString1,String domID,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException;
}
\ No newline at end of file
/* This file is Cteated it incorporate the Pre Save logic from Window
* Gulzar 08/09/06
*/
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.ValidatorRemote;
import ibase.webitm.utility.ITMException;
import java.sql.Connection;
import javax.ejb.Remote; // added for ejb3
//public interface SReturnPrs extends ValidatorRemote, EJBObject
@Remote // added for ejb3
public interface CopyGradeAdParamPrsRemote extends ValidatorRemote
{
public String preSaveRec()throws RemoteException,ITMException;
public String preSaveRec(String xmlString1,String domID,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm;
import ibase.webitm.utility.*;
//import ibase.utility.CommonConstants;
import ibase.system.config.*;
//import java.text.*;
import java.util.*;
//import javax.xml.parsers.*;
import javax.ejb.*;
//import javax.naming.InitialContext;
import java.io.*;
import java.util.Calendar;
import java.util.Date;
import java.sql.*;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.rmi.RemoteException;
import org.w3c.dom.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.ejb.*;
import javax.ejb.Stateless; // added for ejb3
//public class SReturnPrsEJB extends ValidatorEJB implements SessionBean
@Stateless // added for ejb3
public class CopyGradeMthad extends ValidatorEJB implements CopyGradeMthadLocal, CopyGradeMthadRemote
{
public String preSaveRec() throws RemoteException, ITMException
{
return "";
}
public String preSaveRec(String xmlString1, String domId, String objContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{
System.out.println("@@@@@@@@********* CopyGradeMthad Called *******@@@@@@@@");
Document dom = null;
String errString = "";
//ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
try
{
if (xmlString1 != null && xmlString1.trim().length() > 0)
{
dom = GenericUtility.getInstance().parseString(xmlString1);
errString = executepreSaveRec(dom,domId,objContext,editFlag,xtraParams,conn);
if (errString == null || errString.trim().length() == 0)
{
//errString = itmDBAccessLocal.getErrorString("","VTMCONF2","");
}
else
{
conn.rollback();
//errString = itmDBAccessLocal.getErrorString("","VMPROCUSG","");
}
}
}
catch(Exception e)
{
System.out.println("Exception :CopyPayParamPrs :preSaveRec(): " + e.getMessage()+ ":");
e.printStackTrace();
throw new ITMException(e);
}
return errString;
}
private String executepreSaveRec(Document dom, String domID, String ObjContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{
//Connection conn = null;
PreparedStatement pstmt = null,pstmt1 = null,pstmtInser = null;
ResultSet rs = null ,rs1 = null;
String grade_code = "",new_grade_code="";
String sql = "",sql1 = "",sqlInser;
String chgUser = "",chgTerm = "",descr = "";
//String grade_code="";
String limit_type="";
String month_code="",new_month_code="";
String pay_table="";
String new_pay_table="";
String ad_code="";
String eff_date="";
String exp_date="";
String type="";
String prop_yn="";
int amount=0;
int min_basic=0;
int max_basic=0;
int min_amount=0;
int max_amount=0;
int cnt = 0,updCnt = 0;
Date chgdate = null;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
String errString = "";
boolean insertFlag=false;
try
{
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
pay_table = genericUtility.getColumnValue("pay_table",dom);
//varName = genericUtility.getColumnValue("var_name",dom);
new_pay_table = genericUtility.getColumnValue("new_pay_table",dom);
new_grade_code = genericUtility.getColumnValue("new_grade_code",dom);
new_month_code = genericUtility.getColumnValue("new_month_code",dom);
String currAppdate ="";
java.sql.Timestamp currDate = null;
Object date = null;
currDate =new java.sql.Timestamp(System.currentTimeMillis()) ;
System.out.println(genericUtility.getDBDateFormat());
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getDBDateFormat());
date = sdf.parse(currDate.toString());
currDate = java.sql.Timestamp.valueOf(sdf.format(date).toString() + " 00:00:00.0");
currAppdate = new SimpleDateFormat(genericUtility.getApplDateFormat()).format(currDate).toString();
chgUser = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_user");
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_term");
if( pay_table == null || pay_table.trim().length() ==0 )
{
//errString = itmDBAccessEJB.getErrorString("","PRDCODNULL","");
//return errString;
}
else if( new_pay_table == null || new_pay_table.trim().length() == 0 )
{
errString = itmDBAccessEJB.getErrorString("","NEWPAYTBL","");
return errString;
}
else if( new_grade_code == null || new_grade_code.trim().length() == 0 )
{
errString = itmDBAccessEJB.getErrorString("","NEWGCNEMP","");
return errString;
}
else if( new_month_code == null || new_month_code.trim().length() == 0 )
{
errString = itmDBAccessEJB.getErrorString("","NEWMCNEMP","");
return errString;
}
else if( new_pay_table != null && new_pay_table.trim().length() > 0 )
{
/*if( new_pay_table.trim().length() > 5 )
{
errString = itmDBAccessEJB.getErrorString("","NEWSITEINV","");
return errString;
}
else if(checkValidity(new_pay_table, "pay_table", "paytable", conn)<=0){
insertFlag=true;
errString = itmDBAccessEJB.getErrorString("","NEWSITNEXI","");
return errString;
}*/
}
if(new_pay_table!=null && checkValidity(new_pay_table, "pay_table", "PAYTABLE", conn)<=0){
//insertFlag=true;
errString = itmDBAccessEJB.getErrorString("","NEWPAYNO","");
return errString;
}
if( new_grade_code !=null && checkValidity(new_grade_code, "GRADE_CODE", "GRADE", conn)<=0){
//insertFlag=true;
errString = itmDBAccessEJB.getErrorString("","GCNOEXIST","");
return errString;
}
if( new_month_code!=null ){
//insertFlag=true;
if(Integer.parseInt(new_month_code) <= 0 || Integer.parseInt(new_month_code) > 12){
errString = itmDBAccessEJB.getErrorString("","MNCNOEXIST","");
return errString;
}
}
if( pay_table != null && pay_table != null && new_pay_table.trim().length() > 0 && pay_table.trim().length() > 0)
{
//sql = " SELECT var_name,var_type,var_value,descr,var_subs FROM payrparm WHERE prd_code = ? "; // and var_name = ?";
sql = "SELECT * FROM GRADE_MTHAD WHERE PAY_TABLE=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,pay_table);
//pstmt.setString(2,varName);
rs = pstmt.executeQuery();
while(rs.next())
{
System.out.println("inside rs");
grade_code = rs.getString("grade_code");
month_code= rs.getString("month_code");
ad_code =rs.getString("ad_code");
eff_date =rs.getString("eff_date");
exp_date =rs.getString("exp_date");
type = rs.getString("type");
amount =rs.getInt("amount");
min_basic =rs.getInt("min_basic");
max_basic =rs.getInt("max_basic");
min_amount =rs.getInt("min_amt");
max_amount =rs.getInt("max_amt");
prop_yn = rs.getString("prop_yn");
//sql1 = "SELECT count(*) FROM payrparm WHERE prd_code = ? and var_name = ? ";
sql1 ="SELECT count(*) FROM GRADE_MTHAD WHERE PAY_TABLE = ? and GRADE_CODE=? AND MONTH_CODE=? AND AD_CODE=? AND EFF_DATE=?";
pstmt1 = conn.prepareStatement(sql1);
pstmt1.setString(1, new_pay_table);
pstmt1.setString(2, new_grade_code);
pstmt1.setString(3, new_month_code);
pstmt1.setString(4, ad_code);
java.sql.Timestamp effDateChg = null;
effDateChg=getTimestamp(eff_date);
pstmt1.setTimestamp(5, effDateChg);
rs1 = pstmt1.executeQuery();
if(rs1.next())
{
cnt = rs1.getInt(1);
}
rs1.close();
rs1 = null;
pstmt1.close();
pstmt1 = null;
System.out.println("@@@@@:::cnt:["+cnt+"]");
if(cnt == 0)
{
sqlInser = "INSERT INTO GRADE_MTHAD ( pay_table, grade_code, month_code, ad_code, eff_date, exp_date, type, amount, min_basic, max_basic, min_amt, max_amt, prop_yn, chg_date, chg_user, chg_term) "
+" VALUES (?,?,?, ?,?,?, ?,?,?, ?,?,?,?,?,?,?) ";
pstmtInser = conn.prepareStatement(sqlInser);
pstmtInser.setString(1,new_pay_table);
pstmtInser.setString(2, new_grade_code);
pstmtInser.setString(3, new_month_code);
pstmtInser.setString(4, ad_code );
pstmtInser.setString(5, getDD_MM_YYYY_format(eff_date) );
pstmtInser.setString(6, getDD_MM_YYYY_format(exp_date) );
pstmtInser.setString(7, type );
pstmtInser.setInt(8, amount );
pstmtInser.setInt(9, min_basic );
pstmtInser.setInt(10, max_basic );
pstmtInser.setInt(11, min_amount);
pstmtInser.setInt(12, max_amount);
pstmtInser.setString(13, prop_yn );
pstmtInser.setTimestamp(14,currDate);
pstmtInser.setString(15,chgUser);
pstmtInser.setString(16,chgTerm);
///currAppdate
/*pstmtInser.setString(7,chgUser);
pstmtInser.setString(8,chgTerm);
pstmtInser.setDouble(9,limit_hrs);
pstmtInser.setString(10,limit_type);
pstmtInser.setDouble(11,min_minutes);*/
updCnt = pstmtInser.executeUpdate();
pstmtInser.close();
pstmtInser=null;
if(updCnt > 0 )
{
conn.commit();
System.out.println("@@@@@ Record inserted for table no["+new_pay_table +"]:::::::: @@@@@");
}
}
else
{
//System.out.println("@@@@@ :::::Record already exist for PeriodCode["+newPeriodCode +"]::varName["+ varName +"] :::::: @@@@@");
//errString = itmDBAccessLocal.getErrorString("","VMDUPREC1","");
}
}
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
}
//valueXmlString.append("</Root>\r\n");
} // end of try
catch(Exception e)
{
try
{
conn.rollback();
}
catch(Exception ex)
{
throw new ITMException(ex);
}
throw new ITMException(e);
}
finally
{
try
{
conn.close();
conn = null;
}
catch(Exception e)
{
throw new ITMException(e);
}
}
return errString ;
}
public String getDD_MM_YYYY_format(String str) throws Exception{
DateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
Date date;
String dd_mm_yyyy="";
date = (Date)formatter.parse(str);
System.out.println("DDMMYYYY="+date);
SimpleDateFormat format = new SimpleDateFormat("dd-MMM-yyyy");
dd_mm_yyyy=format.format(date);
//String orcleFormat= oracleFormatDate(dd_mm_yyyy);
System.out.println("orcleFormat dd-mm-yyyy=="+dd_mm_yyyy);
return dd_mm_yyyy;
}
public Timestamp getTimestamp(String str) throws Exception{
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss.S");
java.util.Date date = sdf.parse(str);
java.sql.Timestamp timestamp = new java.sql.Timestamp(date.getTime());
//System.out.println("====="+timestamp);
return timestamp;
}
public int checkValidity(String retrival, String column_name, String table_name, Connection from_site_conn) throws SQLException{
boolean flag=false;
PreparedStatement pstmt=null;
ResultSet rs=null;
String Query="";
Connection conn=null;
int count=0;
Connection localConnection =null;
try{
conn = from_site_conn;
Query="select count("+column_name+") from "+table_name+" where "+column_name+"='"+retrival+"'";
System.out.println("====QUERY=="+Query);
pstmt=conn.prepareStatement(Query);
rs=pstmt.executeQuery(Query);
if(rs.next()){
count=rs.getInt(1);
}
}catch(Exception e){
e.printStackTrace();
}finally{
if(pstmt!=null){
pstmt.close();
pstmt=null;
}
if(rs!=null){
rs.close();
rs=null;
}
}
System.out.println("count="+count);
return count;
}
}
/* This file is Cteated it incorporate the Pre Save logic from Window
* Gulzar 08/09/06
*/
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.ValidatorLocal;
import ibase.webitm.utility.ITMException;
import java.sql.Connection;
import javax.ejb.Local; // added for ejb3
//public interface SReturnPrs extends ValidatorLocal, EJBObject
@Local // added for ejb3
public interface CopyGradeMthadLocal extends ValidatorLocal
{
public String preSaveRec()throws RemoteException,ITMException;
public String preSaveRec(String xmlString1,String domID,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException;
}
\ No newline at end of file
/* This file is Cteated it incorporate the Pre Save logic from Window
* Gulzar 08/09/06
*/
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.ValidatorRemote;
import ibase.webitm.utility.ITMException;
import java.sql.Connection;
import javax.ejb.Remote; // added for ejb3
//public interface SReturnPrs extends ValidatorRemote, EJBObject
@Remote // added for ejb3
public interface CopyGradeMthadRemote extends ValidatorRemote
{
public String preSaveRec()throws RemoteException,ITMException;
public String preSaveRec(String xmlString1,String domID,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm;
import ibase.webitm.utility.*;
//import ibase.utility.CommonConstants;
import ibase.system.config.*;
//import java.text.*;
import java.util.*;
//import javax.xml.parsers.*;
import javax.ejb.*;
//import javax.naming.InitialContext;
import java.io.*;
import java.util.Calendar;
import java.util.Date;
import java.sql.*;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.rmi.RemoteException;
import org.w3c.dom.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.ejb.*;
import javax.ejb.Stateless; // added for ejb3
//public class SReturnPrsEJB extends ValidatorEJB implements SessionBean
@Stateless // added for ejb3
public class CopyGradeOtParamPrs extends ValidatorEJB implements CopyGradeOtParamPrsLocal, CopyGradeOtParamPrsRemote
{
public String preSaveRec() throws RemoteException, ITMException
{
return "";
}
public String preSaveRec(String xmlString1, String domId, String objContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{
System.out.println("@@@@@@@@********* CopyGradeOtParamPrs Called *******@@@@@@@@");
Document dom = null;
String errString = "";
//ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
try
{
if (xmlString1 != null && xmlString1.trim().length() > 0)
{
dom = GenericUtility.getInstance().parseString(xmlString1);
errString = executepreSaveRec(dom,domId,objContext,editFlag,xtraParams,conn);
if (errString == null || errString.trim().length() == 0)
{
//errString = itmDBAccessLocal.getErrorString("","VTMCONF2","");
}
else
{
conn.rollback();
//errString = itmDBAccessLocal.getErrorString("","VMPROCUSG","");
}
}
}
catch(Exception e)
{
System.out.println("Exception :CopyPayParamPrs :preSaveRec(): " + e.getMessage()+ ":");
e.printStackTrace();
throw new ITMException(e);
}
return errString;
}
private String executepreSaveRec(Document dom, String domID, String ObjContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{
//Connection conn = null;
PreparedStatement pstmt = null,pstmt1 = null,pstmtInser = null;
ResultSet rs = null ,rs1 = null;
String site_code = "",new_site_code="";
String sql = "",sql1 = "",sqlInser;
String chgUser = "",chgTerm = "",descr = "";
String grade_code="";
String limit_type="";
double min_minutes=0.0;
double limit_hrs=0.0;
int cnt = 0,updCnt = 0;
Date chgdate = null;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
String errString = "";
boolean insertFlag=false;
try
{
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
site_code = genericUtility.getColumnValue("site_code",dom);
//varName = genericUtility.getColumnValue("var_name",dom);
new_site_code = genericUtility.getColumnValue("new_site_code",dom);
String currAppdate ="";
java.sql.Timestamp currDate = null;
Object date = null;
currDate =new java.sql.Timestamp(System.currentTimeMillis()) ;
System.out.println(genericUtility.getDBDateFormat());
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getDBDateFormat());
date = sdf.parse(currDate.toString());
currDate = java.sql.Timestamp.valueOf(sdf.format(date).toString() + " 00:00:00.0");
currAppdate = new SimpleDateFormat(genericUtility.getApplDateFormat()).format(currDate).toString();
chgUser = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_user");
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_term");
if( site_code == null || site_code.trim().length() ==0 )
{
//errString = itmDBAccessEJB.getErrorString("","PRDCODNULL","");
//return errString;
}
else if( new_site_code == null || new_site_code.trim().length() == 0 )
{
errString = itmDBAccessEJB.getErrorString("","NEWSITENUL","");
return errString;
}
else if( new_site_code != null && new_site_code.trim().length() > 0 )
{
if( new_site_code.trim().length() > 5 )
{
errString = itmDBAccessEJB.getErrorString("","NEWSITEINV","");
return errString;
}
else if(checkValidity(new_site_code, "site_code", "site", conn)<=0){
insertFlag=true;
errString = itmDBAccessEJB.getErrorString("","NEWSITNEXI","");
return errString;
}
}
if( site_code != null && site_code != null && new_site_code.trim().length() > 0 && site_code.trim().length() > 0 && insertFlag==false)
{
//sql = " SELECT var_name,var_type,var_value,descr,var_subs FROM payrparm WHERE prd_code = ? "; // and var_name = ?";
sql = "SELECT * FROM GRADE_SITE_OT WHERE SITE_CODE=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,site_code);
//pstmt.setString(2,varName);
rs = pstmt.executeQuery();
while(rs.next())
{
grade_code = rs.getString("grade_code");
limit_hrs =rs.getDouble("limit_hrs");
limit_type= rs.getString("limit_type");
min_minutes =rs.getDouble("min_minutes");
//sql1 = "SELECT count(*) FROM payrparm WHERE prd_code = ? and var_name = ? ";
sql1 ="SELECT count(*) FROM GRADE_SITE_OT WHERE SITE_CODE = ? and GRADE_CODE=?";
pstmt1 = conn.prepareStatement(sql1);
pstmt1.setString(1, new_site_code);
pstmt1.setString(2, grade_code);
rs1 = pstmt1.executeQuery();
if(rs1.next())
{
cnt = rs1.getInt(1);
}
rs1.close();
rs1 = null;
pstmt1.close();
pstmt1 = null;
System.out.println("@@@@@:::cnt:["+cnt+"]");
if(cnt == 0)
{
sqlInser = "INSERT INTO GRADE_SITE_OT ( grade_code, site_code, add_date, add_user, add_term, chg_date, chg_user, chg_term, limit_hrs, limit_type, min_minutes) "
+" VALUES (?,?,?, ?,?,?, ?,?,?, ?,?) ";
pstmtInser = conn.prepareStatement(sqlInser);
pstmtInser.setString(1,grade_code);
pstmtInser.setString(2, new_site_code);
pstmtInser.setTimestamp(3, currDate );
pstmtInser.setString(4,chgUser);
pstmtInser.setString(5,chgTerm);
pstmtInser.setTimestamp(6, currDate ); ///currAppdate
pstmtInser.setString(7,chgUser);
pstmtInser.setString(8,chgTerm);
pstmtInser.setDouble(9,limit_hrs);
pstmtInser.setString(10,limit_type);
pstmtInser.setDouble(11,min_minutes);
updCnt = pstmtInser.executeUpdate();
pstmtInser.close();
pstmtInser=null;
if(updCnt > 0 )
{
conn.commit();
System.out.println("@@@@@ Record inserted for table no["+new_site_code +"]:::::::: @@@@@");
}
}
else
{
//System.out.println("@@@@@ :::::Record already exist for PeriodCode["+newPeriodCode +"]::varName["+ varName +"] :::::: @@@@@");
//errString = itmDBAccessLocal.getErrorString("","VMDUPREC1","");
}
}
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
}
//valueXmlString.append("</Root>\r\n");
} // end of try
catch(Exception e)
{
try
{
conn.rollback();
}
catch(Exception ex)
{
throw new ITMException(ex);
}
throw new ITMException(e);
}
finally
{
try
{
conn.close();
conn = null;
}
catch(Exception e)
{
throw new ITMException(e);
}
}
return errString ;
}
/*public String getDD_MM_YYYY_format(String str) throws Exception{
DateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
Date date;
String dd_mm_yyyy="";
date = (Date)formatter.parse(str);
System.out.println("DDMMYYYY="+date);
SimpleDateFormat format = new SimpleDateFormat("dd-MMM-yyyy");
dd_mm_yyyy=format.format(date);
//String orcleFormat= oracleFormatDate(dd_mm_yyyy);
System.out.println("orcleFormat dd-mm-yyyy=="+dd_mm_yyyy);
return dd_mm_yyyy;
}
public Timestamp getTimestamp(String str) throws Exception{
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss.S");
java.util.Date date = sdf.parse(str);
java.sql.Timestamp timestamp = new java.sql.Timestamp(date.getTime());
//System.out.println("====="+timestamp);
return timestamp;
}
*/
public int checkValidity(String retrival, String column_name, String table_name, Connection from_site_conn) throws SQLException{
boolean flag=false;
PreparedStatement pstmt=null;
ResultSet rs=null;
String Query="";
Connection conn=null;
int count=0;
Connection localConnection =null;
try{
conn = from_site_conn;
Query="select count("+column_name+") from "+table_name+" where "+column_name+"='"+retrival+"'";
System.out.println("====QUERY=="+Query);
pstmt=conn.prepareStatement(Query);
rs=pstmt.executeQuery(Query);
if(rs.next()){
count=rs.getInt(1);
}
}catch(Exception e){
e.printStackTrace();
}finally{
if(pstmt!=null){
pstmt.close();
pstmt=null;
}
if(rs!=null){
rs.close();
rs=null;
}
}
System.out.println("count="+count);
return count;
}
}
/* This file is Cteated it incorporate the Pre Save logic from Window
* Gulzar 08/09/06
*/
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.ValidatorLocal;
import ibase.webitm.utility.ITMException;
import java.sql.Connection;
import javax.ejb.Local; // added for ejb3
//public interface SReturnPrs extends ValidatorLocal, EJBObject
@Local // added for ejb3
public interface CopyGradeOtParamPrsLocal extends ValidatorLocal
{
public String preSaveRec()throws RemoteException,ITMException;
public String preSaveRec(String xmlString1,String domID,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException;
}
\ No newline at end of file
/* This file is Cteated it incorporate the Pre Save logic from Window
* Gulzar 08/09/06
*/
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.ValidatorRemote;
import ibase.webitm.utility.ITMException;
import java.sql.Connection;
import javax.ejb.Remote; // added for ejb3
//public interface SReturnPrs extends ValidatorRemote, EJBObject
@Remote // added for ejb3
public interface CopyGradeOtParamPrsRemote extends ValidatorRemote
{
public String preSaveRec()throws RemoteException,ITMException;
public String preSaveRec(String xmlString1,String domID,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.adm;
import ibase.webitm.utility.*;
//import ibase.utility.CommonConstants;
import ibase.system.config.*;
//import java.text.*;
import java.util.*;
//import javax.xml.parsers.*;
import javax.ejb.*;
//import javax.naming.InitialContext;
import java.io.*;
import java.util.Calendar;
import java.util.Date;
import java.sql.*;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.rmi.RemoteException;
import org.w3c.dom.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.ejb.*;
import javax.ejb.Stateless; // added for ejb3
//public class SReturnPrsEJB extends ValidatorEJB implements SessionBean
@Stateless // added for ejb3
public class CopyGradePerkParamPrs extends ValidatorEJB implements CopyGradePerkParamPrsLocal, CopyGradePerkParamPrsRemote
{
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
public String preSaveRec() throws RemoteException, ITMException
{
return "";
}
public String preSaveRec(String xmlString1, String domId, String objContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{
System.out.println("@@@@@@@@********* CopyGradePerkParamPrs Called *******@@@@@@@@");
Document dom = null;
String errString = "";
//ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
try
{
if (xmlString1 != null && xmlString1.trim().length() > 0)
{
dom = GenericUtility.getInstance().parseString(xmlString1);
errString = executepreSaveRec(dom,domId,objContext,editFlag,xtraParams,conn);
if (errString == null || errString.trim().length() == 0)
{
//errString = itmDBAccessLocal.getErrorString("","VTMCONF2","");
}
else
{
conn.rollback();
//errString = itmDBAccessLocal.getErrorString("","VMPROCUSG","");
}
}
}
catch(Exception e)
{
System.out.println("Exception :CopyPayParamPrs :preSaveRec(): " + e.getMessage()+ ":");
e.printStackTrace();
throw new ITMException(e);
}
return errString;
}
private String executepreSaveRec(Document dom, String domID, String ObjContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{
//Connection conn = null;
PreparedStatement pstmt = null,pstmt1 = null,pstmtInser = null;
ResultSet rs = null ,rs1 = null;
String pay_table = "",new_pay_table="";
String sql = "",sql1 = "",sqlInser;
String chgUser = "",chgTerm = "";
String grade_code="",new_grade_code="";
String ad_code="",ad_code_main="",type="";
double cycle_time=0.0,cycle_start=0.0,cycle_end=0.0,validity_period=0.0;
java.sql.Timestamp exp_date=null,eff_date=null;
java.sql.Timestamp last_proc_for=null,next_proc_date=null;
double amount=0.0;
int cnt = 0,updCnt = 0;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
String errString = "";
// boolean insertFlag=false;
try
{
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
pay_table = genericUtility.getColumnValue("pay_table",dom);
grade_code = genericUtility.getColumnValue("grade_code",dom);
new_pay_table = genericUtility.getColumnValue("new_pay_table",dom);
new_grade_code = genericUtility.getColumnValue("new_grade_code",dom);
String currAppdate ="";
java.sql.Timestamp currDate = null;
Object date = null;
currDate =new java.sql.Timestamp(System.currentTimeMillis()) ;
System.out.println(genericUtility.getDBDateFormat());
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getDBDateFormat());
date = sdf.parse(currDate.toString());
currDate = java.sql.Timestamp.valueOf(sdf.format(date).toString() + " 00:00:00.0");
currAppdate = new SimpleDateFormat(genericUtility.getApplDateFormat()).format(currDate).toString();
chgUser = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_user");
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_term");
if( pay_table == null || pay_table.trim().length() ==0 )
{
//errString = itmDBAccessEJB.getErrorString("","PRDCODNULL","");ME
//return errString;ME
}
else if( new_pay_table == null || new_pay_table.trim().length() == 0 )
{
errString = itmDBAccessEJB.getErrorString("","NEWPAYTBL","");
return errString;
}
else if( new_pay_table != null && new_pay_table.trim().length() > 0 )
{
/* if( new_pay_table.trim().length() > 5 )
{
errString = itmDBAccessEJB.getErrorString("","NEWSITEINV","");
return errString;
}*/
/*else if(checkValidity(new_pay_table, "pay_table", "site", conn)<=0){
insertFlag=true;
errString = itmDBAccessEJB.getErrorString("","NEWSITNEXI","");
return errString;
}*/
}
if(new_pay_table!=null && checkValidity(new_pay_table, "pay_table", "PAYTABLE", conn)<=0){
//insertFlag=true;
errString = itmDBAccessEJB.getErrorString("","NEWPAYNO","");
return errString;
}
if( new_grade_code!=null && checkValidity(new_grade_code, "GRADE_CODE", "GRADE", conn)<=0){
//insertFlag=true;
errString = itmDBAccessEJB.getErrorString("","GCNOEXIST","");
return errString;
}
/*ME if( pay_table != null && pay_table != null && new_pay_table.trim().length() > 0 && pay_table.trim().length() > 0 )
{
//sql = " SELECT var_name,var_type,var_value,descr,var_subs FROM payrparm WHERE prd_code = ? "; // and var_name = ?";
sql="SELECT * FROM PAYTABLE WHERE PAY_TABLE=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,new_pay_table);
rs = pstmt.executeQuery();
if(rs.next()){
}else{
errString = itmDBAccessEJB.getErrorString("","NEWPAYNO","");
return errString;
}*/
System.out.println("BEFORE PAYTABLE GRADE CHECK ............");
System.out.println("----------- pay_table : "+pay_table+" grade_code : "+grade_code);
sql = "SELECT * FROM GRADE_PERK WHERE PAY_TABLE=? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,pay_table);
// pstmt.setString(2,grade_code);
rs = pstmt.executeQuery();
while(rs.next())
{
grade_code = rs.getString("grade_code");
ad_code =rs.getString("ad_code");
ad_code_main =rs.getString("ad_code__main");
eff_date= rs.getTimestamp("eff_date");
exp_date=rs.getTimestamp("exp_date");
java.sql.Timestamp expDateChg = null;
if(exp_date != null)
{
expDateChg=getTimestamp(exp_date);
}
type=rs.getString("type");
amount=rs.getDouble("amount");
cycle_time=rs.getDouble("cycle_time");
cycle_start=rs.getDouble("cycle_start");
cycle_end=rs.getDouble("cycle_end");
last_proc_for=rs.getTimestamp("last_proc_for");
java.sql.Timestamp last_proc_forChg = null;
if(last_proc_for != null)
{
last_proc_forChg=getTimestamp(last_proc_for);
}
next_proc_date=rs.getTimestamp("next_proc_date");
java.sql.Timestamp next_proc_dateChg = null;
System.out.println("next_proc_date value :"+next_proc_date);
if(next_proc_date != null)
{
next_proc_dateChg=getTimestamp(next_proc_date);
}
validity_period=rs.getDouble("validity_period");
System.out.println("IN LOOP");
java.sql.Timestamp effDateChg = null;
//sql1 = "SELECT count(*) FROM payrparm WHERE prd_code = ? and var_name = ? ";
sql1 ="SELECT count(*) FROM GRADE_PERK WHERE PAY_TABLE = ? and GRADE_CODE=? and AD_CODE=? and AD_CODE__MAIN=? and EFF_DATE=?";
pstmt1 = conn.prepareStatement(sql1);
if(new_pay_table != null && new_pay_table.trim().length() > 0 && new_grade_code==null){
//if only new pay table enters then copy data from paytable and against grade code into new paytable
System.out.println("COUNT CONDTION 1");
pstmt1.setString(1, new_pay_table);
pstmt1.setString(2, grade_code);
}else if(new_pay_table == null && new_grade_code!=null && new_grade_code.trim().length() > 0){
//if only new gradecode enters then copy data from paytable and against grade code into exiting paytable with new gradecode
System.out.println("COUNT CONDTION 2");
pstmt1.setString(1, pay_table);
pstmt1.setString(2, new_grade_code);
} else if(new_pay_table != null && new_pay_table.trim().length() > 0 && new_grade_code!=null && new_grade_code.trim().length() > 0){
//if both new gradecode and gradecode enters then copy data from paytable and against grade code into new paytable and new gradecode
System.out.println("COUNT CONDTION 3");
pstmt1.setString(1, new_pay_table);
pstmt1.setString(2, new_grade_code);
} else if(new_pay_table == null && new_grade_code==null ){
// validation
System.out.println("NEW GRADE CODE AND PAYTABLE BOTH ARE EMPTY.........");
errString = itmDBAccessEJB.getErrorString("","PAYGRTBL","");
return errString;
}
pstmt1.setString(3, ad_code);
pstmt1.setString(4, ad_code_main);
if(eff_date != null)
{
effDateChg=getTimestamp(eff_date);
}
if(effDateChg != null)
{
pstmt1.setTimestamp(5, effDateChg);
}
System.out.println("EXECUTE");
rs1 = pstmt1.executeQuery();
if(rs1.next())
{
cnt = rs1.getInt(1);
}
rs1.close();
rs1 = null;
pstmt1.close();
pstmt1 = null;
System.out.println("@@@@@:::cnt:["+cnt+"]");
if(cnt == 0)
{
System.out.println("IN INSERT");
sqlInser = "INSERT INTO GRADE_PERK (pay_table, grade_code, ad_code,ad_code__main, eff_date, exp_date, type, amount, cycle_time, cycle_start, cycle_end, last_proc_for,next_proc_date,chg_date,chg_user,chg_term,validity_period) "
+" VALUES (?,?,?, ?,?,?, ?,?,?, ?,?,?,?,?,?,?,?) ";
pstmtInser = conn.prepareStatement(sqlInser);
if(new_pay_table != null && new_pay_table.trim().length() > 0 && new_grade_code==null ){
//if only new pay table enters then copy data from paytable and against grade code into new paytable
System.out.println("INSERT CONDTION 1");
pstmtInser.setString(1, new_pay_table);
pstmtInser.setString(2, grade_code);
}else if(new_pay_table == null && new_grade_code!=null && new_grade_code.trim().length() > 0){
//if only new gradecode enters then copy data from paytable and against grade code into exiting paytable with new gradecode
System.out.println("INSERT CONDTION 2");
pstmtInser.setString(1, pay_table);
pstmtInser.setString(2, new_grade_code);
} else if(new_pay_table != null && new_pay_table.trim().length() > 0 && new_grade_code!=null && new_grade_code.trim().length() > 0){
//if both new gradecode and gradecode enters then copy data from paytable and against grade code into new paytable and new gradecode
System.out.println("INSERT CONDTION 3");
pstmtInser.setString(1, new_pay_table);
pstmtInser.setString(2, new_grade_code);
}
//pstmtInser.setString(1,new_pay_table);ME
//pstmtInser.setString(2, grade_code);ME
pstmtInser.setString(3, ad_code);
pstmtInser.setString(4, ad_code_main);
pstmtInser.setTimestamp(5,effDateChg);
pstmtInser.setTimestamp(6,expDateChg);
pstmtInser.setString(7, type);
pstmtInser.setDouble(8,amount);
pstmtInser.setDouble(9,cycle_time);
pstmtInser.setDouble(10,cycle_start);
pstmtInser.setDouble(11,cycle_end);
pstmtInser.setTimestamp(12,last_proc_forChg);
pstmtInser.setTimestamp(13, next_proc_dateChg);
pstmtInser.setTimestamp( 14, currDate);
pstmtInser.setString(15, chgUser);
pstmtInser.setString(16, chgTerm);
pstmtInser.setDouble(17,validity_period);
updCnt = pstmtInser.executeUpdate();
pstmtInser.close();
pstmtInser=null;
if(updCnt > 0 )
{
conn.commit();
System.out.println("@@@@@ Record inserted for table no["+new_pay_table +"]:::::::: @@@@@");
}
}
else
{
System.out.println("@@@@@ :::::Record already exist for PeriodCode["+new_pay_table +"]::varName["+ grade_code +"] :::::: @@@@@");
//errString = itmDBAccessLocal.getErrorString("","VMDUPREC1","");
// errString = itmDBAccessEJB.getErrorString("","NEWPAYAA","");ME
}
}
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
//valueXmlString.append("</Root>\r\n");
} // end of try
catch(Exception e)
{
try
{
conn.rollback();
}
catch(Exception ex)
{
throw new ITMException(ex);
}
throw new ITMException(e);
}
finally
{
try
{
conn.close();
conn = null;
}
catch(Exception e)
{
throw new ITMException(e);
}
}
return errString ;
}
public String getDD_MM_YYYY_format(String str) throws Exception{
DateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
Date date;
String dd_mm_yyyy="";
date = (Date)formatter.parse(str);
System.out.println("DDMMYYYY="+date);
SimpleDateFormat format = new SimpleDateFormat("dd-MMM-yyyy");
dd_mm_yyyy=format.format(date);
//String orcleFormat= oracleFormatDate(dd_mm_yyyy);
System.out.println("orcleFormat dd-mm-yyyy=="+dd_mm_yyyy);
return dd_mm_yyyy;
}
java.sql.Timestamp timestamp = null;
public Timestamp getTimestamp(Timestamp str) throws Exception{
//SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss.S");
/*System.out.println("=====time"+genericUtility.getDBDateFormat());
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getDBDateFormat());
java.util.Date date = sdf.parse(str.toString());
timestamp = java.sql.Timestamp.valueOf(sdf.format(date).toString() + " 00:00:00.0");
System.out.println("=====time"+timestamp);*/
java.sql.Timestamp currDate = null;
Object date = null;
currDate =new java.sql.Timestamp(System.currentTimeMillis()) ;
System.out.println("date of generic utility"+genericUtility.getDBDateFormat()+"STR VALUE:"+str);
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getDBDateFormat());
date = sdf.parse(str.toString());
currDate = java.sql.Timestamp.valueOf(sdf.format(date).toString() + " 00:00:00.0");
return currDate;
}
public int checkValidity(String retrival, String column_name, String table_name, Connection from_site_conn) throws SQLException{
boolean flag=false;
PreparedStatement pstmt=null;
ResultSet rs=null;
String Query="";
Connection conn=null;
int count=0;
Connection localConnection =null;
try{
conn = from_site_conn;
Query="select count("+column_name+") from "+table_name+" where "+column_name+"='"+retrival+"'";
System.out.println("====QUERY=="+Query);
pstmt=conn.prepareStatement(Query);
rs=pstmt.executeQuery(Query);
if(rs.next()){
count=rs.getInt(1);
}
}catch(Exception e){
e.printStackTrace();
}finally{
if(pstmt!=null){
pstmt.close();
pstmt=null;
}
if(rs!=null){
rs.close();
rs=null;
}
}
System.out.println("count="+count);
return count;
}
}
/* This file is Cteated it incorporate the Pre Save logic from Window
* Gulzar 08/09/06
*/
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.ValidatorLocal;
import ibase.webitm.utility.ITMException;
import java.sql.Connection;
import javax.ejb.Local; // added for ejb3
//public interface SReturnPrs extends ValidatorLocal, EJBObject
@Local // added for ejb3
public interface CopyGradePerkParamPrsLocal extends ValidatorLocal
{
public String preSaveRec()throws RemoteException,ITMException;
public String preSaveRec(String xmlString1,String domID,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException;
}
\ No newline at end of file
/* This file is Cteated it incorporate the Pre Save logic from Window
* Gulzar 08/09/06
*/
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.ValidatorRemote;
import ibase.webitm.utility.ITMException;
import java.sql.Connection;
import javax.ejb.Remote; // added for ejb3
//public interface SReturnPrs extends ValidatorRemote, EJBObject
@Remote // added for ejb3
public interface CopyGradePerkParamPrsRemote extends ValidatorRemote
{
public String preSaveRec()throws RemoteException,ITMException;
public String preSaveRec(String xmlString1,String domID,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException;
}
\ No newline at end of file
/********************************************************
Title : CopyHolParamPrcLocal
********************************************************/
package ibase.webitm.ejb.adm;
import ibase.webitm.utility.*;
//import ibase.utility.CommonConstants;
import ibase.system.config.*;
//import java.text.*;
import java.util.*;
//import javax.xml.parsers.*;
import javax.ejb.*;
//import javax.naming.InitialContext;
import java.io.*;
import java.util.Calendar;
import java.util.Date;
import java.sql.*;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.rmi.RemoteException;
import org.w3c.dom.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.ejb.*;
import javax.ejb.Stateless; // added for ejb3
//public class SReturnPrsEJB extends ValidatorEJB implements SessionBean
@Stateless // added for ejb3
public class CopyHolParamPrs extends ValidatorEJB implements CopyHolParamPrsLocal, CopyHolParamPrsRemote
{
/*
public void ejbCreate() throws RemoteException, CreateException
{
}
public void ejbRemove()
{
}
public void ejbActivate()
{
}
public void ejbPassivate()
{
}*/
public String preSaveRec() throws RemoteException, ITMException
{
return "";
}
public String preSaveRec(String xmlString1, String domId, String objContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{
System.out.println("@@@@@@@@********* CopyPayParamPrs Called *******@@@@@@@@");
Document dom = null;
String errString = "";
//ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
try
{
System.out.println("CopyPayParamPrs xmlString1 [" + xmlString1 + "]");
if (xmlString1 != null && xmlString1.trim().length() > 0)
{
dom = GenericUtility.getInstance().parseString(xmlString1);
errString = executepreSaveRec(dom,domId,objContext,editFlag,xtraParams,conn);
if (errString == null || errString.trim().length() == 0)
{
System.out.println("@@@@@ CopyPayParamPrs transaction insert succesfully........");
//errString = itmDBAccessLocal.getErrorString("","VTMCONF2","");
}
else
{
conn.rollback();
System.out.println("@@@@@ insertion failed........");
//errString = itmDBAccessLocal.getErrorString("","VMPROCUSG","");
}
}
}
catch(Exception e)
{
System.out.println("Exception :CopyPayParamPrs :preSaveRec(): " + e.getMessage()+ ":");
e.printStackTrace();
throw new ITMException(e);
}
return errString;
}
private String executepreSaveRec(Document dom, String domID, String ObjContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{
//Connection conn = null;
PreparedStatement pstmt = null,pstmt1 = null,pstmtInser = null;
ResultSet rs = null ,rs1 = null;
String hol_tblno = "",newhol_tblno="";
String sql = "",sql1 = "",sqlInser;
//String varName = "",varType = "",varValue = "",chgUser = "",chgTerm = "",descr = "";
String holType = "",chgUser = "",chgTerm = "",descr = "";
int noDays=0;
int cnt = 0,updCnt = 0;
String holDate="";
Date chgdate = null;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
//ITMDBAccessEJB itmDBAccess = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
String errString = "";
try
{
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
hol_tblno = genericUtility.getColumnValue("hol_tblno",dom);
//varName = genericUtility.getColumnValue("var_name",dom);
newhol_tblno = genericUtility.getColumnValue("new_hol_tblno",dom);
String currAppdate ="";
java.sql.Timestamp currDate = null;
Object date = null;
currDate =new java.sql.Timestamp(System.currentTimeMillis()) ;
System.out.println(genericUtility.getDBDateFormat());
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getDBDateFormat());
date = sdf.parse(currDate.toString());
currDate = java.sql.Timestamp.valueOf(sdf.format(date).toString() + " 00:00:00.0");
System.out.println("@@@@ currDate [[[[[["+currDate+"]]]]]]]");
currAppdate = new SimpleDateFormat(genericUtility.getApplDateFormat()).format(currDate).toString();
chgUser = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_user");
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_term");
if( hol_tblno == null || hol_tblno.trim().length() ==0 )
{
//errString = itmDBAccessEJB.getErrorString("","PRDCODNULL","");
//return errString;
}
else if( newhol_tblno == null || newhol_tblno.trim().length() == 0 )
{
errString = itmDBAccessEJB.getErrorString("","NEWTBLNUL","");
return errString;
}
else if( newhol_tblno != null && newhol_tblno.trim().length() > 0 )
{
if( newhol_tblno.trim().length() > 5 )
{
errString = itmDBAccessEJB.getErrorString("","NEWTBLINV","");
return errString;
}
}
if( hol_tblno != null && hol_tblno != null && newhol_tblno.trim().length() > 0 && hol_tblno.trim().length() > 0)
{
//sql = " SELECT var_name,var_type,var_value,descr,var_subs FROM payrparm WHERE prd_code = ? "; // and var_name = ?";
sql = "SELECT * FROM HOLIDAY WHERE HOL_TBLNO=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,hol_tblno);
//pstmt.setString(2,varName);
rs = pstmt.executeQuery();
while(rs.next())
{
holDate = rs.getString("hol_date");
holType = rs.getString("hol_type");
descr = rs.getString("descr");
noDays = rs.getInt("no_days");
//sql1 = "SELECT count(*) FROM payrparm WHERE prd_code = ? and var_name = ? ";
sql1 ="SELECT count(*) FROM HOLIDAY WHERE HOL_TBLNO = ? and hol_date=? and hol_type=?";
pstmt1 = conn.prepareStatement(sql1);
pstmt1.setString(1, newhol_tblno);
//pstmt1.setTimestamp(2,holDate);
pstmt1.setString(2, getDD_MM_YYYY_format(holDate));
pstmt1.setString(3,holType);
rs1 = pstmt1.executeQuery();
if(rs1.next())
{
cnt = rs1.getInt(1);
}
rs1.close();
rs1 = null;
pstmt1.close();
pstmt1 = null;
System.out.println("@@@@@:::cnt:["+cnt+"]");
if(cnt == 0)
{
sqlInser = "INSERT INTO HOLIDAY ( hol_tblno, hol_date, hol_type, descr, no_days, chg_date, chg_user, chg_term) "
+" VALUES (?,?,?, ?,?,?, ?,?) ";
pstmtInser = conn.prepareStatement(sqlInser);
pstmtInser.setString(1,newhol_tblno);
//pstmtInser.setString(2,holDate);
pstmtInser.setTimestamp(2,getTimestamp(holDate));
pstmtInser.setString(3,holType);
pstmtInser.setString(4,descr);
pstmtInser.setInt(5,noDays);
pstmtInser.setTimestamp(6, currDate ); ///currAppdate
pstmtInser.setString(7,chgUser);
pstmtInser.setString(8,chgTerm);
updCnt = pstmtInser.executeUpdate();
pstmtInser.close();
pstmtInser=null;
if(updCnt > 0 )
{
conn.commit();
System.out.println("@@@@@ Record inserted for table no["+newhol_tblno +"]:::::::: @@@@@");
}
}
else
{
//System.out.println("@@@@@ :::::Record already exist for PeriodCode["+newPeriodCode +"]::varName["+ varName +"] :::::: @@@@@");
//errString = itmDBAccessLocal.getErrorString("","VMDUPREC1","");
}
}
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
}
//valueXmlString.append("</Root>\r\n");
} // end of try
catch(Exception e)
{
try
{
conn.rollback();
}
catch(Exception ex)
{
throw new ITMException(ex);
}
throw new ITMException(e);
}
finally
{
try
{
conn.close();
conn = null;
}
catch(Exception e)
{
throw new ITMException(e);
}
}
return errString ;
}
public String getDD_MM_YYYY_format(String str) throws Exception{
DateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
Date date;
String dd_mm_yyyy="";
date = (Date)formatter.parse(str);
System.out.println("DDMMYYYY="+date);
SimpleDateFormat format = new SimpleDateFormat("dd-MMM-yyyy");
dd_mm_yyyy=format.format(date);
//String orcleFormat= oracleFormatDate(dd_mm_yyyy);
System.out.println("orcleFormat dd-mm-yyyy=="+dd_mm_yyyy);
return dd_mm_yyyy;
}
public Timestamp getTimestamp(String str) throws Exception{
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss.S");
java.util.Date date = sdf.parse(str);
java.sql.Timestamp timestamp = new java.sql.Timestamp(date.getTime());
//System.out.println("====="+timestamp);
return timestamp;
}
}
/* This file is Cteated it incorporate the Pre Save logic from Window
* Gulzar 08/09/06
*/
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.ValidatorLocal;
import ibase.webitm.utility.ITMException;
import java.sql.Connection;
import javax.ejb.Local; // added for ejb3
//public interface SReturnPrs extends ValidatorLocal, EJBObject
@Local // added for ejb3
public interface CopyHolParamPrsLocal extends ValidatorLocal
{
public String preSaveRec()throws RemoteException,ITMException;
public String preSaveRec(String xmlString1,String domID,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException;
}
\ No newline at end of file
/* This file is Cteated it incorporate the Pre Save logic from Window
* Gulzar 08/09/06
*/
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.ValidatorRemote;
import ibase.webitm.utility.ITMException;
import java.sql.Connection;
import javax.ejb.Remote; // added for ejb3
//public interface SReturnPrs extends ValidatorRemote, EJBObject
@Remote // added for ejb3
public interface CopyHolParamPrsRemote extends ValidatorRemote
{
public String preSaveRec()throws RemoteException,ITMException;
public String preSaveRec(String xmlString1,String domID,String objContext,String editFlag, String xtraParams, Connection conn)throws RemoteException,ITMException;
}
\ No newline at end of file
/******************************************************** /********************************************************
Title : CopyPayParamPrcLocal Title : CopyPayParamPrcLocal
Date : 19/07/12 Date : 19/07/12
Developer: Kunal Mandhre Developer: Kunal Mandhre
********************************************************/ ********************************************************/
// cpatil start // cpatil start
///* added and modify by chandrakant patil on 06/06/2012 */ ///* added and modify by chandrakant patil on 06/06/2012 */
package ibase.webitm.ejb.adm; package ibase.webitm.ejb.adm;
import ibase.webitm.utility.*; import ibase.webitm.utility.*;
//import ibase.utility.CommonConstants; //import ibase.utility.CommonConstants;
import ibase.system.config.*; import ibase.system.config.*;
//import java.text.*; //import java.text.*;
import java.util.*; import java.util.*;
//import javax.xml.parsers.*; //import javax.xml.parsers.*;
import javax.ejb.*; import javax.ejb.*;
//import javax.naming.InitialContext; //import javax.naming.InitialContext;
import java.io.*; import java.io.*;
import java.util.Calendar; import java.util.Calendar;
import java.util.Date; import java.util.Date;
import java.sql.*; import java.sql.*;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.rmi.RemoteException; import java.rmi.RemoteException;
import org.w3c.dom.*; import org.w3c.dom.*;
import ibase.webitm.utility.ITMException; import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.GenericUtility; import ibase.webitm.utility.GenericUtility;
import ibase.webitm.ejb.*; import ibase.webitm.ejb.*;
import javax.ejb.Stateless; // added for ejb3 import javax.ejb.Stateless; // added for ejb3
//public class SReturnPrsEJB extends ValidatorEJB implements SessionBean //public class SReturnPrsEJB extends ValidatorEJB implements SessionBean
@Stateless // added for ejb3 @Stateless // added for ejb3
public class CopyPayParamPrs extends ValidatorEJB implements CopyPayParamPrsLocal, CopyPayParamPrsRemote public class CopyPayParamPrs extends ValidatorEJB implements CopyPayParamPrsLocal, CopyPayParamPrsRemote
{ {
/* /*
public void ejbCreate() throws RemoteException, CreateException public void ejbCreate() throws RemoteException, CreateException
{ {
} }
public void ejbRemove() public void ejbRemove()
{ {
} }
public void ejbActivate() public void ejbActivate()
{ {
} }
public void ejbPassivate() public void ejbPassivate()
{ {
}*/ }*/
public String preSaveRec() throws RemoteException, ITMException public String preSaveRec() throws RemoteException, ITMException
{ {
return ""; return "";
} }
public String preSaveRec(String xmlString1, String domId, String objContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException public String preSaveRec(String xmlString1, String domId, String objContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{ {
System.out.println("@@@@@@@@********* CopyPayParamPrs Called *******@@@@@@@@"); System.out.println("@@@@@@@@********* CopyPayParamPrs Called *******@@@@@@@@");
Document dom = null; Document dom = null;
String errString = ""; String errString = "";
//ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB(); //ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
try try
{ {
System.out.println("CopyPayParamPrs xmlString1 [" + xmlString1 + "]"); System.out.println("CopyPayParamPrs xmlString1 [" + xmlString1 + "]");
if (xmlString1 != null && xmlString1.trim().length() > 0) if (xmlString1 != null && xmlString1.trim().length() > 0)
{ {
dom = GenericUtility.getInstance().parseString(xmlString1); dom = GenericUtility.getInstance().parseString(xmlString1);
errString = executepreSaveRec(dom,domId,objContext,editFlag,xtraParams,conn); errString = executepreSaveRec(dom,domId,objContext,editFlag,xtraParams,conn);
if (errString == null || errString.trim().length() == 0) if (errString == null || errString.trim().length() == 0)
{ {
System.out.println("@@@@@ CopyPayParamPrs transaction insert succesfully........"); System.out.println("@@@@@ CopyPayParamPrs transaction insert succesfully........");
//errString = itmDBAccessLocal.getErrorString("","VTMCONF2",""); //errString = itmDBAccessLocal.getErrorString("","VTMCONF2","");
} }
else else
{ {
conn.rollback(); conn.rollback();
System.out.println("@@@@@ insertion failed........"); System.out.println("@@@@@ insertion failed........");
//errString = itmDBAccessLocal.getErrorString("","VMPROCUSG",""); //errString = itmDBAccessLocal.getErrorString("","VMPROCUSG","");
} }
} }
} }
catch(Exception e) catch(Exception e)
{ {
System.out.println("Exception :CopyPayParamPrs :preSaveRec(): " + e.getMessage()+ ":"); System.out.println("Exception :CopyPayParamPrs :preSaveRec(): " + e.getMessage()+ ":");
e.printStackTrace(); e.printStackTrace();
throw new ITMException(e); throw new ITMException(e);
} }
return errString; return errString;
} }
private String executepreSaveRec(Document dom, String domID, String ObjContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException private String executepreSaveRec(Document dom, String domID, String ObjContext, String editFlag, String xtraParams, Connection conn) throws RemoteException, ITMException
{ {
//Connection conn = null; //Connection conn = null;
PreparedStatement pstmt = null,pstmt1 = null,pstmtInser = null; PreparedStatement pstmt = null,pstmt1 = null,pstmtInser = null;
ResultSet rs = null ,rs1 = null; ResultSet rs = null ,rs1 = null;
String periodCode = "",newPeriodCode=""; String periodCode = "",newPeriodCode="";
String sql = "",sql1 = "",sqlInser; String sql = "",sql1 = "",sqlInser;
String varName = "",varType = "",varValue = "",chgUser = "",chgTerm = "",descr = ""; String varName = "",varType = "",varValue = "",chgUser = "",chgTerm = "",descr = "";
double varSubs = 0.0; double varSubs = 0.0;
int cnt = 0,updCnt = 0; int cnt = 0,updCnt = 0;
Date chgdate = null; Date chgdate = null;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB(); ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
//ITMDBAccessEJB itmDBAccess = new ITMDBAccessEJB(); //ITMDBAccessEJB itmDBAccess = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB(); ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
String errString = ""; String errString = "";
try try
{ {
ConnDriver connDriver = new ConnDriver(); ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM"); conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false); conn.setAutoCommit(false);
periodCode = genericUtility.getColumnValue("prd_code",dom); periodCode = genericUtility.getColumnValue("prd_code",dom);
//varName = genericUtility.getColumnValue("var_name",dom); //varName = genericUtility.getColumnValue("var_name",dom);
newPeriodCode = genericUtility.getColumnValue("new_prd_code",dom); newPeriodCode = genericUtility.getColumnValue("new_prd_code",dom);
String currAppdate =""; String currAppdate ="";
java.sql.Timestamp currDate = null; java.sql.Timestamp currDate = null;
Object date = null; Object date = null;
currDate =new java.sql.Timestamp(System.currentTimeMillis()) ; currDate =new java.sql.Timestamp(System.currentTimeMillis()) ;
System.out.println(genericUtility.getDBDateFormat()); System.out.println(genericUtility.getDBDateFormat());
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getDBDateFormat()); SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getDBDateFormat());
date = sdf.parse(currDate.toString()); date = sdf.parse(currDate.toString());
currDate = java.sql.Timestamp.valueOf(sdf.format(date).toString() + " 00:00:00.0"); currDate = java.sql.Timestamp.valueOf(sdf.format(date).toString() + " 00:00:00.0");
System.out.println("@@@@ currDate [[[[[["+currDate+"]]]]]]]"); System.out.println("@@@@ currDate [[[[[["+currDate+"]]]]]]]");
currAppdate = new SimpleDateFormat(genericUtility.getApplDateFormat()).format(currDate).toString(); currAppdate = new SimpleDateFormat(genericUtility.getApplDateFormat()).format(currDate).toString();
chgUser = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_user"); chgUser = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_user");
System.out.println("chg_user ...... :"+chgUser); System.out.println("chg_user ...... :"+chgUser);
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_term"); chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chg_term");
System.out.println("chg_term ...... :"+chgTerm); System.out.println("chg_term ...... :"+chgTerm);
System.out.println("@@@@@ :periodCode:["+periodCode+"]:::::newPeriodCode:["+ newPeriodCode+"]"); System.out.println("@@@@@ :periodCode:["+periodCode+"]:::::newPeriodCode:["+ newPeriodCode+"]");
if( periodCode == null || periodCode.trim().length() ==0 ) if( periodCode == null || periodCode.trim().length() ==0 )
{ {
errString = itmDBAccessEJB.getErrorString("","PRDCODNULL",""); errString = itmDBAccessEJB.getErrorString("","PRDCODNULL","");
return errString; return errString;
} }
else if( newPeriodCode == null || newPeriodCode.trim().length() == 0 ) else if( newPeriodCode == null || newPeriodCode.trim().length() == 0 )
{ {
errString = itmDBAccessEJB.getErrorString("","NEWPRCONUL",""); errString = itmDBAccessEJB.getErrorString("","NEWPRCONUL","");
return errString; return errString;
} }
else if( newPeriodCode != null && newPeriodCode.trim().length() > 0 ) else if( newPeriodCode != null && newPeriodCode.trim().length() > 0 )
{ {
if( newPeriodCode.trim().length() == 6 ) if( newPeriodCode.trim().length() == 6 )
{ {
for (int i = 0; i < newPeriodCode.length(); i++) for (int i = 0; i < newPeriodCode.length(); i++)
{ {
if (!Character.isDigit(newPeriodCode.charAt(i))) if (!Character.isDigit(newPeriodCode.charAt(i)))
{ {
errString = itmDBAccessEJB.getErrorString("","NEWPRCOINV",""); errString = itmDBAccessEJB.getErrorString("","NEWPRCOINV","");
return errString; return errString;
} }
} }
} }
else else
{ {
errString = itmDBAccessEJB.getErrorString("","NEWPRCOINV",""); errString = itmDBAccessEJB.getErrorString("","NEWPRCOINV","");
return errString; return errString;
} }
} }
//else if( varName == null || varName.trim().length() ==0 ) //else if( varName == null || varName.trim().length() ==0 )
//{ //{
// errString = itmDBAccessEJB.getErrorString("","VARNAMNULL",""); // errString = itmDBAccessEJB.getErrorString("","VARNAMNULL","");
//} //}
//else //else
if( newPeriodCode != null && periodCode != null && newPeriodCode.trim().length() > 0 && periodCode.trim().length() > 0) if( newPeriodCode != null && periodCode != null && newPeriodCode.trim().length() > 0 && periodCode.trim().length() > 0)
{ {
sql = " SELECT var_name,var_type,var_value,descr,var_subs FROM payrparm WHERE prd_code = ? "; // and var_name = ?"; sql = " SELECT var_name,var_type,var_value,descr,var_subs FROM payrparm WHERE prd_code = ? "; // and var_name = ?";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1,periodCode); pstmt.setString(1,periodCode);
//pstmt.setString(2,varName); //pstmt.setString(2,varName);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
while(rs.next()) while(rs.next())
{ {
varName = rs.getString("var_name"); varName = rs.getString("var_name");
varType = rs.getString("var_type"); varType = rs.getString("var_type");
varValue = rs.getString("var_value"); varValue = rs.getString("var_value");
descr = rs.getString("descr"); descr = rs.getString("descr");
varSubs = rs.getDouble("var_subs"); varSubs = rs.getDouble("var_subs");
sql1 = "SELECT count(*) FROM payrparm WHERE prd_code = ? and var_name = ? "; sql1 = "SELECT count(*) FROM payrparm WHERE prd_code = ? and var_name = ? ";
pstmt1 = conn.prepareStatement(sql1); pstmt1 = conn.prepareStatement(sql1);
pstmt1.setString(1,newPeriodCode); pstmt1.setString(1,newPeriodCode);
pstmt1.setString(2,varName); pstmt1.setString(2,varName);
rs1 = pstmt1.executeQuery(); rs1 = pstmt1.executeQuery();
if(rs1.next()) if(rs1.next())
{ {
cnt = rs1.getInt(1); cnt = rs1.getInt(1);
} }
rs1.close(); rs1.close();
rs1 = null; rs1 = null;
pstmt1.close(); pstmt1.close();
pstmt1 = null; pstmt1 = null;
System.out.println("@@@@@:::cnt:["+cnt+"]"); System.out.println("@@@@@:::cnt:["+cnt+"]");
if(cnt == 0) if(cnt == 0)
{ {
sqlInser = "INSERT INTO payrparm ( prd_code,var_name,var_type,var_value,chg_date,chg_user,chg_term,descr,var_subs ) " sqlInser = "INSERT INTO payrparm ( prd_code,var_name,var_type,var_value,chg_date,chg_user,chg_term,descr,var_subs ) "
+" VALUES (?,?,?,?,?,?,?,?,?) "; +" VALUES (?,?,?,?,?,?,?,?,?) ";
pstmtInser = conn.prepareStatement(sqlInser); pstmtInser = conn.prepareStatement(sqlInser);
pstmtInser.setString(1,newPeriodCode); pstmtInser.setString(1,newPeriodCode);
pstmtInser.setString(2,varName); pstmtInser.setString(2,varName);
pstmtInser.setString(3,varType); pstmtInser.setString(3,varType);
pstmtInser.setString(4,varValue); pstmtInser.setString(4,varValue);
pstmtInser.setTimestamp(5, currDate ); ///currAppdate pstmtInser.setTimestamp(5, currDate ); ///currAppdate
//pstmtInser.setDate(5,new java.sql.Date(chgdate.getTime())); //pstmtInser.setDate(5,new java.sql.Date(chgdate.getTime()));
pstmtInser.setString(6,chgUser); pstmtInser.setString(6,chgUser);
pstmtInser.setString(7,chgTerm); pstmtInser.setString(7,chgTerm);
pstmtInser.setString(8,descr); pstmtInser.setString(8,descr);
pstmtInser.setDouble(9,varSubs); pstmtInser.setDouble(9,varSubs);
updCnt = pstmtInser.executeUpdate(); updCnt = pstmtInser.executeUpdate();
pstmtInser.close(); pstmtInser.close();
pstmtInser=null; pstmtInser=null;
if(updCnt > 0 ) if(updCnt > 0 )
{ {
conn.commit(); conn.commit();
System.out.println("@@@@@ Record inserted for PeriodCode["+newPeriodCode +"]::varName["+ varName +"] :::::: @@@@@"); System.out.println("@@@@@ Record inserted for PeriodCode["+newPeriodCode +"]::varName["+ varName +"] :::::: @@@@@");
} }
} }
else else
{ {
System.out.println("@@@@@ :::::Record already exist for PeriodCode["+newPeriodCode +"]::varName["+ varName +"] :::::: @@@@@"); System.out.println("@@@@@ :::::Record already exist for PeriodCode["+newPeriodCode +"]::varName["+ varName +"] :::::: @@@@@");
//errString = itmDBAccessLocal.getErrorString("","VMDUPREC1",""); //errString = itmDBAccessLocal.getErrorString("","VMDUPREC1","");
} }
} }
if(rs != null) if(rs != null)
{ {
rs.close(); rs.close();
rs = null; rs = null;
} }
if(pstmt != null) if(pstmt != null)
{ {
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
} }
} }
//valueXmlString.append("</Root>\r\n"); //valueXmlString.append("</Root>\r\n");
} // end of try } // end of try
catch(Exception e) catch(Exception e)
{ {
try try
{ {
conn.rollback(); conn.rollback();
} }
catch(Exception ex) catch(Exception ex)
{ {
throw new ITMException(ex); throw new ITMException(ex);
} }
throw new ITMException(e); throw new ITMException(e);
} }
finally finally
{ {
try try
{ {
conn.close(); conn.close();
conn = null; conn = null;
} }
catch(Exception e) catch(Exception e)
{ {
throw new ITMException(e); throw new ITMException(e);
} }
} }
return errString ; return errString ;
} }
} }
// cpatil end // cpatil end
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
import java.sql.*;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import javax.ejb.*;
import org.w3c.dom.*;
import ibase.system.config.ConnDriver;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.GenericUtility;
import javax.ejb.Stateless; // added for ejb3
@Stateless
public class PfNumberprs extends ValidatorEJB implements PfNumberprsLocal,PfNumberprsRemote
{
String retString = "";
String objName = "";
Document domStr = null;
ResultSet rs = null;
PreparedStatement pstmt = null;
String sql = "";
String bookType = "";
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
public String itemChanged() throws RemoteException, ITMException
{
return "";
}
public String itemChanged(String currXmlDataStr, String hdrXmlDataStr, String allXmlDataStr, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException, ITMException
{
System.out.println ( "HELLO_");
Document currDom = null;
Document hdrDom = null;
Document hdrDomNew = null;
Document allDom = null;
String errString = null;
GenericUtility genericUtility = GenericUtility.getInstance();
try
{
if (currXmlDataStr != null && currXmlDataStr.trim().length()!=0)
{
currDom = genericUtility.parseString(currXmlDataStr);
}
if (hdrXmlDataStr != null && hdrXmlDataStr.trim().length()!=0)
{
hdrDom = genericUtility.parseString(hdrXmlDataStr);
}
if (allXmlDataStr != null && allXmlDataStr.trim().length()!=0)
{
allDom = genericUtility.parseString(allXmlDataStr);
}
errString = itemChanged( currDom, hdrDom, allDom, objContext, currentColumn, editFlag, xtraParams );
System.out.println ( "ErrString :" + errString);
}
catch (Exception e)
{
System.out.println ( "Exception :DocMasMapEJB :itemChanged(String,String):" + e.getMessage() + ":" );
errString = genericUtility.createErrorString(e);
}
System.out.println ( "returning from DocMasMapEJB itemChanged" );
return errString;
}
public String itemChanged( Document currDom, Document hdrDom, Document allDom, String objContext, String currentColumn, String editFlag, String xtraParams ) throws RemoteException,ITMException
{
String sql = "";
String columnValue = "";
String userId = "";
String docDescr="";
String docNameDescr="";
String empCode = "";
String empFname = "";
String empMname = "";
String empLname = "";
String designation = "";
String reportTo = "";
String reportToAdmin = "";
String departmentDescr = "";
String reportToAdminFname = "";
String outTime = "";
long strIn_timeLong = 0;
long strOut_timeLong = 0;
StringBuffer valueXmlString = new StringBuffer();
Connection connObject = null;
PreparedStatement pstmt = null;
ResultSet rSet = null;
int currentFormNo = 0;
int count=0;
java.sql.Date currentDate = null;
String retDateStr = "";
GenericUtility genericUtility = GenericUtility.getInstance();
String confirmed = "";
String statusDate1 = "";
String statusDate = "";
String childNodeName = null;
NodeList parentNodeList = null;
NodeList childNodeList = null;
Node parentNode = null;
Node childNode = null;
int childNodeListLength = 0;
int ctr = 0;
try
{
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
DateFormat dateFormat = new SimpleDateFormat(genericUtility.getApplDateFormat());
java.util.Date todayDt = new java.util.Date();
String todayDateStr = dateFormat.format(todayDt);
System.out.println("todayDateStr date testing"+todayDateStr);
statusDate1 = genericUtility.getValidDateString(todayDateStr,genericUtility.getApplDateFormat(), genericUtility.getDBDateFormat());
System.out.println("statusDate1 date testing"+statusDate1);
statusDate = todayDateStr;
System.out.println("status date testing"+statusDate + " 00:00:00");
System.out.println("editFlag="+editFlag);
userId = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginCode" );
ConnDriver connDriver = null;
connDriver = new ConnDriver();
connObject = connDriver.getConnectDB("DriverValidator");
parentNodeList = currDom.getElementsByTagName("Detail1");
parentNode = parentNodeList.item(0);
childNodeList = parentNode.getChildNodes();
valueXmlString.append("<Detail1>");
childNodeListLength = childNodeList.getLength();
do
{
childNode = childNodeList.item(ctr);
childNodeName = childNode.getNodeName();
ctr++;
}
while (ctr < childNodeListLength && !childNodeName.equals(currentColumn));
if( objContext != null && objContext.trim().length() > 0 )
{
currentFormNo = Integer.parseInt( objContext );
}
valueXmlString = new StringBuffer( "<?xml version=\"1.0\"?>\r\n<Root>\r\n<Header>\r\n<editFlag>" );
valueXmlString.append( editFlag ).append( "</editFlag>\r\n</Header>\r\n" );
valueXmlString.append( "<Detail1>\r\n" );
if(currentColumn.trim().equalsIgnoreCase("itm_default") || currentColumn.trim().equalsIgnoreCase("itm_defaultedit") )
{
System.out.println(" tran date value"+statusDate);
valueXmlString.append( "<tran_date><![CDATA[" ).append( statusDate ).append( "]]></tran_date>\r\n" );
}
valueXmlString.append( "</Detail1>\r\n" );
}//End of TRY itemChanged doc
catch(Exception e)
{
System.out.println( "Exception :DocMasMapEJB :itemChanged:" + e.getMessage() + ":" );
throw new ITMException(e);
}//End of Catch
finally
{
try
{
if( rSet != null )
{
rSet.close();
rSet = null;
}
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
if( connObject != null && ! connObject.isClosed() )
{
connObject.close();
}
}
catch(Exception e)
{
System.out.println( "Exception :DocMasMapEJB:itemChanged :==>\n"+e.getMessage());
throw new ITMException(e);
}
}//End of Finally
valueXmlString.append( "</Root>\r\n" );
return valueXmlString.toString();
}//End of Item changed
public String preSave()throws RemoteException,ITMException
{
return "";
}
public String preSave(String domString, String editFlag, String xtraParams, Connection conn ) throws RemoteException,ITMException
{
NodeList parentNodeList = null;
NodeList childNodeList = null;
Node childNode = null;
Node parentNode = null;
int parentNodeListLength = 0;
int childNodeListLen = 0;
int childNodeListLength = 0;
String childNodeName = "";
String refLineNum = null;
String bkRefLineNum = null;
String lineNum = null;
String lineNum3 = null;
String lineNum4 = null;
String errString = null;
String updateFlag="";
int roomCnt = 0;
int banqCnt = 0;
double payContr = 0.0;
Document domStr = null;
String updtFlag="";
String status = null;
ResultSet rs = null;
PreparedStatement pstmt = null ;
String sqlQuery="";
String key="REQ";
String val="";
int count=0;
double countBudget = 0.0;
String budgetShare = "";
ArrayList sumArrList =new ArrayList();
String acctCode = null;
String deptCode = null;
String cctrCode = null;
String analCode = null;
String checkStr = null;
String confHall = "";
String eventName = "";
String prefHtlBudg = "";
String keyStr = "";
ArrayList checkArrayList = new ArrayList();
String sqlStr = null;
String empCode = "";
String pfNum = "";
Statement stmt = null;
String errorCode = null;
String userId = null;
String tranDate = null;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance();
try
{
System.out.println("Pre_Save start");
if (domString != null && domString.trim().length() != 0 )
{
domStr = parseString(domString);
}
parentNodeList = domStr.getElementsByTagName("Detail1");
parentNodeListLength = parentNodeList.getLength();
for (int selectedRow = 0; selectedRow < parentNodeListLength; selectedRow++)
{
parentNode = parentNodeList.item(selectedRow);
childNodeList = parentNode.getChildNodes();
childNodeListLength = childNodeList.getLength();
for (int childRow = 0; childRow < childNodeListLength; childRow++)
{
childNode = childNodeList.item(childRow);
childNodeName = childNode.getNodeName();
// updtFlag = getAttribValue(parentNode,"attribute", "updateFlag");
if(!updtFlag.equalsIgnoreCase("D"))
{
if(childNode.getFirstChild()!=null)
{
if (childNodeName.equals("emp_code"))
{
empCode = (childNode.getFirstChild().getNodeValue().trim());
System.out.println("Inside presave empCode"+empCode);
}
else if (childNodeName.equals("tran_date"))
{
tranDate = (childNode.getFirstChild().getNodeValue().trim());
System.out.println("Inside presave tranDate"+tranDate);
}
else if (childNodeName.equals("pf_no"))
{
pfNum = (childNode.getFirstChild().getNodeValue().trim());
System.out.println("Inside presave pfNum"+pfNum);
}
}
}
}
}
if(tranDate == null || tranDate.trim().length() <= 0 )
{
String errCode = "VTBLKCHDTE";
errString=getError("Tran date should not be left blank",errCode,conn);
return errString;
}
if(empCode == null || empCode.trim().length() <= 0 )
{
String errCode = "VTBLKCHODN";
errString=getError("Employee code should not be left blank",errCode,conn);
return errString;
}
else if(empCode != null && empCode.trim().length() > 0)
{
sql = "SELECT COUNT(*) AS COUNT FROM EMPLOYEE WHERE EMP_CODE = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, empCode);
rs = pstmt.executeQuery();
if (rs.next())
{
count = rs.getInt("COUNT");
}
if (count == 0)
{
String errCode = "VTINVCHODN";
errString=getError("Invalid employee code, please enter valid employee code",errCode,conn);
return errString;
}
}
if(pfNum == null || pfNum.trim().length() <= 0 )
{
String errCode = "VTBLKPFODN";
errString=getError("Pf number should not be left blank",errCode,conn);
return errString;
}
if(empCode != null && empCode.trim().length() > 0 && pfNum != null && pfNum.trim().length() > 0)
{
sqlStr = "UPDATE EMPLOYEE SET PF_NO = '"+pfNum+"' WHERE EMP_CODE = '"+empCode+"' ";
System.out.println("sqlStr.........:: " + sqlStr);
stmt = conn.createStatement();
count = stmt.executeUpdate(sqlStr);
conn.commit();
}//End Of if(empStatus)
}//End Of Try Block
catch (SQLException sqe)
{
System.out.println("The SQLException occurs in [EmpAdPrsEJB] :: [executepreSaveRec] :"+sqe);
sqe.printStackTrace();
try
{
conn.rollback();
}
catch(Exception sqe1){}
throw new ITMException(sqe);
}
catch(Exception e)
{
System.out.println("The Exception occurs in [EmpAdPrsEJB] :: [executepreSaveRec] :"+e);
e.printStackTrace();
try
{
conn.rollback();
}
catch(Exception e1){}
throw new ITMException(e);
}
finally
{
try
{
System.out.println("Closing stmt and pstmt In [executepreSaveRec]......");
if (rs != null)
{
rs.close();
rs = null;
}
if(stmt != null)
{
stmt.close();
stmt = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
}
catch(Exception e)
{
System.err.println("Exception :[EmpAdPrsEJB] :: [executepreSaveRec] :\n"+e.getMessage());
e.printStackTrace();
throw new ITMException(e);
}
}
return retString;
}
private Node getCurrentDetailFromDom(Document dom,String domId)
{
NodeList detailList = null;
Node currDetail = null,reqDetail = null;
String currDomId = "";
int detailListLength = 0;
detailList = dom.getElementsByTagName("Detail1");
detailListLength = detailList.getLength();
for (int ctr = 0;ctr < detailListLength;ctr++)
{
currDetail = detailList.item(ctr);
currDomId = currDetail.getAttributes().getNamedItem("domID").getNodeValue();
if (currDomId.equals(domId))
{
reqDetail = currDetail;
break;
}
}
return reqDetail;
}
private String getError(String descr,String Code,Connection conn)
throws ITMException, Exception
{
String mainStr ="";
try
{
String errString = "";
errString = new ITMDBAccessEJB().getErrorString("",Code,"","",conn);
String begPart = errString.substring(0,errString.indexOf("<message>")+9);
String endDesc = errString.substring(errString.indexOf("</description>"));
mainStr= begPart+"Invalid Data"+"</message><description>";
mainStr= mainStr+" "+descr+" "+endDesc;
System.out.println("mainStr:::::::::::::::::: "+mainStr);
begPart = null;
}
catch(Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
return mainStr;
}
private String getCurrentUpdateFlag(Node currDetail)
{
NodeList currDetailList = null;
String updateStatus = "",nodeName = "";
int currDetailListLength = 0;
currDetailList = currDetail.getChildNodes();
currDetailListLength = currDetailList.getLength();
for (int i=0;i< currDetailListLength;i++)
{
nodeName = currDetailList.item(i).getNodeName();
if (nodeName.equalsIgnoreCase("Attribute"))
{
updateStatus = currDetailList.item(i).getAttributes().getNamedItem("updateFlag").getNodeValue();
break;
}
}
return updateStatus;
}
}
package ibase.webitm.ejb.adm;
import ibase.webitm.ejb.ValidatorLocal;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import java.sql.Connection;
import javax.ejb.Local;
import org.w3c.dom.Document;
// added for ejb3
@Local
public interface PfNumberprsLocal extends ValidatorLocal
{
public String preSave()throws RemoteException,ITMException;
public String preSave( String domString, String editFlag, String xtraParams, Connection conn ) throws RemoteException,ITMException;
public String itemChanged() throws RemoteException,ITMException;
public String itemChanged(String xmlString_, String xmlString1,String xmlString2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException;
public String itemChanged(Document dom_, Document dom1, Document dom2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.ValidatorRemote;
import ibase.webitm.utility.ITMException;
import java.sql.Connection;
import javax.ejb.Remote; // added for ejb3
import org.w3c.dom.Document;
@Remote
public interface PfNumberprsRemote extends ValidatorRemote
{
public String preSave()throws RemoteException,ITMException;
public String preSave( String domString, String editFlag, String xtraParams, Connection conn ) throws RemoteException,ITMException;
public String itemChanged() throws RemoteException,ITMException;
public String itemChanged(String xmlString_, String xmlString1,String xmlString2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException;
public String itemChanged(Document dom_, Document dom1, Document dom2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException;
}
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