Commit e6cc6360 authored by rzore's avatar rzore

changes made for getting connection through transDB

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@182675 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 3e0692fb
...@@ -3,6 +3,7 @@ package ibase.dashboard.calendar.ejb; ...@@ -3,6 +3,7 @@ package ibase.dashboard.calendar.ejb;
import ibase.system.config.ConnDriver; import ibase.system.config.ConnDriver;
import ibase.utility.CommonConstants; import ibase.utility.CommonConstants;
import ibase.utility.E12GenericUtility; import ibase.utility.E12GenericUtility;
import ibase.utility.UserInfoBean;
import ibase.webitm.ejb.ValidatorEJB; import ibase.webitm.ejb.ValidatorEJB;
import java.sql.Connection; import java.sql.Connection;
...@@ -633,4 +634,102 @@ public class CalendarDBR extends ValidatorEJB implements CalendarDBRLocal, Calen ...@@ -633,4 +634,102 @@ public class CalendarDBR extends ValidatorEJB implements CalendarDBRLocal, Calen
} }
return input.trim(); return input.trim();
} }
// commented and added by rupali on 27-03-18 for getting connection by using transDB [start]
public JSONObject getStationCountNew( String period, String loginCode, UserInfoBean userInfo )
{
JSONObject stationCountJson = null;
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
try
{
ConnDriver connDriver = new ConnDriver();
//conn = connDriver.getConnectDB("Driver");
if( userInfo != null && userInfo.getTransDB() != null )
{
String transDB = E12GenericUtility.checkNull( userInfo.getTransDB() );
conn = connDriver.getConnectDB( transDB );
}
stationCountJson = new JSONObject();
StringBuilder queryBuilder = new StringBuilder();
if("ORACLE".equalsIgnoreCase(CommonConstants.DB_NAME))
{
queryBuilder.append("SELECT stan_type, sum(planned_visit) as planned_visit, sum(actual_visit) as actual_visit ");
queryBuilder.append("from(select det.stan_type as stan_type , trunc(sysdate) as plan_date, det.work_days as planned_visit, 0 as actual_visit ");
queryBuilder.append("from SF_PLAN_PARAM hdr, SF_PLAN_PARAM_STAN det where det.param_table = hdr.param_table ");
queryBuilder.append("and det.prd_code = hdr.prd_code and hdr.prd_code = '"+period+"' union all ");
queryBuilder.append("select distinct sr.station_type as stan_type, trunc(sp.plan_date) as plan_date, 0 as planned_visit,1 as actual_visit from sprs_plan_place spp, sprs_plan_hdr sp, period prd, sprs_route sr ");
queryBuilder.append("where spp.plan_id = sp.plan_id and sr.sprs_code = sp.sprs_code__plan and spp.work_stan_code = sr.stan_code and prd.code = '"+period+"' ");
queryBuilder.append("and sp.plan_date >=prd.fr_date and sp.plan_date<=prd.to_date and sp.sprs_code__plan = '"+loginCode+"') group by stan_type");
}
else if("DB2".equalsIgnoreCase(CommonConstants.DB_NAME))
{
queryBuilder.append("SELECT stan_type, sum(planned_visit) as planned_visit, sum(actual_visit) as actual_visit ");
queryBuilder.append("from(select det.stan_type as stan_type , date(current date) as plan_date, det.work_days as planned_visit, 0 as actual_visit ");
queryBuilder.append("from SF_PLAN_PARAM hdr, SF_PLAN_PARAM_STAN det where det.param_table = hdr.param_table ");
queryBuilder.append("and det.prd_code = hdr.prd_code and hdr.prd_code = '"+period+"' union all ");
queryBuilder.append("select distinct sr.station_type as stan_type, date(sp.plan_date) as plan_date, 0 as planned_visit,1 as actual_visit from sprs_plan_place spp, sprs_plan_hdr sp, period prd, sprs_route sr ");
queryBuilder.append("where spp.plan_id = sp.plan_id and sr.sprs_code = sp.sprs_code__plan and spp.work_stan_code = sr.stan_code and prd.code = '"+period+"' ");
queryBuilder.append("and sp.plan_date >=prd.fr_date and sp.plan_date<=prd.to_date and sp.sprs_code__plan = '"+loginCode+"') as caldash group by stan_type");
}
String sqlQuery = queryBuilder.toString();
pstmt = conn.prepareStatement( sqlQuery );
rs = pstmt.executeQuery();
int count = 0;
while( rs.next() )
{
String stnType = checkNull(rs.getString(1)).trim();
String planedVisit = rs.getString(2).trim();
String actualVisit = rs.getString(3).trim();
JSONObject rowData = new JSONObject();
System.out.println("### getting percentage outside total ["+planedVisit+"] and Visited ["+actualVisit+"] stnType ["+stnType+"]");
String percent = ""+calculatePercentCount( planedVisit, actualVisit );
stnType = checkNull( stnType );
if( !"".equalsIgnoreCase( stnType ) )
{
rowData.put("Total", planedVisit );
rowData.put("Visited", actualVisit );
rowData.put("Title", stnType );
rowData.put("Visited/Total", actualVisit+"/"+planedVisit);
rowData.put("circledisplay", "c100");
rowData.put("percentage", percent);
stationCountJson.put( count, rowData );
count ++;
}
}
}
catch (Exception e)
{
System.out.println("Exception while getting places new data ["+e+"]");
e.printStackTrace();
}
finally
{
try
{
if (conn != null)
{
conn.close();
conn = null;
pstmt.close();
rs.close();
}
}
catch (Exception e)
{
}
}
System.out.println("### Final json String is ["+stationCountJson.toJSONString()+"]");
return stationCountJson;
}
// commented and added by rupali on 27-03-18 for getting connection by using transDB [end]
} }
package ibase.dashboard.calendar.ejb; package ibase.dashboard.calendar.ejb;
import ibase.utility.UserInfoBean;
import ibase.webitm.ejb.ValidatorLocal; import ibase.webitm.ejb.ValidatorLocal;
import javax.ejb.Local; import javax.ejb.Local;
...@@ -13,4 +14,5 @@ public interface CalendarDBRLocal extends ValidatorLocal ...@@ -13,4 +14,5 @@ public interface CalendarDBRLocal extends ValidatorLocal
// public JSONObject getPlacesDetails( String datasourcename, String period, String loginCode ); // public JSONObject getPlacesDetails( String datasourcename, String period, String loginCode );
// public JSONObject getStationCount( String period, String loginCode ); // public JSONObject getStationCount( String period, String loginCode );
public JSONObject getStationCountNew( String period, String loginCode ); public JSONObject getStationCountNew( String period, String loginCode );
public JSONObject getStationCountNew( String period, String loginCode, UserInfoBean userInfo ); // commented and added by rupali on 27-03-18 for getting connection by using transDB
} }
package ibase.dashboard.calendar.ejb; package ibase.dashboard.calendar.ejb;
import ibase.utility.UserInfoBean;
import ibase.webitm.ejb.ValidatorRemote; import ibase.webitm.ejb.ValidatorRemote;
import javax.ejb.Remote; import javax.ejb.Remote;
...@@ -13,4 +14,5 @@ public interface CalendarDBRRemote extends ValidatorRemote ...@@ -13,4 +14,5 @@ public interface CalendarDBRRemote extends ValidatorRemote
// public JSONObject getPlacesDetails( String datasourcename, String period, String loginCode ); // public JSONObject getPlacesDetails( String datasourcename, String period, String loginCode );
// public JSONObject getStationCount( String period, String loginCode ); // public JSONObject getStationCount( String period, String loginCode );
public JSONObject getStationCountNew( String period, String loginCode ); public JSONObject getStationCountNew( String period, String loginCode );
public JSONObject getStationCountNew( String period, String loginCode, UserInfoBean userInfo ); // commented and added by rupali on 27-03-18 for getting connection by using transDB
} }
...@@ -52,7 +52,10 @@ public class CalendarDBRServlet extends HttpServlet ...@@ -52,7 +52,10 @@ public class CalendarDBRServlet extends HttpServlet
calendarDBRRemote.setUserInfo(userInfo); calendarDBRRemote.setUserInfo(userInfo);
//JSONObject jsonObjData = (JSONObject) calendarDBRRemote.getPlacesVisitedCount( dataSourceName, period, loginCode ); //JSONObject jsonObjData = (JSONObject) calendarDBRRemote.getPlacesVisitedCount( dataSourceName, period, loginCode );
//JSONObject jsonObjData = (JSONObject) calendarDBRRemote.getStationCount( period, loginCode ); //JSONObject jsonObjData = (JSONObject) calendarDBRRemote.getStationCount( period, loginCode );
JSONObject jsonObjData = (JSONObject) calendarDBRRemote.getStationCountNew(period, loginCode); // commented and added by rupali on 27-03-18 for getting connection by using transDB [start]
//JSONObject jsonObjData = (JSONObject) calendarDBRRemote.getStationCountNew(period, loginCode);
JSONObject jsonObjData = (JSONObject) calendarDBRRemote.getStationCountNew(period, loginCode, userInfo);
// commented and added by rupali on 27-03-18 for getting connection by using transDB [end]
OutputStream outputStream = response.getOutputStream(); OutputStream outputStream = response.getOutputStream();
outputStream.write(jsonObjData.toString().getBytes()); outputStream.write(jsonObjData.toString().getBytes());
outputStream.flush(); outputStream.flush();
......
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