From 8546b3d285af4235a0ef615a0c6e89486ae2c806 Mon Sep 17 00:00:00 2001
From: fuliqi <fuliqi@qq.com>
Date: 星期四, 17 十月 2024 21:01:37 +0800
Subject: [PATCH] 达梦不支持value改为values

---
 src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java |  154 ++++++++++++++++++++++++++++++++++-----------------
 1 files changed, 102 insertions(+), 52 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 bd7cc38..904e0e2 100644
--- a/src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java
+++ b/src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java
@@ -9,7 +9,9 @@
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.ycl.jxkg.base.Result;
 import com.ycl.jxkg.base.SystemCode;
+import com.ycl.jxkg.constants.ExamScoreConstant;
 import com.ycl.jxkg.context.WebContext;
+import com.ycl.jxkg.domain.base.AbsVo;
 import com.ycl.jxkg.domain.entity.*;
 import com.ycl.jxkg.domain.exam.PaperFixQuestionDTO;
 import com.ycl.jxkg.domain.exam.PaperQuestion;
@@ -115,7 +117,7 @@
         entity.setStatus(ExamStatusEnum.getStatusByTime(form.getStartTime(), form.getEndTime(), null));
         // 濡傛灉淇敼鎴愬姛鍙戦�乵q娑堟伅
         if (baseMapper.updateById(entity) > 0) {
-            this.sendMQ(entity, entity.getUpdateVersion() + 1);
+            this.sendMQ(entity, entity.getUpdateVersion());
         }
         return Result.ok("淇敼鎴愬姛");
     }
