处理班级试题作答详情和满分

sexam/src/main/java/com/xhkjedu/sexam/controller/exam/EBaseController.java

         return new ResultVo(0, "设置成功");
     }
 
+    /*
+     * 处理班级试题作答详情和满分
+     * @Param []
+     * @Author ywx
+     * @Date 2022/11/23 15:13
+     * @return com.xhkjedu.vo.ResultVo
+     **/
+    @PostMapping("/handle_answerjson")
+    public ResultVo handleAnswerjson() {
+        eReportGenerateService.handleAnswerjson();
+        return new ResultVo(0, "设置成功");
+    }
 }

sexam/src/main/java/com/xhkjedu/sexam/mapper/report/EReportGenerateMapper.java

 package com.xhkjedu.sexam.mapper.report;
 
+import com.xhkjedu.sexam.model.exam.EClass;
+import com.xhkjedu.sexam.model.reportclass.ERclassQuestion;
 import com.xhkjedu.sexam.model.reportstu.ERstudent;
 import org.apache.ibatis.annotations.Param;
 
 
     //根据考试id获取考试模式
     Integer getExamModeById(@Param("examid") Integer examid);
+
+    //获取未处理的学生作答情况
+    List<ERclassQuestion> listAnswerJson();
+
+    //获取复合题满分人数
+    Integer getFullscorenum(@Param("q") ERclassQuestion q);
+
+    //获取考试班级集合
+    List<EClass> listClassByExamIds(@Param("examids") List<Integer> examids);
+
+    //更新班级试题作答详情和满分
+    void updateClassQuestion(@Param("q") ERclassQuestion q);
 }

sexam/src/main/java/com/xhkjedu/sexam/model/reportclass/ERclassQuestion.java

 
     //违规学生
     private String badstujson;
+
+    //满分人数
+    private Integer fullscorenum;
 }

sexam/src/main/java/com/xhkjedu/sexam/service/report/EReportGenerateService.java

 import com.xhkjedu.sexam.mapper.reportclass.*;
 import com.xhkjedu.sexam.mapper.reportstu.*;
 import com.xhkjedu.sexam.mapper.system.UserMapper;
+import com.xhkjedu.sexam.model.exam.EClass;
 import com.xhkjedu.sexam.model.paperstudent.EPaperStudentQuestion;
 import com.xhkjedu.sexam.model.report.ERbase;
 import com.xhkjedu.sexam.model.report.ERrank;
 import com.xhkjedu.sexam.vo.report.ExamPaperClassVo;
 import com.xhkjedu.sexam.vo.system.UserVo;
 import com.xhkjedu.utils.N_Utils;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
  * @date 2022/8/8 10:04
  **/
 @Service
