Commit ecc50ea3 authored by dsawant's avatar dsawant

budget amount updation code


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@93181 ce508802-f39f-4f6c-b175-0d175dae99d5
parent b3ee5cd9
package ibase.webitm.ejb.fin; package ibase.webitm.ejb.fin;
import java.rmi.RemoteException; import java.rmi.RemoteException;
import java.sql.Connection; import java.sql.Connection;
import java.sql.PreparedStatement; import java.sql.PreparedStatement;
...@@ -18,13 +19,21 @@ import ibase.webitm.utility.ITMException; ...@@ -18,13 +19,21 @@ import ibase.webitm.utility.ITMException;
@Stateless @Stateless
public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements BudgetGroupAcctAmdConfirmLocal,BudgetGroupAcctAmdConfirmRemote public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements BudgetGroupAcctAmdConfirmLocal,BudgetGroupAcctAmdConfirmRemote
{ {
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
String chgUser =null, chgTerm = null, userId = null;
String errString="";
public String actionHandler(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException public String actionHandler(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{ {
String retString = ""; String retString = "";
try try
{ {
userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "logincode");
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "chg_term");
chgUser = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "chg_user");
retString = confirmAmmend(tranId,xtraParams,forcedFlag); retString = confirmAmmend(tranId,xtraParams,forcedFlag);
} }
...@@ -39,7 +48,7 @@ public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements Budge ...@@ -39,7 +48,7 @@ public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements Budge
} }
private String confirmAmmend(String tranId,String xtraParams,String forcedFlag) private String confirmAmmend(String tranIdAmd,String xtraParams,String forcedFlag)
{ {
System.out.println("--------------confirm method of BudgetGroupAcctAmdConfirm ------------- "); System.out.println("--------------confirm method of BudgetGroupAcctAmdConfirm ------------- ");
...@@ -48,7 +57,7 @@ public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements Budge ...@@ -48,7 +57,7 @@ public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements Budge
ITMDBAccessEJB itmdbAccess=new ITMDBAccessEJB(); ITMDBAccessEJB itmdbAccess=new ITMDBAccessEJB();
ResultSet rs = null; ResultSet rs = null;
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
String retString = "",errString="";
String sql = "",confirmed=""; String sql = "",confirmed="";
try try
...@@ -56,8 +65,9 @@ public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements Budge ...@@ -56,8 +65,9 @@ public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements Budge
conn = ConnDriver.getConnectDB("DriverITM"); conn = ConnDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false); conn.setAutoCommit(false);
sql = "select confirmed from budgrp_acct_amd where amd_no = ?"; sql = "select confirmed from budgrp_acct_amd where amd_no = ?";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId); pstmt.setString(1, tranIdAmd);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if( rs.next() ) if( rs.next() )
{ {
...@@ -75,15 +85,10 @@ public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements Budge ...@@ -75,15 +85,10 @@ public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements Budge
} }
else else
{ {
int updCnt =updateBudgetAmmend(conn,tranId,xtraParams); errString =updateBudgetAmmend(conn,tranIdAmd,xtraParams);
System.out.println("UPDATE COUNT --updCnt-->>"+updCnt);
if (updCnt > 0 ) return errString;
{
retString=new ITMDBAccessEJB().getErrorString("", "VTCONSUCC", "", "", conn);
conn.commit();
System.out.println("Confirm and conf date updated successfully.......");
}
} }
} }
...@@ -123,28 +128,30 @@ public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements Budge ...@@ -123,28 +128,30 @@ public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements Budge
} }
} }
System.out.println("Returning Result ::"+retString); System.out.println("Returning Result ::"+errString);
return retString; return errString;
} }
private int updateBudgetAmmend(Connection conn,String tranId,String xtraParams) private String updateBudgetAmmend(Connection conn,String tranIdAmd,String xtraParams)
{ {
System.out.println("---------in updateConfirm method------------"); System.out.println("---------in updateConfirm method------------");
String loginEmpCode ="",sql="",budGrpCode="",budgetId="",finEntity="",tran_id="",acctCode="",cctrCode="",analCode="",deptCode="";; String loginEmpCode ="",sql="",budGrpCode="",budgetId="",tran_id="";
double budAmount=0.0; double budAmount=0.0;
PreparedStatement pstmt1=null; PreparedStatement pstmt1=null;
ResultSet rs1=null; ResultSet rs1=null;
int count=0,countAcctdet=0; int count=0,countAcctdet=0;
/*
try try
{ {
sql="select budget_id from budgrp_acct_amd where amd_no = ? "; sql="select budget_id from budgrp_acct_amd where amd_no = ? ";
pstmt1 = conn.prepareStatement(sql); pstmt1 = conn.prepareStatement(sql);
pstmt1.setString(1, tranId); pstmt1.setString(1, tranIdAmd);
rs1 = pstmt1.executeQuery(); rs1 = pstmt1.executeQuery();
if( rs1.next() ) if( rs1.next() )
{ {
...@@ -170,13 +177,11 @@ public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements Budge ...@@ -170,13 +177,11 @@ public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements Budge
pstmt1.close(); pstmt1.close();
pstmt1=null; pstmt1=null;
//-------------------------------------------------------------------------------- //--------------------------------------------------------------------------------
sql="select bud_group_code,budget_amt from budgrp_actdet_amd where amd_no = ? "; sql="select bud_group_code,budget_amt from budgrp_actdet_amd where amd_no = ? ";
pstmt1 = conn.prepareStatement(sql); pstmt1 = conn.prepareStatement(sql);
pstmt1.setString(1, tranId); pstmt1.setString(1, tranIdAmd);
rs1 = pstmt1.executeQuery(); rs1 = pstmt1.executeQuery();
if( rs1.next() ) if( rs1.next() )
{ {
...@@ -191,69 +196,23 @@ public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements Budge ...@@ -191,69 +196,23 @@ public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements Budge
sql=null; sql=null;
sql="update bud_grp_acctdet set budget_amt = ? where tran_id = ? and bud_group_code = ?"; sql="update bud_grp_acctdet set budget_amt = ? where tran_id = ? and bud_group_code = ?";
pstmt1 = conn.prepareStatement( sql ); pstmt1 = conn.prepareStatement( sql );
pstmt1.setDouble(1, budAmount); pstmt1.setDouble(1, budAmount);
pstmt1.setString(2, tran_id); pstmt1.setString(2, tran_id);
pstmt1.setString(3, budGrpCode); pstmt1.setString(3, budGrpCode);
conn.setAutoCommit(false);
countAcctdet = pstmt1.executeUpdate(); countAcctdet = pstmt1.executeUpdate();
System.out.println("----countAcctdet : "+countAcctdet); System.out.println("----countAcctdet : "+countAcctdet);
//--------------------------------------------------------------------------------------------------------------------------
//updatation for budget_amt column for table acctbudget
sql = "select fin_entity,from_date from budgets where budget_id= ?";
pstmt1 = conn.prepareStatement(sql);
pstmt1.setString(1,budgetId);
rs1 = pstmt1.executeQuery();
Date fromDate = null;
if(rs1.next()){
finEntity = rs1.getString(1);
fromDate = rs1.getDate(5);
}
System.out.println("--------finEntity: "+finEntity+" fromDate: "+fromDate);
sql=null;
sql="select acct_code,cctr_code,anal_code,dept_code from bud_group_det where bud_group_code = ?";
pstmt1 = conn.prepareStatement(sql);
pstmt1.setString(1, budGrpCode);
rs1 = pstmt1.executeQuery();
if( rs1.next() )
{
acctCode=rs1.getString(1);
cctrCode=rs1.getString(1);
analCode=rs1.getString(1);
deptCode=rs1.getString(1);
}
sql=null;
sql="update acctbudget set budget_amt = ? where fin_entity = ?,acct_code = ?,cctr_code = ?,anal_code = ?,dept_code= ? ";
pstmt1 = conn.prepareStatement( sql );
pstmt1.setDouble(1, budAmount);
pstmt1.setString(2, finEntity);
//pstmt1.setDate(3, fromDate);
pstmt1.setString(3, loginEmpCode);
pstmt1.setString(4, tranId);
count = pstmt1.executeUpdate();
System.out.println("In updateBudgetAmmend : budGrpCode : "+budgetId+" budAmount : "+budAmount);
rs1.close();
rs1=null;
pstmt1.close();
pstmt1=null;
sql="update budgrp_acct_amd set confirmed = ?,conf_date = ?,emp_code__aprv = ? where amd_no = ?"; sql="update budgrp_acct_amd set confirmed = ?,conf_date = ?,emp_code__aprv = ? where amd_no = ?";
...@@ -262,12 +221,104 @@ public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements Budge ...@@ -262,12 +221,104 @@ public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements Budge
pstmt1.setString(1, "Y"); pstmt1.setString(1, "Y");
pstmt1.setTimestamp(2, this.getCurrdateAppFormat()); pstmt1.setTimestamp(2, this.getCurrdateAppFormat());
pstmt1.setString(3, loginEmpCode); pstmt1.setString(3, loginEmpCode);
pstmt1.setString(4, tranId); pstmt1.setString(4, tranIdAmd);
count = pstmt1.executeUpdate(); count = pstmt1.executeUpdate();
System.out.println("confirm updated -------->>>>>>>>>updCount :"+count); System.out.println("confirm updated -------->>>>>>>>>updCount :"+count);
// Added by deepak
String finEntity1 = null;
Double final_budget_amt = 0.00;
Float allocperc1 = 0.00f;
Date fromDate = null ;
sql = "select fin_entity,from_date from budgets where budget_id= ?";
PreparedStatement pstmt = conn.prepareStatement(sql);
pstmt.setString(1,budgetId);
ResultSet rs = pstmt.executeQuery();
finEntity1 = null;
fromDate = null;
if(rs.next()){
finEntity1 = rs.getString(1);
fromDate = rs.getDate(2);
}
if(finEntity1==null||fromDate==null){
//Error : Required data not found from budgets
errString = itmDBAccessEJB.getErrorString("","VTBUDINFNF",chgUser);
return errString;
}
String acctcode1="",cctrcode1="",analcode1="",deptcode1="";
String sqlQuery="select acct_code, cctr_code, anal_code, dept_code,alloc_perc from bud_group_det where bud_group_code = ?";
PreparedStatement Mysql1pstmt = conn.prepareStatement(sqlQuery);
Mysql1pstmt.setString(1, budGrpCode);
ResultSet Mysql1rs1 = Mysql1pstmt.executeQuery();
while( Mysql1rs1.next() )
{
acctcode1 =Mysql1rs1.getString(1)==null ? "":Mysql1rs1.getString(1);
cctrcode1 =Mysql1rs1.getString(2)==null ? "":Mysql1rs1.getString(2);
analcode1 =Mysql1rs1.getString(3)==null ? "":Mysql1rs1.getString(3);
deptcode1 =Mysql1rs1.getString(4)==null ? "":Mysql1rs1.getString(4);
allocperc1 = Mysql1rs1.getFloat(5);
if(deptcode1==null||analcode1==null||cctrcode1==null||acctcode1==null){
errString = itmDBAccessEJB.getErrorString("","VTBUDGRPNF",chgUser);
return errString;
}
final_budget_amt = (budAmount * allocperc1)/100;
PreparedStatement Mysqlpstmt;
String Mysql=null;
Mysql="update acctbudget set budget_amt = ? where fin_entity= ? and acct_code= ? and cctr_code = ? and anal_code = ? and dept_code = ? and from_date = ?";
Mysqlpstmt = conn.prepareStatement(Mysql);
Mysqlpstmt.setDouble(1, final_budget_amt);
Mysqlpstmt.setString(2, finEntity1);
Mysqlpstmt.setString(3, acctcode1);
Mysqlpstmt.setString(4, cctrcode1);
Mysqlpstmt.setString(5, analcode1);
Mysqlpstmt.setString(6, deptcode1);
Mysqlpstmt.setDate(7,(java.sql.Date)fromDate);
int MysqlcountAcctdet = Mysqlpstmt.executeUpdate();
Mysqlpstmt.close();
Mysqlpstmt = null;
System.out.println("----MysqlcountAcctdet : "+MysqlcountAcctdet);
}
conn.commit();
errString=new ITMDBAccessEJB().getErrorString("", "VTCONSUCC", "", "", conn);
System.out.println(acctcode1+""+cctrcode1+""+analcode1+""+deptcode1+""+allocperc1);
Mysql1rs1.close();
Mysql1rs1=null;
Mysql1pstmt.close();
Mysql1pstmt=null;
return errString;
} }
catch(SQLException se) catch(SQLException se)
...@@ -309,8 +360,8 @@ public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements Budge ...@@ -309,8 +360,8 @@ public class BudgetGroupAcctAmdConfirm extends ActionHandlerEJB implements Budge
e.printStackTrace(); e.printStackTrace();
} }
*/
return count; return errString;
} }
private java.sql.Timestamp getCurrdateAppFormat() private java.sql.Timestamp getCurrdateAppFormat()
......
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