From 16b4725365f3286c2d2a80945e26f35f89b53f24 Mon Sep 17 00:00:00 2001
From: fuliqi <fuliqi@qq.com>
Date: 星期五, 28 六月 2024 11:37:06 +0800
Subject: [PATCH] answer表改为score表,阅卷代码

---
 src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java |  560 ++++++++++++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 502 insertions(+), 58 deletions(-)

diff --git a/src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java b/src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java
index a73b531..43b3573 100644
--- a/src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java
+++ b/src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java
@@ -2,30 +2,49 @@
 
 import com.alibaba.fastjson2.JSON;
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ycl.jxkg.base.Result;
+import com.ycl.jxkg.base.SystemCode;
 import com.ycl.jxkg.context.WebContext;
 import com.ycl.jxkg.domain.entity.*;
+import com.ycl.jxkg.domain.exam.PaperFixQuestionDTO;
+import com.ycl.jxkg.domain.exam.PaperQuestionSettingDTO;
+import com.ycl.jxkg.domain.form.AddTimeForm;
+import com.ycl.jxkg.domain.form.ExamForm;
+import com.ycl.jxkg.domain.form.ForceSubmitForm;
+import com.ycl.jxkg.domain.query.ExamQuery;
+import com.ycl.jxkg.domain.question.QuestionObject;
 import com.ycl.jxkg.domain.vo.*;
+import com.ycl.jxkg.domain.vo.admin.exam.ExamPaperEditRequestVO;
+import com.ycl.jxkg.domain.vo.admin.exam.ExamPaperMarkAnswerVO;
+import com.ycl.jxkg.domain.vo.admin.exam.ExamPaperMarkVO;
+import com.ycl.jxkg.domain.vo.student.exam.ExamPaperReadVO;
+import com.ycl.jxkg.domain.vo.student.exam.ExamPaperSubmitVO;
+import com.ycl.jxkg.enums.DeductTypeEnum;
+import com.ycl.jxkg.enums.ExamPaperTypeEnum;
 import com.ycl.jxkg.enums.QuestionTypeEnum;
+import com.ycl.jxkg.enums.WebsocketCommendEnum;
 import com.ycl.jxkg.enums.general.ExamStatusEnum;
 import com.ycl.jxkg.enums.general.ExamSubmitTempStatusEnum;
 import com.ycl.jxkg.mapper.*;
+import com.ycl.jxkg.server.WebsocketServer;
+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.query.ExamQuery;
-import org.springframework.stereotype.Service;
-import lombok.RequiredArgsConstructor;
+import com.ycl.jxkg.utils.JsonUtil;
 import com.ycl.jxkg.utils.PageUtil;
+import lombok.RequiredArgsConstructor;
 import org.springframework.beans.BeanUtils;
+import org.springframework.context.annotation.Bean;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.stereotype.Service;
 import org.springframework.util.Assert;
 import org.springframework.util.StringUtils;
 
-import java.util.Date;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -44,6 +63,11 @@
     private final ExamSubmitTempMapper examSubmitTempMapper;
     private final ClassesUserMapper classesUserMapper;
     private final ExamPaperMapper examPaperMapper;
