Skip to content

B
business-java
Commit eef26617 authored by manohar's avatar manohar
Browse files
Options

This commit was generated by cvs2svn to compensate for changes in r154, 

which included commits to RCS files with non-trunk default branches.

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@91219 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 2b178062
Hide whitespace changes
Inline Side-by-side
Showing with 641 additions and 59 deletions
webitm-mfg/ibase/webitm/ejb/mfg/ConfirmWorkCal.java 0 → 100755
View file @ eef26617
package ibase.webitm.ejb.mfg;
import ibase.webitm.utility.*;
import org.w3c.dom.*;
import ibase.utility.CommonConstants;
import ibase.webitm.ejb.*;
import ibase.system.config.*;
import java.rmi.RemoteException;
import java.util.*;
import java.text.*;
import java.sql.*;
import javax.ejb.*;
import java.util.Calendar;
import java.util.Date;
import javax.naming.InitialContext;
import ibase.system.config.AppConnectParm;
//import ibase.webitm.ejb.MasterStateful;
//import ibase.webitm.ejb.MasterStatefulHome;
import org.apache.axis.client.Call;
import org.apache.axis.client.Service;
import org.apache.axis.encoding.XMLType;
import javax.xml.rpc.ParameterMode;
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class ConfirmWorkCal extends ActionHandlerEJB implements ConfirmWorkCalLocal,ConfirmWorkCalRemote
{
GenericUtility genericUtility = GenericUtility.getInstance();
String userId ="";
String termId = "";
String loginSite = "";
/* public void ejbCreate() throws RemoteException, CreateException
{
System.out.println("Create Method Called....");
}
public void ejbRemove()
{
}
public void ejbActivate()
{
}
public void ejbPassivate()
{
} */
public String confirm() throws RemoteException,ITMException
{
System.out.println("confirm() Method Called....");
return "";
}
public String confirm(String xmlString, String xtraParams, String objContext) throws RemoteException,ITMException
{
String retString = null;
System.out.println("Xtra Params : " + xtraParams);
//genericUtility = GenericUtility.getInstance();
try
{
retString = actionConfirmWorkCal(xmlString, xtraParams);
}
catch(Exception e)
{
System.out.println("Exception :actionHandler(String xmlString):" + e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
System.out.println("returning from actionHandler"+retString);
return (retString);
}
private String actionConfirmWorkCal(String xmlString ,String xtraParams) throws RemoteException,ITMException, Exception
{
Connection conn = null;
Document dom = null;
boolean isError = false;
Document dom1 = null;
String retString = "",errCode = "";
PreparedStatement pstmt = null;
ResultSet rs = null;
int cnt = 0;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
ConnDriver connDriver = new ConnDriver();
String sql = "";
//String siteCode = "";
String custCode = "";
String empCode = "";
String[] values = new String[5];
String confirmed = "";
userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode");
loginSite = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginSiteCode");
empCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginEmpCode");
termId = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "termId" );
java.sql.Timestamp currDate = null;
java.sql.Timestamp tranDate = null;
String returnString = null;
boolean conFlag = false;
int ctr = 0;
String errStr = "",day = "",shift = "",workCtr = "",workDate = "";
java.sql.Timestamp wrkDate =null,FromDate = null;
StringTokenizer strTokens = null;
try
{
System.out.println("Values xmlString ::::::::::: "+xmlString);
//dom = parseString(xmlString);
//System.out.println("Dom after parsing ::::::::::: "+dom);
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
connDriver = null;
strTokens = new StringTokenizer(xmlString,":");
while(strTokens.hasMoreTokens())
{
values[ctr] = strTokens.nextToken();
System.out.println("Values in while loop ::::::::::: "+values[ctr]);
ctr++;
}
//System.out.println("Values from string tokenizer ::::::::::: "+values);
//workDate = genericUtility.getColumnValue("work_date",dom);
//System.out.println("workDate from dom ........."+workDate);
//day = genericUtility.getColumnValue("day_no",dom);
//shift = genericUtility.getColumnValue("shift",dom);
//workCtr = genericUtility.getColumnValue("workCtr",dom);
//day = genericUtility.getColumnValue("day_no",dom);
//wrkDate = java.sql.Timestamp.valueOf(workDate + " 00:00:00.00");
//currDate = new Timestamp( System.currentTimeMillis() );
//workDate = genericUtility.getValidDateString(dateto,genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat());
sql = "select confirmed from work_calendar where site_code = ? "
+" and work_date =? and day_no =? and shift = ? and work_ctr = ? ";
FromDate = java.sql.Timestamp.valueOf(genericUtility.getValidDateString(values[1],genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat()) +" 00:00:00.0");
pstmt = conn.prepareStatement(sql);
pstmt.setString( 1, values[0] );
pstmt.setTimestamp( 2, FromDate );
pstmt.setString( 3, values[2] );
pstmt.setString( 4, values[3] );
pstmt.setString( 5, values[4] );
rs = pstmt.executeQuery();
if( rs.next() )
{
confirmed = rs.getString(1);
//System.out.println("get confirmed :::::: " +confirmed);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if( confirmed != null && confirmed.trim().equalsIgnoreCase("Y") )
{
errStr = "TRNADYCONF";
returnString = itmDBAccessEJB.getErrorString("",errStr,userId);
return returnString;
}
else
{
sql = " update work_calendar set confirmed ='Y' "
+" where site_code = ? and work_date = ? "
+" and day_no = ? and shift =? and work_ctr = ?";
System.out.println( "upd sql " + sql );
pstmt = conn.prepareStatement( sql );
pstmt.setString( 1, values[0] );
pstmt.setTimestamp( 2, FromDate);
pstmt.setString( 3, values[2] );
pstmt.setString( 4, values[3] );
pstmt.setString( 5, values[4] );
int chkupdt = pstmt.executeUpdate();
System.out.println("If 1 then updated = "+chkupdt);
pstmt.close();
pstmt = null;
if(chkupdt != 1)
{
errCode = "VTUPDHDR";
}
}
}
catch(SQLException e)
{
isError = true;
System.out.println("Exception :ConfirmWorkCalEJB :confirm :SQLException :==>\n"+e.getMessage());
retString = GenericUtility.getInstance().createErrorString(e);
throw new ITMException(e);
}
catch(Exception e)
{
isError = true;
System.out.println("Exception :ConfirmWorkCalEJB :confirm :==>\n"+e.getMessage());
retString = GenericUtility.getInstance().createErrorString(e);
throw new ITMException(e);
}
finally
{
try
{
if( !isError && retString.trim().length() == 0 )
{
conn.commit();
retString = new ITMDBAccessEJB().getErrorString("","VTCONF","");
System.out.println("ConfirmWorkCalEJB:confirm:Committed");
}
else
{
conn.rollback();
System.out.println("CConfirmWorkCalEJB:confirm:Rolled back");
retString = new ITMDBAccessEJB().getErrorString("",errCode,"");
}
if(conn != null)
{
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
conn.close();
conn = null;
}
}
catch(Exception e)
{
System.out.println("Exception :ConfirmOOSIncidentEJB :confirm :==>\n"+e.getMessage());
throw new ITMException(e);
}
}
return retString;
}
}
webitm-mfg/ibase/webitm/ejb/mfg/ConfirmWorkCalAll.java 0 → 100755
View file @ eef26617
package ibase.webitm.ejb.mfg;
import ibase.webitm.utility.*;
import org.w3c.dom.*;
import ibase.utility.CommonConstants;
import ibase.webitm.ejb.*;
import ibase.system.config.*;
import java.rmi.RemoteException;
import java.util.*;
import java.text.*;
import java.sql.*;
import javax.ejb.*;
import java.util.Calendar;
import java.util.Date;
import javax.naming.InitialContext;
import ibase.system.config.AppConnectParm;
//import ibase.webitm.ejb.MasterStateful;
//import ibase.webitm.ejb.MasterStatefulHome;
import org.apache.axis.client.Call;
import org.apache.axis.client.Service;
import org.apache.axis.encoding.XMLType;
import javax.xml.rpc.ParameterMode;
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class ConfirmWorkCalAll extends ActionHandlerEJB implements ConfirmWorkCalAllLocal,ConfirmWorkCalAllRemote
{
GenericUtility genericUtility = GenericUtility.getInstance();
String userId ="";
String termId = "";
String loginSite = "";
/* public void ejbCreate() throws RemoteException, CreateException
{
System.out.println("Create Method Called....");
}
public void ejbRemove()
{
}
public void ejbActivate()
{
}
public void ejbPassivate()
{
} */
public String confirm() throws RemoteException,ITMException
{
System.out.println("confirm() Method Called....");
return "";
}
public String confirm(String xmlString, String xtraParams, String objContext) throws RemoteException,ITMException
{
String retString = null;
System.out.println("Xtra Params : " + xtraParams);
//genericUtility = GenericUtility.getInstance();
try
{
retString = actionConfirmWorkCal(xmlString, xtraParams);
}
catch(Exception e)
{
System.out.println("Exception :actionHandler(String xmlString):" + e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
System.out.println("returning from actionHandler"+retString);
return (retString);
}
private String actionConfirmWorkCal(String xmlString ,String xtraParams) throws RemoteException,ITMException, Exception
{
Connection conn = null;
Document dom = null;
boolean isError = false;
Document dom1 = null;
String retString = "",errCode = "";
PreparedStatement pstmt = null;
ResultSet rs = null;
int cnt = 0;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
ConnDriver connDriver = new ConnDriver();
String sql = "";
//String siteCode = "";
String custCode = "",sqlPrd = "";
String empCode = "";
String[] values = new String[5];
String confirmed = "";
userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode");
loginSite = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginSiteCode");
empCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginEmpCode");
termId = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "termId" );
java.sql.Timestamp currDate = null;
java.sql.Timestamp tranDate = null;
String returnString = null;
boolean conFlag = false;
int ctr = 0;
String errStr = "",day = "",shift = "",workCtr = "",workDate = "";
java.sql.Timestamp wrkDate =null,FromDate = null,fr_date = null,to_date = null;
StringTokenizer strTokens = null;
try
{
System.out.println("Values xmlString ::::::::::: "+xmlString);
//dom = parseString(xmlString);
//System.out.println("Dom after parsing ::::::::::: "+dom);
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
connDriver = null;
strTokens = new StringTokenizer(xmlString,":");
while(strTokens.hasMoreTokens())
{
values[ctr] = strTokens.nextToken();
System.out.println("Values in while loop ::::::::::: "+values[ctr]);
ctr++;
}
//System.out.println("Values from string tokenizer ::::::::::: "+values);
//workDate = genericUtility.getColumnValue("work_date",dom);
//System.out.println("workDate from dom ........."+workDate);
//day = genericUtility.getColumnValue("day_no",dom);
//shift = genericUtility.getColumnValue("shift",dom);
//workCtr = genericUtility.getColumnValue("workCtr",dom);
//day = genericUtility.getColumnValue("day_no",dom);
//wrkDate = java.sql.Timestamp.valueOf(workDate + " 00:00:00.00");
//currDate = new Timestamp( System.currentTimeMillis() );
//workDate = genericUtility.getValidDateString(dateto,genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat());
boolean confFlag = false;
FromDate = java.sql.Timestamp.valueOf(genericUtility.getValidDateString(values[1],genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat()) +" 00:00:00.0");
sqlPrd = "SELECT fr_date,to_date FROM PERIOD where ? BETWEEN fr_date and to_date";
pstmt = conn.prepareStatement(sqlPrd);
pstmt.setTimestamp( 1, FromDate );
rs = pstmt.executeQuery();
if( rs.next() )
{
fr_date = rs.getTimestamp(1);
to_date = rs.getTimestamp(2);
System.out.println("get from_date from period :::::: " +fr_date);
System.out.println("get to_date from period :::::: " +to_date);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
/* sql = "select confirmed from work_calendar where site_code = ? "
+" and work_date =? and day_no =? and shift = ? and work_ctr = ? "; */
sql = "select confirmed from work_calendar where "
+" work_date between ? and ? ";
FromDate = java.sql.Timestamp.valueOf(genericUtility.getValidDateString(values[1],genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat()) +" 00:00:00.0");
pstmt = conn.prepareStatement(sql);
/* pstmt.setString( 1, values[0] );
pstmt.setTimestamp( 2, FromDate );
pstmt.setString( 3, values[2] );
pstmt.setString( 4, values[3] );
pstmt.setString( 5, values[4] ); */
//pstmt.setString( 1, values[0] );
pstmt.setTimestamp( 1, fr_date );
pstmt.setTimestamp( 2, to_date );
/* pstmt.setString( 4, values[3] );
pstmt.setString( 5, values[4] ); */
rs = pstmt.executeQuery();
while( rs.next() )
{
confirmed = rs.getString(1);
//System.out.println("get confirmed :::::: " +confirmed);
if( confirmed == null || confirmed.trim().equalsIgnoreCase("N") )
{
confFlag = true;
}
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if(confFlag)
{
//update
sql = "update work_calendar set confirmed ='Y' "
+"where work_date between ? and ?";
System.out.println( "update sql " + sql );
pstmt = conn.prepareStatement( sql );
//pstmt.setString( 1, values[0] );
pstmt.setTimestamp( 1, fr_date);
pstmt.setTimestamp( 2, to_date );
/* pstmt.setString( 4, values[3] );
pstmt.setString( 5, values[4] ); */
int chkupdt = pstmt.executeUpdate();
System.out.println("chkupdt==> "+chkupdt);
pstmt.close();
pstmt = null;
if(chkupdt != 1)
{
errCode = "VTUPDHDR";
}
}
else
{
errStr = "TRNADYCONF";
returnString = itmDBAccessEJB.getErrorString("",errStr,userId);
return returnString;
}
}
catch(SQLException e)
{
isError = true;
System.out.println("Exception :ConfirmWorkCalAllEJB :confirm :SQLException :==>\n"+e.getMessage());
retString = GenericUtility.getInstance().createErrorString(e);
throw new ITMException(e);
}
catch(Exception e)
{
isError = true;
System.out.println("Exception :ConfirmWorkCalAllEJB :confirm :==>\n"+e.getMessage());
retString = GenericUtility.getInstance().createErrorString(e);
throw new ITMException(e);
}
finally
{
try
{
if( !isError && retString.trim().length() == 0 )
{
conn.commit();
retString = new ITMDBAccessEJB().getErrorString("","VTCONF","");
System.out.println("ConfirmWorkCalAllEJB:confirm:Committed");
}
else
{
conn.rollback();
System.out.println("ConfirmWorkCalAllEJB:confirm:Rolled back");
retString = new ITMDBAccessEJB().getErrorString("",errCode,"");
}
if(conn != null)
{
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
conn.close();
conn = null;
}
}
catch(Exception e)
{
System.out.println("Exception :ConfirmOOSIncidentEJB :confirm :==>\n"+e.getMessage());
throw new ITMException(e);
}
}
return retString;
}
}
webitm-mfg/ibase/webitm/ejb/mfg/ConfirmWorkCalAllLocal.java 0 → 100755
View file @ eef26617
package ibase.webitm.ejb.mfg;
import java.rmi.RemoteException;
//import ibase.webitm.utility.ITMException;
//import javax.ejb.CreateException;
//import javax.ejb.EJBHome;
//import ibase.webitm.ejb.ActionHandlerHome;
//import ibase.webitm.ejb.ActionHandler;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface ConfirmWorkCalAllLocal extends ActionHandlerLocal
{
//public ActionHandler create() throws RemoteException, CreateException;
public String confirm() throws RemoteException,ITMException;
public String confirm(String xmlString, String xtraParams, String objContext) throws RemoteException,ITMException;
}
\ No newline at end of file
webitm-mfg/ibase/webitm/ejb/mfg/ConfirmWorkCalAllRemote.java 0 → 100755
View file @ eef26617
package ibase.webitm.ejb.mfg;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
//import ibase.webitm.ejb.ActionHandler;
import ibase.webitm.ejb.ActionHandlerRemote;// added for ejb3
import javax.ejb.Remote; // added for ejb3
@Remote
public interface ConfirmWorkCalAllRemote extends ActionHandlerRemote
{
public String confirm() throws RemoteException,ITMException;
public String confirm(String xmlString, String xtraParams, String objContext) throws RemoteException,ITMException;
}
\ No newline at end of file
webitm-mfg/ibase/webitm/ejb/mfg/ConfirmWorkCalLocal.java 0 → 100755
View file @ eef26617
package ibase.webitm.ejb.mfg;
import java.rmi.RemoteException;
//import ibase.webitm.utility.ITMException;
//import javax.ejb.CreateException;
//import javax.ejb.EJBHome;
//import ibase.webitm.ejb.ActionHandlerHome;
//import ibase.webitm.ejb.ActionHandler;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface ConfirmWorkCalLocal extends ActionHandlerLocal
{
//public ActionHandler create() throws RemoteException, CreateException;
public String confirm() throws RemoteException,ITMException;
public String confirm(String xmlString, String xtraParams, String objContext) throws RemoteException,ITMException;
}
\ No newline at end of file
webitm-mfg/ibase/webitm/ejb/mfg/ConfirmWorkCalRemote.java 0 → 100755
View file @ eef26617
package ibase.webitm.ejb.mfg;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
//import ibase.webitm.ejb.ActionHandler;
import ibase.webitm.ejb.ActionHandlerRemote;// added for ejb3
import javax.ejb.Remote; // added for ejb3
@Remote
public interface ConfirmWorkCalRemote extends ActionHandlerRemote
{
public String confirm() throws RemoteException,ITMException;
public String confirm(String xmlString, String xtraParams, String objContext) throws RemoteException,ITMException;
}
\ No newline at end of file
webitm-mfg/ibase/webitm/ejb/mfg/WorkCalendarPrc.java
View file @ eef26617
...@@ -2,7 +2,7 @@ ...@@ -2,7 +2,7 @@
/******************************************************** /********************************************************
Title : WokCalendarPrcEJB Title : WokCalendarPrcEJB
Date : 23/12/08 Date : 23/12/08
Author: pankaj singh Author: Pankaj singh
********************************************************/ ********************************************************/
package ibase.webitm.ejb.mfg; package ibase.webitm.ejb.mfg;
...@@ -27,10 +27,10 @@ import java.util.GregorianCalendar; ...@@ -27,10 +27,10 @@ import java.util.GregorianCalendar;
import java.util.Calendar; import java.util.Calendar;
import java.util.Date; import java.util.Date;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import javax.ejb.Stateless; // added for ejb3 import javax.ejb.Stateless;
@Stateless // added for ejb3 @Stateless
public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal, WorkCalendarPrcRemote //SessionBean public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal, WorkCalendarPrcRemote
{ {
Connection sqlConn = null; Connection sqlConn = null;
Connection oraConn = null; Connection oraConn = null;
...@@ -77,7 +77,7 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal ...@@ -77,7 +77,7 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB(); ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
/*public void ejbCreate() throws RemoteException, CreateException /* public void ejbCreate() throws RemoteException, CreateException
{ {
System.out.println("Create Method Called...."); System.out.println("Create Method Called....");
} }
...@@ -89,7 +89,7 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal ...@@ -89,7 +89,7 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal
} }
public void ejbPassivate() public void ejbPassivate()
{ {
}*/ } */
public String process() throws RemoteException,ITMException public String process() throws RemoteException,ITMException
{ {
return ""; return "";
...@@ -141,11 +141,11 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal ...@@ -141,11 +141,11 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
PreparedStatement InsertPstmt = null; PreparedStatement InsertPstmt = null;
ResultSet rs = null; ResultSet rs = null;
String sql = "" ,sql1 = "",errString = ""; String sql = "" ,sqlw = "",errString = "";
String retString = "" ,errCode = "",tranId=""; String retString = "" ,errCode = "",tranId="";
String loginSiteCode="",empCode="",chgUser="",chgTerm="",loginCode=""; String loginSiteCode="",empCode="",chgUser="",chgTerm="",loginCode="";
String policyNo="",insCertNo="",agent_code="",invoiceId=""; String policyNo="",insCertNo="",agent_code="",invoiceId="";
int count =0,cnt =0; int count =0,cnt =0,cnt1 = 0;
String curr_code="",dayNo = "",shiftOfDay = ""; String curr_code="",dayNo = "",shiftOfDay = "";
double exch_rate=0,netAmt=0; double exch_rate=0,netAmt=0;
Timestamp tranDate =null; Timestamp tranDate =null;
...@@ -173,25 +173,63 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal ...@@ -173,25 +173,63 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal
oraConn.setAutoCommit(false); oraConn.setAutoCommit(false);
connDriver = null; connDriver = null;
siteCode = genericUtility.getColumnValue("site_code",headerDom); siteCode = genericUtility.getColumnValue("site_code",headerDom);
wokCntr = genericUtility.getColumnValue("work_cntr",headerDom); wokCntr = genericUtility.getColumnValue("work_cntr",headerDom);
//wokCntr = wokCntr == null ? "" :wokCntr;
datefrom = genericUtility.getColumnValue("date_from",headerDom); datefrom = genericUtility.getColumnValue("date_from",headerDom);
dateto = genericUtility.getColumnValue("date_to",headerDom); dateto = genericUtility.getColumnValue("date_to",headerDom);
System.out.println("Values from dom \n sitecode " + siteCode + "\n wokCntr " + wokCntr + "\n datefrom " + datefrom + "\n dateto " + dateto ); System.out.println("Values from dom \n sitecode " + siteCode + "\n wokCntr " + wokCntr + "\n datefrom " + datefrom + "\n dateto " + dateto );
sql = "Select Count(*) from site where site_code = '"+siteCode+"' "; //sql = "Select Count(*) from site where site_code = '"+siteCode+"' ";
System.out.println("select qry from site_code.." + sql); /* sqlw = "Select Count(*) from workcntr where work_ctr = '"+wokCntr+"' "; */
pstmt= oraConn.prepareStatement(sql); //System.out.println("select qry from site_code.." + sql);
rs = pstmt.executeQuery(); /*if(siteCode == null || siteCode.trim().length() == 0)
if(rs.next())
{ {
cnt = rs.getInt(1); return errString = itmDBAccessEJB.getErrorString("","SPSTCODNUL",chgUser);
} }
pstmt.close(); if(wokCntr == null || wokCntr.trim().length() == 0)
rs.close(); {
pstmt = null; return errString = itmDBAccessEJB.getErrorString("","SPSTCODNUL",chgUser);
rs = null; }*/
if (cnt == 0) if(siteCode == null || siteCode.trim().length() == 0)
{ {
return errString = itmDBAccessEJB.getErrorString("","VMSITE1",chgUser); return errString = itmDBAccessEJB.getErrorString("","SPSTCODNUL",chgUser);
}
else
{
sql = "Select count(*) from site where site_code = '"+siteCode+"' ";
pstmt= oraConn.prepareStatement(sql);
rs = pstmt.executeQuery();
if(rs.next())
{
cnt = rs.getInt(1);
}
pstmt.close();
rs.close();
pstmt = null;
rs = null;
if (cnt == 0)
{
return errString = itmDBAccessEJB.getErrorString("","VMSITE1",chgUser);
}//VMWCTR1
}
if(wokCntr != null)
{
sqlw = "Select count(*) from workcntr where work_ctr = '"+wokCntr+"' ";
pstmt= oraConn.prepareStatement(sqlw);
rs = pstmt.executeQuery();
if(rs.next())
{
cnt1 = rs.getInt(1);
}
pstmt.close();
rs.close();
pstmt = null;
rs = null;
if (cnt1 == 0)
{
return errString = itmDBAccessEJB.getErrorString("","VMWCTR1",chgUser);
}
} }
if(datefrom == null || datefrom.trim().length() == 0 || dateto == null || dateto.trim().length() == 0) if(datefrom == null || datefrom.trim().length() == 0 || dateto == null || dateto.trim().length() == 0)
{ {
...@@ -212,9 +250,7 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal ...@@ -212,9 +250,7 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal
{ {
return errString = itmDBAccessEJB.getErrorString("","VMVALIDDT",chgUser); return errString = itmDBAccessEJB.getErrorString("","VMVALIDDT",chgUser);
} }
} }
if(wokCntr == null || wokCntr.trim().length() == 0) if(wokCntr == null || wokCntr.trim().length() == 0)
{ {
sql = "select count(*) " sql = "select count(*) "
...@@ -230,7 +266,7 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal ...@@ -230,7 +266,7 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal
+ " and work_ctr = '" + wokCntr + "'" + " and work_ctr = '" + wokCntr + "'"
+ " and work_date between ? and ? "; + " and work_date between ? and ? ";
} }
System.out.println("sql for count " + sql); System.out.println("sql for count ....... " + sql);
pstmt = oraConn.prepareStatement(sql); pstmt = oraConn.prepareStatement(sql);
pstmt.setTimestamp(1,FromDate); pstmt.setTimestamp(1,FromDate);
pstmt.setTimestamp(2,ToDate); pstmt.setTimestamp(2,ToDate);
...@@ -272,11 +308,11 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal ...@@ -272,11 +308,11 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal
//caled insertSchedule to insert schehedule after deleting existing records //caled insertSchedule to insert schehedule after deleting existing records
//errString = insertSchedule(siteCode,wokCntr,FromDate,ToDate,chgUser,chgTerm); //errString = insertSchedule(siteCode,wokCntr,FromDate,ToDate,chgUser,chgTerm);
} }
errString = insertSchedule(siteCode,wokCntr,FromDate,ToDate,chgUser,chgTerm,oraConn); errString = insertSchedule(siteCode,wokCntr,FromDate,ToDate,chgUser,chgTerm,oraConn);
if(errString != null && errString.trim().length() == 0) if(errString != null && errString.trim().length() == 0)
{ {
oraConn.commit(); oraConn.commit();
System.out.println("Connection commited"); System.out.println("Connection commited................. ");
errString = itmDBAccessEJB.getErrorString("","WRKCALSUCC",chgUser); errString = itmDBAccessEJB.getErrorString("","WRKCALSUCC",chgUser);
} }
else else
...@@ -311,7 +347,7 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal ...@@ -311,7 +347,7 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal
} }
System.out.println("returning from WokCalendarPrcEJB "+errString); System.out.println("returning from WokCalendarPrcEJB "+errString);
return errString; return errString;
} //end process }//end process
public String insertSchedule(String siteCode,String wokCntr,Timestamp FromDate,Timestamp ToDate,String chgUser,String chgTerm,Connection oraConn ) public String insertSchedule(String siteCode,String wokCntr,Timestamp FromDate,Timestamp ToDate,String chgUser,String chgTerm,Connection oraConn )
{ {
String retStr = ""; String retStr = "";
...@@ -337,8 +373,8 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal ...@@ -337,8 +373,8 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal
System.out.println("Inserting records.........."); System.out.println("Inserting records..........");
try try
{ {
sql = "select hol_tblno from site where site_code = '" + siteCode + "'"; sql = "select hol_tblno from site where site_code = '" + siteCode + "'";
System.out.println("sql for hol_tblno " + sql); System.out.println("Sql for hol_tblno ::::: " + sql);
pstmt = oraConn.prepareStatement(sql); pstmt = oraConn.prepareStatement(sql);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
while( rs.next() ) while( rs.next() )
...@@ -371,13 +407,13 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal ...@@ -371,13 +407,13 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal
System.out.println("FromDate changed :- " + FromDate); System.out.println("FromDate changed :- " + FromDate);
} }
sql = " select count(*) " sql = " select count(*) "
+ " from holiday " + " from holiday "
+ " where hol_tblno = '" + holTblno + "'" + " where hol_tblno = '" + holTblno + "'"
+ " and hol_date = ?"; + " and hol_date = ?";
pstmt = oraConn.prepareStatement(sql); pstmt = oraConn.prepareStatement(sql);
pstmt.setTimestamp(1,FromDate); pstmt.setTimestamp(1,FromDate);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
while( rs.next() ) while( rs.next())
{ {
count = rs.getInt(1); count = rs.getInt(1);
} }
...@@ -428,16 +464,15 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal ...@@ -428,16 +464,15 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal
sql = " SELECT " sql = " SELECT "
+ " DAY_NO ,SHIFT " + " DAY_NO ,SHIFT "
+ " FROM WORKSHFT " + " FROM WORKSHFT "
+ " WHERE site_code = '" + siteCode + "'"; + " WHERE site_code = '" + siteCode + "'";
} }
else else
{ {
sql = " SELECT DAY_NO ,SHIFT FROM WORKCNTRSHFT" sql = " SELECT DAY_NO ,SHIFT FROM WORKCNTRSHFT"
+ " WHERE site_code = '" + siteCode + "'" + " WHERE site_code = '" + siteCode + "'"
+ " and work_ctr = '" + wokCntr + "'"; + " and work_ctr = '" + wokCntr + "'";
} }
System.out.println("select day,shift query :::: " + sql);
System.out.println("select day,shift query " + sql);
pstmt = oraConn.prepareStatement(sql); pstmt = oraConn.prepareStatement(sql);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
while( rs.next() ) while( rs.next() )
...@@ -457,16 +492,16 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal ...@@ -457,16 +492,16 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal
Iterator it = dayMap.keySet().iterator(); Iterator it = dayMap.keySet().iterator();
Iterator itshft = shiftMap.keySet().iterator(); Iterator itshft = shiftMap.keySet().iterator();
System.out.println("Reading data...... " ); System.out.println("Reading data...... " );
while( itshft.hasNext() ) while( itshft.hasNext() )
{ {
while( it.hasNext() ) while( it.hasNext() )
{ {
System.out.println("Inside map.................."); System.out.println("Inside map..................");
InsertPstmt.setString(1,siteCode); InsertPstmt.setString(1,siteCode);
InsertPstmt.setTimestamp(2,FromDate); InsertPstmt.setTimestamp(2,FromDate);
System.out.println("primary setting wor date " + FromDate); System.out.println("primary setting work date " + FromDate);
dayNum = it.next(); dayNum = it.next();
dayOb = dayMap.get(dayNum) ; dayOb = dayMap.get(dayNum);
//System.out.println(" primary Day:- " + dayNum + " value:-" + dayOb); //System.out.println(" primary Day:- " + dayNum + " value:-" + dayOb);
InsertPstmt.setString(3,dayOb.toString()); InsertPstmt.setString(3,dayOb.toString());
shftName = itshft.next(); shftName = itshft.next();
...@@ -474,11 +509,12 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal ...@@ -474,11 +509,12 @@ public class WorkCalendarPrc extends ProcessEJB implements WorkCalendarPrcLocal
System.out.println(" primary Day:- " + dayNum + " value:-" + dayOb +" primary Shift:- " + shftName + " value:-" + shiftOb); System.out.println(" primary Day:- " + dayNum + " value:-" + dayOb +" primary Shift:- " + shftName + " value:-" + shiftOb);
InsertPstmt.setString(4,shiftOb.toString()); InsertPstmt.setString(4,shiftOb.toString());
InsertPstmt.setString(5,working); InsertPstmt.setString(5,working);
InsertPstmt.setString(6,"Y"); InsertPstmt.setString(6,"N");
InsertPstmt.setTimestamp(7,currDate); InsertPstmt.setTimestamp(7,currDate);
InsertPstmt.setString(8,chgUser); InsertPstmt.setString(8,chgUser);
InsertPstmt.setString(9,chgTerm); InsertPstmt.setString(9,chgTerm);
System.out.println(" primary setting wokCntr " + wokCntr); //InsertPstmt.setString(10,chgTerm);
System.out.println(" primary setting wokCntr ::::: " + wokCntr);
if(wokCntr == null || wokCntr.trim().length() == 0) if(wokCntr == null || wokCntr.trim().length() == 0)
{ {
InsertPstmt.setString(10," "); InsertPstmt.setString(10," ");
......
webitm-mfg/ibase/webitm/ejb/mfg/WorkCalendarPrcLocal.java
View file @ eef26617
package ibase.webitm.ejb.mfg; package ibase.webitm.ejb.mfg;
import java.rmi.RemoteException; import java.rmi.RemoteException;
//import javax.ejb.EJBObject; //import javax.ejb.CreateException;
import org.w3c.dom.*; //import javax.ejb.EJBHome;
import ibase.webitm.utility.ITMException; //import ibase.webitm.ejb.ProcessHome;
import ibase.webitm.ejb.*; //import ibase.webitm.ejb.Process;
import javax.xml.parsers.*;
import ibase.webitm.ejb.ProcessLocal; import ibase.webitm.ejb.ProcessLocal;
import ibase.webitm.utility.ITMException;
import javax.ejb.Local; // added for ejb3 import javax.ejb.Local; // added for ejb3
import ibase.webitm.utility.ITMException;
@Local // added for ejb3 @Local // added for ejb3`
public interface WorkCalendarPrcLocal extends ProcessLocal
public interface WorkCalendarPrcLocal extends ProcessLocal//, EJBObject
{ {
//public ibase.webitm.ejb.Process create() throws RemoteException, CreateException;
public String process() throws RemoteException,ITMException; public String process() throws RemoteException,ITMException;
public String process(String string1, String string2, String windowName, String xtraParams) throws RemoteException,ITMException; public String process(String string1, String string2, String windowName, String xtraParams) throws RemoteException,ITMException;
} }
\ No newline at end of file
webitm-mfg/ibase/webitm/ejb/mfg/WorkCalendarPrcRemote.java
View file @ eef26617
...@@ -6,14 +6,14 @@ import org.w3c.dom.*; ...@@ -6,14 +6,14 @@ import org.w3c.dom.*;
import ibase.webitm.utility.ITMException; import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*; import ibase.webitm.ejb.*;
import javax.xml.parsers.*; import javax.xml.parsers.*;
import ibase.webitm.ejb.ProcessRemote; //import ibase.webitm.ejb.Process;
import ibase.webitm.utility.ITMException; import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ProcessRemote;
import javax.ejb.Remote; // added for ejb3 import javax.ejb.Remote; // added for ejb3
import ibase.webitm.ejb.ValidatorRemote;// added for ejb3
@Remote // added for ejb3 @Remote // added for ejb3
public interface WorkCalendarPrcRemote extends ProcessRemote
public interface WorkCalendarPrcRemote extends ProcessRemote//, EJBObject
{ {
public String process() throws RemoteException,ITMException; public String process() throws RemoteException,ITMException;
public String process(String string1, String string2, String windowName, String xtraParams) throws RemoteException,ITMException; public String process(String string1, String string2, String windowName, 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