Commit 1e85e48f authored by dpawar's avatar dpawar

added Bond recovery java files


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@92319 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 61360648
package ibase.webitm.ejb.adm;
import ibase.system.config.ConnDriver;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException;
import java.util.*;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.text.SimpleDateFormat;
import java.sql.Timestamp;
import org.w3c.dom.Document;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import javax.ejb.Stateless;
@Stateless
public class BondRecovery extends ValidatorEJB implements BondRecoveryLocal, BondRecoveryRemote
{
public String wfValData() throws RemoteException,ITMException
{
return "";
}
public String itemChanged() throws RemoteException,ITMException
{
return "";
}
public String wfValData(String xmlString, String xmlString1,String xmlString2, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException
{
String errString = null;
Document dom = null;
Document dom1 = null;
Document dom2 = null;
NodeList parentNodeList = null;
NodeList childNodeList = null;
Node parentNode = null;
Node childNode = null;
String childNodeName = "";
System.out.println("\n\n xmlString in wfValData \n:" + xmlString + "\n");
System.out.println("\n\n xmlString1 in wfValData \n :" + xmlString1 +"\n");
System.out.println("\n\n xmlString2 in wfValData \n :" + xmlString2 +"\n");
try
{
dom = parseString(xmlString);
dom1 = parseString(xmlString1);
if (xmlString2.trim().length() > 0)
{
dom2 = parseString("<Root>" + xmlString2+ "</Root>");
}
//errString = wfValData(dom,dom1,dom2,objContext,editFlag,xtraParams);
//ADDED FOR INVOIKING VALIDATION IN WORKFLOW
if( objContext != null && Integer.parseInt(objContext) == 1 )
{
parentNodeList = dom2.getElementsByTagName("Header0");
parentNode = parentNodeList.item(1);
childNodeList = parentNode.getChildNodes();
for(int x=0;x<childNodeList.getLength();x++)
{
childNode = childNodeList.item(x);
childNodeName = childNode.getNodeName();
if(childNodeName.equalsIgnoreCase("Detail1"))
{
errString = wfValData(dom,dom1,dom2,"1",editFlag,xtraParams);
if(errString != null && errString.trim().length() > 0)
break;
}
else if(childNodeName.equalsIgnoreCase("Detail2"))
{
errString = wfValData(dom,dom1,dom2,"2",editFlag,xtraParams);
if(errString != null && errString.trim().length() > 0)
break;
}
else if(childNodeName.equalsIgnoreCase("Detail3"))
{
errString = wfValData(dom,dom1,dom2,"3",editFlag,xtraParams);
if(errString != null && errString.trim().length() > 0)
break;
}
}
}
else
{
errString = wfValData(dom,dom1,dom2,objContext,editFlag,xtraParams);
}
}
catch(Exception e)
{
System.out.println("Exception : ChangecontrolEJB : wfValData(String xmlString) : ==>\n"+e.getMessage());
}
return (errString);
}
public String wfValData(Document dom, Document dom1, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException
{
return "";
}
public String wfValData(String xmlString, String xmlString1,String xmlString2, String objContext, String editFlag) throws RemoteException,ITMException
{
return "";
}
public String itemChanged(Document dom, Document dom1,String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException
{
return "";
}
public String itemChanged(String xmlString, String xmlString1,String xmlString2, String objContext, String currentColumn, String editFlag) throws RemoteException,ITMException
{
return "";
}
public String wfValData(Document dom, Document dom1,Document dom2, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException
{
System.out.println("in wfValData........");
NodeList parentNodeList = null;
NodeList childNodeList = null;
Node parentNode = null;
Node childNode = null;
int ctr = 0,cnt = 0;
String childNodeName = null;
String errString = "";
String errCode = "";
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
String sql = "";
String userId = "";
int currentFormNo=0;
int childNodeListLength;
String empCode="",siteCode = "",recAmtAct="";
GenericUtility genericUtility = GenericUtility.getInstance();
try
{
System.out.println("in try.....");
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
connDriver = null;
userId = getValueFromXTRA_PARAMS(xtraParams,"loginCode");
//ccStatus=genericUtility.getColumnValue("status",dom);
if(objContext != null && objContext.trim().length() > 0)
{
currentFormNo = Integer.parseInt(objContext);
}
switch(currentFormNo)
{
case 1 :
parentNodeList = dom.getElementsByTagName("Detail1");
parentNode = parentNodeList.item(0);
childNodeList = parentNode.getChildNodes();
childNodeListLength = childNodeList.getLength();
for(ctr = 0; ctr < childNodeListLength; ctr++)
{
childNode = childNodeList.item(ctr);
childNodeName = childNode.getNodeName();
if (childNodeName.equalsIgnoreCase("emp_code"))
{
empCode = genericUtility.getColumnValue("emp_code",dom);
System.out.println(" eMP CODE -->>"+empCode);
if (empCode == null || empCode.trim().length() == 0 )
{
errCode = "VNULEMPC";
errString = getErrorString("emp_code",errCode,userId);
System.out.println("in message error code 1....");
break;
}
else
{
sql = "select count(1) from employee where emp_code = ?";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,empCode);
rs = pstmt.executeQuery();
if(rs.next())
{
cnt = rs.getInt(1);
}
pstmt.close();
rs.close();
pstmt = null;
rs = null;
if(cnt == 0)
{
errCode = "VMEMPCD1";
errString = getErrorString("emp_code",errCode,userId);
break;
}
}
}
else if (childNodeName.equalsIgnoreCase("site_code"))
{
siteCode = genericUtility.getColumnValue("site_code",dom);
if (siteCode == null || siteCode.trim().length() == 0 )
{
errCode = "VMSITENULL";
errString = getErrorString("site_code",errCode,userId);
break;
}
else
{
sql = "select count(1) from site where site_code = ? ";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,siteCode);
rs = pstmt.executeQuery();
if(rs.next())
{
cnt = rs.getInt(1);
}
pstmt.close();
rs.close();
pstmt = null;
rs = null;
if(cnt == 0)
{
errCode = "VMSITENVAL";
errString = getErrorString("site_code",errCode,userId);
break;
}
}
}
else if (childNodeName.equalsIgnoreCase("recovery_amt__act"))
{
recAmtAct = genericUtility.getColumnValue("recovery_amt__act",dom);
String recAmtDue = genericUtility.getColumnValue("amt__due",dom);
System.out.println("Actual amt :"+recAmtAct+" recAmtDue :"+recAmtDue);
if (recAmtAct == null || recAmtAct.trim().length() == 0 )
{
errCode = "VBACTAMT";
errString = getErrorString("recovery_amt__act",errCode,userId);
break;
}
double recAmountAct=0.0,recAmountDue=0.0;
if( recAmtDue !=null || recAmtDue.trim().length() == 0 )
{
recAmountAct=Double.parseDouble(recAmtAct);
recAmountDue=Double.parseDouble(recAmtDue);
if (recAmountAct > recAmountDue)
{
errCode="RECAMTNUL";
errString = getErrorString("amt__due",errCode,userId);
break;
}
}
}
}// for loop end
} //end switch
}//end try
catch(Exception e)
{
e.printStackTrace();
errString = e.getMessage();
}
finally
{
try
{
if(conn!=null)
{
conn.close();
conn = null;
}
if(pstmt != null )
{
pstmt.close();
pstmt = null;
}
if(rs != null )
{
rs.close();
rs = null;
}
}
catch(Exception d)
{
d.printStackTrace();
}
}
return errString;
}
public String itemChanged(String xmlString, String xmlString1,String xmlString2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException
{
System.out.println("in item changed");
Document dom = null;
Document dom1 = null;
Document dom2 = null;
String valueXmlString = "";
//System.out.println("\n\n xmlString in ItemChanged \n:" + xmlString + "\n");
//System.out.println("\n\n xmlString1 In ItemChanged \n :" + xmlString1 +"\n");
try
{
dom = parseString(xmlString);
dom1 = parseString(xmlString1);
if (xmlString2.trim().length() > 0 )
{
dom2 = parseString(xmlString2);
}
valueXmlString = itemChanged(dom,dom1,dom2,objContext,currentColumn,editFlag,xtraParams);
}
catch(Exception e)
{
System.out.println("Exception : [ChangeControlEJB][itemChanged(String,String)] :==>\n"+e.getMessage());
}
return valueXmlString;
}
public String itemChanged(Document dom, Document dom1,Document dom2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException
{
System.out.println("in item changed.......");
StringBuffer valueXmlString = new StringBuffer();
NodeList parentNodeList = null;
NodeList childNodeList = null;
Node parentNode = null;
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null ;
int currentFormNo = 0;
String deptCode="", empCode="";
String deptDescr = "",dateRelieve="",dateJoin="";
String sql = "",descr = "",empfname = "", empmname = "", emplname = "";
ConnDriver connDriver = new ConnDriver();
String acct_code="", cctr_code="";
int bondPrd=0;
double bondAmt=0.0,bondAmtDone=0.0,bondAmtDue=0.0;
String tranDate="",loginEmpCode="";
String [] datearrayJ=new String[3];
String [] datearrayR=new String[3];
String splitdateJ="",splitmonthJ="",splityearJ="",splitdateR="",splitmonthR="",splityearR="";
Timestamp timestampDateJ = null,timestampDateR=null;
try
{
GenericUtility genericUtility = GenericUtility.getInstance();
SimpleDateFormat simpleDateFormat = new SimpleDateFormat(genericUtility.getApplDateFormat());
Timestamp timestamp = new Timestamp(System.currentTimeMillis());
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
connDriver=null;
if(objContext != null && objContext.trim().length()>0)
{
currentFormNo = Integer.parseInt(objContext);
}
valueXmlString = new StringBuffer("<?xml version=\"1.0\"?><Root><header><editFlag>");
valueXmlString.append(editFlag).append("</editFlag></header>");
switch(currentFormNo)
{
case 1 :
valueXmlString.append("<Detail1>");
parentNodeList = dom.getElementsByTagName("Detail1");
parentNode = parentNodeList.item(0);
childNodeList = parentNode.getChildNodes();
if(currentColumn.trim().equalsIgnoreCase("itm_default"))
{
System.out.println("in itm changed.....");
String confirmed="N";
tranDate = simpleDateFormat.format(timestamp).toString();
System.out.println("Tran Date 111: "+tranDate.toString());
valueXmlString.append("<tran_date>").append("<![CDATA["+tranDate.trim()+"]]>").append("</tran_date>");
valueXmlString.append("<confirmed>").append("<![CDATA["+confirmed+"]]>").append("</confirmed>");
}//end item_default
else if(currentColumn.trim().equalsIgnoreCase("site_code"))
{
System.out.println("site code change...");
String siteCode =genericUtility.getColumnValue("site_code",dom);
sql = "SELECT DESCR FROM SITE WHERE SITE_CODE = ? ";
pstmt= conn.prepareStatement(sql);
pstmt.setString(1,siteCode);
rs = pstmt.executeQuery();
while(rs.next())
{
descr = rs.getString(1) == null ? "" : rs.getString(1);
}
pstmt.close();
rs.close();
pstmt = null;
rs = null;
valueXmlString.append("<site_descr>").append("<![CDATA["+descr.trim()+"]]>").append("</site_descr>");
}
else if(currentColumn.trim().equalsIgnoreCase("emp_code"))
{
System.out.println("IN EMP CODE OF ITEM CHANGE");
empCode = genericUtility.getColumnValue("emp_code",dom);
System.out.println("Employee Code in item change ---->>>"+empCode);
sql = " Select e.emp_fname,e.emp_mname,e.emp_lname,e.dept_code,d.descr,e.acct_code__sal,e.CCTR_CODE__SAL,e.date_join,e.RELIEVE_DATE,e.BOND_AMT__RECO from "+
" employee e,department d "+
" where e.dept_code = d.dept_code and e.emp_code = ? ";
pstmt= conn.prepareStatement(sql);
pstmt.setString(1,empCode);
rs = pstmt.executeQuery();
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
while(rs.next())
{
empfname = rs.getString(1) == null ? "" : rs.getString(1);
empmname = rs.getString(2) == null ? "" : rs.getString(2);
emplname = rs.getString(3) == null ? "" : rs.getString(3);
deptCode = rs.getString(4) == null ? "" : rs.getString(4);
descr = rs.getString(5) == null ? "" : rs.getString(5);
acct_code = rs.getString(6) == null ? getAcctCodeFromDept(conn,pstmt,rs,empCode) : rs.getString(6);
cctr_code = rs.getString(7) == null ? getCctrCodeFromDept(conn,pstmt,rs,empCode) : rs.getString(7);
timestampDateJ = rs.getTimestamp(8);
timestampDateR = rs.getTimestamp(9);
//bondAmtDone=rs.getDouble(10);
if(timestampDateJ != null) dateJoin = sdf.format(timestampDateJ).toString();
if(timestampDateR != null) dateRelieve = sdf.format(timestampDateR).toString();
valueXmlString.append("<emp_fname>").append("<![CDATA["+empfname+"]]>").append("</emp_fname>");
valueXmlString.append("<emp_mname>").append("<![CDATA["+empmname+"]]>").append("</emp_mname>");
valueXmlString.append("<emp_lname>").append("<![CDATA["+emplname+"]]>").append("</emp_lname>");
valueXmlString.append("<dept_code>").append("<![CDATA["+deptCode+"]]>").append("</dept_code>");
valueXmlString.append("<department_descr>").append("<![CDATA["+descr+"]]>").append("</department_descr>");
valueXmlString.append("<acct_code__bond>").append("<![CDATA["+acct_code+"]]>").append("</acct_code__bond>");
valueXmlString.append("<cctr_code__bond>").append("<![CDATA["+cctr_code+"]]>").append("</cctr_code__bond>");
valueXmlString.append("<date_join>").append("<![CDATA["+dateJoin+"]]>").append("</date_join>");
valueXmlString.append("<relieve_date>").append("<![CDATA["+dateRelieve+"]]>").append("</relieve_date>");
System.out.println("First Name :"+empfname+" Middle Name :"+empmname+" Last Name :"+emplname);
System.out.println("Dept code :"+deptCode+" descr : "+descr);
System.out.println("in item change---->>>>acct_code111 : "+acct_code+" cctr_code :"+cctr_code+" Date Join :"+dateJoin+" Relieve Date : "+dateRelieve);
}
pstmt.close();
rs.close();
pstmt = null;
rs = null;
//*********************************************************************************************
if (dateRelieve !=null && dateJoin !=null&& dateRelieve.length()>0 && dateJoin.length()>0)
{
StringTokenizer st = new StringTokenizer(dateJoin, "/");
StringTokenizer st1 = new StringTokenizer(dateRelieve, "/");
int i=0;
while (st.hasMoreElements())
{
datearrayJ[i]=st.nextToken();
i++;
}
i=0;
splitdateJ=datearrayJ[0];
splitmonthJ=datearrayJ[1];
int join=Integer.parseInt(datearrayJ[2]);
if (join>=80 && join<=99)
splityearJ="19"+datearrayJ[2];
else
splityearJ="20"+datearrayJ[2];
System.out.println("splitdate :--> "+splitdateJ+" splitmonth :--> "+splitmonthJ+" splityear :--> "+splityearJ);
while (st1.hasMoreElements())
{
datearrayR[i]=st1.nextToken();
i++;
}
i=0;
splitdateR=datearrayR[0];
splitmonthR=datearrayR[1];
int relieve=Integer.parseInt(datearrayR[2]);
if (relieve>=80 && relieve<=99)
splityearR="19"+datearrayR[2];
else
splityearR="20"+datearrayR[2];
System.out.println("splitdate :--> "+splitdateR+" splitmonth :--> "+splitmonthR+" splityear :--> "+splityearR);
Calendar dateJ = new GregorianCalendar(Integer.parseInt(splityearR), Integer.parseInt(splitmonthR), Integer.parseInt(splitdateR));
Calendar dateR = new GregorianCalendar(Integer.parseInt(splityearJ),Integer.parseInt(splitmonthJ), Integer.parseInt(splitdateJ));
int monthsBetween = (int) monthsBetween(dateJ, dateR);
System.out.println("Difference between months ------->>>>"+monthsBetween);
sql="select BOND_AMT,BOND_PRD from EMPLOYEE_BOND WHERE EMP_CODE = ? and BOND_PRD >= ?";
pstmt= conn.prepareStatement(sql);
pstmt.setString(1,empCode);
pstmt.setInt(2,monthsBetween);
rs = pstmt.executeQuery();
if(rs.next())
{
bondAmt = rs.getDouble(1);
bondPrd = rs.getInt(2);
valueXmlString.append("<bond_amt>").append("<![CDATA["+bondAmt+"]]>").append("</bond_amt>");
valueXmlString.append("<bond_prd>").append("<![CDATA["+bondPrd+"]]>").append("</bond_prd>");
System.out.println("------>>> BOND AMT : "+bondAmt+" Bond Period : "+bondPrd);
}
pstmt.close();
rs.close();
pstmt = null;
rs = null;
sql="select BOND_AMT__RECO from EMPLOYEE where emp_code = ?";
pstmt= conn.prepareStatement(sql);
pstmt.setString(1,empCode);
rs = pstmt.executeQuery();
while(rs.next())
{
bondAmtDue= bondAmtDue+rs.getDouble(1);
}
System.out.println("After while bond amt due------->>>>"+bondAmtDue);
bondAmtDone=bondAmtDue;
bondAmtDue=bondAmt-bondAmtDue;
valueXmlString.append("<amt__due>").append("<![CDATA["+bondAmtDue+"]]>").append("</amt__due>");
valueXmlString.append("<recovery_amt__done>").append("<![CDATA["+bondAmtDone+"]]>").append("</recovery_amt__done>");
}
pstmt.close();
rs.close();
pstmt = null;
rs = null;
}
valueXmlString.append("</Detail1>");
break;
}// end switch
valueXmlString.append("</Root>");
}
catch(Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if(conn!=null)
{
conn.close();
conn = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(rs != null)
{
rs.close();
rs = null;
}
}
catch(Exception d)
{
d.printStackTrace();
}
}
System.out.println("Return xml ---->>>>"+valueXmlString.toString());
return valueXmlString.toString();
}
public String getAcctCodeFromDept(Connection conn,PreparedStatement pstmt,ResultSet rs,String loginEmpCode)
{
String acct_code="";
try
{
String sql1 = "SELECT D.ACCT_CODE,E.EMP_CODE FROM EMPLOYEE E,DEPARTMENT D WHERE E.DEPT_CODE=D.DEPT_CODE AND E.EMP_CODE=?";
pstmt = conn.prepareStatement(sql1);
pstmt.setString(1,loginEmpCode);
rs = pstmt.executeQuery();
if(rs.next())
{
acct_code = rs.getString(1) ;
}
}
catch(Exception e)
{
e.printStackTrace();
}
return acct_code;
}
public String getCctrCodeFromDept(Connection conn,PreparedStatement pstmt,ResultSet rs,String loginEmpCode)
{
String cctr_code="";
try
{
String sql1 = "SELECT D.CCTR_CODE,E.EMP_CODE FROM EMPLOYEE E,DEPARTMENT D WHERE E.DEPT_CODE=D.DEPT_CODE AND E.EMP_CODE=?";
pstmt = conn.prepareStatement(sql1);
pstmt.setString(1,loginEmpCode);
rs = pstmt.executeQuery();
if(rs.next())
{
cctr_code = rs.getString(1) ;
}
}
catch(Exception e)
{
e.printStackTrace();
}
return cctr_code;
}
public static double monthsBetween(Calendar date1, Calendar date2)
{
//new GregorianCalendar(yyyy, mm, dd) here month 0 is for January
double monthsBetween = 0;
//difference in month for years
monthsBetween = (date1.get(Calendar.YEAR)-date2.get(Calendar.YEAR))*12;
//difference in month for months
monthsBetween += date1.get(Calendar.MONTH)-date2.get(Calendar.MONTH);
//difference in month for days
if(date1.get(Calendar.DAY_OF_MONTH)!=date1.getActualMaximum(Calendar.DAY_OF_MONTH)
&& date1.get(Calendar.DAY_OF_MONTH)!=date1.getActualMaximum(Calendar.DAY_OF_MONTH) ){
monthsBetween += ((date1.get(Calendar.DAY_OF_MONTH)-date2.get(Calendar.DAY_OF_MONTH))/31d);
}
return monthsBetween;
}
/*public int getBondPeriod(Connection conn,PreparedStatement pstmt,ResultSet rs,String EmpCode,int monthsBetween)
{
ArrayList<Integer> bondprdList=new ArrayList<Integer>();
try
{
String sql1 = "SELECT bond_prd where emp_code= ?";
pstmt = conn.prepareStatement(sql1);
pstmt.setString(1,EmpCode);
rs = pstmt.executeQuery();
if(rs.next())
{
bondprdList.add(rs.getInt(1));
}
System.out.println("in Bond list --->> :"+bondprdList);
Iterator itr = bondprdList.iterator();
while(itr.hasNext())
{
int i=Integer.parseInt(itr.next().toString());
if (i==monthsBetween)
return i;
}
}
catch(Exception e)
{
e.printStackTrace();
}
//return bondprdList;
}*/
}
package ibase.webitm.ejb.adm;
import ibase.webitm.ejb.dis.DistCommon;
import java.rmi.RemoteException;
import org.w3c.dom.*;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.ITMException;
import javax.ejb.Local;
public interface BondRecoveryLocal extends ValidatorLocal {
public String wfValData(String xmlString, String xmlString1, String objContext, 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;
public String itemChanged() throws RemoteException,ITMException;
public String itemChanged(String xmlString, String xmlString1, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException;
public String itemChanged(String xmlString, String xmlString1, String winName, 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 ibase.webitm.ejb.dis.DistCommon;
import java.rmi.RemoteException;
import org.w3c.dom.*;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.ITMException;
import javax.ejb.Local;
public interface BondRecoveryRemote extends ValidatorLocal {
public String wfValData(String xmlString, String xmlString1, String objContext, 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;
public String itemChanged() throws RemoteException,ITMException;
public String itemChanged(String xmlString, String xmlString1, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException;
public String itemChanged(String xmlString, String xmlString1, String winName, 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 ibase.webitm.ejb.dis.DistCommon;
import ibase.webitm.ejb.sys.SysCommon;
import ibase.system.config.ConnDriver;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.sys.UtilMethods;
import java.util.*;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.Date;
import javax.ejb.CreateException;
import javax.ejb.SessionBean;
import java.text.SimpleDateFormat;
import java.text.DecimalFormat;
import java.sql.Timestamp;
import org.w3c.dom.Document;
import org.w3c.dom.NamedNodeMap;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import javax.ejb.Stateless; // added for ejb3
import ibase.webitm.ejb.ITMDBAccessEJB;
import org.w3c.dom.CDATASection;
import java.text.*;
import java.sql.*;
@Stateless // added for ejb3
public class EmpBondDefinition extends ValidatorEJB implements EmpBondDefinitionLocal,EmpBondDefinitionRemote
{
public String wfValData() throws RemoteException,ITMException
{
return "";
}
public String itemChanged() throws RemoteException,ITMException
{
return "";
}
public String wfValData(String xmlString, String xmlString1,String xmlString2, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException
{
String errString = null;
Document dom = null;
Document dom1 = null;
Document dom2 = null;
NodeList parentNodeList = null;
NodeList childNodeList = null;
Node parentNode = null;
Node childNode = null;
String childNodeName = "";
System.out.println("\n\n xmlString in wfValData \n:" + xmlString + "\n");
System.out.println("\n\n xmlString1 in wfValData \n :" + xmlString1 +"\n");
System.out.println("\n\n xmlString2 in wfValData \n :" + xmlString2 +"\n");
try
{
dom = parseString(xmlString);
dom1 = parseString(xmlString1);
if (xmlString2.trim().length() > 0)
{
dom2 = parseString("<Root>" + xmlString2+ "</Root>");
}
//errString = wfValData(dom,dom1,dom2,objContext,editFlag,xtraParams);
//ADDED FOR INVOIKING VALIDATION IN WORKFLOW
if( objContext != null && Integer.parseInt(objContext) == 1 )
{
parentNodeList = dom2.getElementsByTagName("Header0");
parentNode = parentNodeList.item(1);
childNodeList = parentNode.getChildNodes();
for(int x=0;x<childNodeList.getLength();x++)
{
childNode = childNodeList.item(x);
childNodeName = childNode.getNodeName();
if(childNodeName.equalsIgnoreCase("Detail1"))
{
errString = wfValData(dom,dom1,dom2,"1",editFlag,xtraParams);
if(errString != null && errString.trim().length() > 0)
break;
}
else if(childNodeName.equalsIgnoreCase("Detail2"))
{
errString = wfValData(dom,dom1,dom2,"2",editFlag,xtraParams);
if(errString != null && errString.trim().length() > 0)
break;
}
else if(childNodeName.equalsIgnoreCase("Detail3"))
{
errString = wfValData(dom,dom1,dom2,"3",editFlag,xtraParams);
if(errString != null && errString.trim().length() > 0)
break;
}
}
}
else
{
errString = wfValData(dom,dom1,dom2,objContext,editFlag,xtraParams);
}
}
catch(Exception e)
{
System.out.println("Exception : ChangecontrolEJB : wfValData(String xmlString) : ==>\n"+e.getMessage());
}
return (errString);
}
public String wfValData(Document dom, Document dom1, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException
{
return "";
}
public String wfValData(String xmlString, String xmlString1,String xmlString2, String objContext, String editFlag) throws RemoteException,ITMException
{
return "";
}
public String itemChanged(Document dom, Document dom1,String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException
{
return "";
}
public String itemChanged(String xmlString, String xmlString1,String xmlString2, String objContext, String currentColumn, String editFlag) throws RemoteException,ITMException
{
return "";
}
public String wfValData(Document dom, Document dom1,Document dom2, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException
{
System.out.println("in wfValData........");
NodeList parentNodeList = null;
NodeList childNodeList = null;
Node parentNode = null;
Node childNode = null;
int ctr = 0,cnt = 0;
String childNodeName = null;
String errString = "";
String errCode = "";
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
String sql = "";
String userId = "";
int currentFormNo=0,i=0;
int childNodeListLength;
String empCode="",bondamt="",bondprd="",siteCode = "";
SimpleDateFormat simpleDateFormat = null;
try
{
System.out.println("in try.....");
ConnDriver connDriver = new ConnDriver();
GenericUtility genericUtility = GenericUtility.getInstance();
simpleDateFormat = new SimpleDateFormat(genericUtility.getApplDateFormat());
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
connDriver = null;
userId = getValueFromXTRA_PARAMS(xtraParams,"loginCode");
if(objContext != null && objContext.trim().length() > 0)
{
currentFormNo = Integer.parseInt(objContext);
}
switch(currentFormNo)
{
case 1 :
System.out.println("in switch.....");
parentNodeList = dom.getElementsByTagName("Detail1");
parentNode = parentNodeList.item(0);
childNodeList = parentNode.getChildNodes();
childNodeListLength = childNodeList.getLength();
for(ctr = 0; ctr < childNodeListLength; ctr++)
{
childNode = childNodeList.item(ctr);
childNodeName = childNode.getNodeName();
if (childNodeName.equalsIgnoreCase("emp_code"))
{
empCode = getColumnValue("emp_code",dom);
if (empCode == null || empCode.trim().length() == 0 )
{
errCode = "VNULEMPC";
errString = getErrorString("emp_code",errCode,userId);
break;
}
else
{
sql = "select count(1) from employee where emp_code = ? ";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,empCode);
rs = pstmt.executeQuery();
if(rs.next())
{
cnt = rs.getInt(1);
}
pstmt.close();
rs.close();
pstmt = null;
rs = null;
if(cnt == 0)
{
errCode = "VMEMPCD1 ";
errString = getErrorString("emp_code",errCode,userId);
break;
}
}
}
else if (childNodeName.equalsIgnoreCase("site_code"))
{
siteCode = getColumnValue("site_code",dom);
if (siteCode == null || siteCode.trim().length() == 0 )
{
errCode = "VMSITENULL";
errString = getErrorString("site_code",errCode,userId);
break;
}
else
{
sql = "select count(1) from site where site_code = ? ";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,siteCode);
rs = pstmt.executeQuery();
if(rs.next())
{
cnt = rs.getInt(1);
}
pstmt.close();
rs.close();
pstmt = null;
rs = null;
if(cnt == 0)
{
errCode = "VMSITENVAL";
errString = getErrorString("site_code",errCode,userId);
break;
}
}
}
}// for loop end
break;
case 2:
System.out.println("in detail 2 ------>>>>>>>>");
parentNodeList = dom.getElementsByTagName("Detail2");
parentNode = parentNodeList.item(0);
childNodeList = parentNode.getChildNodes();
childNodeListLength = childNodeList.getLength();
for(ctr = 0; ctr < childNodeListLength; ctr++)
{
childNode = childNodeList.item(ctr);
childNodeName = childNode.getNodeName();
if (childNodeName.equalsIgnoreCase("bond_amt"))
{
bondamt = genericUtility.getColumnValue("bond_amt",dom);
if (bondamt == null )
{
errCode = "VMBAMTNULL";
errString = getErrorString("bond_amt",errCode,userId);
break;
}
}
if (childNodeName.equalsIgnoreCase("bond_prd"))
{
bondprd = genericUtility.getColumnValue("bond_prd",dom);
if (bondprd == null || bondprd.trim().length() == 0 )
{
errCode = "VMBPRDNULL";
errString = getErrorString("bond_prd",errCode,userId);
break;
}
}
}// for loop end
break;
} //end switch
}//end try
catch(Exception e)
{
e.printStackTrace();
errString = e.getMessage();
}
finally
{
try
{
if(conn!=null)
{
conn.close();
conn = null;
}
if(pstmt != null )
{
pstmt.close();
pstmt = null;
}
if(rs != null )
{
rs.close();
rs = null;
}
}
catch(Exception d)
{
d.printStackTrace();
}
}
return errString;
}
public String itemChanged(String xmlString, String xmlString1,String xmlString2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException
{
Document dom = null;
Document dom1 = null;
Document dom2 = null;
String valueXmlString = "";
//System.out.println("\n\n xmlString in ItemChanged \n:" + xmlString + "\n");
//System.out.println("\n\n xmlString1 In ItemChanged \n :" + xmlString1 +"\n");
try
{
dom = parseString(xmlString);
dom1 = parseString(xmlString1);
if (xmlString2.trim().length() > 0 )
{
dom2 = parseString(xmlString2);
}
valueXmlString = itemChanged(dom,dom1,dom2,objContext,currentColumn,editFlag,xtraParams);
}
catch(Exception e)
{
System.out.println("Exception : [ChangeControlEJB][itemChanged(String,String)] :==>\n"+e.getMessage());
}
return valueXmlString;
}
public String itemChanged(Document dom, Document dom1,Document dom2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException
{
StringBuffer valueXmlString = new StringBuffer();
NodeList parentNodeList = null;
NodeList childNodeList = null;
Node parentNode = null;
Node childNode = null;
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null ;
int ctr=0;
String childNodeName = null;
String columnValue = null;
int currentFormNo = 0;
String deptCode="",empCode="",deptDescr = "";
String sql = "",descr = "",empfname = "", empmname = "", emplname = "";
ConnDriver connDriver = new ConnDriver();
String tranDate="",loginEmpCode="";
try
{
GenericUtility genericUtility = GenericUtility.getInstance();
SimpleDateFormat simpleDateFormat = new SimpleDateFormat(genericUtility.getApplDateFormat());
Timestamp timestamp = new Timestamp(System.currentTimeMillis());
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
connDriver=null;
if(objContext != null && objContext.trim().length()>0)
{
currentFormNo = Integer.parseInt(objContext);
}
valueXmlString = new StringBuffer("<?xml version=\"1.0\"?><Root><header><editFlag>");
valueXmlString.append(editFlag).append("</editFlag></header>");
switch(currentFormNo)
{
case 1 :
valueXmlString.append("<Detail1>");
parentNodeList = dom.getElementsByTagName("Detail1");
parentNode = parentNodeList.item(0);
childNodeList = parentNode.getChildNodes();
ctr = 0;
int childNodeListLength = childNodeList.getLength();
do
{
childNode = childNodeList.item(ctr);
childNodeName = childNode.getNodeName();
if(childNodeName.equals(currentColumn))
{
if (childNode.getFirstChild() != null)
{
columnValue = childNode.getFirstChild().getNodeValue().trim();
}
}
ctr++;
}while(ctr < childNodeListLength && !childNodeName.equals(currentColumn));
if(currentColumn.trim().equalsIgnoreCase("itm_default"))
{
System.out.println("in itm chnaged.....");
String confirmed="N";
tranDate = simpleDateFormat.format(timestamp).toString();
System.out.println("Tran Date 111: "+tranDate.toString());
valueXmlString.append("<tran_date>").append("<![CDATA["+tranDate.trim()+"]]>").append("</tran_date>");
valueXmlString.append("<confirmed>").append("<![CDATA["+confirmed+"]]>").append("</confirmed>");
String loginSiteCode = GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode");
sql = "SELECT DESCR FROM SITE WHERE SITE_CODE = ? ";
pstmt= conn.prepareStatement(sql);
pstmt.setString(1,loginSiteCode);
rs = pstmt.executeQuery();
if(rs.next())
{
descr = rs.getString(1) == null ? "" : rs.getString(1);
}
pstmt.close();
rs.close();
pstmt = null;
rs = null;
valueXmlString.append("<site_code>").append("<![CDATA["+loginSiteCode+"]]>").append("</site_code>");
valueXmlString.append("<site_descr>").append("<![CDATA["+descr+"]]>").append("</site_descr>");
loginEmpCode = GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode");
sql = " SELECT E.EMP_FNAME,E.EMP_MNAME,E.EMP_LNAME,E.DEPT_CODE,D.DESCR FROM "+
" EMPLOYEE E,DEPARTMENT D WHERE D.DEPT_CODE = E.DEPT_CODE AND "+
" E.EMP_CODE = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,loginEmpCode);
rs = pstmt.executeQuery();
while(rs.next())
{
empfname = rs.getString(1) == null ? "" : rs.getString(1).trim();
empmname = rs.getString(2) == null ? "" : rs.getString(2).trim();
emplname = rs.getString(3) == null ? "" : rs.getString(3).trim();
deptCode = rs.getString(4) == null ? "" : rs.getString(4).trim();
deptDescr = rs.getString(5) == null ? "" : rs.getString(5).trim();
valueXmlString.append("<emp_code>").append("<![CDATA["+ loginEmpCode +"]]>").append("</emp_code>");
valueXmlString.append("<emp_fname>").append("<![CDATA["+empfname +"]]>").append("</emp_fname>");
valueXmlString.append("<emp_mname>").append("<![CDATA["+empmname +"]]>").append("</emp_mname>");
valueXmlString.append("<emp_lname>").append("<![CDATA["+emplname +"]]>").append("</emp_lname>");
valueXmlString.append("<dept_code>").append("<![CDATA["+ deptCode +"]]>").append("</dept_code>");
valueXmlString.append("<department_descr>").append("<![CDATA["+ deptDescr +"]]>").append("</department_descr>");
}
pstmt.close();
rs.close();
pstmt = null;
rs = null;
}
else if(currentColumn.trim().equalsIgnoreCase("site_code"))
{
System.out.println("site code change...");
String siteCode = getColumnValue("site_code",dom);
sql = "SELECT DESCR FROM SITE WHERE SITE_CODE = ? ";
pstmt= conn.prepareStatement(sql);
pstmt.setString(1,siteCode);
rs = pstmt.executeQuery();
while(rs.next())
{
descr = rs.getString(1) == null ? "" : rs.getString(1);
}
pstmt.close();
rs.close();
pstmt = null;
rs = null;
valueXmlString.append("<site_descr>").append("<![CDATA["+descr.trim()+"]]>").append("</site_descr>");
}
else if(currentColumn.trim().equalsIgnoreCase("emp_code"))
{
empCode = genericUtility.getColumnValue("emp_code",dom);
sql = " Select e.emp_fname,e.emp_mname,e.emp_lname,e.dept_code,d.descr from "+
" employee e,department d "+
" where e.dept_code = d.dept_code and e.emp_code = ? ";
pstmt= conn.prepareStatement(sql);
pstmt.setString(1,empCode);
rs = pstmt.executeQuery();
while(rs.next())
{
empfname = rs.getString(1) == null ? "" : rs.getString(1);
empmname = rs.getString(2) == null ? "" : rs.getString(2);
emplname = rs.getString(3) == null ? "" : rs.getString(3);
deptCode = rs.getString(4) == null ? "" : rs.getString(4);
descr = rs.getString(5) == null ? "" : rs.getString(5);
valueXmlString.append("<emp_fname>").append("<![CDATA["+empfname+"]]>").append("</emp_fname>");
valueXmlString.append("<emp_mname>").append("<![CDATA["+empmname+"]]>").append("</emp_mname>");
valueXmlString.append("<emp_lname>").append("<![CDATA["+emplname+"]]>").append("</emp_lname>");
valueXmlString.append("<dept_code>").append("<![CDATA["+deptCode+"]]>").append("</dept_code>");
valueXmlString.append("<department_descr>").append("<![CDATA["+descr+"]]>").append("</department_descr>");
System.out.println("First Name :"+empfname+" Middle Name :"+empmname+" Last Name :"+emplname);
System.out.println("Dept code :"+deptCode+" descr : "+descr);
}
pstmt.close();
rs.close();
pstmt = null;
rs = null;
}
valueXmlString.append("</Detail1>");
break;
}// end switch
valueXmlString.append("</Root>");
}
catch(Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if(conn!=null)
{
conn.close();
conn = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(rs != null)
{
rs.close();
rs = null;
}
}
catch(Exception d)
{
d.printStackTrace();
}
}
System.out.println("Return xml ---->>>>"+valueXmlString.toString());
return valueXmlString.toString();
}
}//end class
package ibase.webitm.ejb.adm;
import ibase.webitm.ejb.dis.DistCommon;
import java.rmi.RemoteException;
import org.w3c.dom.*;
//import javax.ejb.EJBObject;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.ITMException;
import javax.ejb.Local;
public interface EmpBondDefinitionLocal extends ValidatorLocal {
public String wfValData() throws RemoteException,ITMException;
public String wfValData(String xmlString, String xmlString1, String objContext, 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;
public String itemChanged() throws RemoteException,ITMException;
public String itemChanged(String xmlString, String xmlString1, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException;
public String itemChanged(String xmlString, String xmlString1, String winName, 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 ibase.webitm.ejb.dis.DistCommon;
import java.rmi.RemoteException;
import org.w3c.dom.*;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.ITMException;
import javax.ejb.Remote;
public interface EmpBondDefinitionRemote extends ValidatorLocal{
public String wfValData() throws RemoteException,ITMException;
public String wfValData(String xmlString, String xmlString1, String objContext, 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;
public String itemChanged() throws RemoteException,ITMException;
public String itemChanged(String xmlString, String xmlString1, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException;
public String itemChanged(String xmlString, String xmlString1, String winName, 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.adv;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.GenericUtility;
import ibase.system.config.ConnDriver;
import java.sql.*;
import java.rmi.RemoteException;
import javax.ejb.Stateless;
@Stateless
public class BondRecoveryConfirm extends ActionHandlerEJB implements BondRecoveryConfirmLocal,BondRecoveryConfirmRemote
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
String retString = "";
try
{
Connection conn=null;
retString = confirm( tranId, xtraParams, forcedFlag, conn);
}
catch(Exception e)
{
System.out.println("Exception :BondRecoveryConfirm :confirm():" + e.getMessage() + ":");
retString = GenericUtility.getInstance().createErrorString(e);
e.printStackTrace();
}
return retString;
}
public String confirm( String tranId, String xtraParams, String forcedFlag, Connection conn)
{
System.out.println("--------------confirm method of BondRecoveryConfirm -------------");
ResultSet rs=null;
PreparedStatement pstmt = null;
conn=null;
ITMDBAccessEJB itmdbAccess=new ITMDBAccessEJB();
String sql="",confirmed="",errString="",empcode="",retString="";
double recAmtAct=0.0,recAmtDue=0.0;
int updCnt=0;
try
{
ConnDriver connDriver=new ConnDriver();
conn=connDriver.getConnectDB("DriverValidator");
conn.setAutoCommit(false);
sql = "SELECT emp_code,CONFIRMED FROM BOND_RECOVERY WHERE TRAN_ID = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if( rs.next() )
{
confirmed =rs.getString("CONFIRMED")==null ? "":rs.getString("CONFIRMED");
empcode=rs.getString(1);
}
System.out.println("confirm value before update :"+confirmed);
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
if ( rs != null )
{
rs.close();
rs = null;
}
if( confirmed != null && confirmed.equalsIgnoreCase("Y") )
{
errString = itmdbAccess.getErrorString("", "AEBCONF", "", "", conn);
return errString;
}
sql="select emp_code,recovery_amt__act,recovery_amt__due from Bond_recovery where emp_code = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, empcode);
rs = pstmt.executeQuery();
sql="update employee set BOND_AMT__RECO = ? where emp_code = ?";
pstmt = conn.prepareStatement( sql );
while(rs.next())
{
empcode=rs.getString(1);
recAmtAct=recAmtAct+rs.getDouble(2);
recAmtDue=rs.getDouble(3);
System.out.println("empcode -->"+empcode+"recAmtAct : "+recAmtAct+" recAmtDue : "+recAmtDue);
}
System.out.println("Recovery amt actual------>>>>"+recAmtAct);
pstmt.setDouble(1,recAmtAct);
pstmt.setString(2,empcode);
updCnt = pstmt.executeUpdate();
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
if ( rs != null )
{
rs.close();
rs = null;
}
System.out.println("UPDATE COUNT ---->>"+updCnt);
if (updCnt > 0)
{
retString=new ITMDBAccessEJB().getErrorString("", "VCONFSUC", "", "", conn);
updateConfirm(conn,tranId);
conn.commit();
System.out.println("BOND_AMT__RECO column of Employee updated successfully.......row(s) updated :"+updCnt);
}else
{
retString=new ITMDBAccessEJB().getErrorString("", "VCONFUSUC", "", "", conn);
conn.rollback();
System.out.println("Not Updated actual Bond amount........");
}
}
catch(Exception e)
{
try
{
conn.rollback();
}
catch (Exception e1)
{
}
e.printStackTrace();
System.out.println("Exception ::"+e.getMessage());
}
finally
{
try
{
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (conn!=null)
{
conn.close();
conn=null;
}
}
catch(Exception e)
{
System.out.println(e.getMessage());
e.printStackTrace();
}
}
System.out.println("Returning Result ::"+retString);
return retString;
}
public void updateConfirm(Connection conn,String tranId)
{
System.out.println("in updateConfirm method -------->>>");
String sql = "UPDATE BOND_RECOVERY SET CONFIRMED = 'Y' WHERE TRAN_ID = ?";
PreparedStatement pstmt1=null;
try
{
pstmt1 = conn.prepareStatement( sql );
pstmt1.setString(1, tranId);
int updCnt = pstmt1.executeUpdate();
System.out.println("confirm updated -------->>>>>>>>>updCount :"+updCnt);
}
catch(Exception e)
{
try
{
conn.rollback();
}
catch(Exception e1)
{
e1.printStackTrace();
}
e.printStackTrace();
}
try
{
if(pstmt1 != null)
{
pstmt1.close();
pstmt1 = null;
}
}
catch(Exception e)
{
System.out.println(e.getMessage());
e.printStackTrace();
}
}
}
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.Connection;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local;
@Local
public interface BondRecoveryConfirmLocal extends ActionHandlerLocal
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
public String confirm( String tranId, String xtraParams, String forcedFlag, Connection conn) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.Connection;
import javax.ejb.Remote;
import ibase.webitm.ejb.ActionHandlerRemote;
import ibase.webitm.utility.ITMException;
@Remote
public interface BondRecoveryConfirmRemote extends ActionHandlerRemote
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
public String confirm( String tranId, String xtraParams, String forcedFlag, Connection conn) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.adm.adv;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.GenericUtility;
import ibase.system.config.ConnDriver;
import java.sql.*;
import java.rmi.RemoteException;
import javax.ejb.Stateless;
@Stateless
public class EmpBondDefConfirm extends ActionHandlerEJB implements EmpBondDefConfirmLocal,EmpBondDefConfirmRemote
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
String retString = "";
try
{
Connection conn=null;
retString = confirm( tranId, xtraParams, forcedFlag, conn);
}
catch(Exception e)
{
System.out.println("Exception :EmpBondDefConfirm :confirm():" + e.getMessage() + ":");
retString = GenericUtility.getInstance().createErrorString(e);
e.printStackTrace();
}
return retString;
}
public String confirm( String tranId, String xtraParams, String forcedFlag, Connection conn)
{
System.out.println("--------------confirm method of EmpBondDefConfirm ------------- ");
ResultSet rs = null;
PreparedStatement pstmt = null;
conn = null;
ITMDBAccessEJB itmdbAccess=new ITMDBAccessEJB();
String retString = "",errString="";
String sql = "",empcode="",confirmed="";
double bondamt=0.0;
int lineno=0,bondprd=0,updCnt=0;
try
{
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverValidator");
conn.setAutoCommit(false);
sql = "SELECT CONFIRMED FROM EMPLOYEE_BOND_DEF WHERE TRAN_ID = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if( rs.next() )
{
confirmed =rs.getString("CONFIRMED")==null ? "":rs.getString("CONFIRMED");
}
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
if ( rs != null )
{
rs.close();
rs = null;
}
if( confirmed != null && confirmed.equalsIgnoreCase("Y") )
{
errString = itmdbAccess.getErrorString("", "AEBCONF", "", "", conn);
return errString;
}
sql="select ed.tran_id,e.emp_code,ed.line_no,ed.bond_amt,ed.bond_prd from employee_bond_def_det ed,employee_bond_def e "+
" where ed.tran_id=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
sql="update employee_bond set bond_amt = ?,bond_prd = ? where line_no = ? and emp_code = ?";
pstmt = conn.prepareStatement( sql );
while(rs.next())
{
lineno=rs.getInt("line_no");
bondamt=rs.getInt("bond_amt");
bondprd=rs.getInt("bond_prd");
empcode=rs.getString("emp_code");
pstmt.setDouble(1, bondamt);
pstmt.setInt(2, bondprd);
pstmt.setInt(3, lineno);
pstmt.setString(4,empcode);
updCnt = pstmt.executeUpdate();
}
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
if ( rs != null )
{
rs.close();
rs = null;
}
System.out.println("UPDATE COUNT ---->>"+updCnt);
if (updCnt > 0)
{
retString=new ITMDBAccessEJB().getErrorString("", "VCONFSUC", "", "", conn);
updateConfirm(conn,tranId);
conn.commit();
System.out.println("Bond amount and bond period updated successfully.......row(s) updated :"+updCnt);
}else
{
retString=new ITMDBAccessEJB().getErrorString("", "VCONFUSUC", "", "", conn);
conn.rollback();
System.out.println("Not Updated Bond amount and bond period........");
}
}
catch(Exception e)
{
try
{
conn.rollback();
}
catch (Exception e1)
{
}
e.printStackTrace();
System.out.println("Exception ::"+e.getMessage());
}
finally
{
try
{
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (conn!=null)
{
conn.close();
conn=null;
}
}
catch(Exception e)
{
System.out.println(e.getMessage());
e.printStackTrace();
}
}
System.out.println("Returning Result ::"+retString);
return retString;
}
public void updateConfirm(Connection conn,String tranId)
{
System.out.println("in updateConfirm method -------->>>");
String sql = "UPDATE EMPLOYEE_BOND_DEF SET CONFIRMED = 'Y' WHERE TRAN_ID = ?";
PreparedStatement pstmt1=null;
try
{
pstmt1 = conn.prepareStatement( sql );
pstmt1.setString(1, tranId);
int updCnt = pstmt1.executeUpdate();
System.out.println("confirm updated -------->>>>>>>>>updCount :"+updCnt);
}
catch(Exception e)
{
try
{
conn.rollback();
}
catch(Exception e1)
{
e1.printStackTrace();
}
e.printStackTrace();
}
try
{
if(pstmt1 != null)
{
pstmt1.close();
pstmt1 = null;
}
}
catch(Exception e)
{
System.out.println(e.getMessage());
e.printStackTrace();
}
}
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.Connection;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local;
@Local
public interface EmpBondDefConfirmLocal extends ActionHandlerLocal
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
public String confirm( String tranId, String xtraParams, String forcedFlag, Connection conn) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.adm.adv;
import java.sql.Connection;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerRemote;// added for ejb3
import javax.ejb.Remote; // added for ejb3
@Remote
public interface EmpBondDefConfirmRemote extends ActionHandlerRemote
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
public String confirm( String tranId, String xtraParams, String forcedFlag, Connection conn) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.HashSet;
import java.util.Set;
import javax.ejb.Stateless;
import org.w3c.dom.Document;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import ibase.system.config.ConnDriver;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.ejb.ActionHandlerEJB;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.utility.ITMException;
@Stateless
public class EmpBondDefault extends ActionHandlerEJB implements EmpBondDefaultLocal,EmpBondDefaultRemote
{
public String actionHandler(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException, ITMException
{
Document dom = null;
GenericUtility genericUtility = GenericUtility.getInstance();
String retString = "";
try
{
dom = genericUtility.parseString(xmlString);
retString = actionHandler(actionType, dom, objContext, xtraParams);
}
catch (Exception ex)
{
System.out.println("in catch");
ex.printStackTrace();
throw new ITMException(ex);
}
return retString;
}
private String actionHandler(String actionType, Document dom, String objContext, String xtraParams) throws ITMException
{
String sql = "", childNodeName = "";
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
ConnDriver connDriver = new ConnDriver();
NodeList parentNodeList = null, childNodeList = null;
Node parentNode = null, childNode = null;
int bondAmt=0,bondPrd=0;
GenericUtility genericUtility;
StringBuffer valueXmlBuff;
String retString = "",empcode="", userId = "";
ValidatorEJB validatorEJB;
String emp="";
int lineNo=0;
try
{
validatorEJB = new ValidatorEJB();
userId = validatorEJB.getValueFromXTRA_PARAMS(xtraParams, "loginCode");
valueXmlBuff = new StringBuffer();
genericUtility = GenericUtility.getInstance();
empcode =genericUtility.getColumnValue("emp_code",dom);
valueXmlBuff.append("<?xml version=\"1.0\"?>\r\n");
valueXmlBuff.append("<Root>\r\n");
parentNodeList = dom.getElementsByTagName("Detail1");
//loginEmpCode = GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode");
for (int i = 0; i < parentNodeList.getLength(); i++)
{
parentNode = parentNodeList.item(i);
childNodeList = parentNode.getChildNodes();
for (int j = 0; j < childNodeList.getLength(); j++)
{
childNode = childNodeList.item(j);
childNodeName = childNode.getNodeName();
}
}
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
connDriver = null;
sql="select e.line_no,e.bond_prd,e.bond_amt from employee_bond e where e.emp_code=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, empcode);
rs = pstmt.executeQuery();
while (rs.next())
{
// lineNo++;
lineNo=rs.getInt("LINE_NO");
bondAmt = rs.getInt("BOND_AMT");
bondPrd = rs.getInt("BOND_PRD");
valueXmlBuff.append("<Detail>\r\n");
valueXmlBuff.append("<line_no>").append("<![CDATA["+lineNo+"]]>").append("</line_no>");
valueXmlBuff.append("<bond_amt__curr>").append("<![CDATA["+bondAmt+"]]>").append("</bond_amt__curr>");
valueXmlBuff.append("<bond_prd__curr>").append("<![CDATA["+bondPrd+"]]>").append("</bond_prd__curr>");
valueXmlBuff.append("<bond_amt>").append("<![CDATA["+bondAmt+"]]>").append("</bond_amt>");
valueXmlBuff.append("<bond_prd>").append("<![CDATA["+bondPrd+"]]>").append("</bond_prd>");
valueXmlBuff.append("</Detail>\r\n");
System.out.println("------->>>>Line no :"+lineNo+" Bond Amt :"+bondAmt+" bond period : "+bondPrd);
}
pstmt.close();
pstmt = null;
rs.close();
rs = null;
valueXmlBuff.append("</Root>\r\n");
retString = valueXmlBuff.toString();
System.out.println("Return String ..in deafault EJB ----------->>>>>>>>>>> \n" + retString);
return retString;
}
catch (Exception e)
{
System.out.println("Exception : TrainingDefault : actionHandler " + e.getMessage());
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if (conn != null)
{
conn.close();
conn = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
}
catch (Exception e)
{
e.printStackTrace();
}
}
//return retString;
}
}
\ No newline at end of file
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import javax.ejb.Remote;
import ibase.webitm.ejb.ActionHandlerLocal;
import ibase.webitm.ejb.ActionHandlerRemote;
import ibase.webitm.utility.ITMException;
public interface EmpBondDefaultLocal extends ActionHandlerLocal
{
public String actionHandler(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException, ITMException;
}
package ibase.webitm.ejb.adm.adv;
import java.rmi.RemoteException;
import javax.ejb.Remote;
import ibase.webitm.ejb.ActionHandlerRemote;
import ibase.webitm.utility.ITMException;
@Remote
public interface EmpBondDefaultRemote extends ActionHandlerRemote
{
public String actionHandler(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException, ITMException;
}
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