增加在考试表中查询课程的代码

exam-work-api/src/main/java/cn/com/qmth/examcloud/service/examwork/api/ExamStudentApi.java

@@ -1,5 +1,6 @@
 package cn.com.qmth.examcloud.service.examwork.api;
 
+import cn.com.qmth.examcloud.common.dto.core.Course;
 import cn.com.qmth.examcloud.common.uac.entity.AccessUser;
 import cn.com.qmth.examcloud.service.examwork.dao.ExamRepo;
 import cn.com.qmth.examcloud.service.examwork.entity.Exam;
@@ -345,4 +346,16 @@ public class ExamStudentApi {
             return new ResponseEntity(new ErrorMsg(e.getMessage()), HttpStatus.INTERNAL_SERVER_ERROR);
         }
     }
+    
+    @ApiOperation(value = "从考试表中查询课程", notes = "从考试表中查询课程")
+    @GetMapping("/findCoursesFromExamStudent")
+    public ResponseEntity<Object> findCoursesFromExamStudent(String examId,String orgId){
+    	try{
+    		List<Course> courses = examStudentService.findCoursesFromExamStudent(examId, orgId);
+    		return new ResponseEntity<Object>(courses,HttpStatus.OK);
+    	} catch (Exception e) {
+            e.printStackTrace();
+            return new ResponseEntity(new ErrorMsg(e.getMessage()), HttpStatus.INTERNAL_SERVER_ERROR);
+        }
+    }
 }

exam-work-api/src/main/java/cn/com/qmth/examcloud/service/examwork/service/ExamStudentService.java

@@ -572,4 +572,43 @@ public class ExamStudentService {
 			}
 		});
 	}
+	
+	/**
+	 * 根据考试和学习中心查询课程
+	 * @param examId
+	 * @param orgId
+	 * @return
+	 */
+	public List<Course> findCoursesFromExamStudent(String examId,String orgId){
+		List<Object> paramsList = new ArrayList<Object>();
+		if(StringUtils.isEmpty(examId)){
+			return null;
+		}
+		StringBuilder sql = new StringBuilder();
+		paramsList.add(examId);
+		sql.append("SELECT t.course_code course_code,"
+						+ "t.course_level course_level,"
+						+ "t.course_name course_name "+
+				   " FROM ecs_exam_student t  "+
+				   " where  t.exam_id = ? ");
+				   
+		if(!StringUtils.isEmpty(orgId)){
+			sql.append(" and t.org_id = ? ");
+			paramsList.add(orgId);
+		}
+		sql.append(" group by course_code");
+		Object[] params = new Object[paramsList.size()];
+		for(int i = 0;i<paramsList.size();i++){
+			params[i] = paramsList.get(i);
+		}
+		return jdbcTemplate.query(sql.toString(),params,new RowMapper<Course>(){
+			@Override
+			public Course mapRow(ResultSet resultSet, int rowNum) throws SQLException {
+				Course course = new Course();
+				course.setCode(resultSet.getString("course_code"));
+				course.setName(resultSet.getString("course_name"));
+				return course;
+			}
+		});
+	}
 }