package com.qxueyou.scc.admin.classes.service.impl;
|
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
import com.qxueyou.scc.teach.subject.model.view.MyLectureV;
|
import com.qxueyou.scc.teach.subject.model.view.MySubjectV;
|
import com.qxueyou.scc.teach.subject.service.ILectureService;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.cache.annotation.Cacheable;
|
import org.springframework.stereotype.Service;
|
|
import com.querydsl.core.Tuple;
|
import com.querydsl.jpa.impl.JPAQuery;
|
import com.qxueyou.scc.admin.classes.dao.ClassDAO;
|
import com.qxueyou.scc.admin.classes.model.ClsClass;
|
import com.qxueyou.scc.admin.classes.model.QClsClass;
|
import com.qxueyou.scc.admin.classes.model.QClsClassReSubject;
|
import com.qxueyou.scc.admin.classes.service.IClassService;
|
import com.qxueyou.scc.admin.progress.model.Progress;
|
import com.qxueyou.scc.admin.progress.model.view.QSubjectProgressTreeV;
|
import com.qxueyou.scc.admin.score.service.IScoreService;
|
import com.qxueyou.scc.admin.teacher.service.ITeacherService;
|
import com.qxueyou.scc.base.model.Pager;
|
import com.qxueyou.scc.base.model.Result;
|
import com.qxueyou.scc.base.service.ICacheService;
|
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.model.StuStudent;
|
import com.qxueyou.scc.teach.subject.model.QSubject;
|
import com.qxueyou.scc.teach.subject.model.Subject;
|
|
/**
|
* 班级服务类
|
*
|
* @author xiadehu
|
*/
|
@Service
|
public class ClsClassService extends CommonAppService implements IClassService {
|
|
@Autowired
|
ClassDAO clsDao;
|
|
@Autowired
|
IScoreService scoreService;
|
|
@Autowired
|
ICacheService cache;
|
|
@Autowired
|
ITeacherService teacherService;
|
|
@Autowired
|
ILectureService lectureService;
|
|
/**
|
* 添加班级
|
*/
|
@Override
|
public Result insertClass(String className, String classNumber, Date startTime, Date endTime, String subjectId,
|
String teacherId) {
|
|
ClsClass cls = new ClsClass();
|
|
TraceUtils.setCreateTrace(cls);
|
|
cls.setClassNumber(classNumber);
|
cls.setName(className);
|
cls.setStartTime(startTime);
|
cls.setEndTime(endTime);
|
cls.setTeacherId(teacherId);
|
cls.setOrgId(ClientUtils.getOrgId());
|
save(cls);
|
return new Result(true, "success",CollectionUtils.newStringMap("classId",cls.getClassId()));
|
}
|
/**
|
* 添加补考班级班级
|
*/
|
@Override
|
public Result insertReClass(String className, String classNumber, Date startTime, Date endTime, String subjectId,
|
String teacherId,String classTypes) {
|
|
ClsClass cls = new ClsClass();
|
|
TraceUtils.setCreateTrace(cls);
|
|
cls.setClassNumber(classNumber);
|
cls.setName(className);
|
cls.setStartTime(startTime);
|
cls.setEndTime(endTime);
|
cls.setTeacherId(teacherId);
|
cls.setOrgId(ClientUtils.getOrgId());
|
cls.setClassTypes(classTypes);
|
save(cls);
|
return new Result(true, "success",CollectionUtils.newStringMap("classId",cls.getClassId()));
|
}
|
@Override
|
public ClsClass getReClass(String classTypes) {
|
String hql = "select c from ClsClass c where c.deleteFlag is false and c.classTypes=? ";
|
|
ClsClass cls = findUnique(hql, CollectionUtils.newList(classTypes),
|
ClsClass.class);
|
return cls;
|
}
|
|
@Override
|
public Result updateClass(String classId, String className, String classNumber, Date startTime, Date endTime,
|
String subjectId, boolean needJoinAudit, boolean needQuitAudit, boolean showAnalysisAfterExer,
|
boolean canMultiExer, boolean needForum, String teacherId) {
|
|
ClsClass cls = read(ClsClass.class, classId);
|
|
TraceUtils.setUpdateTrace(cls);
|
|
cls.setClassNumber(classNumber);
|
cls.setName(className);
|
cls.setStartTime(startTime);
|
cls.setEndTime(endTime);
|
cls.setNeedJoinAudit(needJoinAudit);
|
cls.setNeedQuitAudit(needQuitAudit);
|
cls.setShowAnalysisAfterExer(showAnalysisAfterExer);
|
cls.setCanMultiExer(canMultiExer);
|
cls.setNeedForum(needForum);
|
cls.setTeacherId(teacherId);
|
save(cls);
|
|
return new Result(true, "success");
|
}
|
|
@Override
|
public ClsClass read(String classId) {
|
return read(ClsClass.class, classId);
|
}
|
//
|
// /**
|
// * 原始：获取班级列表
|
// */
|
// @Override
|
// public List<ClsClass> getClassLst(String keyword, String teacherId, Integer pageSize, Integer pageNum, Integer pageType) {
|
// String keyword_ = StringUtils.isBlank(keyword) ? "" : keyword;
|
//// System.out.println(keyword_);
|
// StringBuffer hql = new StringBuffer("from ClsClass c where c.deleteFlag is false and c.orgId=? and c.name like ? and c.createId=?");
|
//
|
// if (pageType == 1) {
|
// hql.append(" and c.endTime >= sysdate() ");
|
// }else if(pageType == 2) {
|
// hql.append(" and c.endTime < sysdate() ");
|
// }
|
//// System.out.println("vvvvv"+ClientUtils.getOrgId()+"333333333"+ClientUtils.getUserId());
|
// List<Object> args = CollectionUtils.newList(ClientUtils.getOrgId(),keyword_ + "%",ClientUtils.getUserId());
|
//// System.out.println(args);
|
// if (!StringUtils.isEmpty(teacherId)) {
|
// hql.append(" and exists( select 1 from ClsClassReSubject r,Subject t where r.subjectId=t.subjectId and c.classId= r.classId and t.teacherId=? and r.deleteFlag is false and t.deleteFlag is false)");
|
// args.add(teacherId);
|
// }
|
//
|
// hql.append(" order by c.createTime desc");
|
//// System.out.println(hql.toString());
|
//// System.out.println(findList(hql.toString(), new Pager(pageSize, pageNum), args, ClsClass.class));
|
// return findList(hql.toString(), new Pager(pageSize, pageNum), args, ClsClass.class);
|
// }
|
|
/**
|
* 优化获取班级列表
|
* @param keyword
|
* @param teacherId
|
* @param pageSize
|
* @param pageNum
|
* @param pageType
|
* @return
|
*/
|
public List<ClsClass> getClassLst(String keyword, String teacherId, Integer pageSize, Integer pageNum, Integer pageType) {
|
String keyword_ = StringUtils.isBlank(keyword) ? "" : keyword;
|
// System.out.println(keyword_);
|
StringBuffer hql = new StringBuffer("from ClsClass c where c.deleteFlag is false and c.orgId=? and c.name like ? ");
|
|
if (pageType == 1) {
|
hql.append(" and c.endTime >= sysdate() ");
|
}else if(pageType == 2) {
|
hql.append(" and c.endTime < sysdate() ");
|
}
|
// if (!StringUtils.isEmpty(teacherId)) {
|
// hql.append("and c.createId=?)");
|
// }
|
// System.out.println("vvvvv"+ClientUtils.getOrgId()+"333333333"+ClientUtils.getUserId()); ,ClientUtils.getUserId()
|
List<Object> args = CollectionUtils.newList(ClientUtils.getOrgId(),keyword_ + "%");
|
// System.out.println(args);
|
if (!StringUtils.isEmpty(teacherId)) {
|
hql.append(" and exists( select 1 from ClsClassReSubject r,Subject t where r.subjectId=t.subjectId and c.classId= r.classId and t.teacherId=? and r.deleteFlag is false and t.deleteFlag is false)");
|
args.add(teacherId);
|
}
|
|
hql.append(" order by c.createTime desc");
|
// System.out.println(hql.toString());
|
// System.out.println(findList(hql.toString(), new Pager(pageSize, pageNum), args, ClsClass.class));
|
return findList(hql.toString(), new Pager(pageSize, pageNum), args, ClsClass.class);
|
}
|
|
@Override
|
public int getClassLstCount(String keyword, String teacherId, Integer pageType) {
|
StringBuffer hql = new StringBuffer("from ClsClass c where c.deleteFlag is false and c.orgId=? and c.name like ?");
|
|
if (pageType == 1) {
|
hql.append(" and c.endTime >= sysdate() ");
|
}else if(pageType == 2) {
|
hql.append(" and c.endTime < sysdate() ");
|
}
|
|
List<Object> args = CollectionUtils.newList(ClientUtils.getOrgId(),keyword + "%");
|
|
if (!StringUtils.isEmpty(teacherId)) {
|
hql.append(" and exists( select 1 from ClsClassReSubject r,Subject t where r.subjectId=t.subjectId and c.classId= r.classId and t.teacherId=? and r.deleteFlag is false and t.deleteFlag is false)");
|
args.add(teacherId);
|
}
|
|
return findCount(hql.toString(), args);
|
}
|
|
@Override
|
public List<ClsClass> listMyClass() {
|
|
String hql = "select c from ClsClass c,StuStudent s where c.classId=s.classId and s.userId=? and s.status=?";
|
|
System.out.println(ClientUtils.getUserId());
|
|
List<ClsClass> result = find(hql, CollectionUtils.newList(ClientUtils.getUserId(), StuStudent.STATUS_ACTIVE),
|
ClsClass.class);
|
|
return result;
|
}
|
|
/**
|
* 删除班级
|
*/
|
@Override
|
public Result deleteClass(String[] classIds) {
|
for (String classId : classIds) {
|
deleteClass(classId);
|
//删除班级学员
|
this.deleteStudent(classId);
|
//删除班级课程
|
this.deleteClassSubject(classId);
|
}
|
|
return new Result(true, "success");
|
}
|
|
/**
|
* 删除班级学员
|
*/
|
private void deleteStudent(String classId) {
|
this.bulkUpdate("update StuStudent set deleteFlag = 1 where classId = ?", new Object[] {classId});
|
}
|
|
/**
|
* 删除班级课程
|
*/
|
private void deleteClassSubject(String classId) {
|
this.bulkUpdate("delete from ClsClassReSubject where classId=?", new Object[] {classId});
|
}
|
|
/**
|
* @param classId 班级id
|
* @return
|
*/
|
private Result deleteClass(String classId) {
|
|
ClsClass cls = read(ClsClass.class, classId);
|
|
TraceUtils.setUpdateTrace(cls);
|
cls.setDeleteFlag(true);
|
|
save(cls);
|
|
return new Result(true, "success");
|
}
|
|
@Override
|
public List<Map<String, Object>> getSubjectLstByClsId(String classId) {
|
String hql = "from MySubjectV where classId = ?";
|
List<MySubjectV> mySubjectVList = find(hql,CollectionUtils.newList(classId),MySubjectV.class);
|
List<Map<String,Object>> maps = new ArrayList<>();
|
for(MySubjectV mySubjectV : mySubjectVList){
|
List<MyLectureV> myLectureVList = lectureService.listLectureVBySubjectId(mySubjectV.getId().getUserId(),mySubjectV.getId().getSubjectId(), "", 1000, 1, null);
|
Double percent = 0.0;
|
Double progressValue = 0.0;
|
Double percentAvg = 0.0;
|
if(!myLectureVList.isEmpty()) {
|
for (MyLectureV myLectureV : myLectureVList) {
|
if (myLectureV.getPercent() != null && myLectureV.getProgressValue() != null) {
|
percent += myLectureV.getPercent();
|
progressValue += myLectureV.getProgressValue().intValue();
|
}
|
}
|
percentAvg = percent / myLectureVList.size();
|
if (percentAvg.isNaN()) {
|
percentAvg = 0.0;
|
}
|
}
|
}
|
return null;
|
}
|
|
@Override
|
public Result addStudent(String classId, int count) {
|
|
clsDao.addStudent(classId, count);
|
|
return new Result(true);
|
}
|
|
@Cacheable(value = "ClsClassService_ClassActivityInfo")
|
@Override
|
public Map<String, Object> getClassActivityInfo(String classId) {
|
|
Map<String, Object> result = scoreService.queryClassHomeworkScoreInfo(classId);
|
result.putAll(scoreService.queryClassExamScoreInfo(classId));
|
|
ClsClass cls = read(classId);
|
|
result.put("classId", cls.getClassId());
|
result.put("className", cls.getName());
|
result.put("coverPageUrl", cls.getImgPath());
|
result.put("status", cls.getProgress());
|
result.put("studentCount", cls.getStudentCount());
|
result.put("startTime", cls.getStartTime());
|
|
return result;
|
}
|
|
@Override
|
public Result getAllClassLst() {
|
String hql = "select c.name as className, c.teacherId as teacherId ,c.classId as classId ,c.classNumber as classNumber from ClsClass c where c.deleteFlag is false ";
|
|
List<Map<String, Object>> classLst = findListWithMapByHql(hql, null);
|
int classCount = findCountByComplexHql("from ClsClass where deleteFlag is false", null);
|
return new Result(true, "success",
|
CollectionUtils.newObjectMap("classLst", classLst, "classCount", classCount));
|
|
}
|
|
@Override
|
public List<ClsClass> getClassLstByTeacherId() {
|
String hql = "select c from ClsClass c,UserTeacher t where "
|
+ " EXISTS(select 1 from ClsClassReSubject r ,Subject s where r.subjectId=s.subjectId and r.classId =c.classId and r.deleteFlag is false and s.teacherId = t.teacherId) and t.userId= ? order by c.createTime desc ";
|
|
return find(hql, CollectionUtils.newList(ClientUtils.getUserId()), ClsClass.class);
|
}
|
|
@Override
|
public List<Map<String,Object>> queryAvailableClassIdAndName(String teacherId,String subjectId) {
|
StringBuffer hql = new StringBuffer(1000);
|
// and c.endTime>=sysdate() 增加条件过滤掉历史班级
|
hql.append("select c.classId as classId ,c.name as className from ClsClass c where c.deleteFlag is false and c.orgId=:orgId and c.createId=:createId " );
|
Map<String,Object> queryParam = new HashMap<String,Object>();
|
queryParam.put("orgId", ClientUtils.getOrgId());
|
queryParam.put("createId", ClientUtils.getUserId());
|
|
if(StringUtils.isNotEmpty(teacherId)||StringUtils.isNotEmpty(subjectId)){
|
hql.append(" and exists (select 1 from ClsClassReSubject r ,Subject s where r.subjectId=s.subjectId and r.classId =c.classId and r.deleteFlag is false ");
|
}
|
|
if(!StringUtils.isEmpty(teacherId)){
|
hql.append(" and s.teacherId=:teacherId ");
|
queryParam.put("teacherId", teacherId);
|
}
|
|
if(!StringUtils.isEmpty(subjectId)){
|
hql.append(" and s.origSubjectId=:subjectId ");
|
queryParam.put("subjectId", subjectId);
|
}
|
|
if(StringUtils.isNotEmpty(teacherId)||StringUtils.isNotEmpty(subjectId)){
|
hql.append(")");
|
}
|
|
return this.findListWithMapByHql(hql.toString(), queryParam);
|
}
|
|
@Override
|
public List<Map<String,Object>> queryAllClassIdAndName() {
|
StringBuffer hql = new StringBuffer(500);
|
// c.deleteFlag is false and
|
hql.append("select c.classId as classId ,c.name as className from ClsClass c where c.endTime>=:endTime and deleteFlag is false and c.orgId=:orgId " );
|
|
return this.findListWithMapByHql(hql.toString(), CollectionUtils.newObjectMap("endTime",new Date(),"orgId",ClientUtils.getOrgId()));
|
}
|
|
|
|
/**
|
* 查询班级
|
*
|
* type 1正常班級，2历史班級
|
*/
|
public Result classList(String keyword, Pager pager, int type) {
|
//获取老师id
|
String teacherId = teacherService.getTeacherIdByUserId(ClientUtils.getUserId());
|
if (StringUtils.isEmpty(teacherId)) {
|
return new Result(false, "非老师角色无法查看班级");
|
}
|
QClsClass qClsClass = QClsClass.clsClass;
|
QSubject qSubject = QSubject.subject;
|
QClsClassReSubject qClsClassReSubject = QClsClassReSubject.clsClassReSubject;
|
QSubjectProgressTreeV qSubjectProgressTreeV = QSubjectProgressTreeV.subjectProgressTreeV;
|
|
//查询脚本
|
JPAQuery<Tuple> queryDsl = this.getQueryFactory()
|
.select(qClsClass.name, qClsClass.classId, qClsClass.classNumber, qClsClass.studentCount,
|
qClsClass.createTime, qClsClass.startTime, qClsClass.endTime, qSubject)
|
.from(qClsClass, qSubject, qClsClassReSubject)
|
.where(qClsClass.deleteFlag.isFalse().and((type == 2 ? qClsClass.endTime.lt(new Date()) : qClsClass.endTime.gt(new Date()))).and(qClsClass.name.like("%" + keyword + "%"))
|
.and(qSubject.teacherId.eq(teacherId)).and(qSubject.deleteFlag.isFalse())
|
.and(qClsClassReSubject.deleteFlag.isFalse())
|
.and(qClsClassReSubject.classId.eq(qClsClass.classId))
|
.and(qClsClassReSubject.subjectId.eq(qSubject.subjectId)))
|
.groupBy(qClsClass.classId);
|
|
//总数
|
long count = queryDsl.fetchCount();
|
|
//listData
|
List<Map<String, Object>> listData = queryDsl.limit(pager.getPageSize()).offset(pager.getOffset())
|
.orderBy(qClsClass.createTime.desc(), qSubject.createTime.desc()).fetch().stream().map(tuple -> {
|
Map<String, Object> map = new HashMap<String, Object>();
|
Subject subject = tuple.get(qSubject);
|
|
map.put("className", tuple.get(qClsClass.name));
|
map.put("classId", tuple.get(qClsClass.classId));
|
map.put("classNumber", tuple.get(qClsClass.classNumber));
|
map.put("studentCount", tuple.get(qClsClass.studentCount));
|
map.put("createTime", tuple.get(qClsClass.createTime));
|
map.put("startTime", tuple.get(qClsClass.startTime));
|
map.put("endTime", tuple.get(qClsClass.endTime));
|
if (subject != null) {
|
map.put("subjectName", subject.getName());
|
map.put("progressPercent",
|
this.getQueryFactory().select(qSubjectProgressTreeV.percent.avg())
|
.from(qSubjectProgressTreeV)
|
.where(qSubjectProgressTreeV.id.nodeId.eq(subject.getSubjectId())
|
.and(qSubjectProgressTreeV.nodeType.eq(Progress.PROGRESS_TYPE_SUBJECT)))
|
.groupBy(qSubjectProgressTreeV.id.nodeId).fetchOne());
|
} else {
|
map.put("subjectName", "暂无开班课程");
|
map.put("progressPercent", 0);
|
}
|
return map;
|
}).collect(Collectors.toList());
|
|
return new Result(true, "success", CollectionUtils.newObjectMap("count", count, "listData", listData));
|
}
|
|
@Override
|
public String [] queryClassNamesByIds(String[] classIds){
|
if(classIds!=null && classIds.length==0){
|
return null;
|
}
|
|
String [] classNames = null;
|
|
List<Map<String,Object>> lstResult= this.findListWithMapByHql("select c.classId as classId ,c.name as className from ClsClass c where c.classId in (:classIds) ",
|
CollectionUtils.newObjectMap("classIds",classIds));
|
|
if(lstResult!=null && lstResult.size()==classIds.length){
|
Map<String,String> map= new HashMap<String,String>(lstResult.size());
|
classNames =new String [classIds.length];
|
|
for(Map<String,Object> item:lstResult){
|
map.put((String)item.get("classId"), (String)item.get("className"));
|
}
|
|
for(int i=0;i<classIds.length;i++){
|
classNames[i]= map.get(classIds[i]);
|
}
|
}
|
|
return classNames;
|
}
|
|
@Override
|
public List<ClsClass> queryStudentClassesByUserId(String userId) {
|
return this.find("from ClsClass c where c.deleteFlag is false and exists( select 1 from StuStudent t where t.classId = c.classId and t.userId=? and t.status=? ) ",
|
CollectionUtils.newList(userId,StuStudent.STATUS_ACTIVE),ClsClass.class);
|
}
|
|
|
}
|
