fuliqi
2024-06-18 c46f49af9e766aed0ba583fce0efab98ebcdf76c
src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java
@@ -1,23 +1,32 @@
package com.ycl.jxkg.service.impl;
import com.alibaba.fastjson2.JSON;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
import com.ycl.jxkg.context.WebContext;
import com.ycl.jxkg.domain.entity.Exam;
import com.ycl.jxkg.domain.entity.*;
import com.ycl.jxkg.domain.exam.PaperFixQuestionDTO;
import com.ycl.jxkg.domain.vo.*;
import com.ycl.jxkg.domain.vo.admin.exam.ExamPaperEditRequestVO;
import com.ycl.jxkg.enums.ExamPaperTypeEnum;
import com.ycl.jxkg.enums.QuestionTypeEnum;
import com.ycl.jxkg.enums.general.ExamStatusEnum;
import com.ycl.jxkg.mapper.ExamMapper;
import com.ycl.jxkg.enums.general.ExamSubmitTempStatusEnum;
import com.ycl.jxkg.mapper.*;
import com.ycl.jxkg.service.ExamPaperService;
import com.ycl.jxkg.service.ExamService;
import com.ycl.jxkg.base.Result;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ycl.jxkg.domain.form.ExamForm;
import com.ycl.jxkg.domain.vo.ExamVO;
import com.ycl.jxkg.domain.query.ExamQuery;
import org.springframework.stereotype.Service;
import lombok.RequiredArgsConstructor;
import com.ycl.jxkg.utils.PageUtil;
import org.springframework.beans.BeanUtils;
import org.springframework.util.Assert;
import org.springframework.util.StringUtils;
import java.util.List;
import java.util.*;
import java.util.stream.Collectors;
/**
@@ -32,9 +41,15 @@
    private final ExamMapper examMapper;
    private final WebContext webContext;
    private final QuestionMapper questionMapper;
    private final ExamSubmitTempMapper examSubmitTempMapper;
    private final ClassesUserMapper classesUserMapper;
    private final ExamPaperMapper examPaperMapper;
    private final ExamPaperService examPaperService;
    /**
     * 添加
     *
     * @param form
     * @return
     */
@@ -49,6 +64,7 @@
    /**
     * 修改
     *
     * @param form
     * @return
     */
@@ -65,6 +81,7 @@
    /**
     * 批量删除
     *
     * @param ids
     * @return
     */
@@ -76,6 +93,7 @@
    /**
     * id删除
     *
     * @param id
     * @return
     */
