学生信息管理系统.zip

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.Clazz; import com.lizhou.bean.Course; import com.lizhou.bean.CourseItem; import com.lizhou.bean.Grade; 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.StudentDaoImpl; import com.lizhou.dao.impl.TeacherDaoImpl; import com.lizhou.dao.inter.BaseDaoInter; 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 TeacherService { private TeacherDaoInter dao; public TeacherService(){ dao = new TeacherDaoImpl(); } /** * 获取教师信息 * @param page * @param rows * @return */ public String getTeacherList(Page page) { //sql语句 String sql = "SELECT * FROM teacher ORDER BY id DESC LIMIT ?,?"; //获取数据 List<Teacher> list = dao.getTeacherList(sql, new Object[]{page.getStart(), page.getSize()}, null, null); //获取总记录数 long total = dao.count("SELECT COUNT(*) FROM teacher", new Object[]{}); //定义Map Map<String, Object> jsonMap = new HashMap<String, Object>(); //total键 存放总记录数，必须的 jsonMap.put("total", total); //rows键 存放每页记录 list jsonMap.put("rows", list); //格式化Map,以json格式返回数据 String result = JSONObject.fromObject(jsonMap).toString(); //返回 return result; } /** * 获取某个老师的具体信息：包括所选课程 * @param number * @return */ public Teacher getTeacher(String number) { //sql语句 String sql = "SELECT * FROM teacher WHERE number=?"; //获取数据 List<Teacher> list = dao.getTeacherList(sql, new Object[]{number}, null, null); //返回 return list.get(0); } /** * 获取某年级下老师的班级 * @param number * @param grade * @return */ public String getExamClazz(String number, Grade grade) { //sql语句 String sql = "SELECT * FROM teacher WHERE number=?"; //获取数据 Teacher list = dao.getTeacherList(sql, new Object[]{number}, grade, null).get(0); List<Clazz> clazzList = new LinkedList<>(); List<CourseItem> courseItem = list.getCourseList(); for(CourseItem item : courseItem){ boolean flag = true; for(Clazz clazz : clazzList){ if(clazz.getId() == item.getClazzid()){ flag = false; break; } } if(flag){ clazzList.add(item.getClazz()); } } String result = JSONArray.fromObject(clazzList).toString(); //返回 return result; } /** * 查询考试下老师的课程 * @param number * @param grade * @param clazz * @return */ public String getExamClazz(String number, Grade grade, Clazz clazz) { //sql语句 String sql = "SELECT * FROM teacher WHERE number=?"; //获取数据 Teacher list = dao.getTeacherList(sql, new Object[]{number}, grade, clazz).get(0); List<Course> courseList = new LinkedList<>(); List<CourseItem> courseItem = list.getCourseList(); for(CourseItem item : courseItem){ courseList.add(item.getCourse()); } String result = JSONArray.fromObject(courseList).toString(); //返回 return result; } /** * 获取老师详细信息 * @param number * @return */ public String getTeacherResult(String number) { Teacher teacher = getTeacher(number); String result = JSONObject.fromObject(teacher).toString(); //返回 return result; } /** * 添加老师信息 * @param teacher * @throws Exception */ public void addTeacher(Teacher teacher) throws Exception { Connection conn = MysqlTool.getConnection(); try { //开启事务 MysqlTool.startTransaction(); String sql = "INSERT INTO teacher(number, name, sex, qq, photo) value(?,?,?,?,?)"; Object[] param = new Object[]{ teacher.getNumber(), teacher.getName(), teacher.getSex(), teacher.getPhone(), teacher.getQq() }; //添加教师信息 int teacherid = dao.insertReturnKeysTransaction(conn, sql, param); //设置课程 if(teacher.getCourse() != null && teacher.getCourse().length > 0){ for(String course : teacher.getCourse()){ String[] gcc = course.split("_"); int gradeid = Integer.parseInt(gcc[0]); int clazzid = Integer.parseInt(gcc[1]); int courseid = Integer.parseInt(gcc[2]); dao.insertTransaction(conn, "INSERT INTO clazz_course_teacher(clazzid, gradeid, courseid, teacherid) value(?,?,?,?) ", new Object[]{clazzid, gradeid, courseid, teacherid}); } } //添加用户记录 dao.insertTransaction(conn, "INSERT INTO user(account, name, type) value(?,?,?)", new Object[]{ teacher.getNumber(), teacher.getName(), User.USER_TEACHER }); //提交事务 MysqlTool.commit(); } catch (Exception e) { //回滚事务 MysqlTool.rollback(); e.printStackTrace(); throw e; } finally { MysqlTool.closeConnection(); } } /** * 修改教师信息 * @param teacher * @throws Exception */ public void editTeacher(Teacher teacher) throws Exception { Connection conn = MysqlTool.getConnection(); try { //开启事务 MysqlTool.startTransaction(); String sql = "UPDATE teacher set name=?,sex=?,phone=?,qq=? WHERE id=?"; Object[] param = new Object[]{ teacher.getName(), teacher.getSex(), teacher.getPhone(), teacher.getQq(), teacher.getId() }; //修改教师信息 dao.updateTransaction(conn, sql, param); //修改系统用户信息 dao.update("UPDATE user SET name=? WHERE account=?", new Object[]{teacher.getName(), teacher.getNumber()}); //删除教师与课程的关联 dao.deleteTransaction(conn, "DELETE FROM clazz_course_teacher WHERE teacherid =?", new Object[]{teacher.getId()}); //设置课程 if(teacher.getCourse() != null && teacher.getCourse().length > 0){ for(String course : teacher.getCourse()){ String[] gcc = course.split("_"); int gradeid = Integer.parseInt(gcc[0]); int clazzid = Integer.parseInt(gcc[1]); int courseid = Integer.parseInt(gcc[2]); dao.insertTransaction(conn, "INSERT INTO clazz_course_teacher(clazzid, gradeid, courseid, teacherid) value(?,?,?,?) ", new Object[]{clazzid, gradeid, courseid, teacher.getId()}); } } //提交事务 MysqlTool.commit(); } catch (Exception e) { //回滚事务 MysqlTool.rollback(); e.printStackTrace(); throw e; } finally { MysqlTool.closeConnection(); } } /** * 教师修改个人信息 * @param teacher */ public void editTeacherPersonal(Teacher teacher){ String sql = "UPDATE teacher SET name=?, sex=?, phone=?, qq=? WHERE number=?"; //更新信息 dao.update(sql, new Object[]{ teacher.getName(), teacher.getSex(), teacher.getPhone(), teacher.getQq(), teacher.getNumber()}); dao.update("UPDATE user SET name=? WHERE account=?", new Object[]{teacher.getName(), teacher.getNumber()}); } /** * 删除教师 * @param ids 教师ID数组 * @param numbers 教师工号数组 * @throws Exception */ public void deleteTeacher(String[] ids, String[] numbers) throws Exception{ //获取占位符 String mark = StringTool.getMark(ids.length); Integer tid[] = new Integer[ids.length]; for(int i =0 ;i < ids.length;i++){ tid[i] = Integer.parseInt(ids[i]); } //获取连接 Connection conn = MysqlTool.getConnection(); //开启事务 MysqlTool.startTransaction(); try { //删除教师与课程的关联 dao.deleteTransaction(conn, "DELETE FROM c