+    private final ExamPaperService examPaperService;
+    private final WebsocketServer websocketServer;
+    private final UserMapper userMapper;
+    private final ExamPaperScoreMapper examPaperScoreMapper;
+    private final ExamPaperScoreDetailMapper examPaperScoreDetailMapper;
 
     /**
      * 娣诲姞
@@ -110,18 +134,166 @@
     @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())) {
+            if (!StringUtils.hasText(item.getClassName())) {
                 item.setClassName("鐝骇涓嶅瓨鍦ㄦ垨琚垹闄�");
                 item.setClassesId(null);
             }
-            if (! StringUtils.hasText(item.getExamPaperName())) {
+            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
+    @Transactional(rollbackFor = Exception.class)
+    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("鑰冭瘯鏈粦瀹氳瘯鍗�");
+        }
+        if (ExamStatusEnum.NOT_START.equals(exam.getStatus())) {
+            throw new RuntimeException("鑰冭瘯杩樻湭寮�濮�");
+        }
+        if (ExamStatusEnum.FINISHED.equals(exam.getStatus())) {
+            throw new RuntimeException("鑰冭瘯宸茬粡缁撴潫");
+        }
+        // 鏌ュ嚭鑰冭瘯璇曞嵎
+        ExamPaper examPaper = examPaperMapper.selectById(exam.getExamPaperId());
+        if (Objects.isNull(examPaper)) {
+            throw new RuntimeException("璇曞嵎涓嶅瓨鍦�");
+        }
+        // 濡傛灉宸茬粡鍙傚姞杩囪�冭瘯锛岀洿鎺ヨ繑鍥炴暟鎹�
+        ExamSubmitTemp hasJoin = new LambdaQueryChainWrapper<>(examSubmitTempMapper)
+                .eq(ExamSubmitTemp::getExamId, id)
+                .eq(ExamSubmitTemp::getUserId, webContext.getCurrentUser().getId())
+                .one();
+        if (Objects.nonNull(hasJoin)) {
+            StartExamVO startExamVO = new StartExamVO();
+            startExamVO.setExamName(exam.getExamName());
+            startExamVO.setId(hasJoin.getExamId());
+            startExamVO.setTitleList(JSON.parseArray(hasJoin.getExamSubmit(), PaperFixQuestionVO.class));
+            startExamVO.setSuggestTime(examPaper.getSuggestTime());
+            startExamVO.setDoTime(hasJoin.getDoTime());
+            return Result.ok(startExamVO);
+        }
+        // 灏嗛鐩浆鎹负鍙复鏃朵繚瀛樼殑棰樼洰缁撴瀯銆傚浐瀹氳瘯鍗峰拰闅忓簭璇曞嵎鐨勯鐩槸鐩存帴淇濆瓨鍒癱ontent瀛楁鐨�
+        if (ExamPaperTypeEnum.Fixed.getCode().equals(examPaper.getPaperType())
+                || ExamPaperTypeEnum.RandomOrder.getCode().equals(examPaper.getPaperType())) {
+            if (StringUtils.hasText(examPaper.getContent())) {
+                throw new RuntimeException("璇曞嵎棰樼洰涓虹┖");
+            }
+            // 杞崲
+            List<PaperFixQuestionVO> data = this.coverTo(examPaper);
+            return Result.ok().data(data);
+        } else if (ExamPaperTypeEnum.Random.getCode().equals(examPaper.getPaperType())) {
+            // 鏍规嵁闅忔満璇曞嵎鐨勯厤缃紝闅忔満鐢熸垚瀵瑰簲棰樼洰
+            if (!StringUtils.hasText(examPaper.getContent())) {
+                throw new RuntimeException("璇曞嵎閰嶇疆寮傚父锛岃鑱旂郴鑰佸笀");
+            }
+            List<PaperQuestionSettingDTO> paperSettingList = JSON.parseArray(examPaper.getContent(), PaperQuestionSettingDTO.class);
+
+            // 璇曞嵎鍐呭
+            List<PaperFixQuestionVO> examData = new ArrayList<>(8);
+            for (PaperQuestionSettingDTO paperSetting : paperSettingList) {
+                PaperFixQuestionVO paperFixQuestionVO = new PaperFixQuestionVO();
+                paperFixQuestionVO.setTitle(paperSetting.getTitle());
+                paperFixQuestionVO.setQuestionType(paperSetting.getQuestionType());
+                // 鎷垮埌璇剧洰涓嬫煇绫婚鍨嬬殑x閬撻殢鏈洪
+                List<Question> questions = questionMapper.getRandomQuestion(examPaper.getSubjectId(), paperSetting.getQuestionType(), paperSetting.getNum());
+                if (paperSetting.getNum() > questions.size()) {
+                    throw new RuntimeException("閰嶇疆鐨勯鐩暟涓嶈冻浠ョ敓鎴愯瘯鍗�");
+                }
+                // 鎷垮埌棰樼洰鍚庣粍瑁呬负鍙复鏃朵繚瀛樼殑棰樼洰缁撴瀯
+                List<DoQuestionVO> childQuestions = questions.stream().map(item -> {
+                    DoQuestionVO doQuestionVO = new DoQuestionVO();
+                    doQuestionVO.setTitle(item.getTitle());
+                    doQuestionVO.setQuestionType(item.getQuestionType());
+                    if (StringUtils.hasText(item.getContent())) {
+                        QuestionObject questionObject = JSON.parseObject(item.getContent(), QuestionObject.class);
+                        doQuestionVO.setQuestionItemList(questionObject.getQuestionItemObjects());
+                    }
+                    doQuestionVO.setId(item.getId());
+                    doQuestionVO.setOriginalFile(item.getOriginalFile());
+                    doQuestionVO.setAudioFile(item.getAudioFile());
+                    return doQuestionVO;
+                }).collect(Collectors.toList());
+                paperFixQuestionVO.setQuestionList(childQuestions);
+                examData.add(paperFixQuestionVO);
+            }
+            ExamSubmitTemp examSubmitTemp = new ExamSubmitTemp();
+            examSubmitTemp.setExamId(id);
+            //TODO
+            examSubmitTemp.setStatus(ExamSubmitTempStatusEnum.temp);
+            examSubmitTemp.setExamSubmit(JSON.toJSONString(examData));
+            examSubmitTemp.setCreateTime(new Date());
+            examSubmitTemp.setUserId(webContext.getCurrentUser().getId());
+            //TODO
+            examSubmitTemp.setMarkPaperStatus(ExamSubmitTempStatusEnum.temp);
+            examSubmitTempMapper.insert(examSubmitTemp);
+            StartExamVO startExamVO = new StartExamVO();
+            startExamVO.setExamName(exam.getExamName());
+            startExamVO.setId(exam.getId());
+            startExamVO.setTitleList(examData);
+            startExamVO.setSuggestTime(examPaper.getSuggestTime());
+            return Result.ok(startExamVO);
+        }
+        return Result.ok();
+    }
+
+    /**
+     * 灏嗘暟鎹簱瀛樺偍鐨勯鐩紝杞负鍙复鏃朵繚瀛樼殑棰樼洰缁撴瀯
+     *
+     * @param examPaper 璇曞嵎
+     * @return
+     */
+    private List<PaperFixQuestionVO> coverTo(ExamPaper examPaper) {
+        if (!StringUtils.hasText(examPaper.getContent())) {
+            throw new RuntimeException("璇曞嵎鏈厤缃鐩紝璇疯仈绯昏�佸笀");
+        }
+        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());
+                // 濉┖棰橀渶瑕佹姽闄ontent(鍥犱负鏄瓟妗�)
+                if (QuestionTypeEnum.GapFilling.getCode().equals(doQuestionVO.getQuestionType())) {
+                    question.getItems().stream().forEach(option -> {
+                        option.setContent("");
+                    });
+                }
+                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());
     }
 
     /**
@@ -151,81 +323,105 @@
         return Result.ok().data(vos);
     }
 
+    /**
+     * 涓诲姩鎻愪氦璇曞嵎
+     *
+     * @param submitData 璇曞嵎鍋氶鎻愪氦鏁版嵁
+     * @return
+     */
     @Override
