补录成绩导入

sexam/pom.xml

@@ -74,6 +74,17 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-amqp</artifactId>
         </dependency>
+        <!--  导入和导出excel时需要的jar包 -->
+        <dependency>
+            <groupId>org.apache.poi</groupId>
+            <artifactId>poi-ooxml</artifactId>
+            <version>3.17</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.poi</groupId>
+            <artifactId>poi</artifactId>
+            <version>3.17</version>
+        </dependency>
     </dependencies>
     <dependencyManagement>
         <dependencies>

sexam/src/main/java/com/xhkjedu/sexam/controller/paperstudent/EPsqbatchController.java

@@ -13,6 +13,7 @@ import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
 
 import javax.annotation.Resource;
 import java.util.List;
@@ -60,7 +61,18 @@ public class EPsqbatchController {
         }
     }
 
-
+    /*
+     * 补录成绩导入
+     * @Param [file, batch]
+     * @Author ywx
+     * @Date 2022/11/21 15:14
+     * @return com.xhkjedu.vo.ResultVo
+     **/
+    @PostMapping("/import")
+    public ResultVo importRecord(MultipartFile file, EPsqbatch batch) {
+        N_Utils.validation(new Object[]{batch.getEpid(), "试卷id", 1, batch.getTeacherid(), "教师id", 1});
+        return ePsqbatchService.importRecord(file, batch);
+    }
 
 
 }

sexam/src/main/java/com/xhkjedu/sexam/mapper/exam/EClassStudentMapper.java

@@ -28,4 +28,7 @@ public interface EClassStudentMapper extends TkMapper<EClassStudent> {
 
     //批量生成学生pdf报告
     void updateBatchReportstupath(@Param("list")List<EClassStudent> list);
+
+    //考试学生列表
+    List<Map> listStuByExamId(@Param("examid") Integer examid);
 }

sexam/src/main/java/com/xhkjedu/sexam/mapper/paperstudent/EPaperStudentQuestionMapper.java

@@ -64,4 +64,7 @@ public interface EPaperStudentQuestionMapper extends TkMapper<EPaperStudentQuest
 
     //获取未合并图片考试模式列表
     List<Map> listExamByIds(@Param("examids") List<Integer> examids);
+
+    //获取学生试题列表
+    List<EPaperStudentQuestion> listQuestionByStu(@Param("studentid") Integer studentid,@Param("eptqids") List<Integer> eptqids);
 }

sexam/src/main/java/com/xhkjedu/sexam/model/paperstudent/EPsqbatch.java

