package com.qxueyou.scc.teach.student.service.impl; import java.time.LocalDateTime; import java.util.*; import java.util.stream.Collectors; import cn.hutool.core.date.LocalDateTimeUtil; import cn.hutool.core.util.RandomUtil; import com.qxueyou.scc.admin.classes.model.ClsClass; import com.qxueyou.scc.base.dao.CommonDAO; import com.qxueyou.scc.exam.model.ExamResultV; import com.qxueyou.scc.exercise.model.ExerciseCompleteInfo; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.qxueyou.scc.admin.classes.service.IClassService; import com.qxueyou.scc.admin.progress.model.view.QSubjectProgressTreeV; import com.qxueyou.scc.admin.progress.model.view.SubjectProgressTreeV; import com.qxueyou.scc.base.model.Pager; import com.qxueyou.scc.base.model.Result; import com.qxueyou.scc.base.service.impl.CommonAppService; import com.qxueyou.scc.base.util.ClientUtils; import com.qxueyou.scc.base.util.CollectionUtils; import com.qxueyou.scc.base.util.TraceUtils; import com.qxueyou.scc.teach.student.dao.StudentDAO; import com.qxueyou.scc.teach.student.model.QStuStudent; import com.qxueyou.scc.teach.student.model.StuStudent; import com.qxueyou.scc.teach.student.service.IStudentService; import com.qxueyou.scc.teach.subject.service.ISubjectService; import com.qxueyou.scc.user.model.QUser; import com.qxueyou.scc.user.model.User; import com.qxueyou.scc.user.service.IUserService; import org.springframework.util.DigestUtils; @Service public class StudentService extends CommonAppService implements IStudentService { @Autowired IClassService clsService; @Autowired IUserService userService; @Autowired ISubjectService subjectService; @Autowired StudentDAO dao; @Autowired CommonDAO commonDAO; @Override public Result insertStudent(String classId, String name, String studentNo, boolean sex, String phoneNo, String orgId) { if (dao.exists(studentNo, orgId)) { return new Result(false, "学号已存在"); } User user = userService.insertUser(name, studentNo, phoneNo, "000000", sex, orgId); //ClsClass cls = clsService.read(classId); StuStudent student = new StuStudent(); TraceUtils.setCreateTrace(student); student.setStatus(StuStudent.STATUS_ACTIVE); student.setClassId(classId); //student.setSubjectId(cls.getSubjects().get(0).getSubjectId()); student.setName(name); student.setStudentNo(studentNo); student.setSex(sex); student.setUserId(user.getUserId()); student.setMobilePhone(phoneNo); if(StringUtils.isNoneBlank(classId)) { bulkUpdate("update ClsClass set studentCount = studentCount + 1 where deleteFlag is false and classId = ?", new Object[]{classId}); } save(student); return new Result(true, "success", CollectionUtils.newStringMap("studentId", student.getStudentId(), "password", user.getPassword())); } @Override public Result insertStudent(String classId, String name, String studentNo, boolean sex, String phoneNo, String orgId, String comName, String photo, String passporName, String nationality, String ancestralHome, String birthday, String birthplace, String chinaStatus, String registeredAddress, String homeAddress, String religiousBelief, String email, String workUnit) { if (dao.exists(studentNo, orgId)) { return new Result(false, "身份证已存在"); } User user = userService.insertUser(name, studentNo, phoneNo, "000000", sex, orgId); //ClsClass cls = clsService.read(classId); StuStudent student = new StuStudent(); TraceUtils.setCreateTrace(student); String currentTime = LocalDateTimeUtil.format(LocalDateTime.now(), "yyMMddHHmmssSSS"); String examCardNo = currentTime.concat(RandomUtil.randomNumbers(1)); student.setStudentNumber(examCardNo); student.setStatus(StuStudent.STATUS_ACTIVE); student.setClassId(classId); //student.setSubjectId(cls.getSubjects().get(0).getSubjectId()); student.setName(name); student.setStudentNo(studentNo); student.setSex(sex); student.setUserId(user.getUserId()); student.setMobilePhone(phoneNo); //公司名称 student.setSubjectId(comName); student.setPhoto(photo); student.setPassporName(passporName); student.setNationality(nationality); student.setAncestralHome(ancestralHome); student.setBirthday(birthday); student.setBirthplace(birthplace); student.setChinaStatus(chinaStatus); student.setRegisteredAddress(registeredAddress); student.setHomeAddress(homeAddress); student.setReligiousBelief(religiousBelief); student.setEmail(email); student.setWorkUnit(workUnit); if(StringUtils.isNoneBlank(classId)) { bulkUpdate("update ClsClass set studentCount = studentCount + 1 where deleteFlag is false and classId = ?", new Object[]{classId}); } save(student); return new Result(true, "success", CollectionUtils.newStringMap("studentId", student.getStudentId(), "password", user.getPassword())); } @Override public Result updateImgStudent(String studentId){ //根据学学员ID，获取用户信息 StuStudent stu = this.read(StuStudent.class, studentId); stu.setTenantId("1"); save(stu); return new Result(true, "success"); } @Override public Result updateStudent(String studentId, String name,String password, String studentNo, boolean sex, String phoneNo , String photo, String passporName, String nationality, String ancestralHome, String birthday, String birthplace, String chinaStatus, String registeredAddress, String homeAddress, String religiousBelief, String email, String workUnit, String graduationDestination) { //根据学学员ID，获取用户信息 StuStudent stu = this.read(StuStudent.class, studentId); if(stu.getStudentNo() != null){ if (!stu.getStudentNo().equals(studentNo) && dao.exists(studentNo,ClientUtils.getOrgId())) { return new Result(false, "学号已存在"); } } stu.setName(name); stu.setSex(sex); stu.setStudentNo(studentNo); stu.setMobilePhone(phoneNo); TraceUtils.setUpdateTrace(stu); stu.setPhoto(photo); stu.setPassporName(passporName); stu.setNationality(nationality); stu.setAncestralHome(ancestralHome); stu.setBirthday(birthday); stu.setBirthplace(birthplace); stu.setChinaStatus(chinaStatus); stu.setRegisteredAddress(registeredAddress); stu.setHomeAddress(homeAddress); stu.setReligiousBelief(religiousBelief); stu.setEmail(email); stu.setWorkUnit(workUnit); save(stu); User user = this.read(User.class, stu.getUserId()); user.setAccount(studentNo); user.setSex(sex); user.setMobilePhone(phoneNo); //随机字符串 String salt= UUID.randomUUID().toString(); //盐值 user.setSalt(salt); //对密码进行加密处理 String newPassword= DigestUtils.md5DigestAsHex((salt+password).getBytes()); if(!StringUtils.isEmpty(newPassword)){ user.setPassword(newPassword); } user.setName(name); save(user); return new Result(true, "success"); } @Override public List> getStudentLst(String classId, String keyword, Pager pager) { QUser qUser = QUser.user; QStuStudent qStuStudent = QStuStudent.stuStudent; return this.getQueryFactory() .select(qStuStudent.photo,qStuStudent.passporName,qStuStudent.nationality,qStuStudent.ancestralHome,qStuStudent.birthday,qStuStudent.birthplace,qStuStudent.chinaStatus, qStuStudent.registeredAddress,qStuStudent.homeAddress,qStuStudent.religiousBelief,qStuStudent.email,qStuStudent.workUnit,qStuStudent.graduationDestination, qStuStudent.studentId, qStuStudent.name, qStuStudent.studentNo, qStuStudent.sex, qStuStudent.mobilePhone, qStuStudent.status, qStuStudent.studyDuration, qStuStudent.tenantId, qStuStudent.score, qStuStudent.graduationText, qUser.imgPath) .from(qUser, qStuStudent) .where(qUser.deleteFlag.isFalse().and(qUser.userId.eq(qStuStudent.userId)) .and(qStuStudent.classId.eq(classId)).and(qStuStudent.name.like("%" + keyword + "%")).and(qStuStudent.deleteFlag.isFalse())) .limit(pager.getPageSize()).offset(pager.getOffset()).orderBy(qStuStudent.createTime.desc()).fetch().stream().map(tuple -> { Map map = new HashMap(); map.put("studentId", tuple.get(qStuStudent.studentId)); map.put("name", tuple.get(qStuStudent.name)); map.put("studentNo", tuple.get(qStuStudent.studentNo)); map.put("studentNumber", tuple.get(qStuStudent.studentNo)); map.put("sex", tuple.get(qStuStudent.sex)); map.put("mobilePhone", tuple.get(qStuStudent.mobilePhone)); map.put("status", tuple.get(qStuStudent.status)); map.put("studyDuration", tuple.get(qStuStudent.studyDuration)); map.put("tenantId", tuple.get(qStuStudent.tenantId)); map.put("score", tuple.get(qStuStudent.score)); map.put("graduationText", tuple.get(qStuStudent.graduationText)); map.put("imgPath", tuple.get(qUser.imgPath)); map.put("photo", tuple.get(qStuStudent.photo)); map.put("passporName", tuple.get(qStuStudent.passporName)); map.put("nationality", tuple.get(qStuStudent.nationality)); map.put("ancestralHome", tuple.get(qStuStudent.ancestralHome)); map.put("birthday", tuple.get(qStuStudent.birthday)); map.put("birthplace", tuple.get(qStuStudent.birthplace)); map.put("chinaStatus", tuple.get(qStuStudent.chinaStatus)); map.put("registeredAddress", tuple.get(qStuStudent.registeredAddress)); map.put("homeAddress", tuple.get(qStuStudent.homeAddress)); map.put("religiousBelief", tuple.get(qStuStudent.religiousBelief)); map.put("email", tuple.get(qStuStudent.email)); map.put("workUnit", tuple.get(qStuStudent.workUnit)); map.put("graduationDestination", tuple.get(qStuStudent.graduationDestination)); return map; }).collect(Collectors.toList()); } @Override public int getStudentsCount(String classId, String keyword) { // //TODO 判断是否为补考分组 // ClsClass cls = clsService.read(classId); // String hql=null; // if(cls!=null && cls.getClassTypes()!=null && "1".equals(cls.getClassTypes())){ // //TODO 补考分组需要另一种查询学员 stu.tenantId = class.classId // hql = "from StuStudent where tenantId=:classId and name like :keyword and deleteFlag is false"; // }else { String hql = "from StuStudent where classId=:classId and name like :keyword and deleteFlag is false"; // } return findCountByComplexHql(hql, CollectionUtils.newObjectMap("classId", classId, "keyword", "%" + keyword + "%" )); } @Override public Result deleteStudent(String classId, String[] studentIds) { for (String studentId : studentIds) { Result result = deleteStudent(classId, studentId); if (!result.isSuccess()) { return result; } } return new Result(true); } private Result deleteStudent(String classId, String studentId) { StuStudent student = read(StuStudent.class, studentId); User user = read(User.class, student.getUserId()); if (StuStudent.STATUS_ACTIVE.equals(student.getStatus())) { return new Result(false, "已激活学员不能移除"); } TraceUtils.setUpdateTrace(student); student.setDeleteFlag(true); save(student); deleteTrace(user); return new Result(true); } @Override public Result doActivateStudent(String[] studentIds) { for (String studentId : studentIds) { activateStudent(studentId, StuStudent.STATUS_ACTIVE); ModeUpdate(studentId,StuStudent.STATUS_ACTIVE); } return new Result(true); } @Override public Result doDeActivateStudent(String[] studentIds) { for (String studentId : studentIds) { activateStudent(studentId, StuStudent.STATUS_DEACTIVE); ModeUpdate(studentId,StuStudent.STATUS_DEACTIVE); } return new Result(true); } private Result ModeUpdate(String studentId,String status){ if(status.equals(StuStudent.STATUS_ACTIVE)){ String hql = "from ExerciseCompleteInfo where studentId=? and deleteFlag is false"; List Params = CollectionUtils.newList(studentId); ExerciseCompleteInfo unique = findUnique(hql, Params, ExerciseCompleteInfo.class); if(unique!=null) { unique.setDeleteFlag(false); commonDAO.update(unique); } }else { String hql = "from ExerciseCompleteInfo where studentId=? and deleteFlag is false"; List Params = CollectionUtils.newList(studentId); ExerciseCompleteInfo unique = findUnique(hql, Params, ExerciseCompleteInfo.class); if(unique!=null){ unique.setDeleteFlag(true); commonDAO.update(unique); } } return new Result(true); } private Result activateStudent(String studentId, String status) { StuStudent student = read(StuStudent.class, studentId); if (StringUtils.equals(status, student.getStatus())) { return new Result(false); } TraceUtils.setUpdateTrace(student); // String currentTime = LocalDateTimeUtil.format(LocalDateTime.now(), "yyMMddHHmmssSSS"); // // String examCardNo = currentTime.concat(RandomUtil.randomNumbers(1)); // // student.setStudentNumber(examCardNo); student.setStatus(status); commonDAO.update(student); clsService.addStudent(student.getClassId(), StuStudent.STATUS_DEACTIVE.equals(status) ? -1 : 1); return new Result(true); } @Override public Result queryStudent(String classId, String studentId) { StuStudent student = read(StuStudent.class, studentId); if(student == null) { return new Result(false, "未查询到学员信息"); } return new Result(true, "success", CollectionUtils.newObjectMap("studentId", student.getStudentId(), "name", student.getName(), "status", student.getStatus(), "studentNo", student.getStudentNo(), "sex", student.getSex(), "mobilePhone", student.getMobilePhone())); } @Override public StuStudent getStudentByUserId(String userId) { return this.findUnique("from StuStudent where userId=? ", CollectionUtils.newList(userId), StuStudent.class); } @Override public StuStudent getStudentByNo(String studentNo) { return this.findUnique("from StuStudent where studentNo=? ", CollectionUtils.newList(studentNo), StuStudent.class); } @Override public List getStudentByclassId(String classId) { QStuStudent qClassStudent=QStuStudent.stuStudent; return new ArrayList<>(this.getQueryFactory() .select(qClassStudent ) .from(qClassStudent) .where(qClassStudent.classId.eq(classId)) .fetch()); } @Override public Result studentProgress(String classId, String studentId) { StuStudent student = read(StuStudent.class, studentId); if(student == null) { return new Result(false, "未查询到学员信息"); } String userId = student.getUserId(); User u = this.read(User.class, userId); if(u == null) { return new Result(false, "未查询到用户信息"); } QSubjectProgressTreeV qSubjectProgressTreeV = QSubjectProgressTreeV.subjectProgressTreeV; //班级进度 SubjectProgressTreeV objSubjectProgressTreeV = this.getQueryFactory().selectFrom(qSubjectProgressTreeV).where(qSubjectProgressTreeV.id.nodeId.eq(classId).and(qSubjectProgressTreeV.id.userId.eq(userId))).fetchOne(); if(objSubjectProgressTreeV != null) { //学员总数 long studentCount = this.getQueryFactory().selectFrom(qSubjectProgressTreeV).where(qSubjectProgressTreeV.id.nodeId.eq(classId)).fetchCount(); // 当前学员排行 long studentIndex = this .getQueryFactory().selectFrom(qSubjectProgressTreeV).where(qSubjectProgressTreeV.id.nodeId .eq(classId).and(qSubjectProgressTreeV.percent.gt(objSubjectProgressTreeV.getPercent()) .or(qSubjectProgressTreeV.percent.eq(objSubjectProgressTreeV.getPercent())))) .fetchCount(); //学员的课程 List> lstSubject = this.subjectService.myClsSubjectlist(classId, userId, new Pager(Integer.MAX_VALUE, 0)); return new Result(true, "success", CollectionUtils.newObjectMap("studentId", student.getStudentId(), "name", student.getName(), "imgPath", u.getImgPath(), "status", student.getStatus(), "studentNumber", student.getStudentNo(), "sex", student.getSex(), "mobilePhone", student.getMobilePhone(), "subjectList", lstSubject, "studentCount", studentCount, "studentIndex", studentIndex, "studyDuration", objSubjectProgressTreeV.getProgressValue())); }{ return new Result(true, "success", CollectionUtils.newObjectMap("studentId", student.getStudentId(), "name", student.getName(), "imgPath", u.getImgPath(), "status", student.getStatus(), "studentNumber", student.getStudentNo(), "sex", student.getSex(), "mobilePhone", student.getMobilePhone(), "subjectList", new ArrayList>(), "studentCount", 0, "studentIndex", 1, "studyDuration", 0)); } } }