-    public Result examSubmit(ExamSubmitVO submitData) {
+    public Result examSubmit(StartExamVO submitData) {
         // 鏍¢獙
-        Exam exam = examMapper.selectById(submitData.getExamId());
+        Exam exam = examMapper.selectById(submitData.getId());
         if (Objects.isNull(exam)) {
             throw new RuntimeException("璇ヨ�冭瘯涓嶅瓨鍦�");
         }
-        // 鍒ゆ柇鍗曢�夈�佸閫夈�佸垽鏂瀵归敊
-        List<Integer> questionIds = submitData.getQuestionList().stream().map(DoQuestionVO::getId).collect(Collectors.toList());
-        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())) {
-                    // 濡傛灉鏄�夋嫨棰橈紝閭d箞灏嗙瓟妗堣浆涓簂ist
-                    List<String> answerList = JSON.parseArray(correct, String.class);
-                    item.setRight(answerList.containsAll(item.getAnswerList()));
-                } else {
-                    item.setRight(question.getCorrect().equals(item.getAnswer()));
-                }
-            }
-        });
+//        // 鍒ゆ柇鍗曢�夈�佸閫夈�佸垽鏂瀵归敊
+//        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())) {
+//                    // 濡傛灉鏄�夋嫨棰橈紝閭d箞灏嗙瓟妗堣浆涓簂ist
+//                    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
         // 鐜板湪鍙渶瑕佷繚瀛樺埌涓�寮犱复鏃惰〃
         // 璇ユ帴鍙f槸涓诲姩鎻愪氦锛屾墍浠ョ姸鎬侀兘璁剧疆涓哄畬鎴愶紝浠ヤ究鍚庣画鑰佸笀闃呭嵎
