package com.gkhy.exam.system.service.impl;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.gkhy.exam.common.constant.CacheConstant;
|
import com.gkhy.exam.common.enums.ResourceTypeEnum;
|
import com.gkhy.exam.common.exception.ApiException;
|
import com.gkhy.exam.common.utils.RedisUtils;
|
import com.gkhy.exam.system.domain.*;
|
import com.gkhy.exam.system.domain.vo.StudentStudyPeriodVO;
|
import com.gkhy.exam.system.domain.vo.StudentStudyVO;
|
import com.gkhy.exam.system.mapper.ExCoursePhaseMapper;
|
import com.gkhy.exam.system.mapper.ExResourceMapper;
|
import com.gkhy.exam.system.mapper.ExStudentStudyMapper;
|
import com.gkhy.exam.system.service.ExCourseChapterService;
|
import com.gkhy.exam.system.service.ExStudentStudyService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.concurrent.TimeUnit;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 课程学习学习日志表 服务实现类
|
* </p>
|
*
|
* @author kzy
|
* @since 2024-06-06 13:53:17
|
*/
|
@Service
|
public class ExStudentStudyServiceImpl extends ServiceImpl<ExStudentStudyMapper, ExStudentStudy> implements ExStudentStudyService {
|
@Autowired
|
private ExCourseChapterService courseChapterService;
|
@Autowired
|
private ExCoursePhaseMapper coursePhaseMapper;
|
@Autowired
|
private ExResourceMapper resourceMapper;
|
@Autowired
|
private RedisUtils redisUtils;
|
|
@Override
|
public Long insertStudentStudy(ExStudentStudy studentStudy) {
|
int row=0;
|
ExStudentStudy existStudentStudy=baseMapper.selectStudyByObject(studentStudy);
|
if(existStudentStudy!=null){
|
studentStudy.setId(existStudentStudy.getId());
|
row=baseMapper.updateById(existStudentStudy);
|
}else{
|
row=baseMapper.insert(studentStudy);
|
}
|
if(row<1){
|
throw new ApiException("新增学习记录失败");
|
}
|
return studentStudy.getId();
|
}
|
|
@Override
|
public int deleteStudentStudyById(Long studyId) {
|
return baseMapper.deleteById(studyId);
|
}
|
|
@Override
|
public List<StudentStudyVO> selectStudyByPhaseAndStundentId(Long phaseId,Long studentId) {
|
ExCoursePhase coursePhase=coursePhaseMapper.selectById(phaseId);
|
Long courseId=coursePhase.getCourseId();
|
List<ExStudentStudy> studentStudyList= baseMapper.selectStudyByPhaseAndStudentId(phaseId,courseId,studentId);
|
Map<Long,ExStudentStudy> studentStudyMap=studentStudyList.stream().collect(Collectors.toMap(ExStudentStudy::getPeriodId, item->item));
|
List<ExCourseChapter> courseChapterList=courseChapterService.selectChapterByCourseId(courseId);
|
List<StudentStudyVO> studentStudyVOList=courseChapterList.stream().map(item ->{
|
StudentStudyVO studentStudyVO=new StudentStudyVO();
|
studentStudyVO.setChapterId(item.getId());
|
studentStudyVO.setCourseId(item.getCourseId());
|
studentStudyVO.setChapterName(item.getName());
|
List<StudentStudyPeriodVO> studentStudyPeriodVOList=new ArrayList<>();
|
for(ExCourseChapterPeriod courseChapterPeriod:item.getChapterPeriods()){
|
StudentStudyPeriodVO studentStudyPeriodVO=new StudentStudyPeriodVO();
|
studentStudyPeriodVO.setPeriodName(courseChapterPeriod.getName());
|
studentStudyPeriodVO.setPeriodId(courseChapterPeriod.getId());
|
studentStudyPeriodVO.setPeriod(courseChapterPeriod.getPeriod());
|
ExStudentStudy exStudentStudy=studentStudyMap.get(courseChapterPeriod.getId());
|
if(exStudentStudy!=null){
|
studentStudyPeriodVO.setProgress(exStudentStudy.getProgress());
|
studentStudyPeriodVO.setCreateTime(exStudentStudy.getCreateTime());
|
studentStudyPeriodVO.setUpdateTime(exStudentStudy.getUpdateTime());
|
studentStudyPeriodVO.setStudyId(exStudentStudy.getId());
|
}
|
studentStudyPeriodVOList.add(studentStudyPeriodVO);
|
}
|
studentStudyVO.setStudentStudyPeriodVOList(studentStudyPeriodVOList);
|
return studentStudyVO;
|
}).collect(Collectors.toList());
|
|
return studentStudyVOList;
|
}
|
|
@Override
|
public void progress(ExStudentStudy studentStudy) {
|
if(studentStudy.getPhaseId()==null||studentStudy.getPeriodId()==null||studentStudy.getStudentId()==null||studentStudy.getResourceId()==null){
|
throw new ApiException("参数传参错误");
|
}
|
ExResource resource=resourceMapper.selectById(studentStudy.getResourceId());
|
if (ResourceTypeEnum.AUDIO.getCode().equals(resource.getResourceType()) || ResourceTypeEnum.VIDEO.getCode().equals(resource.getResourceType())) {
|
// 音视频处理
|
if (new BigDecimal(resource.getResourceLength()).subtract(new BigDecimal(studentStudy.getCurrentDuration())).intValue() < 1) {
|
// 学习完成
|
completeStudy(studentStudy);
|
}
|
} else if (ResourceTypeEnum.DOC.getCode().equals(resource.getResourceType())) {
|
// 文档类型处理
|
if (studentStudy.getCurrentPage().compareTo(resource.getDocPage()) >= 0) {
|
// 学习完成
|
completeStudy(studentStudy);
|
}
|
}
|
redisUtils.set(CacheConstant.STUDY_PROCESS_KEY + studentStudy.getId(), studentStudy, 1, TimeUnit.DAYS);
|
}
|
|
private void completeStudy(ExStudentStudy studentStudy) {
|
studentStudy.setProgress(BigDecimal.valueOf(100));
|
// 更新观看记录
|
baseMapper.updateById(studentStudy);
|
}
|
}
|
