Commit 315e2dca authored by ysawant's avatar ysawant

Added new migrated component of Address change

EmpAddChgCnc.java
emp_add_chg21.xml
EmpAddChangeConfirm.java
EmpAddChangeConfirmLocal.java
EmpAddChangeConfirmRemote.java
EmpAddChange.java
EmpAddChangeLocal.java
EmpAddChangeRemote.java
emp_add_chg11.xml
w_emp_add_chg.sql
d_emp_add_chg_brow.srd


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@204596 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 6be19411
This diff is collapsed.
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
import org.w3c.dom.Document;
import ibase.webitm.ejb.ValidatorLocal;
import ibase.webitm.utility.ITMException;
public interface EmpAddChangeLocal extends ValidatorLocal
{
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;
public String wfValData(String xmlString, String xmlString1,String xmlString2, String objContext, String editFlag,String xtraParams) throws RemoteException,ITMException ;
public String wfValData(Document dom, Document dom1, Document dom2,String objContext, String editFlag, String xtraParams)throws RemoteException, ITMException;
}
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
import org.w3c.dom.Document;
import ibase.webitm.ejb.ValidatorRemote;
import ibase.webitm.utility.ITMException;
public interface EmpAddChangeRemote extends ValidatorRemote
{
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;
public String wfValData(String xmlString, String xmlString1,String xmlString2, String objContext, String editFlag,String xtraParams) throws RemoteException,ITMException ;
public String wfValData(Document dom, Document dom1, Document dom2,String objContext, String editFlag, String xtraParams)throws RemoteException, ITMException;
}
//Migrated By Yashwant on 19/07/2019[Start]
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Timestamp;
import java.text.SimpleDateFormat;
import ibase.utility.E12GenericUtility;
import ibase.webitm.ejb.ActionHandlerEJB;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException;
public class EmpAddChangeConfirm extends ActionHandlerEJB implements EmpAddChangeConfirmLocal,EmpAddChangeConfirmRemote
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
String retString = "";
Connection conn=null;
try
{
conn= getConnection();
retString=postLogic(tranId, tranId, xtraParams, forcedFlag, conn);
System.out.println("retString from postLogic : "+retString);
if(retString != null && retString.trim().length() > 0)
{
conn.rollback();
}
else
{
conn.commit();
}
}
catch(Exception e)
{
System.out.println("Exception :EmpAddChangeConfirm :confirm():" + e.getMessage() + ":");
retString = GenericUtility.getInstance().createErrorString(e);
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if(conn != null)
{
conn.close();
conn = null;
}
}
catch (Exception e) {
e.printStackTrace();
}
}
return retString;
}
public String postLogic(String asTranidFr,String asTranidTo,String xtraParams,String forcedFlag,Connection conn) throws ITMException
{
String lsTranId="";
String lsConf="";
String sql="";
ResultSet rs=null;
PreparedStatement pstmt = null;
ITMDBAccessEJB itmDbAcess = new ITMDBAccessEJB();
E12GenericUtility genericUtility = new E12GenericUtility();
String errString="";
String userId="";
try
{
userId = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode"));
if(asTranidFr.equalsIgnoreCase(asTranidTo))
{
lsTranId = asTranidFr;
}
sql="select confirmed as ls_conf from employee_add_change where tran_id = ?";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,lsTranId);
rs = pstmt.executeQuery();
if(rs.next())
{
lsConf=checkNull(rs.getString("ls_conf"));
}
else
{
errString=checkNull(itmDbAcess.getErrorString("", "VTMCONF20",userId, "", conn));
return errString;
}
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
if("Y".equalsIgnoreCase(lsConf))
{
errString=checkNull(itmDbAcess.getErrorString("", "VTMCONF1",userId, "", conn));
return errString;
}
else if("X".equalsIgnoreCase(lsConf))
{
errString=checkNull(itmDbAcess.getErrorString("", "VTMCANL1",userId, "", conn));
return errString;
}
else
{
errString=gbfUpdation(lsTranId, "Y", xtraParams, conn);
}
}
catch (Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
return errString;
}
public String gbfUpdation( String tranId, String forcedFlag, String xtraParams, Connection conn) throws ITMException
{
System.out.println("--------------gbfUpdation method of EmpAddChangeConfirm -------------");
ResultSet rs=null;
PreparedStatement pstmt = null;
E12GenericUtility genericUtility=new E12GenericUtility();
String sql="";
String empCode="";
String curAdd1="";
String curAdd2="";
String curAdd3="";
String curCity="";
String curPin="";
String curTel1="";
String curTel2="";
String curTel3="";
String curState="";
String perAdd1="";
String perAdd2="";
String perAdd3="";
String perCity="";
String perState="";
String perPin="";
String perTel="";
String mobileNo="";
String smsDomain="";
String emailIdOff="";
String emailIdPer="";
String imeNo="";
String userId="";
String errString="";
String termId="";
String confDate="";
String empCodeAprv="";
Timestamp chgDate=null;
Timestamp ldConfDate=null;
SimpleDateFormat sdf=null;
String todayDate="";
ITMDBAccessEJB itmDbAcess = new ITMDBAccessEJB();
try
{
userId = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode"));
termId = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "termId"));
int count=0;
sdf=new SimpleDateFormat(genericUtility.getApplDateFormat());
todayDate=sdf.format(new java.util.Date());
chgDate = Timestamp.valueOf(genericUtility.getValidDateString(todayDate, genericUtility.getApplDateFormat(), genericUtility.getDBDateFormat()) + " 00:00:00.0");
do
{
sql="select emp_code,cur_add1, cur_add2, cur_add3, cur_city, " +
"cur_state, cur_pin, cur_tel1, cur_tel2," +
" cur_tel3, per_add1, per_add2, per_add3," +
" per_city, per_state, per_pin, per_tel, conf_date, emp_code__aprv," +
" mobile_no , sms_domain , email_id_off , email_id_per, ime_no"+
" from employee_add_change" +
" where tran_id = ?";
pstmt =conn.prepareStatement(sql);
pstmt.setString(1,tranId);
rs = pstmt.executeQuery();
if (rs.next())
{
empCode = checkNull(rs.getString("emp_code"));
curAdd1 = checkNull(rs.getString("cur_add1"));
curAdd2 = checkNull(rs.getString("cur_add2"));
curAdd3 = checkNull(rs.getString("cur_add3"));
curCity = checkNull(rs.getString("cur_city"));
curState=checkNull(rs.getString("cur_state"));
curPin = checkNull(rs.getString("cur_pin"));
curTel1 = checkNull(rs.getString("cur_tel1"));
curTel2 = checkNull(rs.getString("cur_tel2"));
curTel3 = checkNull(rs.getString("cur_tel3"));
perAdd1 = checkNull(rs.getString("per_add1"));
perAdd2 = checkNull(rs.getString("per_add2"));
perAdd3 = checkNull(rs.getString("per_add3"));
perCity = checkNull(rs.getString("per_city"));
perState = checkNull(rs.getString("per_state"));
perPin = checkNull(rs.getString("per_pin"));
perTel = checkNull(rs.getString("per_tel"));
confDate = checkNull(rs.getString("conf_date"));
empCodeAprv = checkNull(rs.getString("emp_code__aprv"));
mobileNo = checkNull(rs.getString("mobile_no"));
smsDomain = checkNull(rs.getString("sms_domain"));
emailIdOff = checkNull(rs.getString("email_id_off"));
emailIdPer = checkNull(rs.getString("email_id_per"));
imeNo = checkNull(rs.getString("ime_no"));
}
else
{
errString=checkNull(itmDbAcess.getErrorString("", "DS000", userId, "", conn));
break;
}
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
if("Y".equalsIgnoreCase(forcedFlag))
{
ldConfDate = Timestamp.valueOf(genericUtility.getValidDateString(todayDate, genericUtility.getApplDateFormat(), genericUtility.getDBDateFormat()) + " 00:00:00.0");
empCodeAprv = empCode;
}
//update employee_add_change set confirmed = 'Y', conf_date = :ld_conf_date,where tran_id = :as_tran_id
sql="update employee_add_change set confirmed = ?, conf_date = ? where tran_id = ?";
pstmt =conn.prepareStatement(sql);
pstmt.setString(1,"Y");
pstmt.setTimestamp(2, ldConfDate);
pstmt.setString(3,tranId);
count = pstmt.executeUpdate();
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(count != 1)
{
errString=itmDbAcess.getErrorString("","DS000NR" , userId, "", conn);
break;
}
System.out.println("confirm updated -------->>>>>>>>>updCount :"+count);
count =0;
sql="update employee set cur_add1 = ?,cur_add2 = ?,cur_add3 = ?,cur_city = ?,"
+ "cur_state = ?,cur_pin = ?,cur_tel1 = ?,cur_tel2 = ?,cur_tel3 = ?,"
+ "per_add1 = ?,per_add2 = ?,per_add3 = ?,per_city = ?,per_state = ?,"
+ "per_pin = ?,per_tel = ?,chg_user = ? ,chg_term = ? ,chg_date= ?,"
+ "mobile_no= ? , sms_domain= ? , email_id_off= ?,email_id_per= ?, ime_no = ?"
+ "where emp_code = ?";
pstmt =conn.prepareStatement(sql);
pstmt.setString(1,curAdd1);
pstmt.setString(2,curAdd2);
pstmt.setString(3,curAdd3);
pstmt.setString(4,curCity);
pstmt.setString(5,curState);
pstmt.setString(6,curPin);
pstmt.setString(7,curTel1);
pstmt.setString(8,curTel2);
pstmt.setString(9,curTel3);
pstmt.setString(10,perAdd1);
pstmt.setString(11,perAdd2);
pstmt.setString(12,perAdd3);
pstmt.setString(13,perCity);
pstmt.setString(14,perState);
pstmt.setString(15,perPin);
pstmt.setString(16,perTel);
pstmt.setString(17,userId);
pstmt.setString(18,termId);
pstmt.setTimestamp(19,chgDate);
pstmt.setString(20,mobileNo);
pstmt.setString(21,smsDomain);
pstmt.setString(22,emailIdOff);
pstmt.setString(23,emailIdPer);
pstmt.setString(24,imeNo);
pstmt.setString(25,empCode);
count = pstmt.executeUpdate();
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(count != 1)
{
errString=itmDbAcess.getErrorString("","DS000NR" , userId, "", conn);
break;
}
break;
}
while(true);
}
catch(Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
}
catch (Exception e)
{
System.out.println("Exception ::" + e);
e.printStackTrace();
throw new ITMException(e);
}
}
return errString;
}
private String checkNull(String input)
{
if (input == null)
{
input = "";
}
else
{
input = input.trim();
}
return input;
}
}
//Migrated By Yashwant on 19/07/2019[End]
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import ibase.webitm.ejb.ActionHandlerLocal;
import ibase.webitm.utility.ITMException;
public interface EmpAddChangeConfirmLocal extends ActionHandlerLocal
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import ibase.webitm.ejb.ActionHandlerRemote;
import ibase.webitm.utility.ITMException;
public interface EmpAddChangeConfirmRemote extends ActionHandlerRemote
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.adm.adv; package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException; import java.rmi.RemoteException;
import java.sql.*; import java.sql.Connection;
import javax.ejb.*; import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.GenericUtility;
import ibase.system.config.*;
import javax.ejb.Stateless; // added for ejb3 import javax.ejb.Stateless; // added for ejb3
import ibase.utility.E12GenericUtility;
import ibase.webitm.ejb.ActionHandlerEJB;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.utility.ITMException;
@Stateless // added for ejb3 @Stateless // added for ejb3
public class EmpAddChgCnc extends ActionHandlerEJB implements EmpAddChgCncLocal,EmpAddChgCncRemote //SessionBean public class EmpAddChgCnc extends ActionHandlerEJB implements EmpAddChgCncLocal,EmpAddChgCncRemote //SessionBean
...@@ -39,7 +42,6 @@ public class EmpAddChgCnc extends ActionHandlerEJB implements EmpAddChgCncLocal, ...@@ -39,7 +42,6 @@ public class EmpAddChgCnc extends ActionHandlerEJB implements EmpAddChgCncLocal,
{ {
String retString = null; String retString = null;
GenericUtility genericUtility = GenericUtility.getInstance();
try try
{ {
retString = actionCancel(tranId, xtraParams, forcedFlag); retString = actionCancel(tranId, xtraParams, forcedFlag);
...@@ -58,28 +60,49 @@ public class EmpAddChgCnc extends ActionHandlerEJB implements EmpAddChgCncLocal, ...@@ -58,28 +60,49 @@ public class EmpAddChgCnc extends ActionHandlerEJB implements EmpAddChgCncLocal,
{ {
String sql = "", empCodeAprove = "", loginEmpCode = "", errCode = "", errString = "", confirmed = "", updSql = ""; String sql = "", empCodeAprove = "", loginEmpCode = "", errCode = "", errString = "", confirmed = "", updSql = "";
Connection conn = null; Connection conn = null;
Statement stmt = null; //Statement stmt = null;
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
ResultSet rs = null; ResultSet rs = null;
int updCnt = 0; int updCnt = 0;
java.sql.Date currDate = null; //java.sql.Date currDate = null;
ConnDriver connDriver = new ConnDriver(); //ConnDriver connDriver = new ConnDriver();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB(); ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance(); //Modified by Yashwant on 18-07-2019[Start]
//GenericUtility genericUtility = GenericUtility.getInstance();
E12GenericUtility genericUtility=new E12GenericUtility();
//
try try
{ {
conn = connDriver.getConnectDB("DriverITM"); //conn = connDriver.getConnectDB("DriverITM");
stmt = conn.createStatement(); conn=getConnection();
//stmt = conn.createStatement();
System.out.println("Tran ID : "+ tranId); System.out.println("Tran ID : "+ tranId);
sql = "SELECT CONFIRMED FROM EMPLOYEE_ADD_CHANGE WHERE TRAN_ID = '"+tranId+"' "; //sql = "SELECT CONFIRMED FROM EMPLOYEE_ADD_CHANGE WHERE TRAN_ID = '"+tranId+"' ";
sql = "SELECT CONFIRMED FROM EMPLOYEE_ADD_CHANGE WHERE TRAN_ID = ?";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
System.out.println("sql :"+sql); System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql); //rs = stmt.executeQuery(sql);
if (rs.next()) if (rs.next())
{ {
confirmed = rs.getString(1); //confirmed = rs.getString(1);
confirmed =checkNull(rs.getString("CONFIRMED"));
}
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
} }
//Modified by Yashwant on 18-07-2019[End]
System.out.println(); System.out.println();
loginEmpCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode"); //loginEmpCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode");
loginEmpCode = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginEmpCode"));
System.out.println("confirmed :"+confirmed+"loginEmpCode :"+loginEmpCode); System.out.println("confirmed :"+confirmed+"loginEmpCode :"+loginEmpCode);
if (confirmed != null && confirmed.equals("N")) if (confirmed != null && confirmed.equals("N"))
{ {
...@@ -98,6 +121,13 @@ public class EmpAddChgCnc extends ActionHandlerEJB implements EmpAddChgCncLocal, ...@@ -98,6 +121,13 @@ public class EmpAddChgCnc extends ActionHandlerEJB implements EmpAddChgCncLocal,
{ {
errCode = "VTSUCC"; errCode = "VTSUCC";
} }
//Modified by Yashwant on 18-07-2019[Start]
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
//Modified by Yashwant on 18-07-2019[End]
} }
else if(confirmed != null && confirmed.equals("Y")) else if(confirmed != null && confirmed.equals("Y"))
{ {
...@@ -110,7 +140,7 @@ public class EmpAddChgCnc extends ActionHandlerEJB implements EmpAddChgCncLocal, ...@@ -110,7 +140,7 @@ public class EmpAddChgCnc extends ActionHandlerEJB implements EmpAddChgCncLocal,
if (errCode != null && errCode.trim().length() > 0) if (errCode != null && errCode.trim().length() > 0)
{ {
System.out.println("EmpAddChgCnc:errCode:"+errCode); System.out.println("EmpAddChgCnc:errCode:"+errCode);
errString = itmDBAccessEJB.getErrorString("",errCode,"","",conn); errString = checkNull(itmDBAccessEJB.getErrorString("",errCode,"","",conn));
} }
} }
catch (SQLException sqx) catch (SQLException sqx)
...@@ -127,26 +157,28 @@ public class EmpAddChgCnc extends ActionHandlerEJB implements EmpAddChgCncLocal, ...@@ -127,26 +157,28 @@ public class EmpAddChgCnc extends ActionHandlerEJB implements EmpAddChgCncLocal,
{ {
try try
{ {
if (conn!=null) //Modified by Yashwant on 18-07-2019[Start]
{ /*if (stmt != null)
conn.close();
conn = null;
}
if (stmt != null)
{ {
stmt.close(); stmt.close();
stmt = null; stmt = null;
}*/
if (rs != null)
{
rs.close();
rs = null;
} }
if (pstmt != null) if (pstmt != null)
{ {
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
} }
if (rs != null) if (conn!=null)
{ {
rs.close(); conn.close();
rs = null; conn = null;
} }
//Modified by Yashwant on 18-07-2019[End]
} }
catch (Exception e) catch (Exception e)
{ {
...@@ -155,4 +187,16 @@ public class EmpAddChgCnc extends ActionHandlerEJB implements EmpAddChgCncLocal, ...@@ -155,4 +187,16 @@ public class EmpAddChgCnc extends ActionHandlerEJB implements EmpAddChgCncLocal,
} }
return errString; return errString;
} }
//Modified by Yashwant on 18-07-2019[Start]
private String checkNull(String input)
{
if (input == null)
{
input = "";
}
return input;
}
//Modified by Yashwant on 18-07-2019[End]
} }
\ No newline at end of file
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
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