+@Slf4j
 public class EReportGenerateService {
     @Resource
     private EReportGenerateMapper eReportGenerateMapper;
         String key2 = "";
         String key3 = "";
 
-        for (int i = 0; i < classStu.size(); i++) {
+        Double qscore = q.getQscore();
+        int stunum = classStu.size();
+        for (int i = 0; i < stunum; i++) {
             EPaperStudentQuestion sq = classStu.get(i);
             String stuanswer = sq.getStuanswer();
             if (q.getCtype() == 1 || q.getCtype() == 2 || q.getCtype() == 4 || q.getCtype() == 5 || q.getCtype() == 6) {
                 if (i == 0) {
                     answermap = new LinkedHashMap<>();
                     //处理分数分段对应,用于分数段[0，50%）   [50%，80%）,  [80%，100%]
-                    score8 = ExamUtil.getScoreRateScore(q.getQscore(), 0.8);
-                    score5 = ExamUtil.getScoreRateScore(q.getQscore(), 0.5);
-                    String str10 = N_Utils.formatDouble(q.getQscore());
+                    score8 = ExamUtil.getScoreRateScore(qscore, 0.8);
+                    score5 = ExamUtil.getScoreRateScore(qscore, 0.5);
+                    String str10 = N_Utils.formatDouble(qscore);
                     String str8 = N_Utils.formatDouble(score8);
                     String str5 = N_Utils.formatDouble(score5);
                     key1 = str8 + "-" + str10;
             }
         }
 
+        List<Map> dafblist = new ArrayList<>();//答案分布
+        Map<String, Map> dafbmap = new HashMap<>();//答案分布
+        for (Map.Entry<String, List<Map>> entry : answermap.entrySet()) {
+            String key = entry.getKey();
+            List<Map> students = entry.getValue();
+            Map dafb = new HashMap();
+            int num = students.size();
+            dafb.put("students", students);
+            dafb.put("num", num);
+            dafb.put("numrate", N_Utils.getIntegerDivideAndMulitiply(num, stunum));
+            dafbmap.put(key, dafb);
+        }
+
         Map rtnmap = new HashMap();
-        rtnmap.put("answerlist", JSON.toJSONString(answermap));
+        rtnmap.put("answerlist", JSON.toJSONString(dafbmap));
+        long fullscorenum = classStu.stream().filter(c -> qscore.equals(c.getStuscore())).count();
+        rtnmap.put("fullscorenum", fullscorenum);
+        rtnmap.put("dafbjson", JSON.toJSONString(dafblist));
         rtnmap.put("goodlist", JSON.toJSONString(goodlist));
         rtnmap.put("badlist", JSON.toJSONString(badlist));
         rtnmap.put("erroroption",erroroption);
                         ercq.setGradesrate(qgsrate);
                         //处理单选题选项情况
                         Map stuansmap = setPaperQuestionsForStuAnswer(qcstulist);
+                        ercq.setFullscorenum(N_Utils.str2Int(stuansmap.get("fullscorenum").toString()));
                         ercq.setAnswerjson(stuansmap.get("answerlist").toString());
                         if(N_Utils.isNotEmpty(stuansmap.get("goodlist"))){
                             ercq.setGoodstujson(stuansmap.get("goodlist").toString());
                         ercq.setGradesrate(N_Utils.getDoubleDivideAndMulitiply(qgstuscore,qgscore));
                         //处理单选题选项情况
                         Map stuansmap = setPaperQuestionsForStuAnswer(qcstulist);
+                        ercq.setFullscorenum(N_Utils.str2Int(stuansmap.get("fullscorenum").toString()));
                         ercq.setAnswerjson(stuansmap.get("answerlist").toString());
                         if(N_Utils.isNotEmpty(stuansmap.get("goodlist"))){
                             ercq.setGoodstujson(stuansmap.get("goodlist").toString());
             }
         }
     }
+
+    //处理班级试题作答详情和满分
+    public void handleAnswerjson() {
+        List<ERclassQuestion> list = eReportGenerateMapper.listAnswerJson();//获取未处理的学生作答情况
+        List<Integer> examids = list.stream().map(l -> l.getExamid()).distinct().collect(Collectors.toList());
+        List<EClass> classes = eReportGenerateMapper.listClassByExamIds(examids);//获取考试班级集合
+        Map<String, Integer> classMap = classes.stream().collect(Collectors.toMap(
+                c -> c.getExamid() + "_" + c.getClassid(), c -> c.getClassnum()));
+        for (ERclassQuestion q : list) {
+            new Thread(()->{
+                try {
+                    updateClassQuestion(classMap, q);
+                }catch (Exception e){
+                    log.error("处理单个班级试题重试：" + e.getMessage());
+                    try {
+                        updateClassQuestion(classMap, q);
+                    }catch (Exception se){
+                        log.error("处理单个班级试题重试出错：" + se.getMessage());
+                    }
+                }
+            }).start();
+        }
+    }
+
+    //处理单个班级试题
+    private void updateClassQuestion(Map<String, Integer> classMap, ERclassQuestion q) {
+        if (N_Utils.isEmptyInteger(q.getEptqid())) {
+            Integer fullscorenum = eReportGenerateMapper.getFullscorenum(q);
+            q.setFullscorenum(fullscorenum);
+        }
+        Integer stunum = classMap.get(q.getExamid() + "_" + q.getClassid());
+        Map<String, Map> dafbmap = new HashMap<>();//答案分布
+        Map<String, List<Map>> answer = JSON.parseObject(q.getAnswerjson(), Map.class);
+        for (Map.Entry<String, List<Map>> entry : answer.entrySet()) {
+            String key = entry.getKey();
+            List<Map> students = entry.getValue();
+            int num = students.size();
+            Map dafb = new HashMap();
+            dafb.put("students", students);
+            dafb.put("num", num);
+            dafb.put("numrate", N_Utils.getIntegerDivideAndMulitiply(num, stunum));
+            dafbmap.put(key, dafb);
+        }
+        q.setAnswerjson(JSON.toJSONString(dafbmap));
+        eReportGenerateMapper.updateClassQuestion(q);
+    }
 }

sexam/src/main/resources/mapper/report/EReportClassMapper.xml

     <!--试卷概况-题库-->
     <select id="listTkSjGk" resultType="java.util.Map">
         select erq.qn,erq.qorder,erq.classavgscore,erq.classsrate,erq.gradeavgscore,erq.gradesrate,erq.classratetype
-        ,erq.answerjson,erq.goodstujson,erq.badstujson,erq.questionid,erq.eptqid,erq.complexity,erq.score
+        ,erq.answerjson,erq.fullscorenum,erq.goodstujson,erq.badstujson,erq.questionid,erq.eptqid,erq.complexity,erq.score
         from e_rclass_question erq
         where erq.examid=#{rank.examid} and erq.classid=#{rank.classid}
         and erq.subjectid=#{rank.subjectid}
     <!--试卷概况-附件-->
     <select id="listFjSjGk" resultType="java.util.Map">
         select erq.qn,erq.qorder,erq.classavgscore,erq.classsrate,erq.gradeavgscore,erq.gradesrate
-        ,erq.answerjson,erq.goodstujson,erq.badstujson,erq.eptqid,erq.classratetype
+        ,erq.answerjson,erq.fullscorenum,erq.goodstujson,erq.badstujson,erq.eptqid,erq.classratetype
         ,epqq.ctype,epqq.score,epqq.answer,epqq.qtypename,epqq.optionnum
         from e_rclass_question erq left join e_paper_qtype_question epqq on erq.eptqid = epqq.eptqid
         where erq.examid=#{rank.examid} and erq.classid=#{rank.classid}

sexam/src/main/resources/mapper/report/EReportGenerateMapper.xml

     <select id="getExamModeById" resultType="java.lang.Integer">
         select exammode from e_base where examid=#{examid}
     </select>
+    <!--获取未处理的学生作答情况-->
+    <select id="listAnswerJson" resultType="com.xhkjedu.sexam.model.reportclass.ERclassQuestion">
+        select q.answerjson,q.rcqid,q.examid,q.epid,q.classid,q.qn,q.score,q.eptqid
+        ,(case when q.eptqid is not null then (select count(*) from e_paper_student_question s
+        where s.eptqid=q.eptqid and s.qscore=s.stuscore)
+        else 0 end)fullscorenum
+        from e_rclass_question q where q.answerjson not like '%numrate%'
+    </select>
+    <!--获取复合题满分人数-->
+    <select id="getFullscorenum" resultType="java.lang.Integer">
+        select count(*) from(select sum(s.stuscore)sscore,s.studentid
+        from e_paper_student_question s where s.epid=#{q.epid} and find_in_set(s.qn,#{q.qn})
+        group by s.studentid )a where a.sscore=#{q.score}
+    </select>
+    <!--获取考试班级集合-->
+    <select id="listClassByExamIds" resultType="com.xhkjedu.sexam.model.exam.EClass">
+        select ec.classid,ec.classnum,ec.examid from e_class ec where ec.examid in
+        <foreach collection="examids" item="examid" open="(" separator="," close=")">#{examid}</foreach>
+    </select>
+    <!--更新班级试题作答详情和满分-->
+    <update id="updateClassQuestion">
+        update e_rclass_question set answerjson=#{q.answerjson},fullscorenum=#{q.fullscorenum} where rcqid=#{q.rcqid}
+    </update>
 </mapper>