package com.qxueyou.scc.admin.course.service.impl;
|
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.List;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import com.qxueyou.scc.admin.classroom.model.ClassRoom;
|
import com.qxueyou.scc.admin.course.model.CourseSchedule;
|
import com.qxueyou.scc.admin.course.model.CourseScheduleDetail;
|
import com.qxueyou.scc.admin.course.model.CourseScheduleReCls;
|
import com.qxueyou.scc.admin.course.service.ICourseScheduleService;
|
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.impl.CommonAppService;
|
import com.qxueyou.scc.base.util.ClientUtils;
|
import com.qxueyou.scc.base.util.CollectionUtils;
|
import com.qxueyou.scc.base.util.QBeanUtils;
|
import com.qxueyou.scc.base.util.TraceUtils;
|
import com.qxueyou.scc.exam.model.ExamInfo;
|
import com.qxueyou.scc.teach.subject.model.Subject;
|
import com.qxueyou.scc.user.model.UserTeacher;
|
|
@Service
|
public class CourseScheduleService extends CommonAppService implements ICourseScheduleService {
|
|
public final static String FULL_DATE_FORMAT = "yyyy-MM-dd HH:mm:ss";
|
|
public final static String SHORT_DATE_FORMAT = "yyyy-MM-dd";
|
|
public final static String SHORT_TIME_FORMAT = "HH:mm:ss";
|
|
public final static String TIME_SPLIT = "-";
|
|
@Autowired
|
private ITeacherService teacherService;
|
|
@Override
|
public String add(CourseSchedule courseSchedule) throws Exception {
|
TraceUtils.setCreateTrace(courseSchedule);
|
courseSchedule.setOrgId(ClientUtils.getOrgId());
|
courseSchedule.setStatus(CourseSchedule.STATUS_DRAFT);
|
|
//保存教师信息
|
UserTeacher teacher= teacherService.getTeacherByUserId(ClientUtils.getUserId());
|
|
if(teacher!=null){
|
courseSchedule.setTeacherId(teacher.getTeacherId());
|
courseSchedule.setTeacherName(teacher.getName());
|
}else{
|
courseSchedule.setTeacherId(ClientUtils.getUserId());
|
courseSchedule.setTeacherName(ClientUtils.getUserName());
|
}
|
|
Subject subject = this.read(Subject.class, courseSchedule.getSubjectId());
|
|
if(subject.getType()==Subject.TYPE_PUBLIC_SUBJECT){
|
courseSchedule.setOpenFlag(CourseSchedule.OPEN_TRUE);
|
}else{
|
courseSchedule.setOpenFlag(CourseSchedule.OPEN_FALSE);
|
}
|
|
this.insert(courseSchedule);
|
|
//生成关联关系
|
List<String> lstClassIds= QBeanUtils.listPropertyVal(courseSchedule.getReClasses(), "classId");
|
this.doClearAndAddReClass(courseSchedule.getScheduleId(),lstClassIds==null?null:lstClassIds.toArray(new String[lstClassIds.size()]));
|
|
//生成明细
|
this.doCreateScheduleDetail(courseSchedule);
|
|
return courseSchedule.getScheduleId();
|
}
|
|
@Override
|
public Result update(CourseSchedule courseSchedule) throws Exception {
|
CourseSchedule newCourseSchedule = read(CourseSchedule.class, courseSchedule.getScheduleId());
|
|
if (newCourseSchedule == null) {
|
return new Result(false, "课表不存在");
|
}
|
|
TraceUtils.setUpdateTrace(newCourseSchedule);
|
newCourseSchedule.setSubjectId(courseSchedule.getSubjectId());
|
newCourseSchedule.setRoomId(courseSchedule.getRoomId());
|
newCourseSchedule.setMark(courseSchedule.getMark());
|
newCourseSchedule.setBeginTime(courseSchedule.getBeginTime());
|
newCourseSchedule.setEndTime(courseSchedule.getEndTime());
|
newCourseSchedule.setMonTime(courseSchedule.getMonTime());
|
newCourseSchedule.setTueTime(courseSchedule.getTueTime());
|
newCourseSchedule.setWedTime(courseSchedule.getWedTime());
|
newCourseSchedule.setThuTime(courseSchedule.getThuTime());
|
newCourseSchedule.setFriTime(courseSchedule.getFriTime());
|
newCourseSchedule.setSatTime(courseSchedule.getSatTime());
|
newCourseSchedule.setSumTime(courseSchedule.getSumTime());
|
|
//保存教师信息
|
UserTeacher teacher= teacherService.getTeacherByUserId(ClientUtils.getUserId());
|
|
if(teacher!=null){
|
courseSchedule.setTeacherId(teacher.getTeacherId());
|
courseSchedule.setTeacherName(teacher.getName());
|
}else{
|
courseSchedule.setTeacherId(ClientUtils.getUserId());
|
courseSchedule.setTeacherName(ClientUtils.getUserName());
|
}
|
|
Subject subject = this.read(Subject.class, courseSchedule.getSubjectId());
|
|
if(subject.getType()==Subject.TYPE_PUBLIC_SUBJECT){
|
courseSchedule.setOpenFlag(CourseSchedule.OPEN_TRUE);
|
}else{
|
courseSchedule.setOpenFlag(CourseSchedule.OPEN_FALSE);
|
}
|
|
this.save(newCourseSchedule);
|
|
List<String> lstClassIds= QBeanUtils.listPropertyVal(newCourseSchedule.getReClasses(), "classId");
|
|
//更新关联关系
|
this.doClearAndAddReClass(courseSchedule.getScheduleId(),lstClassIds==null?null:lstClassIds.toArray(new String[lstClassIds.size()]));
|
|
//生成明细
|
this.doCreateScheduleDetail(courseSchedule);
|
|
// 保存课程班级信息
|
return new Result(true);
|
}
|
|
/**
|
* 清理并添加直播权限班级
|
* @param liveId
|
* @param classIds
|
*/
|
private void doClearAndAddReClass(String scheduleId, String [] classIds) {
|
List<String> reIdLst = this.find("select r.reId from CourseScheduleReCls r where r.scheduleId=?",
|
CollectionUtils.newList(scheduleId), String.class);
|
|
//删除关联关系
|
if(reIdLst!=null && reIdLst.size()>0){
|
this.bulkUpdateInLoop("delete from CourseScheduleReCls where reId=?", reIdLst.toArray());
|
}
|
|
if(classIds != null && classIds.length > 0){
|
for(String classId:classIds){
|
CourseScheduleReCls re = new CourseScheduleReCls();
|
TraceUtils.setCreateTrace(re);
|
re.setClassId(classId);
|
re.setScheduleId(scheduleId);
|
save(re);
|
}
|
}
|
}
|
|
@Override
|
public Result delete(String[] scheduleIds) {
|
Result result = new Result(true);
|
if (scheduleIds != null && scheduleIds.length > 0) {
|
String hql = "update CourseSchedule set deleteFlag = true where scheduleId=?";
|
result = bulkUpdateInLoop(hql, scheduleIds);
|
}
|
return result;
|
}
|
|
@Override
|
public Result doRelease(String[] scheduleIds) {
|
if(scheduleIds==null || scheduleIds.length==0){
|
return new Result(false, "没有选择要发布的课表");
|
}
|
|
List<CourseSchedule> lstCourseSchedule = this.findByComplexHql("from CourseSchedule where scheduleId in (:scheduleIds)",
|
CollectionUtils.newObjectMap("scheduleIds",scheduleIds), CourseSchedule.class);
|
|
for (CourseSchedule schedule : lstCourseSchedule) {
|
if (CourseSchedule.STATUS_DRAFT != schedule.getStatus()) {
|
return new Result(false, "只有草稿状态的课表,才能发布。");
|
}
|
schedule.setStatus(ClassRoom.STATUS_PUBLISH);
|
TraceUtils.setUpdateTrace(schedule);
|
save(schedule);
|
}
|
|
return new Result(true);
|
}
|
|
@Override
|
public Result doCancel(String[] scheduleIds) {
|
if(scheduleIds==null || scheduleIds.length==0){
|
return new Result(false, "没有选择要撤回的课表");
|
}
|
|
List<CourseSchedule> lstCourseSchedule = this.findByComplexHql("from CourseSchedule where scheduleId in (:scheduleIds)",
|
CollectionUtils.newObjectMap("scheduleIds",scheduleIds), CourseSchedule.class);
|
|
for (CourseSchedule schedule : lstCourseSchedule) {
|
if (CourseSchedule.STATUS_PUBLISH != schedule.getStatus()) {
|
return new Result(false, "只有发布状态的课表,才能撤回");
|
}
|
schedule.setStatus(ExamInfo.STATUS_DRAFT);
|
TraceUtils.setUpdateTrace(schedule);
|
save(schedule);
|
}
|
|
return new Result(true);
|
}
|
|
@Override
|
public List<CourseSchedule> list(String keyword, Short status, Integer pageSize, Integer pageNum) {
|
StringBuffer hql = new StringBuffer(500);
|
hql.append(" from CourseSchedule c left join fetch c.subject s left join fetch c.classes where s.name like ? and c.createId=? ");
|
List<Object> params = CollectionUtils.newList('%' + keyword.trim() + '%',ClientUtils.getUserId());
|
|
if(status!=null){
|
hql.append(" and c.status = ? ");
|
params.add(status);
|
}
|
|
hql.append(" and c.deleteFlag is false order by c.createTime desc");
|
|
return findList(hql.toString(),new Pager(pageSize, pageNum),params, CourseSchedule.class);
|
}
|
|
@Override
|
public int listCount(String keyword,Short status) {
|
StringBuffer hql = new StringBuffer(500);
|
hql.append(" from CourseSchedule c left join c.subject s where s.name like ? and c.createId=? ");
|
List<Object> params = CollectionUtils.newList('%' + keyword.trim() + '%',ClientUtils.getUserId());
|
|
if(status!=null){
|
hql.append(" and c.status = ? ");
|
params.add(status);
|
}
|
|
hql.append(" and c.deleteFlag is false ");
|
|
return findCount(hql.toString(),params);
|
}
|
|
@Override
|
public CourseSchedule detail(String courseScheduleId) {
|
return this.read(CourseSchedule.class, courseScheduleId);
|
}
|
|
//查询当前的课表明细信息，
|
@Override
|
public List<CourseSchedule> listTeacherOfSchedule(String date,Integer pageSize, Integer pageNum) throws Exception{
|
|
SimpleDateFormat sdfFull = new SimpleDateFormat(FULL_DATE_FORMAT);
|
|
StringBuffer hql = new StringBuffer(1000);
|
hql.append("from CourseScheduleDetail d left join fetch d.courseSchedule s left join fetch s.subject j left join fetch s.classRoom m left join fetch s.classes c ");
|
hql.append(" where d.deleteFlag is false and d.beginTime>=? and d.endTime<=? ");
|
hql.append(" and s.status=? and s.deleteFlag is false");
|
|
List<Object> params = CollectionUtils.newList();
|
|
params.add(sdfFull.parse(date+" 00:00:00"));
|
params.add(sdfFull.parse(date+" 23:59:59"));
|
params.add(CourseSchedule.STATUS_PUBLISH);
|
|
UserTeacher teacher = ClientUtils.isAdmin() ? null : teacherService.getTeacherByUserId(ClientUtils.getUserId());
|
|
if(teacher!=null){
|
hql.append(" and s.teacherId =?");
|
params.add(teacher.getTeacherId());
|
}
|
|
hql.append(" and d.deleteFlag is false order by d.beginTime asc");
|
return findList(hql.toString(),new Pager(pageSize, pageNum),params, CourseSchedule.class);
|
}
|
|
//查询当前的课表明细信息
|
@Override
|
public int listTeacherOfScheduleCount(String date,Integer pageSize, Integer pageNum) throws ParseException{
|
|
SimpleDateFormat sdf = new SimpleDateFormat(FULL_DATE_FORMAT);
|
|
StringBuffer hql = new StringBuffer(1000);
|
hql.append(" from CourseScheduleDetail d left join d.courseSchedule s where ");
|
hql.append(" d.deleteFlag is false and d.beginTime>=? and d.endTime<=? ");
|
hql.append(" and s.status=? and s.deleteFlag is false and d.deleteFlag is false ");
|
|
List<Object> params = CollectionUtils.newList();
|
params.add(sdf.parse(date + " 00:00:00"));
|
params.add(sdf.parse(date + " 23:59:59"));
|
params.add(CourseSchedule.STATUS_PUBLISH);
|
|
UserTeacher teacher = ClientUtils.isAdmin() ? null : teacherService.getTeacherByUserId(ClientUtils.getUserId());
|
|
if(teacher!=null){
|
hql.append(" and s.teacherId =?");
|
params.add(teacher.getTeacherId());
|
}
|
|
return findCount(hql.toString(),params);
|
}
|
|
//查询当前的课表明细信息
|
@Override
|
public List<CourseSchedule> listStudentSchedule(String date,Integer pageSize, Integer pageNum) throws Exception{
|
StringBuffer hql = new StringBuffer(1000);
|
hql.append("from CourseScheduleDetail d left join fetch d.courseSchedule s left join fetch s.subject j left join fetch s.classRoom m left join fetch s.classes c ");
|
hql.append(" where d.beginTime>=? and d.endTime<=? ");
|
hql.append(" and (c.classId=? or s.openFlag=?) and s.status=? ");
|
|
SimpleDateFormat sdf = new SimpleDateFormat(FULL_DATE_FORMAT);
|
|
List<Object> params = CollectionUtils.newList();
|
params.add(sdf.parse(date+" 00:00:00"));
|
params.add(sdf.parse(date+" 23:59:59"));
|
params.add(ClientUtils.getClassId());
|
params.add(CourseSchedule.OPEN_TRUE);
|
params.add(CourseSchedule.STATUS_PUBLISH);
|
|
hql.append(" and d.deleteFlag is false and s.deleteFlag is false order by d.beginTime asc");
|
|
return findList(hql.toString(),new Pager(pageSize, pageNum),params, CourseSchedule.class);
|
}
|
|
//查询当前的课表明细信息
|
@Override
|
public int listStudentScheduleCount(String date,Integer pageSize, Integer pageNum) throws Exception{
|
StringBuffer hql = new StringBuffer(1000);
|
hql.append(" from CourseScheduleDetail d left join d.courseSchedule s left join s.classes c ");
|
hql.append(" where d.beginTime>=? and d.endTime<=? ");
|
hql.append(" and (c.classId=? or s.openFlag=?) and s.status=? ");
|
hql.append(" and d.deleteFlag is false and s.deleteFlag is false");
|
|
SimpleDateFormat sdfFull = new SimpleDateFormat(FULL_DATE_FORMAT);
|
|
List<Object> params = CollectionUtils.newList();
|
params.add(sdfFull.parse(date+" 00:00:00"));
|
params.add(sdfFull.parse(date+" 23:59:59"));
|
params.add(ClientUtils.getClassId());
|
params.add(CourseSchedule.OPEN_TRUE);
|
params.add(CourseSchedule.STATUS_PUBLISH);
|
|
return findCount(hql.toString(),params);
|
}
|
|
|
//生成明细数据
|
private void doCreateScheduleDetail(CourseSchedule courseSchedule) throws Exception{
|
SimpleDateFormat sdf = new SimpleDateFormat(SHORT_DATE_FORMAT);
|
String scheduleId = courseSchedule.getScheduleId();
|
|
//清理旧的关联关系
|
List<String> detailIdLst = this.find("select d.detailId from CourseScheduleDetail d where d.scheduleId=?",
|
CollectionUtils.newList(scheduleId), String.class);
|
|
if(detailIdLst!=null && detailIdLst.size()>0){
|
this.bulkUpdateInLoop("delete from CourseScheduleDetail where detailId=?", detailIdLst.toArray());
|
}
|
|
//重新生成新的明细
|
Calendar cal = Calendar.getInstance();
|
cal.setTime(courseSchedule.getBeginTime());
|
cal.set(Calendar.HOUR, 0);
|
cal.set(Calendar.MINUTE, 0);
|
cal.set(Calendar.SECOND, 0);
|
int dayOfWeek = -1;
|
String courseTime = null,strDate = null;
|
String [] arrTime = null;
|
|
do{
|
dayOfWeek = cal.get(Calendar.DAY_OF_WEEK);
|
switch(dayOfWeek){
|
case 1 : courseTime =courseSchedule.getSumTime();break;
|
case 2 : courseTime =courseSchedule.getMonTime();break;
|
case 3 : courseTime =courseSchedule.getTueTime();break;
|
case 4 : courseTime =courseSchedule.getWedTime();break;
|
case 5 : courseTime =courseSchedule.getThuTime();break;
|
case 6 : courseTime =courseSchedule.getFriTime();break;
|
case 7 : courseTime =courseSchedule.getSatTime();break;
|
default: break;
|
}
|
|
if(StringUtils.isNotEmpty(courseTime)){
|
arrTime = courseTime.split(TIME_SPLIT);
|
strDate = sdf.format(cal.getTime());
|
this.insertScheduleDetail(strDate.concat(" ").concat(arrTime[0]).concat(":00"),strDate.concat(" ").concat(arrTime[1]).concat(":00"),courseSchedule.getScheduleId());
|
}
|
|
cal.add(Calendar.DATE, 1); //+1
|
|
}while(cal.getTime().getTime()<=courseSchedule.getEndTime().getTime());
|
}
|
|
private void insertScheduleDetail(String beginTime,String endTime, String scheduleId) throws ParseException{
|
CourseScheduleDetail detail = new CourseScheduleDetail();
|
SimpleDateFormat sdf = new SimpleDateFormat(FULL_DATE_FORMAT);
|
detail.setBeginTime(sdf.parse(beginTime));
|
detail.setEndTime(sdf.parse(endTime));
|
detail.setScheduleId(scheduleId);
|
detail.setDeleteFlag(false);
|
TraceUtils.setCreateTrace(detail);
|
this.save(detail);
|
}
|
|
@Override
|
public List<Integer> queryDateFlag(int year ,int month){
|
StringBuffer hql = new StringBuffer(1000);
|
hql.append(" select day(d.beginTime) from CourseScheduleDetail d left join d.courseSchedule s ");
|
hql.append(" where d.deleteFlag is false and d.beginTime >= ? and d.endTime <= ? ");
|
hql.append(" and s.status=? and s.deleteFlag is false ");
|
|
Date beginDate=null,endDate=null;
|
|
Calendar cal = Calendar.getInstance();
|
cal.set(year, month-1, 1, 0 ,0 ,0);
|
beginDate = cal.getTime();
|
cal.clear();
|
cal.set(Calendar.YEAR,year);
|
cal.set(Calendar.MONTH,month-1);
|
cal.set(Calendar.DATE,cal.getActualMaximum(Calendar.DATE));
|
cal.set(Calendar.HOUR, 23);
|
cal.set(Calendar.MINUTE, 59);
|
cal.set(Calendar.SECOND, 59);
|
endDate = cal.getTime();
|
|
List<Object> params = CollectionUtils.newList();
|
params.add(beginDate);
|
params.add(endDate);
|
params.add(CourseSchedule.STATUS_PUBLISH);
|
|
UserTeacher teacher = ClientUtils.isAdmin() ? null : teacherService.getTeacherByUserId(ClientUtils.getUserId());
|
|
if(teacher!=null){
|
hql.append(" and s.teacherId =?");
|
params.add(teacher.getTeacherId());
|
}
|
|
hql.append(" group by day(d.beginTime)");
|
|
return this.find(hql.toString(), params, Integer.class);
|
}
|
|
|
}
|
