Skip to content

B
business-java
Commit dcc82084 authored by rtiwari's avatar rtiwari
Browse files
Options

added for charge back data uploading req: DI3FSUN023 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@94212 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 7e142ed0
Hide whitespace changes
Inline Side-by-side
Showing with 1297 additions and 0 deletions
webitm-dis/ibase/webitm/ejb/dis/adv/ChargeBackFormAccept.java 0 → 100755
View file @ dcc82084
package ibase.webitm.ejb.dis.adv;
import ibase.utility.CommonConstants;
import ibase.webitm.utility.*;
import ibase.webitm.ejb.*;
import ibase.system.config.*;
import java.sql.*;
import java.text.SimpleDateFormat;
import java.rmi.*;
import java.util.*;
import org.w3c.dom.*;
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class ChargeBackFormAccept extends ActionHandlerEJB implements ChargeBackFormVerifyLocal, ChargeBackFormVerifyRemote
{
static
{
System.out.println(" ChargeBackFormAccept getch()");
}
public String actionHandler() throws RemoteException,ITMException
{
System.out.println(" nO ARGS FOUND ::");
return "";
}
public String actionHandler(String tranId, String xtraParams, String forcedFlag) throws RemoteException, ITMException
{
String returnString=null;
System.out.println(".......tranId......."+tranId);
System.out.println(".......xtraParams..."+xtraParams);
System.out.println(".......forcedFlag..."+forcedFlag);
try
{
if(tranId!=null && tranId.trim().length()>0)
{
returnString = chargeBackAccept(tranId,xtraParams,forcedFlag);
}
}
catch (Exception e)
{
System.out.println("Exception ..."+e.getMessage());
e.printStackTrace();
throw new ITMException(e);
}
return returnString;
}
private String chargeBackAccept(String tranId,String xtraParams,String forcedFlag) throws RemoteException,ITMException
{
System.out.println("chargeBackUpd () called........"+tranId);
double qty=0.0;
double saleqty=0.0,saleretqty=0.0,unconfclaimed=0.0,confclaimed=0.0;
String itemCode="",lotNo="",porderNo="",porderDate= "",itemSer= "",rateContr="";
String errString = null,sql="";
String siteCode="",custCode="",tranDatestr="",tranType="",verifyFlag="";
String custCodeCredit = "",loginSite;
Connection conn = null;
ConnDriver connDriver = null;
PreparedStatement pStmt = null,pStmt1=null;
ResultSet rs = null;
ITMDBAccessEJB itmDBAccessEJB = null;
String childNodeName = "";
Node parentNode = null;
NodeList childNodeList = null;
NodeList parentNodeList = null;
int parentNodeListLength = 0;
int childNodeListLength = 0;
Node childNode = null;
StringBuffer errCode = new StringBuffer("");
StringBuffer errCodeDet = null;
String errCodeString = "";
ArrayList list = new ArrayList();
boolean rejectedFlag = false;
int elements = 0;
int lineNo =0 ;
GenericUtility genericUtility = GenericUtility.getInstance();
int cnf=0,cnt=0,chbHed=0,chbDet=0,upConf=0;
java.sql.Timestamp tranDateTs = null;
String prdCode = "",statSal = "";
try
{
connDriver = null;
genericUtility = new GenericUtility();
itmDBAccessEJB = new ITMDBAccessEJB();
connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
connDriver = null;
conn.setAutoCommit(false);
//parentNodeList = dom1.getElementsByTagName("Detail1");
//parentNodeListLength = parentNodeList.getLength();
loginSite = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode");System.out.println(" loginSite::"+loginSite);
// System.out.println("parentNodeListLength------------------->"+parentNodeListLength);
//for (int selectedRow = 0; selectedRow < parentNodeListLength; selectedRow++)
//{
chbHed=0;chbDet=0;
// parentNode = parentNodeList.item(selectedRow);
// childNodeList = parentNode.getChildNodes();
// childNodeListLength = childNodeList.getLength();
// System.out.println("childNodeListLength---->>> "+ childNodeListLength);
//
sql = " select count(*) from charge_back_form where tran_id = ? and confirmed = 'Y'";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, tranId.trim());
rs = pStmt.executeQuery();
if(rs.next())
{
cnf = rs.getInt(1);
}if(rs != null)
rs.close();
rs = null;
if(pStmt != null)
pStmt.close();
pStmt=null;
if(cnf > 0)
{
errString = itmDBAccessEJB.getErrorString("","VTACCALR ","","",conn);
return errString;
}
String chbtranID = generateTranId("w_charge_back",loginSite,conn );System.out.println(" charge_back_tran_id ::"+chbtranID);
sql = " SELECT TRAN_DATE,CUST_CODE__CREDIT,TRAN_TYPE,REMARKS ,PRISE_LIST ,CURR_CODE ,EXCH_RATE,AMOUNT ,NET_AMT,NET_AMT__BC,"+
" EMP_CODE__APRV ,CHG_DATE ,CHG_USER,CHG_TERM ,TRAN_ID__CRN,EFF_DATE ,TAX_AMT,PORDER_NO ,PORDER_DATE ,VENDOR_NO ,"+
" INT_VENDOR_NO ,CUST_NAME_BAT ,CUST_PNAME_BAT ,TEST_PROD ,CUST_CODE__SHIP ,CUST_NAME__SHIP ,CUST_CODE__END,CUST_NAME,CONTRACT_NO ,"+
" PRICE_LIST,CUST_CODE_DLV,SITE_CODE__LOG,CLAUM_AMT ,ITEM_SER,PARENT__TRAN_ID ,REV__TRAN ,SPEC_REASON ,DIRECT_INV ,"+
" SALE_PERIOD ,SITE_CODE__CR ,DISCOUNT_INV ,EMP_CODE "+
" FROM CHARGE_BACK_FORM WHERE TRAN_ID = ? and VERIFY_FLAG= 'Y' AND CONFIRMED NOT IN ('Y') ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, tranId.trim());
rs = pStmt.executeQuery();
if(rs.next())
{
sql = " INSERT INTO CHARGE_BACK( TRAN_DATE,CUST_CODE__CREDIT,TRAN_TYPE,REMARKS ,PRISE_LIST ,CURR_CODE ,EXCH_RATE,AMOUNT ,NET_AMT,NET_AMT__BC,"+
" EMP_CODE__APRV ,CHG_DATE ,CHG_USER,CHG_TERM ,TRAN_ID__CRN,EFF_DATE ,TAX_AMT,PORDER_NO ,PORDER_DATE ,VENDOR_NO ,"+
" INT_VENDOR_NO ,CUST_NAME_BAT ,CUST_PNAME_BAT ,TEST_PROD ,CUST_CODE__SHIP ,CUST_NAME__SHIP ,CUST_CODE__END,CUST_NAME,CONTRACT_NO ,"+
" PRICE_LIST,CUST_CODE_DLV,SITE_CODE__LOG,CLAUM_AMT ,ITEM_SER,PARENT__TRAN_ID ,REV__TRAN ,SPEC_REASON ,DIRECT_INV ,"+
" SALE_PERIOD ,SITE_CODE__CR ,DISCOUNT_INV ,EMP_CODE,TRAN_ID ) "+
" values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
pStmt1 = conn.prepareStatement(sql);
pStmt1.setTimestamp(1,rs.getTimestamp(1));
pStmt1.setString(2,rs.getString(2));
pStmt1.setString(3,rs.getString(3));
pStmt1.setString(4,rs.getString(4));
pStmt1.setString(5,rs.getString(5));
pStmt1.setString(6,rs.getString(6));
pStmt1.setDouble(7,rs.getDouble(7));
pStmt1.setDouble(8,rs.getDouble(8));
pStmt1.setDouble(9,rs.getDouble(9));
pStmt1.setDouble(10,rs.getDouble(10));
pStmt1.setString(11,rs.getString(11));
pStmt1.setTimestamp(12,rs.getTimestamp(12));
pStmt1.setString(13,rs.getString(13));
pStmt1.setString(14,rs.getString(14));
pStmt1.setString(15,rs.getString(15));
pStmt1.setTimestamp(16,rs.getTimestamp(16));
pStmt1.setDouble(17,rs.getDouble(17));
pStmt1.setString(18,rs.getString(18));
pStmt1.setTimestamp(19,rs.getTimestamp(19));
pStmt1.setString(20,rs.getString(20));
pStmt1.setString(21,rs.getString(21));
pStmt1.setString(22,rs.getString(22));
pStmt1.setString(23,rs.getString(23));
pStmt1.setString(24,rs.getString(24));
pStmt1.setString(25,rs.getString(25));
pStmt1.setString(26,rs.getString(26));
pStmt1.setString(27,rs.getString(27));
pStmt1.setString(28,rs.getString(28));
pStmt1.setString(29,rs.getString(29));
pStmt1.setString(30,rs.getString(30));
pStmt1.setString(31,rs.getString(31));
pStmt1.setString(32,rs.getString(32));
pStmt1.setDouble(33,rs.getDouble(33));
pStmt1.setString(34,rs.getString(34));
pStmt1.setString(35,rs.getString(35));
pStmt1.setString(36,rs.getString(36));
pStmt1.setString(37,rs.getString(37));
pStmt1.setString(38,rs.getString(38));
pStmt1.setDouble(39,rs.getDouble(39));
pStmt1.setString(40,rs.getString(40));
pStmt1.setString(41,rs.getString(41));
pStmt1.setString(42,rs.getString(42));
pStmt1.setString(43,chbtranID);
chbHed = pStmt1.executeUpdate();
if(pStmt1 != null)
pStmt1.close();
pStmt1=null;
System.out.println("No. of uploaded header records in a line ::"+chbHed);
}
if(rs != null)
rs.close();
rs = null;
if(pStmt != null)
pStmt.close();
pStmt=null;
sql = " SELECT LINE_NO,CONTRACT_NO ,LINE_NO__CONTR ,CUST_CODE__END ,QUANTITY ,LOT_NO ,RATE__SELL ,RATE__CONTR,RATE__DIFF,AMOUNT,TAX_AMT ,TAX_CLASS,TAX_CHAP ,"+
" TAX_ENV,INVOICE_ID,ITEM_SER,DISCOUNT_PER ,DISCOUNT_AMT ,PORDER_NO,PORDER_DATE , BUYERS_PROD_CODE ,DISC_AMT ,CUST_GRP ,ITEM_REF, NET_AMT ,TRAN_ID__CRN ,"+
" ERROR_MSG,PRICELIST_RATE,CONTRACT_RATE ,ERROR_CODE ,ITEM_CODE__NDC,UNCONF_CLAIMED,DISCOUNT_PER_UNIT ,"+
" CONF_CLAIMED ,SALE_QTY ,SALE_RET_QTY FROM CHARGE_BACK_FORM_DET WHERE TRAN_ID IN(SELECT TRAN_ID FROM CHARGE_BACK_FORM WHERE TRAN_ID = ? AND VERIFY_FLAG = 'Y' AND CONFIRMED NOT IN ('Y')) " +
" AND length(error_code) = 0 or error_code is null";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, tranId.trim());
rs = pStmt.executeQuery();
while(rs.next())
{
lineNo ++;
sql = " INSERT INTO CHARGE_BACK_DET(LINE_NO,CONTRACT_NO ,LINE_NO__CONTR ,CUST_CODE__END ,QUANTITY ,LOT_NO ,RATE__SELL ,RATE__CONTR,RATE__DIFF,AMOUNT,TAX_AMT ,TAX_CLASS,TAX_CHAP ,"+
" TAX_ENV,INVOICE_ID,ITEM_SER,DISCOUNT_PER ,DISCOUNT_AMT ,PORDER_NO,PORDER_DATE , BUYERS_PROD_CODE ,DISC_AMT ,CUST_GRP ,ITEM_REF, NET_AMT ,TRAN_ID__CRN ,"+
" ERROR_MSG,PRICELIST_RATE,CONTRACT_RATE ,ERROR_CODE ,ITEM_CODE__NDC,UNCONF_CLAIMED,DISCOUNT_PER_UNIT ,"+
" CONF_CLAIMED ,SALE_QTY ,SALE_RET_QTY,TRAN_ID) "+
" values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
pStmt1 = conn.prepareStatement(sql);
pStmt1.setDouble(1,lineNo);
pStmt1.setString(2,rs.getString(2));
pStmt1.setString(3,rs.getString(3));
pStmt1.setString(4,rs.getString(4));
pStmt1.setDouble(5,rs.getDouble(5));
pStmt1.setString(6,rs.getString(6));
pStmt1.setDouble(7,rs.getDouble(7));
pStmt1.setDouble(8,rs.getDouble(8));
pStmt1.setDouble(9,rs.getDouble(9));
pStmt1.setDouble(10,rs.getDouble(10));
pStmt1.setDouble(11,rs.getDouble(11));
pStmt1.setString(12,rs.getString(12));
pStmt1.setString(13,rs.getString(13));
pStmt1.setString(14,rs.getString(14));
pStmt1.setString(15,rs.getString(15));
pStmt1.setString(16,rs.getString(16));
pStmt1.setDouble(17,rs.getDouble(17));
pStmt1.setDouble(18,rs.getDouble(18));
pStmt1.setString(19,rs.getString(19));
pStmt1.setTimestamp(20,rs.getTimestamp(20));
pStmt1.setString(21,rs.getString(21));
pStmt1.setDouble(22,rs.getDouble(22));
pStmt1.setString(23,rs.getString(23));
pStmt1.setString(24,rs.getString(24));
pStmt1.setDouble(25,rs.getDouble(25));
pStmt1.setString(26,rs.getString(26));
pStmt1.setString(27,rs.getString(27));
pStmt1.setDouble(28,rs.getDouble(28));
pStmt1.setDouble(29,rs.getDouble(29));
pStmt1.setString(30,rs.getString(30));
pStmt1.setString(31,rs.getString(31));
pStmt1.setDouble(32,rs.getDouble(32));
pStmt1.setDouble(33,rs.getDouble(33));
pStmt1.setDouble(34,rs.getDouble(34));
pStmt1.setDouble(35,rs.getDouble(35));
pStmt1.setDouble(36,rs.getDouble(36));
pStmt1.setString(37,chbtranID);
chbDet = chbDet + pStmt1.executeUpdate();
if(pStmt1 != null)
pStmt1.close();
pStmt1=null;
}
System.out.println("No. of uploaded detail records in a line::"+chbDet);
if(rs != null)
rs.close();
rs = null;
if(pStmt != null)
pStmt.close();
pStmt=null;
if(chbHed ==0 && chbDet == 0)
{
// rejectedFlag = true;
// list.add(tranId);
// list.add(custCode);
// elements ++;
errString = itmDBAccessEJB.getErrorString("","VTACCNT ","","",conn);
}
else
{
// errString = "Accepted";
sql = " update charge_back_form set tran_id__cb = ? , confirmed = 'Y' where tran_id = ?";
pStmt1 = conn.prepareStatement(sql);
pStmt1.setString(1,chbtranID);
pStmt1.setString(2,tranId);
upConf = upConf + pStmt1.executeUpdate();
if(pStmt1 != null)
pStmt1.close();
pStmt1=null;
errString = itmDBAccessEJB.getErrorString("","VTACCSUCC ","","",conn);
}
System.out.println(" No. of successfully accepted records in complete trans."+upConf);
// if(rejectedFlag)
// {
// errString = itmDBAccessEJB.getErrorString("","VTREJCHB","","",conn);
// String begPart = errString.substring( 0, errString.indexOf("<trace>") + 7 );
// String endPart = errString.substring( errString.indexOf("</trace>"));
// String mainStr = begPart + "Following error has occured\n" ;
// if(elements > 0 )
// {
// mainStr = mainStr + "Transaction not varified: \n";
// }
// for(int i = 0; i < elements * 2; i++ )
// {
// if( i > 0)
// {
// i -= 1;
// }
// mainStr = mainStr +
// "Tran Id :"+list.get(i++)+ ",cust code :"+ list.get(i++) + "\n" ;
// }
// mainStr = mainStr + endPart;
// errString = mainStr;
// begPart =null;
// endPart =null;
// mainStr =null;
// //return errString;
// }
// if(errString.indexOf("rejected")>-1)
// {
// errString = itmDBAccessEJB.getErrorString("","PROCNTSUCC ","","",conn);
// }
// else if(errString.indexOf("Accepted")>-1)
// {
// conn.commit();
// errString = itmDBAccessEJB.getErrorString("","PROCSUCC ","","",conn);
// }
}
catch (Exception e)
{
errString = e.getMessage();
System.out.println("Exception..."+e);
throw new ITMException(e);
}
finally
{
try
{
//if(errString.indexOf("VTREJCHB")>-1 || errString.indexOf("PROCSUCC")>-1)
if(errString.indexOf("PROCSUCC")>-1)
{
conn.commit();
}
if( conn != null && ! conn.isClosed() )
{
conn.close();
conn = null;
}
if(pStmt != null)
{
pStmt.close();
pStmt = null;
}
if(pStmt1 != null)
{
pStmt1.close();
pStmt1 = null;
}
if(rs != null)
{
rs.close();
rs = null;
}
}
catch(Exception e)
{
errString = e.getMessage();
System.out.println("Exception : "+e);e.printStackTrace();
throw new ITMException(e);
}
}
return errString;
}
private String generateTranId( String windowName,String siteCode, Connection conn )throws ITMException
{
PreparedStatement pstmt = null;
ResultSet rs = null;
String selSql = "";
String tranId = "";
String tranSer = "";
String keyString = "";
String keyCol = "";
String xmlValues = "";
java.sql.Timestamp currDate = null;
GenericUtility genericUtility = GenericUtility.getInstance();
try
{
SimpleDateFormat sdfAppl = new SimpleDateFormat(genericUtility.getApplDateFormat());
currDate = new java.sql.Timestamp(System.currentTimeMillis());
String currDateStr = sdfAppl.format(currDate);
selSql = "SELECT KEY_STRING, TRAN_ID_COL, REF_SER FROM TRANSETUP WHERE TRAN_WINDOW = ? ";
pstmt = conn.prepareStatement(selSql);
pstmt.setString( 1, windowName );
rs = pstmt.executeQuery();
if (rs.next())
{
keyString = rs.getString("KEY_STRING");
keyCol = rs.getString("TRAN_ID_COL");
tranSer = rs.getString("REF_SER");
}
rs.close();rs = null;
pstmt.close();pstmt = null;
System.out.println("keyString :"+keyString);
System.out.println("keyCol :"+keyCol);
System.out.println("tranSer :"+tranSer);
xmlValues ="<?xml version=\"1.0\" encoding=\"utf-8\"?><Root>";
xmlValues = xmlValues + "<Header></Header>";
xmlValues = xmlValues + "<Detail1>";
xmlValues = xmlValues + "<tran_id></tran_id>";
xmlValues = xmlValues + "<site_code>" + siteCode + "</site_code>";
xmlValues = xmlValues + "<tran_date>" + currDateStr + "</tran_date>";
xmlValues = xmlValues + "</Detail1></Root>";
System.out.println("xmlValues :["+xmlValues+"]");
TransIDGenerator tg = new TransIDGenerator(xmlValues, "BASE", CommonConstants.DB_NAME);
tranId = tg.generateTranSeqID(tranSer, keyCol, keyString, conn);
System.out.println("tranId :"+tranId);
}
catch (SQLException ex)
{
System.out.println("Exception ::" +selSql+ ex.getMessage() + ":");
ex.printStackTrace();
throw new ITMException(ex);
}
catch (Exception e)
{
System.out.println("Exception ::" + e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
}
catch(Exception e){}
}
System.out.println("@@@@@@@@@@@@@@@@@@@@@@tranId[[[[[[[[[[["+tranId+"]]]]]]]]]]]]]]]");
return tranId;
}//end of generateTranTd()
}
webitm-dis/ibase/webitm/ejb/dis/adv/ChargeBackFormVerify.java 0 → 100755
View file @ dcc82084
package ibase.webitm.ejb.dis.adv;
import ibase.webitm.utility.*;
import ibase.webitm.ejb.*;
import ibase.system.config.*;
import java.sql.*;
import java.text.DecimalFormat;
import java.rmi.*;
import java.util.*;
import org.nfunk.jep.JEP; // for ejb3
import javax.ejb.*;
import javax.annotation.*;
import org.w3c.dom.*;
//import java
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class ChargeBackFormVerify extends ActionHandlerEJB implements ChargeBackFormVerifyLocal, ChargeBackFormVerifyRemote
{
static
{
System.out.println(" ChargeBackFormVerify getch()");
}
public String actionHandler(String tranId, String xtraParams, String forcedFlag) throws RemoteException, ITMException
{
String returnString=null;
System.out.println(" actionHandler() called :: ");
System.out.println(".......tranId......."+tranId);
System.out.println(".......xtraParams..."+xtraParams);
System.out.println(".......forcedFlag..."+forcedFlag);
try
{
if(tranId!=null && tranId.trim().length()>0)
{
returnString = verifyAll(tranId,xtraParams,forcedFlag);
}
}
catch (Exception e)
{
System.out.println("Exception ..."+e.getMessage());
e.printStackTrace();
throw new ITMException(e);
}
return returnString;
}
private String verifyAll(String tranId,String xtraParams,String forcedFlag) throws RemoteException,ITMException
{
System.out.println("verifyAll () called........["+tranId+"]");
double qty=0.0,netAmt=0.0,rateSell=0.0;
double saleqty=0.0,saleretqty=0.0,unconfclaimed=0.0,confclaimed=0.0,rateContr=0.0;
String itemCode="",lotNo="",porderNo="",porderDate= "",itemSer= "";
String errString = null,sql="";
String siteCode="",custCode="",tranDatestr="",tranType="",verifyFlag="";
String custCodeCredit = "",loginSite;
Connection conn = null;
ConnDriver connDriver = null;
PreparedStatement pStmt = null,pStmt1=null,pstmtMsg=null;
ResultSet rs = null,rs1=null,rsMsg=null;
ITMDBAccessEJB itmDBAccessEJB = null;
String childNodeName = "";
Node parentNode = null;
NodeList childNodeList = null;
NodeList parentNodeList = null;
int parentNodeListLength = 0;
int childNodeListLength = 0;
Node childNode = null;
StringBuffer errCode = new StringBuffer("");
StringBuffer errCodeDet = null;
StringBuffer errMsgHed = new StringBuffer("");
StringBuffer errMsgDet = new StringBuffer("");
String errCodeString = "";
ArrayList list = new ArrayList();
boolean rejectedFlag = false;
int elements = 0;
//DecimalFormat df = new DecimalFormat("0.000");
GenericUtility genericUtility = GenericUtility.getInstance();
int cnt=0,cnf=0;
java.sql.Timestamp tranDateTs = null;
String prdCode = "",statSal = "";
try
{
System.out.println(" INSIDE TRY { ");
connDriver = null;
genericUtility = new GenericUtility();
itmDBAccessEJB = new ITMDBAccessEJB();
connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
connDriver = null;
conn.setAutoCommit(false);
//parentNodeList = dom1.getElementsByTagName("Detail1");
//parentNodeListLength = parentNodeList.getLength();
loginSite = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode");
rejectedFlag = false;
// System.out.println("parentNodeListLength------------------->"+parentNodeListLength);
sql = " select count(*) from charge_back_form where tran_id = ? and confirmed = 'Y'";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, tranId.trim());
rs = pStmt.executeQuery();
if(rs.next())
{
cnf = rs.getInt(1);
}if(rs != null)
rs.close();
rs = null;
if(pStmt != null)
pStmt.close();
pStmt=null;
if(cnf > 0)
{
errString = itmDBAccessEJB.getErrorString("","VTVARALR ","","",conn);
return errString;
}
sql = " select site_code ,cust_code , cust_code__credit,verify_flag ,tran_date,tran_type from charge_back_form where tran_id = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, tranId);
rs = pStmt.executeQuery();
if(rs.next())
{
siteCode = rs.getString("site_code");
custCode = rs.getString("cust_code");
custCodeCredit = rs.getString("cust_code__credit");
verifyFlag = rs.getString("verify_flag");
tranDateTs = rs.getTimestamp("tran_date");
tranType = rs.getString("tran_type");
}
rs.close();
rs = null;
pStmt.close();
pStmt = null;
if(custCode == null || custCode.trim().length() == 0)
{
errCode.append("VMCUSTNUL,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VMCUSTNUL' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgHed.append(rsMsg.getString(1)+",");
}
else{
errMsgHed.append("VMCUSTNUL"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
else
{
sql = " SELECT COUNT(*) FROM customer WHERE cust_code = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, custCode.trim());
rs = pStmt.executeQuery();
if (rs.next()) {
cnt = rs.getInt(1);
}
if (cnt == 0) {
errCode.append("VMINVCUST,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VMINVCUST' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgHed.append(rsMsg.getString(1)+",");
}
else{
errMsgHed.append("VMINVCUST"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
rs.close();
rs = null;
pStmt.close();
pStmt = null;
}
// tranDateTs = Timestamp.valueOf(genericUtility
// .getValidDateString(tranDatestr,
// genericUtility.getApplDateFormat(),
// genericUtility.getDBDateFormat())
// + " 00:00:00.0");
sql = " Select code from period where ? between fr_date and to_date ";
pStmt = conn.prepareStatement(sql);
pStmt.setTimestamp(1, tranDateTs);
rs = pStmt.executeQuery();
if (rs.next()) {
prdCode = rs.getString(1);
}
rs.close();
rs = null;
pStmt.close();
pStmt = null;
if (prdCode != null && prdCode.trim().length() > 0)
{
sql = " Select count(1) from period_stat where prd_code = ? "
+ " AND site_code = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, prdCode.trim());
pStmt.setString(2, loginSite.trim());
rs = pStmt.executeQuery();
if (rs.next()) {
cnt = rs.getInt(1);
}
rs.close();
rs = null;
pStmt.close();
pStmt = null;
if (cnt > 0) {
sql = " Select stat_sal from period_stat where prd_code = ? and site_code = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, prdCode.trim());
pStmt.setString(2, loginSite.trim());
rs = pStmt.executeQuery();
if (rs.next()) {
statSal = rs.getString(1);
}
rs.close();
rs = null;
pStmt.close();
pStmt = null;
if (statSal != null
&& statSal.trim().equalsIgnoreCase("N")) {
errCode.append("VMSTATSNVL,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VMSTATSNVL' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgHed.append(rsMsg.getString(1)+",");
}
else{
errMsgHed.append("VMSTATSNVL"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
} else {
errCode.append("VMSTATSND,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VMSTATSND' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgHed.append(rsMsg.getString(1)+",");
}
else{
errMsgHed.append("VMSTATSND"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
} else {
errCode.append("VMPRDNTDF,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VMPRDNTDF' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgHed.append(rsMsg.getString(1)+",");
}
else{
errMsgHed.append("VMPRDNTDF"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
if(tranType == null || tranType.trim().length() == 0)
{
errCode.append("VMTRNTPNUL,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VMTRNTPNUL' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgHed.append(rsMsg.getString(1)+",");
}
else{
errMsgHed.append("VMTRNTPNUL"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
if(custCodeCredit == null || custCodeCredit.trim().length() == 0)
{
errCode.append("VMCUSTNUL,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VMCUSTNUL' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgHed.append(rsMsg.getString(1)+",");
}
else{
errMsgHed.append("VMCUSTNUL"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
else
{
sql = " SELECT COUNT(*) FROM customer WHERE cust_code = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, custCodeCredit.trim());
rs = pStmt.executeQuery();
if (rs.next()) {
cnt = rs.getInt(1);
}
if (cnt == 0) {
errCode.append("VMINVCUST,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VMINVCUST' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgHed.append(rsMsg.getString(1)+",");
}
else{
errMsgHed.append("VMINVCUST"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
rs.close();
rs = null;
pStmt.close();
pStmt = null;
}
if(siteCode == null || siteCode.trim().length() == 0)
{
errCode.append("VMSITENUL,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VMSITENUL' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgHed.append(rsMsg.getString(1)+",");
}
else{
errMsgHed.append("VMSITENUL"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
else
{
sql = " SELECT COUNT(*) FROM site WHERE site_code = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, siteCode.trim());
rs = pStmt.executeQuery();
if (rs.next()) {
cnt = rs.getInt(1);
}
if (cnt == 0) {
errCode.append("VMINVSITE,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VMINVSITE' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgHed.append(rsMsg.getString(1)+",");
}
else{
errMsgHed.append("VMINVSITE"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
rs.close();
rs = null;
pStmt.close();
pStmt = null;
}
sql = "select item_code,lot_no,porder_no,porder_date,item_ser,quantity,rate__contr, NET_AMT,RATE__SELL, " +
" sale_qty,sale_ret_qty,unconf_claimed,conf_claimed,line_no from charge_back_form_det where tran_id = ? ";
pStmt1 = conn.prepareStatement(sql);
pStmt1.setString(1, tranId.trim());
rs1 = pStmt1.executeQuery();
while(rs1.next())
{
errCodeDet = new StringBuffer("");
itemCode = rs1.getString("item_code");
lotNo = rs1.getString("lot_no");
porderNo = rs1.getString("porder_no");
porderDate = rs1.getString("porder_date");
itemSer = rs1.getString("item_ser");
qty = rs1.getDouble("quantity");
rateContr = rs1.getDouble("rate__contr");
saleqty = rs1.getDouble("sale_qty");
saleretqty = rs1.getDouble("sale_ret_qty");
unconfclaimed = rs1.getDouble("unconf_claimed");
confclaimed = rs1.getDouble("conf_claimed");
netAmt = rs1.getDouble("NET_AMT");
rateSell = rs1.getDouble("RATE__SELL");
if(netAmt == 0)
{
errCodeDet.append("VTNETAMT,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VTNETAMT' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgDet.append(rsMsg.getString(1)+",");
}
else{
errMsgDet.append("VTNETAMT"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
if(rateSell == 0)
{
errCodeDet.append("VTRATESL,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VTRATESL' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgDet.append(rsMsg.getString(1)+",");
}
else{
errMsgDet.append("VTRATESL"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
if(itemCode == null || itemCode.trim().length() == 0)
{
errCodeDet.append("VTITMNUL,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VTITMNUL' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgDet.append(rsMsg.getString(1)+",");
}
else{
errMsgDet.append("VTITMNUL"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
else
{
sql = "SELECT count(*) from item where item_code = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, itemCode.trim());
rs = pStmt.executeQuery();
if (rs.next()) {
cnt = rs.getInt(1);
}
System.out.println(" COUNT =====> [" + cnt + "]");
if (cnt == 0) {
errCodeDet.append("VTINVITM,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VTINVITM' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgDet.append(rsMsg.getString(1)+",");
}
else{
errMsgDet.append("VTINVITM"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
rs.close();
rs = null;
pStmt.close();
pStmt = null;
}
if(lotNo == null || lotNo.trim().length() == 0)
{
errCodeDet.append("VTLOTNUL,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VTLOTNUL' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgDet.append(rsMsg.getString(1)+",");
}
else{
errMsgDet.append("VTLOTNUL"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
if(porderNo == null || porderNo.trim().length() == 0)
{
errCodeDet.append("VTBILNONUL,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VTBILNONUL' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgDet.append(rsMsg.getString(1)+",");
}
else{
errMsgDet.append("VTBILNONUL"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
else
{
sql = "Select count(1) from charge_back_form A, charge_back_form_det B where"
+ " A.tran_id = B.tran_id "
+ " and A.cust_code = ? "
+ " and B.porder_no = ? "
+ " and A.tran_id <> '" + tranId + "' ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, custCode.trim());
pStmt.setString(2, porderNo.trim());
rs = pStmt.executeQuery();
if (rs.next()) {
cnt = rs.getInt(1);
}
rs.close();
rs = null;
pStmt.close();
pStmt = null;
if (cnt >= 1) {
errCodeDet.append("VTBILNOPST,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VTBILNOPST' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgDet.append(rsMsg.getString(1)+",");
}
else{
errMsgDet.append("VTBILNOPST"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
}
if(porderDate == null || porderDate.trim().length() == 0)
{
errCodeDet.append("VTBILDTNUL,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VTBILDTNUL' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgDet.append(rsMsg.getString(1)+",");
}
else{
errMsgDet.append("VTBILDTNUL"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
if(itemSer == null || itemSer.trim().length() == 0)
{
errCodeDet.append("VTITMSRNUL,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VTITMSRNUL' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgDet.append(rsMsg.getString(1)+",");
}
else{
errMsgDet.append("VTITMSRNUL"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
saleqty = rs1.getDouble("sale_qty");
saleretqty = rs1.getDouble("sale_ret_qty");
unconfclaimed = rs1.getDouble("unconf_claimed");
confclaimed = rs1.getDouble("conf_claimed");
if(qty > 0.0)
{
if (qty > (saleqty - saleretqty
- unconfclaimed - confclaimed))
{
errCodeDet.append("VTINVQUANT,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VTINVQUANT' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgDet.append(rsMsg.getString(1)+",");
}
else{
errMsgDet.append("VTINVQUANT"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
}
if(rateContr < 0)
{
errCodeDet.append("VTSTKBILRT,");
sql = " SELECT MSG_DESCR FROM MESSAGES WHERE MSG_NO = 'VTSTKBILRT' ";
pstmtMsg = conn.prepareStatement(sql);
rsMsg = pstmtMsg.executeQuery();
if (rsMsg.next()) {
errMsgDet.append(rsMsg.getString(1)+",");
}
else{
errMsgDet.append("VTSTKBILRT"+",");
}
rsMsg.close();
rsMsg = null;
pstmtMsg.close();
pstmtMsg = null;
}
errCodeString = errCodeDet.toString();
if(errCodeString != null && errCodeString.trim().length() > 0)
errCodeString = errCodeString.substring(0,errCodeString.length()-1);
String errMsgDetString = errMsgDet.toString();
if(errMsgDetString != null && errMsgDetString.trim().length() > 0)
errMsgDetString = errMsgDetString.substring(0,errMsgDetString.length()-1);
if(errMsgDetString.length() > 4000)
errMsgDetString = errMsgDetString.substring(0,4000);
System.out.println(" errCodeDet String ::"+errCodeString);
System.out.println(" errMsgDetString ::"+errMsgDetString);
// if(errCodeString.trim().length() > 0)
// {
sql= " update charge_back_form_det set error_code = ?,error_msg = ? where tran_id = ? and line_no = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, errCodeString.trim());
pStmt.setString(2, errMsgDetString.trim());
pStmt.setString(3, tranId.trim());
pStmt.setInt(4, Integer.parseInt(rs1.getString("line_no")));
int detupd = pStmt.executeUpdate();
pStmt.close();
pStmt = null;
System.out.println(" detail updated ::"+detupd);
//}
}
rs1.close();
rs1 = null;
pStmt1.close();
pStmt1 = null;
String errCodeHedString = errCode.toString();
String errMsgHedString = errMsgHed.toString();
if(errCodeHedString != null && errCodeHedString.trim().length() > 0)
errCodeHedString = errCodeHedString.substring(0,errCodeHedString.length()-1);
if(errMsgHedString != null && errMsgHedString.trim().length() > 0)
errMsgHedString = errMsgHedString.substring(0,errMsgHedString.length()-1);
// if(errCodeHedString.trim().length()>0 || errCodeString.trim().length() > 0)
if(errCodeHedString.trim().length()>0 )
{
if(errCodeHedString.length() > 4000)
errCodeHedString = errCodeHedString.substring(0,4000);
// rejectedFlag = true;
sql= " update charge_back_form set verify_flag = 'R', error_code = ? , error_msg = ? where tran_id = ? ";
//errString = "rejected";
// list.add(tranId);
// list.add(custCode);
// elements ++;
errString = itmDBAccessEJB.getErrorString("","VTREJCHB1 ","","",conn);
}
else
{
sql= " update charge_back_form set verify_flag = 'Y' , error_code = ?, error_msg = ? where tran_id = ? ";
// errString= "success";
errString = itmDBAccessEJB.getErrorString("","VTCHBSUC ","","",conn);
}
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, errCodeHedString.trim());
pStmt.setString(2, errMsgHedString.trim());
pStmt.setString(3, tranId.trim());
int hedupd = pStmt.executeUpdate();
pStmt.close();
pStmt = null;
System.out.println(" header updated ::"+hedupd);
// if(rejectedFlag)
// {
// errString = itmDBAccessEJB.getErrorString("","VTREJCHB","","",conn);
// String begPart = errString.substring( 0, errString.indexOf("<trace>") + 7 );
// String endPart = errString.substring( errString.indexOf("</trace>"));
// String mainStr = begPart + "Following error has occured\n" ;
// if(elements > 0 )
// {
// mainStr = mainStr + "Transaction not varified: \n";
// }
// for(int i = 0; i < elements * 2; i++ )
// {
// if( i > 0)
// {
// i -= 1;
// }
// mainStr = mainStr +
// "Tran Id :"+list.get(i++)+ ",cust code :"+ list.get(i++) + "\n" ;
// }
// mainStr = mainStr + endPart;
// errString = mainStr;
// begPart =null;
// endPart =null;
// mainStr =null;
// //return errString;
// }
// if(errString.indexOf("notvarified")>-1)
// {
// errString = itmDBAccessEJB.getErrorString("","VTREJCHB ","","",conn);
// }
// else if(errString.indexOf("success")>-1)
// {
// errString = itmDBAccessEJB.getErrorString("","VTCHBSUC ","","",conn);
// }
}
catch (Exception e)
{
errString = e.getMessage();
System.out.println("Exception..."+e);
throw new ITMException(e);
}
finally
{
try
{
if(errString.indexOf("VTCHBSUC")>-1 || errString.indexOf("VTREJCHB")>-1 )
{
conn.commit();
}
if( conn != null && ! conn.isClosed() )
{
conn.close();
conn = null;
}
if(pStmt != null)
{
pStmt.close();
pStmt = null;
}
if(pStmt1 != null)
{
pStmt1.close();
pStmt1 = null;
}
if(rs != null)
{
rs.close();
rs = null;
}
}
catch(Exception e)
{
System.out.println("Exception : "+e);e.printStackTrace();
throw new ITMException(e);
}
}
return errString;
}
}
webitm-dis/ibase/webitm/ejb/dis/adv/ChargeBackFormVerifyLocal.java 0 → 100755
View file @ dcc82084
package ibase.webitm.ejb.dis.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 // added for ejb3
public interface ChargeBackFormVerifyLocal extends ActionHandlerLocal//,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String actionType, String xmlString,String xmlString1, String objContext, String xtraParams) throws RemoteException,ITMException;
}
\ No newline at end of file
webitm-dis/ibase/webitm/ejb/dis/adv/ChargeBackFormVerifyRemote.java 0 → 100755
View file @ dcc82084
package ibase.webitm.ejb.dis.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerRemote;
import javax.ejb.Remote; // added for ejb3
@Remote // added for ejb3
public interface ChargeBackFormVerifyRemote extends ActionHandlerRemote//,EJBObject
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String actionType, String xmlString,String xmlString1, String objContext, String xtraParams) 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