-        saveTempExam(submitData, ExamSubmitTempStatusEnum.FINISH);
-        return Result.ok();
-    }
-
-    @Override
-    public Result timingSubmit(ExamSubmitVO submitData) {
-        saveTempExam(submitData, ExamSubmitTempStatusEnum.TEMP);
+        //TODO
+        saveTempExam(submitData, ExamSubmitTempStatusEnum.finish);
         return Result.ok();
     }
 
     /**
-     * 淇濆瓨涓存椂璇曞嵎
+     * 涓存椂淇濆瓨璇曞嵎
      *
-     * @param submitData  鍓嶇浼犻�掔殑璇曞嵎鏁版嵁
-     * @param status  璇曞嵎鐨勭姸鎬�
+     * @param submitData
+     * @return
      */
-    public void saveTempExam(ExamSubmitVO submitData, ExamSubmitTempStatusEnum status) {
+    @Override
+    public Result timingSubmit(StartExamVO submitData) {
+        //TODO
+        saveTempExam(submitData, ExamSubmitTempStatusEnum.temp);
+        return Result.ok();
+    }
+
+    /**
+     * 淇濆瓨璇曞嵎锛氬鏋滄帴鍙f槸瀹氭椂淇濆瓨閭d箞鏄复鏃惰瘯鍗枫�傚鏋滄帴鍙f槸鑷富鎻愪氦閭d箞鏄畬鎴愯瘯鍗�
+     *
+     * @param submitData 鍓嶇浼犻�掔殑璇曞嵎鏁版嵁
+     * @param status     璇曞嵎鐨勭姸鎬�
+     */
+    public void saveTempExam(StartExamVO submitData, ExamSubmitTempStatusEnum status) {
         ExamSubmitTemp one = new LambdaQueryChainWrapper<>(examSubmitTempMapper)
-                .eq(ExamSubmitTemp::getExamId, submitData.getExamId())
+                .eq(ExamSubmitTemp::getExamId, submitData.getId())
                 .eq(ExamSubmitTemp::getUserId, webContext.getCurrentUser().getId())
+                .eq(ExamSubmitTemp::getDeleted,0)
                 .one();
+
         if (Objects.nonNull(one)) {
-            if (ExamSubmitTempStatusEnum.FINISH.equals(one.getStatus())) {
+            long doTimeL = one.getUpdateTime().getTime() - one.getCreateTime().getTime();
+            Integer doTime = (int) doTimeL;
+            //TODO
+            if (ExamSubmitTempStatusEnum.finish.equals(one.getStatus())) {
                 return;
             }
-            one.setDoTime(submitData.getDoTime());
-            one.setExamSubmit(JSON.toJSONString(submitData.getQuestionList()));
-            one.setCreateTime(new Date());
+            one.setDoTime(doTime);
+            one.setExamSubmit(JSON.toJSONString(submitData.getTitleList()));
+            one.setUpdateTime(new Date());
             one.setStatus(status);
             examSubmitTempMapper.updateById(one);
         } else {
             ExamSubmitTemp examSubmitTemp = new ExamSubmitTemp();
-            examSubmitTemp.setExamId(submitData.getExamId());
-            examSubmitTemp.setDoTime(submitData.getDoTime());
+            examSubmitTemp.setExamId(submitData.getId());
+            examSubmitTemp.setDoTime(0);
             examSubmitTemp.setStatus(status);
             examSubmitTemp.setUserId(webContext.getCurrentUser().getId());
-            examSubmitTemp.setExamSubmit(JSON.toJSONString(submitData.getQuestionList()));
-            examSubmitTemp.setMarkPaperStatus(ExamSubmitTempStatusEnum.TEMP);
+            examSubmitTemp.setExamSubmit(JSON.toJSONString(submitData.getTitleList()));
+            //TODO
+            examSubmitTemp.setMarkPaperStatus(ExamSubmitTempStatusEnum.temp);
             examSubmitTempMapper.insert(examSubmitTemp);
         }
     }
 
     @Override
-    public Result getMarkPaperInfo(Integer id) {
+    public Result getMarkResultInfo(Integer id) {
         Exam exam = baseMapper.selectById(id);
         if (Objects.isNull(exam)) {
             throw new RuntimeException("璇ヨ�冭瘯涓嶅瓨鍦�");
@@ -240,7 +436,8 @@
         // 鍙傝�冧汉鏁�
         Integer joinExamNum = examSubmitTempList.size();
         // 鍙傝�冧絾鏈畬鎴愭彁浜や汉鏁�
-        Integer joinButNotFinishedNum = Math.toIntExact(examSubmitTempList.stream().filter(item -> ExamSubmitTempStatusEnum.TEMP.equals(item.getStatus())).count());
+        //TODO
+        Integer joinButNotFinishedNum = Math.toIntExact(examSubmitTempList.stream().filter(item -> ExamSubmitTempStatusEnum.temp.equals(item.getStatus())).count());
 
         List<StudentExamInfoVO> studentExamList = classesUserMapper.getClassesUserList(exam.getClassesId());
         // 搴旇�冧汉鏁�
@@ -264,4 +461,251 @@
         markPaperVO.setSuggestTime(examPaper.getSuggestTime());
         return Result.ok().data(markPaperVO);
     }
+
+
+    @Override
+    public Result getMarkPaperInfo(Integer examId, Integer userId) {
+        //瀛︾敓绛旈琛�
+        ExamSubmitTemp userExam = new LambdaQueryChainWrapper<>(examSubmitTempMapper)
+                .eq(ExamSubmitTemp::getExamId, examId)
+                .eq(ExamSubmitTemp::getUserId, userId)
+                .one();
+        if (Objects.isNull(userExam)) {
+            throw new RuntimeException("璇ュ鍛樿�冭瘯璁板綍涓嶅瓨鍦�");
+        }
+        ExamVO exam = examMapper.getById(examId);
+        User student = userMapper.getUserById(userId);
+        //灏佽闃呭嵎鍩烘湰鏁版嵁
+        ExamPaperMarkVO paperMarkVO = createVO(userExam, exam, student);
+        //TODO:琛ュ厖棰樼洰绛旀銆佽В鏋�
+        List<PaperFixQuestionVO> titleItems = paperMarkVO.getTitleItems();
+        for (PaperFixQuestionVO titleItem : titleItems) {
+            for (DoQuestionVO doQuestionVO : titleItem.getQuestionList()) {
+
+            }
+        }
+        //闃呭嵎锛屽瑙傞鎵撳垎
+        Result InnerError = markPaper(paperMarkVO);
+        if (InnerError != null) return InnerError;
+
+        return Result.ok(paperMarkVO);
+    }
+    //鎻愪氦鎵规敼
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public Result submitMarkPaper(ExamPaperMarkVO examPaperMark) {
+        Integer userId = webContext.getCurrentUser().getId();
+        //鎻掑叆exam_paper_answer(鎴愮哗琛�)
+        ExamPaperScore examPaperScore = new ExamPaperScore();
+        BeanUtils.copyProperties(examPaperMark,examPaperScore);
+        examPaperScore.setUserScore(new BigDecimal(examPaperMark.getScore()));
+        examPaperScore.setPaperScore(new BigDecimal(examPaperMark.getTotalScore()));
+        examPaperScore.setJudgeUser(userId);
+        examPaperScore.setCreateUser(examPaperMark.getUserId());
+        examPaperScore.setAnswerTime(examPaperMark.getSubmitTime());
+        examPaperScore.setPaperContent(JSON.toJSONString(examPaperMark.getTitleItems()));
+        long questionCorrect =0;
+        long questionCount=0;
+        if(!CollectionUtils.isEmpty(examPaperMark.getAnswers())){
+            questionCorrect = examPaperMark.getAnswers().stream().filter(ExamPaperMarkAnswerVO::getRight).count();
+            questionCount = examPaperMark.getAnswers().size();
+        }
+        examPaperScore.setQuestionCorrect(Integer.valueOf(questionCorrect+""));
+        examPaperScore.setQuestionCount(Integer.valueOf(questionCount+""));
+        examPaperScoreMapper.insert(examPaperScore);
+        return Result.ok();
+    }
+
+    //闃呭嵎
+    private Result markPaper(ExamPaperMarkVO paperMarkVO) {
+        List<PaperFixQuestionVO> titleItems = paperMarkVO.getTitleItems();
+        //鍒濆鍖栭鐩簭鍙�
+        Integer num = 1;
+        List<ExamPaperMarkAnswerVO> answers = new ArrayList<>();
+        for (PaperFixQuestionVO titleItem : titleItems) {
+            for (DoQuestionVO doQuestionVO : titleItem.getQuestionList()) {
+                //鍑嗗棰樼洰搴忓彿渚涘墠绔烦杞娇鐢�
+                ExamPaperMarkAnswerVO answerVO = new ExamPaperMarkAnswerVO();
+                //鑾峰彇璇曞嵎绫诲瀷
+                Integer questionType = doQuestionVO.getQuestionType();
+                /* 濡傛灉鏄畝绛斻�佽绠椼�佸垎鏋愶紝涓嶈缃畆ight鍙缃鐩簭鍙� */
+                if (QuestionTypeEnum.ShortAnswer.getCode().equals(questionType) || QuestionTypeEnum.Calculate.getCode().equals(questionType) || QuestionTypeEnum.Analysis.getCode().equals(questionType)) {
+                    answerVO.setItemOrder(num);
+                    doQuestionVO.setItemOrder(num);
+                }
+                /* 濡傛灉鏄崟閫夈�佽闊炽�佸垽鏂�(鍒ゆ柇绛旀鏄疉銆丅) */
+                else if (QuestionTypeEnum.SingleChoice.getCode().equals(questionType) || QuestionTypeEnum.Audio.getCode().equals(questionType) || QuestionTypeEnum.TrueFalse.getCode().equals(questionType)) {
+                    answerVO.setItemOrder(num);
+                    doQuestionVO.setItemOrder(num);
+                    if (StringUtils.isEmpty(doQuestionVO.getQuestionAnswer())) {
+                        return Result.fail(SystemCode.InnerError.getCode(), doQuestionVO.getTitle() + ",姝ら鐩己灏戠瓟妗堬紝璇峰厛瀹屽杽");
+                    }
+                    trueOrFalse(doQuestionVO, answerVO, doQuestionVO.getQuestionAnswer().equals(doQuestionVO.getAnswer()));
+                }
+                /* 濡傛灉鏄閫� */
+                else if (QuestionTypeEnum.MultipleChoice.getCode().equals(questionType)) {
+                    answerVO.setItemOrder(num);
+                    doQuestionVO.setItemOrder(num);
+                    if (StringUtils.isEmpty(doQuestionVO.getQuestionAnswer())) {
+                        return Result.fail(SystemCode.InnerError.getCode(), doQuestionVO.getTitle() + ",姝ら鐩己灏戠瓟妗堬紝璇峰厛瀹屽杽");
+                    }
+                    //瀛︾敓绛旀
+                    List<String> answerList = doQuestionVO.getAnswerList();
+                    String questionAnswer = doQuestionVO.getQuestionAnswer();
+                    //棰樼洰绛旀
+                    List<String> questionAnswerList = Arrays.asList(questionAnswer.split(","));
+                    //瀛︾敓绛旀涓虹┖锛屽垽鏂负閿�
+                    if (CollectionUtils.isEmpty(answerList)) {
+                        trueOrFalse(doQuestionVO, answerVO, false);
+                        continue;
+                    }
+                    //绛旀鏁伴噺锛屼笉闇�瑕佽�冭檻椤哄簭
+                    int answerCount = answerList.size();
+                    Set<String> set1 = new HashSet<>(answerList);
+                    Set<String> set2 = new HashSet<>(questionAnswerList);
+                    //绛旀瀹屽叏涓�鑷达紝婊″垎
+                    if (set1.equals(set2)) {
+                        trueOrFalse(doQuestionVO, answerVO, true);
+                        continue;
+                    }
+                    if (paperMarkVO.getDeductType() == null) {
+                        return Result.fail(SystemCode.InnerError.getCode(), "璇曞嵎娌℃湁閰嶇疆澶氶�夊緱鍒嗙被鍨嬶紝璇疯仈绯荤鐞嗗憳");
+                    }
+                    //濡傛灉澶氶�夊緱鍒嗙被鍨嬩负 绛旈敊涓嶅緱鍒�
+                    if (Integer.valueOf(DeductTypeEnum.AllCorrect.getCode()).equals(paperMarkVO.getDeductType())) {
+                        trueOrFalse(doQuestionVO, answerVO, false);
+                    }
+                    //濡傛灉澶氶�夊緱鍒嗙被鍨嬩负 婕忛�夊緱鍥哄畾鍒嗗��,鍖呭惈閿欒閫夐」涓嶅緱鍒�
+                    else if (Integer.valueOf(DeductTypeEnum.PartCorrect.getCode()).equals(paperMarkVO.getDeductType())) {
+                        //瀛︾敓绛旀绉婚櫎鎵�鏈夋纭瓟妗堬紝濡傛灉杩樻湁鍏冪礌璇存槑鍖呭惈閿欒閫夐」
+                        answerList.removeAll(questionAnswerList);
+                        if (!CollectionUtils.isEmpty(answerList)) {
+                            trueOrFalse(doQuestionVO, answerVO, false);
+                        } else {
+                            answerVO.setRight(false);
+                            doQuestionVO.setRight(false);
+                            //婕忛�夊緱鍥哄畾鍒�
+                            doQuestionVO.setScore(paperMarkVO.getDeductScore());
+                        }
+                    }
+                    //濡傛灉澶氶�夊緱鍒嗙被鍨嬩负 姣忓涓�棰樺緱鐩稿簲鍒嗗��,鍖呭惈閿欒閫夐」涓嶅緱鍒�
+                    else if (Integer.valueOf(DeductTypeEnum.EachCorrect.getCode()).equals(paperMarkVO.getDeductType())) {
+                        //瀛︾敓绛旀绉婚櫎鎵�鏈夋纭瓟妗堬紝濡傛灉杩樻湁鍏冪礌璇存槑鍖呭惈閿欒閫夐」
+                        answerList.removeAll(questionAnswerList);
+                        if (!CollectionUtils.isEmpty(answerList)) {
+                            trueOrFalse(doQuestionVO, answerVO, false);
+                        } else {
+                            answerVO.setRight(false);
+                            doQuestionVO.setRight(false);
+                            //婕忛�夊緱鍒�
+                            doQuestionVO.setScore(paperMarkVO.getDeductScore().multiply(new BigDecimal(answerCount)));
+                        }
+                    }
+                }
+                /* 濡傛灉鏄~绌� */
+                else if (QuestionTypeEnum.GapFilling.getCode().equals(questionType)) {
+                    answerVO.setItemOrder(num);
+                    doQuestionVO.setItemOrder(num);
+                    if (StringUtils.isEmpty(doQuestionVO.getQuestionAnswer())) {
+                        return Result.fail(SystemCode.InnerError.getCode(), doQuestionVO.getTitle() + ",姝ら鐩己灏戠瓟妗堬紝璇峰厛瀹屽杽");
+                    }
+                    //瀛︾敓绛旀
+                    List<String> answerList = doQuestionVO.getAnswerList();
+                    String questionAnswer = doQuestionVO.getQuestionAnswer();
+                    //棰樼洰绛旀
+                    List<String> questionAnswerList = Arrays.asList(questionAnswer.split(","));
+                    //瀛︾敓绛旀涓虹┖锛屽垽鏂负閿�
+                    if (CollectionUtils.isEmpty(answerList)) {
+                        trueOrFalse(doQuestionVO, answerVO, false);
+                        continue;
+                    }
+                    //鎬荤┖鐨勬暟閲�
+                    int questionAnswerCount = questionAnswerList.size();
+                    //绛旀瀹屽叏涓�鑷达紝婊″垎
+                    if (answerList.equals(questionAnswerList)) {
+                        trueOrFalse(doQuestionVO, answerVO, true);
+                    } else {
+                        answerVO.setRight(false);
+                        doQuestionVO.setRight(false);
+                        //鍋氬鐨勬暟閲�,闇�瑕佹寜椤哄簭姣旇緝
+                        int count = 0;
+                        for (int i = 0; i < answerList.size(); i++) {
+                            if(answerList.get(i).equals(questionAnswerList.get(i))){
+                                count++;
+                            }
+                        }
+                        //杩欎釜棰樼殑鎬诲垎
+                        BigDecimal questionScore = doQuestionVO.getQuestionScore();
+                        //姣忎釜绌虹殑鍒嗘暟
+                        BigDecimal scoreEach = questionScore.divide(new BigDecimal(questionAnswerCount), 1, RoundingMode.DOWN);
+                        BigDecimal score = scoreEach.multiply(new BigDecimal(count));
+                        doQuestionVO.setScore(score);
+                    }
+
+                }
+                num++;
+                answers.add(answerVO);
+            }
+        }
+        paperMarkVO.setAnswers(answers);
+        return null;
+    }
+
+    //璁剧疆鍏ㄥ鎴栧叏閿�
+    private void trueOrFalse(DoQuestionVO doQuestionVO, ExamPaperMarkAnswerVO answerVO, Boolean isCorrect) {
+        if (isCorrect) {
+            //姝g‘
+            answerVO.setRight(isCorrect);
+            doQuestionVO.setRight(isCorrect);
+            doQuestionVO.setScore(doQuestionVO.getQuestionScore());
+        } else {
+            //閿欒
+            answerVO.setRight(isCorrect);
+            doQuestionVO.setRight(isCorrect);
+            doQuestionVO.setScore(BigDecimal.ZERO);
+        }
+    }
+
+    //灏佽闃呭嵎杩斿洖鏁版嵁
+    private ExamPaperMarkVO createVO(ExamSubmitTemp userExam, ExamVO exam, User student) {
+        ExamPaperMarkVO paperMarkVO = new ExamPaperMarkVO();
+        BeanUtils.copyProperties(userExam, paperMarkVO);
+        paperMarkVO.setPaperId(exam.getExamPaperId());
+        //TODO: 璇曞嵎鎬诲垎銆�(澶氶�夊緱鍒嗙被鍨嬨�佸閫夊緱鍒嗗垎鏁�)闇�瑕佸彇ExamSubmitTemp
+        paperMarkVO.setExamName(exam.getExamName());
+        paperMarkVO.setPaperType(exam.getExamPaperType());
+        paperMarkVO.setSubmitTime(userExam.getUpdateTime());
+        paperMarkVO.setUserName(student.getRealName());
+        paperMarkVO.setTitleItems(JSON.parseArray(userExam.getExamSubmit(), PaperFixQuestionVO.class));
+        paperMarkVO.setTotalScore("100");
+        paperMarkVO.setDeductType(DeductTypeEnum.AllCorrect.getCode());
+        paperMarkVO.setDeductScore(BigDecimal.ZERO);
+        return paperMarkVO;
+    }
+
+    @Override
+    public Result monitorList(ExamQuery query) {
+        IPage<ExamSubmitTempVO> page = PageUtil.getPage(query, ExamSubmitTempVO.class);
+        return Result.ok((examSubmitTempMapper.monitorList(page, query)));
+    }
+
+    @Override
+    public Result addTime(AddTimeForm form) {
+        WebsocketDataVO websocket = new WebsocketDataVO();
+        websocket.setCommend(WebsocketCommendEnum.DELAYED.getCommend());
+        websocket.setData(form);
+        // 鍙戦�亀ebsocket娑堟伅
+        websocketServer.sendOneMessage(form.getUserId(), JSON.toJSONString(form));
+        return Result.ok("鎿嶄綔鎴愬姛");
+    }
+
+    @Override
+    public Result forceSubmit(ForceSubmitForm form) {
+        WebsocketDataVO websocket = new WebsocketDataVO();
+        websocket.setCommend(WebsocketCommendEnum.FORCE_SUBMIT.getCommend());
+        websocket.setData(form);
+        // 鍙戦�亀ebsocket娑堟伅
+        websocketServer.sendOneMessage(form.getUserId(), JSON.toJSONString(form));
+        return Result.ok("鎿嶄綔鎴愬姛");
+    }
 }

--
Gitblit v1.8.0