@@ -17,7 +17,7 @@ public class EPsqbatch extends BaseBean {
     @Id
     private Integer batchid;
 
-    //扫描批次名称
+    //科目名称
     private String subjectname;
 
     //考试id

sexam/src/main/java/com/xhkjedu/sexam/model/paperstudent/EPsqbatchDetail.java

@@ -25,6 +25,7 @@ public class EPsqbatchDetail extends BaseBean {
 
     //试卷id
     private Integer epid;
+    private Integer eptqid;
 
     //学生试题id
     private Integer epsqid;

sexam/src/main/java/com/xhkjedu/sexam/service/paperstudent/EPsqbatchService.java

@@ -1,12 +1,27 @@
 package com.xhkjedu.sexam.service.paperstudent;
 
+import com.xhkjedu.sexam.mapper.exam.EClassStudentMapper;
+import com.xhkjedu.sexam.mapper.paper.EPaperQtypeQuestionMapper;
+import com.xhkjedu.sexam.mapper.paperstudent.EPaperStudentQuestionMapper;
 import com.xhkjedu.sexam.mapper.paperstudent.EPsqbatchMapper;
+import com.xhkjedu.sexam.model.paperstudent.EPaperStudentQuestion;
+import com.xhkjedu.sexam.model.paperstudent.EPsqbatch;
+import com.xhkjedu.sexam.model.paperstudent.EPsqbatchDetail;
+import com.xhkjedu.sexam.utils.PoiUtils;
+import com.xhkjedu.sexam.vo.paperstudent.EPsqbatchStuVo;
+import com.xhkjedu.utils.N_Utils;
+import com.xhkjedu.vo.ResultVo;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.interceptor.TransactionAspectSupport;
+import org.springframework.web.multipart.MultipartFile;
 
 import javax.annotation.Resource;
+import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 /**
  * @Description 学生试卷信息
@@ -18,6 +33,12 @@ import java.util.Map;
 public class EPsqbatchService {
     @Resource
     private EPsqbatchMapper ePsqbatchMapper;
+    @Resource
+    private EPaperQtypeQuestionMapper ePaperQtypeQuestionMapper;
+    @Resource
+    private EClassStudentMapper eClassStudentMapper;
+    @Resource
+    private EPaperStudentQuestionMapper ePaperStudentQuestionMapper;
 
     /**
      * @Description 获取考试科目
@@ -40,4 +61,74 @@ public class EPsqbatchService {
     public List<Map> listPsqBatchsByExamid(Integer exmaid){
         return ePsqbatchMapper.listPsqBatchsByExamid(exmaid);
     }
+
+    /*
+     * 补录成绩导入
+     * @Param [file, batch]
+     * @Author ywx
+     * @Date 2022/11/21 15:14
+     * @return com.xhkjedu.vo.ResultVo
+     **/
+    public ResultVo importRecord(MultipartFile file, EPsqbatch batch) {
+        Integer epid = batch.getEpid();
+        Integer examid = batch.getExamid();
+        List<Map> students = eClassStudentMapper.listStuByExamId(examid);//考试学生列表
+        List<Map> qns = ePaperQtypeQuestionMapper.listQnByEpid(epid);
+        try {
+            Map<String, Object> map = PoiUtils.readExcelRecord(file, qns, students);
+            Integer code = (Integer) map.get("code");
+            if (code != 0) return new ResultVo(1, map.get("msg").toString());
+            LinkedHashMap<Integer, List<String>> errMsg = (LinkedHashMap<Integer, List<String>>) map.get("errMsg");
+            if (errMsg.size() != 0) return new ResultVo(1, null, errMsg);
+            ePsqbatchMapper.insertUseGeneratedKeys(batch);
+            List<EPsqbatchStuVo> stus = (List<EPsqbatchStuVo>) map.get("stus");
+            for (EPsqbatchStuVo stu : stus) {
+                new Thread(()->{
+                    try {
+                        saveEPsqbatchDetail(stu,batch);
+                    }catch (Exception e){
+                        log.error("保存学生试题重试：" + e.getMessage());
+                        try {
+                            saveEPsqbatchDetail(stu,batch);
+                        }catch (Exception se){
+                            log.error("保存学生试题重试出错：" + se.getMessage());
+                        }
+                    }
+                }).start();
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return new ResultVo(0,"导入成功");
+    }
+
+    //保存学生试题
+    @Transactional(rollbackFor = Exception.class)
+    public void saveEPsqbatchDetail(EPsqbatchStuVo stu, EPsqbatch batch){
+        try {
+            int timestamp = N_Utils.getSecondTimestamp();
+            Integer batchId = batch.getId();
+            Integer teacherid = batch.getTeacherid();
+            Integer epid = batch.getEpid();
+            Integer studentid = stu.getStudentid();
+            List<EPsqbatchDetail> details = stu.getDetails();
+            //获取试卷中所有试题
+            List<Integer> eptqids = details.stream().map(d -> d.getEptqid()).collect(Collectors.toList());
+            List<EPaperStudentQuestion> questions = ePaperStudentQuestionMapper.listQuestionByStu(studentid,eptqids);
+            for (int i = 0; i < details.size(); i++) {
+                EPsqbatchDetail detail = details.get(i);
+                EPaperStudentQuestion question = questions.get(i);
+                question.setStuscore(detail.getNewscore());
+                detail.setStuscore(question.getStuscore());
+                detail.setEpid(epid);
+                detail.setBatchid(batchId);
+                detail.setTeacherid(teacherid);
+                detail.setCreatetime(timestamp);
+            }
+        } catch (Exception e) {
+            log.error("保存学生试题失败：" + e.getMessage());
+            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+            throw new RuntimeException("保存学生试题失败");
+        }
+    }
 }

sexam/src/main/java/com/xhkjedu/sexam/utils/PoiUtils.java

@@ -0,0 +1,271 @@
+package com.xhkjedu.sexam.utils;
+
+import com.xhkjedu.sexam.model.paperstudent.EPsqbatchDetail;
+import com.xhkjedu.sexam.vo.paperstudent.EPsqbatchStuVo;
+import com.xhkjedu.utils.N_Utils;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.poi.hssf.usermodel.HSSFWorkbook;
+import org.apache.poi.ss.usermodel.*;
+import org.apache.poi.xssf.usermodel.XSSFWorkbook;
+import org.springframework.stereotype.Component;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.InputStream;
+import java.text.DecimalFormat;
+import java.text.SimpleDateFormat;
+import java.util.*;
+import java.util.stream.Collectors;
+
+/**
+ * @author ywx
+ * @classname PoiUtils
+ * @description
+ * @date 2022-11-21 14:46:22
+ **/
+@Component
+@Slf4j
+public class PoiUtils {
+    //2003- 版本的excel
+    private final static String excel2003L = ".xls";
+    //2007+ 版本的excel
+    private final static String excel2007U = ".xlsx";
+
+    /**
+     * 导入教师
+     *
+     * @return java.util.Map<java.lang.String, java.lang.Object>
+     * @Param [file]
+     * @Author ywx
+     * @Date 2022/3/17 9:44
+     **/
+    public static Map<String, Object> readExcelRecord(MultipartFile file, List<Map> qns, List<Map> students) throws Exception {
+        Map<String, Object> resultMap = new HashMap<>();
+        Map<Integer, List<String>> errMsg = new LinkedHashMap<>();
+        try {
+            // 数据校验
+            isExcelEmpty(file);
+            InputStream in = file.getInputStream();
+            String fileName = file.getOriginalFilename();
+            Workbook work = getWorkbook(in, fileName);
+            Sheet sheet;// 分表数据
+            Row row;// 行数据
+            sheet = work.getSheetAt(0);//只取第一个sheet
+            if (sheet == null) {
+                throw new Exception("Excel第一个分表内容为空！");
+            }
+
+            int rows = sheet.getLastRowNum(); // 获取最后一个实际行的下标，比行数小1
+            int firstRowNum = sheet.getFirstRowNum(); // 获取第一个实际行的下标，（firstRowNum=0）
+            row = sheet.getRow(firstRowNum);//标题行
+            int firstCellNum = row.getFirstCellNum();
+            int lastCellNum = row.getLastCellNum();// 每一行的最后一列，获取列数，比最后一列列标大1
+            String qn = qns.stream().map(q -> q.get("qn").toString()).collect(Collectors.joining());
+            Map<Integer, Integer> questionMap = new HashMap<>();
+            Map<Integer, Double> scoreMap = new HashMap<>();
+            for (int i = 0; i < qns.size(); i++) {
+                questionMap.put(i + 2, (Integer) qns.get(i).get("eptqid"));
+                scoreMap.put(i + 2, (Double) qns.get(i).get("score"));
+            }
+            String titleName = "姓名账号" + qn;//标题格式
+            StringBuilder sb = new StringBuilder();
+            for (int y = firstCellNum; y < lastCellNum; y++) {
+                sb.append(row.getCell(y));
+            }
+            int maxIndex = lastCellNum - 1;//最大题号下标
+            String importTitleName = sb.toString();
+            if (!titleName.equals(importTitleName)) throw new Exception("标题格式不正确");
+
+            Map<String, Integer> stuMap = students.stream().collect(Collectors.toMap(
+                    s -> s.get("username").toString() + s.get("loginname").toString()
+                    , s -> (Integer) s.get("studentid")));
+
+            // 导入记录信息
+            List<EPsqbatchStuVo> stus = new ArrayList<>();
+
+            //遍历当前sheet中的所有行 排除第一行  第一行为标题头 不纳入遍历
+            for (int x = firstRowNum + 1; x <= rows; x++) {
+                // 获取行
+                row = sheet.getRow(x);
+                if (row == null) {//若此行为空，则跳出循环继续下一行
+                    continue;
+                } else if (isEmptyCell(row.getCell(0)) && isEmptyCell(row.getCell(1))) {
+                    continue;
+                }
+                firstCellNum = row.getFirstCellNum();// 每一行的第一列，（firstCellNum=0）
+                if (firstCellNum == 1) throw new Exception("第" + (x + 1) + "行姓名不能为空");
+                lastCellNum = row.getLastCellNum();// 每一行的最后一列，获取列数，比最后一列列标大1
+                List<String> mrows = new ArrayList<>();
+                //遍历所有的列
+                String username = getCellValue(row.getCell(0));//姓名
+                String loginname = getCellValue(row.getCell(1));//账号
+                Integer studentid = stuMap.get(username + loginname);
+                if (N_Utils.isEmptyInteger(studentid)) {
+                    mrows.add("第" + (x + 1) + "行学生【" + username + "（" + loginname + "）】不存在");
+                    continue;//学生不存在处理下一行
+                }
+                List<EPsqbatchDetail> details = new ArrayList<>();
+                for (int y = firstCellNum + 2; y < lastCellNum; y++) {
+                    Cell cell = row.getCell(y);
+                    String score = getCellValue(cell);
+                    if (N_Utils.isEmpty(score)) {
+                        continue;//学生分值为空处理下一列
+                    }
+                    EPsqbatchDetail detail = new EPsqbatchDetail();
+                    detail.setStudentid(studentid);
+                    Double stuscore = Double.valueOf(score);
+                    Double qscore = scoreMap.get(y);
+                    if (Double.compare(stuscore, qscore) == 1) {
+                        stuscore = qscore;
+                    }
+                    detail.setNewscore(stuscore);
+                    detail.setEptqid(questionMap.get(y));
+                    details.add(detail);
+                    if (y == maxIndex && N_Utils.isListNotEmpty(mrows)) {
+                        errMsg.put(x + 1, mrows);
+                    }
+                }
+                if (N_Utils.isListNotEmpty(details)) {
+                    EPsqbatchStuVo stu = new EPsqbatchStuVo();
+                    stu.setStudentid(studentid);
+                    stu.setDetails(details);
+                    stus.add(stu);
+                }
+            }
+
+            resultMap.put("code", 0);
+            resultMap.put("stus", stus);
+        } catch (Exception e) {
+            resultMap.put("code", 1);
+            String msg = e.getMessage();
+            resultMap.put("msg", msg);
+            if (msg.contains("Invalid ")) {
+                msg = "格式不正确";
+            }
+            throw new Exception(msg);
+        }
+        resultMap.put("errMsg", errMsg);
+        return resultMap;
+    }
+
+    /**
+     * 根据文件后缀，自适应上传文件的版本
+     *
+     * @return org.apache.poi.ss.usermodel.Workbook
+     * @Param [inStr, fileName]
+     * @Author ywx
+     * @Date 2020/6/3 16:42
+     **/
+    public static Workbook getWorkbook(InputStream inStr, String fileName) throws Exception {
+        Workbook wb;
+        String fileType = fileName.substring(fileName.lastIndexOf("."));
+        if (excel2003L.equals(fileType)) {
+            wb = new HSSFWorkbook(inStr);  //2003-
+        } else if (excel2007U.equals(fileType)) {
+            wb = new XSSFWorkbook(inStr);  //2007+
+        } else {
+            throw new Exception("Excel格式解析有误！");
+        }
+        return wb;
+    }
+
+    /**
+     * 判断单元格是否是空值
+     *
+     * @return java.lang.Boolean
+     * @Param [cell]
+     * @Author ywx
+     * @Date 2020/6/3 16:37
+     **/
+    public static Boolean isEmptyCell(Cell cell) {
+        if (cell != null) {
+            Boolean rtn = true;
+            if (N_Utils.isNotEmpty(PoiUtils.getCellValue(cell))) {
+                rtn = false;
+            }
+            return rtn;
+        } else {
+            return true;
+        }
+    }
+
+    /**
+     * 对表格中数值进行格式化
+     *
+     * @return java.lang.Object
+     * @Param [cell]
+     * @Author ywx
+     * @Date 2020/6/3 16:41
+     **/
+    public static String getCellValue(Cell cell) {
+        String value = null;
+        DecimalFormat df = new DecimalFormat("0");  //格式化number String字符
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");  //日期格式化
+        DecimalFormat df2 = new DecimalFormat("0");  //格式化数字
+        switch (cell.getCellTypeEnum()) {
+            case STRING:
+                value = cell.getRichStringCellValue().getString();
+                break;
+            case NUMERIC:
+                String cellStyle = cell.getCellStyle().getDataFormatString();
+                if ("General".equals(cellStyle)) {
+                    Double d = cell.getNumericCellValue();
+                    if (d.toString().contains("E")) {
+                        cell.setCellType(CellType.STRING);
+                        value = cell.getStringCellValue();
+                    } else {
+                        value = df.format(d);
+                    }
+                } else if ("m/d/yy".equals(cellStyle)) {
+                    value = sdf.format(cell.getDateCellValue());
+                } else {
+                    value = df2.format(cell.getNumericCellValue());
+                }
+                break;
+            case BOOLEAN:
+                boolean rtn = cell.getBooleanCellValue();
+                if (rtn) {
+                    value = "1";//真
+                } else {
+                    value = "0";//假
+                }
+                break;
+            case BLANK:
+                value = "";
+                break;
+            case FORMULA://读取excel公式的值
+                try {
+                    value = String.valueOf(cell.getNumericCellValue());
+                } catch (IllegalStateException e) {
+                    value = String.valueOf(cell.getRichStringCellValue());
+                }
+                break;
+            default:
+                break;
+        }
+        return N_Utils.strTrim(value);
+    }
+
+    /**
+     * 检验Excel内容是否为空
+     *
+     * @return void
+     * @Param [file]
+     * @Author ywx
+     * @Date 2020/6/3 16:36
+     **/
+    public static void isExcelEmpty(MultipartFile file) throws Exception {
+        if (null == file || file.isEmpty()) {
+            throw new Exception("文件不存在！");
+        }
+        InputStream in = file.getInputStream();
+        String fileName = file.getOriginalFilename();
+        Workbook work = getWorkbook(in, fileName);
+        if (null == work) {
+            throw new Exception("Excel内容为空！");
+        }
+        Integer sheet_size = work.getNumberOfSheets();
+        if (sheet_size == 0) {
+            throw new Exception("Excel内容为空！");
+        }
+    }
+}

sexam/src/main/java/com/xhkjedu/sexam/vo/paperstudent/EPsqbatchStuVo.java

@@ -0,0 +1,12 @@
+package com.xhkjedu.sexam.vo.paperstudent;
+
+import com.xhkjedu.sexam.model.paperstudent.EPsqbatchDetail;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class EPsqbatchStuVo {
+    private Integer studentid;//学生id
+    private List<EPsqbatchDetail> details;//试题集合
+}

sexam/src/main/resources/mapper/exam/EClassStudentMapper.xml

@@ -68,4 +68,10 @@
             studentid=#{item.studentid} and examid=#{item.examid}
         </foreach>
     </update>
+    <!--考试学生列表-->
+    <select id="listStuByExamId" resultType="java.util.Map">
+        select es.studentid,u.username,u.loginname
+        from e_class_student es left join t_user u on es.studentid = u.userid
+        where es.examid=#{examid}
+    </select>
 </mapper>

sexam/src/main/resources/mapper/paper/EPaperQtypeQuestionMapper.xml

@@ -72,7 +72,7 @@
     </select>
     <!--试卷中所有试题题号信息-->
     <select id="listQnByEpid" resultType="java.util.Map">
-        select eptqid,concat('第',qn,'题')qn
+        select eptqid,score,concat('第',qn,'题')qn
         from e_paper_qtype_question where epid=#{epid} order by qorder
     </select>
 

sexam/src/main/resources/mapper/paperstudent/EPaperStudentQuestionMapper.xml

@@ -230,5 +230,11 @@
     <select id="listStuQuestionsByEpsid" resultType="com.xhkjedu.sexam.model.paperstudent.EPaperStudentQuestion">
         select * from e_paper_student_question where epsid=#{epsid} order by epsqid
     </select>
-
+    <!--/获取学生试题列表-->
+    <select id="listQuestionByStu" resultType="com.xhkjedu.sexam.model.paperstudent.EPaperStudentQuestion">
+        select epsqid,eptqid,qn,stuscore
+        from e_paper_student_question where studentid=#{studentid} and eptqid in
+        <foreach collection="eptqids" item="eptqid" open="(" separator="," close=")">${eptqid}</foreach>
+        order by epsqid
+    </select>
 </mapper>