@@ -248,6 +250,10 @@
                 .eq(ExamSubmitTemp::getUserId, webContext.getCurrentUser().getId())
                 .one();
         if (Objects.nonNull(hasJoin)) {
+            // 鍏佽鎻愪氦鍚庣户缁綔绛�
+//            if(ExamSubmitTempStatusEnum.finish.equals(hasJoin.getStatus())){
+//                throw new RuntimeException("鎮ㄥ凡鎻愪氦璇曞嵎锛岃鍕块噸澶嶄綔绛�");
+//            }
             StartExamVO startExamVO = new StartExamVO();
             startExamVO.setExamName(exam.getExamName());
             startExamVO.setId(hasJoin.getExamId());
@@ -372,6 +378,24 @@
                 doQuestionVO.setQuestionType(item.getQuestionType());
                 //澧炲姞棰樼洰鍒嗘暟
                 doQuestionVO.setQuestionScore(question.getScore());
+
+                // 棰樼洰鍓湰
+                QuestionAnswerCopyVO copy = new QuestionAnswerCopyVO();
+                copy.setId(question.getId());
+                copy.setAnalyze(question.getAnalyze());
+                copy.setDifficult(question.getDifficult());
+                //濉┖鐨勭瓟妗堝湪Json閲�
+                if (QuestionTypeEnum.GapFilling.getCode().equals(item.getQuestionType())) {
+                    List<String> gapAnswer = new ArrayList<>();
+                    for (QuestionItemObject questionItemObject : question.getItems()) {
+                        gapAnswer.add(questionItemObject.getContent());
+                    }
+                    copy.setCorrect(String.join(ANSWER_SPLIT, gapAnswer));
+                } else {
+                    copy.setCorrect(question.getCorrect());
+                }
+                questionAnswerCopyVOList.add(copy);
+
                 // 濉┖棰橀渶瑕佹姽闄ontent(鍥犱负鏄瓟妗�)
                 if (QuestionTypeEnum.GapFilling.getCode().equals(doQuestionVO.getQuestionType())) {
                     question.getItems().stream().forEach(option -> {
@@ -382,24 +406,6 @@
                 doQuestionVO.setId(question.getId());
                 doQuestionVO.setOriginalFile(question.getOriginalFile());
                 doQuestionVO.setAudioFile(question.getAudioFile());
-
-                // 棰樼洰鍓湰
-                QuestionAnswerCopyVO copy = new QuestionAnswerCopyVO();
-                copy.setId(question.getId());
-                copy.setAnalyze(question.getAnalyze());
-                copy.setDifficult(question.getDifficult());
-                //濉┖鐨勭瓟妗堝湪Json閲�
-                if (QuestionTypeEnum.GapFilling.getCode().equals(item.getQuestionType())) {
-                    List<String> gapAnswer = new ArrayList<>();
-                    for (QuestionItemObject questionItemObject : doQuestionVO.getQuestionItemList()) {
-                        gapAnswer.add(questionItemObject.getContent());
-                    }
-                    copy.setCorrect(String.join(ANSWER_SPLIT, gapAnswer));
-                } else {
-                    copy.setCorrect(question.getCorrect());
-                }
-                questionAnswerCopyVOList.add(copy);
-
                 return doQuestionVO;
             }).collect(Collectors.toList());
             if (ExamPaperTypeEnum.RandomOrder.getCode().equals(examPaper.getPaperType())) {
@@ -556,14 +562,21 @@
         for (StudentExamInfoVO studentExamInfoVO : studentExamList) {
             Integer userId = studentExamInfoVO.getUserId();
             Optional<ExamSubmitTemp> first = examSubmitTempList.stream().filter(examSubmitTemp -> examSubmitTemp.getUserId().equals(userId)).findFirst();
-            if(first.isPresent()){
+            if (first.isPresent()) {
                 ExamSubmitTemp examSubmitTemp = first.get();
                 studentExamInfoVO.setMarkPaperStatus(examSubmitTemp.getMarkPaperStatus());
                 studentExamInfoVO.setStatus(examSubmitTemp.getStatus());
                 studentExamInfoVO.setDoTime(examSubmitTemp.getDoTime());
-            }else {
-                studentExamInfoVO.setMarkPaperStatus(ExamSubmitTempStatusEnum.temp);
+            } else {
+                //涓嶅瓨鍦ㄨ�冭瘯璁板綍
                 studentExamInfoVO.setStatus(ExamSubmitTempStatusEnum.temp);
+                //鏍规嵁Score琛ㄥ垽鏂�
+                ExamPaperScore paperScore = examPaperScoreMapper.getByExamIdUserId(exam.getId(), userId);
+                if(paperScore==null) {
+                    studentExamInfoVO.setMarkPaperStatus(ExamSubmitTempStatusEnum.temp);
+                }else {
+                    studentExamInfoVO.setMarkPaperStatus(ExamSubmitTempStatusEnum.finish);
+                }
                 studentExamInfoVO.setDoTime(0);
             }
         }
@@ -584,20 +597,22 @@
 
     @Override
     public Result getMarkPaperInfo(Integer examId, Integer userId) {
+        User student = userMapper.getUserById(userId);
+        //濡傛灉宸茬粡闃呰繃鍗蜂簡锛屾煡鎴愮哗琛�
+        Result<ExamPaperMarkVO> paperMarkVO1 = checkHasJudge(examId, student);
+        if (paperMarkVO1 != null) return paperMarkVO1;
+
+        ExamVO exam = examMapper.getById(examId);
         //瀛︾敓绛旈琛�
         ExamSubmitTemp userExam = new LambdaQueryChainWrapper<>(examSubmitTempMapper)
                 .eq(ExamSubmitTemp::getExamId, examId)
                 .eq(ExamSubmitTemp::getUserId, userId)
                 .one();
         if (Objects.isNull(userExam)) {
-            throw new RuntimeException("璇ュ鍛樿�冭瘯璁板綍涓嶅瓨鍦�");
+            //缂鸿�冿紝瀛︾敓娌℃湁鍋氶淇℃伅
+            ExamPaperMarkVO paperMarkVO = createVO(null, exam, student);
+            return Result.ok(paperMarkVO);
         }
-        //濡傛灉宸茬粡闃呰繃鍗蜂簡锛屾煡鎴愮哗琛�
-        Result<ExamPaperMarkVO> paperMarkVO1 = checkHasJudge(examId, userId, userExam);
-        if (paperMarkVO1 != null) return paperMarkVO1;
-
-        User student = userMapper.getUserById(userId);
-        ExamVO exam = examMapper.getById(examId);
         //灏佽闃呭嵎鍩烘湰鏁版嵁
         ExamPaperMarkVO paperMarkVO = createVO(userExam, exam, student);
         List<QuestionAnswerCopyVO> answerList = JSONArray.parseArray(userExam.getQuestionAnswerCopy(), QuestionAnswerCopyVO.class);
@@ -628,16 +643,21 @@
     }
 
     //妫�鏌ユ槸鍚﹂槄鍗�
-    private Result<ExamPaperMarkVO> checkHasJudge(Integer examId, Integer userId, ExamSubmitTemp userExam) {
-        if (ExamSubmitTempStatusEnum.finish.equals(userExam.getMarkPaperStatus())) {
-            ExamPaperScore examPaperScore = examPaperScoreMapper.getByExamIdUserId(examId, userId);
+    private Result<ExamPaperMarkVO> checkHasJudge(Integer examId, User student) {
+        ExamPaperScore examPaperScore = examPaperScoreMapper.getByExamIdUserId(examId, student.getId());
+        if (examPaperScore != null) {
             ExamPaperMarkVO paperMarkVO = new ExamPaperMarkVO();
             BeanUtils.copyProperties(examPaperScore, paperMarkVO);
+            paperMarkVO.setUserName(student.getRealName());
             paperMarkVO.setTotalScore(examPaperScore.getTotalScore() + "");
             paperMarkVO.setScore(examPaperScore.getScore() + "");
-            List<PaperFixQuestionVO> paperFixQuestionVOS = JSONArray.parseArray(examPaperScore.getPaperContent(), PaperFixQuestionVO.class);
-            paperMarkVO.setTitleItems(paperFixQuestionVOS);
-            paperMarkVO.setNavbar(JSONArray.parseArray(examPaperScore.getNavbar(), ExamPaperMarkNavbarVO.class));
+            if (!StringUtils.isEmpty(examPaperScore.getPaperContent())) {
+                List<PaperFixQuestionVO> paperFixQuestionVOS = JSONArray.parseArray(examPaperScore.getPaperContent(), PaperFixQuestionVO.class);
+                paperMarkVO.setTitleItems(paperFixQuestionVOS);
+            }
+            if (!StringUtils.isEmpty(examPaperScore.getNavbar())) {
+                paperMarkVO.setNavbar(JSONArray.parseArray(examPaperScore.getNavbar(), ExamPaperMarkNavbarVO.class));
+            }
             return Result.ok(paperMarkVO);
         }
         return null;
@@ -815,16 +835,23 @@
 
     //灏佽闃呭嵎杩斿洖鏁版嵁
     private ExamPaperMarkVO createVO(ExamSubmitTemp userExam, ExamVO exam, User student) {
-        Integer paperId = exam.getExamPaperId();
-        ExamPaper examPaper = examPaperMapper.selectById(paperId);
         ExamPaperMarkVO paperMarkVO = new ExamPaperMarkVO();
-        BeanUtils.copyProperties(userExam, paperMarkVO);
-        paperMarkVO.setPaperId(exam.getExamPaperId());
-        paperMarkVO.setExamName(exam.getExamName());
-        paperMarkVO.setPaperType(exam.getExamPaperType());
-        paperMarkVO.setSubmitTime(userExam.getUpdateTime());
+        if (userExam != null) {
+            BeanUtils.copyProperties(userExam, paperMarkVO);
+            paperMarkVO.setSubmitTime(userExam.getUpdateTime());
+            paperMarkVO.setTitleItems(JSON.parseArray(userExam.getExamSubmit(), PaperFixQuestionVO.class));
+        } else {
+            //缂鸿�冿紝瀛︾敓娌℃湁鍋氶淇℃伅
+            paperMarkVO.setExamId(exam.getId());
+            paperMarkVO.setUserId(student.getId());
+            paperMarkVO.setScore(BigDecimal.ZERO + "");
+            paperMarkVO.setDoTime(0);
+        }
         paperMarkVO.setUserName(student.getRealName());
-        paperMarkVO.setTitleItems(JSON.parseArray(userExam.getExamSubmit(), PaperFixQuestionVO.class));
+        paperMarkVO.setExamName(exam.getExamName());
+        paperMarkVO.setPaperId(exam.getExamPaperId());
+        paperMarkVO.setPaperType(exam.getExamPaperType());
+        ExamPaper examPaper = examPaperMapper.selectById(exam.getExamPaperId());
         paperMarkVO.setTotalScore(examPaper.getScore() + "");
         paperMarkVO.setDeductType(examPaper.getDeductType());
         paperMarkVO.setDeductScore(examPaper.getDeductTypeScore());
@@ -843,13 +870,24 @@
         examPaperScore.setTotalScore(new BigDecimal(examPaperMark.getTotalScore()));
         examPaperScore.setJudgeUser(userId);
         examPaperScore.setJudgeTime(new Date());
-        examPaperScore.setPaperContent(JSON.toJSONString(examPaperMark.getTitleItems()));
-        examPaperScore.setNavbar(JSON.toJSONString(examPaperMark.getNavbar()));
+        if (!StringUtils.isEmpty(examPaperMark.getTitleItems())) {
+            examPaperScore.setPaperContent(JSON.toJSONString(examPaperMark.getTitleItems()));
+        }
+        if (!StringUtils.isEmpty(examPaperMark.getNavbar())) {
+            examPaperScore.setNavbar(JSON.toJSONString(examPaperMark.getNavbar()));
+        }
         long questionCorrect = 0;
         long questionCount = 0;
         if (!CollectionUtils.isEmpty(examPaperMark.getNavbar())) {
+            examPaperScore.setStatus(ExamScoreConstant.PRESENT);
             questionCorrect = examPaperMark.getNavbar().stream().filter(vo -> vo.getRight() != null && vo.getRight()).count();
             questionCount = examPaperMark.getNavbar().size();
+        } else {
+            //缂鸿�冩煡璇曞嵎閰嶇疆
+            Integer paperId = examPaperMark.getPaperId();
+            ExamPaper examPaper = examPaperMapper.selectById(paperId);
+            questionCount = examPaper.getNum();
+            examPaperScore.setStatus(ExamScoreConstant.ABSENT);
         }
         examPaperScore.setQuestionCorrect(Integer.valueOf(questionCorrect + ""));
         examPaperScore.setQuestionCount(Integer.valueOf(questionCount + ""));
@@ -865,8 +903,10 @@
                     .eq(ExamSubmitTemp::getExamId, examPaperMark.getExamId())
                     .eq(ExamSubmitTemp::getUserId, examPaperMark.getUserId())
                     .one();
-            userExam.setMarkPaperStatus(ExamSubmitTempStatusEnum.finish);
-            examSubmitTempMapper.updateById(userExam);
+            if (userExam != null) {
+                userExam.setMarkPaperStatus(ExamSubmitTempStatusEnum.finish);
+                examSubmitTempMapper.updateById(userExam);
+            }
         }
         return Result.ok();
     }
@@ -875,26 +915,36 @@
     @Override
     public Result monitorList(ExamQuery query) {
         IPage<ExamSubmitTempVO> page = PageUtil.getPage(query, ExamSubmitTempVO.class);
-        return Result.ok((examSubmitTempMapper.monitorList(page, query)));
+        IPage<ExamSubmitTempVO> vo = examSubmitTempMapper.monitorList(page, query);
+
+        return Result.ok(vo);
     }
 
     @Override
     public Result addTime(AddTimeForm form) {
+        if (!websocketServer.checkUserOnline(form.getUserId())) {
+            throw new RuntimeException("璇ュ鍛樹笉鍦ㄧ嚎锛屾棤娉曟墽琛岃鎿嶄綔");
+        }
         WebsocketDataVO websocket = new WebsocketDataVO();
-        websocket.setCommend(WebsocketCommendEnum.DELAYED.getCommend());
+        websocket.setCommend(WebsocketCommendEnum.DELAYED.getCommand());
+        BigDecimal sed = BigDecimal.valueOf(60).multiply(form.getAddTimeM());
+        form.setAddTimeM(sed);
         websocket.setData(form);
         // 鍙戦�亀ebsocket娑堟伅
-        websocketServer.sendOneMessage(form.getUserId(), JSON.toJSONString(form));
+        websocketServer.sendOneMessage(form.getUserId(), JSON.toJSONString(websocket));
         return Result.ok("鎿嶄綔鎴愬姛");
     }
 
     @Override
     public Result forceSubmit(ForceSubmitForm form) {
+        if (!websocketServer.checkUserOnline(form.getUserId())) {
+            throw new RuntimeException("璇ュ鍛樹笉鍦ㄧ嚎锛屾棤娉曟墽琛岃鎿嶄綔");
+        }
         WebsocketDataVO websocket = new WebsocketDataVO();
-        websocket.setCommend(WebsocketCommendEnum.FORCE_SUBMIT.getCommend());
+        websocket.setCommend(WebsocketCommendEnum.FORCE_SUBMIT.getCommand());
         websocket.setData(form);
         // 鍙戦�亀ebsocket娑堟伅
-        websocketServer.sendOneMessage(form.getUserId(), JSON.toJSONString(form));
+        websocketServer.sendOneMessage(form.getUserId(), JSON.toJSONString(websocket));
         return Result.ok("鎿嶄綔鎴愬姛");
     }
 }

--
Gitblit v1.8.0