Commit 4e07585d authored by vvengurlekar's avatar vvengurlekar

Dashboard filter ejb added and servlet and checknull utility added

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@177451 ce508802-f39f-4f6c-b175-0d175dae99d5
parent d95c5d7b
package ibase.dashboard.Report.Utility; package ibase.dashboard.Report.Utility;
import ibase.system.config.ConnDriver;
import ibase.utility.UserInfoBean;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
public class DashboardUtility { public class DashboardUtility {
@SuppressWarnings("unused") @SuppressWarnings("unused")
...@@ -41,56 +35,8 @@ public class DashboardUtility { ...@@ -41,56 +35,8 @@ public class DashboardUtility {
} }
return splitedArray; return splitedArray;
} }
/*public String getKeyString(String modName, String fieldName, UserInfoBean userInfo)
{
ConnDriver connDriver = new ConnDriver();
Statement statement = null;
ResultSet resultSet = null;
String keyString = "";
Connection connection = null;
String transDB = "";
try
{
//transDB = userInfo.getTransDB();
if (transDB != null && !"null".equalsIgnoreCase(transDB.trim()) && transDB.trim().length() > 0)
{
connection = connDriver.getConnectDB(transDB);
} else
{
connection = connDriver.getConnectDB("DriverITM");
}
statement = connection.createStatement();
String query = "SELECT SQL_INPUT FROM POPHELP WHERE MOD_NAME ='" + modName + "' AND FIELD_NAME = '" + fieldName.toUpperCase() + "'";
System.out.println("modName is ="+modName+ " fieldName is= "+fieldName + " and query " +query); public String checkNull(String str)
resultSet = statement.executeQuery(query);
if (resultSet.next())
{
keyString = checkNull(resultSet.getString("SQL_INPUT"));
}
} catch (Exception e)
{
e.printStackTrace();
} finally
{
try
{
resultSet.close();
resultSet = null;
statement.close();
statement = null;
connection.close();
connection = null;
} catch (Exception ex)
{
System.out.println("Finally Exception : DashboardUtility: getKeyString()" + ex.getMessage());
ex.printStackTrace();
}
}
return keyString;
}*/
private String checkNull(String str)
{ {
if(str == null) if(str == null)
{ {
...@@ -102,4 +48,17 @@ public class DashboardUtility { ...@@ -102,4 +48,17 @@ public class DashboardUtility {
} }
} }
public String checkDouble(String str)
{
if (str == null)
{
return "0.0";
} else
{
return str;
}
}
} }
package ibase.dashboard.metadata.servlet; package ibase.dashboard.metadata.servlet;
import ibase.dashboard.metadata.ejb.DashboardParentEJBRemote;
import ibase.system.config.AppConnectParm;
import ibase.utility.UserInfoBean;
import ibase.webitm.bean.PopUpBean; import ibase.webitm.bean.PopUpBean;
import ibase.webitm.utility.ITMException; import ibase.webitm.utility.ITMException;
import java.io.IOException; import java.io.IOException;
import java.io.OutputStream; import java.io.OutputStream;
import java.util.StringTokenizer; import java.util.StringTokenizer;
import javax.naming.InitialContext;
import javax.servlet.ServletException; import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession; import javax.servlet.http.HttpSession;
import ibase.utility.UserInfoBean;
import ibase.system.config.ConnDriver;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
public class DashboardFilterServlet extends HttpServlet public class DashboardFilterServlet extends HttpServlet
{ {
...@@ -35,17 +33,22 @@ public class DashboardFilterServlet extends HttpServlet ...@@ -35,17 +33,22 @@ public class DashboardFilterServlet extends HttpServlet
String objName = null; String objName = null;
StringTokenizer st = null; StringTokenizer st = null;
HttpSession session = request.getSession(true); HttpSession session = request.getSession(true);
String transDB ="";
DashboardParentEJBRemote dashboardParentEJBRemote = null;
try try
{ {
String fieldName = request.getParameter("FIELDNAME"); String fieldName = request.getParameter("FIELDNAME");
UserInfoBean userInfo = (UserInfoBean) session.getAttribute("USER_INFO"); UserInfoBean userInfo = (UserInfoBean) session.getAttribute("USER_INFO");
fieldName = fieldName.trim(); fieldName = fieldName.trim();
objName = request.getParameter("OBJ_NAME"); objName = request.getParameter("OBJ_NAME");
transDB = userInfo.getTransDB();
//keyString = request.getParameter("KEYSTRING"); //keyString = request.getParameter("KEYSTRING");
//Add new code By birendra on dated 23/6/2015 //Add new code By birendra on dated 23/6/2015
keyString = this.getKeyString("W_" + objName, fieldName, userInfo); InitialContext ctx = getInitialContext();
dashboardParentEJBRemote = (DashboardParentEJBRemote)ctx.lookup("ibase/DashboardParentEJB/remote");
keyString = dashboardParentEJBRemote.getKeyString("W_" + objName, fieldName, transDB);
//Add new code By Birendra on dated 23/6/2015 //Add new code By Birendra on dated 23/6/2015
int pos = fieldName.lastIndexOf("."); int pos = fieldName.lastIndexOf(".");
...@@ -130,7 +133,34 @@ public class DashboardFilterServlet extends HttpServlet ...@@ -130,7 +133,34 @@ public class DashboardFilterServlet extends HttpServlet
//Add new method for get sql input string from pophel table by Birendra Pandey on dated: //Add new method for get sql input string from pophel table by Birendra Pandey on dated:
public String getKeyString(String modName, String fieldName, UserInfoBean userInfo)
private InitialContext getInitialContext()throws ITMException
{
InitialContext ctx = null;
try
{
AppConnectParm appConnect = new AppConnectParm();
ctx = new InitialContext(appConnect.getProperty());
}
catch(ITMException itme)
{
System.out.println("ITMException :RequestHandlerServlet :getInitialContext :==>");
throw itme;
}
catch(Exception e)
{
System.out.println("Exception :RequestHandlerServlet :getInitialContext :==>");
throw new ITMException(e);
}
return ctx;
}
//
/*public String getKeyString(String modName, String fieldName, UserInfoBean userInfo)
{ {
ConnDriver connDriver = new ConnDriver(); ConnDriver connDriver = new ConnDriver();
Statement statement = null; Statement statement = null;
...@@ -141,6 +171,7 @@ public class DashboardFilterServlet extends HttpServlet ...@@ -141,6 +171,7 @@ public class DashboardFilterServlet extends HttpServlet
try try
{ {
transDB = userInfo.getTransDB(); transDB = userInfo.getTransDB();
dashboardUtility = new DashboardUtility();
if (transDB != null && !"null".equalsIgnoreCase(transDB.trim()) && transDB.trim().length() > 0) if (transDB != null && !"null".equalsIgnoreCase(transDB.trim()) && transDB.trim().length() > 0)
{ {
connection = connDriver.getConnectDB(transDB); connection = connDriver.getConnectDB(transDB);
...@@ -157,7 +188,7 @@ public class DashboardFilterServlet extends HttpServlet ...@@ -157,7 +188,7 @@ public class DashboardFilterServlet extends HttpServlet
resultSet = statement.executeQuery(query); resultSet = statement.executeQuery(query);
if (resultSet.next()) if (resultSet.next())
{ {
keyString = checkNull(resultSet.getString("SQL_INPUT")); keyString = dashboardUtility.checkNull(resultSet.getString("SQL_INPUT"));
} }
} catch (Exception e) } catch (Exception e)
{ {
...@@ -180,19 +211,10 @@ public class DashboardFilterServlet extends HttpServlet ...@@ -180,19 +211,10 @@ public class DashboardFilterServlet extends HttpServlet
} }
return keyString; return keyString;
} }
*/
private String checkNull(String str)
{
if(str == null)
{
return "";
}
else
{
return str ;
}
}
//end the getKeyString method //end the getKeyString method
......
package ibase.dashboard.metadata.servlet; package ibase.dashboard.metadata.servlet;
import ibase.dashboard.metadata.ejb.DashboardParentEJBRemote;
import ibase.system.config.AppConnectParm;
import ibase.system.config.ConnDriver;
import ibase.utility.CommonConstants; import ibase.utility.CommonConstants;
import ibase.utility.UserInfoBean; import ibase.utility.UserInfoBean;
import ibase.webitm.utility.ITMException; import ibase.webitm.utility.ITMException;
...@@ -9,12 +12,18 @@ import java.io.FileReader; ...@@ -9,12 +12,18 @@ import java.io.FileReader;
import java.io.IOException; import java.io.IOException;
import java.io.OutputStream; import java.io.OutputStream;
import java.rmi.RemoteException; import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Calendar;
import java.util.Date;
import javax.naming.InitialContext;
import javax.servlet.ServletException; import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession; import javax.servlet.http.HttpSession;
import org.json.simple.JSONObject; import org.json.simple.JSONObject;
public class ParentMetaDataServlet extends HttpServlet public class ParentMetaDataServlet extends HttpServlet
{ {
...@@ -24,33 +33,34 @@ public class ParentMetaDataServlet extends HttpServlet ...@@ -24,33 +33,34 @@ public class ParentMetaDataServlet extends HttpServlet
doPost(request, response); doPost(request, response);
} }
@SuppressWarnings("unused")
public void doPost(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException public void doPost(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException
{ {
String dataSourceName="";
try try
{ {
JSONObject jsonObjMetaData =null; JSONObject jsonObjMetaData =null;
String fileName= request.getParameter("fileName"); JSONObject jsonObjDefaultValue = null;
System.out.println(" get File Name for Each URL ===" + fileName); DashboardParentEJBRemote dashboardParentEJBRemote = null;
String dataSourceName ="";
String fileName = request.getParameter("fileName");
HttpSession session = request.getSession(true); HttpSession session = request.getSession(true);
ibase.utility.UserInfoBean userInfo = (ibase.utility.UserInfoBean) session.getAttribute("USER_INFO"); UserInfoBean userInfo = (ibase.utility.UserInfoBean) session.getAttribute("USER_INFO");
if (userInfo!=null) if (userInfo!=null)
{ {
dataSourceName = userInfo.getTransDB(); dataSourceName = userInfo.getTransDB();
} }
else else
{ {
userInfo = new UserInfoBean(); userInfo = new UserInfoBean();
dataSourceName = userInfo.getTransDB(); dataSourceName = userInfo.getTransDB();
} }
if(fileName!=null && fileName.trim().length()>0) if(fileName!=null && fileName.trim().length()>0)
{ {
//InitialContext ctx = this.getInitialContext();
jsonObjMetaData = (JSONObject) getMetaData(fileName,dataSourceName); //dashboardParentEJBRemote = (DashboardParentEJBRemote)ctx.lookup("ibase/DashboardParentEJB/remote");
// jsonObjDefaultValue = (JSONObject)dashboardParentEJBRemote.getDefaultFilterValue(dataSourceName);
jsonObjMetaData = (JSONObject) getMetaData(fileName,userInfo);
} }
System.out.println("getMetaData in ParentMetaDataServlet===" + jsonObjMetaData); System.out.println("getMetaData in ParentMetaDataServlet===" + jsonObjMetaData);
OutputStream outputStream = response.getOutputStream(); OutputStream outputStream = response.getOutputStream();
...@@ -71,8 +81,68 @@ public class ParentMetaDataServlet extends HttpServlet ...@@ -71,8 +81,68 @@ public class ParentMetaDataServlet extends HttpServlet
} }
} }
//add new code for get current financial year and period from database
/*@SuppressWarnings("unchecked")
public JSONObject getDefaultFilterValue(UserInfoBean userInfo)
{
ConnDriver connDriver = new ConnDriver();
Statement statement = null;
ResultSet rs = null;
JSONObject parentDataJson = new JSONObject();
Connection connection = null;
String transDB = "";
try
{
transDB = userInfo.getTransDB();
if (transDB != null && !"null".equalsIgnoreCase(transDB.trim()) && transDB.trim().length() > 0)
{
connection = connDriver.getConnectDB(transDB);
}
else
{
connection = connDriver.getConnectDB("DriverITM");
}
statement = connection.createStatement();
String query = " Select Acct_Prd,Code,Descr From Period Where To_Date(Sysdate) Between Fr_Date and To_Date ";
rs = statement.executeQuery(query);
if (rs.next())
{
parentDataJson.put("CURRENT_ACCTCODE",checkNull(rs.getString("Acct_Prd")));
parentDataJson.put("CURRENT_PRDCODE",checkNull(rs.getString("Code")));
parentDataJson.put("CURRENT_SITECODE",userInfo.getSiteCode());
parentDataJson.put("CURRENT_LOGINCODE",userInfo.getSiteCode());
parentDataJson.put("CURRENT_MONTH", "December");
parentDataJson.put("CURRENT_YEAR", "2017");
}
} catch (Exception e)
{
e.printStackTrace();
} finally
{
try
{
rs.close();
rs = null;
statement.close();
statement = null;
connection.close();
connection = null;
} catch (Exception ex)
{
System.out.println("Finally Exception : DashboardFilterServlet: getDefaultFilterValue()" + ex.getMessage());
ex.printStackTrace();
}
}
return parentDataJson;
}*/
//end the new code for get current financial year and period from database
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
private JSONObject getMetaData(String fileName,String dataSourceName) throws RemoteException, ITMException private JSONObject getMetaData(String fileName,UserInfoBean userInfo ) throws RemoteException, ITMException
{ {
String isCurrentLine = ""; String isCurrentLine = "";
JSONObject jsonMetaData = new JSONObject(); JSONObject jsonMetaData = new JSONObject();
...@@ -102,10 +172,68 @@ public class ParentMetaDataServlet extends HttpServlet ...@@ -102,10 +172,68 @@ public class ParentMetaDataServlet extends HttpServlet
System.out.println(" metaData.toString().replace :=" + metaData.toString().replace("//", "").trim()); System.out.println(" metaData.toString().replace :=" + metaData.toString().replace("//", "").trim());
jsonMetaData.put("metaData", metaData.toString().replace("//", "").trim()); jsonMetaData.put("metaData", metaData.toString().replace("//", "").trim());
jsonMetaData.put("tranDB", dataSourceName);
System.out.println("tranDB in ParentMetaDataServlet ********* :"+dataSourceName);
// add new logic for create sub title----------------
//jsonMetaData.put("CURRENT_ACCTCODE",jsonObjDefaultValue.get("CURRENT_ACCTCODE"));
//jsonMetaData.put("CURRENT_PRDCODE", jsonObjDefaultValue.get("CURRENT_PRDCODE"));
//End logic for sub title-----------
Calendar cal = Calendar.getInstance();
cal.setTime(new Date());
int year = cal.get(Calendar.YEAR);
int month = cal.get(Calendar.MONTH)+1;
String currentYear = year+"";
String nextYear = ((year+1)+"").substring(currentYear.length()-2, currentYear.length());
String finYear = currentYear + nextYear+"";
System.out.println("Financial Year : " + finYear);
System.out.println("Period Code : " + month+currentYear);
jsonMetaData.put("tranDB", userInfo.getTransDB());
jsonMetaData.put("SITE_CODE", userInfo.getSiteCode());
jsonMetaData.put("LOGIN_CODE", userInfo.getLoginCode());
jsonMetaData.put("ACCT_PRD", finYear);
jsonMetaData.put("PRDCODE", month+currentYear);
System.out.println("tranDB in ParentMetaDataServlet ********* :"+userInfo.getTransDB());
return jsonMetaData; return jsonMetaData;
} }
private InitialContext getInitialContext()throws ITMException
{
InitialContext ctx = null;
try
{
AppConnectParm appConnect = new AppConnectParm();
ctx = new InitialContext(appConnect.getProperty());
}
catch(ITMException itme)
{
System.out.println("ITMException :RequestHandlerServlet :getInitialContext :==>");
throw itme;
}
catch(Exception e)
{
System.out.println("Exception :RequestHandlerServlet :getInitialContext :==>");
throw new ITMException(e);
}
return ctx;
}
private String checkNull(String str)
{
if(str == null)
{
return "";
}
else
{
return str ;
}
}
} }
\ 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