From 093e995276b9057518b5bbcbc0da7983d7c775fb Mon Sep 17 00:00:00 2001 From: fuliqi <fuliqi@qq.com> Date: 星期五, 05 七月 2024 11:42:35 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/dev' into dev --- src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java | 15 ++++++++++++--- 1 files changed, 12 insertions(+), 3 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..c4c8bfa 100644 --- a/src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java +++ b/src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java @@ -10,6 +10,7 @@ import com.ycl.jxkg.base.Result; import com.ycl.jxkg.base.SystemCode; 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 +116,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("淇敼鎴愬姛"); } @@ -880,8 +881,13 @@ @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)); @@ -890,8 +896,11 @@ @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)); -- Gitblit v1.8.0