package com.gkhy.exam.system.service.impl; import cn.hutool.core.util.ObjectUtil; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.gkhy.exam.common.api.CommonPage; import com.gkhy.exam.common.domain.entity.SysUser; import com.gkhy.exam.common.enums.QuestionTypeEnum; import com.gkhy.exam.common.enums.UserTypeEnum; import com.gkhy.exam.common.exception.ApiException; import com.gkhy.exam.common.utils.PageUtils; import com.gkhy.exam.common.utils.SecurityUtils; import com.gkhy.exam.system.domain.ExExamPaper; import com.gkhy.exam.system.domain.ExPaperStudent; import com.gkhy.exam.system.domain.ExPhaseStudent; import com.gkhy.exam.system.domain.ExStudent; import com.gkhy.exam.system.mapper.*; import com.gkhy.exam.system.service.ExPaperStudentService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.*; import java.util.stream.Collectors; /** *

* 学员与考试题目关系表 服务实现类 *

* * @author kzy * @since 2024-06-06 13:53:17 */ @Service public class ExPaperStudentServiceImpl extends ServiceImpl implements ExPaperStudentService { @Autowired private ExExamPaperMapper examPaperMapper; @Autowired private ExStudentAnswerMapper studentAnswerMapper; @Autowired private ExStudentMapper studentMapper; @Autowired private ExPhaseStudentMapper phaseStudentMapper; @Override public CommonPage selectPaperStudentListForStudent(ExPaperStudent paperStudent) { SysUser user= SecurityUtils.getLoginUser().getUser(); if(!Objects.equals(user.getUserType(), UserTypeEnum.STUDENT.getCode())){ throw new ApiException("非学员用户,不能查看"); } paperStudent.setStudentId(user.getId()); PageUtils.startPage(); List paperList=baseMapper.selectPaperStudentList(paperStudent); return CommonPage.restPage(paperList); } @Override public ExPaperStudent selectPaperStudentById(Long paperStudentId) { return baseMapper.selectPaperStudentById(paperStudentId); } @Override public ExPaperStudent selectPaperStudentById(ExPaperStudent paperStudent) { return baseMapper.selectByPaperStudentId(paperStudent); } @Override public int addPaperStudent(ExPaperStudent paperStudent) { checkUserAllowed(paperStudent); checkStudentUnique(Collections.singletonList(paperStudent)); paperStudent.setCreateId(SecurityUtils.getUserId()); int row=baseMapper.insert(paperStudent); if(row<1){ throw new ApiException("分配学员失败"); } return row; } @Override public int batchAddPaperStudent(Map paperStudentMap) { List phaseIds= (List) paperStudentMap.get("phaseIds"); List studentIds= (List) paperStudentMap.get("studentIds"); if(ObjectUtil.isEmpty(phaseIds) && ObjectUtil.isEmpty(studentIds)){ throw new ApiException("批次id与学员id不能同时为空"); } Long paperId= (Long) paperStudentMap.get("paperId"); if(paperId==null){ throw new ApiException("考卷id不能为空"); } //按批次绑定用户 if(phaseIds.size()>0){ List phaseStudentList=phaseStudentMapper.selectList( Wrappers.lambdaQuery() .in(ExPhaseStudent::getPhaseId, phaseIds)); studentIds=phaseStudentList.stream().map(item -> item.getStudentId()).distinct().collect(Collectors.toList()); } List paperStudents=studentIds.stream().map(item -> { return new ExPaperStudent().setPaperId(paperId).setStudentId(item); }).collect(Collectors.toList()); checkStudentUnique(paperStudents); int row=baseMapper.batchInsert(paperStudents); if(row<1){ throw new ApiException("批量分配学员失败"); } return row; } @Override public void checkStudentUnique(List paperStudents){ for(ExPaperStudent paperStudent:paperStudents) { Integer existCount = baseMapper.selectCountByPaperStudentId(paperStudent.getPaperId(), paperStudent.getStudentId()); if (existCount > 0) { ExStudent student = studentMapper.selectById(paperStudent.getStudentId()); throw new ApiException(String.format("待分配学员<%s>已存在", student.getName())); } } } @Override public CommonPage selectPaperStudentList(ExPaperStudent paperStudent) { if(paperStudent.getPaperId()==null){ throw new ApiException("考卷id不能为空"); } PageUtils.startPage(); List paperStudentList=baseMapper.selectPaperStudentList(paperStudent); return CommonPage.restPage(paperStudentList); } @Override public int deletePaperStudent(Long paperStudentId) { ExPaperStudent paperStudent=baseMapper.selectPaperStudentById(paperStudentId); if(ObjectUtil.isNull(paperStudent)){ throw new ApiException(String.format("该试卷下不存在该学员<>",paperStudent.getStudentName())); } checkUserAllowed(paperStudent); int studentAnswerCount=studentAnswerMapper.countByPaperId(paperStudent.getPaperId(),paperStudent.getStudentId()); if(studentAnswerCount>0){ throw new ApiException(String.format("学员<%s>已进行答题,不能删除",paperStudent.getStudentName())); } //删除学员与试卷关系 return baseMapper.deleteById(paperStudentId); } @Override @Transactional(rollbackFor = RuntimeException.class) public void batchDeletePaperStudent(List paperStudentIds) { for(Long paperStudentId:paperStudentIds){ deletePaperStudent(paperStudentId); } } public void checkUserAllowed(ExPaperStudent paperStudent) { SysUser currentUser= SecurityUtils.getLoginUser().getUser(); if(currentUser.getUserType().equals(UserTypeEnum.SYSTEM_USER.getCode())){ return; } if(currentUser.getUserType().equals(UserTypeEnum.STUDENT.getCode())){ throw new ApiException("没有权限操作"); } ExExamPaper examPaper=examPaperMapper.selectById(paperStudent.getPaperId()); if(!currentUser.getCompanyId().equals(examPaper.getCompanyId())){ throw new ApiException("没有权限操作其他企业考卷"); } } @Override public void endExam(ExPaperStudent paperStudent) { Long endTime=System.currentTimeMillis(); //异步计算 //计算考试成绩 ExExamPaper paper=examPaperMapper.selectById(paperStudent.getPaperId()); int singleCount=studentAnswerMapper.selectPassCount(paperStudent.getPaperId(),paperStudent.getStudentId(), QuestionTypeEnum.SINGLE.getCode()); int multiCount=studentAnswerMapper.selectPassCount(paperStudent.getPaperId(),paperStudent.getStudentId(), QuestionTypeEnum.MULTI.getCode()); int judgeCount=studentAnswerMapper.selectPassCount(paperStudent.getPaperId(),paperStudent.getStudentId(), QuestionTypeEnum.JUDGE.getCode()); int score=singleCount*paper.getSingleScore()+multiCount*paper.getMultiScore()+judgeCount*paper.getJudgeScore(); ExPaperStudent exPaperStudent = new ExPaperStudent() .setPaperId(paperStudent.getPaperId()) .setStudentId(paperStudent.getStudentId()) .setCompleted(1) .setEndTime(endTime) .setScore(score); if(score>=paper.getPassScore()){ exPaperStudent.setPassed(1); }else{ exPaperStudent.setPassed(0); } int row=baseMapper.updateById(exPaperStudent); if(row<1){ throw new ApiException("提交考试失败"); } } }