Skip to content

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

Sarita: Source code EmpITConfirmationIC on 25 SEPT 2018 

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@191154 ce508802-f39f-4f6c-b175-0d175dae99d5
parent aac8fc0b
Show whitespace changes
Inline Side-by-side
Showing with 519 additions and 0 deletions
webitm-adm/ibase/webitm/ejb/adm/EmpITConfirmationIC.java 0 → 100644
View file @ bc80eccc
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.text.SimpleDateFormat;
import javax.ejb.Stateless;
import org.w3c.dom.Document;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.utility.ITMException;
//import com.sun.org.apache.xalan.internal.xsltc.compiler.Pattern;
@Stateless
public class EmpITConfirmationIC extends ValidatorEJB implements EmpITConfirmationICLocal,EmpITConfirmationICRemote
{
ibase.utility.E12GenericUtility genericUtility= new ibase.utility.E12GenericUtility();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
public String itemChanged(String xmlString, String xmlString1, String xmlString2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException, ITMException
{
Document dom = null;
Document domhr = null;
Document domAll = null;
String retString = "";
try
{
System.out.println("************** Inside itemChanged method ****************");
if (xmlString != null && xmlString.trim().length() > 0)
{
dom = genericUtility.parseString(xmlString);
}
if (xmlString1 != null && xmlString1.trim().length() > 0)
{
domhr = genericUtility.parseString(xmlString1);
}
if (xmlString2 != null && xmlString2.trim().length() > 0)
{
domAll = genericUtility.parseString(xmlString2);
}
retString = itemChanged(dom, domhr, domAll, objContext, currentColumn, editFlag, xtraParams);
System.out.println("retString for EmpITConfPrc::" + retString);
}
catch (Exception e)
{
System.out.println(":::" + getClass().getSimpleName() + "::" + e.getMessage());
e.getMessage();
}
return retString;
}//End of itemchange[1]
public String itemChanged(Document dom, Document dom1, Document dom2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException, ITMException
{
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
int currentFormNo = 0;
StringBuffer valueXmlString = new StringBuffer();
SimpleDateFormat sdf1 = null;
java.sql.Timestamp currentDate = null,today = null;
String sql = "",prdcode = "", prdDescr = "",userId = "",siteDescr = "",lsProtectyn = "",accountPrd = "",actPerdDescr = "",loginSite = "";
String empCodeFr = "00" , empCodeTo = "ZZ";
AdmCommon objAdmCommon = new AdmCommon();
String empcodefr = "", empFirstName = "", empLastName = "",empName = "",empcodeTo = "";
int userLev = 0;
String type = "", prdCode = "",siteCodeFr = "",siteDescrFr = "",siteCodeTo = "",siteDescrTo = "",procGroupFrom = "",procGroupFrName = "";
NodeList parentNodeList = null;
NodeList childNodeList = null;
Node parentNode = null;
Node childNode = null;
String childNodeName = "",columnValue="";
int childNodeListLength = 0,ctr=0,totalEmpNo=0;
try
{
conn = getConnection();
today = new java.sql.Timestamp(System.currentTimeMillis()) ;
sdf1 = new SimpleDateFormat(genericUtility.getDBDateFormat());
currentDate = java.sql.Timestamp.valueOf(sdf1.format(today) + " 00:00:00.000");
userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode");
loginSite = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode");
System.out.println("currentDate is ["+currentDate+"] \t userId is ["+userId+"]");
if (objContext != null && objContext.trim().length() > 0)
{
currentFormNo = Integer.parseInt(objContext);
}
System.out.println("[EmpITConfirmationIC] [itemChanged] :currentFormNo ["+currentFormNo+"] \t Current Column ["+currentColumn+"]" );
valueXmlString = new StringBuffer("<?xml version=\"1.0\"?><Root><header><editFlag>");
valueXmlString.append(editFlag).append("</editFlag></header>");
switch (currentFormNo)
{
case 1:
{
parentNodeList = dom.getElementsByTagName("Detail1");
parentNode = parentNodeList.item(0);
childNodeList = parentNode.getChildNodes();
valueXmlString.append("<Detail1>");
ctr = 0;
childNodeListLength = childNodeList.getLength();
do
{
childNode = childNodeList.item(ctr);
childNodeName = childNode.getNodeName();
if(childNodeName.equals(currentColumn))
{
if(childNode.getFirstChild() != null)
{
}
}
ctr ++;
}while(ctr < childNodeListLength && ! childNodeName.equals(currentColumn));
if ("itm_default".equalsIgnoreCase(currentColumn))
{
sql = "select usr_lev from users where code = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, userId);
rs = pstmt.executeQuery();
if (rs.next())
{
userLev = rs.getInt("usr_lev"); System.out.println("User Level is ["+userLev+"]");
}
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
sql = "select code , descr from acctprd where ? between fr_date and to_date";
pstmt = conn.prepareStatement(sql);
pstmt.setTimestamp(1, currentDate);
rs = pstmt.executeQuery();
if (rs.next())
{
prdcode = rs.getString("code");
prdDescr = rs.getString("descr");
System.out.println("prdcode is ["+prdcode+"] \t prdDescr ["+prdDescr+"]");
}
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
valueXmlString.append("<acct_prd>").append("<![CDATA[" + prdcode + "]]>").append("</acct_prd>");
valueXmlString.append("<fr_prd_descr>").append("<![CDATA[" + prdDescr + "]]>").append("</fr_prd_descr>");
valueXmlString.append("<emp_code__fr>").append("<![CDATA[" + empCodeFr + "]]>").append("</emp_code__fr>");
valueXmlString.append("<emp_code__to>").append("<![CDATA[" + empCodeTo + "]]>").append("</emp_code__to>");
if(loginSite != null && loginSite.trim().length() > 0)
{
sql = "select descr from site where site_code = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, loginSite);
rs = pstmt.executeQuery();
if (rs.next())
{
siteDescr = rs.getString("descr");
}
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
valueXmlString.append("<site_code__fr>").append("<![CDATA[" + loginSite + "]]>").append("</site_code__fr>");
valueXmlString.append("<site_code__to>").append("<![CDATA[" + loginSite + "]]>").append("</site_code__to>");
valueXmlString.append("<fr_site_descr>").append("<![CDATA[" + siteDescr + "]]>").append("</fr_site_descr>");
valueXmlString.append("<to_site_descr>").append("<![CDATA[" + siteDescr + "]]>").append("</to_site_descr>");
}//end of if for loginSite
valueXmlString.append("<proc_group__from>").append("<![CDATA[" + empCodeFr + "]]>").append("</proc_group__from>");
valueXmlString.append("<proc_group__to>").append("<![CDATA[" + empCodeTo + "]]>").append("</proc_group__to>");
lsProtectyn = objAdmCommon.getEnv("999999", "HRSITEPROTECTYN", conn);
if(lsProtectyn == null || lsProtectyn.trim().length() == 0)
{
lsProtectyn = "N";
}
else if((lsProtectyn != null && lsProtectyn.trim().length() > 0) && (userLev > 0))
{
valueXmlString.append("<site_code__fr protect='1'>").append("<![CDATA[]]>").append("</site_code__fr>");
valueXmlString.append("<site_code__to protect='1'>").append("<![CDATA[]]>").append("</site_code__to>");
}
}//end of itemchange for itm_default
else if("acct_prd".equalsIgnoreCase(currentColumn))
{
accountPrd = checkNullAndTrim(genericUtility.getColumnValue("acct_prd", dom));
sql = "select descr from ACCTPRD where code = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, accountPrd);
rs = pstmt.executeQuery();
if (rs.next())
{
actPerdDescr = rs.getString("descr");
}
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
valueXmlString.append("<fr_prd_descr>").append("<![CDATA[" + actPerdDescr + "]]>").append("</fr_prd_descr>");
}//end of itemchange for acct_prd
else if("emp_code__fr".equalsIgnoreCase(currentColumn))
{
empcodefr = checkNullAndTrim(genericUtility.getColumnValue("emp_code__fr", dom));
sql = "select emp_fname, emp_lname from employee where emp_code = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, empcodefr);
rs = pstmt.executeQuery();
if (rs.next())
{
empFirstName = rs.getString("emp_fname");
empLastName = rs.getString("emp_lname");
}
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
empName = empFirstName + " " + empLastName;
valueXmlString.append("<emp_name__fr>").append("<![CDATA[" + empName + "]]>").append("</emp_name__fr>");
}//end of itemchange for emp_code__fr
else if("emp_code__to".equalsIgnoreCase(currentColumn))
{
empcodeTo = checkNullAndTrim(genericUtility.getColumnValue("emp_code__to", dom));
sql = "select emp_fname, emp_lname from employee where emp_code = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, empcodeTo);
rs = pstmt.executeQuery();
if (rs.next())
{
empFirstName = rs.getString("emp_fname");
empLastName = rs.getString("emp_lname");
}
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
empName = empFirstName + " " + empLastName;
valueXmlString.append("<emp_name__to>").append("<![CDATA[" + empName + "]]>").append("</emp_name__to>");
//set Total No. of Employees using emp_code__fr and emp_code__to [START]
empcodefr = checkNullAndTrim(genericUtility.getColumnValue("emp_code__fr", dom));
System.out.println("Value of empcodeTo ["+empcodeTo+"] \t Value of empcodefr ["+empcodefr+"]");
if(empcodefr != null && empcodefr.trim().length() > 0)
{
sql = "select count(*) as cnt from employee where emp_code between ? and ? order by emp_code";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, empcodefr);
pstmt.setString(2, empcodeTo);
rs = pstmt.executeQuery();
if (rs.next())
{
totalEmpNo = rs.getInt("cnt"); System.out.println("Tota No. of Employees are :: ["+totalEmpNo+"]");
}
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
valueXmlString.append("<no_employee>").append("<![CDATA[" + totalEmpNo + "]]>").append("</no_employee>");
}
//set Total No. of Employees using emp_code__fr and emp_code__to [END]
}//end of itemchange for emp_code__to
else if("type".equalsIgnoreCase(currentColumn))
{
type = checkNullAndTrim(genericUtility.getColumnValue("type", dom));
sql = "select prd_code from parameter";
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
if (rs.next())
{
prdCode = rs.getString("prd_code");
}
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(("AR".equalsIgnoreCase(type)) || ("AP".equalsIgnoreCase(type)))
{
valueXmlString.append("<prd_code__arr>").append("<![CDATA[" + prdCode + "]]>").append("</prd_code__arr>");
}
}//end of itemchange for type
else if("site_code__fr".equalsIgnoreCase(currentColumn))
{
siteCodeFr = checkNullAndTrim(genericUtility.getColumnValue("site_code__fr", dom));
sql = "select descr from site where site_code = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, siteCodeFr);
rs = pstmt.executeQuery();
if (rs.next())
{
siteDescrFr = rs.getString("descr");
}
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
valueXmlString.append("<fr_site_descr>").append("<![CDATA[" + siteDescrFr + "]]>").append("</fr_site_descr>");
}//end of itemchange for site_code__fr
else if("site_code__to".equalsIgnoreCase(currentColumn))
{
siteCodeTo = checkNullAndTrim(genericUtility.getColumnValue("site_code__to", dom));
sql = "select descr from site where site_code = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, siteCodeTo);
rs = pstmt.executeQuery();
if (rs.next())
{
siteDescrTo = rs.getString("descr");
}
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
valueXmlString.append("<to_site_descr>").append("<![CDATA[" + siteDescrTo + "]]>").append("</to_site_descr>");
}//end of itemchange for site_code__to
else if("proc_group__from".equalsIgnoreCase(currentColumn))
{
procGroupFrom = checkNullAndTrim(genericUtility.getColumnValue("proc_group__from", dom));
sql = "select descr from gencodes where fld_name='PROC_GROUP' and fld_value = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, procGroupFrom);
rs = pstmt.executeQuery();
if (rs.next())
{
procGroupFrName = rs.getString("descr");
}
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
valueXmlString.append("<proc_group__fr_name>").append("<![CDATA[" + procGroupFrName + "]]>").append("</proc_group__fr_name>");
}//end of itemchange for proc_group__from
else if("proc_group__to".equalsIgnoreCase(currentColumn))
{
String procGroupTo = "";
procGroupTo = checkNullAndTrim(genericUtility.getColumnValue("proc_group__to", dom));
sql = "select descr from gencodes where fld_name='PROC_GROUP' and fld_value = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, procGroupTo);
rs = pstmt.executeQuery();
if (rs.next())
{
procGroupTo = rs.getString("descr");
}
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
valueXmlString.append("<proc_group__to_name>").append("<![CDATA[" + procGroupTo + "]]>").append("</proc_group__to_name>");
}//end of itemchange for proc_group__to
valueXmlString.append ("</Detail1>\r\n");
}
break;
}
valueXmlString.append("</Root>\r\n");
} // end of try block
catch (Exception e)
{
System.out.println(":::" + getClass().getSimpleName() + "::" + e.getMessage());
throw new ITMException(e);
}
finally
{
try
{
if (conn != null)
{
conn.close();
conn = null;
}
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
}
catch (Exception e)
{
System.out.println("Exception in EJB[" + getClass().getSimpleName() + "]::itemChanged::[" + e.getMessage() + "]");
}
}
return valueXmlString.toString();
}//End of itemchange[2]
private String checkNullAndTrim(String input)
{
if (input == null)
{
input = "";
}
else
{
input =input.trim();
}
return input;
}//end of method checkNullAndTrim
}
webitm-adm/ibase/webitm/ejb/adm/EmpITConfirmationICLocal.java 0 → 100644
View file @ bc80eccc
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
import javax.ejb.Local;
import org.w3c.dom.Document;
import ibase.webitm.ejb.ValidatorLocal;
import ibase.webitm.utility.ITMException;
@Local // added for ejb3
public interface EmpITConfirmationICLocal extends ValidatorLocal
{
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;
}
\ No newline at end of file
webitm-adm/ibase/webitm/ejb/adm/EmpITConfirmationICRemote.java 0 → 100644
View file @ bc80eccc
package ibase.webitm.ejb.adm;
import java.rmi.RemoteException;
import javax.ejb.Remote; // added for ejb3
import org.w3c.dom.Document;
import ibase.webitm.ejb.ValidatorRemote;
import ibase.webitm.utility.ITMException;
@Remote // added for ejb3
public interface EmpITConfirmationICRemote extends ValidatorRemote
{
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;
}
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment