Commit 1da743cc authored by cpatil's avatar cpatil

modify msg code


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@94351 ce508802-f39f-4f6c-b175-0d175dae99d5
parent ced6d0b2
...@@ -117,6 +117,24 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa ...@@ -117,6 +117,24 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa
} }
sql = "select status from roadpermit where rd_permit_no = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,oldPermNo);
rs = pstmt.executeQuery();
if(rs.next())
{
status = rs.getString("status") ;
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if("C".equalsIgnoreCase(status))
{
retString = itmDBAccessEJB.getErrorString("", "VMRSTCLOS1", "", "", conn);
return retString;
}
sql = "select status from roadpermit where rd_permit_no = ? "; sql = "select status from roadpermit where rd_permit_no = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
...@@ -133,16 +151,56 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa ...@@ -133,16 +151,56 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa
if("C".equalsIgnoreCase(status)) if("C".equalsIgnoreCase(status))
{ {
retString = itmDBAccessEJB.getErrorString("", "VMRSTCLOSE", "", "", conn); retString = itmDBAccessEJB.getErrorString("", "VMRSTCLOS2", "", "", conn);
return retString; return retString;
} }
sql = "select count(1) from distord_iss where rd_permit_no = ? and lr_no not in ( select lr_no from distord_iss where rd_permit_no = ? )"; // select count ( distinct lr_no ) from tarodev.distord_iss where rd_permit_no = 'TEST2' ;
sql = " select count ( distinct lr_no ) from tarodev.distord_iss where rd_permit_no = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,newPermNo);
rs = pstmt.executeQuery();
if(rs.next())
{
count = rs.getInt(1) ;
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if( count > 1 )
{
retString = itmDBAccessEJB.getErrorString("", "VMNEWPNOI2", "", "", conn);
return retString;
}
/*
sql = " select count ( distinct rd_permit_no ) from tarodev.distord_iss where lr_no = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,newPermNo);
rs = pstmt.executeQuery();
if(rs.next())
{
count = rs.getInt(1) ;
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if( count > 1 )
{
retString = itmDBAccessEJB.getErrorString("", "VMNEWPNOI3", "", "", conn);
return retString;
}
*/
sql = " select count(1) from distord_iss where rd_permit_no = ? " +
" and lr_no not in ( select lr_no from distord_iss where rd_permit_no = ? ) ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1,newPermNo); pstmt.setString(1,newPermNo);
pstmt.setString(2,oldPermNo); pstmt.setString(2,oldPermNo);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
while(rs.next()) if(rs.next())
{ {
count = rs.getInt(1) ; count = rs.getInt(1) ;
} }
...@@ -157,6 +215,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa ...@@ -157,6 +215,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa
return retString; return retString;
} }
System.out.println("@@@@newPermNo["+newPermNo+"]::status["+status+"]::oldPermNo["+oldPermNo+"]@@@@@@@"); System.out.println("@@@@newPermNo["+newPermNo+"]::status["+status+"]::oldPermNo["+oldPermNo+"]@@@@@@@");
if( retString == null || retString.trim().length() == 0 ) if( retString == null || retString.trim().length() == 0 )
...@@ -267,7 +326,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa ...@@ -267,7 +326,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa
{ {
isError = true; isError = true;
System.out.println("@@@@@ ret str in catch ["+retString+"]@@@@@@@@"); System.out.println("@@@@@ ret str in catch ["+retString+"]@@@@@@@@");
retString = itmDBAccessEJB.getErrorString("", "VMMPFAIL", "", "", conn); retString = itmDBAccessEJB.getErrorString("", "VMMPFAIL9", "", "", conn);
throw new ITMException(e); throw new ITMException(e);
} }
...@@ -279,7 +338,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa ...@@ -279,7 +338,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa
if ( retString != null && retString.trim().length() > 0 ) if ( retString != null && retString.trim().length() > 0 )
{ {
conn.rollback(); conn.rollback();
retString = itmDBAccessEJB.getErrorString("", "VMMPFAIL", "", "", conn); // retString = itmDBAccessEJB.getErrorString("", "VMMPFAIL9", "", "", conn);
} }
else else
{ {
...@@ -454,7 +513,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa ...@@ -454,7 +513,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa
String sql = "", stateCodeDespatch="",siteCodeShipDespatch="",siteCodeToRDPermit="",stateCodeToRDPermit=""; String sql = "", stateCodeDespatch="",siteCodeShipDespatch="",siteCodeToRDPermit="",stateCodeToRDPermit="";
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB(); ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
Timestamp despDate= null,expiryDate=null; Timestamp despDate= null,expiryDate=null;
int despatchCntr = 0 ;
sql = " select sorder.site_code__ship ,customer.state_code from sorder , customer where sale_order in ( select sord_no from despatch" + sql = " select sorder.site_code__ship ,customer.state_code from sorder , customer where sale_order in ( select sord_no from despatch" +
" where desp_id in ( select desp_id from despatch where rd_permit_no = ? )) and sorder.cust_code__dlv = customer.cust_code " ; " where desp_id in ( select desp_id from despatch where rd_permit_no = ? )) and sorder.cust_code__dlv = customer.cust_code " ;
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
...@@ -462,6 +521,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa ...@@ -462,6 +521,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if(rs.next()) if(rs.next())
{ {
despatchCntr++;
siteCodeShipDespatch = rs.getString("site_code__ship") ; siteCodeShipDespatch = rs.getString("site_code__ship") ;
stateCodeDespatch = rs.getString("state_code") ; stateCodeDespatch = rs.getString("state_code") ;
} }
...@@ -485,13 +545,13 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa ...@@ -485,13 +545,13 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
System.out.println("@@@@@@@siteCodeShipDespatch["+siteCodeShipDespatch+"]:::siteCodeToRDPermit["+siteCodeToRDPermit+"]"); System.out.println("@@@@@@@siteCodeShipDespatch["+siteCodeShipDespatch+"]:::siteCodeToRDPermit["+siteCodeToRDPermit+"]");
if(!( siteCodeShipDespatch.equalsIgnoreCase(siteCodeToRDPermit) )) if( despatchCntr > 0 && (! siteCodeShipDespatch.equalsIgnoreCase(siteCodeToRDPermit) ))
{ {
retString = itmDBAccessEJB.getErrorString("", "VMSITDCDMI", "", "", conn); retString = itmDBAccessEJB.getErrorString("", "VMSITDCDMI", "", "", conn);
return retString; return retString;
} }
System.out.println("@@@@@@@stateCodeDespatch["+stateCodeDespatch+"]:::stateCodeToRDPermit["+stateCodeToRDPermit+"]"); System.out.println("@@@@@@@stateCodeDespatch["+stateCodeDespatch+"]:::stateCodeToRDPermit["+stateCodeToRDPermit+"]");
if(!( stateCodeDespatch.equalsIgnoreCase(stateCodeToRDPermit) )) if( despatchCntr > 0 && (! stateCodeDespatch.equalsIgnoreCase(stateCodeToRDPermit) ))
{ {
retString = itmDBAccessEJB.getErrorString("", "VMSTADCDMI", "", "", conn); retString = itmDBAccessEJB.getErrorString("", "VMSTADCDMI", "", "", conn);
return retString; return retString;
...@@ -510,7 +570,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa ...@@ -510,7 +570,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
System.out.println("@@@@@@@despDate["+despDate+"]:::expiryDate["+expiryDate+"]"); System.out.println("@@@@@@@despDate["+despDate+"]:::expiryDate["+expiryDate+"]");
if( despDate == null ) if( despatchCntr > 0 && despDate == null )
{ {
retString = itmDBAccessEJB.getErrorString("", "VMDATEDMI7", "", "", conn); retString = itmDBAccessEJB.getErrorString("", "VMDATEDMI7", "", "", conn);
return retString; return retString;
...@@ -520,7 +580,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa ...@@ -520,7 +580,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa
retString = itmDBAccessEJB.getErrorString("", "VMDATEDM13", "", "", conn); retString = itmDBAccessEJB.getErrorString("", "VMDATEDM13", "", "", conn);
return retString; return retString;
} }
if( despDate.after(expiryDate)) if( despatchCntr > 0 && despDate.after(expiryDate))
{ {
retString = itmDBAccessEJB.getErrorString("", "VMDATEDMIS", "", "", conn); retString = itmDBAccessEJB.getErrorString("", "VMDATEDMIS", "", "", conn);
return retString; return retString;
...@@ -539,6 +599,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa ...@@ -539,6 +599,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa
String sql = "", siteCodeIssue="",stateCodeIssue="",siteCodeFromRDPermit="",stateCodeToRDPermit=""; String sql = "", siteCodeIssue="",stateCodeIssue="",siteCodeFromRDPermit="",stateCodeToRDPermit="";
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB(); ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
Timestamp tranDate= null,expiryDate=null; Timestamp tranDate= null,expiryDate=null;
int distIssCntr = 0;
sql = "select site_code, state_code from site where site_code in ( select site_code__dlv from distord_iss where rd_permit_no = ? ) "; sql = "select site_code, state_code from site where site_code in ( select site_code__dlv from distord_iss where rd_permit_no = ? ) ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
...@@ -546,6 +607,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa ...@@ -546,6 +607,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if(rs.next()) if(rs.next())
{ {
distIssCntr++;
siteCodeIssue = rs.getString("site_code") ; siteCodeIssue = rs.getString("site_code") ;
stateCodeIssue = rs.getString("state_code") ; stateCodeIssue = rs.getString("state_code") ;
} }
...@@ -570,13 +632,13 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa ...@@ -570,13 +632,13 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa
pstmt = null; pstmt = null;
System.out.println("@@@@@@@siteCodeIssue["+siteCodeIssue+"]:::siteCodeFromRDPermit["+siteCodeFromRDPermit+"]"); System.out.println("@@@@@@@siteCodeIssue["+siteCodeIssue+"]:::siteCodeFromRDPermit["+siteCodeFromRDPermit+"]");
if(!( siteCodeIssue.equalsIgnoreCase(siteCodeFromRDPermit) )) if( distIssCntr > 0 && ( ! siteCodeIssue.equalsIgnoreCase(siteCodeFromRDPermit) ))
{ {
retString = itmDBAccessEJB.getErrorString("", "VMSITECDDM", "", "", conn); retString = itmDBAccessEJB.getErrorString("", "VMSITECDDM", "", "", conn);
return retString; return retString;
} }
System.out.println("@@@@@@@stateCodeIssue["+stateCodeIssue+"]:::stateCodeToRDPermit["+stateCodeToRDPermit+"]"); System.out.println("@@@@@@@stateCodeIssue["+stateCodeIssue+"]:::stateCodeToRDPermit["+stateCodeToRDPermit+"]");
if(!( stateCodeIssue.equalsIgnoreCase(stateCodeToRDPermit) )) if( distIssCntr > 0 && ( ! stateCodeIssue.equalsIgnoreCase(stateCodeToRDPermit) ))
{ {
retString = itmDBAccessEJB.getErrorString("", "VMSTATCDDM", "", "", conn); retString = itmDBAccessEJB.getErrorString("", "VMSTATCDDM", "", "", conn);
return retString; return retString;
...@@ -596,7 +658,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa ...@@ -596,7 +658,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa
pstmt = null; pstmt = null;
System.out.println("@@@@@@@tranDate["+tranDate+"]:::expiryDate["+expiryDate+"]"); System.out.println("@@@@@@@tranDate["+tranDate+"]:::expiryDate["+expiryDate+"]");
if( tranDate == null ) if( distIssCntr > 0 && tranDate == null )
{ {
retString = itmDBAccessEJB.getErrorString("", "VMDATEDM12", "", "", conn); retString = itmDBAccessEJB.getErrorString("", "VMDATEDM12", "", "", conn);
return retString; return retString;
...@@ -608,7 +670,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa ...@@ -608,7 +670,7 @@ public class RoadPerRepPrc extends ProcessEJB implements RoadPerRepPrcLocal ,Roa
return retString; return retString;
} }
if( tranDate.after(expiryDate)) if( distIssCntr > 0 && tranDate.after(expiryDate))
{ {
retString = itmDBAccessEJB.getErrorString("", "VMDATEDMI", "", "", conn); retString = itmDBAccessEJB.getErrorString("", "VMDATEDMI", "", "", conn);
return retString; return retString;
......
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