@@ -87,18 +105,100 @@
    /**
     * 分页查询
     *
     * @param query
     * @return
     */
    @Override
    public Result page(ExamQuery query) {
        IPage<ExamVO> page = PageUtil.getPage(query, ExamVO.class);
        baseMapper.getPage(page, query);
        baseMapper.getPage(page, query, webContext.getCurrentUser().getId());
        page.getRecords().stream().forEach(item -> {
            if (! StringUtils.hasText(item.getClassName())) {
                item.setClassName("班级不存在或被删除");
                item.setClassesId(null);
            }
            if (! StringUtils.hasText(item.getExamPaperName())) {
                item.setExamPaperName("试卷不存在或被删除");
                item.setExamPaperId(null);
            }
        });
        return Result.ok().data(page.getRecords()).total(page.getTotal());
    }
    @Override
    public Result studentPage(ExamQuery query) {
        IPage<ExamVO> page = PageUtil.getPage(query, ExamVO.class);
        baseMapper.studentPage(page, query, webContext.getCurrentUser().getId());
        return Result.ok().data(page.getRecords()).total(page.getTotal());
    }
    @Override
    public Result start(Integer id) {
        Exam exam = baseMapper.selectById(id);
        if (Objects.isNull(exam)) {
            throw new RuntimeException("该考试不存在");
        }
        if (Objects.isNull(exam.getExamPaperId())) {
            throw new RuntimeException("考试未绑定试卷");
        }
        // 查出考试试卷
        ExamPaper examPaper = examPaperMapper.selectById(exam.getExamPaperId());
        if (Objects.isNull(examPaper)) {
            throw new RuntimeException("试卷不存在");
        }
        if (StringUtils.hasText(examPaper.getContent())) {
            throw new RuntimeException("试卷题目为空");
        }
        // 将题目转换为可临时保存的题目结构
        if (ExamPaperTypeEnum.Fixed.getCode().equals(examPaper.getPaperType())
                || ExamPaperTypeEnum.RandomOrder.getCode().equals(examPaper.getPaperType())) {
            // 转换
            List<PaperFixQuestionVO> data = this.coverTo(examPaper);
            return Result.ok().data(data);
        } else if (ExamPaperTypeEnum.Random.getCode().equals(examPaper.getPaperType())) {
            // todo 随机题目生成
        }
        return null;
    }
    /**
     * 将数据库存储的题目,转为可临时保存的题目结构
     *
     * @param examPaper 试卷
     * @return
     */
    private List<PaperFixQuestionVO> coverTo(ExamPaper examPaper) {
        List<PaperFixQuestionDTO> questionWarpList = JSON.parseArray(examPaper.getContent(), PaperFixQuestionDTO.class);
        return questionWarpList.stream().map(item -> {
            PaperFixQuestionVO vo = new PaperFixQuestionVO();
            vo.setTitle(item.getTitle());
            vo.setQuestionType(item.getQuestionType());
            List<DoQuestionVO> doQuestionVOS = item.getQuestionList().stream().map(question -> {
                DoQuestionVO doQuestionVO = new DoQuestionVO();
                doQuestionVO.setTitle(question.getTitle());
                doQuestionVO.setQuestionType(item.getQuestionType());
                doQuestionVO.setQuestionItemList(question.getItems());
                doQuestionVO.setId(question.getId());
                doQuestionVO.setOriginalFile(question.getOriginalFile());
                doQuestionVO.setAudioFile(question.getAudioFile());
                return doQuestionVO;
            }).collect(Collectors.toList());
            if (ExamPaperTypeEnum.RandomOrder.getCode().equals(examPaper.getPaperType())) {
                // 随序试卷打乱顺序
                Collections.shuffle(doQuestionVOS);
            }
            vo.setQuestionList(doQuestionVOS);
            return vo;
        }).collect(Collectors.toList());
    }
    /**
     * 根据id查找
     *
     * @param id
     * @return
     */
@@ -111,6 +211,7 @@
    /**
     * 列表
     *
     * @return
     */
    @Override
