Skip to content

B
business-java
Commit 795b3a2e authored by cpatil's avatar cpatil
Browse files
Options

remove parsing error 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@96943 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 67306c8b
Hide whitespace changes
Inline Side-by-side
Showing with 173 additions and 128 deletions
webitm-dis/ibase/webitm/ejb/dis/RpermitUpdPrc.java
View file @ 795b3a2e
...@@ -70,7 +70,7 @@ public class RpermitUpdPrc extends ProcessEJB implements RpermitUpdPrcLocal,Rper ...@@ -70,7 +70,7 @@ public class RpermitUpdPrc extends ProcessEJB implements RpermitUpdPrcLocal,Rper
e.printStackTrace(); e.printStackTrace();
} }
return retStr; return retStr;
} }
//076RFE0009 //076RFE0009
public String process(Document dom, Document dom2, String windowName,String xtraParams) throws RemoteException, ITMException public String process(Document dom, Document dom2, String windowName,String xtraParams) throws RemoteException, ITMException
...@@ -113,7 +113,7 @@ public class RpermitUpdPrc extends ProcessEJB implements RpermitUpdPrcLocal,Rper ...@@ -113,7 +113,7 @@ public class RpermitUpdPrc extends ProcessEJB implements RpermitUpdPrcLocal,Rper
stateCodeFr= (checkNull(genericUtility.getColumnValue("state_code__fr", dom))).trim(); stateCodeFr= (checkNull(genericUtility.getColumnValue("state_code__fr", dom))).trim();
rcpDateStr = checkNull(genericUtility.getColumnValue("recpt_date", dom)); rcpDateStr = checkNull(genericUtility.getColumnValue("recpt_date", dom));
remarks = checkNull(genericUtility.getColumnValue("remarks", dom)); remarks = checkNull(genericUtility.getColumnValue("remarks", dom));
hmap.put("rpermitFr", rpermitFr); hmap.put("rpermitFr", rpermitFr);
hmap.put("rpermitTo", rpermitTo); hmap.put("rpermitTo", rpermitTo);
hmap.put("siteCodeFr", siteCodeFr); hmap.put("siteCodeFr", siteCodeFr);
...@@ -121,8 +121,8 @@ public class RpermitUpdPrc extends ProcessEJB implements RpermitUpdPrcLocal,Rper ...@@ -121,8 +121,8 @@ public class RpermitUpdPrc extends ProcessEJB implements RpermitUpdPrcLocal,Rper
hmap.put("stateCodeFr", stateCodeFr); hmap.put("stateCodeFr", stateCodeFr);
hmap.put("rcpDateStr", rcpDateStr); hmap.put("rcpDateStr", rcpDateStr);
hmap.put("remarks", remarks); hmap.put("remarks", remarks);
if(rpermitFr ==null || rpermitFr.trim().length() == 0) if(rpermitFr ==null || rpermitFr.trim().length() == 0)
{ {
errString = itmDBAccessEJB.getErrorString("","VPRPERFR1 ","","",conn); errString = itmDBAccessEJB.getErrorString("","VPRPERFR1 ","","",conn);
...@@ -142,45 +142,45 @@ public class RpermitUpdPrc extends ProcessEJB implements RpermitUpdPrcLocal,Rper ...@@ -142,45 +142,45 @@ public class RpermitUpdPrc extends ProcessEJB implements RpermitUpdPrcLocal,Rper
{ {
sql= " select count(*) from roadpermit where rd_permit_no = ? "; sql= " select count(*) from roadpermit where rd_permit_no = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, rpermitFr); pstmt.setString(1, rpermitFr);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if(rs.next()) if(rs.next())
{ {
cnt = rs.getInt(1); cnt = rs.getInt(1);
} }
rs.close(); rs.close();
rs = null; rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
if(cnt == 0) if(cnt == 0)
{ {
errString = itmDBAccessEJB.getErrorString("","VPRDFR1","","",conn); errString = itmDBAccessEJB.getErrorString("","VPRDFR1","","",conn);
return errString; return errString;
} }
} }
if(rpermitTo !=null & rpermitTo.trim().length() > 0) if(rpermitTo !=null & rpermitTo.trim().length() > 0)
{ {
sql= " select count(*) from roadpermit where rd_permit_no = ? "; sql= " select count(*) from roadpermit where rd_permit_no = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, rpermitTo); pstmt.setString(1, rpermitTo);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if(rs.next()) if(rs.next())
{ {
cnt = rs.getInt(1); cnt = rs.getInt(1);
} }
rs.close(); rs.close();
rs = null; rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
if(cnt == 0) if(cnt == 0)
{ {
errString = itmDBAccessEJB.getErrorString("","VPRDTO1","","",conn); errString = itmDBAccessEJB.getErrorString("","VPRDTO1","","",conn);
return errString; return errString;
} }
} }
if(rpermitFr.trim().length() > 0 && rpermitTo.trim().length() > 0) if(rpermitFr.trim().length() > 0 && rpermitTo.trim().length() > 0)
{ {
for(int i= rpermitFr.length()-1; i >= 0; i--) for(int i= rpermitFr.length()-1; i >= 0; i--)
{ {
countCharFr ++; countCharFr ++;
...@@ -207,17 +207,43 @@ public class RpermitUpdPrc extends ProcessEJB implements RpermitUpdPrcLocal,Rper ...@@ -207,17 +207,43 @@ public class RpermitUpdPrc extends ProcessEJB implements RpermitUpdPrcLocal,Rper
pattern2.append(rpermitTo.charAt(i)); pattern2.append(rpermitTo.charAt(i));
} }
} }
comp1 = pattern1.reverse().toString(); comp1 = pattern1.reverse().toString();
comp2= pattern2.reverse().toString(); comp2= pattern2.reverse().toString();
numStr1 = getter1.reverse().toString(); numStr1 = getter1.reverse().toString();
numStr2 = getter2.reverse().toString(); numStr2 = getter2.reverse().toString();
System.out.println("numStr1:"+numStr1+"numStr2:"+numStr2);
if(numStr1.trim().length() > 0 && numStr2.trim().length() > 0 ) ///
// String a1= "ABC2071025177533";
// String a2= "ABC2071025177600";
String common = "";
for( int i = 0 ; i< rpermitFr.length() && i< rpermitTo.length(); i++)
{
if( rpermitFr.charAt(i) == rpermitTo.charAt(i) )
{
common = common +rpermitFr.charAt(i);
}
}
String rpermitFrremaining = rpermitFr.substring(common.length(), rpermitFr.length());
String rpermitToremaining = rpermitTo.substring(common.length(), rpermitTo.length());
if(rpermitFrremaining.trim().length() > 0 && rpermitToremaining.trim().length() > 0 )
{ {
numFr = Integer.parseInt(numStr1); numFr = Integer.parseInt(rpermitFrremaining);
numTo = Integer.parseInt(numStr2); numTo = Integer.parseInt(rpermitToremaining);
} }
// if(!comp1.equals(comp2) || countCharTo!= countCharFr) ///
System.out.println("numStr1:"+numStr1+"numStr2:"+numStr2+"common["+common+"]");
// if(numStr1.trim().length() > 0 && numStr2.trim().length() > 0 )
// {
// numFr = Integer.parseInt(numStr1);
// numTo = Integer.parseInt(numStr2);
// }
// if(!comp1.equals(comp2) || countCharTo!= countCharFr)
if(!comp1.equals(comp2)) if(!comp1.equals(comp2))
{ {
errString = itmDBAccessEJB.getErrorString("","VPPATERN1 ","","",conn); errString = itmDBAccessEJB.getErrorString("","VPPATERN1 ","","",conn);
...@@ -230,51 +256,57 @@ public class RpermitUpdPrc extends ProcessEJB implements RpermitUpdPrcLocal,Rper ...@@ -230,51 +256,57 @@ public class RpermitUpdPrc extends ProcessEJB implements RpermitUpdPrcLocal,Rper
} }
else else
{ {
hmap.put("pattern1", comp1); // hmap.put("pattern1", comp1);
hmap.put("pattern2", comp2); // hmap.put("pattern2", comp2);
hmap.put("getter1", numStr1); // hmap.put("getter1", numStr1);
hmap.put("getter2", numStr2); // hmap.put("getter2", numStr2);
hmap.put("pattern1", common);
hmap.put("pattern2", common);
hmap.put("getter1", rpermitFrremaining);
hmap.put("getter2", rpermitToremaining);
} }
} }
if(siteCodeFr.trim().length() > 0) if(siteCodeFr.trim().length() > 0)
{ {
sql = "select count(*) from site where site_code = ? "; sql = "select count(*) from site where site_code = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, siteCodeFr); pstmt.setString(1, siteCodeFr);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if(rs.next()) if(rs.next())
{ {
cnt = rs.getInt(1); cnt = rs.getInt(1);
} }
rs.close(); rs.close();
rs = null; rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
if(cnt == 0) if(cnt == 0)
{ {
errString = itmDBAccessEJB.getErrorString("","VPSITECD1","","",conn); errString = itmDBAccessEJB.getErrorString("","VPSITECD1","","",conn);
return errString; return errString;
} }
} }
if(stateCodeFr.trim().length() > 0) if(stateCodeFr.trim().length() > 0)
{ {
sql = "select count(*) from state where state_code = ? "; sql = "select count(*) from state where state_code = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, stateCodeFr); pstmt.setString(1, stateCodeFr);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if(rs.next()) if(rs.next())
{ {
cnt = rs.getInt(1); cnt = rs.getInt(1);
} }
rs.close(); rs.close();
rs = null; rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
if(cnt == 0) if(cnt == 0)
{ {
errString = itmDBAccessEJB.getErrorString("","VPSTATCDFR","","",conn); errString = itmDBAccessEJB.getErrorString("","VPSTATCDFR","","",conn);
return errString; return errString;
} }
} }
if(errString == null || errString.trim().length() == 0) if(errString == null || errString.trim().length() == 0)
{ {
...@@ -284,60 +316,60 @@ public class RpermitUpdPrc extends ProcessEJB implements RpermitUpdPrcLocal,Rper ...@@ -284,60 +316,60 @@ public class RpermitUpdPrc extends ProcessEJB implements RpermitUpdPrcLocal,Rper
} }
catch( Exception e) catch( Exception e)
{ {
try try
{
conn.rollback();
}
catch (SQLException ex)
{
Logger.getLogger(RpermitUpdPrc.class.getName()).log(Level.SEVERE, null, ex);
}
e.printStackTrace();
}
finally
{
try
{
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(); conn.rollback();
} System.out.println("--no record found--");
catch (SQLException ex) errString = itmDBAccessEJB.getErrorString("","VTNOREC1 ","","",conn);
}
else
{ {
Logger.getLogger(RpermitUpdPrc.class.getName()).log(Level.SEVERE, null, ex); conn.rollback();
System.out.println("--process not completed--");
errString = itmDBAccessEJB.getErrorString("","VTEPFAIL ","","",conn);
} }
e.printStackTrace(); if( conn != null && ! conn.isClosed() )
}
finally
{
try
{ {
if((errString != null ) && (errString.indexOf("Success") > -1)) conn.close();
{ conn = null;
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);
}
if( conn != null && ! conn.isClosed() )
{
conn.close();
conn = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(rs != null)
{
rs.close();
rs = null;
}
} }
catch(Exception e) if(pstmt != null)
{ {
System.out.println("Exception : "+e);e.printStackTrace(); pstmt.close();
throw new ITMException(e); pstmt = null;
}
if(rs != null)
{
rs.close();
rs = null;
} }
} }
catch(Exception e)
{
System.out.println("Exception : "+e);e.printStackTrace();
throw new ITMException(e);
}
}
return errString; return errString;
} }
private String UpdateRPermit(HashMap gmap,String xtraParams,Connection conn) throws RemoteException, ITMException private String UpdateRPermit(HashMap gmap,String xtraParams,Connection conn) throws RemoteException, ITMException
...@@ -360,7 +392,7 @@ public class RpermitUpdPrc extends ProcessEJB implements RpermitUpdPrcLocal,Rper ...@@ -360,7 +392,7 @@ public class RpermitUpdPrc extends ProcessEJB implements RpermitUpdPrcLocal,Rper
String stateCodeFr = "",rpermitFr="",rpermitTo="",pattern1=""; String stateCodeFr = "",rpermitFr="",rpermitTo="",pattern1="";
try try
{ {
System.out.println("@@@@@@@ UpdateRPermit called::"); System.out.println("@@@@@@@ UpdateRPermit called::gmap["+gmap+"]");
genericUtility = GenericUtility.getInstance(); genericUtility = GenericUtility.getInstance();
SimpleDateFormat sdf1 = new SimpleDateFormat(genericUtility.getDBDateFormat()); SimpleDateFormat sdf1 = new SimpleDateFormat(genericUtility.getDBDateFormat());
if(((String)gmap.get("allocDateStr")) != null && ((String)gmap.get("allocDateStr")).trim().length() > 0) if(((String)gmap.get("allocDateStr")) != null && ((String)gmap.get("allocDateStr")).trim().length() > 0)
...@@ -385,41 +417,54 @@ public class RpermitUpdPrc extends ProcessEJB implements RpermitUpdPrcLocal,Rper ...@@ -385,41 +417,54 @@ public class RpermitUpdPrc extends ProcessEJB implements RpermitUpdPrcLocal,Rper
stateCodeFr = checkNull((String)gmap.get("stateCodeFr")); stateCodeFr = checkNull((String)gmap.get("stateCodeFr"));
remarks = (String)gmap.get("remarks"); remarks = (String)gmap.get("remarks");
//String pattern2 = (String)gmap.get("pattern2"); //String pattern2 = (String)gmap.get("pattern2");
if(rpermitFr != null && rpermitFr.trim().length()>0) if(rpermitFr != null && rpermitFr.trim().length()>0)
rpermitNoFr = Integer.parseInt(rpermitFr); rpermitNoFr = Integer.parseInt(rpermitFr);
if(rpermitTo != null && rpermitTo.trim().length()>0) if(rpermitTo != null && rpermitTo.trim().length()>0)
rpermitNoTo = Integer.parseInt(rpermitTo); rpermitNoTo = Integer.parseInt(rpermitTo);
range = rpermitNoTo - rpermitNoFr; range = rpermitNoTo - rpermitNoFr;
System.out.println("rpermitNoFr::"+rpermitNoFr+"rpermitNoTo:"+rpermitNoTo); System.out.println("rpermitNoFr::"+rpermitNoFr+"rpermitNoTo:"+rpermitNoTo);
if( gmap.get("rpermitFr").toString().equalsIgnoreCase(gmap.get("rpermitTo").toString()) )
{
range = 0;
}
System.out.println("@@@@@@ range["+range+"]pattern1+rpermitFr["+pattern1+""+rpermitFr+"]");
for(int k = 0;k<= range;k++) for(int k = 0;k<= range;k++)
{ {
sql = "update roadpermit set site_code__fr = ? , alloc_date = ?,state_code__fr = ?,recpt_date = ?, remarks = ?, " + 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 = ? "; " chg_term = ? , chg_user = ? , chg_date = ? where rd_permit_no = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, siteCodeFr); pstmt.setString(1, siteCodeFr);
pstmt.setTimestamp(2, allocDate); pstmt.setTimestamp(2, allocDate);
pstmt.setString(3, stateCodeFr); pstmt.setString(3, stateCodeFr);
pstmt.setTimestamp(4, rcpDate); pstmt.setTimestamp(4, rcpDate);
pstmt.setString(5, remarks); pstmt.setString(5, remarks);
pstmt.setString(6, chgTerm); pstmt.setString(6, chgTerm);
pstmt.setString(7, chgUser); pstmt.setString(7, chgUser);
pstmt.setTimestamp(8, currDate); pstmt.setTimestamp(8, currDate);
pstmt.setString(9, pattern1+rpermitFr); pstmt.setString(9, pattern1+rpermitFr);
inRows = inRows+ pstmt.executeUpdate(); inRows = inRows+ pstmt.executeUpdate();
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
zeros=""; zeros="";
num = Integer.parseInt(rpermitFr);
num ++; if( rpermitFr != null && (!"".equalsIgnoreCase(rpermitFr)) )
numStr = Integer.toString(num); {
for(int i = 1; i <= rpermitFr.length() - numStr.length();i++) System.out.println("@@@@@ inside if...rpermitFr["+rpermitFr+"].");
{ num = Integer.parseInt(rpermitFr);
zeros = zeros+0 ; num ++;
} numStr = Integer.toString(num);
rpermitFr = zeros+num; for(int i = 1; i <= rpermitFr.length() - numStr.length();i++)
System.out.println("result string "+rpermitFr); {
zeros = zeros+0 ;
}
rpermitFr = zeros+num;
}
System.out.println("result string "+rpermitFr);
} }
System.out.println("No.Of Rows updated ::"+inRows); System.out.println("No.Of Rows updated ::"+inRows);
if(inRows > 0) if(inRows > 0)
......
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