Commit a9a4ce5d authored by kpandey's avatar kpandey

Added new Dao and Service For course-library component

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@198650 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 1b629a65
package ibase.dashboard.common.hibernate.dao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.text.SimpleDateFormat;
import java.util.Date;
import org.json.JSONException;
import org.json.JSONArray;
import org.json.JSONObject;
import ibase.system.config.ConnDriver;
import ibase.utility.E12GenericUtility;
import ibase.utility.UserInfoBean;
public class CourseDao {
private UserInfoBean userInfo = null;
public UserInfoBean getUserInfo()
{
return this.userInfo;
}
public void setUserInfo(UserInfoBean userInfo)
{
System.out.println("getUserInfo"+userInfo);
this.userInfo = userInfo;
System.out.println("getUserInfo"+userInfo);
}
public JSONArray getAllCourseData()
{
JSONArray jsnArray = new JSONArray();
PreparedStatement pstmt = null;
ResultSet rs = null;
Connection conn =null;
StringBuffer sql=new StringBuffer();
ConnDriver connDriver = new ConnDriver();
try
{
if(conn == null)
{
conn = getConnection();
}
sql.append("SELECT ")
.append(" COURSE_CODE,THEROPETIC_AREA, DESCRIPTION,START_DATE,END_DATE,COURSE_TAG,ATTACHMENT,NO_ATTACHMENTS,TRAN_DATE, NO_QUESTIONS ")
.append(" from SRV_COURSE");
System.out.println("sql["+sql+"]");
pstmt = conn.prepareStatement( sql.toString() );
System.out.println("pstmt["+pstmt+"]");
E12GenericUtility genericUtility = new E12GenericUtility();
String sourceDateFormat=genericUtility.getApplDateFormat();
String targetDateFormat=genericUtility.getDBDateFormat();
rs = pstmt.executeQuery();
System.out.println("rs querry execute ["+rs+"]");
while( rs.next() )
{
JSONObject jsonObject = new JSONObject();
String startDate = checkNull(rs.getString( "START_DATE" ));
String endDate = checkNull(rs.getString( "END_DATE" ));
String tranDate = checkNull(rs.getString( "TRAN_DATE" ));
String attachMent = checkNull(rs.getString( "ATTACHMENT" ));
String courseID = checkNull(rs.getString( "COURSE_CODE" ));
System.out.println("even date for from and to date before"+startDate);
//startDate=genericUtility.getValidDateString(startDate, sourceDateFormat, targetDateFormat);
//endDate=genericUtility.getValidDateString(endDate, sourceDateFormat, targetDateFormat);
//tranDate=genericUtility.getValidDateString(tranDate, sourceDateFormat, targetDateFormat);
jsonObject.put("COURSE_CODE", courseID);
jsonObject.put("THEROPETIC_AREA", checkNull(rs.getString( "THEROPETIC_AREA" )));
jsonObject.put("DESCRIPTION", checkNull(rs.getString( "DESCRIPTION" )));//
jsonObject.put( "START_DATE", startDate );
jsonObject.put( "END_DATE", endDate );
jsonObject.put("COURSE_TAG", checkNull(rs.getString( "COURSE_TAG" )));
jsonObject.put("ATTACHMENT", attachMent);
JSONArray videoList=getCourseVideoPath(attachMent);
JSONArray courseQuestList=getAllQuestions(courseID);
//JSONArray courseInformation = new JSONArray();
/*JSONObject courseInformation = new JSONObject();
courseInformation.put("VIDEO_LIST", videoList);
courseInformation.put("COURSE_QUESTION", courseQuestList);*/
//courseInformation.put(courseDetail);
jsonObject.put("VIDEO_LIST", videoList);
jsonObject.put("COURSE_QUESTION", courseQuestList);
jsonObject.put("NO_ATTACHMENTS", checkNull(rs.getString( "NO_ATTACHMENTS" )));
jsonObject.put("TRAN_DATE", tranDate);
jsonObject.put("NO_QUESTIONS", checkNull(rs.getString( "NO_QUESTIONS" )));
jsnArray.put(jsonObject );
}
System.out.println("getAllCourseData ["+jsnArray+"]");
if (rs!= null)
{
rs.close();
rs = null;
}
if(pstmt!=null)
{
pstmt.close();
pstmt = null;
}
if (conn != null)
{
conn.close();
conn = null;
}
}
catch (Exception e)
{
System.out.println("Exception in EDetailingDao["+e.getMessage()+"]");
}
finally
{
try
{
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(conn != null && ! conn.isClosed() )
{
conn.close();
conn = null;
}
}
catch(Exception e)
{
}
}
return jsnArray;
}
public JSONObject getCourseData(String courseId)
{
JSONObject courseObj = new JSONObject();
PreparedStatement pstmt = null;
ResultSet rs = null;
Connection conn =null;
StringBuffer sql=new StringBuffer();
ConnDriver connDriver = new ConnDriver();
JSONObject jsonObject = new JSONObject();
try
{
if(conn == null)
{
conn = getConnection();
}
sql.append("SELECT ")
.append(" COURSE_CODE,THEROPETIC_AREA, DESCRIPTION,START_DATE,END_DATE,COURSE_TAG,ATTACHMENT,NO_ATTACHMENTS,TRAN_DATE, NO_QUESTIONS ")
.append(" from SRV_COURSE")
.append(" WHERE COURSE_CODE='"+courseId+"'");
System.out.println("sql["+sql+"]");
pstmt = conn.prepareStatement( sql.toString() );
System.out.println("pstmt["+pstmt+"]");
E12GenericUtility genericUtility = new E12GenericUtility();
String sourceDateFormat=genericUtility.getApplDateFormat();
String targetDateFormat=genericUtility.getDBDateFormat();
rs = pstmt.executeQuery();
System.out.println("rs querry execute ["+rs+"]");
while( rs.next() )
{
String startDate = checkNull(rs.getString( "START_DATE" ));
String endDate = checkNull(rs.getString( "END_DATE" ));
String tranDate = checkNull(rs.getString( "TRAN_DATE" ));
String attachMent = checkNull(rs.getString( "ATTACHMENT" ));
courseId = checkNull(rs.getString( "COURSE_CODE" ));
System.out.println("even date for from and to date before"+startDate+attachMent);
//startDate=genericUtility.getValidDateString(startDate, sourceDateFormat, targetDateFormat);
//endDate=genericUtility.getValidDateString(endDate, sourceDateFormat, targetDateFormat);
//tranDate=genericUtility.getValidDateString(tranDate, sourceDateFormat, targetDateFormat);
jsonObject.put("COURSE_CODE", courseId);
jsonObject.put("THEROPETIC_AREA", checkNull(rs.getString( "THEROPETIC_AREA" )));
jsonObject.put("DESCRIPTION", checkNull(rs.getString( "DESCRIPTION" )));//
jsonObject.put( "START_DATE", startDate );
jsonObject.put( "END_DATE", endDate );
jsonObject.put("COURSE_TAG", checkNull(rs.getString( "COURSE_TAG" )));
jsonObject.put("ATTACHMENT", attachMent);
JSONArray videoList=getCourseVideoPath(attachMent);
JSONArray courseQuestList=getAllQuestions(courseId);
//JSONArray courseInformation = new JSONArray();
/*JSONObject courseInformation = new JSONObject();
courseInformation.put("VIDEO_LIST", videoList);
courseInformation.put("COURSE_QUESTION", courseQuestList);*/
//courseInformation.put(courseDetail);
//jsonObject.put("COURSE_INFORMATION", courseInformation);
jsonObject.put("VIDEO_LIST", videoList);
jsonObject.put("COURSE_QUESTION", courseQuestList);
/*JSONArray videoList=getCourseVideoPath(attachMent);
jsonObject.put("VIDEO_LIST", videoList);*/
jsonObject.put("NO_ATTACHMENTS", checkNull(rs.getString( "NO_ATTACHMENTS" )));
jsonObject.put("TRAN_DATE", tranDate);
jsonObject.put("NO_QUESTIONS", checkNull(rs.getString( "NO_QUESTIONS" )));
}
System.out.println(" getCourseData ["+jsonObject+"]");
if (rs!= null)
{
rs.close();
rs = null;
}
if(pstmt!=null)
{
pstmt.close();
pstmt = null;
}
if (conn != null)
{
conn.close();
conn = null;
}
}
catch (Exception e)
{
System.out.println("Exception in EDetailingDao["+e.getMessage()+"]");
}
finally
{
try
{
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(conn != null && ! conn.isClosed() )
{
conn.close();
conn = null;
}
}
catch(Exception e)
{
}
}
return jsonObject;
}
public JSONArray getAllQuestions(String courseId) {
JSONArray jsnArray = new JSONArray();
PreparedStatement pstmt = null;
ResultSet rs = null;
Connection conn =null;
StringBuffer sql=new StringBuffer();
ConnDriver connDriver = new ConnDriver();
try
{
if(conn == null)
{
conn = getConnection();
}
sql.append("select COURSE_CODE,LINE_NO,QUESTION,OPTION_A,OPTION_B,OPTION_C,OPTION_D,MULTI_OPT,ANSWER ")
.append(" from SRV_COURSE_DET ")
.append(" where COURSE_CODE='"+courseId+"'");
System.out.println("sql["+sql+"]");
pstmt = conn.prepareStatement( sql.toString() );
System.out.println("pstmt["+pstmt+"]");
rs = pstmt.executeQuery();
System.out.println("rs querry execute ["+rs+"]");
int count = 1;
while( rs.next() )
{
JSONObject jsonObject = new JSONObject();
jsonObject.put("COURSE_CODE", checkNull(rs.getString( "COURSE_CODE" )));
jsonObject.put("LINE_NO", rs.getInt("LINE_NO"));
jsonObject.put("QUEST_NO", count);
jsonObject.put("QUESTION", checkNull(rs.getString( "QUESTION" )));//
jsonObject.put("MULTI_OPT", checkNull(rs.getString( "MULTI_OPT" )));
/*jsonObject.put("OPTION_A", checkNull(rs.getString( "OPTION_A" )));
jsonObject.put("OPTION_B", checkNull(rs.getString( "OPTION_B" )));
jsonObject.put("OPTION_C", checkNull(rs.getString( "OPTION_C" )));
jsonObject.put("OPTION_D", checkNull(rs.getString( "OPTION_D" )));*/
JSONArray options = new JSONArray();
options.put(rs.getString( "OPTION_A" ));
options.put(rs.getString( "OPTION_B" ));
options.put(rs.getString( "OPTION_C" ));
options.put(rs.getString( "OPTION_D" ));
jsonObject.put("OPTIONS",options);
jsonObject.put("ANSWER", checkNull(rs.getString( "ANSWER" )));
jsonObject.put("SELECTED_ANS", "");
jsnArray.put(jsonObject );
count++;
}
System.out.println("getAllQuestions ["+jsnArray+"]");
if (rs!= null)
{
rs.close();
rs = null;
}
if(pstmt!=null)
{
pstmt.close();
pstmt = null;
}
if (conn != null)
{
conn.close();
conn = null;
}
}
catch (Exception e)
{
System.out.println("Exception in EDetailingDao["+e.getMessage()+"]");
}
finally
{
try
{
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(conn != null && ! conn.isClosed() )
{
conn.close();
conn = null;
}
}
catch(Exception e)
{
}
}
return jsnArray;
}
public JSONObject getQuestionData(String courseId, String questionId) {
PreparedStatement pstmt = null;
ResultSet rs = null;
Connection conn =null;
StringBuffer sql=new StringBuffer();
ConnDriver connDriver = new ConnDriver();
JSONObject jsonObject = new JSONObject();
try
{
if(conn == null)
{
conn = getConnection();
}
sql.append("select COURSE_CODE,LINE_NO,QUESTION,OPTION_A,OPTION_B,OPTION_C,OPTION_D,MULTI_OPT,ANSWER")
.append(" from SRV_COURSE_DET ")
.append(" where COURSE_CODE='"+courseId+"'")
.append(" AND QUESTION='"+questionId+"'");
System.out.println("sql["+sql+"]");
pstmt = conn.prepareStatement( sql.toString() );
System.out.println("pstmt["+pstmt+"]");
rs = pstmt.executeQuery();
System.out.println("rs querry execute ["+rs+"]");
int count = 1;
while( rs.next() )
{
jsonObject.put("COURSE_CODE", checkNull(rs.getString( "COURSE_CODE" )));
jsonObject.put("LINE_NO", rs.getInt("LINE_NO"));
jsonObject.put("QUEST_NO", count);
jsonObject.put("QUESTION", checkNull(rs.getString( "QUESTION" )));
jsonObject.put("MULTI_OPT", checkNull(rs.getString( "MULTI_OPT" )));
/*jsonObject.put("OPTION_A", checkNull(rs.getString( "OPTION_A" )));
jsonObject.put("OPTION_B", checkNull(rs.getString( "OPTION_B" )));
jsonObject.put("OPTION_C", checkNull(rs.getString( "OPTION_C" )));
jsonObject.put("OPTION_D", checkNull(rs.getString( "OPTION_D" )));*/
JSONArray options = new JSONArray();
options.put(rs.getString( "OPTION_A" ));
options.put(rs.getString( "OPTION_B" ));
options.put(rs.getString( "OPTION_C" ));
options.put(rs.getString( "OPTION_D" ));
jsonObject.put("OPTIONS",options);
//jsonObject.put("ANSWER", checkNull(rs.getString( "ANSWER" )));
jsonObject.put("SELECTED_ANS", "");
count++;
}
System.out.println("getQuestionData ["+jsonObject+"]");
if (rs!= null)
{
rs.close();
rs = null;
}
if(pstmt!=null)
{
pstmt.close();
pstmt = null;
}
if (conn != null)
{
conn.close();
conn = null;
}
}
catch (Exception e)
{
System.out.println("Exception in EDetailingDao["+e.getMessage()+"]");
}
finally
{
try
{
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(conn != null && ! conn.isClosed() )
{
conn.close();
conn = null;
}
}
catch(Exception e)
{
}
}
return jsonObject;
}
public JSONArray getCourseVideoPath(String attachMentId) {
PreparedStatement pstmt = null;
ResultSet rs = null;
Connection conn =null;
StringBuffer sql=new StringBuffer();
ConnDriver connDriver = new ConnDriver();
String docId="";
JSONArray jsnArray = new JSONArray();
try
{
if(conn == null)
{
conn = getConnection();
}
sql.append("SELECT DOC_ID FROM doc_transaction_link WHERE ref_id='"+attachMentId+"'")
.append(" AND ref_ser='COURSE' ");
System.out.println("sql["+sql+"]");
pstmt = conn.prepareStatement( sql.toString() );
System.out.println("pstmt["+pstmt+"]");
rs = pstmt.executeQuery();
System.out.println("rs querry execute ["+rs+"]");
while( rs.next() )
{
JSONObject jsonObject = new JSONObject();
docId = checkNull(rs.getString( "DOC_ID" ));
jsonObject.put("DOC_ID",docId);
jsonObject.put("VIDEO_PATH", "/ibase/WebITMDocumentHandlerServlet?ACTION=GET_DOCUMENT&DOC_ID="+docId+"&DOC_TYPE=mp4");
jsonObject.put("IMAGE_PATH", "/ibase/DocumentViewerServlet?ACTION=GET_PREVIEW_IMAGE&DOC_ID="+docId+"&ENTERPRISE=Driver");
jsonObject.put("FILE_TYPE", "mp4");
jsonObject.put("TIME", "");
jsonObject.put("PERCENTAGE", "0");
jsnArray.put(jsonObject);
}
System.out.println("getQuestionData ["+jsnArray+"]");
if (rs!= null)
{
rs.close();
rs = null;
}
if(pstmt!=null)
{
pstmt.close();
pstmt = null;
}
if (conn != null)
{
conn.close();
conn = null;
}
}
catch (Exception e)
{
System.out.println("Exception in EDetailingDao["+e.getMessage()+"]");
}
finally
{
try
{
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(conn != null && ! conn.isClosed() )
{
conn.close();
conn = null;
}
}
catch(Exception e)
{
}
}
return jsnArray;
}
public Connection getConnection()
{
Connection conn = null;
ConnDriver connDriver = new ConnDriver();
try
{
System.out.println(" In StrgMeetwizardBean :: getConnection() :: ["+this.userInfo+"]");
if(this.userInfo != null)
{
String transDB = this.userInfo.getTransDB();
System.out.println(" StrgMeetwizardBean getConnection :: transDB :: ["+transDB+"]");
if( transDB != null && transDB.trim().length() > 0 && !"null".equalsIgnoreCase(transDB))
{
conn = connDriver.getConnectDB(transDB);
connDriver = null;
System.out.println(" StrgMeetwizardBean getConnection :: transDB :: on if condition :["+transDB+"]");
}
else
{
System.out.println(" StrgMeetwizardBean :: transDB is null :: So that creating connection using DriverITM....");
conn = connDriver.getConnectDB("DriverITM");
connDriver = null;
}
}
else
{
System.out.println(" StrgMeetwizardBean :: UserInfo is null :: So that creating connection using DriverITM....");
conn = connDriver.getConnectDB("DriverITM");
connDriver = null;
}
}
catch(Exception e)
{
System.out.println("Exception : [StrgMeetwizardBean][getConnection] :==>\n"+e.getMessage());
e.printStackTrace();
}
return conn;
}
public String checkNull(String input)
{
if (input == null || "null".equalsIgnoreCase(input))
{
input= "";
}
return input.trim();
}
}
package ibase.dashboard.common.webService;
import java.text.SimpleDateFormat;
import javax.servlet.ServletContext;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.Produces;
import javax.ws.rs.QueryParam;
import javax.ws.rs.core.Context;
import javax.ws.rs.core.MediaType;
import org.json.JSONArray;
import org.json.JSONObject;
import ibase.dashboard.common.hibernate.dao.CourseDao;
import ibase.hibernate.bean.UserDocContent;
import ibase.utility.BaseException;
import ibase.utility.E12GenericUtility;
import ibase.utility.UserInfoBean;
@Path("/api")
public class CoursService {
@Context
HttpServletRequest request; // The proxy of Request will be injected into this singleton
@GET
@Path("/course/all")
@Produces(MediaType.APPLICATION_JSON)
public String getAllCoursesInfo() throws Exception
{
HttpSession session = request.getSession();
String sessionId=request.getSession().getId() ;
JSONArray jsnArray = new JSONArray();
ibase.utility.UserInfoBean userInfo = ( ibase.utility.UserInfoBean )session.getAttribute( "USER_INFO" );
try
{
if(userInfo != null ) {
System.out.println("get all course info ");
CourseDao courseDao = new CourseDao();
jsnArray=courseDao.getAllCourseData();
}
}
catch (Exception e)
{
System.out.println("Inside getAllCourseInfo :::"+e);
}
return jsnArray.toString();
}
@GET
@Path("/course/{courseId}")
@Produces(MediaType.APPLICATION_JSON)
public String getCourseInfo(@PathParam("courseId") String courseId ) throws Exception
{
HttpSession session = request.getSession();
String sessionId=request.getSession().getId() ;
JSONObject courseData = new JSONObject();
ibase.utility.UserInfoBean userInfo = ( ibase.utility.UserInfoBean )session.getAttribute( "USER_INFO" );
try
{
if(userInfo != null ) {
System.out.println("get getCourseInfo "+courseId);
CourseDao courseDao = new CourseDao();
courseData=courseDao.getCourseData(courseId);
}
}
catch (Exception e)
{
System.out.println("Inside getAllCourseInfo :::"+e);
}
return courseData.toString();
}
@GET
@Path("/course/question/{courseId}/all")
@Produces(MediaType.APPLICATION_JSON)
public String getAllQuestions(@PathParam("courseId") String courseId ) throws Exception
{
HttpSession session = request.getSession();
String sessionId=request.getSession().getId() ;
JSONArray questionData = new JSONArray();
ibase.utility.UserInfoBean userInfo = ( ibase.utility.UserInfoBean )session.getAttribute( "USER_INFO" );
try
{
if(userInfo != null ) {
System.out.println("get getCourseInfo "+courseId);
CourseDao courseDao = new CourseDao();
questionData=courseDao.getAllQuestions(courseId);
}
}
catch (Exception e)
{
System.out.println("Inside getAllQuestions :::"+e);
}
return questionData.toString();
}
@GET
@Path("/course/question/{courseId}/{questionId}")
@Produces(MediaType.APPLICATION_JSON)
public String getQuestionData(@PathParam("courseId") String courseId ,@PathParam("questionId") String questionId ) throws Exception
{
HttpSession session = request.getSession();
String sessionId=request.getSession().getId() ;
JSONObject courseData = new JSONObject();
ibase.utility.UserInfoBean userInfo = ( ibase.utility.UserInfoBean )session.getAttribute( "USER_INFO" );
try
{
if(userInfo != null ) {
System.out.println("get getCourseInfo "+courseId);
CourseDao courseDao = new CourseDao();
courseData=courseDao.getQuestionData(courseId,questionId);
}
}
catch (Exception e)
{
System.out.println("Inside getQuestionData :::"+e);
}
return courseData.toString();
}
private UserInfoBean getUserInfo()
{
UserInfoBean userInfo = null;
HttpSession session = request.getSession();
Object userObj = session.getAttribute( "USER_INFO" );
System.out.println(" CustomerInfoService getUserInfo userObj >>[" + userObj + "]" );
if(userObj != null)
{
try
{
userInfo = new UserInfoBean( userObj.toString() );
}
catch (BaseException e)
{
e.printStackTrace();
}
}
return userInfo;
}
}
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