Skip to content

B
business-java
Commit 8f8325f4 authored by prahate's avatar prahate
Browse files
Options

Added code for sending auto-mail after ReceiptAutoConf Post Save.[F15FSUN005] 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@99198 ce508802-f39f-4f6c-b175-0d175dae99d5
parent bf6421b5
Hide whitespace changes
Inline Side-by-side
Showing with 344 additions and 237 deletions
webitm-fin/ibase/webitm/ejb/fin/ReceiptAutoConfPOS.java
View file @ 8f8325f4
package ibase.webitm.ejb.fin; package ibase.webitm.ejb.fin;
import ibase.system.config.AppConnectParm; import ibase.system.config.AppConnectParm;
import ibase.utility.EMail;
import ibase.webitm.ejb.ITMDBAccessEJB; import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.MasterStatefulLocal; import ibase.webitm.ejb.MasterStatefulLocal;
import ibase.webitm.ejb.ValidatorEJB; import ibase.webitm.ejb.ValidatorEJB;
...@@ -22,69 +24,191 @@ import org.apache.axis.client.Service; ...@@ -22,69 +24,191 @@ import org.apache.axis.client.Service;
import org.apache.axis.encoding.XMLType; import org.apache.axis.encoding.XMLType;
import org.w3c.dom.Document; import org.w3c.dom.Document;
import ibase.webitm.ejb.fin.adv.ReceiptAdvConf; import ibase.webitm.ejb.fin.adv.ReceiptAdvConf;
@javax.ejb.Stateless
public class ReceiptAutoConfPOS extends ValidatorEJB implements ReceiptAutoConfPOSLocal, ReceiptAutoConfPOSRemote @javax.ejb.Stateless
{ public class ReceiptAutoConfPOS extends ValidatorEJB implements ReceiptAutoConfPOSLocal, ReceiptAutoConfPOSRemote {
FinCommon finCommon = new FinCommon(); FinCommon finCommon = new FinCommon();
DistCommon distCommon = new DistCommon(); DistCommon distCommon = new DistCommon();
public String postSave()throws RemoteException,ITMException public String postSave() throws RemoteException, ITMException {
{
return ""; return "";
} }
public String postSave( String domString, String editFlag, String xtraParams, Connection conn ) throws RemoteException,ITMException public String postSave(String domString, String editFlag,String xtraParams, Connection conn) throws RemoteException,ITMException
{ {
String retString= postSave( domString, editFlag, xtraParams,true, conn ); String retString = postSave(domString, editFlag, xtraParams, true, conn);
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
Document dom = genericUtility.parseString(domString); Document dom = genericUtility.parseString(domString);
String tranId=""; PreparedStatement pstmt = null;
if(retString.trim().length()==0) ResultSet rs= null;
String tranId = "";
StringBuffer commInfo = new StringBuffer();
String sql="",userType="",custCode="",tranType="",rcpMode="",bankCode="",refNo="",confDate="";
String refDate="",remarks="",dlvMode="",dlvRef="",netAmt="",currCode="",exchRate="",empCodeAprv="",descr="",custName="";
String formatCode="RECPT_MAIL";
Timestamp tranDate=null;
if (retString.trim().length() == 0)
{ {
System.out.println("@V@ Post save return string :-["+retString+"]"); System.out.println("@V@ Post save return string :-[" + retString+ "]");
tranId = GenericUtility.getInstance().getColumnValue("tran_id",dom); tranId = GenericUtility.getInstance().getColumnValue("tran_id", dom);
ReceiptAdvConf obj=new ReceiptAdvConf(); ReceiptAdvConf obj = new ReceiptAdvConf();
retString=obj.confirm(tranId, xtraParams, "",conn); retString = obj.confirm(tranId, xtraParams, "", conn);
System.out.println("@V@ Confirm return string :- ["+retString+"]"); System.out.println("@V@ Confirm return string :- [" + retString+ "]");
if(retString.contains("VTCICONF3")) if (retString.contains("VTCICONF3"))
{ {
retString=""; //Added by Pankaj to send auto-mail to concern employee on 20/NOV/2015
try
{
sql="SELECT TRAN_DATE,CUST_CODE,TRAN_TYPE,RCP_MODE,BANK_CODE,REF_NO,REF_DATE,REMARKS,DLV_MODE," +
"DLV_REF,NET_AMT,CURR_CODE,EXCH_RATE,EMP_CODE__APRV,CONF_DATE FROM RECEIPT WHERE TRAN_ID = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if(rs.next())
{
tranDate = (rs.getTimestamp("TRAN_DATE"));
custCode = checkNull(rs.getString("CUST_CODE"));
tranType = checkNull(rs.getString("TRAN_TYPE"));
rcpMode = checkNull(rs.getString("RCP_MODE"));
bankCode = checkNull(rs.getString("BANK_CODE"));
refNo = checkNull(rs.getString("REF_NO"));
refDate = checkNull(rs.getString("REF_DATE"));
remarks = checkNull(rs.getString("REMARKS"));
dlvMode = checkNull(rs.getString("DLV_MODE"));
dlvRef = checkNull(rs.getString("DLV_REF"));
netAmt = checkNull(rs.getString("NET_AMT"));
currCode = checkNull(rs.getString("CURR_CODE"));
exchRate = checkNull(rs.getString("EXCH_RATE"));
empCodeAprv = checkNull(rs.getString("EMP_CODE__APRV"));
confDate = checkNull(rs.getString("CONF_DATE"));
System.out.println("refDate before>>>>"+refDate);
System.out.println("tranDate>>>>"+tranDate);
refDate = genericUtility.getValidDateString(refDate,genericUtility.getDBDateFormat(),genericUtility.getApplDateFormat());
confDate = genericUtility.getValidDateString(confDate,genericUtility.getDBDateFormat(),genericUtility.getApplDateFormat());
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
sql = "select cust_name from customer where cust_code= ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, custCode);
rs = pstmt.executeQuery();
if(rs.next())
{
custName = checkNull(rs.getString("cust_name"));
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
sql="SELECT descr FROM gencodes WHERE MOD_NAME = 'X' AND FLD_NAME = 'EMAIL_ID_AML' " +
"and sh_descr in(select registr_5 from customer c,receipt r " +
"where c.cust_code=r.cust_code and r.tran_id= ?) ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if(rs.next())
{
descr = checkNull(rs.getString("descr"));
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if(descr != null && descr.trim().length() > 0)
{
System.out.println("Inside else");
sql="select emp_code from employee where email_id_off= ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, descr);
rs = pstmt.executeQuery();
if(rs.next())
{
empCodeAprv = checkNull(rs.getString("emp_code"));
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
}
else
{
System.out.println("descr is Null>>>>>");
empCodeAprv = empCodeAprv;
}
commInfo.append("<ROOT>");
commInfo.append("<MAIL><EMAIL_TYPE>page</EMAIL_TYPE><ENTITY_CODE>BASE</ENTITY_CODE>");
commInfo.append("<ENTITY_TYPE>"+userType+"</ENTITY_TYPE>");
commInfo.append("<TO_ADD></TO_ADD>");
//commInfo.append("<cc_to>"+travelCodeEmail+","+nsmCodeEmail+"</cc_to>");
commInfo.append("<BCC_ADD></BCC_ADD>");
commInfo.append("<FORMAT_CODE>"+formatCode+"</FORMAT_CODE>");
commInfo.append("<ATTACHMENT><BODY></BODY><LOCATION></LOCATION></ATTACHMENT>");
commInfo.append("</MAIL>");
commInfo.append("<XML_DATA><ROOT><Detail1><TRAN_ID>"+tranId+"</TRAN_ID><TRAN_DATE>"+tranDate+"</TRAN_DATE>" +
"<CUST_CODE>"+custCode+"</CUST_CODE><CUST_NAME>"+custName+"</CUST_NAME><TRAN_TYPE>"+tranType+"</TRAN_TYPE><RCP_MODE>"+rcpMode+"</RCP_MODE>" +
"<BANK_CODE>"+bankCode+"</BANK_CODE><REF_NO>"+refNo+"</REF_NO><REF_DATE>"+refDate+"</REF_DATE>" +
"<REMARKS>"+remarks+"</REMARKS><CONF_DATE>"+confDate+"</CONF_DATE><DLV_MODE>"+dlvMode+"</DLV_MODE><DLV_REF>"+dlvRef+"</DLV_REF>" +
"<NET_AMT>"+netAmt+"</NET_AMT><CURR_CODE>"+currCode+"</CURR_CODE><EXCH_RATE>"+exchRate+"</EXCH_RATE>" +
"<emp_code>"+empCodeAprv+"</emp_code>");
// commInfo.append("<cc_to>"+travelCodeEmail+","+nsmCodeEmail+"</cc_to>");
commInfo.append("</Detail1></ROOT></XML_DATA>");
commInfo.append("</ROOT>");
EMail email = new EMail();
email.sendMail(commInfo.toString(), "ITM");
retString = "submited";
System.out.println(" information submited::");
}
catch( Exception e )
{
e.printStackTrace();
System.out.println("Exception ::"+ e.getMessage());
throw new ITMException(e);
}
} }
// End by Pankaj R on 20/NOV/15
} }
return retString; return retString;
} }
public String postSave( String domString, String editFlag, String xtraParams,boolean autoConfirm, Connection conn ) throws RemoteException,ITMException
{ public String postSave(String domString, String editFlag,
String xtraParams, boolean autoConfirm, Connection conn)
throws RemoteException, ITMException {
System.out.println("In ReceiptAdvPostSave ... "); System.out.println("In ReceiptAdvPostSave ... ");
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
Document dom = null; Document dom = null;
ResultSet rs =null; ResultSet rs = null;
boolean isError = false; boolean isError = false;
String tranIdRcp = ""; String tranIdRcp = "";
String tranId = "",lineNo=""; String tranId = "", lineNo = "";
String errString =""; String errString = "";
String xmlString =null; String xmlString = null;
String sql = null; String sql = null;
String sqlC=null; String sqlC = null;
StringBuffer xmlBuff = new StringBuffer(); StringBuffer xmlBuff = new StringBuffer();
//PreparedStatement pstmt=null; // PreparedStatement pstmt=null;
String bankCode = null; String bankCode = null;
String finEntity = null; String finEntity = null;
String currCode = null; String currCode = null;
double exchRate = 0; double exchRate = 0;
double chqAmt = 0, chqAmtActual = 0, netAmt = 0, diffAmtExchTotal = 0, netAmtBc = 0 ; double chqAmt = 0, chqAmtActual = 0, netAmt = 0, diffAmtExchTotal = 0, netAmtBc = 0;
String tranDate =null; String tranDate = null;
String custCode =null; String custCode = null;
String siteCode = null; String siteCode = null;
String acctCodeBal = null; String acctCodeBal = null;
String acctCodeAr = null; String acctCodeAr = null;
String cctrCodeBal = null; String cctrCodeBal = null;
String cctrCodeAr = null; String cctrCodeAr = null;
String acctCodeAdv = null; String acctCodeAdv = null;
String cctrCodeAdv = null; String cctrCodeAdv = null;
String refNo = null; String refNo = null;
...@@ -95,28 +219,28 @@ public class ReceiptAutoConfPOS extends ValidatorEJB implements ReceiptAutoConfP ...@@ -95,28 +219,28 @@ public class ReceiptAutoConfPOS extends ValidatorEJB implements ReceiptAutoConfP
String cctrFinS = ""; String cctrFinS = "";
String acctFin = ""; String acctFin = "";
String acctFinS = ""; String acctFinS = "";
String bdFluctuationCf=""; String bdFluctuationCf = "";
String sql1 =""; String sql1 = "";
String errorString=""; String errorString = "";
double rcpAmt=0,finChg=0, diffAmtExchDet = 0, diffAmtExchAdv = 0, diffAmtExchEpc = 0, newAdvAmt = 0; double rcpAmt = 0, finChg = 0, diffAmtExchDet = 0, diffAmtExchAdv = 0, diffAmtExchEpc = 0, newAdvAmt = 0;
double billAmtDet = 0, advAmtHdr = 0, adjAmtAdv = 0, bdAmt =0, advAmtRact = 0, othAmt = 0.0,exchRateHdr = 0.0, taxAmt = 0,amount = 0.0,othAmttemp =0.0; double billAmtDet = 0, advAmtHdr = 0, adjAmtAdv = 0, bdAmt = 0, advAmtRact = 0, othAmt = 0.0, exchRateHdr = 0.0, taxAmt = 0, amount = 0.0, othAmttemp = 0.0;
int cnt=0; int cnt = 0;
try try {
{ ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
dom = genericUtility.parseString(domString); dom = genericUtility.parseString(domString);
tranId = GenericUtility.getInstance().getColumnValue("tran_id",dom); tranId = GenericUtility.getInstance()
currCode = GenericUtility.getInstance().getColumnValue("curr_code",dom); .getColumnValue("tran_id", dom);
currCode = GenericUtility.getInstance().getColumnValue("curr_code",
dom);
sql="select adv_amt, exch_rate,chq_amt,curr_Code from receipt WHERE tran_id = ? "; sql = "select adv_amt, exch_rate,chq_amt,curr_Code from receipt WHERE tran_id = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1,tranId ); pstmt.setString(1, tranId);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if (rs.next()) if (rs.next()) {
{
advAmtHdr = rs.getDouble(1); advAmtHdr = rs.getDouble(1);
exchRateHdr = rs.getDouble(2); exchRateHdr = rs.getDouble(2);
chqAmtActual = rs.getDouble(3); chqAmtActual = rs.getDouble(3);
...@@ -126,112 +250,109 @@ public class ReceiptAutoConfPOS extends ValidatorEJB implements ReceiptAutoConfP ...@@ -126,112 +250,109 @@ public class ReceiptAutoConfPOS extends ValidatorEJB implements ReceiptAutoConfP
rs = null; rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
bdFluctuationCf=checkNull(finCommon.getFinparams("999999","BD_FLUCTUATION_CF",conn));//added by sagar on 21/08/14.. bdFluctuationCf = checkNull(finCommon.getFinparams("999999",
System.out.println(">>>>>>>>>>>>>>Finparam varValue:"+varValue); "BD_FLUCTUATION_CF", conn));// added by sagar on 21/08/14..
if(bdFluctuationCf == null || bdFluctuationCf.trim().equalsIgnoreCase("NULLFOUND")) System.out.println(">>>>>>>>>>>>>>Finparam varValue:" + varValue);
{ if (bdFluctuationCf == null
bdFluctuationCf="N"; || bdFluctuationCf.trim().equalsIgnoreCase("NULLFOUND")) {
bdFluctuationCf = "N";
} }
if("N".equals(bdFluctuationCf.trim())) //Condition added by sagar on 21/08/14.. if ("N".equals(bdFluctuationCf.trim())) // Condition added by sagar
// on 21/08/14..
{ {
sql="UPDATE rcpdet set exch_rate = ? " sql = "UPDATE rcpdet set exch_rate = ? "
+" WHERE tran_id = ? " + " WHERE tran_id = ? "
+ " and (curr_code = ? or exch_rate is null) "; + " and (curr_code = ? or exch_rate is null) ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setDouble(1,exchRateHdr ); pstmt.setDouble(1, exchRateHdr);
pstmt.setString(2,tranId ); pstmt.setString(2, tranId);
pstmt.setString(3,currCode ); pstmt.setString(3, currCode);
cnt = pstmt.executeUpdate(); cnt = pstmt.executeUpdate();
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
sql="UPDATE rcpdet set diff_amt__exch = (rcp_amt * EXCH_RATE__RCV) - (rcp_amt * exch_rate) " sql = "UPDATE rcpdet set diff_amt__exch = (rcp_amt * EXCH_RATE__RCV) - (rcp_amt * exch_rate) "
+" WHERE tran_id = ? " + " WHERE tran_id = ? "
+ " and (curr_code = ? or exch_rate is null) "; + " and (curr_code = ? or exch_rate is null) ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1,tranId ); pstmt.setString(1, tranId);
pstmt.setString(2,currCode ); pstmt.setString(2, currCode);
cnt = pstmt.executeUpdate(); cnt = pstmt.executeUpdate();
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
} }
sql="select sum(diff_amt__exch), sum(tax_amt) from rcpdet WHERE tran_id = ? " ; sql = "select sum(diff_amt__exch), sum(tax_amt) from rcpdet WHERE tran_id = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1,tranId ); pstmt.setString(1, tranId);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if (rs.next()) if (rs.next()) {
{
diffAmtExchDet = rs.getDouble(1); diffAmtExchDet = rs.getDouble(1);
taxAmt = rs.getDouble(2); taxAmt = rs.getDouble(2);
} }
rs.close(); rs.close();
rs = null; rs = null;
sql="select sum(diff_amt__exch) from rcpadv WHERE tran_id = ? " ; sql = "select sum(diff_amt__exch) from rcpadv WHERE tran_id = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1,tranId ); pstmt.setString(1, tranId);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if (rs.next()) if (rs.next()) {
{
diffAmtExchAdv = rs.getDouble(1); diffAmtExchAdv = rs.getDouble(1);
} }
rs.close(); rs.close();
rs = null; rs = null;
sql="select sum(diff_amt__exch) from rcpepc_adj WHERE tran_id = ? " ; sql = "select sum(diff_amt__exch) from rcpepc_adj WHERE tran_id = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1,tranId ); pstmt.setString(1, tranId);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if (rs.next()) if (rs.next()) {
{
diffAmtExchEpc = rs.getDouble(1); diffAmtExchEpc = rs.getDouble(1);
} }
rs.close(); rs.close();
rs = null; rs = null;
sql1 ="select sum(amount * exch_rate ) oth_amt from rcpacct WHERE tran_id = ? AND eff_bank <> 'N'"; sql1 = "select sum(amount * exch_rate ) oth_amt from rcpacct WHERE tran_id = ? AND eff_bank <> 'N'";
pstmt = conn.prepareStatement(sql1); pstmt = conn.prepareStatement(sql1);
pstmt.setString(1,tranId ); pstmt.setString(1, tranId);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if (rs.next()) if (rs.next()) {
{
othAmttemp = rs.getDouble(1); othAmttemp = rs.getDouble(1);
} }
rs.close(); rs.close();
rs = null; rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
System.out.println("Other Amount Temp before division>>>>" + othAmttemp); System.out.println("Other Amount Temp before division>>>>"
if(othAmttemp != 0) + othAmttemp);
{ if (othAmttemp != 0) {
othAmt = (othAmttemp /exchRateHdr); othAmt = (othAmttemp / exchRateHdr);
} }
System.out.println("ExchangeRate hdr after division>>>>>" + exchRateHdr); System.out.println("ExchangeRate hdr after division>>>>>"
+ exchRateHdr);
System.out.println("Other Amount after division>>>>>" + othAmt); System.out.println("Other Amount after division>>>>>" + othAmt);
sql="UPDATE receipt SET oth_amt = ?, tax_amt = ? WHERE tran_id = ? " ; sql = "UPDATE receipt SET oth_amt = ?, tax_amt = ? WHERE tran_id = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setDouble(1,othAmt ); pstmt.setDouble(1, othAmt);
pstmt.setDouble(2,taxAmt ); pstmt.setDouble(2, taxAmt);
pstmt.setString(3,tranId ); pstmt.setString(3, tranId);
cnt = pstmt.executeUpdate(); cnt = pstmt.executeUpdate();
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
System.out.println("Other Amount on update11111111>>>>>" + othAmt); System.out.println("Other Amount on update11111111>>>>>" + othAmt);
sql="select sum(adj_amt) from rcpadv WHERE tran_id = ? "; sql = "select sum(adj_amt) from rcpadv WHERE tran_id = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1,tranId ); pstmt.setString(1, tranId);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if (rs.next()) if (rs.next()) {
{
adjAmtAdv = rs.getDouble(1); adjAmtAdv = rs.getDouble(1);
} }
rs.close(); rs.close();
...@@ -239,32 +360,30 @@ public class ReceiptAutoConfPOS extends ValidatorEJB implements ReceiptAutoConfP ...@@ -239,32 +360,30 @@ public class ReceiptAutoConfPOS extends ValidatorEJB implements ReceiptAutoConfP
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
if("N".equals(bdFluctuationCf.trim())) //Condition added by Manoj on 22/08/14.. if ("N".equals(bdFluctuationCf.trim())) // Condition added by Manoj
// on 22/08/14..
{ {
sql="select sum(d.rcp_amt * d.exch_rate / h.exch_rate), sum(case when r.bill_disc = 'Y' then d.BILL_DISC_AMT + d. FIN_CHG else 0 end ) " sql = "select sum(d.rcp_amt * d.exch_rate / h.exch_rate), sum(case when r.bill_disc = 'Y' then d.BILL_DISC_AMT + d. FIN_CHG else 0 end ) "
+ " from receipt h, rcpdet d, receivables r " + " from receipt h, rcpdet d, receivables r "
+ " WHERE h.tran_id = d.tran_id " + " WHERE h.tran_id = d.tran_id "
+ " and r.tran_ser = d.ref_ser " + " and r.tran_ser = d.ref_ser "
+ " and r.ref_no = d.ref_no " + " and r.ref_no = d.ref_no "
+ " and r.line_no__ref = d.line_no__ref " + " and r.line_no__ref = d.line_no__ref "
+ " and h.tran_id = ? " ; + " and h.tran_id = ? ";
} } else {
else sql = "select sum(d.rcp_amt * d.exch_rate__rcv / h.exch_rate), sum(case when r.bill_disc = 'Y' then d.BILL_DISC_AMT + d. FIN_CHG else 0 end ) "
{
sql="select sum(d.rcp_amt * d.exch_rate__rcv / h.exch_rate), sum(case when r.bill_disc = 'Y' then d.BILL_DISC_AMT + d. FIN_CHG else 0 end ) "
+ " from receipt h, rcpdet d, receivables r " + " from receipt h, rcpdet d, receivables r "
+ " WHERE h.tran_id = d.tran_id " + " WHERE h.tran_id = d.tran_id "
+ " and r.tran_ser = d.ref_ser " + " and r.tran_ser = d.ref_ser "
+ " and r.ref_no = d.ref_no " + " and r.ref_no = d.ref_no "
+ " and r.line_no__ref = d.line_no__ref " + " and r.line_no__ref = d.line_no__ref "
+ " and h.tran_id = ? " ; + " and h.tran_id = ? ";
} }
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1,tranId ); pstmt.setString(1, tranId);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if (rs.next()) if (rs.next()) {
{
billAmtDet = rs.getDouble(1); billAmtDet = rs.getDouble(1);
bdAmt = rs.getDouble(2); bdAmt = rs.getDouble(2);
} }
...@@ -272,83 +391,90 @@ public class ReceiptAutoConfPOS extends ValidatorEJB implements ReceiptAutoConfP ...@@ -272,83 +391,90 @@ public class ReceiptAutoConfPOS extends ValidatorEJB implements ReceiptAutoConfP
rs = null; rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
billAmtDet=roundVal(billAmtDet, 3); billAmtDet = roundVal(billAmtDet, 3);
//chqAmt = billAmtDet + bdAmt + adjAmtAdv; // 21/01/14 bd amount removed from bill_amt // chqAmt = billAmtDet + bdAmt + adjAmtAdv; // 21/01/14 bd amount
chqAmt = billAmtDet ;//+ adjAmtAdv; // removed from bill_amt
// 25/02/14 manoharan if all details are dropped t6he bill_amt should be 0 chqAmt = billAmtDet;// + adjAmtAdv;
//if (chqAmt != 0) // 25/02/14 manoharan if all details are dropped t6he bill_amt
//{ // should be 0
sql="UPDATE receipt SET bill_amt = ?, ADVADJ_AMT = ? WHERE tran_id = ? " ; // if (chqAmt != 0)
pstmt = conn.prepareStatement(sql); // {
pstmt.setDouble(1,chqAmt ); sql = "UPDATE receipt SET bill_amt = ?, ADVADJ_AMT = ? WHERE tran_id = ? ";
pstmt.setDouble(2,adjAmtAdv); pstmt = conn.prepareStatement(sql);
pstmt.setString(3,tranId ); pstmt.setDouble(1, chqAmt);
cnt = pstmt.executeUpdate(); pstmt.setDouble(2, adjAmtAdv);
pstmt.close(); pstmt.setString(3, tranId);
pstmt = null; cnt = pstmt.executeUpdate();
//} pstmt.close();
System.out.println("05/07/14 bill_amt ["+ chqAmt +"] billAmtDet [" + billAmtDet + "] advadj_amt [" + adjAmtAdv +"] oth_amt [" + othAmt + "] taxAmt [" + taxAmt + "] diffAmtExchDet [" + diffAmtExchDet + "] diffAmtExchAdv [" + diffAmtExchAdv + "] diffAmtExchEpc [" + diffAmtExchEpc + "]" ); pstmt = null;
// 21/03/14 manoharan update advance // }
if (chqAmtActual != 0) System.out.println("05/07/14 bill_amt [" + chqAmt
{ + "] billAmtDet [" + billAmtDet + "] advadj_amt ["
+ adjAmtAdv + "] oth_amt [" + othAmt + "] taxAmt ["
+ taxAmt + "] diffAmtExchDet [" + diffAmtExchDet
+ "] diffAmtExchAdv [" + diffAmtExchAdv
+ "] diffAmtExchEpc [" + diffAmtExchEpc + "]");
// 21/03/14 manoharan update advance
if (chqAmtActual != 0) {
// 29/05/14 manoharan // 29/05/14 manoharan
// 30/06/14 manoharan not to deduct dbamt // 30/06/14 manoharan not to deduct dbamt
//sql="select chq_amt - ((case when bill_amt is null then 0 else bill_amt end)+ (case when advadj_amt is null then 0 else advadj_amt end) - ? + (case when oth_amt is null then 0 else oth_amt end) + (case when fin_chg is null then 0 else fin_chg end) + tax_amt) from receipt WHERE tran_id = ? " ; // sql="select chq_amt - ((case when bill_amt is null then 0 else bill_amt end)+ (case when advadj_amt is null then 0 else advadj_amt end) - ? + (case when oth_amt is null then 0 else oth_amt end) + (case when fin_chg is null then 0 else fin_chg end) + tax_amt) from receipt WHERE tran_id = ? "
sql="select chq_amt - ((case when bill_amt is null then 0 else bill_amt end) + (case when oth_amt is null then 0 else oth_amt end) + (case when fin_chg is null then 0 else fin_chg end) + tax_amt) from receipt WHERE tran_id = ? " ; // ;
sql = "select chq_amt - ((case when bill_amt is null then 0 else bill_amt end) + (case when oth_amt is null then 0 else oth_amt end) + (case when fin_chg is null then 0 else fin_chg end) + tax_amt) from receipt WHERE tran_id = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
//pstmt.setDouble(1,bdAmt ); // pstmt.setDouble(1,bdAmt );
pstmt.setString(1,tranId ); pstmt.setString(1, tranId);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if (rs.next()) if (rs.next()) {
{
newAdvAmt = rs.getDouble(1); newAdvAmt = rs.getDouble(1);
} }
rs.close(); rs.close();
rs = null; rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
System.out.println("newAdvAmt: "+newAdvAmt); System.out.println("newAdvAmt: " + newAdvAmt);
if (newAdvAmt < 0 ) if (newAdvAmt < 0) {
{
errorString = itmDBAccessEJB.getErrorString("", "VTNEGADV",
errorString=itmDBAccessEJB.getErrorString("","VTNEGADV","","",conn); "", "", conn);
System.out.println("errorString :"+errorString); System.out.println("errorString :" + errorString);
//throw new Exception("Advance amount calculated is becoming negative [" + newAdvAmt + "]" ); // throw new
// Exception("Advance amount calculated is becoming negative ["
// + newAdvAmt + "]" );
} }
// end 29/05/14 manoharan // end 29/05/14 manoharan
// 30/06/14 manoharan not to deduct dbamt // 30/06/14 manoharan not to deduct dbamt
//sql="UPDATE receipt SET adv_amt = chq_amt - ((case when bill_amt is null then 0 else bill_amt end)+ (case when advadj_amt is null then 0 else advadj_amt end) - ? + (case when oth_amt is null then 0 else oth_amt end) + (case when fin_chg is null then 0 else fin_chg end) + tax_amt) WHERE tran_id = ? " ; // sql="UPDATE receipt SET adv_amt = chq_amt - ((case when bill_amt is null then 0 else bill_amt end)+ (case when advadj_amt is null then 0 else advadj_amt end) - ? + (case when oth_amt is null then 0 else oth_amt end) + (case when fin_chg is null then 0 else fin_chg end) + tax_amt) WHERE tran_id = ? "
sql="UPDATE receipt SET adv_amt = chq_amt - ((case when bill_amt is null then 0 else bill_amt end) + (case when oth_amt is null then 0 else oth_amt end) + (case when fin_chg is null then 0 else fin_chg end) + tax_amt) WHERE tran_id = ? " ; // ;
sql = "UPDATE receipt SET adv_amt = chq_amt - ((case when bill_amt is null then 0 else bill_amt end) + (case when oth_amt is null then 0 else oth_amt end) + (case when fin_chg is null then 0 else fin_chg end) + tax_amt) WHERE tran_id = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
//pstmt.setDouble(1,bdAmt ); // pstmt.setDouble(1,bdAmt );
pstmt.setString(1,tranId ); pstmt.setString(1, tranId);
cnt = pstmt.executeUpdate(); cnt = pstmt.executeUpdate();
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
if( cnt > 0) if (cnt > 0) {
{ System.out.println("update successfully [" + cnt + "]");
System.out.println("update successfully ["+cnt+"]");
} }
} }
// - (case when bill_disc_amt is null then 0 else bill_disc_amt end) removed on 21/01/14 // - (case when bill_disc_amt is null then 0 else bill_disc_amt end)
//change done by kunal on 01/feb/14 minus bill_disc_amt // removed on 21/01/14
// change done by kunal on 01/feb/14 minus bill_disc_amt
diffAmtExchTotal = diffAmtExchDet + diffAmtExchAdv + diffAmtExchEpc;
diffAmtExchTotal = diffAmtExchDet + diffAmtExchAdv + diffAmtExchEpc;
sql="select ((case when adv_amt is null then 0 else adv_amt end)+ (case when bill_amt is null then 0 else bill_amt end)+ (case when advadj_amt is null then 0 else advadj_amt end) + (case when oth_amt is null then 0 else oth_amt end) + (case when fin_chg is null then 0 else fin_chg end) + tax_amt) net_amt from receipt WHERE tran_id = ? " ; sql = "select ((case when adv_amt is null then 0 else adv_amt end)+ (case when bill_amt is null then 0 else bill_amt end)+ (case when advadj_amt is null then 0 else advadj_amt end) + (case when oth_amt is null then 0 else oth_amt end) + (case when fin_chg is null then 0 else fin_chg end) + tax_amt) net_amt from receipt WHERE tran_id = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
//pstmt.setDouble(1,bdAmt ); // pstmt.setDouble(1,bdAmt );
pstmt.setString(1,tranId ); pstmt.setString(1, tranId);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if (rs.next()) if (rs.next()) {
{
netAmt = rs.getDouble(1); netAmt = rs.getDouble(1);
} }
rs.close(); rs.close();
...@@ -357,49 +483,42 @@ public class ReceiptAutoConfPOS extends ValidatorEJB implements ReceiptAutoConfP ...@@ -357,49 +483,42 @@ public class ReceiptAutoConfPOS extends ValidatorEJB implements ReceiptAutoConfP
pstmt = null; pstmt = null;
netAmt = netAmt - bdAmt; netAmt = netAmt - bdAmt;
netAmtBc = netAmt * exchRateHdr; netAmtBc = netAmt * exchRateHdr;
/* /*
sql="UPDATE receipt SET DIFF_AMT__EXCH = ? + ? + ?, net_amt = ((case when adv_amt is null then 0 else adv_amt end)+ (case when bill_amt is null then 0 else bill_amt end)+ (case when advadj_amt is null then 0 else advadj_amt end) - ? + (case when oth_amt is null then 0 else oth_amt end) + (case when fin_chg is null then 0 else fin_chg end) + tax_amt) , " * sql="UPDATE receipt SET DIFF_AMT__EXCH = ? + ? + ?, net_amt = ((case when adv_amt is null then 0 else adv_amt end)+ (case when bill_amt is null then 0 else bill_amt end)+ (case when advadj_amt is null then 0 else advadj_amt end) - ? + (case when oth_amt is null then 0 else oth_amt end) + (case when fin_chg is null then 0 else fin_chg end) + tax_amt) , "
+" net_amt__bc = ((case when adv_amt is null then 0 else adv_amt end)+ (case when bill_amt is null then 0 else bill_amt end)+ (case when advadj_amt is null then 0 else advadj_amt end) - ? + (case when oth_amt is null then 0 else oth_amt end) + (case when fin_chg is null then 0 else fin_chg end) + tax_amt) * exch_rate, " * +
+" bill_disc_amt = ? WHERE tran_id = ? " ; * " net_amt__bc = ((case when adv_amt is null then 0 else adv_amt end)+ (case when bill_amt is null then 0 else bill_amt end)+ (case when advadj_amt is null then 0 else advadj_amt end) - ? + (case when oth_amt is null then 0 else oth_amt end) + (case when fin_chg is null then 0 else fin_chg end) + tax_amt) * exch_rate, "
* +" bill_disc_amt = ? WHERE tran_id = ? " ; pstmt =
* conn.prepareStatement(sql);
*
* pstmt.setDouble(1,diffAmtExchDet );
* pstmt.setDouble(2,diffAmtExchAdv );
* pstmt.setDouble(3,diffAmtExchEpc ); pstmt.setDouble(4,bdAmt
* );//added by kunal on 03/feb/14 pstmt.setDouble(5,bdAmt );
* //added by kunal on 03/feb/14 pstmt.setDouble(6,bdAmt );
* pstmt.setString(7,tranId ); cnt = pstmt.executeUpdate();
* pstmt.close(); pstmt = null;
*/
sql = "UPDATE receipt SET DIFF_AMT__EXCH = ? , net_amt = ? , net_amt__bc = ?, bill_disc_amt = ? WHERE tran_id = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setDouble(1,diffAmtExchDet ); pstmt.setDouble(1, diffAmtExchTotal);
pstmt.setDouble(2,diffAmtExchAdv ); pstmt.setDouble(2, netAmt);
pstmt.setDouble(3,diffAmtExchEpc ); pstmt.setDouble(3, netAmtBc);
pstmt.setDouble(4,bdAmt );//added by kunal on 03/feb/14 pstmt.setDouble(4, bdAmt);
pstmt.setDouble(5,bdAmt ); //added by kunal on 03/feb/14 pstmt.setString(5, tranId);
pstmt.setDouble(6,bdAmt );
pstmt.setString(7,tranId );
cnt = pstmt.executeUpdate(); cnt = pstmt.executeUpdate();
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
*/
sql="UPDATE receipt SET DIFF_AMT__EXCH = ? , net_amt = ? , net_amt__bc = ?, bill_disc_amt = ? WHERE tran_id = ? " ;
pstmt = conn.prepareStatement(sql);
pstmt.setDouble(1,diffAmtExchTotal ); if (cnt > 0) {
pstmt.setDouble(2,netAmt ); System.out.println("update successfully [" + cnt + "]");
pstmt.setDouble(3,netAmtBc );
pstmt.setDouble(4,bdAmt );
pstmt.setString(5,tranId );
cnt = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
if( cnt > 0)
{
System.out.println("update successfully ["+cnt+"]");
} }
if( cnt > 0) if (cnt > 0) {
{ System.out.println("update successfully [" + cnt + "]");
System.out.println("update successfully ["+cnt+"]");
} }
} } catch (Exception e) {
catch(Exception e)
{
try { try {
conn.rollback(); conn.rollback();
} catch (SQLException e1) { } catch (SQLException e1) {
...@@ -407,66 +526,54 @@ public class ReceiptAutoConfPOS extends ValidatorEJB implements ReceiptAutoConfP ...@@ -407,66 +526,54 @@ public class ReceiptAutoConfPOS extends ValidatorEJB implements ReceiptAutoConfP
e1.printStackTrace(); e1.printStackTrace();
} }
isError = true; isError = true;
System.out.println("Exception :DcdetPostSaveEJB : :==>\n"+e.getMessage()); System.out.println("Exception :DcdetPostSaveEJB : :==>\n"
+ e.getMessage());
e.printStackTrace(); e.printStackTrace();
throw new ITMException(e); throw new ITMException(e);
} } finally {
finally try {
{ System.out.println("isError [" + isError + "]");
try if (conn != null) {
{
System.out.println("isError ["+isError+"]");
if( conn != null )
{
/*if( isError ) /*
{ * if( isError ) { conn.rollback(); } else { conn.commit();
conn.rollback(); * }
} */
else
{
conn.commit();
}*/
} }
if(pstmt != null) if (pstmt != null) {
{
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
} }
} } catch (Exception e) {
catch(Exception e) System.out.println("Exception :SavexPreSaveEJB : :==>\n"
{ + e.getMessage());
System.out.println("Exception :SavexPreSaveEJB : :==>\n"+e.getMessage()); try {
try
{
System.out.println("Before rollback"); System.out.println("Before rollback");
conn.rollback(); conn.rollback();
} }
catch(SQLException sqle) catch (SQLException sqle) {
{
System.out.println(sqle); System.out.println(sqle);
} }
throw new ITMException(e); throw new ITMException(e);
} }
} }
System.out.println("Out DcdetPostSaveEJB ... "); System.out.println("Out DcdetPostSaveEJB ... ");
return errorString; return errorString;
}
private java.math.BigDecimal round(int scale ,double round)
{
return new java.math.BigDecimal(round).setScale(scale, java.math.BigDecimal.ROUND_UP);
} }
private double roundVal(double round,int scale) private java.math.BigDecimal round(int scale, double round) {
{ return new java.math.BigDecimal(round).setScale(scale,
return Math.round(round*Math.pow(10, scale))/Math.pow(10, scale); java.math.BigDecimal.ROUND_UP);
} }
private String checkNull( String input )
{ private double roundVal(double round, int scale) {
if ( input == null ) return Math.round(round * Math.pow(10, scale)) / Math.pow(10, scale);
{ }
private String checkNull(String input) {
if (input == null) {
input = ""; input = "";
} }
return input; return input;
......
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