From 8d42b23c07433f11cb0b1e16d9c74b0e29fd35ce Mon Sep 17 00:00:00 2001 From: xiangpei <xiangpei@timesnew.cn> Date: 星期五, 05 七月 2024 09:57:42 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/dev' into dev --- src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java | 11 +++++++++-- 1 files changed, 9 insertions(+), 2 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 03ff2fa..d45c7e3 100644 --- a/src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java +++ b/src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java @@ -116,9 +116,8 @@ 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("淇敼鎴愬姛"); } @@ -882,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()); + BigDecimal sed = BigDecimal.valueOf(60).multiply(form.getAddTimeM()); + form.setAddTimeM(sed); websocket.setData(form); // 鍙戦�亀ebsocket娑堟伅 websocketServer.sendOneMessage(form.getUserId(), JSON.toJSONString(form)); @@ -892,6 +896,9 @@ @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.setData(form); -- Gitblit v1.8.0