Skip to content

B
business-java
Commit c4ef0190 authored by nsawalakhe's avatar nsawalakhe
Browse files
Options

Added ejb,local,remote and servlet of ProductAssessment 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@101204 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 6bc93130
Hide whitespace changes
Inline Side-by-side
Showing with 710 additions and 0 deletions
webitm-dashboard/ibase/dashboard/sfa/ejb/ProductAssessment.java 0 → 100755
View file @ c4ef0190
package ibase.dashboard.sfa.ejb;
import ibase.dashboard.Report.Utility.DashboardUtility;
import ibase.system.config.ConnDriver;
import ibase.webitm.ejb.ValidatorEJB;
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 javax.ejb.Stateless;
import org.json.simple.JSONObject;
/**
* Session Bean implementation class SalesPersonSales
*/
@Stateless
public class ProductAssessment extends ValidatorEJB implements ProductAssessmentLocal, ProductAssessmentRemote
{
public ProductAssessment() {
// TODO Auto-generated constructor stub
}
GenericUtility genericUtility = GenericUtility.getInstance();
@SuppressWarnings("unchecked")
@Override
public JSONObject getProductAssessmentEventServlet(String loginId, String dataSourceName,String zone,String region,String product,String team,String event) throws RemoteException, ITMException
{
JSONObject rawDataEmployeeProdSurveylJson = new JSONObject();
JSONObject rowData = null;
String sql = "";
String zoneCodeFilter="";
String regionCodeFilter="";
String teamCodeFilter="";
String productFilter="";
String whereClause = "";
ResultSet rs = null;
PreparedStatement pstmt = null;
Connection conn = null;
ConnDriver connDriver = new ConnDriver();
DashboardUtility dashbordUtil = new DashboardUtility();
try
{
//System.out.println(" Inside ProductAssessment for getProductAssessmentEventServlet Data Soruc Name ="+dataSourceName+" loginId=:"+ loginId);
//System.out.println("zone :"+zone+"==== region :"+region+ "===== product :"+product+"=== team :"+team);
conn = connDriver.getConnectDB(dataSourceName);
connDriver = null;
if ((product != null) && (product.trim().length() > 0))
{
product = dashbordUtil.getCommaSeparated(product);
productFilter = " WHERE APPR.ENTITY_CODE IN (" + product + ") ";
}
if((zone.trim().length() > 0) || (region.trim().length() > 0) || (team.trim().length() > 0))
{
whereClause = " Where ";
}
if ((zone != null) && (zone.trim().length() > 0))
{
if((region.length()>0) || (team.length()>0))
{
System.out.println("zone" + zone);
zone = dashbordUtil.getCommaSeparated(zone);
zoneCodeFilter = " e.ZONECODE IN (" + zone + ") AND ";
}
else
{
zone = dashbordUtil.getCommaSeparated(zone);
zoneCodeFilter = " e.ZONECODE IN (" + zone + ")";
}
}
if ((region != null) && (region.trim().length() > 0))
{
if(team.length()>0)
{
System.out.println("region" + region);
region = dashbordUtil.getCommaSeparated(region);
regionCodeFilter = " r.Name IN (" + region + ") AND ";
}
else
{
region = dashbordUtil.getCommaSeparated(region);
regionCodeFilter = " r.Name IN (" + region + ")";
}
}
if ((team != null) && (team.trim().length() > 0))
{
System.out.println("team" + team);
team = dashbordUtil.getCommaSeparated(team);
teamCodeFilter = " e.teamcode IN (" + team + ") ";
}
/*sql= "select e.ZONECODE ZONE, r.Name as REGION, e.teamcode TEAM, " +
"(e.FIRSTNAME +' '+ e.LASTNAME) NAME ,COUNT(SUR.MGR) NOS, " +
"SUM(SUR.RESULT) TOTAL from dbo.employee e INNER JOIN HR.DBO.REGION r on e.regionid = r.id INNER JOIN (SELECT APP.ENTITY_CODE EMP_CODE, " +
"SRE.EMP_CODE MGR, sum(CAST(SRD.result AS INT)) RESULT, " +
"APPR.ENTITY_CODE PRD_CODE, APPR.ENTITY_DESCR PRD_DESC FROM dbo.survey_result_EMP SRE INNER JOIN dbo.survey_result SR ON SRE.TRAN_ID = SR.TRAN_ID__FORM INNER JOIN dbo.survey_result_det SRD ON SR.TRAN_ID = SRD.TRAN_ID INNER JOIN (SELECT * FROM dbo.survey_result_appl WHERE APPL_ENTITY = 'E') APP ON SRD.TRAN_ID = APP.TRAN_ID INNER JOIN (SELECT * FROM dbo.survey_result_appl WHERE APPL_ENTITY = 'P') APPR ON SRD.TRAN_ID = APPR.TRAN_ID WHERE APPR.ENTITY_CODE = "+product+" GROUP BY APP.ENTITY_CODE, " +
"SRE.EMP_CODE, APPR.ENTITY_CODE, " +
"APPR.ENTITY_DESCR) SUR ON e.code = SUR.EMP_CODE WHERE e.ZONECODE = "+zone+" AND r.Name = "+region+" AND e.teamcode = "+team+" GROUP BY e.ZONECODE, " +
"r.Name, e.teamcode, (e.FIRSTNAME +' '+ e.LASTNAME)";
*/
/*working SQL on dated 04-11-2015*/
sql= "select e.ZONECODE ZONE, r.Name as REGION, e.teamcode TEAM, " +
"(e.FIRSTNAME +' '+ e.LASTNAME) NAME ,COUNT(SUR.MGR) NOS, " +
"SUM(SUR.RESULT) TOTAL from dbo.employee e " +
"INNER JOIN DBO.REGION r on e.regionid = r.id " +
"INNER JOIN (SELECT APP.ENTITY_CODE EMP_CODE, " +
"SRE.EMP_CODE MGR, sum(CAST(SRD.result AS INT)) RESULT, " +
"APPR.ENTITY_CODE PRD_CODE, APPR.ENTITY_DESCR PRD_DESC " +
"FROM dbo.survey_result_EMP SRE INNER JOIN dbo.survey_result SR ON SRE.TRAN_ID = SR.TRAN_ID__FORM " +
"INNER JOIN dbo.survey_result_det SRD ON SR.TRAN_ID = SRD.TRAN_ID " +
"INNER JOIN (SELECT * FROM dbo.survey_result_appl WHERE APPL_ENTITY = 'E') APP ON SRD.TRAN_ID = APP.TRAN_ID " +
"INNER JOIN (SELECT * FROM dbo.survey_result_appl WHERE APPL_ENTITY = 'I') APPR ON SRD.TRAN_ID = APPR.TRAN_ID " +
" "+productFilter+" GROUP BY APP.ENTITY_CODE, " +
"SRE.EMP_CODE, APPR.ENTITY_CODE, " +
"APPR.ENTITY_DESCR) SUR ON e.code = SUR.EMP_CODE " +
" "+whereClause+" "+zoneCodeFilter+regionCodeFilter+ teamCodeFilter+" " +
"GROUP BY e.ZONECODE, " +
"r.Name, e.teamcode, (e.FIRSTNAME +' '+ e.LASTNAME)";
/* sql for Testing on dated 06-11-2015*/
/*sql = "select e.ZONECODE ZONE, r.Name as REGION, e.teamcode TEAM, " +
"(e.FIRSTNAME +' '+ e.LASTNAME) NAME ,COUNT(SUR.MGR) NOS, " +
"SUM(SUR.RESULT) TOTAL from dbo.employee e INNER JOIN HR.DBO.REGION r on e.regionid = r.id INNER JOIN (SELECT APP.ENTITY_CODE EMP_CODE, " +
"SRE.EMP_CODE MGR, sum(CAST(SRD.result AS INT)) RESULT, " +
"APPR.ENTITY_CODE PRD_CODE, " +
"APPR.ENTITY_DESCR PRD_DESC FROM dbo.survey_result_EMP SRE INNER JOIN dbo.survey_result SR ON SRE.TRAN_ID = SR.TRAN_ID__FORM INNER JOIN dbo.survey_result_det SRD ON SR.TRAN_ID = SRD.TRAN_ID INNER JOIN (SELECT * FROM dbo.survey_result_appl WHERE APPL_ENTITY = 'E') APP ON SRD.TRAN_ID = APP.TRAN_ID INNER JOIN (SELECT * FROM dbo.survey_result_appl " +
//"WHERE APPL_ENTITY = 'I' " +
")APPR ON SRD.TRAN_ID = APPR.TRAN_ID " +
//"and SRD.TRAN_ID IN ('ES00002043','ES00002044','ES00002045') " +
"GROUP BY APP.ENTITY_CODE, SRE.EMP_CODE, APPR.ENTITY_CODE, APPR.ENTITY_DESCR) SUR ON e.code = SUR.EMP_CODE GROUP BY e.ZONECODE, r.Name, e.teamcode, (e.FIRSTNAME +' '+ e.LASTNAME)";
*/
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
int count = 0;
while (rs.next())
{
rowData = new JSONObject();
rowData.put("zone",checkNull (rs.getString("ZONE")));
rowData.put("region", checkNull(rs.getString("REGION")));
rowData.put("team",checkNull( rs.getString("TEAM")));
rowData.put("name", checkNull(rs.getString("NAME")));
rowData.put("nos",checkNull( rs.getString("NOS")));
rowData.put("total",checkNull( rs.getString("TOTAL")));
//rowData.put("%", rs.getString("%"));
//rowData.put("detail", rs.getString("DETAIL"));
rawDataEmployeeProdSurveylJson.put(count, rowData);
count++;
}
}
catch (Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if (conn != null)
{
if (rs != null)
rs.close();
rs = null;
if (pstmt != null)
pstmt.close();
pstmt = null;
conn.close();
conn = null;
}
conn = null;
} catch (Exception d)
{
d.printStackTrace();
System.out.println("Exception in :ProductAssessment getProductAssessmentEventServlet :" + d.getMessage());
throw new ITMException(d);
}
}
return rawDataEmployeeProdSurveylJson;
}
@SuppressWarnings("unchecked")
@Override
public JSONObject getProductAssessmentProductServlet(String dataSourceName,String personName) throws RemoteException, ITMException
{
JSONObject rawDataEmployeeProductlJson = new JSONObject();
JSONObject rowData = null;
String sql = "";
ResultSet rs = null;
PreparedStatement pstmt = null;
Connection conn = null;
ConnDriver connDriver = new ConnDriver();
try
{
System.out.println(" Inside ProductAssessment for getProductAssessmentProductServlet Data Soruc Name ="+dataSourceName+ "==== personName :"+personName);
conn = connDriver.getConnectDB(dataSourceName);
connDriver = null;
/*sql from sarvesh*/
/*sql="SELECT (e.FIRSTNAME +' '+ e.LASTNAME) NAME, sm.descr as SURVEY , " +
"CAST(SRD.result AS INT) RESULT FROM dbo.survey_result_EMP SRE " +
"INNER JOIN dbo.survey_result SR ON SRE.TRAN_ID = SR.TRAN_ID__FORM " +
"INNER JOIN dbo.survey_result_det SRD ON SR.TRAN_ID = SRD.TRAN_ID " +
"INNER JOIN (SELECT * FROM dbo.survey_result_appl " +
"WHERE APPL_ENTITY = 'E') APP ON SRD.TRAN_ID = APP.TRAN_ID " +
"INNER JOIN (SELECT * FROM dbo.survey_result_appl " +
"WHERE APPL_ENTITY = 'P') APPR ON SRD.TRAN_ID = APPR.TRAN_ID " +
"INNER JOIN dbo.employee e ON APP.ENTITY_CODE = e.code " +
"INNER JOIN dbo.survey_master sm ON SRD.SURVEY_CODE = sm.SURVEY_CODE " +
"WHERE (e.FIRSTNAME +' '+ e.LASTNAME) = 'EMP_NAME' AND APPR.ENTITY_DESCR IN ('PRD_DESC')";
*/
/*sql for testing*/
/*sql="select NAME, SURVEY, RESULT from ( SELECT (e.FIRSTNAME +' '+ e.LASTNAME) as NAME, " +
"sm.descr as SURVEY, CAST(SRD.result AS INT) RESULT FROM dbo.survey_result_EMP SRE " +
"INNER JOIN dbo.survey_result SR ON SRE.TRAN_ID = SR.TRAN_ID__FORM " +
"INNER JOIN dbo.survey_result_det SRD ON SR.TRAN_ID = SRD.TRAN_ID " +
"INNER JOIN (SELECT * FROM dbo.survey_result_appl " +
"WHERE APPL_ENTITY = 'E') APP ON SRD.TRAN_ID = APP.TRAN_ID " +
"INNER JOIN (SELECT * FROM dbo.survey_result_appl " +
"WHERE APPL_ENTITY = 'P') APPR ON SRD.TRAN_ID = APPR.TRAN_ID " +
"INNER JOIN dbo.employee e ON APP.ENTITY_CODE = e.code " +
"INNER JOIN dbo.survey_master sm ON SRD.SURVEY_CODE = sm.SURVEY_CODE ) A " +
"WHERE NAME = 'Amrapali A. Nimbalkar' " +
"AND SURVEY IN ('Opening','Detailing','Probing','Listening')";
*/
//" WHERE SRD.SURVEY_CODE LIKE 'P%' " +
//" WHERE SRD.SURVEY_CODE LIKE 'P%' " +
/*sql = "select MGR, NAME, SURVEY, SUM(RESULT) RESULT from ( SELECT (e1.FIRSTNAME +' '+ e1.LASTNAME) as MGR, " +
"(e.FIRSTNAME +' '+ e.LASTNAME) as NAME, sm.descr as SURVEY, CAST(SRD.result AS INT) RESULT " +
"FROM dbo.survey_result_EMP SRE INNER JOIN dbo.survey_result SR ON SRE.TRAN_ID = SR.TRAN_ID__FORM " +
"INNER JOIN dbo.survey_result_det SRD ON SR.TRAN_ID = SRD.TRAN_ID " +
"INNER JOIN (SELECT * FROM dbo.survey_result_appl " +
"WHERE APPL_ENTITY = 'E') APP ON SRD.TRAN_ID = APP.TRAN_ID " +
//"INNER JOIN (SELECT * FROM dbo.survey_result_appl " +
//"WHERE APPL_ENTITY = 'P') APPR ON SRD.TRAN_ID = APPR.TRAN_ID " +
"INNER JOIN dbo.employee e ON APP.ENTITY_CODE = e.code " +
"INNER JOIN dbo.survey_master sm ON SRD.SURVEY_CODE = sm.SURVEY_CODE " +
"LEFT OUTER JOIN dbo.employee e1 ON SRE.EMP_CODE = e1.code) A " +
"WHERE NAME = 'Prasad Kadam' " +
"AND SURVEY IN ('Opening','Detailing','Probing','Listening') " +
"GROUP BY MGR, NAME, SURVEY";
*/
/*wORKING SQL*/
sql = "SELECT NAME, PRD_NAME, PERC, REPORT,RESULTCNT FROM (SELECT DET_PRD.NAME , DET_PRD.PRD_NAME,RESULT,TOTAL, " +
"Str((RESULT * 100.0/TOTAL),4,1) AS PERC, 'Obtained Marks' AS REPORT,(RESULT) as RESULTCNT " +
"FROM ( select e.CODE, SUM(SUR.RESULT) TOTAL from dbo.employee e " +
"INNER JOIN DBO.REGION r on e.regionid = r.id " +
"INNER JOIN (SELECT APP.ENTITY_CODE EMP_CODE, SRE.EMP_CODE MGR, sum(CAST(SRD.result AS INT)) RESULT, " +
"APPR.ENTITY_CODE PRD_CODE, APPR.ENTITY_DESCR PRD_DESC FROM dbo.survey_result_EMP SRE " +
"INNER JOIN dbo.survey_result SR ON SRE.TRAN_ID = SR.TRAN_ID__FORM " +
"INNER JOIN dbo.survey_result_det SRD ON SR.TRAN_ID = SRD.TRAN_ID " +
"INNER JOIN (SELECT * FROM dbo.survey_result_appl WHERE APPL_ENTITY = 'E') APP ON SRD.TRAN_ID = APP.TRAN_ID " +
"INNER JOIN (SELECT * FROM dbo.survey_result_appl " +
" WHERE APPL_ENTITY = 'I'" +
") APPR ON SRD.TRAN_ID = APPR.TRAN_ID " +
"GROUP BY APP.ENTITY_CODE, SRE.EMP_CODE, APPR.ENTITY_CODE, APPR.ENTITY_DESCR) " +
"SUR ON e.code = SUR.EMP_CODE " +
"WHERE (e.FIRSTNAME +' '+ e.LASTNAME) = '"+personName+"' GROUP BY e.CODE ) HDR " +
"INNER JOIN (SELECT (e.FIRSTNAME +' '+ e.LASTNAME) NAME, APPR.ENTITY_DESCR as PRD_NAME , " +
"SUM(CAST(SRD.result AS INT)) RESULT , e.code FROM dbo.survey_result_EMP SRE " +
"INNER JOIN dbo.survey_result SR ON SRE.TRAN_ID = SR.TRAN_ID__FORM " +
"INNER JOIN dbo.survey_result_det SRD ON SR.TRAN_ID = SRD.TRAN_ID " +
"INNER JOIN (SELECT * FROM dbo.survey_result_appl WHERE APPL_ENTITY = 'E') " +
"APP ON SRD.TRAN_ID = APP.TRAN_ID INNER JOIN (SELECT * FROM dbo.survey_result_appl " +
" WHERE APPL_ENTITY = 'I'" +
") APPR ON SRD.TRAN_ID = APPR.TRAN_ID " +
"INNER JOIN dbo.employee e ON APP.ENTITY_CODE = e.code " +
"INNER JOIN dbo.survey_master sm ON SRD.SURVEY_CODE = sm.SURVEY_CODE " +
"WHERE (e.FIRSTNAME +' '+ e.LASTNAME) = '"+personName+"' " +
"GROUP BY (e.FIRSTNAME +' '+ e.LASTNAME) , APPR.ENTITY_DESCR , e.code) DET_PRD ON HDR.CODE = DET_PRD.CODE " +
"UNION ALL " +
"SELECT DET_PRD.NAME , DET_PRD.PRD_NAME,RESULT,TOTAL, Str((100-(RESULT * 100.0/TOTAL)),4,1) PERC, 'NR' AS REPORT,(TOTAL - RESULT) as RESULTCNT " +
"FROM ( select e.CODE, SUM(SUR.RESULT) TOTAL from dbo.employee e INNER JOIN DBO.REGION r on e.regionid = r.id INNER JOIN (SELECT APP.ENTITY_CODE EMP_CODE, " +
"SRE.EMP_CODE MGR, sum(CAST(SRD.result AS INT)) RESULT, APPR.ENTITY_CODE PRD_CODE, APPR.ENTITY_DESCR PRD_DESC FROM dbo.survey_result_EMP SRE " +
"INNER JOIN dbo.survey_result SR ON SRE.TRAN_ID = SR.TRAN_ID__FORM " +
"INNER JOIN dbo.survey_result_det SRD ON SR.TRAN_ID = SRD.TRAN_ID INNER JOIN (SELECT * FROM dbo.survey_result_appl WHERE APPL_ENTITY = 'E') APP ON SRD.TRAN_ID = APP.TRAN_ID " +
"INNER JOIN (SELECT * FROM dbo.survey_result_appl " +
"WHERE APPL_ENTITY = 'I'" +
") APPR ON SRD.TRAN_ID = APPR.TRAN_ID " +
"GROUP BY APP.ENTITY_CODE, SRE.EMP_CODE, APPR.ENTITY_CODE, APPR.ENTITY_DESCR) SUR ON e.code = SUR.EMP_CODE " +
"WHERE (e.FIRSTNAME +' '+ e.LASTNAME) = '"+personName+"' GROUP BY e.CODE ) HDR INNER JOIN (SELECT (e.FIRSTNAME +' '+ e.LASTNAME) NAME, APPR.ENTITY_DESCR as PRD_NAME , " +
"SUM(CAST(SRD.result AS INT)) RESULT , e.code FROM dbo.survey_result_EMP SRE INNER JOIN dbo.survey_result SR ON SRE.TRAN_ID = SR.TRAN_ID__FORM " +
"INNER JOIN dbo.survey_result_det SRD ON SR.TRAN_ID = SRD.TRAN_ID INNER JOIN (SELECT * FROM dbo.survey_result_appl WHERE APPL_ENTITY = 'E') APP ON SRD.TRAN_ID = APP.TRAN_ID " +
"INNER JOIN (SELECT * FROM dbo.survey_result_appl " +
"WHERE APPL_ENTITY = 'I'" +
") APPR ON SRD.TRAN_ID = APPR.TRAN_ID INNER JOIN dbo.employee e ON APP.ENTITY_CODE = e.code " +
"INNER JOIN dbo.survey_master sm ON SRD.SURVEY_CODE = sm.SURVEY_CODE " +
"WHERE (e.FIRSTNAME +' '+ e.LASTNAME) = '"+personName+"' GROUP BY (e.FIRSTNAME +' '+ e.LASTNAME) , APPR.ENTITY_DESCR , e.code) DET_PRD ON HDR.CODE = DET_PRD.CODE) X " +
"ORDER BY NAME, PRD_NAME";
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
int count = 0;
while (rs.next())
{
rowData = new JSONObject();
rowData.put("prd_name", checkNull(rs.getString("PRD_NAME")));
rowData.put("name", checkNull(rs.getString("NAME")));
rowData.put("perc", checkNull(rs.getString("PERC")));
rowData.put("report", checkNull(rs.getString("REPORT")));
rowData.put("resultcnt", checkNull(rs.getString("RESULTCNT")));
rawDataEmployeeProductlJson.put(count, rowData);
count++;
}
}
catch (Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if (conn != null)
{
if (rs != null)
rs.close();
rs = null;
if (pstmt != null)
pstmt.close();
pstmt = null;
conn.close();
conn = null;
}
conn = null;
} catch (Exception d)
{
d.printStackTrace();
System.out.println("Exception in :getProductAssessmentProductServlet:" + d.getMessage());
throw new ITMException(d);
}
}
System.out.println("ProductAssessment rawDataEmployeeProductlJson String======>>"+rawDataEmployeeProductlJson.toString());
return rawDataEmployeeProductlJson;
}
@SuppressWarnings("unchecked")
@Override
public JSONObject getProductAssessmentProductRatingServlet(String dataSourceName,String personName,String productName) throws RemoteException, ITMException
{
JSONObject rawDataEmployeeProductlRatingJson = new JSONObject();
JSONObject rowData = null;
String sql = "";
ResultSet rs = null;
PreparedStatement pstmt = null;
Connection conn = null;
ConnDriver connDriver = new ConnDriver();
try
{
System.out.println(" Inside ProductAssessment for getProductAssessmentProductRatingServlet Data Soruc Name ="+dataSourceName+" personName=:"+ personName + "=== productName :"+ productName);
conn = connDriver.getConnectDB(dataSourceName);
connDriver = null;
/*sql= "select MGR, SUM(RESULT) RESULT from ( SELECT (e1.FIRSTNAME +' '+ e1.LASTNAME) as MGR, " +
"(e.FIRSTNAME +' '+ e.LASTNAME) as NAME, sm.descr as SURVEY, CAST(SRD.result AS INT) RESULT " +
"FROM dbo.survey_result_EMP SRE INNER JOIN dbo.survey_result SR ON SRE.TRAN_ID = SR.TRAN_ID__FORM " +
"INNER JOIN dbo.survey_result_det SRD ON SR.TRAN_ID = SRD.TRAN_ID " +
"INNER JOIN (SELECT * FROM dbo.survey_result_appl " +
"WHERE APPL_ENTITY = 'E') APP ON SRD.TRAN_ID = APP.TRAN_ID " +
"INNER JOIN (SELECT * FROM dbo.survey_result_appl " +
"WHERE APPL_ENTITY = 'I') APPR ON SRD.TRAN_ID = APPR.TRAN_ID " +
"INNER JOIN dbo.employee e ON APP.ENTITY_CODE = e.code " +
"INNER JOIN dbo.survey_master sm ON SRD.SURVEY_CODE = sm.SURVEY_CODE " +
"LEFT OUTER JOIN dbo.employee e1 ON SRE.EMP_CODE = e1.code) A " +
"WHERE NAME = 'Prasad Kadam' " +
"AND SURVEY IN ('Opening','Detailing','Probing','Listening') " +
"GROUP BY MGR ";*/
/*wORKING SQL*/
sql = "SELECT sm.DESCR as SURVEY , SUM(CAST(SRD.result AS INT)) RESULT FROM dbo.survey_result_EMP SRE " +
"INNER JOIN dbo.survey_result SR ON SRE.TRAN_ID = SR.TRAN_ID__FORM " +
"INNER JOIN dbo.survey_result_det SRD ON SR.TRAN_ID = SRD.TRAN_ID " +
"INNER JOIN (SELECT * FROM dbo.survey_result_appl " +
"WHERE APPL_ENTITY = 'E') APP ON SRD.TRAN_ID = APP.TRAN_ID " +
"INNER JOIN (SELECT * FROM dbo.survey_result_appl " +
"WHERE APPL_ENTITY = 'I') APPR ON SRD.TRAN_ID = APPR.TRAN_ID " +
"INNER JOIN dbo.employee e ON APP.ENTITY_CODE = e.code " +
"INNER JOIN dbo.survey_master sm ON SRD.SURVEY_CODE = sm.SURVEY_CODE " +
"WHERE (e.FIRSTNAME +' '+ e.LASTNAME) = '"+personName+"' and APPR.ENTITY_DESCR = '"+productName+"' " +
"GROUP BY sm.DESCR";
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
int count = 0;
while (rs.next())
{
rowData = new JSONObject();
rowData.put("survey", checkNull(rs.getString("SURVEY")));
rowData.put("result", checkNull(rs.getString("RESULT")));
rawDataEmployeeProductlRatingJson.put(count, rowData);
count++;
}
}
catch (Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if (conn != null)
{
if (rs != null)
rs.close();
rs = null;
if (pstmt != null)
pstmt.close();
pstmt = null;
conn.close();
conn = null;
}
conn = null;
} catch (Exception d)
{
d.printStackTrace();
System.out.println("Exception in :getProductAssessmentProductRatingServlet:" + d.getMessage());
throw new ITMException(d);
}
}
System.out.println("ProductAssessment rawDataEmployeeProductlRatingJson String======>>"+rawDataEmployeeProductlRatingJson.toString());
return rawDataEmployeeProductlRatingJson;
}
private String checkNull(String str)
{
if(str == null)
{
return "";
}
else
{
return str ;
}
}
}
webitm-dashboard/ibase/dashboard/sfa/ejb/ProductAssessmentLocal.java 0 → 100755
View file @ c4ef0190
package ibase.dashboard.sfa.ejb;
import java.rmi.RemoteException;
import ibase.webitm.ejb.ValidatorLocal;
import ibase.webitm.utility.ITMException;
import javax.ejb.Local;
import org.json.simple.JSONObject;
@Local
public interface ProductAssessmentLocal extends ValidatorLocal
{
public JSONObject getProductAssessmentEventServlet(String loginId, String dataSourceName,String zone,String region,String product,String team,String event) throws RemoteException, ITMException;
public JSONObject getProductAssessmentProductServlet(String dataSourceName,String name) throws RemoteException, ITMException;
public JSONObject getProductAssessmentProductRatingServlet(String dataSourceName,String personName,String productName) throws RemoteException, ITMException;
}
webitm-dashboard/ibase/dashboard/sfa/ejb/ProductAssessmentRemote.java 0 → 100755
View file @ c4ef0190
package ibase.dashboard.sfa.ejb;
import java.rmi.RemoteException;
import ibase.webitm.ejb.ValidatorRemote;
import ibase.webitm.utility.ITMException;
import javax.ejb.Remote;
import org.json.simple.JSONObject;
@Remote
public interface ProductAssessmentRemote extends ValidatorRemote
{
public JSONObject getProductAssessmentEventServlet(String loginId, String dataSourceName,String zone,String region,String product,String team,String event) throws RemoteException, ITMException;
public JSONObject getProductAssessmentProductServlet(String dataSourceName,String name) throws RemoteException, ITMException;
public JSONObject getProductAssessmentProductRatingServlet(String dataSourceName,String personName,String productName) throws RemoteException, ITMException;
}
webitm-dashboard/ibase/dashboard/sfa/servlet/ProductAssessmentEventServlet.java 0 → 100755
View file @ c4ef0190
package ibase.dashboard.sfa.servlet;
import ibase.dashboard.sfa.ejb.ProductAssessmentRemote;
import ibase.system.config.AppConnectParm;
import ibase.webitm.utility.ITMException;
import java.io.IOException;
import java.io.OutputStream;
import javax.naming.InitialContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.json.simple.JSONObject;
import javax.servlet.http.HttpSession;
public class ProductAssessmentEventServlet extends HttpServlet
{
private static final long serialVersionUID = 1L;
JSONObject jsonObjMetaData = null;
JSONObject jsonMetaData = null;
public void doGet(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException
{
doPost(request, response);
}
@SuppressWarnings("unchecked")
public void doPost(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException
{
ProductAssessmentRemote productAssessmentRemote = null;
InitialContext context = null;
AppConnectParm appConnectParm = new AppConnectParm();
String dataSourceName = "";
String loginId = "";
String zone ="";
String region = "";
String product = "";
String team = "";
String event = "";
try
{
response.setContentType("application/xml");
HttpSession session = request.getSession(true);
ibase.utility.UserInfoBean userInfo = (ibase.utility.UserInfoBean) session.getAttribute("USER_INFO");
loginId = userInfo.getLoginCode();
dataSourceName = request.getParameter("dataSourceName");
zone = request.getParameter("zone");
region = request.getParameter("region");
product = request.getParameter("product");
team = request.getParameter("team");
event = request.getParameter("event");
//period = request.getParameter("period");
System.out.println("in ProductAssessmentEventServlet zone :"+zone+"===== region :"+region +"dataSourceName: ="+dataSourceName);
System.out.println("in ProductAssessmentEventServlet product :"+product+"===== team :"+team +"event: ="+event);
context = new InitialContext(appConnectParm.getProperty());
productAssessmentRemote = (ProductAssessmentRemote) context.lookup("ibase/ProductAssessment/remote");
//JSONObject jsonObjData = (JSONObject) productAssessmentRemote.getEmployeeEvents( loginId, dataSourceName, zone, region, product, team, event);
JSONObject jsonObjData = (JSONObject) productAssessmentRemote.getProductAssessmentEventServlet( loginId, dataSourceName, zone, region, product, team, event);
OutputStream outputStream = response.getOutputStream();
outputStream.write(jsonObjData.toString().getBytes());
outputStream.flush();
outputStream.close();
System.out.println("Final data set for ProductAssessmentEventServlet build the Graph is===" + jsonObjData);
} catch (Exception e)
{
System.out.println("Exception : ProductAssessmentEventServlet :doPost(HttpServletRequest request, HttpServletResponse response) :" + e);
try
{
throw new ITMException(e);
} catch (ITMException e1)
{
e1.printStackTrace();
}
}
}
}
\ No newline at end of file
webitm-dashboard/ibase/dashboard/sfa/servlet/ProductAssessmentProductRatingServlet.java 0 → 100755
View file @ c4ef0190
package ibase.dashboard.sfa.servlet;
import ibase.dashboard.sfa.ejb.ProductAssessmentRemote;
import ibase.system.config.AppConnectParm;
import ibase.webitm.utility.ITMException;
import java.io.IOException;
import java.io.OutputStream;
import javax.naming.InitialContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.json.simple.JSONObject;
import javax.servlet.http.HttpSession;
public class ProductAssessmentProductRatingServlet extends HttpServlet
{
private static final long serialVersionUID = 1L;
JSONObject jsonObjMetaData = null;
JSONObject jsonMetaData = null;
public void doGet(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException
{
doPost(request, response);
}
@SuppressWarnings("unchecked")
public void doPost(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException
{
ProductAssessmentRemote productAssessmentRemote = null;
InitialContext context = null;
AppConnectParm appConnectParm = new AppConnectParm();
String dataSourceName = "";
String personName = "";
String productName = "";
try
{
response.setContentType("application/xml");
dataSourceName = request.getParameter("dataSourceName");
personName = request.getParameter("name");
productName = request.getParameter("productName");
System.out.println("personName =" + personName +"==== productName :"+productName);
context = new InitialContext(appConnectParm.getProperty());
productAssessmentRemote = (ProductAssessmentRemote) context.lookup("ibase/ProductAssessment/remote");
System.out.println("in ProductAssessmentProductRatingServlet");
//JSONObject jsonObjData = (JSONObject) productAssessmentRemote.getEmployeeProductRating(dataSourceName,personName,productName);
JSONObject jsonObjData = (JSONObject) productAssessmentRemote.getProductAssessmentProductRatingServlet(dataSourceName,personName,productName);
OutputStream outputStream = response.getOutputStream();
outputStream.write(jsonObjData.toString().getBytes());
outputStream.flush();
outputStream.close();
System.out.println(" Final data set for ProductAssessmentProductRatingServlet build the Graph is===" + jsonObjData);
} catch (Exception e)
{
System.out.println("Exception : ProductAssessmentProductRatingServlet :doPost(HttpServletRequest request, HttpServletResponse response) :" + e);
try
{
throw new ITMException(e);
} catch (ITMException e1)
{
e1.printStackTrace();
}
}
}
}
\ No newline at end of file
webitm-dashboard/ibase/dashboard/sfa/servlet/ProductAssessmentProductServlet.java 0 → 100755
View file @ c4ef0190
package ibase.dashboard.sfa.servlet;
import ibase.dashboard.sfa.ejb.ProductAssessmentRemote;
import ibase.system.config.AppConnectParm;
import ibase.webitm.utility.ITMException;
import java.io.IOException;
import java.io.OutputStream;
import javax.naming.InitialContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.json.simple.JSONObject;
import javax.servlet.http.HttpSession;
public class ProductAssessmentProductServlet extends HttpServlet
{
private static final long serialVersionUID = 1L;
JSONObject jsonObjMetaData = null;
JSONObject jsonMetaData = null;
public void doGet(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException
{
doPost(request, response);
}
@SuppressWarnings("unchecked")
public void doPost(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException
{
ProductAssessmentRemote productAssessmentRemote = null;
InitialContext context = null;
AppConnectParm appConnectParm = new AppConnectParm();
String dataSourceName = "";
String personName = "";
try
{
response.setContentType("application/xml");
dataSourceName = request.getParameter("dataSourceName");
personName = request.getParameter("name");
System.out.println(" ProductAssessmentProductServlet personName =" + personName + "===== dataSourceName :"+dataSourceName);
context = new InitialContext(appConnectParm.getProperty());
productAssessmentRemote = (ProductAssessmentRemote) context.lookup("ibase/ProductAssessment/remote");
//JSONObject jsonObjData = (JSONObject) productAssessmentRemote.getEmployeeProduct(dataSourceName,personName);
JSONObject jsonObjData = (JSONObject) productAssessmentRemote.getProductAssessmentProductServlet(dataSourceName,personName);
OutputStream outputStream = response.getOutputStream();
outputStream.write(jsonObjData.toString().getBytes());
outputStream.flush();
outputStream.close();
System.out.println(" Final data set for ProductAssessmentProductServlet build the Graph is===" + jsonObjData);
} catch (Exception e)
{
System.out.println("Exception : ProductAssessmentProductServlet :doPost(HttpServletRequest request, HttpServletResponse response) :" + e);
try
{
throw new ITMException(e);
} catch (ITMException e1)
{
e1.printStackTrace();
}
}
}
}
\ 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