From daab257f14b5453f0690f8098b99c7b0e35ffd6d Mon Sep 17 00:00:00 2001 From: jiandan Date: Tue, 14 Apr 2026 17:04:47 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AD=A6=E7=94=9F=E6=88=90=E7=BB=A9=E7=AE=A1?= =?UTF-8?q?=E7=90=86=E7=B3=BB=E7=BB=9F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/com/lizhou/service/ExamService.java | 307 ++++++++++++++++++++++++ 1 file changed, 307 insertions(+) create mode 100644 src/com/lizhou/service/ExamService.java diff --git a/src/com/lizhou/service/ExamService.java b/src/com/lizhou/service/ExamService.java new file mode 100644 index 0000000..11ea5ff --- /dev/null +++ b/src/com/lizhou/service/ExamService.java @@ -0,0 +1,307 @@ +package com.lizhou.service; + +import java.sql.Connection; +import java.util.HashMap; +import java.util.LinkedList; +import java.util.List; +import java.util.Map; + +import com.lizhou.bean.Course; +import com.lizhou.bean.CourseItem; +import com.lizhou.bean.Exam; +import com.lizhou.bean.Page; +import com.lizhou.bean.Student; +import com.lizhou.bean.Teacher; +import com.lizhou.bean.User; +import com.lizhou.dao.impl.BaseDaoImpl; +import com.lizhou.dao.impl.ExamDaoImpl; +import com.lizhou.dao.impl.StudentDaoImpl; +import com.lizhou.dao.impl.TeacherDaoImpl; +import com.lizhou.dao.inter.BaseDaoInter; +import com.lizhou.dao.inter.ExamDaoInter; +import com.lizhou.dao.inter.StudentDaoInter; +import com.lizhou.dao.inter.TeacherDaoInter; +import com.lizhou.tools.MysqlTool; +import com.lizhou.tools.StringTool; + +import net.sf.json.JSONArray; +import net.sf.json.JSONObject; + +/** + * 教师类服务层 + * @author bojiangzhou + * + */ +public class ExamService { + + private ExamDaoInter dao; + + public ExamService(){ + dao = new ExamDaoImpl(); + } + + /** + * 获取考试信息 + * @param exam 参数 + * @param page 分页 + * @return + */ + public String getExamList(Exam exam, Page page) { + //sql语句 + StringBuffer sb = new StringBuffer("SELECT * FROM exam "); + //参数 + List param = new LinkedList<>(); + //判断条件 + if(exam != null){ + if(exam.getGradeid() != 0){//条件：年级 + int gradeid = exam.getGradeid(); + param.add(gradeid); + sb.append("AND gradeid=? "); + } + if(exam.getClazzid() != 0){ + int clazzid = exam.getClazzid(); + param.add(clazzid); + sb.append("AND clazzid=? "); + } + } + //添加排序 + sb.append("ORDER BY id DESC "); + //分页 + if(page != null){ + param.add(page.getStart()); + param.add(page.getSize()); + sb.append("LIMIT ?,?"); + } + String sql = sb.toString().replaceFirst("AND", "WHERE"); + //获取数据 + List list = dao.getExamList(sql, param); + //获取总记录数 + long total = getCount(exam); + //定义Map + Map jsonMap = new HashMap(); + //total键 存放总记录数，必须的 + jsonMap.put("total", total); + //rows键 存放每页记录 list + jsonMap.put("rows", list); + //格式化Map,以json格式返回数据 + String result = JSONObject.fromObject(jsonMap).toString(); + //返回 + return result; + } + + /** + * 获取记录数 + * @param exam + * @return + */ + private long getCount(Exam exam){ + //sql语句 + StringBuffer sb = new StringBuffer("SELECT COUNT(*) FROM exam "); + //参数 + List param = new LinkedList<>(); + //判断条件 + if(exam != null){ + if(exam.getGrade() != null){//条件：年级 + int gradeid = exam.getGradeid(); + param.add(gradeid); + sb.append("AND gradeid=? "); + } + if(exam.getClazz() != null){ + int clazzid = exam.getClazzid(); + param.add(clazzid); + sb.append("AND clazzid=? "); + } + } + String sql = sb.toString().replaceFirst("AND", "WHERE"); + + long count = dao.count(sql, param).intValue(); + + return count; + } + + /** + * 添加考试 + * @param exam + * @throws Exception + */ + public void addExam(Exam exam) throws Exception { + Connection conn = MysqlTool.getConnection(); + try { + //开启事务 + MysqlTool.startTransaction(); + + //添加考试信息 + int examid = dao.insertReturnKeysTransaction(conn, + "INSERT INTO exam(name, time, remark, type, gradeid, clazzid, courseid) value(?,?,?,?,?,?,?)", + new Object[]{ + exam.getName(), + exam.getTime(), + exam.getRemark(), + exam.getType(), + exam.getGradeid(), + exam.getClazzid(), + exam.getCourseid() + }); + + //添加学生成绩表 + String sql = "INSERT INTO escore(examid,clazzid,studentid,gradeid,courseid) value(?,?,?,?,?)"; + + if(exam.getType() == Exam.EXAM_GRADE_TYPE){ //年级统考 + + //查询该年级的课程 + List couObjList = dao.getList(Course.class, + "SELECT courseid id FROM grade_course WHERE gradeid=?", + new Object[]{exam.getGradeid()}); + + //查询该年级下的学生 + List stuList = dao.getList(Student.class, + "SELECT id, clazzid FROM student WHERE gradeid=?", + new Object[]{exam.getGradeid()}); + + //转换类型 + List couList = new LinkedList<>(); + for(Object obj : couObjList){ + Course course = (Course) obj; + couList.add(course); + } + //批量参数 + Object[][] param = new Object[stuList.size()*couList.size()][5]; + int index = 0; + for(int i = 0;i < stuList.size();i++){ + Student student = (Student) stuList.get(i); + for(int j = 0;j < couList.size();j++){ + param[index][0] = examid; + param[index][1] = student.getClazzid(); + param[index][2] = student.getId(); + param[index][3] = exam.getGradeid(); + param[index][4] = couList.get(j).getId(); + + index++; + } + } + //批量添加学生考试表 + dao.insertBatchTransaction(conn, sql, param); + + } else{ //平时考试 + + //查询该班级下的学生 + List stuList = dao.getList(Student.class, + "SELECT id FROM student WHERE clazzid=?", + new Object[]{exam.getClazzid()}); + + //批量参数 + Object[][] param = new Object[stuList.size()][5]; + for(int i = 0;i < stuList.size();i++){ + Student student = (Student) stuList.get(i); + param[i][0] = examid; + param[i][1] = exam.getClazzid(); + param[i][2] = student.getId(); + param[i][3] = exam.getGradeid(); + param[i][4] = exam.getCourseid(); + } + //批量添加学生考试表 + dao.insertBatchTransaction(conn, sql, param); + } + + //提交事务 + MysqlTool.commit(); + } catch (Exception e) { + //回滚事务 + MysqlTool.rollback(); + e.printStackTrace(); + throw e; + } finally { + MysqlTool.closeConnection(); + } + } + + /** + * 删除考试 + * @param ids + * @throws Exception + */ + public void deleteExam(int id) throws Exception{ + //获取连接 + Connection conn = MysqlTool.getConnection(); + //开启事务 + MysqlTool.startTransaction(); + try { + //删除成绩表 + dao.deleteTransaction(conn, "DELETE FROM escore WHERE examid=?", new Object[]{id}); + //删除考试 + dao.deleteTransaction(conn, "DELETE FROM exam WHERE id =?", new Object[]{id}); + + //提交事务 + MysqlTool.commit(); + } catch (Exception e) { + //回滚事务 + MysqlTool.rollback(); + e.printStackTrace(); + throw e; + } finally { + MysqlTool.closeConnection(); + } + } + + /** + * 获取某老师的考试 + * @param id + * @return + */ + public String teacherExamList(String number) { + //获取教师信息 + Teacher teacher = new TeacherService().getTeacher(number); + + List itemList = teacher.getCourseList(); + if(itemList.size() == 0){ + return ""; + } + StringBuffer g = new StringBuffer(); + StringBuffer c = new StringBuffer(); + for(CourseItem item : itemList){ + g.append(","+item.getGradeid()); + c.append(","+item.getCourseid()); + } + + StringBuffer sb = new StringBuffer("SELECT * FROM exam WHERE (gradeid IN ("); + sb.append(g.toString().replaceFirst(",", "")); + sb.append(") AND type=1) OR (courseid IN ("); + sb.append(c.toString().replaceFirst(",", "")); + sb.append(") AND type=2)"); + //sql语句 + String sql = sb.toString(); + //获取数据 + List list = dao.getExamList(sql, null); + + //格式化Map,以json格式返回数据 + String result = JSONArray.fromObject(list).toString(); + //返回 + return result; + } + + /** + * 获取某个学生考试列表 + * @param number + * @return + */ + public String studentExamList(String number) { + + //获取学生详细信息 + Student student = new StudentDaoImpl().getStudentList("SELECT * FROM student WHERE number="+number, null).get(0); + + String sql = "SELECT * FROM exam WHERE (gradeid=? AND type=1) OR (clazzid=? AND type=2)"; + + List param = new LinkedList<>(); + param.add(student.getGradeid()); + param.add(student.getClazzid()); + + //获取数据 + List list = dao.getExamList(sql, param); + + //格式化Map,以json格式返回数据 + String result = JSONArray.fromObject(list).toString(); + + return result; + } + +}