Skip to content

B
business-java
Commit ec43c071 authored by agaikwad's avatar agaikwad
Browse files
Options

Request_Id-F16IFRA002 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@104991 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 6676ebf0
Hide whitespace changes
Inline Side-by-side
Showing with 639 additions and 11 deletions
webitm-fin/ibase/webitm/ejb/fin/adv/UndoRecievableAdjAct.java 0 → 100755
View file @ ec43c071
package ibase.webitm.ejb.fin.adv;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import javax.ejb.Stateless;
import org.w3c.dom.Document;
import ibase.system.config.ConnDriver;
import ibase.webitm.ejb.ActionHandlerEJB;
import ibase.webitm.ejb.ITMDBAccessEJB;
//import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.utility.ITMException;
@Stateless
public class UndoRecievableAdjAct extends ActionHandlerEJB implements UndoRecievableAdjActLocal, UndoRecievableAdjActRemote
{
ibase.utility.E12GenericUtility genericUtility= new ibase.utility.E12GenericUtility();
ITMDBAccessEJB itmDBAccess = new ITMDBAccessEJB();
public String actionHandler() throws RemoteException,ITMException
{
return "";
}
public String actionHandler(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException,ITMException
{
String retString = "";
Document dom = null;
try
{
System.out.println("Call method =Action handler");
System.out.println("action Type====="+actionType);
if (actionType.equalsIgnoreCase("Adj Amount"))
{
if(xmlString != null && xmlString.trim().length()!=0)
{
System.out.println("XML String :"+xmlString);
dom = new ibase.utility.E12GenericUtility().parseString(xmlString);
System.out.println("dom :"+dom);
}
retString = actionDlvTerm(dom,objContext,xtraParams);
}
}
catch(Exception e)
{
System.out.println("Exception actionHandler(String xmlString):" + e.getMessage() + ":");
throw new ITMException(e);
}
return retString;
}
private String actionDlvTerm(Document dom, String objContext, String xtraParams) throws RemoteException , ITMException
{
String sql = "", sql1="";
String refNoHeader="",tranType="",tranId="",remarks="",refNo="",refSer="",adjAmt="";
ResultSet rs = null,rs1=null;
Connection conn = null;
Statement stmt = null;
PreparedStatement pstmt = null;
PreparedStatement pstmt1 = null;
StringBuffer valueXmlString = new StringBuffer("<?xml version=\"1.0\"?>\r\n<Root>\r\n");
ConnDriver connDriver = new ConnDriver();
try
{
conn = connDriver.getConnectDB("DriverITM");
int undoLineNo=1;
refNoHeader = checkNull(genericUtility.getColumnValue("ref_no",dom));
System.out.println("ref_no["+refNoHeader+"]");
tranType = checkNull(genericUtility.getColumnValue("tran_type",dom));
tranId=checkNull(genericUtility.getColumnValue("tran_id",dom));
remarks=checkNull(genericUtility.getColumnValue("remarks",dom));
sql="select ref_no,ref_ser,adj_amt from receivables_adj where ref_no_adj= ? and ref_ser_adj= ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, refNoHeader);
pstmt.setString(2, tranType);
rs = pstmt.executeQuery();
while (rs.next())
{
refNo=rs.getString(1);
refSer=rs.getString(2);
adjAmt =rs.getString(3);
sql="select ref_no,ref_ser,adj_amt from receivables_adj where ref_no_adj= ? and ref_ser_adj= ? and ref_no=? and ref_ser = ? and adj_amt= ?";
pstmt1 = conn.prepareStatement(sql);
pstmt1.setString(1, refNoHeader);
pstmt1.setString(2, tranType);
pstmt1.setString(3, refNo);
pstmt1.setString(4, refSer);
pstmt1.setString(5, adjAmt);
rs1 = pstmt1.executeQuery();
while (rs1.next())
{
valueXmlString.append("<Detail>\r\n");
/* if(tranId != null & tranId.trim().length() >0)
{*/
valueXmlString.append("<tran_id>").append("<![CDATA[").append(tranId).append("]]>").append("</tran_id>\r\n");
/* }
else
{
tranId=" ";
valueXmlString.append("<tran_id>").append("<![CDATA[").append(tranId).append("]]>").append("</tran_id>\r\n");
}*/
valueXmlString.append("<line_no>").append("<![CDATA[").append(undoLineNo).append("]]>").append("</line_no>\r\n");
valueXmlString.append("<ref_no>").append("<![CDATA[").append(rs1.getString(1).trim()).append("]]>").append("</ref_no>\r\n");
valueXmlString.append("<ref_ser>").append("<![CDATA[").append(rs1.getString(2).trim()).append("]]>").append("</ref_ser>\r\n");
valueXmlString.append("<adj_amt>").append("<![CDATA[").append(rs1.getString(3).trim()).append("]]>").append("</adj_amt>\r\n");
valueXmlString.append("<remarks>").append("<![CDATA[").append(remarks).append("]]>").append("</remarks>\r\n");
undoLineNo++;
System.out.println("undoLineNo["+undoLineNo+"]");
valueXmlString.append("</Detail>\r\n");
}
rs1.close();
rs1 = null;
pstmt1.close();
pstmt1 = null;
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
valueXmlString.append("</Root>\r\n");
}
catch(SQLException e)
{
System.out.println("Exception : Undo Detail...." +e.getMessage());
throw new ITMException(e);
}
catch(Exception e)
{
System.out.println("Exception" +e.getMessage());
throw new ITMException(e);
}
finally
{
try
{
conn.close();
conn = null;
}
catch(Exception e){}
}
System.out.println("valueXmlString.toString() "+valueXmlString.toString());
return valueXmlString.toString();
}
private String checkNull(String input)
{
if (input == null)
{
input="";
}
return input;
}
}
webitm-fin/ibase/webitm/ejb/fin/adv/UndoRecievableAdjActLocal.java 0 → 100755
View file @ ec43c071
package ibase.webitm.ejb.fin.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local; // added for ejb3
@Local
public interface UndoRecievableAdjActLocal extends ActionHandlerLocal
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException,ITMException;public String actionHandler(String actionType, String xmlString, String xmlString1, String objContext, String xtraParams) throws RemoteException,ITMException;
}
webitm-fin/ibase/webitm/ejb/fin/adv/UndoRecievableAdjActRemote.java 0 → 100755
View file @ ec43c071
package ibase.webitm.ejb.fin.adv;
import java.rmi.RemoteException;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerRemote;
import javax.ejb.Remote;
@Remote
public interface UndoRecievableAdjActRemote extends ActionHandlerRemote
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException,ITMException;
}
webitm-fin/ibase/webitm/ejb/fin/adv/UndoRecievableAdjConf.java
View file @ ec43c071
...@@ -28,6 +28,9 @@ import java.sql.Timestamp; ...@@ -28,6 +28,9 @@ import java.sql.Timestamp;
import ibase.utility.E12GenericUtility; import ibase.utility.E12GenericUtility;
import javax.ejb.Stateless; import javax.ejb.Stateless;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
@Stateless @Stateless
public class UndoRecievableAdjConf extends ActionHandlerEJB implements UndoRecievableAdjConfLocal,UndoRecievableAdjConfRemote public class UndoRecievableAdjConf extends ActionHandlerEJB implements UndoRecievableAdjConfLocal,UndoRecievableAdjConfRemote
{ {
...@@ -41,13 +44,17 @@ public class UndoRecievableAdjConf extends ActionHandlerEJB implements UndoRecie ...@@ -41,13 +44,17 @@ public class UndoRecievableAdjConf extends ActionHandlerEJB implements UndoRecie
String confirmed=""; String confirmed="";
ResultSet rs = null,rs1=null; ResultSet rs = null,rs1=null;
PreparedStatement pstmt = null,pstmt1=null; PreparedStatement pstmt = null,pstmt1=null;
ResultSet rs2 = null;
PreparedStatement pstmt2 = null;
// GenericUtility genericUtility = null; // GenericUtility genericUtility = null;
Connection conn = null; Connection conn = null;
ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB(); ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
//ConnDriver connDriver = new ConnDriver(); //ConnDriver connDriver = new ConnDriver();
String errString = null; String errString = null;
String errString1 = null;
int cnt=0,updCnt=0,updCnt1=0,updCnt2=0,undoLineNo=1,upCnt=0,upCount=0; int cnt=0,updCnt=0,updCnt1=0,updCnt2=0,undoLineNo=1,upCnt=0,upCount=0;
int cnt1=0;
String refNo="",refSer="",refNoHeader="",tranType=""; String refNo="",refSer="",refNoHeader="",tranType="";
double adjAmt=0,totalAmt=0,sumAdjAmt=0,adjAmt1=0,totalAmt1=0,adjAmt2=0,totalAmt2=0; double adjAmt=0,totalAmt=0,sumAdjAmt=0,adjAmt1=0,totalAmt1=0,adjAmt2=0,totalAmt2=0;
String loginEmpCode="",statusBef=""; String loginEmpCode="",statusBef="";
...@@ -63,18 +70,48 @@ public class UndoRecievableAdjConf extends ActionHandlerEJB implements UndoRecie ...@@ -63,18 +70,48 @@ public class UndoRecievableAdjConf extends ActionHandlerEJB implements UndoRecie
ConnDriver connDriver = null; ConnDriver connDriver = null;
connDriver = new ConnDriver(); connDriver = new ConnDriver();
//Changes and Commented By Bhushan on 06-06-2016 :START //Changes and Commented By Bhushan on 06-06-2016 :START
//conn = connDriver.getConnectDB("DriverITM"); //conn = connDriver.getConnectDB("DriverITM");
conn = getConnection(); conn = getConnection();
//Changes and Commented By Bhushan on 06-06-2016 :END //Changes and Commented By Bhushan on 06-06-2016 :END
conn.setAutoCommit(false); conn.setAutoCommit(false);
userId = e12GenericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode"); userId = e12GenericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode");
System.out.println("--login code--"+userId); System.out.println("--login code--"+userId);
System.out.println("xtraParams:"+xtraParams);
System.out.println("Getting Tran_ID=============="+tranId); if(tranId!=null && tranId.trim().length()>0)
if(tranId!=null && tranId.trim().length()>0) {
{ sql="select count(*) from undo_rec_adjdet where tran_id=? ";
System.out.println("@@@@@tranId"+tranId+"]"); pstmt2 = conn.prepareStatement(sql);
pstmt2.setString(1, tranId);
rs2 = pstmt2.executeQuery();
if (rs2.next())
{
cnt1 = rs2.getInt(1);
}
rs2.close();
rs2 = null;
pstmt2.close();
pstmt2 = null;
System.out.println("cnt1==========="+cnt1);
if(cnt1 > 0)
{
errString1= undoRecivablesDet(tranId,conn);
System.out.println("Errstring1#################["+errString1+"]");
if(errString1 !=null && errString1.trim().length() > 0)
{
System.out.println("errString1 !=null["+errString1+"]");
errString=errString1;
System.out.println("errString !=null["+errString+"]");
}
}
else
{
System.out.println("Else#######################");
System.out.println("Getting Tran_ID ELSE=============="+tranId);
/* if(tranId!=null && tranId.trim().length()>0)
{*/
System.out.println("@@@@@tranId Else"+tranId+"]");
sql = " select confirmed from undo_rec_adj where tran_id = ? "; sql = " select confirmed from undo_rec_adj where tran_id = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
...@@ -90,7 +127,7 @@ conn = getConnection(); ...@@ -90,7 +127,7 @@ conn = getConnection();
rs = null; rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
sql="";
if ("Y".equalsIgnoreCase(confirmed)) if ("Y".equalsIgnoreCase(confirmed))
{ {
System.out.println("transaction already confirmed"); System.out.println("transaction already confirmed");
...@@ -149,7 +186,6 @@ conn = getConnection(); ...@@ -149,7 +186,6 @@ conn = getConnection();
} }
else else
{ {
System.out.println("Record exist in receivables_adj>>>>>>>>> "); System.out.println("Record exist in receivables_adj>>>>>>>>> ");
sql="select ref_ser,ref_no,adj_amt from receivables_adj where ref_no_adj= ? and ref_ser_adj= ? "; sql="select ref_ser,ref_no,adj_amt from receivables_adj where ref_no_adj= ? and ref_ser_adj= ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
...@@ -159,6 +195,7 @@ conn = getConnection(); ...@@ -159,6 +195,7 @@ conn = getConnection();
while (rs.next()) while (rs.next())
{ {
System.out.println("@@@@@@ inside while "); System.out.println("@@@@@@ inside while ");
refSer = rs.getString("ref_ser"); refSer = rs.getString("ref_ser");
...@@ -168,6 +205,23 @@ conn = getConnection(); ...@@ -168,6 +205,23 @@ conn = getConnection();
System.out.println("refNo==========="+refNo); System.out.println("refNo==========="+refNo);
System.out.println("refSer==========="+refSer); System.out.println("refSer==========="+refSer);
System.out.println("adjAmt==========="+adjAmt); System.out.println("adjAmt==========="+adjAmt);
sql="select ref_ser, ref_no , adj_amt from undo_rec_adjdet where ref_ser=? and ref_no=? and adj_amt=?";
pstmt2 = conn.prepareStatement(sql);
pstmt2.setString(1, refSer);
pstmt2.setString(2, refNo);
pstmt2.setDouble(3, adjAmt);
rs2 = pstmt2.executeQuery();
if (rs2.next())
{
refSer = rs2.getString("ref_ser");
refNo = rs2.getString("ref_no");
adjAmt = rs2.getDouble("adj_amt");
}
rs2.close();
rs2 = null;
pstmt2.close();
pstmt2 = null;
sql1="insert into undo_rec_adjdet(tran_id,line_no,ref_no,ref_ser,adj_amt) values(?,?,?,?,?)"; sql1="insert into undo_rec_adjdet(tran_id,line_no,ref_no,ref_ser,adj_amt) values(?,?,?,?,?)";
pstmt1 = conn.prepareStatement(sql1); pstmt1 = conn.prepareStatement(sql1);
...@@ -424,7 +478,8 @@ conn = getConnection(); ...@@ -424,7 +478,8 @@ conn = getConnection();
} }
} }
} }
}//else
} }
...@@ -487,9 +542,383 @@ conn = getConnection(); ...@@ -487,9 +542,383 @@ conn = getConnection();
System.out.println(""); System.out.println("");
return errString ; return errString ;
} }
private String undoRecivablesDet(String tranId, Connection conn)
{
String sql = "",sql1="";
String confirmed="";
ResultSet rs = null,rs1=null;
PreparedStatement pstmt = null,pstmt1=null;
ResultSet rs2 = null;
PreparedStatement pstmt2 = null;
ITMDBAccessEJB itmDBAccessLocal = new ITMDBAccessEJB();
String errString = null;
int cnt=0,updCnt=0,updCnt1=0,updCnt2=0,undoLineNo=1,upCnt=0,upCount=0;
int cnt1=0;
String refNoHeader="",tranType="";
double totalAmt=0,sumAdjAmt=0,adjAmt1=0,totalAmt1=0,adjAmt2=0,totalAmt2=0,adjAmt=0;
String loginEmpCode="",statusBef="";
Timestamp sysDate = null;
String refNo="",refSer="";
try
{
E12GenericUtility genericUtility = new E12GenericUtility();
System.out.println("transaction not confirmed");
Calendar currentDate = Calendar.getInstance();
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
String sysDateStr = sdf.format(currentDate.getTime());
System.out.println("Now the date is :=> " + sysDateStr);
sysDate= Timestamp.valueOf(genericUtility.getValidDateString(sysDateStr, genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat()) + " 00:00:00.0");
System.out.println(">>>>>>>>sysDate:"+sysDate);
System.out.println(">>>>>>>>loginEmpCode:"+loginEmpCode);
sql="select ref_no,tran_type from undo_rec_adj where tran_id= ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if(rs.next())
{
refNoHeader = rs.getString("ref_no");
tranType= rs.getString("tran_type");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("@@@@@@ refNo from undo_rec_adj " + refNo);
System.out.println("@@@@@@ tranType from undo_rec_adj " + tranType);
//added
sql="select count(1) from receivables_adj where ref_no_adj= ? and ref_ser_adj= ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, refNoHeader);
pstmt.setString(2, tranType);
rs = pstmt.executeQuery();
if(rs.next())
{
cnt=rs.getInt(1);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if(cnt==0)
{
System.out.println("Record not exist in receivables_adj>>>>>>>>>:"+cnt);
errString = itmDBAccessLocal.getErrorString("","VTREF03","");
}
else
{
System.out.println("Record exist in receivables_adj>>>>>>>>> ");
sql="select ref_ser,ref_no,adj_amt from receivables_adj where ref_no_adj= ? and ref_ser_adj= ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, refNoHeader);
pstmt.setString(2, tranType);
rs = pstmt.executeQuery();
while (rs.next())
{
System.out.println("@@@@@@ inside while ");
refSer = rs.getString("ref_ser");
refNo = rs.getString("ref_no");
adjAmt = rs.getDouble("adj_amt");
System.out.println("refNo==========="+refNo);
System.out.println("refSer==========="+refSer);
System.out.println("adjAmt==========="+adjAmt);
sql="select ref_ser, ref_no , adj_amt from undo_rec_adjdet where ref_ser=? and ref_no=? and adj_amt=?";
pstmt2 = conn.prepareStatement(sql);
pstmt2.setString(1, refSer);
pstmt2.setString(2, refNo);
pstmt2.setDouble(3, adjAmt);
rs2 = pstmt2.executeQuery();
if (rs2.next())
{
refSer = rs2.getString("ref_ser");
refNo = rs2.getString("ref_no");
adjAmt = rs2.getDouble("adj_amt");
}
rs2.close();
rs2 = null;
pstmt2.close();
pstmt2 = null;
/*
sql1="insert into undo_rec_adjdet(tran_id,line_no,ref_no,ref_ser,adj_amt) values(?,?,?,?,?)";
pstmt1 = conn.prepareStatement(sql1);
pstmt1.setString(1,tranId);
pstmt1.setInt(2,undoLineNo);
pstmt1.setString(3,refNo);
pstmt1.setString(4,refSer);
pstmt1.setDouble(5,adjAmt);
pstmt1.executeUpdate();
pstmt1.close();
pstmt1 = null; */
sumAdjAmt=sumAdjAmt+adjAmt;
System.out.println("SumADJAMOUNT============"+sumAdjAmt);
sql1=" update receivables set adj_amt =adj_amt-? where ref_no= ? and tran_ser=?";
pstmt1 = conn.prepareStatement(sql1);
pstmt1.setDouble(1, adjAmt);
pstmt1.setString(2, refNo);
pstmt1.setString(3, refSer);
updCnt = pstmt1.executeUpdate();
pstmt1.close();
pstmt1 = null;
System.out.println("@@@updCnt========["+updCnt+"]");
System.out.println("Status Checking*********");
sql1="select tot_amt,adj_amt,status from receivables where ref_no= ? and tran_ser=?";
pstmt1 = conn.prepareStatement(sql1);
pstmt1.setString(1, refNo);
pstmt1.setString(2, refSer);
rs1 = pstmt1.executeQuery();
if(rs1.next())
{
totalAmt1=Math.abs(rs1.getDouble("tot_amt"));
adjAmt1=Math.abs(rs1.getDouble("adj_amt"));
statusBef=rs1.getString("status");
}
rs1.close();
rs1 = null;
pstmt1.close();
pstmt1 = null;
System.out.println("totalAmt1============"+totalAmt1);
System.out.println("adjAmt1============"+adjAmt1);
System.out.println("statusBef============"+statusBef);
if(adjAmt1==0)
{
status="U";
System.out.println("adjAmt1==0*********");
}
else if(adjAmt1==totalAmt1)
{
System.out.println("adjAmt1==totalAmt1*********");
status="A";
}
else if(adjAmt1!=0 && totalAmt1>adjAmt1)
{
System.out.println("totalAmt1>adjAmt1*********");
status="P";
}
System.out.println("status=****-========="+status);
System.out.println("refNo=-========="+refNo);
System.out.println("refSer=-========="+refSer);
sql1=" update receivables set status = ? where ref_no= ? and tran_ser=?";
pstmt1 = conn.prepareStatement(sql1);
pstmt1.setString(1, status);
pstmt1.setString(2, refNo);
pstmt1.setString(3, refSer);
upCount = pstmt1.executeUpdate();
pstmt1.close();
pstmt1= null;
sql1="delete from receivables_adj where ref_no=? and ref_ser=? and ref_no_adj= ? and ref_ser_adj= ?";
pstmt1 = conn.prepareStatement(sql1);
pstmt1.setString(1, refNo);
pstmt1.setString(2, refSer);
pstmt1.setString(3, refNoHeader);//Changed by Manoj dtd 04/03/2016 to delete only undo invoice
pstmt1.setString(4, tranType);
pstmt1.executeUpdate();
System.out.println("Data deleted sucessfully");
undoLineNo++;
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("SumADJAMOUNT11111111111============"+sumAdjAmt);
if(sumAdjAmt>0)
{
sql="update receivables_adj set adj_amt= adj_amt - ? where ref_no= ? and ref_ser= ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setDouble(1, sumAdjAmt);
pstmt.setString(2, refNoHeader);
pstmt.setString(3, tranType);
updCnt1 = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
System.out.println("@@@updCnt=receivables_adj=========["+updCnt1+"]");
sql1=" update receivables set adj_amt =adj_amt-? where ref_no= ? and tran_ser=?";
pstmt1 = conn.prepareStatement(sql1);
pstmt1.setDouble(1, sumAdjAmt);
pstmt1.setString(2, refNoHeader);
pstmt1.setString(3, tranType);
updCnt2 = pstmt1.executeUpdate();
pstmt1.close();
pstmt1 = null;
System.out.println("@@@updCnt for receivables========["+updCnt2+"]");
sql1="update INVOICE set adj_amount= adj_amount- ? WHERE invoice_id= ?";
pstmt = conn.prepareStatement(sql1);
pstmt.setDouble(1, sumAdjAmt);
pstmt.setString(2, refNoHeader);
updCnt = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
System.out.println("@@@updCnt ===INVOICE===["+updCnt+"]");
}
else
{
sql="update receivables_adj set adj_amt= adj_amt + ? where ref_no= ? and ref_ser= ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setDouble(1, sumAdjAmt);
pstmt.setString(2, refNoHeader);
pstmt.setString(3, tranType);
updCnt1 = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
System.out.println("@@@updCnt== receivables_adj========["+updCnt1+"]");
sql1=" update receivables set adj_amt =adj_amt + ? where ref_no= ? and tran_ser=?";
pstmt1 = conn.prepareStatement(sql1);
pstmt1.setDouble(1, sumAdjAmt);
pstmt1.setString(2, refNoHeader);
pstmt1.setString(3, tranType);
updCnt2 = pstmt1.executeUpdate();
pstmt1.close();
pstmt1 = null;
System.out.println("@@@updCnt for receivables========["+updCnt2+"]");
sql1="update INVOICE set adj_amount= adj_amount + ? WHERE invoice_id= ?";
pstmt = conn.prepareStatement(sql1);
pstmt.setDouble(1, sumAdjAmt);
pstmt.setString(2, refNoHeader);
updCnt = pstmt.executeUpdate();
pstmt.close();
pstmt= null;
System.out.println("@@@updCnt=== INVOICE ["+updCnt+"]");
}
System.out.println("refNoHeader@@@@@@@@============"+refNoHeader);
System.out.println("tranType@@@@@@@@@@@@============"+tranType);
sql1="select tot_amt,adj_amt,status from receivables where ref_no= ? and tran_ser=?";
pstmt= conn.prepareStatement(sql1);
pstmt.setString(1, refNoHeader);
pstmt.setString(2, tranType);
rs = pstmt.executeQuery();
if(rs.next())
{
totalAmt2=Math.abs(rs.getDouble("tot_amt"));
adjAmt2=Math.abs(rs.getDouble("adj_amt"));
statusBef=rs.getString("status");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("totalAmt1============"+totalAmt2);
System.out.println("adjAmt1============"+adjAmt2);
System.out.println("statusBef============"+statusBef);
if(adjAmt2==0)
{
status="U";
System.out.println("adjAmt2=0*********");
}
else if(adjAmt2==totalAmt2)
{
System.out.println("adjAmt2==totalAmt2********");
status="A";
}
else if(adjAmt2!=0 && totalAmt2>adjAmt2)
{
System.out.println("adjAmt2!=0 && totalAmt2>adjAmt2*********");
status="P";
}
System.out.println("status=****-========="+status);
System.out.println("refNoHeader=-========="+refNoHeader);
System.out.println("tranType=-========="+tranType);
sql1=" update receivables set status = ? where ref_no= ? and tran_ser=?";
pstmt1 = conn.prepareStatement(sql1);
pstmt1.setString(1, status);
pstmt1.setString(2, refNoHeader);
pstmt1.setString(3, tranType);
upCnt = pstmt1.executeUpdate();
pstmt1.close();
pstmt1= null;
if (updCnt>0 && updCnt1>0 && updCnt2>0)
{
sql = " update undo_rec_adj set confirmed = 'Y',conf_date = ?, emp_code__aprv = ? where tran_id = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setTimestamp(1, sysDate);
pstmt.setString(2, loginEmpCode);
pstmt.setString(3, tranId);
cnt = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
System.out.println(">>>>>>>>>>>>>>>>>cnt:"+cnt);
if (cnt>0)
{
errString = itmDBAccessLocal.getErrorString("","VTCNFSUCC","");
}
else
{
errString = itmDBAccessLocal.getErrorString("","VTUNCNFIRM","");
}
}
else
{
System.out.println("not updated >>>>>>>>updCnt1>>>>>>>>>>>>:"+updCnt1);
errString = itmDBAccessLocal.getErrorString("","VTUNCNFIRM","");
}
}
}
catch( Exception e )
{
System.out.println("UndoRecievableAdjConf Detail record Available..."+e.getMessage());
e.printStackTrace();
try
{
conn.rollback();
}
catch(Exception e1)
{
System.out.println("UndoRecievableAdjConf Detail record Available..."+e1.getMessage());
e1.printStackTrace();
}
}
return errString;
}
} }
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