Commit 90c9ca9a authored by kshinde's avatar kshinde

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@185255 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 60135ef4
package ibase.webitm.ejb.fin.adv;
import java.rmi.RemoteException;
import java.sql.*;
import javax.ejb.*;
import ibase.webitm.utility.*;
import ibase.webitm.ejb.*;
import ibase.system.config.*;
import javax.ejb.Stateless;
import javax.naming.InitialContext;
import javax.xml.rpc.ParameterMode;
import org.apache.axis.client.Call;
import org.apache.axis.client.Service;
import org.apache.axis.encoding.XMLType;
import ibase.webitm.ejb.fin.FinCommon;
import ibase.webitm.ejb.fin.adv.JvConfirm;
import ibase.webitm.ejb.fin.adv.PayIbcaConf;
import ibase.webitm.ejb.dis.DistCommon;
import ibase.utility.CommonConstants;
import ibase.utility.E12GenericUtility;
import ibase.utility.UserInfoBean;
import ibase.webitm.utility.TransIDGenerator;
import ibase.webitm.utility.ITMException;
import java.text.SimpleDateFormat;
import java.util.*;
@Stateless
public class LoanConf extends ActionHandlerEJB implements LoanConfLocal,LoanConfRemote //SessionBean
{
E12GenericUtility genericUtility = new E12GenericUtility();
public String confirm(String tranId,String xtraParams,String forcedFlag) throws RemoteException,ITMException{
String errString ="";
Connection conn = null;
try{
errString = confirm(tranId, xtraParams, forcedFlag, conn);
}catch (Exception e) {
// TODO: handle exception
System.out.println("Exception in confirm() ==>"+e.getMessage());
errString = genericUtility.createErrorString(e);
System.out.println("errString in cofirm() ==>"+errString);
e.printStackTrace();
throw new ITMException(e);
}
return errString;
}
public String confirm(String tranId,String xtraParams,String forcedFlag,Connection conn) throws RemoteException,ITMException
{
PreparedStatement pstmt = null;
ResultSet rs = null;
String sql = "";
String confirm = "" ,siteCode = "";
String errString = "" ;
FinCommon finCommon = null;
ITMDBAccessEJB itmDBAccessEJB = null;
boolean isLocalConn = false;
try
{
finCommon = new FinCommon();
itmDBAccessEJB = new ITMDBAccessEJB();
if(conn == null)
{
conn = getConnection();
conn.setAutoCommit(false);
isLocalConn = true;
}
sql =" select confirmed,site_code from loan_hdr where tran_id = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,tranId);
rs = pstmt.executeQuery();
if(rs.next())
{
confirm = rs.getString("confirmed");
siteCode = rs.getString("site_code");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if(confirm != null && "Y".equalsIgnoreCase(confirm))
{
System.out.println("The Selected transaction is already confirmed");
errString = itmDBAccessEJB.getErrorString("","VTMCONF1","","",conn);
return errString;
}
else
{
errString = this.loanConfirm(tranId,xtraParams,forcedFlag,conn);
if(errString != null && errString.trim().length() > 0)
{
return errString;
}
}
} //end of try
catch(Exception e)
{
System.out.println("Exception ::"+e.getMessage());
errString = genericUtility.createErrorString(e);
e.printStackTrace();
try{
conn.rollback();
}
catch(Exception e1){
System.out.println("Exception while rollbacking222.......");
}
throw new ITMException(e);
}
finally
{
System.out.println("IN fINALLY loanConfirm confirm @#......>>["+isLocalConn+"]");
System.out.println("IN fINALLY loanConfirm confirm errString@#......>>["+errString+"]");
try
{
if(errString != null && errString.trim().length() > 0)
{
if(errString.indexOf("CONFSUCCES") > -1)
{
if(isLocalConn){
System.out.println("Transaction commited111.............from loanConfirm");
conn.commit();
}
}
else
{
System.out.println("CONNECTION Rollbacking......................................");
conn.rollback();
System.out.println("CONNECTION Rollback......................................");
}
}
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(isLocalConn)
conn.close();
}
catch(Exception e)
{
System.out.println("Exception : "+e);e.printStackTrace();
throw new ITMException(e);
}
}
return errString;
} //end of confirm method
@SuppressWarnings({ "rawtypes", "unchecked" })
private String loanConfirm(String tranId,String xtraParams,String forcedFlag, Connection conn)throws RemoteException,ITMException
{
PreparedStatement pstmt = null;
PreparedStatement pstmtInsert = null;
PreparedStatement pstmtInner = null;
ResultSet rs = null;
ResultSet rsInner = null;
String sql = "",sqlInsert = "",sqlInner="";
String loginEmpCode = "" ;
ITMDBAccessEJB itmDBAccessEJB = null;
FinCommon Fcommon = new FinCommon();
DistCommon Dcommon = new DistCommon();
java.sql.Timestamp tranDate = null;
java.sql.Timestamp effDate = null;
java.sql.Timestamp billDate = null;
java.sql.Timestamp dueDate = null;
java.sql.Timestamp resiDate = null;
java.sql.Timestamp relieveDate = null;
HashMap mischdrMap=null,miscdetMap=null,miscAdvMap=null,miscAcctMap =null,miscdetListMap=null;
ArrayList miscdetList = new ArrayList();
ArrayList miscAcctList = new ArrayList();
ArrayList miscAdvList = new ArrayList();
double taxAmt=0,rndTo=0,totAmt=0,netAmt=0,advAmt=0,netAmtBc=0,diffAmtExch=0,suppBillAmt=0,exchRate=0,rndAmt=0,billAmt=0;
String siteCodehdr="",loanType="",tranType="",loanPartyhdr="",bankCode="",
acctCodePay="",cctrCodePay="",securityTerm="",othRef="",remarks=null,currCode="",finEnt="";
String lineNoDet="",refSerDet="",AcctCodeDet="",cctrCodeDet="",currCodeDet="",exchRateDet="",refNoDet="",sundryCodeDet="",
sundryTypeDet="";
String errString="";
Timestamp sanctionDt=null,disburseDt=null,tranDatehdr=null;
Double loanAmthdr=0d,marginAmt=0d,marginAmtDet=0d,loanAmtBcHdr=0d,amountPaid=0d;
int lineInt =0,cnt = 0;
SimpleDateFormat sdf = null;
try
{
sdf=new SimpleDateFormat(new E12GenericUtility().getApplDateFormat());
//Getting Data from loan header
sql=" SELECT TRAN_DATE, SITE_CODE, LOAN_TYPE, TRAN_TYPE, LOAN_PARTY, PARTY_NAME, BANK_CODE,BANK_NAME,"
+ "SANTION_DATE, DISBURS_DATE, ACCT_CODE__PAY, CCTR_CODE__PAY, LOAN_AMOUNT, CURR_CODE, EXCH_RATE,"
+ "LOAN_AMT__BC, LOAN_TENURE, LOAN_TENUE_UNIT, REPAY_DAYS, INT_RATE, MORATORIUM_PRD,"
+ "SECURITY_TERM, OTH_REF, REMARKS"
+ "FROM LOANPARTY WHERE tran_id = ?";
pstmt=conn.prepareStatement(sql);
rs=pstmt.executeQuery();
if(rs.next())
{
tranDatehdr=rs.getTimestamp("TRAN_DATE");
siteCodehdr=rs.getString("SITE_CODE");
loanType=rs.getString("LOAN_TYPE");
tranType=rs.getString("TRAN_TYPE");
loanPartyhdr=rs.getString("LOAN_PARTY");
bankCode=rs.getString("BANK_CODE");
sanctionDt=rs.getTimestamp("SANTION_DATE");
disburseDt=rs.getTimestamp("DISBURS_DATE");
acctCodePay=rs.getString("ACCT_CODE__PAY");
cctrCodePay=rs.getString("CCTR_CODE__PAY");
loanAmthdr=rs.getDouble("LOAN_AMOUNT");
loanAmtBcHdr=rs.getDouble("LOAN_AMT__BC");
currCode=rs.getString("CURR_CODE");
exchRate=rs.getDouble("EXCH_RATE");
securityTerm=rs.getString("SECURITY_TERM");
othRef=rs.getString("OTH_REF");
remarks=rs.getString("REMARKS");
}
pstmt.close();
pstmt=null;
rs.close();
rs=null;
//Getting data from loan_detail
sql="SELECT L.TRAN_ID,L.LINE_NO, L.REF_SER, L.REF_NO, L.ACCT_CODE,L.CCTR_CODE,L.AMOUNT_PAID,M.SUNDRY_CODE,M.SUNDRY_TYPE"
+ "FROM LOAN_DET L,MISC_VOUCHER M WHERE L.tran_id = ? and M.tran_id=L.ref_no";
pstmt=conn.prepareStatement(sql);
rs=pstmt.executeQuery();
if(rs.next())
{
lineNoDet=rs.getString("LINE_NO");
refSerDet=rs.getString("REF_SER");
refNoDet=rs.getString("REF_NO");
AcctCodeDet=rs.getString("ACCT_CODE");
cctrCodeDet=rs.getString("CCTR_CODE");
amountPaid=rs.getDouble("AMOUNT_PAID");
sundryCodeDet=rs.getString("SUNDRY_CODE");
sundryTypeDet=rs.getString("SUNDRY_TYPE");
currCodeDet=rs.getString("CURR_CODE");
exchRateDet=rs.getString("EXCH_RATE");
}
pstmt.close();
pstmt=null;
rs.close();
rs=null;
//Finentity from site
sql="Select fin_entity from site where site_code = ? ";
pstmt=conn.prepareStatement(sql);
rs=pstmt.executeQuery();
if(rs.next())
{
finEnt=rs.getString(1);
}
pstmt.close();
pstmt=null;
rs.close();
rs=null;
HashMap sundryBalUpd=new HashMap();
HashMap miscPayUpd= new HashMap();
//New buyers Credit
if("0".equalsIgnoreCase(loanType))
{
//creating misc receipt entry
StringBuffer xmlBuff= new StringBuffer();
xmlBuff.append("<?xml version='1.0' encoding='ISO-8859-1'?>\n");
xmlBuff.append("<DocumentRoot>");
xmlBuff.append("<description>").append("Datawindow Root").append("</description>");
xmlBuff.append("<group0>");
xmlBuff.append("<description>").append("Group0 description").append("</description>");
xmlBuff.append("<Header0>");
xmlBuff.append("<objName><![CDATA[").append("misc_rcp").append("]]></objName>");
xmlBuff.append("<pageContext><![CDATA[").append("1").append("]]></pageContext>");
xmlBuff.append("<objContext><![CDATA[").append("1").append("]]></objContext>");
xmlBuff.append("<editFlag><![CDATA[").append("A").append("]]></editFlag>");
xmlBuff.append("<focusedColumn><![CDATA[").append("").append("]]></focusedColumn>");
xmlBuff.append("<action><![CDATA[").append("SAVE").append("]]></action>");
xmlBuff.append("<elementName><![CDATA[").append("").append("]]></elementName>");
xmlBuff.append("<keyValue><![CDATA[").append("1").append("]]></keyValue>");
xmlBuff.append("<taxKeyValue><![CDATA[").append("").append("]]></taxKeyValue>");
xmlBuff.append("<saveLevel><![CDATA[").append("1").append("]]></saveLevel>");
xmlBuff.append("<forcedSave><![CDATA[").append(true).append("]]></forcedSave>");
xmlBuff.append("<taxInFocus><![CDATA[").append(false).append("]]></taxInFocus>");
xmlBuff.append("<description>").append("Header0 members").append("</description>");
xmlBuff.append("<Detail1 dbID=\"\" domID=\'1\' objName=\"misc_rcp\" objContext=\"1\">");
xmlBuff.append("<attribute selected=\"N\" updateFlag=\"A\" status=\"N\" pkNames=\"\"/>");
xmlBuff.append("<tran_id/>");
xmlBuff.append("<tran_date><![CDATA[" + (sdf.format(tranDatehdr)) + "]]></tran_date>");
xmlBuff.append("<sundry_code><![CDATA[" + (loanPartyhdr) + "]]></tran_date>");
xmlBuff.append("<sundry_type><![CDATA[" + ("L") + "]]></sundry_type>");
xmlBuff.append("<tran_type><![CDATA[" + ("") + "]]></tran_type>");//tran type ??
xmlBuff.append("<site_code><![CDATA[" + (siteCodehdr) + "]]></site_code>");
xmlBuff.append("<bank_code><![CDATA[" + (bankCode) + "]]></bank_code>");
xmlBuff.append("<net_amt><![CDATA[" + (loanAmthdr) + "]]></net_amt>");
xmlBuff.append("<curr_code><![CDATA[" + (currCode) + "]]></curr_code>");
xmlBuff.append("<exch_rate><![CDATA[" + (exchRate) + "]]></exch_rate>");
xmlBuff.append("<net_amt__bc><![CDATA[" + (loanAmtBcHdr) + "]]></net_amt__bc>");
xmlBuff.append("<sundry_type><![CDATA[" + ("L") + "]]></sundry_type>");
xmlBuff.append("</Detail1>");
xmlBuff.append("<Detail2 dbID=\"\" domID=\'1\' objName=\"misc_rcp\" objContext=\"2\">");
xmlBuff.append("<attribute pkNames=\"\" selected=\"N\" updateFlag=\"A\" status=\"N\" />");
xmlBuff.append("<tran_id/>");
xmlBuff.append("<line_no>"+("1")+"</line_no>");
xmlBuff.append("<acct_code><![CDATA[" + (acctCodePay) + "]]></acct_code>");
xmlBuff.append("<cctr_code><![CDATA[" + (cctrCodePay) + "]]></cctr_code>");
xmlBuff.append("<amount><![CDATA[" + netAmt + "]]></amount>");
xmlBuff.append("<anal_code><![CDATA[" +null+ "]]></anal_code>");
xmlBuff.append("</Detail2>");
errString=saveData(xtraParams,siteCodehdr, xmlBuff.toString(), conn);
if( errString.indexOf("Success") == -1 )
{
return errString;
}
//Getting tranID from response String
String[] arrayForTranId = errString.split("<TranID>");
int endIndex = arrayForTranId[1].indexOf("</TranID>");
tranId = arrayForTranId[1].substring(0,endIndex);
if(tranId != null && tranId.trim().length() > 0)
{
System.out.println("tran_id [" + tranId + "]");
errString = null;
}
//confirm webservice misc receipt
errString=confirmReceipt("misc_rcp",tranId, xtraParams,forcedFlag,conn);
if( errString.indexOf("VTSUCC1") == -1 )
{
return errString;
}
//--Generating payable against loanParty Start
miscPayUpd.put("tran_ser","LCVOUH");
miscPayUpd.put("tran_date",tranDate);
miscPayUpd.put("bill_no"," ");
miscPayUpd.put("curr_code",currCode);
miscPayUpd.put("exchrate",exchRate);
miscPayUpd.put("sundry_type","L");
miscPayUpd.put("sundry_code",loanPartyhdr);
miscPayUpd.put("acct_code_lc",acctCodePay);
miscPayUpd.put("cctr_code_lc",cctrCodePay);
//miscPayUpd.put("due_date",dueDate);
miscPayUpd.put("site_code",siteCodehdr);
miscPayUpd.put("tot_amt",loanAmthdr);
miscPayUpd.put("bank_code",bankCode);
miscPayUpd.put("auto_pay","N");
miscPayUpd.put("pay_mode","T");
miscPayUpd.put("paid","N");
miscPayUpd.put("adv_amt",0);
errString=Fcommon.gbfMiscPayUpd(miscPayUpd, conn);
if(errString!=null && errString.trim().length()>0)
{
return errString;
}
//--Generating payable against loanParty end
}
else if("1".equalsIgnoreCase(loanType)) //New TermLoan
{
}
else //convert buyers credit to Term Loan(Type 2)
{
//--Negative payables towards detail loan party start
miscPayUpd.put("tran_ser","");
miscPayUpd.put("tran_date",tranDate);
miscPayUpd.put("ref_no",refNoDet);
miscPayUpd.put("bill_no"," ");
miscPayUpd.put("curr_code",currCode);
miscPayUpd.put("exchrate",exchRate);
miscPayUpd.put("sundry_type",sundryTypeDet);
miscPayUpd.put("sundry_code",sundryCodeDet);
miscPayUpd.put("acct_code",AcctCodeDet);
miscPayUpd.put("cctr_code",cctrCodeDet);
//miscPayUpd.put("due_date",dueDate);
miscPayUpd.put("site_code",siteCodehdr);
miscPayUpd.put("tot_amt",-marginAmtDet);
miscPayUpd.put("bank_code",bankCode);
miscPayUpd.put("auto_pay","N");
miscPayUpd.put("pay_mode","T");
miscPayUpd.put("paid","N");
miscPayUpd.put("adv_amt",0);
errString=Fcommon.gbfMiscPayUpd(miscPayUpd, conn);
if(errString!=null && errString.trim().length()>0)
{
return errString;
}
//Gltrace debit note to sundry code
HashMap glTraceUpd=new HashMap();
glTraceUpd.put("tran_date", tranDate);
glTraceUpd.put("eff_date", tranDate);
glTraceUpd.put("fin_entity", "");
glTraceUpd.put("site_code", siteCodehdr);
glTraceUpd.put("sundry_type", sundryTypeDet);
glTraceUpd.put("sundry_code", sundryCodeDet);
glTraceUpd.put("acct_code", AcctCodeDet);
glTraceUpd.put("cctr_code", cctrCodeDet);
glTraceUpd.put("curr_code", currCodeDet);
glTraceUpd.put("exch_rate", exchRateDet);
glTraceUpd.put("dr_amt", amountPaid);
glTraceUpd.put("cr_amt", 0);
//glTraceUpd.put("ref_type", "D");
glTraceUpd.put( "ref_id",tranId);
errString=Fcommon.glTraceUpdate(glTraceUpd, conn);
if(errString!=null && errString.trim().length()>0)
{
return errString;
}
//SundryBal debit to sundry code
sundryBalUpd.put("tran_date", tranDate);
//sundryBalUpd.put("eff_date", effDate);
sundryBalUpd.put("fin_entity", finEnt);
sundryBalUpd.put("site_code", siteCodehdr);
sundryBalUpd.put("sundry_type", sundryTypeDet);
sundryBalUpd.put("sundry_code", sundryCodeDet);
sundryBalUpd.put("acct_code", acctCodePay);
sundryBalUpd.put("cctr_code", cctrCodeDet);
sundryBalUpd.put("curr_code", currCodeDet);
sundryBalUpd.put("exch_rate", exchRateDet);
sundryBalUpd.put("dr_amt", 0);
sundryBalUpd.put("cr_amt", amountPaid);
sundryBalUpd.put("adv_amt", 0);
errString=Fcommon.gbf_sundrybal_upd(sundryBalUpd, conn);
if(errString!=null && errString.trim().length()>0)
{
return errString;
}
//--negative payables towards detail loan party start
///Positive payable against loanParty header Start
miscPayUpd.put("tran_ser","");//Tran_ser ??
miscPayUpd.put("tran_date",tranDate);
miscPayUpd.put("ref_no",refNoDet);
miscPayUpd.put("bill_no"," ");
miscPayUpd.put("curr_code",currCode);
miscPayUpd.put("exchrate",exchRate);
miscPayUpd.put("sundry_type",sundryTypeDet);
miscPayUpd.put("sundry_code",sundryCodeDet);
miscPayUpd.put("acct_code",acctCodePay);
miscPayUpd.put("cctr_code_lc",cctrCodePay);
miscPayUpd.put("due_date",dueDate);
miscPayUpd.put("site_code",siteCodehdr);
miscPayUpd.put("tot_amt",loanAmthdr);
miscPayUpd.put("bank_code",bankCode);
miscPayUpd.put("auto_pay","N");
miscPayUpd.put("pay_mode","T");
miscPayUpd.put("paid","N");
miscPayUpd.put("adv_amt",0);
//Misc Payables against loanParty
errString=Fcommon.gbfMiscPayUpd(miscPayUpd, conn);
if(errString!=null && errString.trim().length()>0)
{
return errString;
}
glTraceUpd.put("tran_date", tranDate);
glTraceUpd.put("eff_date", tranDate);
glTraceUpd.put("fin_entity", "");
glTraceUpd.put("site_code", siteCodehdr);
glTraceUpd.put("sundry_type", loanPartyhdr);
glTraceUpd.put("sundry_code", "L");
glTraceUpd.put("acct_code", acctCodePay);
glTraceUpd.put("cctr_code", cctrCodePay);
glTraceUpd.put("curr_code", currCode);
glTraceUpd.put("exch_rate", exchRate);
glTraceUpd.put("dr_amt", amountPaid);
glTraceUpd.put("cr_amt", 0);
//glTraceUpd.put("ref_type", "D");
glTraceUpd.put( "ref_id",tranId);
errString=Fcommon.glTraceUpdate(glTraceUpd, conn);
if(errString!=null && errString.trim().length()>0)
{
return errString;
}
sundryBalUpd.put("tran_date", tranDate);
//sundryBalUpd.put("eff_date", effDate);
sundryBalUpd.put("fin_entity", finEnt);
sundryBalUpd.put("site_code", siteCodehdr);
sundryBalUpd.put("sundry_type", "L");
sundryBalUpd.put("sundry_code", loanPartyhdr);
sundryBalUpd.put("acct_code", acctCodePay);
sundryBalUpd.put("cctr_code", cctrCodePay);
sundryBalUpd.put("curr_code", currCode);
sundryBalUpd.put("exch_rate", exchRate);
sundryBalUpd.put("dr_amt", 0);
sundryBalUpd.put("cr_amt", amountPaid);
sundryBalUpd.put("adv_amt", 0);
errString=Fcommon.gbf_sundrybal_upd(sundryBalUpd, conn);
if(errString!=null && errString.trim().length()>0)
{
return errString;
}
///Positive payable against loanParty header end
}
} //try
catch (Exception e)
{
System.out.println("Exception :loanConfirm :loanConfirmmethod :==>"+e.getMessage());
errString = genericUtility.createErrorString(e);
throw new ITMException(e);
}
finally
{
try
{
if(rs != null)
{
rs.close();
rs = null;
}
if(rsInner != null)
{
rsInner.close();
rsInner = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(pstmtInner != null)
{
pstmtInner.close();
pstmtInner = null;
}
}
catch(Exception e)
{
System.out.println("Exception : "+e);e.printStackTrace();
throw new ITMException(e);
}
}
return errString;
}
private String saveData(String xtraParams,String siteCode, String xmlString, Connection conn) throws ITMException
{
System.out.println("saving data...........");
InitialContext ctx = null;
String retString = null;
String userId =""; //Added By PriyankaC on 15/03/2018. [START]
MasterStatefulLocal masterStateful = null; // for ejb3
E12GenericUtility genericUtility=new E12GenericUtility();
ibase.utility.UserInfoBean userInfoBean=new UserInfoBean();
try
{
//Added By PriyankaC on 15/03/2018. [START]
userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode");
System.out.println("userId" + userId + "]");
//Added By PriyankaC on 15/03/2018. [END]
AppConnectParm appConnect = new AppConnectParm();
ctx = new InitialContext(appConnect.getProperty());
masterStateful = (MasterStatefulLocal) ctx.lookup("ibase/MasterStatefulEJB/local");
System.out.println("-----------masterStateful------- " + masterStateful);
String[] authencate = new String[2];
//authencate[0] = "";
authencate[0] = userId; //Changed By PriynkaC on 15/03/2018
authencate[1] = "";
System.out.println("xmlString to masterstateful [" + xmlString + "]");
userInfoBean.setEmpCode(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode"));
userInfoBean.setRemoteHost(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "termId"));
userInfoBean.setSiteCode(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode"));
userInfoBean.setLoginCode(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode"));
userInfoBean.setEntityCode(genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode"));
retString = masterStateful.processRequest(authencate, siteCode, true, xmlString, true, conn);
} catch (ITMException itme)
{
System.out.println("ITMException :CreateDistOrder :saveData :==>");
throw itme;
} catch (Exception e)
{
e.printStackTrace();
System.out.println("Exception :CreateDistOrder :saveData :==>");
throw new ITMException(e);
}
return retString;
}
public String confirmReceipt(String businessObj, String tranIdFr,String xtraParams, String forcedFlag,Connection conn) throws ITMException
{
String methodName = "";
String compName = "";
String retString = "";
String serviceCode = "";
String serviceURI = "";
String actionURI = "";
String sql = "";
PreparedStatement pStmt = null;
ResultSet rs = null;
int cnt = 0;
try
{
methodName = "gbf_post";
actionURI = "http://NvoServiceurl.org/" + methodName;
forcedFlag="";
System.out.println("forcedFlag Method["+forcedFlag+"]");
sql = "SELECT SERVICE_CODE,COMP_NAME FROM SYSTEM_EVENTS WHERE OBJ_NAME = ? AND EVENT_CODE = 'pre_confirm' ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1,businessObj);
rs = pStmt.executeQuery();
if ( rs.next() )
{
serviceCode = rs.getString("SERVICE_CODE");
compName = rs.getString("COMP_NAME");
}
if (pStmt != null)
{
pStmt.close();
pStmt=null;
}
if (rs !=null)
{
rs.close();
rs=null;
}
sql = "SELECT SERVICE_URI FROM SYSTEM_EVENT_SERVICES WHERE SERVICE_CODE = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1,serviceCode);
rs = pStmt.executeQuery();
if ( rs.next() )
{
serviceURI = rs.getString("SERVICE_URI");
}
if (pStmt != null)
{
pStmt.close();
pStmt=null;
}
if (rs !=null)
{
rs.close();
rs=null;
}
System.out.println("SERVICE_URI["+serviceURI+"]");
Service service = new Service();
Call call = (Call)service.createCall();
call.setTargetEndpointAddress(new java.net.URL(serviceURI));
call.setOperationName( new javax.xml.namespace.QName("http://NvoServiceurl.org", methodName ) );
call.setUseSOAPAction(true);
call.setSOAPActionURI(actionURI);
Object[] aobj = new Object[4];
call.addParameter( new javax.xml.namespace.QName("http://NvoServiceurl.org", "component_name"), XMLType.XSD_STRING, ParameterMode.IN);
call.addParameter( new javax.xml.namespace.QName("http://NvoServiceurl.org", "tran_id"), XMLType.XSD_STRING, ParameterMode.IN);
call.addParameter( new javax.xml.namespace.QName("http://NvoServiceurl.org", "xtra_params"), XMLType.XSD_STRING, ParameterMode.IN);
call.addParameter( new javax.xml.namespace.QName("http://NvoServiceurl.org", "forced_flag"), XMLType.XSD_STRING, ParameterMode.IN);
aobj[0] = new String(compName);
aobj[1] = new String(tranIdFr);
aobj[2] = new String(xtraParams);
aobj[3] = new String(forcedFlag);
call.setReturnType(XMLType.XSD_STRING);
retString = (String)call.invoke(aobj);
System.out.println("Return string from NVO is:==>["+retString+"]");
}
catch(Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if (pStmt != null )
{
pStmt.close();
pStmt = null;
}
if (rs !=null)
{
rs.close();
rs=null;
}
}
catch(Exception e)
{}
}
return retString;
}
} //class
package ibase.webitm.ejb.fin.adv;
import java.rmi.RemoteException;
import javax.ejb.Local;
import ibase.webitm.ejb.ActionHandlerLocal;
import ibase.webitm.utility.ITMException;
@Local
public interface LoanConfLocal extends ActionHandlerLocal//, EJBObject
{
public String confirm(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.fin.adv;
import java.rmi.RemoteException;
import javax.ejb.Remote;
import ibase.webitm.ejb.ActionHandlerRemote;
import ibase.webitm.utility.ITMException;
@Remote
public interface LoanConfRemote extends ActionHandlerRemote//, EJBObject
{
public String confirm(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
\ No newline at end of file
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