Skip to content

B
business-java
Commit 1c9be8c5 authored by piyush's avatar piyush
Browse files
Options

Head Allocation related changes merged 

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@217309 ce508802-f39f-4f6c-b175-0d175dae99d5
parent b4a622eb
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 1264 additions and 187 deletions
webitm-adm/src/ibase/webitm/ejb/adm/adv/PayStruChgReqCancel.java
View file @ 1c9be8c5
......@@ -14,6 +14,10 @@ import ibase.webitm.ejb.ActionHandlerEJB;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.adm.AdmCommon;
import ibase.webitm.utility.ITMException;
import ibase.utility.UserInfoBean;
import ibase.webitm.ejb.DBAccessEJB;
import ibase.webitm.ejb.adm.adv.PayStruChgReqConfirm;
@Stateless
public class PayStruChgReqCancel extends ActionHandlerEJB implements PayStruChgReqCancelLocal,PayStruChgReqCancelRemote
{
......@@ -25,11 +29,30 @@ public class PayStruChgReqCancel extends ActionHandlerEJB implements PayStruChgR
Connection conn = null;
String userId = "";
String retString = "";
UserInfoBean userInfoBean = null;
DBAccessEJB dbAccessEJB = new DBAccessEJB();
String transInfoXml = "";
String userInfoStr = "";
PayStruChgReqConfirm payStruChgReqConfirm = new PayStruChgReqConfirm();
try
{
System.out.println(":::Inside PayStruChgReqCancel : cancel():::");
conn = getConnection();
userId = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode"));
userInfoBean = payStruChgReqConfirm.createUserInfo(userId, null, conn);
userInfoStr = userInfoBean.toString();
try
{
transInfoXml = payStruChgReqConfirm.getXMLFromDBForEdit("pay_stru_chg_req_wiz","2",1,tranId, "String","PYALOC", userInfoStr);
}
catch (Exception e1)
{
System.out.println("Exception :PayStruChgReqConfirm :confirm():" + e1.getMessage() + ":");
e1.printStackTrace();
transInfoXml = "";
}
retString = postLogic(tranId, xtraParams, forcedFlag, conn);
System.out.println("retString from postLogic : "+retString);
......@@ -41,11 +64,35 @@ public class PayStruChgReqCancel extends ActionHandlerEJB implements PayStruChgR
else
{
conn.commit();
if (transInfoXml != null && transInfoXml.trim().length() > 0)
{
try
{
payStruChgReqConfirm.doMailActivity(tranId , transInfoXml, userInfoStr, "PYALCHRCAN", "HR", "", xtraParams, conn);
}
catch (Exception e2)
{
System.out.println("Exception :PayStruChgReqConfirm :confirm():" + e2.getMessage() + ":");
e2.printStackTrace();
}
}
retString = itmDbAcess.getErrorString("","VTPAYALC12" , userId, "", conn);
}
}
catch(Exception e)
{
try
{
if (conn != null)
{
conn.rollback();
}
}
catch (Exception e3)
{
System.out.println("Exception :PayStruChgReqConfirm :confirm():" + e3.getMessage() + ":");
e3.printStackTrace();
}
System.out.println("Exception :PayStruChgReqCancel :Cancel():" + e.getMessage() + ":");
retString = genericUtility.createErrorString(e);
e.printStackTrace();
......@@ -57,6 +104,7 @@ public class PayStruChgReqCancel extends ActionHandlerEJB implements PayStruChgR
{
if(conn != null)
{
conn.rollback();
conn.close();
conn = null;
}
......@@ -76,7 +124,7 @@ public class PayStruChgReqCancel extends ActionHandlerEJB implements PayStruChgR
String sql = "";
//String workSite = "";
String empCodeHr = "";
String loginEmpCode = "",emailCC="";
String loginEmpCode = "",emailCC="", empCode = "";
String email = "";
ResultSet rs = null;
PreparedStatement pstmt = null;
......@@ -88,17 +136,18 @@ public class PayStruChgReqCancel extends ActionHandlerEJB implements PayStruChgR
try
{
System.out.println(":::Inside PayStruChgReqCancel : postLogic():::");
userId = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode"));
loginEmpCode=userId;
userId = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode"));
loginEmpCode = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode"));
workSite = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode"));
sql = "SELECT REQ_STATUS FROM PAY_STRU_CHG_REQ_HDR WHERE TRAN_ID = ?";
sql = "SELECT REQ_STATUS, EMP_CODE FROM PAY_STRU_CHG_REQ_HDR WHERE TRAN_ID = ? FOR UPDATE NOWAIT";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,Tranid);
rs = pstmt.executeQuery();
if(rs.next())
{
reqStatus = checkNull(rs.getString("REQ_STATUS"));
empCode = checkNull(rs.getString("EMP_CODE"));
System.out.println("reqStatus:::==" +reqStatus);
}
if (rs != null)
......@@ -122,7 +171,7 @@ public class PayStruChgReqCancel extends ActionHandlerEJB implements PayStruChgR
else if("U".equalsIgnoreCase(reqStatus))
{
//
sql = "UPDATE PAY_STRU_CHG_REQ_HDR SET REQ_STATUS = 'C' where TRAN_ID = ? ";
sql = "UPDATE PAY_STRU_CHG_REQ_HDR SET REQ_STATUS = 'C', STATUS_DATE = trunc(FN_SYSDATE()) where TRAN_ID = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,Tranid);
cnt = pstmt.executeUpdate();
......@@ -134,72 +183,11 @@ public class PayStruChgReqCancel extends ActionHandlerEJB implements PayStruChgR
pstmt = null;
}
if(cnt > 0)
if(cnt != 1)
{
errString = checkNull(itmDbAcess.getErrorString("", "VTPAYALC12",userId, "", conn));//Status Updated successfully
System.out.println("Status Updated successfully...." +cnt);
sql = "SELECT EMAIL_ID_OFF FROM EMPLOYEE WHERE EMP_CODE = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,loginEmpCode);
rs = pstmt.executeQuery();
if(rs.next())
{
emailCC = checkNull(rs.getString("EMAIL_ID_OFF"));
System.out.println("emailCC:::==" +emailCC);
}
if(rs != null)
{
rs.close();
rs = null;
}
pstmt.clearParameters();
empList=getHREmpCode(loginEmpCode, conn);
System.out.println("empList getting is ::::" +empList.toString());
System.out.println("length of empList::::" +empList.toString().length());
if( empList.size() > 0 )
{
System.out.println("empList size "+empList.size());
for(int i = 0 ; i < empList.size(); i++)
{
empCodeHr = empList.get(i).toString();
System.out.println("empCodeHr FROM EMPLIST...."+empCodeHr);
pstmt.setString(1, empCodeHr);
rs = pstmt.executeQuery();
if(rs.next())
{
email = rs.getString("EMAIL_ID_OFF");
System.out.println("email generated from mailList:::::::" +email);
}
if(rs != null)
{
rs.close();
rs = null;
}
pstmt.clearParameters();
/**calling send mail method*/
// String objName=getObjName(domString, objContext);
isMailSend = sendMail(email, "PYALOC","pay_stru_chg_req_wiz",Tranid,"PYALCHRCAN", "E", empCodeHr, email,emailCC, conn);
if(isMailSend)
{
MailCnt++;
System.out.println("Payroll Process mail send successfully >> "+MailCnt);
}
}
}
errString = checkNull(itmDbAcess.getErrorString("", "VTPAYALC16", userId, "", conn));
}
if(isMailSend)
{
System.out.println("Payroll Process mail send successfully >> "+MailCnt);
}
//
System.out.println("Payroll Process mail send successfully >> "+MailCnt);
}
}
catch (Exception e)
......@@ -280,7 +268,7 @@ public class PayStruChgReqCancel extends ActionHandlerEJB implements PayStruChgR
String mailDomStr = valueXmlString.toString();
System.out.println(" [PayStruChgReqSubmit] :sendMail mailDomStr :-->" + mailDomStr);
EMail email = new EMail();
email.sendMail(mailDomStr, "ITM", conn);
email.sendMail(mailDomStr, "ITM");
System.out.println("PayStruChgReqSubmit mail delivered successfully" );
emailFlag = true;
}
......@@ -292,78 +280,5 @@ public class PayStruChgReqCancel extends ActionHandlerEJB implements PayStruChgR
}
return emailFlag;
}
private ArrayList<String> getHREmpCode (String empCode, Connection conn) throws ITMException
{
String hrEmpCode = "", hrEmpCode1 = "", hrEmpCode2 = "";
PreparedStatement pstmt = null;
ResultSet rs = null;
ArrayList<String> empCodeList=new ArrayList();
//int hrCnt=0;
try
{
//hrCnt++;
String sql = "SELECT FN_GET_HR_EMP_CODE( ?, 'PYALC', 1) AS HR_EMP_CODE, FN_GET_HR_EMP_CODE( ?, 'PYALC', 2) AS HR_EMP_CODE_1, FN_GET_HR_EMP_CODE( ?, 'PYALC', 3) AS HR_EMP_CODE_2 FROM DUAL";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, empCode);
pstmt.setString(2, empCode);
pstmt.setString(3, empCode);
rs = pstmt.executeQuery();
if(rs.next())
{
hrEmpCode = checkNull(rs.getString("HR_EMP_CODE"));
hrEmpCode1 = checkNull(rs.getString("HR_EMP_CODE_1"));
hrEmpCode2 = checkNull(rs.getString("HR_EMP_CODE_2"));
}
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(hrEmpCode.trim().length()>0)
{
empCodeList.add(hrEmpCode);
}
if(hrEmpCode1.trim().length()>0)
{
empCodeList.add(hrEmpCode1);
}
if(hrEmpCode2.trim().length()>0)
{
empCodeList.add(hrEmpCode2);
}
}
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(SQLException sqle)
{
sqle.printStackTrace();
throw new ITMException(sqle);
}
}
return empCodeList;
}
}
\ No newline at end of file
}
webitm-adm/src/ibase/webitm/ejb/adm/adv/PayStruChgReqReject.java 0 → 100644
View file @ 1c9be8c5
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.SQLException;
import java.util.ArrayList;
import javax.ejb.Stateless;
import ibase.utility.E12GenericUtility;
import ibase.utility.EMail;
import ibase.webitm.ejb.ActionHandlerEJB;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.adm.AdmCommon;
import ibase.webitm.utility.ITMException;
import ibase.utility.UserInfoBean;
import ibase.webitm.ejb.DBAccessEJB;
import ibase.webitm.ejb.adm.adv.PayStruChgReqConfirm;
@Stateless
public class PayStruChgReqReject extends ActionHandlerEJB implements PayStruChgReqRejectLocal,PayStruChgReqRejectRemote
{
AdmCommon admCommon = new AdmCommon();
ITMDBAccessEJB itmDbAcess = new ITMDBAccessEJB();
E12GenericUtility genericUtility = new E12GenericUtility();
public String actionHandler() throws RemoteException,ITMException
{
return "";
}
public String actionHandler(String tranId, String xtraParams, String forcedFlag)
{
Connection conn = null;
String userId = "";
String retString = "";
UserInfoBean userInfoBean = null;
DBAccessEJB dbAccessEJB = new DBAccessEJB();
String transInfoXml = "";
String userInfoStr = "";
PayStruChgReqConfirm payStruChgReqConfirm = new PayStruChgReqConfirm();
try
{
System.out.println(":::Inside PayStruChgReqReject : actionHandler(String tranId, String xtraParams, String forcedFlag):::");
conn = getConnection();
retString = actionHandler(tranId, xtraParams, forcedFlag, conn);
System.out.println("retString from actionHandler(tranId, xtraParams, forcedFlag, conn) : "+retString);
if(retString != null && retString.trim().length() > 0 && retString.indexOf("VTPAYALC19")<0)
{
conn.rollback();
}
else
{
conn.commit();
/*
if (transInfoXml != null && transInfoXml.trim().length() > 0)
{
try
{
payStruChgReqConfirm.doMailActivity(tranId , transInfoXml, userInfoStr, "PYALCREJ01", "EMP", "HR", xtraParams, conn);
}
catch (Exception e2)
{
System.out.println("Exception :PayStruChgReqConfirm :doMailActivity(tranId , transInfoXml, userInfoStr, "PYALCREJ01", "EMP", "HR", xtraParams, conn):" + e2.getMessage() + ":");
e2.printStackTrace();
}
}
*/
retString = itmDbAcess.getErrorString("","VTPAYALC19" , userId, "", conn);
}
}
catch(Exception e)
{
try
{
if (conn != null)
{
conn.rollback();
}
}
catch (Exception e3)
{
System.out.println("Exception :PayStruChgReqConfirm :confirm():" + e3.getMessage() + ":");
e3.printStackTrace();
}
System.out.println("Exception :PayStruChgReqCancel :Cancel():" + e.getMessage() + ":");
retString = genericUtility.createErrorString(e);
e.printStackTrace();
}
finally
{
try
{
if(conn != null)
{
conn.rollback();
conn.close();
conn = null;
}
}
catch (Exception e)
{
e.printStackTrace();
}
}
return retString;
}
public String actionHandler(String tranId, String xtraParams, String forcedFlag, Connection conn)
{
String userId = "";
String retString = "";
UserInfoBean userInfoBean = null;
DBAccessEJB dbAccessEJB = new DBAccessEJB();
String transInfoXml = "";
String userInfoStr = "";
PayStruChgReqConfirm payStruChgReqConfirm = new PayStruChgReqConfirm();
try
{
System.out.println(":::Inside PayStruChgReqReject : actionHandler(String tranId, String xtraParams, String forcedFlag, Connection conn):::");
userId = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode"));
userInfoBean = payStruChgReqConfirm.createUserInfo(userId, null, conn);
userInfoStr = userInfoBean.toString();
try
{
transInfoXml = payStruChgReqConfirm.getXMLFromDBForEdit("pay_stru_chg_req_hr_wiz","2",1,tranId, "String","PYALOC", userInfoStr);
}
catch (Exception e1)
{
System.out.println("Exception :PayStruChgReqReject :actionHandler(String tranId, String xtraParams, String forcedFlag, Connection conn):" + e1.getMessage() + ":");
e1.printStackTrace();
transInfoXml = "";
}
retString = postLogic(tranId, xtraParams, forcedFlag, conn);
System.out.println("retString from PayStruChgReqReject : postLogic(tranId, xtraParams, forcedFlag, conn); : "+retString);
if(retString != null && retString.trim().length() > 0 && retString.indexOf("VTPAYALC19")<0)
{
conn.rollback();
}
else
{
conn.commit();
if (transInfoXml != null && transInfoXml.trim().length() > 0)
{
try
{
payStruChgReqConfirm.doMailActivity(tranId , transInfoXml, userInfoStr, "PYALCREJ01", "EMP", "HR", xtraParams, conn);
}
catch (Exception e2)
{
System.out.println("Exception :payStruChgReqConfirm :doMailActivity(tranId , transInfoXml, userInfoStr, \"PYALCREJ01\", \"EMP\", \"HR\", xtraParams, conn);:" + e2.getMessage() + ":");
e2.printStackTrace();
}
}
retString = itmDbAcess.getErrorString("","VTPAYALC19" , userId, "", conn);
}
}
catch(Exception e)
{
try
{
if (conn != null)
{
conn.rollback();
}
}
catch (Exception e3)
{
System.out.println("Exception :PayStruChgReqReject : actionHandler(String tranId, String xtraParams, String forcedFlag, Connection conn) :" + e3.getMessage() + ":");
e3.printStackTrace();
}
System.out.println("Exception :PayStruChgReqReject : actionHandler(String tranId, String xtraParams, String forcedFlag, Connection conn) :" + e.getMessage() + ":");
retString = genericUtility.createErrorString(e);
e.printStackTrace();
}
finally
{
}
return retString;
}
@SuppressWarnings("resource")
public String postLogic(String Tranid,String xtraParams,String forcedFlag,Connection conn) throws ITMException, SQLException
{
String errString = "";
String userId = "";
String sql = "";
//String workSite = "";
String empCodeHr = "";
String loginEmpCode = "",emailCC="", empCode = "";
String email = "";
ResultSet rs = null;
PreparedStatement pstmt = null;
ArrayList<String> empList = new ArrayList();
int cnt = 0 , MailCnt = 0;
boolean isMailSend = false;
String workSite = "";
String reqStatus = "";
String cancelRemarks = "";
try
{
System.out.println(":::Inside PayStruChgReqReject : postLogic(String Tranid,String xtraParams,String forcedFlag,Connection conn) :::");
userId = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode"));
loginEmpCode = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode"));
workSite = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode"));
sql = "SELECT REQ_STATUS, EMP_CODE, CANCEL_REMARKS FROM PAY_STRU_CHG_REQ_HDR WHERE TRAN_ID = ? FOR UPDATE NOWAIT";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,Tranid);
rs = pstmt.executeQuery();
if(rs.next())
{
reqStatus = checkNull(rs.getString("REQ_STATUS"));
empCode = checkNull(rs.getString("EMP_CODE"));
cancelRemarks = checkNull(rs.getString("CANCEL_REMARKS"));
System.out.println("PayStruChgReqReject : postLogic(String Tranid,String xtraParams,String forcedFlag,Connection conn) reqStatus:::==" +reqStatus);
}
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
if("A".equalsIgnoreCase(reqStatus))
{
errString = checkNull(itmDbAcess.getErrorString("", "VTPAYALC13",userId, "", conn));//Already Approved
}
else if("C".equalsIgnoreCase(reqStatus))
{
errString = checkNull(itmDbAcess.getErrorString("", "VTPAYALC14",userId, "", conn));//Already Cancelled
}
else if("U".equalsIgnoreCase(reqStatus))
{
//
if (cancelRemarks == null || cancelRemarks.trim().length() == 0)
{
errString = checkNull(itmDbAcess.getErrorString("", "VTPAYALC21",userId, "", conn));//Already Cancelled
}
else
{
sql = "UPDATE PAY_STRU_CHG_REQ_HDR SET REQ_STATUS = 'C', WF_STATUS = 'R', STATUS_DATE = trunc(FN_SYSDATE()) where TRAN_ID = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,Tranid);
cnt = pstmt.executeUpdate();
System.out.println("CNT1111...." +cnt);
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(cnt != 1)
{
errString = checkNull(itmDbAcess.getErrorString("", "VTPAYALC20", userId, "", conn));
}
System.out.println("Head Allocation Rejection mail send successfully >> "+MailCnt);
}
}
}
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 e1)
{
e1.printStackTrace();
throw new ITMException(e1);
}
}
System.out.println("errString inside postLogic(String Tranid,String xtraParams,String forcedFlag,Connection conn) of PayStruChgReqReject-->"+errString);
return errString;
}
private String checkNull(String input)
{
if (input == null)
{
input = "";
}
else
{
input = input.trim();
}
return input;
}
}
webitm-adm/src/ibase/webitm/ejb/adm/adv/PayStruChgReqRejectLocal.java 0 → 100644
View file @ 1c9be8c5
package ibase.webitm.ejb.adm.adv;
import javax.ejb.Local;
import ibase.webitm.ejb.ActionHandlerLocal;
@Local
public interface PayStruChgReqRejectLocal extends ActionHandlerLocal
{
public String actionHandler(String tranId, String xtraParams, String forcedFlag);
}
webitm-adm/src/ibase/webitm/ejb/adm/adv/PayStruChgReqRejectRemote.java 0 → 100644
View file @ 1c9be8c5
package ibase.webitm.ejb.adm.adv;
import javax.ejb.Remote;
import ibase.webitm.ejb.ActionHandlerRemote;
@Remote
public interface PayStruChgReqRejectRemote extends ActionHandlerRemote
{
public String actionHandler(String tranId, String xtraParams, String forcedFlag);
}
webitm-adm/src/ibase/webitm/ejb/adm/adv/PayStruChgReqSubmit.java
View file @ 1c9be8c5
......@@ -20,6 +20,8 @@ import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.ejb.adm.AdmCommon;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.adm.adv.PayStruChgReqConfirm;
import ibase.webitm.ejb.adm.adv.PayStruChgReqReject;
@Stateless
public class PayStruChgReqSubmit extends ValidatorEJB implements PayStruChgReqSubmitLocal,PayStruChgReqSubmitRemote
......@@ -37,6 +39,7 @@ public class PayStruChgReqSubmit extends ValidatorEJB implements PayStruChgReqSu
//String workSite = "";
String empCodeHr = "";
String loginEmpCode = "";
String empCode = "";
String deptCode = "";
String siteCode = "";
String finEntity = "";
......@@ -50,15 +53,33 @@ public class PayStruChgReqSubmit extends ValidatorEJB implements PayStruChgReqSu
ArrayList<String> empList = new ArrayList();
int cnt = 0 , MailCnt = 0;
boolean isMailSend = false;
Document dom = null;
String objName = "";
String cancelRemarks = "";
String hrAction = "";
try
{
System.out.println(":::Inside PayStruChgReqSubmit : postLogic():::");
// userId = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode"));
userId = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode"));
userId = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode"));
loginEmpCode = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode"));
if(xmlString != null && xmlString.trim().length()!=0)
{
dom = genericUtility.parseString(xmlString);
empCode = checkNull( genericUtility.getColumnValue("emp_code",dom) ) ;
objName = checkNull( getObjNameFromDom(dom,"objName",1));
}
if (objName != null && (objName.equalsIgnoreCase("pay_stru_chg_req_hr") || objName.equalsIgnoreCase("pay_stru_chg_req_hr_wiz")))
{
errString = performHrAction(dom, Tranid, forcedFlag, xtraParams, conn);
return errString;
}
if (empCode == null || empCode.trim().length() == 0)
{
empCode = loginEmpCode;
}
System.out.println("Login Emp Code::"+userId);
loginEmpCode=userId;
//workSite = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode"));
sql = "UPDATE PAY_STRU_CHG_REQ_HDR SET WF_STATUS = 'S' where TRAN_ID = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,Tranid);
......@@ -72,7 +93,7 @@ public class PayStruChgReqSubmit extends ValidatorEJB implements PayStruChgReqSu
//mail
sql = "SELECT EMAIL_ID_OFF FROM EMPLOYEE WHERE EMP_CODE = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, loginEmpCode);
pstmt.setString(1, empCode);
rs = pstmt.executeQuery();
if(rs.next())
{
......@@ -86,9 +107,10 @@ public class PayStruChgReqSubmit extends ValidatorEJB implements PayStruChgReqSu
rs = null;
}
pstmt.clearParameters();
String mailToAddress = "";
if(cnt>0)
{
empList=getHREmpCode(loginEmpCode, conn);
empList=getHREmpCode(empCode, conn);
System.out.println("empList getting is ::::" +empList.toString());
System.out.println("length of empList::::" +empList.toString().length());
if( empList.size() > 0 )
......@@ -98,13 +120,13 @@ public class PayStruChgReqSubmit extends ValidatorEJB implements PayStruChgReqSu
{
empCodeHr = empList.get(i).toString();
System.out.println("EMPCODE FROM EMPLIST...."+empCodeHr);
email = "";
pstmt.setString(1, empCodeHr);
rs = pstmt.executeQuery();
if(rs.next())
{
email = rs.getString("EMAIL_ID_OFF");
email = checkNull(rs.getString("EMAIL_ID_OFF"));
System.out.println("email generated from mailList:::::::" +email);
}
/**calling send mail method*/
......@@ -114,11 +136,35 @@ public class PayStruChgReqSubmit extends ValidatorEJB implements PayStruChgReqSu
rs = null;
}
pstmt.clearParameters();
isMailSend = sendMail(xmlString, "PYALOC","pay_stru_chg_req_wiz",Tranid,"PYALCHRAPR", "E", empCodeHr,email,employeeMail, conn);
if(isMailSend)
if (email != null && email.trim().length() > 0)
{
MailCnt++;
System.out.println("Mail send successfully >> "+MailCnt);
if (mailToAddress == null || mailToAddress.trim().length() == 0)
{
mailToAddress = email.trim();
}
else
{
mailToAddress = mailToAddress + "," + email.trim();
}
}
}
if (mailToAddress != null && mailToAddress.trim().length() > 0)
{
try
{
//isMailSend = sendMail(xmlString, "PYALOC","pay_stru_chg_req_wiz",Tranid,"PYALCHRAPR", "E", empCodeHr,email,employeeMail, conn);
isMailSend = sendMail(xmlString, "PYALOC","pay_stru_chg_req_wiz",Tranid,"PYALCHRAPR", "E", empCodeHr,mailToAddress,"", conn);
if(isMailSend)
{
MailCnt++;
System.out.println("Mail send successfully >> "+MailCnt);
}
}
catch (Exception expSendMail)
{
expSendMail.printStackTrace();
System.out.println("Exception in Mail send >> " + expSendMail.getMessage());
}
}
}
......@@ -147,10 +193,6 @@ public class PayStruChgReqSubmit extends ValidatorEJB implements PayStruChgReqSu
pstmt.close();
pstmt = null;
}
if(isMailSend)
{
conn.commit();
}
} catch (SQLException e) {
e.printStackTrace();
}
......@@ -188,13 +230,14 @@ public class PayStruChgReqSubmit extends ValidatorEJB implements PayStruChgReqSu
valueXmlString.append("<LINK_ADDR>").append("<![CDATA[" + "" + "]]>").append("</LINK_ADDR>");
valueXmlString.append("</MAIL>");
valueXmlString.append("<XML_DATA>").append(transInfo).append("</XML_DATA>");
valueXmlString.append("<EMAIL_TYPE>").append("<![CDATA[" + "link" + "]]>").append("</EMAIL_TYPE>");
//valueXmlString.append("<EMAIL_TYPE>").append("<![CDATA[" + "link" + "]]>").append("</EMAIL_TYPE>");
valueXmlString.append("<EMAIL_TYPE>").append("<![CDATA[" + "page" + "]]>").append("</EMAIL_TYPE>");
valueXmlString.append("</ROOT>");
String mailDomStr = valueXmlString.toString();
System.out.println(" [PayStruChgReqSubmit] :sendMail mailDomStr :-->" + mailDomStr);
EMail email = new EMail();
email.sendMail(mailDomStr, "ITM", conn);
email.sendMail(mailDomStr, "ITM");
System.out.println("PayStruChgReqSubmit mail delivered successfully" );
emailFlag = true;
}
......@@ -294,4 +337,86 @@ public class PayStruChgReqSubmit extends ValidatorEJB implements PayStruChgReqSu
return empCodeList;
}
private String getObjNameFromDom( Document dom, String attribute , int currFormNo) throws ITMException
{
String objName = "";
try
{
NodeList detailList = null;
Node currDetail = null,reqDetail = null;
int detailListLength = 0;
detailList = dom.getElementsByTagName("Detail" + currFormNo);
detailListLength = detailList.getLength();
for (int ctr = 0;ctr < detailListLength;ctr++)
{
currDetail = detailList.item(ctr);
objName = currDetail.getAttributes().getNamedItem(attribute).getNodeValue();
System.out.println("objNameobjName>>>::asjhdg::["+objName+"]");
break;
}
if(objName == null || objName.trim().length() == 0)
{
NodeList objNameList = dom.getElementsByTagName("objName");
if(objNameList != null && objNameList.getLength() > 0)
{
Node objNameNode = objNameList.item(0);
if(objNameNode != null && objNameNode.getFirstChild() != null)
{
objName = checkNull(objNameNode.getFirstChild().getNodeValue());
System.out.println("objNameobjName>>> in anothere if null ::asjhdg::["+objName+"]");
}
}
}
}
catch(Exception e)
{
e.printStackTrace();
}
return objName;
}
private String performHrAction(Document dom, String Tranid, String forcedFlag, String xtraParams, Connection conn) throws ITMException
{
String cancelRemarks = "";
String hrAction = "";
String empCode = "";
String returnString = "";
PayStruChgReqConfirm payStruChgReqConfirm = new PayStruChgReqConfirm();
PayStruChgReqReject payStruChgReqReject = new PayStruChgReqReject();
try
{
empCode = checkNull( genericUtility.getColumnValue("emp_code",dom) ) ;
hrAction = checkNull( genericUtility.getColumnValue("hr_action",dom) ) ;
cancelRemarks = checkNull( genericUtility.getColumnValue("cancel_remarks",dom) ) ;
if (hrAction.trim().equalsIgnoreCase("P"))
{
return "";
}
else if (hrAction.trim().equalsIgnoreCase("A"))
{
returnString = payStruChgReqConfirm.confirm(Tranid, forcedFlag, xtraParams, conn);
}
else if (hrAction.trim().equalsIgnoreCase("R"))
{
returnString = payStruChgReqReject.actionHandler(Tranid, forcedFlag, xtraParams, conn);
}
else if (hrAction.trim().equalsIgnoreCase("C"))
{
returnString = payStruChgReqReject.actionHandler(Tranid, forcedFlag, xtraParams, conn);
}
}
catch (Exception e)
{
System.out.println("Exception :PayStruChgReqSubmit :performHrAction():" + e.getMessage() + ":");
returnString = new E12GenericUtility().createErrorString(e);
e.printStackTrace();
throw new ITMException(e);
}
finally
{
}
return returnString;
}
}
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