Skip to content

B
business-java
Commit 55526ac0 authored by rtiwari's avatar rtiwari
Browse files
Options

EJB ADDED FOR DI3JSUN001 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@94095 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 01a22843
Hide whitespace changes
Inline Side-by-side
Showing with 463 additions and 0 deletions
webitm-dis/ibase/webitm/ejb/dis/RpermitUpdPrc.java 0 → 100755
View file @ 55526ac0
/**
* DEVELOP BY RITESH ON 06/JAN/14
* PURPOSE: ROAD PERMIT RECORDS UPDATION PROCESS (DI3JSUN001)
*/
package ibase.webitm.ejb.dis;
import ibase.system.config.ConnDriver;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ProcessEJB;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Timestamp;
import java.text.SimpleDateFormat;
import java.util.HashMap;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.ejb.Stateless;
import org.w3c.dom.Document;
@Stateless
public class RpermitUpdPrc extends ProcessEJB implements RpermitUpdPrcLocal,RpermitUpdPrcRemote
{
static
{
System.out.println("-- RpermitUpdPrc compiled -- ");
}
public String process() throws RemoteException,ITMException
{
return "";
}
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException
{
Document detailDom = null;
Document headerDom = null;
GenericUtility genericUtility = GenericUtility.getInstance();
String retStr = "";
try
{
System.out.println("xmlString[process]::::::::::;;;"+xmlString);
System.out.println("xmlString2[process]::::::::::;;;"+xmlString2);
System.out.println("windowName[process]::::::::::;;;"+windowName);
System.out.println("xtraParams[process]:::::::::;;;"+xtraParams);
}
catch(Exception e)
{
System.out.println(e.getMessage());
e.printStackTrace();
}
try
{
if(xmlString != null && xmlString.trim().length()!=0)
{
headerDom = genericUtility.parseString(xmlString);
System.out.println("headerDom" + headerDom);
}
if(xmlString2 != null && xmlString2.trim().length()!=0)
{
detailDom = genericUtility.parseString(xmlString2);
System.out.println("detailDom" + detailDom);
}
retStr = process(headerDom, detailDom, windowName, xtraParams);
}
catch (Exception e)
{
System.out.println("Exception :RpermitUpdPrc :process(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":");
e.printStackTrace();
}
return retStr;
}
//076RFE0009
public String process(Document dom, Document dom2, String windowName,String xtraParams) throws RemoteException, ITMException
{
System.out.println("RpermitUpdPrc process called........");
String errString = "";
Connection conn = null;
ConnDriver connDriver = null;
//PreparedStatement pstmt = null;
//ResultSet rs = null;
ITMDBAccessEJB itmDBAccessEJB = null;
GenericUtility genericUtility = null;
String siteCodeFr="",allocDateStr="",stateCodeFr="";
String rcpDateStr="",rpermitFr="",rpermitTo="",remarks="";
StringBuffer getter1 = new StringBuffer("");
StringBuffer pattern1 = new StringBuffer("");
StringBuffer getter2 = new StringBuffer("");
StringBuffer pattern2 = new StringBuffer("");
boolean flagTo = false,flagFr = false;;
HashMap hmap = null;
int countCharFr = 0,countCharTo = 0,cnt=0;
String numStr2="",numStr1="",comp1="",comp2="",sql="";
PreparedStatement pstmt = null;
ResultSet rs = null;
try
{
genericUtility = new GenericUtility();
itmDBAccessEJB = new ITMDBAccessEJB();
connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
connDriver = null;
conn.setAutoCommit(false);
hmap = new HashMap();
rpermitFr = (checkNull(genericUtility.getColumnValue("road_permit__from", dom))).trim();
rpermitTo = (checkNull(genericUtility.getColumnValue("road_permit__to", dom))).trim();
siteCodeFr = (checkNull(genericUtility.getColumnValue("site_code__fr", dom))).trim();
allocDateStr = checkNull(genericUtility.getColumnValue("alloc_date", dom));
stateCodeFr= (checkNull(genericUtility.getColumnValue("state_code__fr", dom))).trim();
rcpDateStr = checkNull(genericUtility.getColumnValue("recpt_date", dom));
remarks = checkNull(genericUtility.getColumnValue("remarks", dom));
hmap.put("rpermitFr", rpermitFr);
hmap.put("rpermitTo", rpermitTo);
hmap.put("siteCodeFr", siteCodeFr);
hmap.put("allocDateStr", allocDateStr);
hmap.put("stateCodeFr", stateCodeFr);
hmap.put("rcpDateStr", rcpDateStr);
hmap.put("remarks", remarks);
if(rpermitFr ==null || rpermitFr.trim().length() == 0)
{
errString = itmDBAccessEJB.getErrorString("","VPRPERFR1 ","","",conn);
return errString;
}
if(rpermitTo ==null || rpermitTo.trim().length() == 0)
{
errString = itmDBAccessEJB.getErrorString("","VPRPERTO1 ","","",conn);
return errString;
}
if(stateCodeFr ==null || stateCodeFr.trim().length() == 0)
{
errString = itmDBAccessEJB.getErrorString("","VPSTATCD2 ","","",conn);
return errString;
}
if(rpermitFr.trim().length() > 0 && rpermitTo.trim().length() > 0)
{
for(int i= rpermitFr.length()-1; i >= 0; i--)
{
countCharFr ++;
if((rpermitFr.charAt(i) <= 57 && rpermitFr.charAt(i) >= 48) && flagFr == false)
{
getter1.append(rpermitFr.charAt(i));
}
else
{
flagFr = true;
pattern1.append(rpermitFr.charAt(i));
}
}
for(int i= rpermitTo.length()-1; i >= 0; i--)
{
countCharTo ++;
if((rpermitTo.charAt(i) <= 57 && rpermitTo.charAt(i) >= 48) && flagTo == false)
{
getter2.append(rpermitTo.charAt(i));
}
else
{
flagTo = true;
pattern2.append(rpermitTo.charAt(i));
}
}
comp1 = pattern1.reverse().toString();
comp2= pattern2.reverse().toString();
numStr1 = getter1.reverse().toString();
numStr2 = getter2.reverse().toString();
System.out.println("numStr1:"+numStr1+"numStr2:"+numStr2);
// if(!comp1.equals(comp2) || countCharTo!= countCharFr)
if(!comp1.equals(comp2))
{
errString = itmDBAccessEJB.getErrorString("","VPPATERN1 ","","",conn);
return errString;
}
else
{
hmap.put("pattern1", comp1);
hmap.put("pattern2", comp2);
hmap.put("getter1", numStr1);
hmap.put("getter2", numStr2);
}
}
if(siteCodeFr.trim().length() > 0)
{
sql = "select count(*) from site where site_code = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, siteCodeFr);
rs = pstmt.executeQuery();
if(rs.next())
{
cnt = rs.getInt(1);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if(cnt == 0)
{
errString = itmDBAccessEJB.getErrorString("","VPSITECD1","","",conn);
return errString;
}
}
if(stateCodeFr.trim().length() > 0)
{
sql = "select count(*) from state where state_code = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, stateCodeFr);
rs = pstmt.executeQuery();
if(rs.next())
{
cnt = rs.getInt(1);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if(cnt == 0)
{
errString = itmDBAccessEJB.getErrorString("","VPSTATCDIN","","",conn);
return errString;
}
}
if(errString == null || errString.trim().length() == 0)
{
System.out.println(" method calling ....");
errString = UpdateRPermit(hmap,xtraParams,conn);
}
if((errString != null ) && (errString.indexOf("Success") > -1))
{
conn.commit();
System.out.println("--process completed--");
errString = itmDBAccessEJB.getErrorString("","VPSUCC1 ","","",conn);
}
else if((errString != null ) && (errString.indexOf("VTNOREC") > -1))
{
conn.rollback();
System.out.println("--no record found--");
errString = itmDBAccessEJB.getErrorString("","VTNOREC1 ","","",conn);
}
else
{
conn.rollback();
System.out.println("--process not completed--");
errString = itmDBAccessEJB.getErrorString("","VTEPFAIL ","","",conn);
}
}
catch( Exception e)
{
try
{
conn.rollback();
}
catch (SQLException ex)
{
Logger.getLogger(RpermitUpdPrc.class.getName()).log(Level.SEVERE, null, ex);
}
e.printStackTrace();
}
finally
{
try
{
if(errString != null && errString.trim().length() > 0)
{
if(errString.indexOf("VPSUCC1") > -1 )
{
conn.commit();
System.out.println("--transaction commited--");
}
else
{
conn.rollback();
System.out.println("--transaction rollback--");
}
}
if( conn != null && ! conn.isClosed() )
{
conn.close();
conn = null;
}
}
catch(Exception e)
{
System.out.println("Exception : "+e);e.printStackTrace();
throw new ITMException(e);
}
}
return errString;
}
private String UpdateRPermit(HashMap gmap,String xtraParams,Connection conn) throws RemoteException, ITMException
{
String userId = "";
String termId = "";
String chgTerm="",chgUser="";
String sql = "";
PreparedStatement pstmt = null;
ResultSet rs = null;
GenericUtility genericUtility = null;
String retString = null;
//String loginSite ="";
String siteCodeFr="";
Timestamp currDate = null,rcpDate=null,allocDate=null;
java.util.Date datealloc = null,datercp=null;
int rpermitNoTo = 0,rpermitNoFr = 1;
int inRows=0,range= 0,num = 0;
String zeros="",numStr="",remarks="";
String stateCodeFr = "",rpermitFr="",rpermitTo="",pattern1="";
try
{
System.out.println("@@@@@@@ UpdateRPermit called::");
genericUtility = GenericUtility.getInstance();
SimpleDateFormat sdf1 = new SimpleDateFormat(genericUtility.getDBDateFormat());
if(((String)gmap.get("allocDateStr")) != null && ((String)gmap.get("allocDateStr")).trim().length() > 0)
{
datealloc = genericUtility.getDateObject((String)gmap.get("allocDateStr"));
allocDate = java.sql.Timestamp.valueOf(sdf1.format(datealloc).toString() + " 00:00:00.0");
}
if(((String)gmap.get("rcpDateStr")) != null && ((String)gmap.get("rcpDateStr")).trim().length() > 0)
{
datercp = genericUtility.getDateObject((String)gmap.get("rcpDateStr"));
rcpDate = java.sql.Timestamp.valueOf(sdf1.format(datercp).toString() + " 00:00:00.0");
}
currDate = java.sql.Timestamp.valueOf(sdf1.format(new java.util.Date()).toString() + " 00:00:00.0");
userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode"); System.out.println("--login code--"+userId);
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "termId"); System.out.println("--term id--"+termId);
chgUser = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"userId");System.out.println("--term id--"+termId);
//loginSite = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode");
rpermitFr = (String)gmap.get("getter1");
rpermitTo = (String)gmap.get("getter2");
pattern1 = (String)gmap.get("pattern1");
siteCodeFr = checkNull((String)gmap.get("siteCodeFr"));
stateCodeFr = checkNull((String)gmap.get("stateCodeFr"));
remarks = (String)gmap.get("remarks");
//String pattern2 = (String)gmap.get("pattern2");
if(rpermitFr != null && rpermitFr.trim().length()>0)
rpermitNoFr = Integer.parseInt(rpermitFr);
if(rpermitTo != null && rpermitTo.trim().length()>0)
rpermitNoTo = Integer.parseInt(rpermitTo);
range = rpermitNoTo - rpermitNoFr;
System.out.println("rpermitNoFr::"+rpermitNoFr+"rpermitNoTo:"+rpermitNoTo);
for(int k = 0;k<= range;k++)
{
sql = "update roadpermit set site_code__fr = ? , alloc_date = ?,state_code__fr = ?,recpt_date = ?, remarks = ?, " +
" chg_term = ? , chg_user = ? , chg_date = ? where rd_permit_no = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, siteCodeFr);
pstmt.setTimestamp(2, allocDate);
pstmt.setString(3, stateCodeFr);
pstmt.setTimestamp(4, rcpDate);
pstmt.setString(5, remarks);
pstmt.setString(6, chgTerm);
pstmt.setString(7, chgUser);
pstmt.setTimestamp(8, currDate);
pstmt.setString(9, pattern1+rpermitFr);
inRows = inRows+ pstmt.executeUpdate();
pstmt.close();
pstmt = null;
zeros="";
num = Integer.parseInt(rpermitFr);
num ++;
numStr = Integer.toString(num);
for(int i = 1; i <= rpermitFr.length() - numStr.length();i++)
{
zeros = zeros+0 ;
}
rpermitFr = zeros+num;
System.out.println("result string "+rpermitFr);
}
System.out.println("No.Of Rows updated ::"+inRows);
if(inRows > 0)
{
retString = "Success";
}else{
retString = "VTNOREC";
}
}
catch(Exception e)
{
e.printStackTrace();
retString = e.getMessage();
throw new ITMException(e);
}
finally
{
try
{
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(rs != null)
{
rs.close();
rs = null;
}
}
catch(Exception e)
{
e.printStackTrace();
retString = e.getMessage();
throw new ITMException(e);
}
}
System.out.println("Returning Result [" + retString + "]");
return retString;
}
private String checkNull(String input)
{
if(input == null)
{
input = "";
}
return input;
}
}
\ No newline at end of file
webitm-dis/ibase/webitm/ejb/dis/RpermitUpdPrcLocal.java 0 → 100755
View file @ 55526ac0
package ibase.webitm.ejb.dis;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import org.w3c.dom.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ProcessLocal;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface RpermitUpdPrcLocal extends ibase.webitm.ejb.ProcessLocal//, EJBObject
{
public String process() throws RemoteException,ITMException;
public String process(Document dom, Document dom2, String windowName, String xtraParams) throws RemoteException,ITMException;
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException;
// public String getData(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException;
// public String getData(Document dom, Document dom2, String windowNamem, String xtraParams) throws RemoteException,ITMException;
}
webitm-dis/ibase/webitm/ejb/dis/RpermitUpdPrcRemote.java 0 → 100755
View file @ 55526ac0
package ibase.webitm.ejb.dis;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import org.w3c.dom.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ProcessRemote;
import javax.ejb.Remote; // added for ejb3
@Remote // added for ejb3
public interface RpermitUpdPrcRemote extends ibase.webitm.ejb.ProcessRemote//, EJBObject
{
public String process() throws RemoteException,ITMException;
public String process(Document dom, Document dom2, String windowName, String xtraParams) throws RemoteException,ITMException;
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException;
// public String getData(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException;
// public String getData(Document dom, Document dom2, String windowNamem, 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