Skip to content

B
business-java
Commit e1b4c28a authored by dsawant's avatar dsawant
Browse files
Options

updated java file for masters sales pers bank and strg cust bank 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@93475 ce508802-f39f-4f6c-b175-0d175dae99d5
parent d31022cb
Show whitespace changes
Inline Side-by-side
Showing with 1101 additions and 0 deletions
webitm-fin/ibase/webitm/ejb/fin/SalesPersonBank.java
View file @ e1b4c28a
......@@ -597,6 +597,122 @@ public class SalesPersonBank extends ValidatorEJB implements SalesPersonBankLoca
}
}
//added on 06.08.2013
if((currentColumn.trim().equalsIgnoreCase("bank_code__ben")))
{
String bankcodeben = genericUtility.getColumnValue("bank_code__ben",dom);
System.out.println("bank_code__ben ----- :->> "+bankcodeben);
if(bankcodeben != null && bankcodeben.trim().length()>0 )
{
sql = "Select Bank_Name, Addr1, Addr2, Addr3, City,pin,State_Code, Count_Code From Bank Where Bank_Code = ?";
pstmt= conn.prepareStatement(sql);
pstmt.setString(1,bankcodeben);
rs = pstmt.executeQuery();
if(rs.next())
{
banknameben = rs.getString(1) == null ? "" : rs.getString(1);
add1 = rs.getString(2) == null ? "" : rs.getString(2);
add2 = rs.getString(3) == null ? "" : rs.getString(3);
add3 = rs.getString(4) == null ? "" : rs.getString(4);
city = rs.getString(5) == null ? "" : rs.getString(5);
pin = rs.getString(6) == null ? "" : rs.getString(6);
statecode = rs.getString(7) == null ? "" : rs.getString(7);
countcode = rs.getString(8) == null ? "" : rs.getString(8);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
valueXmlString.append("<bank_name__ben>").append("<![CDATA[" + banknameben + "]]>").append("</bank_name__ben>");
valueXmlString.append("<addr1__ben>").append("<![CDATA[" + add1 + "]]>").append("</addr1__ben>");
valueXmlString.append("<addr2__ben>").append("<![CDATA[" + add2 + "]]>").append("</addr2__ben>");
valueXmlString.append("<addr3__ben>").append("<![CDATA[" + add3 + "]]>").append("</addr3__ben>");
valueXmlString.append("<city__ben>").append("<![CDATA[" + city + "]]>").append("</city__ben>");
valueXmlString.append("<pin__ben>").append("<![CDATA[" + pin + "]]>").append("</pin__ben>");
valueXmlString.append("<state_code__ben>").append("<![CDATA[" + statecode + "]]>").append("</state_code__ben>");
valueXmlString.append("<count_code__ben>").append("<![CDATA[" + countcode + "]]>").append("</count_code__ben>");
}
else
{
valueXmlString.append("<bank_name__ben>").append("<![CDATA[]]>").append("</bank_name__ben>");
valueXmlString.append("<addr1__ben>").append("<![CDATA[]]>").append("</addr1__ben>");
valueXmlString.append("<addr2__ben>").append("<![CDATA[]]>").append("</addr2__ben>");
valueXmlString.append("<addr3__ben>").append("<![CDATA[]]>").append("</addr3__ben>");
valueXmlString.append("<city__ben>").append("<![CDATA[]]>").append("</city__ben>");
valueXmlString.append("<pin__ben>").append("<![CDATA[]]>").append("</pin__ben>");
valueXmlString.append("<state_code__ben>").append("<![CDATA[]]>").append("</state_code__ben>");
valueXmlString.append("<count_code__ben>").append("<![CDATA[]]>").append("</count_code__ben>");
}
}
if((currentColumn.trim().equalsIgnoreCase("bank_code__inter")))
{
String bankcodeint = genericUtility.getColumnValue("bank_code__inter",dom);
System.out.println("bank_code__inter ----- :->> "+bankcodeint);
if(bankcodeint != null && bankcodeint.trim().length()>0 )
{
sql = "Select Bank_Name, Addr1, Addr2, Addr3, City,pin,State_Code, Count_Code From Bank Where Bank_Code = ?";
pstmt= conn.prepareStatement(sql);
pstmt.setString(1,bankcodeint);
rs = pstmt.executeQuery();
while(rs.next())
{
banknameinter = rs.getString(1) == null ? "" : rs.getString(1);
add1int = rs.getString(2) == null ? "" : rs.getString(2);
add2int = rs.getString(3) == null ? "" : rs.getString(3);
add3int = rs.getString(4) == null ? "" : rs.getString(4);
cityint = rs.getString(5) == null ? "" : rs.getString(5);
pinint = rs.getString(6) == null ? "" : rs.getString(6);
statecodeint = rs.getString(7) == null ? "" : rs.getString(7);
countcodeint = rs.getString(8) == null ? "" : rs.getString(8);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
valueXmlString.append("<bank_name__inter>").append("<![CDATA[" + banknameinter + "]]>").append("</bank_name__inter>");
valueXmlString.append("<addr1__inter>").append("<![CDATA[" + add1int + "]]>").append("</addr1__inter>");
valueXmlString.append("<addr2__inter>").append("<![CDATA[" + add2int + "]]>").append("</addr2__inter>");
valueXmlString.append("<addr3__inter>").append("<![CDATA[" + add3int + "]]>").append("</addr3__inter>");
valueXmlString.append("<city__inter>").append("<![CDATA[" + cityint + "]]>").append("</city__inter>");
valueXmlString.append("<pin__inter>").append("<![CDATA[" + pinint + "]]>").append("</pin__inter>");
valueXmlString.append("<state_code__inter>").append("<![CDATA[" + statecodeint + "]]>").append("</state_code__inter>");
valueXmlString.append("<count_code__inter>").append("<![CDATA[" + countcodeint + "]]>").append("</count_code__inter>");
}
else
{
valueXmlString.append("<bank_name__inter>").append("<![CDATA[]]>").append("</bank_name__inter>");
valueXmlString.append("<addr1__inter>").append("<![CDATA[]]>").append("</addr1__inter>");
valueXmlString.append("<addr2__inter>").append("<![CDATA[]]>").append("</addr2__inter>");
valueXmlString.append("<addr3__inter>").append("<![CDATA[]]>").append("</addr3__inter>");
valueXmlString.append("<city__inter>").append("<![CDATA[]]>").append("</city__inter>");
valueXmlString.append("<pin__inter>").append("<![CDATA[]]>").append("</pin__inter>");
valueXmlString.append("<state_code__inter>").append("<![CDATA[]]>").append("</state_code__inter>");
valueXmlString.append("<count_code__inter>").append("<![CDATA[]]>").append("</count_code__inter>");
}
}
//added on 06.08.2013
valueXmlString.append("</Detail1>");
}// end switch
valueXmlString.append("</Root>");
......
webitm-fin/ibase/webitm/ejb/fin/SalesPersonBankConf.java 0 → 100755
View file @ e1b4c28a
package ibase.webitm.ejb.fin;
import ibase.system.config.ConnDriver;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ITMDBAccessLocal;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException;
import java.sql.*;
import java.util.StringTokenizer;
import java.rmi.RemoteException;
import javax.ejb.Stateless;
@Stateless
public class SalesPersonBankConf extends ActionHandlerEJB implements SalesPersonBankConfLocal,SalesPersonBankConfRemote
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
System.out.println("--------------confirm method of SalesPersonBankConf ------------- : ");
String retString = "";
try
{
retString = confirmSPBank(tranId,xtraParams,forcedFlag);
}
catch(Exception e)
{
System.out.println("Exception :SalesPersonBankConf :confirm():" + e.getMessage() + ":");
retString = GenericUtility.getInstance().createErrorString(e);
e.printStackTrace();
}
return retString;
}
private String confirmSPBank(String tranId,String xtraParams,String forcedFlag)
{
System.out.println("---------Class : SalesPersonBankConf-->> confirm method called-----------");
String salespers = null;
String bankcode = null;
ResultSet rs=null;
Connection conn=null;
ConnDriver ConnDriver = new ConnDriver();
PreparedStatement pstmt=null;
String errString="",sql="",loginSite="",ActiveYN="",itemCode="",regulatedPrice="";
String itmCodeDt2="",lotNo="",lotSl="", detail2xmlString="";
double invRate=0.0,invQty=0.0,PODrate=0.0,PODqty=0.0,allowedAmt=0.0,stockistAmt=0.0,debitNoteAmtAct=0.0;
int updCnt=0,lineNo=0;
ITMDBAccessLocal itmdbAccess=new ITMDBAccessEJB();
try
{
ConnDriver connDriver = null;
connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverValidator");
conn.setAutoCommit(false);
String confirmed="";
String[] pkValuesArr = string2StringArray(tranId, ":");
salespers = pkValuesArr[0].trim();
bankcode = pkValuesArr[1].trim();
sql = "select confirmed,active_yn from sales_pers_bank WHERE sales_pers = ? and bank_code__ben = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, salespers);
pstmt.setString(2, bankcode);
rs = pstmt.executeQuery();
if( rs.next() )
{
confirmed =rs.getString(1)==null ? "N":rs.getString(1);
ActiveYN=rs.getString(2)==null ? "Y" : rs.getString(2);
}
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
if ( rs != null )
{
rs.close();
rs = null;
}
if( confirmed != null && confirmed.equalsIgnoreCase("Y") )
{
System.out.println("transaction is already confirmmmm");
//if already confirm then show error
errString = itmdbAccess.getErrorString("", "VTALCONF", "", "", conn);
return errString;
}
if( ActiveYN != null && ActiveYN.equalsIgnoreCase("N") )
{
System.out.println("deactivated transaction can not be confirmmm");
//deactivate transaction can not confirm
errString = itmdbAccess.getErrorString("", "VMDECTRA", "", "", conn);
return errString;
}
GenericUtility genericUtility=new GenericUtility();
String loginCode=genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode");
System.out.println("Login Code ------->> "+loginCode);
sql="update sales_pers_bank set confirmed = ?,conf_date = ?, emp_code__aprv = ? where sales_pers = ? and bank_code__ben = ? ";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1, "Y");
pstmt.setDate(2, new java.sql.Date(System.currentTimeMillis()));
pstmt.setString(3,loginCode);
pstmt.setString(4, salespers);
pstmt.setString(5, bankcode);
updCnt=pstmt.executeUpdate();
if (updCnt > 0)
{
System.out.println("successfully confirmed");
conn.commit();
errString = itmdbAccess.getErrorString("", "VTCONSUCC", "", "", conn);
return errString;
}
}
catch(SQLException se)
{
System.out.println("SQLException : class SalesPersonBankConf : ");
se.printStackTrace();
try
{
conn.rollback();
}
catch(Exception e){
System.out.println("Exception : Occure during rollback........");e.printStackTrace();
}
}
catch(Exception e)
{
try
{
conn.rollback();
}
catch (Exception e1)
{
}
e.printStackTrace();
System.out.println("Exception Class [SalesPersonBankConf]::"+e.getMessage());
}
finally
{
try
{
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (conn!=null)
{
conn.close();
conn=null;
}
}
catch(Exception e)
{
System.out.println(e.getMessage());
e.printStackTrace();
}
}
System.out.println("[SalesPersonBankConf]errstring :"+errString);
return errString;
}
private String[] string2StringArray(String str1 , String delimeter)
{
StringTokenizer st = new StringTokenizer(str1,delimeter);
int count = st.countTokens() ;
String[] arry1 = new String[count];
int i = 0;
while(st.hasMoreTokens())
{
arry1[i] = st.nextToken();
System.out.println("Token "+i+" :["+arry1[i]+"]");
i++;
}
return arry1 ;
}
}
webitm-fin/ibase/webitm/ejb/fin/SalesPersonBankConfLocal.java 0 → 100755
View file @ e1b4c28a
package ibase.webitm.ejb.fin;
import ibase.webitm.ejb.ActionHandlerLocal;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import javax.ejb.Local;
@Local
public interface SalesPersonBankConfLocal extends ActionHandlerLocal
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
webitm-fin/ibase/webitm/ejb/fin/SalesPersonBankConfRemote.java 0 → 100755
View file @ e1b4c28a
package ibase.webitm.ejb.fin;
import ibase.webitm.ejb.ActionHandlerRemote;
import ibase.webitm.utility.ITMException;
import javax.ejb.Remote;
import java.rmi.RemoteException;
@Remote
public interface SalesPersonBankConfRemote extends ActionHandlerRemote
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
webitm-fin/ibase/webitm/ejb/fin/StrgCustBank.java
View file @ e1b4c28a
......@@ -614,6 +614,121 @@ public class StrgCustBank extends ValidatorEJB implements StrgCustBankLocal,
}
}
//added on 06.08.2013
if((currentColumn.trim().equalsIgnoreCase("bank_code__ben")))
{
String bankcodeben = genericUtility.getColumnValue("bank_code__ben",dom);
System.out.println("bank_code__ben ----- :->> "+bankcodeben);
if(bankcodeben != null && bankcodeben.trim().length()>0 )
{
sql = "Select Bank_Name, Addr1, Addr2, Addr3, City,pin,State_Code, Count_Code From Bank Where Bank_Code = ?";
pstmt= conn.prepareStatement(sql);
pstmt.setString(1,bankcodeben);
rs = pstmt.executeQuery();
if(rs.next())
{
banknameben = rs.getString(1) == null ? "" : rs.getString(1);
add1 = rs.getString(2) == null ? "" : rs.getString(2);
add2 = rs.getString(3) == null ? "" : rs.getString(3);
add3 = rs.getString(4) == null ? "" : rs.getString(4);
city = rs.getString(5) == null ? "" : rs.getString(5);
pin = rs.getString(6) == null ? "" : rs.getString(6);
statecode = rs.getString(7) == null ? "" : rs.getString(7);
countcode = rs.getString(8) == null ? "" : rs.getString(8);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
valueXmlString.append("<bank_name__ben>").append("<![CDATA[" + banknameben + "]]>").append("</bank_name__ben>");
valueXmlString.append("<addr1__ben>").append("<![CDATA[" + add1 + "]]>").append("</addr1__ben>");
valueXmlString.append("<addr2__ben>").append("<![CDATA[" + add2 + "]]>").append("</addr2__ben>");
valueXmlString.append("<addr3__ben>").append("<![CDATA[" + add3 + "]]>").append("</addr3__ben>");
valueXmlString.append("<city__ben>").append("<![CDATA[" + city + "]]>").append("</city__ben>");
valueXmlString.append("<pin__ben>").append("<![CDATA[" + pin + "]]>").append("</pin__ben>");
valueXmlString.append("<state_code__ben>").append("<![CDATA[" + statecode + "]]>").append("</state_code__ben>");
valueXmlString.append("<count_code__ben>").append("<![CDATA[" + countcode + "]]>").append("</count_code__ben>");
}
else
{
valueXmlString.append("<bank_name__ben>").append("<![CDATA[]]>").append("</bank_name__ben>");
valueXmlString.append("<addr1__ben>").append("<![CDATA[]]>").append("</addr1__ben>");
valueXmlString.append("<addr2__ben>").append("<![CDATA[]]>").append("</addr2__ben>");
valueXmlString.append("<addr3__ben>").append("<![CDATA[]]>").append("</addr3__ben>");
valueXmlString.append("<city__ben>").append("<![CDATA[]]>").append("</city__ben>");
valueXmlString.append("<pin__ben>").append("<![CDATA[]]>").append("</pin__ben>");
valueXmlString.append("<state_code__ben>").append("<![CDATA[]]>").append("</state_code__ben>");
valueXmlString.append("<count_code__ben>").append("<![CDATA[]]>").append("</count_code__ben>");
}
}
if((currentColumn.trim().equalsIgnoreCase("bank_code__inter")))
{
String bankcodeint = genericUtility.getColumnValue("bank_code__inter",dom);
System.out.println("bank_code__inter ----- :->> "+bankcodeint);
if(bankcodeint != null && bankcodeint.trim().length()>0 )
{
sql = "Select Bank_Name, Addr1, Addr2, Addr3, City,pin,State_Code, Count_Code From Bank Where Bank_Code = ?";
pstmt= conn.prepareStatement(sql);
pstmt.setString(1,bankcodeint);
rs = pstmt.executeQuery();
while(rs.next())
{
banknameinter = rs.getString(1) == null ? "" : rs.getString(1);
add1int = rs.getString(2) == null ? "" : rs.getString(2);
add2int = rs.getString(3) == null ? "" : rs.getString(3);
add3int = rs.getString(4) == null ? "" : rs.getString(4);
cityint = rs.getString(5) == null ? "" : rs.getString(5);
pinint = rs.getString(6) == null ? "" : rs.getString(6);
statecodeint = rs.getString(7) == null ? "" : rs.getString(7);
countcodeint = rs.getString(8) == null ? "" : rs.getString(8);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
valueXmlString.append("<bank_name__inter>").append("<![CDATA[" + banknameinter + "]]>").append("</bank_name__inter>");
valueXmlString.append("<addr1__inter>").append("<![CDATA[" + add1int + "]]>").append("</addr1__inter>");
valueXmlString.append("<addr2__inter>").append("<![CDATA[" + add2int + "]]>").append("</addr2__inter>");
valueXmlString.append("<addr3__inter>").append("<![CDATA[" + add3int + "]]>").append("</addr3__inter>");
valueXmlString.append("<city__inter>").append("<![CDATA[" + cityint + "]]>").append("</city__inter>");
valueXmlString.append("<pin__inter>").append("<![CDATA[" + pinint + "]]>").append("</pin__inter>");
valueXmlString.append("<state_code__inter>").append("<![CDATA[" + statecodeint + "]]>").append("</state_code__inter>");
valueXmlString.append("<count_code__inter>").append("<![CDATA[" + countcodeint + "]]>").append("</count_code__inter>");
}
else
{
valueXmlString.append("<bank_name__inter>").append("<![CDATA[]]>").append("</bank_name__inter>");
valueXmlString.append("<addr1__inter>").append("<![CDATA[]]>").append("</addr1__inter>");
valueXmlString.append("<addr2__inter>").append("<![CDATA[]]>").append("</addr2__inter>");
valueXmlString.append("<addr3__inter>").append("<![CDATA[]]>").append("</addr3__inter>");
valueXmlString.append("<city__inter>").append("<![CDATA[]]>").append("</city__inter>");
valueXmlString.append("<pin__inter>").append("<![CDATA[]]>").append("</pin__inter>");
valueXmlString.append("<state_code__inter>").append("<![CDATA[]]>").append("</state_code__inter>");
valueXmlString.append("<count_code__inter>").append("<![CDATA[]]>").append("</count_code__inter>");
}
}
//added on 06.08.2013
valueXmlString.append("</Detail1>");
}// end switch
valueXmlString.append("</Root>");
......
webitm-fin/ibase/webitm/ejb/fin/StrgCustBankConf.java 0 → 100755
View file @ e1b4c28a
package ibase.webitm.ejb.fin;
import ibase.system.config.ConnDriver;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ITMDBAccessLocal;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException;
import java.sql.*;
import java.util.StringTokenizer;
import javax.ejb.Stateless;
import java.rmi.RemoteException;
@Stateless
public class StrgCustBankConf extends ActionHandlerEJB implements StrgCustBankConfLocal,StrgCustBankConfRemote
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
System.out.println("--------------confirm method of StrgCustBankConf ------------- : "+tranId);
String retString = "";
try
{
retString = confirmSCBank(tranId,xtraParams,forcedFlag);
}
catch(Exception e)
{
System.out.println("Exception :StrgCustBankConf :confirm():" + e.getMessage() + ":");
retString = GenericUtility.getInstance().createErrorString(e);
e.printStackTrace();
}
return retString;
}
private String confirmSCBank(String tranId,String xtraParams,String forcedFlag)
{
System.out.println("---------Class : StrgCustBankConf-->> confirm method called-----------");
String scCode = null;
String bankcode = null;
ResultSet rs=null;
Connection conn=null;
ConnDriver ConnDriver = new ConnDriver();
PreparedStatement pstmt=null;
String errString="",sql="",loginSite="",ActiveYN="",itemCode="",regulatedPrice="";
String itmCodeDt2="",lotNo="",lotSl="", detail2xmlString="";
double invRate=0.0,invQty=0.0,PODrate=0.0,PODqty=0.0,allowedAmt=0.0,stockistAmt=0.0,debitNoteAmtAct=0.0;
int updCnt=0,lineNo=0;
ITMDBAccessLocal itmdbAccess=new ITMDBAccessEJB();
try
{
ConnDriver connDriver = null;
connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverValidator");
conn.setAutoCommit(false);
String confirmed="";
String[] pkValuesArr = string2StringArray(tranId, ":");
scCode = pkValuesArr[0].trim();
bankcode = pkValuesArr[1].trim();
sql = "select confirmed,active_yn from strg_cust_bank WHERE sc_code = ? and bank_code__ben = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, scCode);
pstmt.setString(2, bankcode);
rs = pstmt.executeQuery();
if( rs.next() )
{
confirmed =rs.getString(1)==null ? "N":rs.getString(1);
ActiveYN=rs.getString(2)==null ? "Y" : rs.getString(2);
}
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
if ( rs != null )
{
rs.close();
rs = null;
}
if( confirmed != null && confirmed.equalsIgnoreCase("Y") )
{
System.out.println("transaction is already confirmmmm");
//if already confirm then show error
errString = itmdbAccess.getErrorString("", "VTALCONF", "", "", conn);
return errString;
}
if( ActiveYN != null && ActiveYN.equalsIgnoreCase("N") )
{
//right
System.out.println("deactivated transaction can not be confirmmm");
//Deactivated transaction can not confirm
errString = itmdbAccess.getErrorString("", "VMDECTRA", "", "", conn);
return errString;
}
GenericUtility genericUtility=new GenericUtility();
String loginCode=genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode");
System.out.println("Login Code ------->> "+loginCode);
sql="update strg_cust_bank set confirmed = ?,conf_date = ?, emp_code__aprv = ? where sc_code = ? and bank_code__ben = ? ";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1, "Y");
pstmt.setDate(2, new java.sql.Date(System.currentTimeMillis()));
pstmt.setString(3,loginCode);
pstmt.setString(4, scCode);
pstmt.setString(5, bankcode);
updCnt=pstmt.executeUpdate();
if (updCnt > 0)
{
System.out.println("successfully confirmed");
conn.commit();
errString = itmdbAccess.getErrorString("", "VTCONSUCC", "", "", conn);
return errString;
}
}
catch(SQLException se)
{
System.out.println("SQLException : class StrgCustBankConf : ");
se.printStackTrace();
try
{
conn.rollback();
}
catch(Exception e){
System.out.println("Exception : Occure during rollback........");e.printStackTrace();
}
}
catch(Exception e)
{
try
{
conn.rollback();
}
catch (Exception e1)
{
}
e.printStackTrace();
System.out.println("Exception Class [StrgCustBankConf]::"+e.getMessage());
}
finally
{
try
{
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (conn!=null)
{
conn.close();
conn=null;
}
}
catch(Exception e)
{
System.out.println(e.getMessage());
e.printStackTrace();
}
}
System.out.println("[StrgCustBankConf]errstring :"+errString);
return errString;
}
private String[] string2StringArray(String str1 , String delimeter)
{
StringTokenizer st = new StringTokenizer(str1,delimeter);
int count = st.countTokens() ;
System.out.println("TOKEN COUNT"+count);
String[] arry1 = new String[count];
int i = 0;
while(st.hasMoreTokens())
{
arry1[i] = st.nextToken();
System.out.println("Token "+i+" :["+arry1[i]+"]");
i++;
}
return arry1 ;
}
}
webitm-fin/ibase/webitm/ejb/fin/StrgCustBankConfLocal.java 0 → 100755
View file @ e1b4c28a
package ibase.webitm.ejb.fin;
import ibase.webitm.ejb.ActionHandlerLocal;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import javax.ejb.Local;
@Local
public interface StrgCustBankConfLocal extends ActionHandlerLocal
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
webitm-fin/ibase/webitm/ejb/fin/StrgCustBankConfRemote.java 0 → 100755
View file @ e1b4c28a
package ibase.webitm.ejb.fin;
import ibase.webitm.ejb.ActionHandlerRemote;
import ibase.webitm.utility.ITMException;
import javax.ejb.Remote;
import java.rmi.RemoteException;
@Remote
public interface StrgCustBankConfRemote extends ActionHandlerRemote
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
webitm-fin/ibase/webitm/ejb/fin/adv/SalesPersonBankDeactivate.java 0 → 100755
View file @ e1b4c28a
package ibase.webitm.ejb.fin.adv;
import ibase.system.config.ConnDriver;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ITMDBAccessLocal;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException;
import java.sql.*;
import java.util.StringTokenizer;
import java.rmi.RemoteException;
import javax.ejb.Stateless;
@Stateless
public class SalesPersonBankDeactivate extends ActionHandlerEJB implements SalesPersonBankDeactivateLocal,SalesPersonBankDeactivateRemote
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
System.out.println("--------------confirm method of SalesPersonBankDeactivate ------------- : ");
String retString = "";
try
{
retString = deactive(tranId,xtraParams,forcedFlag);
}
catch(Exception e)
{
System.out.println("Exception :SalesPersonBankDeactivate :confirm():" + e.getMessage() + ":");
retString = GenericUtility.getInstance().createErrorString(e);
e.printStackTrace();
}
return retString;
}
private String deactive(String tranId,String xtraParams,String forcedFlag)
{
System.out.println("---------Class : SalesPersonBankDeactivate-->> deactive method called-----------");
String salespers = null;
String bankcode = null;
ResultSet rs=null;
Connection conn=null;
ConnDriver ConnDriver = new ConnDriver();
PreparedStatement pstmt=null;
String errString="",sql="",loginSite="",ActiveYN="",itemCode="",regulatedPrice="";
String itmCodeDt2="",lotNo="",lotSl="", detail2xmlString="";
double invRate=0.0,invQty=0.0,PODrate=0.0,PODqty=0.0,allowedAmt=0.0,stockistAmt=0.0,debitNoteAmtAct=0.0;
int updCnt=0,lineNo=0;
ITMDBAccessLocal itmdbAccess=new ITMDBAccessEJB();
try
{
ConnDriver connDriver = null;
connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverValidator");
conn.setAutoCommit(false);
String confirmed="";
String[] pkValuesArr = string2StringArray(tranId, ":");
salespers = pkValuesArr[0].trim();
bankcode = pkValuesArr[1].trim();
sql = "select confirmed,active_yn from sales_pers_bank WHERE sales_pers = ? and bank_code__ben = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, salespers);
pstmt.setString(2, bankcode);
rs = pstmt.executeQuery();
if( rs.next() )
{
confirmed =rs.getString(1)==null ? "N":rs.getString(1);
ActiveYN=rs.getString(2)==null ? "Y" : rs.getString(2);
}
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
if ( rs != null )
{
rs.close();
rs = null;
}
if( ActiveYN != null && ActiveYN.equalsIgnoreCase("N") )
{
//deactivate transaction can not confirm
System.out.println("transaction is already deactivated");
errString = itmdbAccess.getErrorString("", "VMDETPTALS", "", "", conn);
return errString;
}
if( confirmed != null && confirmed.equalsIgnoreCase("Y") )
{
System.out.println("confirm transaction can not be deactivated");
//if already confirm then show error
errString = itmdbAccess.getErrorString("", "VMDECTRACF", "", "", conn);
return errString;
}
GenericUtility genericUtility=new GenericUtility();
String loginCode=genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode");
System.out.println("Login Code ------->> "+loginCode);
sql="update sales_pers_bank set active_yn = ? where sales_pers = ? and bank_code__ben = ? ";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1, "N");
pstmt.setString(2, salespers);
pstmt.setString(3, bankcode);
updCnt=pstmt.executeUpdate();
if (updCnt > 0)
{
System.out.println("successfully deactivated");
conn.commit();
errString = itmdbAccess.getErrorString("", "VMDETRASUC", "", "", conn);
return errString;
}
}
catch(SQLException se)
{
System.out.println("SQLException : class SalesPersonBankDeactivate : ");
se.printStackTrace();
try
{
conn.rollback();
}
catch(Exception e){
System.out.println("Exception : Occure during rollback........");e.printStackTrace();
}
}
catch(Exception e)
{
try
{
conn.rollback();
}
catch (Exception e1)
{
}
e.printStackTrace();
System.out.println("Exception Class [SalesPersonBankDeactivate]::"+e.getMessage());
}
finally
{
try
{
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (conn!=null)
{
conn.close();
conn=null;
}
}
catch(Exception e)
{
System.out.println(e.getMessage());
e.printStackTrace();
}
}
System.out.println("[SalesPersonBankDeactivate]errstring :"+errString);
return errString;
}
private String[] string2StringArray(String str1 , String delimeter)
{
StringTokenizer st = new StringTokenizer(str1,delimeter);
int count = st.countTokens() ;
String[] arry1 = new String[count];
int i = 0;
while(st.hasMoreTokens())
{
arry1[i] = st.nextToken();
System.out.println("Token "+i+" :["+arry1[i]+"]");
i++;
}
return arry1 ;
}
}
webitm-fin/ibase/webitm/ejb/fin/adv/SalesPersonBankDeactivateLocal.java 0 → 100755
View file @ e1b4c28a
package ibase.webitm.ejb.fin.adv;
import ibase.webitm.ejb.ActionHandlerLocal;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import javax.ejb.Local;
@Local
public interface SalesPersonBankDeactivateLocal extends ActionHandlerLocal
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
webitm-fin/ibase/webitm/ejb/fin/adv/SalesPersonBankDeactivateRemote.java 0 → 100755
View file @ e1b4c28a
package ibase.webitm.ejb.fin.adv;
import ibase.webitm.ejb.ActionHandlerRemote;
import ibase.webitm.utility.ITMException;
import javax.ejb.Remote;
import java.rmi.RemoteException;
@Remote
public interface SalesPersonBankDeactivateRemote extends ActionHandlerRemote
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
webitm-fin/ibase/webitm/ejb/fin/adv/StrgCustBankDeactivate.java 0 → 100755
View file @ e1b4c28a
package ibase.webitm.ejb.fin.adv;
import ibase.system.config.ConnDriver;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ITMDBAccessLocal;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.StringTokenizer;
import javax.ejb.Stateless;
@Stateless
public class StrgCustBankDeactivate extends ActionHandlerEJB implements StrgCustBankDeactivateLocal,StrgCustBankDeactivateRemote
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
System.out.println("--------------confirm method of StrgCustBankDeactivate ------------- : ");
String retString = "";
try
{
retString = deactive(tranId,xtraParams,forcedFlag);
}
catch(Exception e)
{
System.out.println("Exception :StrgCustBankDeactivate :confirm():" + e.getMessage() + ":");
retString = GenericUtility.getInstance().createErrorString(e);
e.printStackTrace();
}
return retString;
}
private String deactive(String tranId,String xtraParams,String forcedFlag)
{
System.out.println("---------Class : StrgCustBankDeactivate-->> deactive method called-----------");
String scCode = null;
String bankcode = null;
ResultSet rs=null;
Connection conn=null;
ConnDriver ConnDriver = new ConnDriver();
PreparedStatement pstmt=null;
String errString="",sql="",loginSite="",ActiveYN="",itemCode="",regulatedPrice="";
String itmCodeDt2="",lotNo="",lotSl="", detail2xmlString="";
double invRate=0.0,invQty=0.0,PODrate=0.0,PODqty=0.0,allowedAmt=0.0,stockistAmt=0.0,debitNoteAmtAct=0.0;
int updCnt=0,lineNo=0;
ITMDBAccessLocal itmdbAccess=new ITMDBAccessEJB();
try
{
ConnDriver connDriver = null;
connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverValidator");
conn.setAutoCommit(false);
String confirmed="";
String[] pkValuesArr = string2StringArray(tranId, ":");
scCode = pkValuesArr[0].trim();
bankcode = pkValuesArr[1].trim();
sql = "select confirmed,active_yn from strg_cust_bank WHERE sc_code = ? and bank_code__ben = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, scCode);
pstmt.setString(2, bankcode);
rs = pstmt.executeQuery();
if( rs.next() )
{
confirmed =rs.getString(1)==null ? "N":rs.getString(1);
ActiveYN=rs.getString(2)==null ? "Y" : rs.getString(2);
}
if( pstmt != null )
{
pstmt.close();
pstmt = null;
}
if ( rs != null )
{
rs.close();
rs = null;
}
if( ActiveYN != null && ActiveYN.equalsIgnoreCase("N") )
{
//deactivate transaction can not confirm
System.out.println("transaction is already deactivated");
errString = itmdbAccess.getErrorString("", "VMDETPTALS", "", "", conn);
return errString;
}
if( confirmed != null && confirmed.equalsIgnoreCase("Y") )
{
System.out.println("confirm transaction can not be deactivated");
//if already confirm then show error
errString = itmdbAccess.getErrorString("", "VMDECTRACF", "", "", conn);
return errString;
}
GenericUtility genericUtility=new GenericUtility();
String loginCode=genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode");
System.out.println("Login Code ------->> "+loginCode);
sql="update strg_cust_bank set active_yn = ? where sc_code = ? and bank_code__ben = ? ";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1, "N");
pstmt.setString(2, scCode);
pstmt.setString(3, bankcode);
updCnt=pstmt.executeUpdate();
if (updCnt > 0)
{
System.out.println("successfully deactivated");
conn.commit();
errString = itmdbAccess.getErrorString("", "VMDETRASUC", "", "", conn);
return errString;
}
}
catch(SQLException se)
{
System.out.println("SQLException : class StrgCustBankDeactivate : ");
se.printStackTrace();
try
{
conn.rollback();
}
catch(Exception e){
System.out.println("Exception : Occure during rollback........");e.printStackTrace();
}
}
catch(Exception e)
{
try
{
conn.rollback();
}
catch (Exception e1)
{
}
e.printStackTrace();
System.out.println("Exception Class [StrgCustBankDeactivate]::"+e.getMessage());
}
finally
{
try
{
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (conn!=null)
{
conn.close();
conn=null;
}
}
catch(Exception e)
{
System.out.println(e.getMessage());
e.printStackTrace();
}
}
System.out.println("[StrgCustBankDeactivate]errstring :"+errString);
return errString;
}
private String[] string2StringArray(String str1 , String delimeter)
{
StringTokenizer st = new StringTokenizer(str1,delimeter);
int count = st.countTokens() ;
String[] arry1 = new String[count];
int i = 0;
while(st.hasMoreTokens())
{
arry1[i] = st.nextToken();
System.out.println("Token "+i+" :["+arry1[i]+"]");
i++;
}
return arry1 ;
}
}
webitm-fin/ibase/webitm/ejb/fin/adv/StrgCustBankDeactivateLocal.java 0 → 100755
View file @ e1b4c28a
package ibase.webitm.ejb.fin.adv;
import ibase.webitm.ejb.ActionHandlerLocal;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import javax.ejb.Local;
@Local
public interface StrgCustBankDeactivateLocal extends ActionHandlerLocal
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
webitm-fin/ibase/webitm/ejb/fin/adv/StrgCustBankDeactivateRemote.java 0 → 100755
View file @ e1b4c28a
package ibase.webitm.ejb.fin.adv;
import ibase.webitm.ejb.ActionHandlerRemote;
import ibase.webitm.utility.ITMException;
import javax.ejb.Remote;
import java.rmi.RemoteException;
@Remote
public interface StrgCustBankDeactivateRemote extends ActionHandlerRemote
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
}
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