@@ -121,4 +222,123 @@
                .collect(Collectors.toList());
        return Result.ok().data(vos);
    }
    @Override
    public Result examSubmit(ExamSubmitVO submitData) {
        // 校验
        Exam exam = examMapper.selectById(submitData.getExamId());
        if (Objects.isNull(exam)) {
            throw new RuntimeException("该考试不存在");
        }
//        // 判断单选、多选、判断题对错
//        List<Integer> questionIds = new ArrayList<>(24);
//        submitData.getPaperQuestionList().forEach(item -> {
//            List<Integer> ids = item.getQuestionList().stream().map(DoQuestionVO::getId).collect(Collectors.toList());
//            questionIds.addAll(ids);
//        });
//        List<Question> questionList = questionMapper.getAnswerInfo(questionIds);
//        Map<Integer, Question> answerMap = questionList.stream().collect(Collectors.toMap(Question::getId, entity -> entity));
//        submitData.getQuestionList().stream().forEach(item -> {
//            Question question = answerMap.get(item.getId());
//            if (Objects.nonNull(question)
//                    && (QuestionTypeEnum.SingleChoice.getCode().equals(question.getQuestionType())
//                    || QuestionTypeEnum.MultipleChoice.getCode().equals(question.getQuestionType())
//                    || QuestionTypeEnum.TrueFalse.getCode().equals(question.getQuestionType())
//            )) {
//                String correct = question.getCorrect();
//                if (QuestionTypeEnum.MultipleChoice.getCode().equals(question.getQuestionType())) {
//                    // 如果是选择题,那么将答案转为list
//                    List<String> answerList = JSON.parseArray(correct, String.class);
//                    item.setRight(answerList.containsAll(item.getAnswerList()));
//                } else {
//                    item.setRight(question.getCorrect().equals(item.getAnswer()));
//                }
//            }
//        });
        // 阅卷后才往exam_paper_answer保存考试成绩、以及保存到exam_paper_customer_answer
        // 现在只需要保存到一张临时表
        // 该接口是主动提交,所以状态都设置为完成,以便后续老师阅卷
        saveTempExam(submitData, ExamSubmitTempStatusEnum.FINISH);
        return Result.ok();
    }
    @Override
    public Result timingSubmit(ExamSubmitVO submitData) {
        saveTempExam(submitData, ExamSubmitTempStatusEnum.TEMP);
        return Result.ok();
    }
    /**
     * 保存临时试卷
     *
     * @param submitData  前端传递的试卷数据
     * @param status  试卷的状态
     */
    public void saveTempExam(ExamSubmitVO submitData, ExamSubmitTempStatusEnum status) {
        ExamSubmitTemp one = new LambdaQueryChainWrapper<>(examSubmitTempMapper)
                .eq(ExamSubmitTemp::getExamId, submitData.getExamId())
                .eq(ExamSubmitTemp::getUserId, webContext.getCurrentUser().getId())
                .one();
        if (Objects.nonNull(one)) {
            if (ExamSubmitTempStatusEnum.FINISH.equals(one.getStatus())) {
                return;
            }
            one.setDoTime(submitData.getDoTime());
            one.setExamSubmit(JSON.toJSONString(submitData.getPaperQuestionList()));
            one.setCreateTime(new Date());
            one.setStatus(status);
            examSubmitTempMapper.updateById(one);
        } else {
            ExamSubmitTemp examSubmitTemp = new ExamSubmitTemp();
            examSubmitTemp.setExamId(submitData.getExamId());
            examSubmitTemp.setDoTime(submitData.getDoTime());
            examSubmitTemp.setStatus(status);
            examSubmitTemp.setUserId(webContext.getCurrentUser().getId());
            examSubmitTemp.setExamSubmit(JSON.toJSONString(submitData.getPaperQuestionList()));
            examSubmitTemp.setMarkPaperStatus(ExamSubmitTempStatusEnum.TEMP);
            examSubmitTempMapper.insert(examSubmitTemp);
        }
    }
    @Override
    public Result getMarkPaperInfo(Integer id) {
        Exam exam = baseMapper.selectById(id);
        if (Objects.isNull(exam)) {
            throw new RuntimeException("该考试不存在");
        }
        ExamPaper examPaper = examPaperMapper.selectById(exam.getExamPaperId());
        if (Objects.isNull(examPaper)) {
            throw new RuntimeException("考试试卷不存在");
        }
        List<ExamSubmitTemp> examSubmitTempList = new LambdaQueryChainWrapper<>(examSubmitTempMapper)
                .eq(ExamSubmitTemp::getExamId, id)
                .list();
        // 参考人数
        Integer joinExamNum = examSubmitTempList.size();
        // 参考但未完成提交人数
        Integer joinButNotFinishedNum = Math.toIntExact(examSubmitTempList.stream().filter(item -> ExamSubmitTempStatusEnum.TEMP.equals(item.getStatus())).count());
        List<StudentExamInfoVO> studentExamList = classesUserMapper.getClassesUserList(exam.getClassesId());
        // 应考人数
        Integer shouldUserNum = studentExamList.size();
        studentExamList.stream().forEach(item -> {
            if (StringUtils.hasText(item.getExamSubmit())) {
                item.setQuestionList(JSON.parseArray(item.getExamSubmit(), DoQuestionVO.class));
            }
        });
        MarkPaperVO markPaperVO = new MarkPaperVO();
        markPaperVO.setExamName(exam.getExamName());
        markPaperVO.setExamId(exam.getId());
        markPaperVO.setJoinButNotFinishNum(joinButNotFinishedNum);
        markPaperVO.setShouldJoinNum(shouldUserNum);
        markPaperVO.setStudentExamInfoVOList(studentExamList);
        markPaperVO.setMissJoinNum(shouldUserNum - joinExamNum);
        markPaperVO.setJoinNum(joinExamNum);
        markPaperVO.setExamPaperName(examPaper.getName());
        markPaperVO.setSuggestTime(examPaper.getSuggestTime());
        return Result.ok().data(markPaperVO);
    }
}