blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xiangpei
2024-06-26 eaa622851fd5c701868518969ea51ec061b223b0 
 src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java


@@ -3,28 +3,34 @@


import com.alibaba.fastjson2.JSON;


import com.baomidou.mybatisplus.core.metadata.IPage;


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.context.WebContext;


import com.ycl.jxkg.domain.entity.*;


import com.ycl.jxkg.domain.entity.Exam;


import com.ycl.jxkg.domain.entity.ExamPaper;


import com.ycl.jxkg.domain.entity.ExamSubmitTemp;


import com.ycl.jxkg.domain.entity.Question;


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.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.PageUtil;


import lombok.RequiredArgsConstructor;


import org.springframework.beans.BeanUtils;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.stereotype.Service;


import org.springframework.util.Assert;


import org.springframework.util.StringUtils;




@@ -48,6 +54,7 @@


    private final ClassesUserMapper classesUserMapper;


    private final ExamPaperMapper examPaperMapper;


    private final ExamPaperService examPaperService;


    private final WebsocketServer websocketServer;




    /**


     * 添加


@@ -138,6 +145,7 @@






    @Override


    @Transactional(rollbackFor = Exception.class)


    public Result start(Integer id) {


        Exam exam = baseMapper.selectById(id);


        if (Objects.isNull(exam)) {


@@ -201,6 +209,14 @@


                paperFixQuestionVO.setQuestionList(childQuestions);


                examData.add(paperFixQuestionVO);


            }


            ExamSubmitTemp examSubmitTemp = new ExamSubmitTemp();


            examSubmitTemp.setExamId(id);


            examSubmitTemp.setStatus(ExamSubmitTempStatusEnum.TEMP);


            examSubmitTemp.setExamSubmit(JSON.toJSONString(examData));


            examSubmitTemp.setCreateTime(new Date());


            examSubmitTemp.setUserId(webContext.getCurrentUser().getId());


            examSubmitTemp.setMarkPaperStatus(ExamSubmitTempStatusEnum.TEMP);


            examSubmitTempMapper.insert(examSubmitTemp);


            return Result.ok(examData);


        }


        return Result.ok();


@@ -416,4 +432,30 @@


        }


        return Result.ok(vo);


    }




    @Override


    public Result monitorList(ExamQuery query) {


        IPage<ExamSubmitTempVO> page = PageUtil.getPage(query, ExamSubmitTempVO.class);


        return Result.ok().data(examSubmitTempMapper.monitorList(page, query));


    }




    @Override


    public Result addTime(AddTimeForm form) {


        WebsocketDataVO websocket = new WebsocketDataVO();


        websocket.setCommend(WebsocketCommendEnum.DELAYED.getCommend());


        websocket.setData(form);


        // 发送websocket消息


        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);


        // 发送websocket消息


        websocketServer.sendOneMessage(form.getUserId(), JSON.toJSONString(form));


        return Result.ok("操作成功");


    }


}