Commit d25fafc7 authored by nsawalakhe's avatar nsawalakhe

Added new

AttendanceCompliance.java,
AttendanceComplianceLocal.java,
AttendanceComplianceRemote.java
and AttendanceComplianceServlet for Gardenia


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@98777 ce508802-f39f-4f6c-b175-0d175dae99d5
parent e3258676
package ibase.dashboard.sfa.ejb;
import ibase.system.config.ConnDriver;
import ibase.webitm.ejb.ValidatorEJB;
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;
@Stateless
public class AttendanceCompliance extends ValidatorEJB implements AttendanceComplianceLocal,
AttendanceComplianceRemote
{
public AttendanceCompliance()
{
}
@SuppressWarnings("unchecked")
public JSONObject getAttendance(String dataSourceName, String empCode)
throws RemoteException, ITMException
{
JSONObject rowDataPendingTaskJson = new JSONObject();
JSONObject rowData = null;
String sql = "";
ResultSet rs = null;
PreparedStatement pstmt = null;
Connection conn = null;
ConnDriver connDriver = new ConnDriver();
int count = 0;
try
{
conn = connDriver.getConnectDB(dataSourceName);
connDriver = null;
sql = "SELECT SALES_PERS, SP_NAME, to_char(LAST_REPORT,'dd/mm/yyyy') AS LAST_REPORT, ROUND(TRUNC(SYSDATE)-TRUNC(LAST_REPORT)) NOT_REPORTED,"
+ " EMP_NAME, MOBILE_NO FROM (SELECT SP.SALES_PERS, SP.SP_NAME,MAX(S.EVENT_DATE) LAST_REPORT,"
+ " (NVL(TRIM(E1.EMP_FNAME),'')||NVL(TRIM(E1.EMP_MNAME),' ')||NVL(TRIM(E1.EMP_LNAME),'')) EMP_NAME, "
+ " E.MOBILE_NO FROM SPRS_ACT_TRAN S INNER JOIN EMPLOYEE E ON S.SALES_PERS = E.EMP_CODE "
+ " INNER JOIN SALES_PERS SP ON E.EMP_CODE = SP.SALES_PERS LEFT "
+ " OUTER JOIN EMPLOYEE E1 ON E1.EMP_CODE = E.REPORT_TO "
+ " WHERE E.REPORT_TO = '" + empCode + "'"
+ " GROUP BY SP.SALES_PERS, SP.SP_NAME, (NVL(TRIM(E1.EMP_FNAME),'')||NVL(TRIM(E1.EMP_MNAME),' ')||NVL(TRIM(E1.EMP_LNAME),'')), E.MOBILE_NO) A ";
System.out.println("sql is =" + sql);
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
while (rs.next())
{
rowData = new JSONObject();
rowData.put("salespersn", checkNull(rs.getString("SALES_PERS")));
rowData.put("spname", checkNull(rs.getString("SP_NAME")));
rowData.put("lastreport", (rs.getString("LAST_REPORT")));
rowData.put("notreported", checkNull(rs.getString("NOT_REPORTED")));
rowData.put("empname", checkNull(rs.getString("EMP_NAME")));
rowData.put("mobileno", checkNull(rs.getString("MOBILE_NO")));
rowDataPendingTaskJson.put(Integer.valueOf(count), rowData);
count++;
}
System.out.println(" rowDataPendingTaskJson is =" + rowDataPendingTaskJson);
}
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 :getTask():" + d.getMessage());
throw new ITMException(d);
}
}
return rowDataPendingTaskJson;
}
private String checkNull(String str)
{
if (str == null)
{
return "";
} else
{
return str;
}
}
}
package ibase.dashboard.sfa.ejb;
import ibase.webitm.ejb.ValidatorLocal;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import javax.ejb.Local;
import org.json.simple.JSONObject;
@Local
public abstract interface AttendanceComplianceLocal extends ValidatorLocal
{
public abstract JSONObject getAttendance(String dataSourceName,String empCode)throws RemoteException, ITMException;
}
package ibase.dashboard.sfa.ejb;
import ibase.webitm.ejb.ValidatorRemote;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import javax.ejb.Remote;
import org.json.simple.JSONObject;
@Remote
public abstract interface AttendanceComplianceRemote extends ValidatorRemote
{
public abstract JSONObject getAttendance(String dataSourceName,String empCode) throws RemoteException, ITMException;
}
package ibase.dashboard.sfa.servlet;
import ibase.dashboard.sfa.ejb.AttendanceComplianceRemote;
import ibase.system.config.AppConnectParm;
import ibase.utility.UserInfoBean;
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 javax.servlet.http.HttpSession;
import org.json.simple.JSONObject;
public class AttendanceComplianceServlet extends HttpServlet
{
private static final long serialVersionUID = 1L;
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws IOException, ServletException
{
doPost(request, response);
}
public void doPost(HttpServletRequest request, HttpServletResponse response)
throws IOException, ServletException
{
AttendanceComplianceRemote gardeniaRemote = null;
InitialContext context = null;
AppConnectParm appConnectParm = new AppConnectParm();
String dataSourceName = "";
String loginId = "";
HttpSession session = null;
JSONObject jsonObjData = null;
OutputStream outputStream = null;
UserInfoBean userInfo = null;
try
{
response.setContentType("application/xml");
session = request.getSession(true);
userInfo = (UserInfoBean) session.getAttribute("USER_INFO");
loginId = userInfo.getLoginCode();
dataSourceName = request.getParameter("dataSourceName");
System.out.println("loginId is =" + loginId);
context = new InitialContext(appConnectParm.getProperty());
gardeniaRemote = (AttendanceComplianceRemote) context
.lookup("ibase/AttendanceCompliance/remote");
jsonObjData = (JSONObject) gardeniaRemote.getAttendance(dataSourceName,
loginId);
outputStream = response.getOutputStream();
outputStream.write(jsonObjData.toString().getBytes());
outputStream.flush();
outputStream.close();
System.out
.println(" Final data set for AttendanceComplianceServlet build the Graph is==="
+ jsonObjData);
}
catch (Exception e)
{
System.out
.println("Exception : AttendanceComplianceServlet :doPost(HttpServletRequest request, HttpServletResponse response) :"
+ e);
try
{
throw new ITMException(e);
}
catch (ITMException e1)
{
e1.printStackTrace();
}
}
}
}
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