server/src/main/java/cn/com/qmth/scancentral/service/impl/StudentServiceImpl.java

package cn.com.qmth.scancentral.service.impl;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;

import javax.validation.constraints.NotNull;

import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.io.FileUtils;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.google.gson.Gson;
import com.qmth.boot.core.collection.PageResult;
import com.qmth.boot.core.concurrent.service.ConcurrentService;
import com.qmth.boot.core.exception.ParameterException;
import com.qmth.boot.core.exception.StatusException;
import com.qmth.boot.tools.excel.ExcelReader;
import com.qmth.boot.tools.excel.enums.ExcelType;
import com.qmth.boot.tools.uuid.FastUUID;

import cn.com.qmth.scancentral.bean.AbsentQueryDomain;
import cn.com.qmth.scancentral.bean.AnswerDeleteDomain;
import cn.com.qmth.scancentral.bean.AnswerQueryDomain;
import cn.com.qmth.scancentral.bean.AssignedQueryDomain;
import cn.com.qmth.scancentral.bean.ImportCetAbsentDomain;
import cn.com.qmth.scancentral.bean.ImportStudentDomain;
import cn.com.qmth.scancentral.bean.PageDeleteDomain;
import cn.com.qmth.scancentral.bean.User;
import cn.com.qmth.scancentral.bean.answersave.ArrayResult;
import cn.com.qmth.scancentral.bean.answersave.BoolResult;
import cn.com.qmth.scancentral.bean.answersave.StringResult;
import cn.com.qmth.scancentral.bean.omredit.OmrEditDomain;
import cn.com.qmth.scancentral.bean.omredit.OmrEditPaper;
import cn.com.qmth.scancentral.bean.omredit.OmrFieldEditDomain;
import cn.com.qmth.scancentral.bean.refix.AnswerRefixDomain;
import cn.com.qmth.scancentral.bean.refix.PageRefixDomain;
import cn.com.qmth.scancentral.bean.refix.PaperRefixDomain;
import cn.com.qmth.scancentral.config.SysProperty;
import cn.com.qmth.scancentral.consumer.BreachImportConsumer;
import cn.com.qmth.scancentral.consumer.CustStatusImportConsumer;
import cn.com.qmth.scancentral.dao.StudentDao;
import cn.com.qmth.scancentral.entity.AnswerCardEntity;
import cn.com.qmth.scancentral.entity.ExamEntity;
import cn.com.qmth.scancentral.entity.OmrGroupEntity;
import cn.com.qmth.scancentral.entity.PaperEntity;
import cn.com.qmth.scancentral.entity.PaperPageEntity;
import cn.com.qmth.scancentral.entity.QuestionEntity;
import cn.com.qmth.scancentral.entity.StudentEntity;
import cn.com.qmth.scancentral.entity.StudentPaperEntity;
import cn.com.qmth.scancentral.entity.SubjectEntity;
import cn.com.qmth.scancentral.entity.UserEntity;
import cn.com.qmth.scancentral.enums.AsyncTaskStatus;
import cn.com.qmth.scancentral.enums.ExamMode;
import cn.com.qmth.scancentral.enums.ExamStatus;
import cn.com.qmth.scancentral.enums.ExamStatusCheckMode;
import cn.com.qmth.scancentral.enums.GroupType;
import cn.com.qmth.scancentral.enums.ImageCheckStatus;
import cn.com.qmth.scancentral.enums.LockType;
import cn.com.qmth.scancentral.enums.OP;
import cn.com.qmth.scancentral.enums.OmrField;
import cn.com.qmth.scancentral.enums.Role;
import cn.com.qmth.scancentral.enums.ScanStatus;
import cn.com.qmth.scancentral.enums.UploadStatus;
import cn.com.qmth.scancentral.exception.NotFoundExceptions;
import cn.com.qmth.scancentral.exception.ParameterExceptions;
import cn.com.qmth.scancentral.model.ManualAbsentImportDTO;
import cn.com.qmth.scancentral.service.AnswerCardService;
import cn.com.qmth.scancentral.service.AnswerCardSubjectService;
import cn.com.qmth.scancentral.service.AssignedCheckHistoryService;
import cn.com.qmth.scancentral.service.AsyncTaskService;
import cn.com.qmth.scancentral.service.BatchService;
import cn.com.qmth.scancentral.service.ExamRoomService;
import cn.com.qmth.scancentral.service.ExamService;
import cn.com.qmth.scancentral.service.FileService;
import cn.com.qmth.scancentral.service.MarkSiteService;
import cn.com.qmth.scancentral.service.OmrGroupService;
import cn.com.qmth.scancentral.service.OmrTaskService;
import cn.com.qmth.scancentral.service.PaperPageService;
import cn.com.qmth.scancentral.service.PaperService;
import cn.com.qmth.scancentral.service.QuestionService;
import cn.com.qmth.scancentral.service.StudentPaperService;
import cn.com.qmth.scancentral.service.StudentService;
import cn.com.qmth.scancentral.service.SubjectService;
import cn.com.qmth.scancentral.service.ToolExportService;
import cn.com.qmth.scancentral.service.UserService;
import cn.com.qmth.scancentral.support.SpringContextHolder;
import cn.com.qmth.scancentral.support.TaskLock;
import cn.com.qmth.scancentral.support.TaskLockUtil;
import cn.com.qmth.scancentral.util.BatchGetDataUtil;
import cn.com.qmth.scancentral.util.BatchSetDataUtil;
import cn.com.qmth.scancentral.util.MD5Util;
import cn.com.qmth.scancentral.util.PageUtil;
import cn.com.qmth.scancentral.vo.AbsentInfoVo;
import cn.com.qmth.scancentral.vo.AbsentManualImportVo;
import cn.com.qmth.scancentral.vo.AbsentQueryVo;
import cn.com.qmth.scancentral.vo.AnswerDeleteVo;
import cn.com.qmth.scancentral.vo.AnswerExportK12Vo;
import cn.com.qmth.scancentral.vo.AnswerExportVo;
import cn.com.qmth.scancentral.vo.AnswerRefixVo;
import cn.com.qmth.scancentral.vo.ExportCetMarkingQueryVo;
import cn.com.qmth.scancentral.vo.ExportCetVo;
import cn.com.qmth.scancentral.vo.ImportStudentQueryVo;
import cn.com.qmth.scancentral.vo.ImportStudentVo;
import cn.com.qmth.scancentral.vo.PaperDeleteVo;
import cn.com.qmth.scancentral.vo.ScanAnswerInfoVo;
import cn.com.qmth.scancentral.vo.StudentUploadVo;
import cn.com.qmth.scancentral.vo.UpdateTimeVo;
import cn.com.qmth.scancentral.vo.answerquery.AnswerPageVo;
import cn.com.qmth.scancentral.vo.answerquery.AnswerPaperVo;
import cn.com.qmth.scancentral.vo.answerquery.AnswerQueryParam;
import cn.com.qmth.scancentral.vo.answerquery.AnswerQueryVo;
import cn.com.qmth.scancentral.vo.answerquery.StudentPaperVo;
import cn.com.qmth.scancentral.vo.assginedcheck.AssginedTaskResult;
import cn.com.qmth.scancentral.vo.assginedcheck.AssignedCheckExamRoomExport;
import cn.com.qmth.scancentral.vo.assginedcheck.AssignedCheckExport;
import cn.com.qmth.scancentral.vo.assginedcheck.AssignedTaskSaveVo;
import cn.com.qmth.scancentral.vo.asynctask.BreachAndStatusImportTaskVo;
import cn.com.qmth.scancentral.vo.asynctask.ExamStatusImportTaskVo;
import cn.com.qmth.scancentral.vo.asynctask.ExamStatusResetTaskVo;
import cn.com.qmth.scancentral.vo.paper.PaperCetVo;
import cn.com.qmth.scancentral.vo.paper.PaperPageCetVo;
import cn.com.qmth.scancentral.vo.student.StudentAnswerVo;
import cn.com.qmth.scancentral.vo.student.StudentExamRoomVo;
import cn.com.qmth.scancentral.vo.student.StudentPageQuery;
import cn.com.qmth.scancentral.vo.student.StudentPageVo;
import cn.com.qmth.scancentral.vo.student.StudentQuery;
import cn.com.qmth.scancentral.vo.student.StudentVo;
import cn.com.qmth.scancentral.vo.studentimport.StudentCountVo;
import cn.com.qmth.scancentral.vo.subject.SubjectScanProgressVo;
import cn.com.qmth.scancentral.vo.subject.TaskIdVo;
import cn.com.qmth.scancentral.vo.task.TaskStatusVo;

@Service
public class StudentServiceImpl extends ServiceImpl<StudentDao, StudentEntity> implements StudentService {

    private static final Logger log = LoggerFactory.getLogger(StudentService.class);

    private static ExecutorService exec;

    @Autowired
    private AsyncTaskService asyncTaskService;

    @Autowired
    private PaperService paperService;

    @Autowired
    private PaperPageService paperPageService;

    @Autowired
    private StudentPaperService studentPaperService;

    @Autowired
    private ExamService examService;

    @Autowired
    private SubjectService subjectService;

    @Autowired
    private BatchService batchService;

    @Autowired
    private AnswerCardService answerCardService;

    @Autowired
    private ConcurrentService concurrentService;

    @Autowired
    private OmrTaskService omrTaskService;

    @Autowired
    private OmrGroupService omrGroupService;

    @Autowired
    private QuestionService questionService;

    @Autowired
    private SysProperty sysProperty;

    @Autowired
    private ToolExportService toolExportService;

    @Autowired
    private AnswerCardSubjectService answerCardSubjectService;

    @Autowired
    private AssignedCheckHistoryService assignedCheckHistoryService;

    @Autowired
    private UserService userService;

    @Autowired
    private FileService fileService;

    @Autowired
    private MarkSiteService markSiteService;

    @Autowired
    private ExamRoomService examRoomService;
    static {
        int threadCount = 5;
        exec = new ThreadPoolExecutor(threadCount, threadCount, 0L, TimeUnit.SECONDS,
                new LinkedBlockingQueue<>(threadCount * 2), r -> {
                    Thread t = new Thread(r);
                    return t;
                }, (r, executor) -> {
                    if (!executor.isShutdown()) {
                        try {
                            executor.getQueue().put(r);
                        } catch (InterruptedException e) {
                            throw new RuntimeException(e);
                        }
                    }
                });
    }

    /**
     * 整体更新考生绑定的paper并刷新考生状态，若集合为空则表示考生无扫描结果，需要在外部调用处对考生上锁
     *
     * @param id
     * @param studentPaperList
     */
    @Override
    @Transactional
    // @Lockable(name = LockType.STUDENT, key = "#id")
    public void updateStudentAndPaper(@NotNull User user, @NotNull Long id,
            @NotNull List<StudentPaperEntity> studentPaperList) {
        for (StudentPaperEntity studentPaper : studentPaperList) {
            studentPaper.setStudentId(id);
        }
        // 清空原有绑定关系
        studentPaperService.removeByStudentId(id);
        // 保存绑定关系
        studentPaperService.saveOrUpdateBatchByMultiId(studentPaperList);
        // 更新考生状态
        updateStudentByPaper(user, id, true,true);
    }

    /**
     * 根据考生当前绑定的paper刷新考生状态，需要在外部调用处对考生上锁
     *
     * @param id
     */
    @Override
    @Transactional
    // @Lockable(name = LockType.STUDENT, key = "#id")
    public StudentEntity updateStudentByPaper(@NotNull User user, @NotNull Long id, @NotNull boolean updateOmrTask, boolean updateAssignedCount) {
        StudentEntity student = baseMapper.selectById(id);
        if (student == null) {
            throw new ParameterException("找不到对应的考生");
        }
        ExamEntity exam = examService.getById(student.getExamId());
        // 重置状态
        student.setIncomplete(false);
        student.setAssigned(false);
        student.setAssignedSuspect(false);
        student.setQuestionFilled(false);
        student.setSubjectiveFilled(false);
        student.setDevice(null);
        student.setCardNumber(null);
        student.setPaperType("#");
        student.setOmrAbsent(false);
        student.setExamStatus(ExamStatus.OK);
        int paperCount = 0;
        List<StudentPaperEntity> studentPaperList = studentPaperService.findByStudentId(id);
        int omrExamNumberCount = 0;
        for (StudentPaperEntity studentPaper : studentPaperList) {
            paperCount++;
            // 获取paper详情更新考生状态
            PaperEntity paper = paperService.getById(studentPaper.getPaperId());
            student.setAssigned(student.getAssigned() || paper.getAssigned());
            // student.setAssignedSuspect(student.getAssignedSuspect() ||
            // paper.getAssignedSuspect());
            student.setQuestionFilled(student.getQuestionFilled() || paper.getQuestionFilled());
            student.setSubjectiveFilled(student.getSubjectiveFilled() || paper.getSubjectiveFilled());
            student.setCardNumber(paper.getCardNumber());
            // 单独判断首张纸正面的识别结果
            if (studentPaper.getPaperNumber() == 1) {
                // 根据识别结果更新考生属性
                PaperPageEntity page = paperPageService.findPaperIdAndIndex(paper.getId(), 1);
                List<String> paperTypeBarcodeContents = markSiteService
                        .findPaperTypeBarcodeContentByExamAndSubjectCode(student.getExamId(), student.getSubjectCode());
                if (page.getPaperType() == null || page.getPaperType().getResult().length() == 0
                        || page.getPaperType().getResult().equals("#")) {
                    student.setPaperType("#");
                } else if (CollectionUtils.isNotEmpty(paperTypeBarcodeContents)
                        && !paperTypeBarcodeContents.contains(page.getPaperType().getResult())) {
                    student.setPaperType("?");
                } else {
                    student.setPaperType(page.getPaperType().getResult());
                }
                // student.setPaperType(page.getPaperType() != null ?
                // page.getPaperType().getResult() : "#");
                student.setOmrAbsent(page.getAbsent() == null ? false : page.getAbsent().getResult());
                student.setDevice(batchService.findByPaperId(paper.getId()).getDevice());
            }
            // 计算识别位数
            int paperExamNumberCount = paper.getOmrExamNumber().replace("#", "").length();
            if (omrExamNumberCount < paperExamNumberCount) {
                omrExamNumberCount = paperExamNumberCount;
            }
        }
        // 更新考生状态
        if (paperCount > 0) {
            AnswerCardEntity answerCard = answerCardService.findByExamAndNumber(student.getExamId(),
                    student.getCardNumber());
            student.setIncomplete(paperCount != answerCard.getPaperCount());
            student.setStatus(ScanStatus.SCANNED);
        } else {
            student.setStatus(ScanStatus.UNEXIST);
            student.setExamStatus(null);
        }
        // 更新缺考校验状态
        if (exam.getExamNumberFillCount() != null) {
            resetExamStatus(student, omrExamNumberCount, exam.getExamNumberFillCount());
        }
        student.setFileUploadStatus(UploadStatus.WAITING_UPLOAD);
        student.setImageCheckStatus(ImageCheckStatus.WAITING);
        student.setDataUploadStatus(UploadStatus.WAITING_UPLOAD);
        student.setUpdaterId(user.getId());
        student.setUpdateTime(System.currentTimeMillis());
        saveOrUpdate(student);
        // try {
        // SignatureInfo signatureInfo = new SignatureInfo(SignatureType.TOKEN,
        // user.getAccount(),
        // user.getMarkingCloudToken());
        // apiClient.studentFileDelete(signatureInfo.toString(),
        // student.getExamId(), student.getExamNumber());
        // } catch (RetrofitResponseError e) {
        // e.printStackTrace();
        // if (e.getCode() == 401) {
        // throw AuthorizationException.SIGNATURE_INVALID;
        // } else {
        // throw e;
        // }
        // }
        if (updateOmrTask) {
            // 遍历固定任务分组
            List<OmrGroupEntity> gs = omrGroupService.findByExamIdAndSubjectCode(student.getExamId(),
                    student.getSubjectCode());
            if (CollectionUtils.isNotEmpty(gs)) {
                for (OmrGroupEntity g : gs) {
                    concurrentService.getReadWriteLock(LockType.OMR_GROUP + "-" + g.getId()).readLock().lock();
                    omrTaskService.deleteByStudentIdAndGroupId(g.getId(), student.getId(),true);
                    // 默认分组重新生成识别对照任务，其他任务不生成
                    if (g.getFixed()) {
                        omrTaskService.saveTask(g, student.getId());
                    }
                    concurrentService.getReadWriteLock(LockType.OMR_GROUP + "-" + g.getId()).readLock().unlock();
                }
            }
        }
        if(updateAssignedCount){
            this.updateAssignedCheckCount(student.getId(), true);
        }
        return student;
    }

    @Override
    public Integer getStudentAnswerCount(Long examId) {
        if (examId == null) {
            throw new ParameterException("examId不能为空");
        }
        QueryWrapper<StudentEntity> queryWrapper = new QueryWrapper<>();
        queryWrapper.lambda().eq(StudentEntity::getExamId, examId);
        queryWrapper.lambda().eq(StudentEntity::getCheckMark, true);
        return this.count(queryWrapper);
    }

    @Override
    public StudentVo findOne(StudentQuery query) {
        Long examId = query.getExamId();
        String examNumber = query.getExamNumber();
        String subjectCode = query.getSubjectCode();
        if (StringUtils.isBlank(examNumber) || StringUtils.isBlank(subjectCode)) {
            throw new ParameterException("examNumber subjectCode不能都为空");
        }
        QueryWrapper<StudentEntity> queryWrapper = new QueryWrapper<>();
        queryWrapper.lambda().eq(StudentEntity::getExamId, examId);
        queryWrapper.lambda().eq(StudentEntity::getExamNumber, examNumber);
        queryWrapper.lambda().eq(StudentEntity::getSubjectCode, subjectCode);
        StudentEntity s = baseMapper.selectOne(queryWrapper);
        if (s == null) {
            throw new ParameterException("未找到考生");
        }
        StudentVo vo = StudentVo.of(s);
        SubjectEntity sub = subjectService.findByExamIdAndCode(examId, s.getSubjectCode());
        vo.setSubjectName(sub.getName());
        return vo;

    }

    @Override
    public int getCountByExam(Long examId) {
        QueryWrapper<StudentEntity> wrapper = new QueryWrapper<>();
        LambdaQueryWrapper<StudentEntity> lw = wrapper.lambda();
        lw.eq(StudentEntity::getExamId, examId);
        return this.count(wrapper);
    }

    @Override
    public int getPackageCountByExam(Long examId) {
        return baseMapper.getPackageCountByExam(examId);
    }

    @Override
    public int getCountByExamAndScanStatus(Long examId, ScanStatus status) {
        QueryWrapper<StudentEntity> wrapper = new QueryWrapper<>();
        LambdaQueryWrapper<StudentEntity> lw = wrapper.lambda();
        lw.eq(StudentEntity::getExamId, examId);
        lw.eq(StudentEntity::getStatus, status);
        return this.count(wrapper);
    }

    @Override
    public List<StudentVo> packageList(StudentQuery query) {
        List<StudentVo> ret = new ArrayList<>();
        StudentVo one = findOne(query);
        if (one != null) {
            List<StudentEntity> list = findByExamAndPackage(query.getExamId(), one.getPackageCode(),
                    one.getSubjectCode());
            if (CollectionUtils.isNotEmpty(list)) {
                for (StudentEntity e : list) {
                    StudentVo vo = StudentVo.of(e);
                    vo.setSubjectName(one.getSubjectName());
                    ret.add(vo);
                }
            }
        }
        return ret;
    }

    @Override
    public List<StudentEntity> findByExamAndPackage(Long examId, String packageCode, String subjectCode) {
        if (examId == null) {
            throw new ParameterException("examId 不能为空");
        }
        if (StringUtils.isBlank(packageCode)) {
            throw new ParameterException("packageCode不能为空");
        }
        QueryWrapper<StudentEntity> queryWrapper = new QueryWrapper<>();
        queryWrapper.lambda().eq(StudentEntity::getExamId, examId);
        queryWrapper.lambda().eq(StudentEntity::getPackageCode, packageCode);
        if (StringUtils.isNotBlank(subjectCode)) {
            queryWrapper.lambda().eq(StudentEntity::getSubjectCode, subjectCode);
        }
        return this.list(queryWrapper);
    }

    @Override
    public int getAssignedCountByExam(Long examId) {
        QueryWrapper<StudentEntity> wrapper = new QueryWrapper<>();
        LambdaQueryWrapper<StudentEntity> lw = wrapper.lambda();
        lw.eq(StudentEntity::getExamId, examId);
        lw.eq(StudentEntity::getAssigned, true);
        return this.count(wrapper);
    }

    @Override
    public int getUnscannedCountByExamAndSubject(Long examId, String subjectCode) {
        QueryWrapper<StudentEntity> wrapper = new QueryWrapper<>();
        LambdaQueryWrapper<StudentEntity> lw = wrapper.lambda();
        lw.eq(StudentEntity::getExamId, examId);
        lw.eq(StudentEntity::getSubjectCode, subjectCode);
        List<ScanStatus> ss = new ArrayList<>();
        ss.add(ScanStatus.MANUAL_ABSENT);
        ss.add(ScanStatus.UNEXIST);
        lw.in(StudentEntity::getStatus, ss);
        return this.count(wrapper);
    }

    @Override
    public int getAbsentSuspectCountByExam(Long examId) {
        QueryWrapper<StudentEntity> wrapper = new QueryWrapper<>();
        LambdaQueryWrapper<StudentEntity> lw = wrapper.lambda();
        lw.eq(StudentEntity::getExamId, examId);
        lw.eq(StudentEntity::getAbsentSuspect, true);
        return this.count(wrapper);
    }

    @Override
    public int getIncompleteCountByExam(Long examId) {
        QueryWrapper<StudentEntity> wrapper = new QueryWrapper<>();
        LambdaQueryWrapper<StudentEntity> lw = wrapper.lambda();
        lw.eq(StudentEntity::getExamId, examId);
        lw.eq(StudentEntity::getIncomplete, true);
        return this.count(wrapper);
    }

    @Override
    public AbsentInfoVo absentInfo(Long examId, GroupType groupType, String groupName) {
        AbsentInfoVo vo = baseMapper.absentInfo(examId, groupType != null ? groupType.getFieldName() : null,
                StringUtils.trimToNull(groupName));
        if (vo == null) {
            vo = new AbsentInfoVo();
        }
        return vo;
    }

    // private Integer totalCount(Long examId) {
    // QueryWrapper<StudentEntity> wrapper = new QueryWrapper<>();
    // LambdaQueryWrapper<StudentEntity> lw = wrapper.lambda();
    // lw.eq(StudentEntity::getExamId, examId);
    // return this.count(wrapper);
    // }
    //
    // private Integer countByStatus(Long examId, ScanStatus st) {
    // QueryWrapper<StudentEntity> wrapper = new QueryWrapper<>();
    // LambdaQueryWrapper<StudentEntity> lw = wrapper.lambda();
    // lw.eq(StudentEntity::getExamId, examId);
    // lw.eq(StudentEntity::getStatus, st);
    // return this.count(wrapper);
    // }
    //
    // private Integer countByAbsentSuspect(Long examId) {
    // QueryWrapper<StudentEntity> wrapper = new QueryWrapper<>();
    // LambdaQueryWrapper<StudentEntity> lw = wrapper.lambda();
    // lw.eq(StudentEntity::getExamId, examId);
    // lw.eq(StudentEntity::getAbsentSuspect, true);
    // return this.count(wrapper);
    // }
    //
    // private Integer countByIncomplete(Long examId) {
    // QueryWrapper<StudentEntity> wrapper = new QueryWrapper<>();
    // LambdaQueryWrapper<StudentEntity> lw = wrapper.lambda();
    // lw.eq(StudentEntity::getExamId, examId);
    // lw.eq(StudentEntity::getIncomplete, true);
    // return this.count(wrapper);
    // }

    @Override
    public PageResult<AbsentQueryVo> absentQuery(AbsentQueryDomain query) {
        IPage<AbsentQueryVo> iPage = baseMapper.absentQueryPage(new Page<>(query.getPageNumber(), query.getPageSize()),
                query.getGroupType().getFieldName(), query);
        return PageUtil.of(iPage);
    }

    @Override
    public List<String> absentSummary(AbsentQueryDomain query) {
        return baseMapper.absentQuerySummary(query.getGroupType().getFieldName(), query);
    }

    @Override
    public List<AbsentQueryVo> absentExportList(AbsentQueryDomain query) {
        return baseMapper.absentExportList(new Page<>(query.getPageNumber(), query.getPageSize()),
                query.getGroupType().getFieldName(), query);
    }

    @Transactional
    @Override
    public AbsentManualImportVo absentManualImport(Long examId, MultipartFile multipartFile) {
        List<ManualAbsentImportDTO> list = null;
        try {
            list = ExcelReader.create(ExcelType.XLSX, multipartFile.getInputStream(), 0)
                    .getObjectList(ManualAbsentImportDTO.class);
        } catch (IOException e) {
            throw new ParameterException("Excel解析出错", e);
        } catch (Exception e) {
            throw new ParameterException("Excel解析出错", e);
        }
        if (CollectionUtils.isEmpty(list)) {
            throw new ParameterException("Excel无内容");
        }

        // if (10001 < lineList.size()) {
        // throw new ParameterException("数据行数不能超过10000");
        // }

        int updateCount = 0;
        int ignoreCount = 0;
        int suspectCount = 0;
        for (ManualAbsentImportDTO data : list) {
            String examNumber = trimAndNullIfBlank(data.getExamNumber());
            String subjectCode = trimAndNullIfBlank(data.getSubjectCode());
            if (StringUtils.isBlank(examNumber)) {
                throw new ParameterException("examNumber不能为空");
            }
            if (StringUtils.isBlank(subjectCode)) {
                throw new ParameterException("科目代码不能为空");
            }
            StudentEntity student = this.findByExamAndSubjectCodeAndExamNumber(examId, subjectCode, examNumber);
            if (student == null) {
                throw new ParameterException("考生信息未找到:" + examNumber + ":" + subjectCode);
            }
            if (ScanStatus.MANUAL_ABSENT.equals(student.getStatus())) {
                ignoreCount++;
            } else if (ScanStatus.SCANNED.equals(student.getStatus())) {
                absentSuspectUpdate(student.getExamId(), student.getSubjectCode(), student.getExamNumber(), true);
                suspectCount++;
            } else {
                absentManualUpdate(student.getExamId(), student.getSubjectCode(), student.getExamNumber());
                updateCount++;
            }

        }
        AbsentManualImportVo vo = new AbsentManualImportVo();
        vo.setIgnoreCount(ignoreCount);
        vo.setUpdateCount(updateCount);
        vo.setSuspectCount(suspectCount);
        return vo;
    }

    private String trimAndNullIfBlank(String s) {
        if (StringUtils.isBlank(s)) {
            return null;
        }
        return s.trim();
    }

    @Transactional
    @Override
    public UpdateTimeVo absentManualUpdate(Long examId, String subjectCode, String examNumber) {
        StudentEntity student = this.findByExamAndSubjectCodeAndExamNumber(examId, subjectCode, examNumber);
        if (student == null) {
            throw new ParameterException("考生未找到:" + examNumber);
        }
        if (student.getStatus() != ScanStatus.UNEXIST) {
            throw new ParameterException("考生不是未扫描状态:" + examNumber);
        }
        LambdaUpdateWrapper<StudentEntity> lw = new LambdaUpdateWrapper<>();
        lw.set(StudentEntity::getStatus, ScanStatus.MANUAL_ABSENT);
        lw.set(StudentEntity::getDataUploadStatus, UploadStatus.WAITING_UPLOAD);
        lw.eq(StudentEntity::getId, student.getId());
        lw.eq(StudentEntity::getStatus, ScanStatus.UNEXIST);
        update(lw);
        return UpdateTimeVo.create();
    }

    @Transactional
    @Override
    public UpdateTimeVo absentSuspectUpdate(Long examId, String subjectCode, String examNumber, boolean enable) {
        StudentEntity student = this.findByExamAndSubjectCodeAndExamNumber(examId, subjectCode, examNumber);
        if (student == null) {
            throw new ParameterException("考生未找到:" + examNumber);
        }
        LambdaUpdateWrapper<StudentEntity> lw = new LambdaUpdateWrapper<>();
        lw.set(StudentEntity::getAbsentSuspect, enable);
        lw.set(StudentEntity::getDataUploadStatus, UploadStatus.WAITING_UPLOAD);
        lw.eq(StudentEntity::getId, student.getId());
        update(lw);
        return UpdateTimeVo.create();
    }

    @Override
    public ScanAnswerInfoVo scanAnswerInfo(Long examId) {
        return baseMapper.getInfoCountByExam(examId);
    }

    @Override
    public List<String> summary(AnswerQueryDomain query) {
        // 不分页查询考生准考证号
        return baseMapper.querySummary(query);
    }

    @Override
    public List<AnswerExportVo> exportList(AnswerQueryDomain query) {
        // 分页查询考生导出信息
        return baseMapper.exportList(new Page<>(query.getPageNumber(), query.getPageSize()), query);
    }

    @Override
    public List<AnswerExportK12Vo> exportListK12(AnswerQueryDomain query) {
        // 分页查询考生导出信息
        List<AnswerExportVo> list = baseMapper.exportList(new Page<>(query.getPageNumber(), query.getPageSize()),
                query);
        List<AnswerExportK12Vo> ret = new ArrayList<>();
        if (CollectionUtils.isNotEmpty(list)) {
            for (AnswerExportVo vo : list) {
                AnswerExportK12Vo kvo = new AnswerExportK12Vo();
                BeanUtils.copyProperties(vo, kvo);
                ret.add(kvo);
            }
        }
        return ret;
    }

    @Override
    public PageResult<AnswerQueryVo> query(AnswerQueryParam query) {
        // 查询考生分页信息
        IPage<AnswerQueryVo> iPage = baseMapper.queryPage(new Page<>(query.getPageNumber(), query.getPageSize()),
                query);
        if (CollectionUtils.isNotEmpty(iPage.getRecords())) {
            Map<Long, AnswerQueryVo> map = new HashMap<>();

            for (AnswerQueryVo vo : iPage.getRecords()) {
                List<AnswerPaperVo> papers = new ArrayList<>();
                vo.setPapers(papers);
                if (vo.getCardPaperCount() != null) {
                    for (int i = 1; i <= vo.getCardPaperCount(); i++) {
                        AnswerPaperVo pv = new AnswerPaperVo();
                        pv.setNumber(i);
                        papers.add(pv);
                    }
                }
                map.put(vo.getId(), vo);
            }
            // 根据考生id查找绑定paper
            List<Long> studentIds = iPage.getRecords().stream().map(p -> p.getId()).collect(Collectors.toList());
            List<StudentPaperVo> paperList = new BatchGetDataUtil<StudentPaperVo, Long>() {

                @Override
                public List<StudentPaperVo> getData(List<Long> paramList) {
                    return paperService.listByStudentIds(paramList);
                }
            }.getDataForBatch(studentIds, 20);

            if (CollectionUtils.isNotEmpty(paperList)) {
                Map<Long, AnswerPaperVo> paperMap = new HashMap<>();
                for (StudentPaperVo p : paperList) {
                    AnswerQueryVo vo = map.get(p.getStudentId());
                    if (vo == null) {
                        continue;
                    }
                    List<AnswerPaperVo> papers = vo.getPapers();
                    if (papers == null) {
                        continue;
                    }
                    if (papers.size() < p.getNumber()) {
                        continue;
                    }
                    AnswerPaperVo pvo = papers.get(p.getNumber() - 1);
                    pvo.setId(p.getPaperId());
                    pvo.setNumber(p.getNumber());
                    pvo.setAssigned(p.getAssigned());
                    paperMap.put(p.getPaperId(), pvo);
                }
                // 查找page
                List<Long> paperIds = paperList.stream().map(p -> p.getPaperId()).collect(Collectors.toList());
                List<PaperPageEntity> paperPageList = new BatchGetDataUtil<PaperPageEntity, Long>() {

                    @Override
                    public List<PaperPageEntity> getData(List<Long> paramList) {
                        return paperPageService.listByPaperList(paramList);
                    }
                }.getDataForBatch(paperIds, 20);

                if (CollectionUtils.isNotEmpty(paperPageList)) {
                    for (PaperPageEntity p : paperPageList) {
                        AnswerPaperVo pvo = paperMap.get(p.getPaperId());
                        if (pvo == null) {
                            continue;
                        }
                        List<AnswerPageVo> pages = pvo.getPages();
                        if (pages == null) {
                            pages = new ArrayList<>();
                            pvo.setPages(pages);
                        }
                        AnswerPageVo pageVo = new AnswerPageVo();
                        pageVo.setIndex(p.getPageIndex());
                        pageVo.setSheetUri(p.getSheetPath());
                        pageVo.setSliceUri(p.getSlicePath());
                        if (query.getWithOmrDetail() != null && query.getWithOmrDetail()) {
                            pageVo.setAbsent(p.getAbsent());
                            pageVo.setBreach(p.getBreach());
                            pageVo.setPaperType(p.getPaperType());
                            pageVo.setQuestion(p.getQuestion());
                            pageVo.setSelective(p.getSelective());
                            pageVo.setRecogData(p.getRecogData());
                        }
                        pages.add(pageVo);
                    }
                }
            }
        }
        return PageUtil.of(iPage);
    }

    @Transactional
    @Override
    public void updateFileUploadStatus(@NotNull Long id, @NotNull UploadStatus status) {
        LambdaUpdateWrapper<StudentEntity> lw = new LambdaUpdateWrapper<>();
        lw.set(StudentEntity::getFileUploadStatus, status);
        lw.eq(StudentEntity::getId, id);
        update(lw);
    }

    @Transactional
    @Override
    public void updateOmrAbsent(@NotNull Long id, @NotNull Boolean omrAbsent) {
        LambdaUpdateWrapper<StudentEntity> lw = new LambdaUpdateWrapper<>();
        lw.set(StudentEntity::getOmrAbsent, omrAbsent);
        lw.eq(StudentEntity::getId, id);
        update(lw);
    }

    @Transactional
    @Override
    public void deletetByExamIdAndUnCreateTime(Long examId, long createTime) {
        QueryWrapper<StudentEntity> wrapper = new QueryWrapper<>();
        LambdaQueryWrapper<StudentEntity> lw = wrapper.lambda();
        lw.eq(StudentEntity::getExamId, examId);
        lw.ne(StudentEntity::getCreateTime, createTime);
        this.baseMapper.delete(wrapper);
    }

    @Override
    public boolean existUploadData() {
        return CollectionUtils.isNotEmpty(baseMapper.findToUpload(1))
                || CollectionUtils.isNotEmpty(baseMapper.findUploadError(1));
    }

    @Override
    public List<StudentUploadVo> findToUpload(int pageSize) {
        if (pageSize <= 0) {
            pageSize = 100;
        }
        List<StudentUploadVo> result = baseMapper.findToUpload(pageSize);
        if (CollectionUtils.isEmpty(result)) {
            result = baseMapper.findUploadError(pageSize);
        }
        return result;
    }

    @Override
    public int getCountByExamAndCardNumber(Long examId, Integer number) {
        QueryWrapper<StudentEntity> wrapper = new QueryWrapper<>();
        LambdaQueryWrapper<StudentEntity> lw = wrapper.lambda();
        lw.eq(StudentEntity::getExamId, examId);
        lw.eq(StudentEntity::getCardNumber, number);
        return this.count(wrapper);
    }

    @Transactional
    @Override
    public int importStudent(List<ImportStudentDomain> students) {
        List<StudentEntity> savelist = new ArrayList<StudentEntity>();
        List<StudentEntity> updatelist = new ArrayList<StudentEntity>();
        // Map<Long,Map<String, StudentEntity>> map =new HashMap<Long,
        // Map<String,StudentEntity>>();
        for (ImportStudentDomain domain : students) {
            // Map<String, StudentEntity> examMap =map.get(domain.getExamId());
            // if(examMap ==null) {
            // examMap = new HashMap<String, StudentEntity>();
            // List<StudentEntity> list2 = this.list();
            // for (StudentEntity s : list2) {
            // examMap.put(s.getExamNumber(), s);
            // }
            // map.put(domain.getExamId(), examMap);
            // }
            // StudentEntity entity = examMap.get(domain.getExamNumber());
            StudentEntity entity = this.findByExamAndSubjectCodeAndExamNumber(domain.getExamId(),
                    domain.getSubjectCode(), domain.getExamNumber());
            if (entity == null) {
                entity = this.findByExamAndSubjectCodeAndExamNumber(domain.getExamId(), domain.getSubjectCode(),
                        domain.getExamNumber());
            }
            if (entity == null) {
                entity = new StudentEntity();
                entity.setStatus(ScanStatus.UNEXIST);
                entity.setImageCheckStatus(ImageCheckStatus.WAITING);
                entity.setAbsentSuspect(false);
                entity.setAssigned(false);
                entity.setIncomplete(false);
                entity.setOmrAbsent(false);
                entity.setQuestionFilled(false);
                entity.setSubjectiveFilled(false);
                entity.setPaperType("#");
                entity.setCheckMark(false);
                entity.setAssignedSuspect(false);
                savelist.add(entity);
            } else {
                updatelist.add(entity);
            }
            entity.setExamId(domain.getExamId());
            entity.setName(domain.getName());
            entity.setSubjectCode(domain.getSubjectCode());
            entity.setExamNumber(domain.getExamNumber());
            entity.setPackageCode(domain.getPackageCode());
            entity.setExamRoom(domain.getExamRoom());
            entity.setProvince(domain.getProvince());
            entity.setExamSite(domain.getExamSite());
            entity.setExamSiteName(domain.getExamSiteName());
            entity.setSeatNumber(domain.getSeatNumber());
            entity.setCampusName(domain.getCampusName());
            entity.setCampusCode(domain.getCampusCode());
        }
        if (savelist.size() > 0) {
            this.saveBatch(savelist);
        }
        if (updatelist.size() > 0) {
            this.updateBatchById(updatelist);
        }
        return students.size();
    }

    @Override
    public StudentEntity findByExamAndSubjectCodeAndExamNumber(Long examId, String subjectCode, String examNumber) {
        if (examId == null) {
            throw new ParameterException("examId 不能为空");
        }
        if (StringUtils.isBlank(subjectCode)) {
            throw new ParameterException("subjectCode不能为空");
        }
        if (StringUtils.isBlank(examNumber)) {
            throw new ParameterException("examNumber");
        }
        QueryWrapper<StudentEntity> queryWrapper = new QueryWrapper<>();
        queryWrapper.lambda().eq(StudentEntity::getExamId, examId);
        queryWrapper.lambda().eq(StudentEntity::getSubjectCode, subjectCode);
        queryWrapper.lambda().eq(StudentEntity::getExamNumber, examNumber);
        return baseMapper.selectOne(queryWrapper);
    }

    @Override
    public int countByQuery(ImportStudentQueryVo query) {
        if (query.getExamId() == null) {
            throw new ParameterException("examId不能为空");
        }
        return baseMapper.countByQuery(query);
    }

    @Override
    public int countCetMarking(ExportCetMarkingQueryVo query) {
        if (query.getExamId() == null) {
            throw new ParameterException("examId不能为空");
        }
        return baseMapper.countCetMarking(query);
    }

    @Override
    public List<ImportStudentVo> findByQuery(ImportStudentQueryVo query) {
        if (query.getExamId() == null) {
            throw new ParameterException("examId不能为空");
        }
        ExamEntity exam = examService.getById(query.getExamId());
        if (exam == null) {
            throw new ParameterException("未找到考试");
        }
        IPage<ImportStudentVo> iPage = baseMapper
                .listPageQuery(new Page<ImportStudentVo>(query.getPageNumber(), query.getPageSize()), query);
        if (query.getWithAnswer() != null && query.getWithAnswer()) {
            for (ImportStudentVo student : iPage.getRecords()) {
                List<StudentPaperEntity> papers = studentPaperService.findByStudentId(student.getId());
                List<PaperPageEntity> pageList = new ArrayList<>();
                for (StudentPaperEntity sp : papers) {
                    List<PaperPageEntity> pages = paperPageService.listByPaperId(sp.getPaperId());
                    pageList.addAll(pages);
                }
                List<String> answers = new ArrayList<String>();
                for (PaperPageEntity p : pageList) {
                    if (p.getPageIndex() == 1) {
                        student.setPaperType(p.getPaperType() == null ? null : p.getPaperType().getResult());
                    }
                    disposeQuestionMark(p.getQuestion());
                    if (p.getQuestion() != null && CollectionUtils.isNotEmpty(p.getQuestion().getResult())) {
                        answers.addAll(p.getQuestion().getResult());
                    }
                }
                student.setAnswer(answers);
            }
        }
        return iPage.getRecords();
    }

    private void disposeQuestionMark(ArrayResult ar) {
        if (ar != null && CollectionUtils.isNotEmpty(ar.getResult())) {
            for (int i = 0; i < ar.getResult().size(); i++) {
                ar.getResult().set(i, ar.getResult().get(i).replaceAll("\\?", ""));
            }
        }
    }

    @Override
    public int getOmrAbsentCountByExam(Long examId) {
        QueryWrapper<StudentEntity> wrapper = new QueryWrapper<>();
        LambdaQueryWrapper<StudentEntity> lw = wrapper.lambda();
        lw.eq(StudentEntity::getExamId, examId);
        lw.eq(StudentEntity::getOmrAbsent, true);
        return this.count(wrapper);
    }

    @Override
    public boolean existPictureCopyData() {
        List<StudentUploadVo> list = baseMapper.findToPictureCopy(1);
        return CollectionUtils.isNotEmpty(list);
    }

    @Override
    public List<StudentUploadVo> findToPictureCopy(int pageSize) {
        if (pageSize <= 0) {
            pageSize = 100;
        }
        return baseMapper.findToPictureCopy(pageSize);
    }

    @Override
    public Double getUploadProgress(Long examId) {
        // int total = getCountByExamAndScanStatus(examId, ScanStatus.SCANNED);
        // if (total == 0) {
        // return 0.0;
        // }
        int needUpload = baseMapper.getNeedUploadCount(examId);
        int uploaded = baseMapper.getUploadedCount(examId);
        int total = needUpload + uploaded;
        if (total == 0) {
            return 0.0;
        }
        BigDecimal totalB = new BigDecimal(total);
        BigDecimal uploadedB = new BigDecimal(uploaded);
        return uploadedB.divide(totalB, 2, BigDecimal.ROUND_HALF_UP).doubleValue();
    }

    @Transactional
    @Override
    public void studentClean(Long examId, String subjectCode) {
        ExamEntity exam = examService.getById(examId);
        if (exam == null) {
            throw ParameterExceptions.EXAM_NOT_FOUND;
        }

        if (batchService.getCountByExamAndSubject(examId, subjectCode) > 0) {
            throw new ParameterException("已开始扫描不能清空");
        }

        LambdaQueryWrapper<StudentEntity> wrapper = Wrappers.lambdaQuery();
        wrapper.eq(StudentEntity::getExamId, examId);
        wrapper.eq(StudentEntity::getSubjectCode, subjectCode);
        baseMapper.delete(wrapper);
        examRoomService.clearByExamAndSubject(examId, subjectCode);

    }

    @Transactional
    @Override
    // @Lockable
    public PaperDeleteVo paperDelete(User user, PageDeleteDomain domain) {
        Integer paperNumber = domain.getPaperNumber();
        StudentEntity student = this.findByExamAndSubjectCodeAndExamNumber(domain.getExamId(), domain.getSubjectCode(),
                domain.getExamNumber());
        if (student == null) {
            throw new ParameterException("考生信息未找到");
        }
        concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().lock();
        try {
            updateStudentAndPaper(user, student.getId(),
                    removeStudentPaper(studentPaperService.findByStudentId(student.getId()), paperNumber));
            PaperDeleteVo vo = new PaperDeleteVo();
            vo.setPaperCount(studentPaperService.countByStudentId(student.getId()));
            vo.setUpdateTime(new Date().getTime());
            return vo;
        } finally {
            concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().unlock();
        }
    }

    private List<StudentPaperEntity> removeStudentPaper(List<StudentPaperEntity> list, Integer paperNumber) {
        boolean find = false;
        List<StudentPaperEntity> left = new ArrayList<>();
        for (StudentPaperEntity entity : list) {
            if (entity.getPaperNumber().equals(paperNumber)) {
                find = true;
            } else {
                left.add(entity);
            }
        }
        if (!find) {
            throw new ParameterException("未找到该张扫描结果");
        } else if (left.size() > 0 && paperNumber == 1) {
            throw new StatusException("需先删除其他张之后才能删除第一张");
        } else {
            return left;
        }
    }

    @Transactional
    @Override
    // @Lockable
    public AnswerDeleteVo answerDelete(User user, AnswerDeleteDomain domain) {
        Long examId = domain.getExamId();
        String examNumber = domain.getExamNumber();
        StudentEntity student = this.findByExamAndSubjectCodeAndExamNumber(examId, domain.getSubjectCode(), examNumber);
        if (student == null) {
            throw new ParameterException("考生信息未找到");
        }
        concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().lock();
        try {
            updateStudentAndPaper(user, student.getId(), new ArrayList<>());
            AnswerDeleteVo vo = new AnswerDeleteVo();
            vo.setStatus(ScanStatus.UNEXIST);
            vo.setUpdateTime(new Date().getTime());
            return vo;
        } finally {
            concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().unlock();
        }
    }

    @Transactional
    @Override
    // @Lockable
    public AnswerRefixVo answerRefix(User user, AnswerRefixDomain domain) {
        StudentEntity student = this.findByExamAndSubjectCodeAndExamNumber(domain.getExamId(), domain.getSubjectCode(),
                domain.getExamNumber());
        if (student == null) {
            throw new ParameterException("考生信息未找到");
        }
        AnswerCardEntity answerCard = answerCardService.findByExamAndNumber(domain.getExamId(), domain.getCardNumber());
        if (answerCard == null) {
            throw new ParameterException("卡格式信息未找到");
        }
        boolean allowSubject = answerCardSubjectService.checkSubject(answerCard.getExamId(), answerCard.getNumber(),
                student.getSubjectCode());
        if (!allowSubject) {
            throw new ParameterException("卡格式与考生科目不匹配");
        }
        // if (domain.getPapers().size() != answerCard.getPaperCount()) {
        // throw new ParameterException("卡格式张数不一致");
        // }
        List<String> paperTypeBarcodeContents = markSiteService
                .findPaperTypeBarcodeContentByExamAndSubjectCode(student.getExamId(), student.getSubjectCode());
        concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().lock();
        try {
            List<StudentPaperEntity> studentPaperList = studentPaperService.findByStudentId(student.getId());
            for (StudentPaperEntity studentPaper : studentPaperList) {
                PaperRefixDomain paperDomain = domain.findPaperDomain(studentPaper.getPaperNumber(),
                        studentPaper.getPaperId());
                if (paperDomain == null) {
                    throw new ParameterException("与考生当前paper不一致，paperNumber=" + studentPaper.getPaperNumber());
                }
                PaperEntity paper = paperService.getById(paperDomain.getId());
                if (paper == null) {
                    throw new ParameterException("考生当前paper不存在，paperId=" + paperDomain.getId());
                }
                paper.setCardNumber(answerCard.getNumber());
                paper.setMismatch(paperDomain.getMismatch());
                List<PaperPageEntity> pages = new ArrayList<>();
                for (PageRefixDomain pageDomain : paperDomain.getPages()) {
                    PaperPageEntity page = paperPageService.findPaperIdAndIndex(paper.getId(), pageDomain.getIndex());
                    if (page == null) {
                        throw new ParameterException("与考生当前page不一致，pageIndex=" + pageDomain.getIndex());
                    }
                    pages.add(pageDomain.update(page, paperTypeBarcodeContents));
                }
                paperService.savePaperAndPages(paper, pages);
            }
            updateStudentByPaper(user, student.getId(), true,false);
            return AnswerRefixVo.create();
        } finally {
            concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().unlock();
        }
    }

    @Transactional
    @Override
    public UpdateTimeVo omrEdit(User user, OmrEditDomain domain) {
        StudentEntity student = this.findByExamAndSubjectCodeAndExamNumber(domain.getExamId(), domain.getSubjectCode(),
                domain.getExamNumber());
        if (student == null) {
            throw new ParameterException("考生信息未找到");
        }
        concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().lock();
        try {
            for (OmrEditPaper paperEdit : domain.getPapers()) {
                StudentPaperEntity sp = studentPaperService.findByStudentIdAndPaperNumber(student.getId(),
                        paperEdit.getNumber());
                if (sp == null) {
                    throw new ParameterException("未找到绑定扫描结果");
                }
                PaperEntity paperEntity = paperService.getById(sp.getPaperId());
                if (paperEntity == null) {
                    throw new ParameterException("未找到paper信息结果");
                }
                paperEntity.setUpdaterId(user.getId());
                paperEntity.setUpdateTime(System.currentTimeMillis());
                List<PaperPageEntity> pages = paperPageService.listByPaperId(paperEntity.getId());
                for (PaperPageEntity pageEntity : pages) {
                    paperEdit.updatePage(pageEntity);
                }
                paperService.savePaperAndPages(paperEntity, pages);
            }
            updateStudentByPaper(user, student.getId(), false,false);
            return UpdateTimeVo.create();
        } finally {
            concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().unlock();
        }
    }

    @Transactional
    @Override
    public UpdateTimeVo omrFieldEdit(User user, OmrFieldEditDomain domain) {
        StudentEntity student = this.findByExamAndSubjectCodeAndExamNumber(domain.getExamId(), domain.getSubjectCode(),
                domain.getExamNumber());
        if (student == null) {
            throw new ParameterException("考生信息未找到");
        }
        concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().lock();
        try {
            StudentPaperEntity sp = studentPaperService.findByStudentIdAndPaperNumber(student.getId(),
                    domain.getPaperNumber());
            if (sp == null) {
                throw new ParameterException("未找到绑定扫描结果");
            }
            PaperEntity paperEntity = paperService.getById(sp.getPaperId());
            if (paperEntity == null) {
                throw new ParameterException("未找到paper信息结果");
            }
            paperEntity.setUpdaterId(user.getId());
            paperEntity.setUpdateTime(System.currentTimeMillis());
            List<PaperPageEntity> pages = paperPageService.listByPaperId(paperEntity.getId());
            boolean pageIndexValid = false;
            for (PaperPageEntity pageEntity : pages) {
                if (pageEntity.getPageIndex().equals(domain.getPageIndex())) {
                    pageIndexValid = true;
                    Gson gson = new Gson();
                    if (StringUtils.isBlank(domain.getValue().toString())) {
                        throw new ParameterException("field值为空");
                    }
                    if (OmrField.ABSENT.equals(domain.getField())) {
                        pageEntity.setAbsent(gson.fromJson(domain.getValue().toString(), BoolResult.class));
                    } else if (OmrField.BREACH.equals(domain.getField())) {
                        pageEntity.setBreach(gson.fromJson(domain.getValue().toString(), BoolResult.class));
                    } else if (OmrField.PAPER_TYPE.equals(domain.getField())) {
                        pageEntity.setPaperType(gson.fromJson(domain.getValue().toString(), StringResult.class));
                    } else if (OmrField.QUESTION.equals(domain.getField())) {
                        pageEntity.setQuestion(gson.fromJson(domain.getValue().toString(), ArrayResult.class));
                    } else if (OmrField.SELECTIVE.equals(domain.getField())) {
                        pageEntity.setSelective(gson.fromJson(domain.getValue().toString(), ArrayResult.class));
                    } else {
                        throw new ParameterException("field值错误");
                    }
                }
            }
            if (!pageIndexValid) {
                throw new ParameterException("未找到page信息结果");
            }
            paperService.savePaperAndPages(paperEntity, pages);
            updateStudentByPaper(user, student.getId(), false,false);
            return UpdateTimeVo.create();
        } finally {
            concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().unlock();
        }
    }

    @Transactional
    @Override
    public Integer importCetAbsent(List<ImportCetAbsentDomain> students) {
        List<StudentEntity> list = new ArrayList<StudentEntity>();
        for (ImportCetAbsentDomain domain : students) {
            if (domain.getExamId() == null) {
                throw new StatusException("考试id不能为空");
            }
            if (domain.getExamNumber() == null) {
                throw new StatusException("准考证号不能为空");
            }
            // if (domain.getAbsent() == null) {
            // throw new StatusException("缺考信息不能为空");
            // }
            StudentEntity entity = this.findByExamAndSubjectCodeAndExamNumber(domain.getExamId(),
                    domain.getSubjectCode(), domain.getExamNumber());
            if (entity == null) {
                throw new StatusException("未找到考生");
            }
            entity.setBreachCode(domain.getBreachCode());
            // entity.setExamStatus(domain.getAbsent() ? ExamStatus.ABSENT :
            // null);
            list.add(entity);
        }
        this.updateBatchById(list);
        return list.size();
    }

    @Override
    public List<ExportCetVo> exportCetData(ExportCetMarkingQueryVo query) {
        if (query.getExamId() == null) {
            throw new StatusException("examId不能为空");
        }
        ExamEntity exam = examService.getById(query.getExamId());
        if (exam == null) {
            throw new StatusException("未找到考试");
        }
        List<String> paperTypeBarcodeContents = markSiteService
                .findPaperTypeBarcodeContentByExamAndSubjectCode(query.getExamId(), query.getSubjectCode());
        int subjectCodeVal = Integer.valueOf(query.getSubjectCode());
        if (subjectCodeVal <= 2) {
            if (CollectionUtils.isEmpty(paperTypeBarcodeContents)) {
                throw new StatusException("该科目条码值未设置");
            }
        }
        if (!ExamMode.CET.equals(exam.getMode())) {
            throw new StatusException("该考试不是CET");
        }
        IPage<ExportCetVo> iPage = baseMapper
                .listCetMarkingPage(query);
        if (CollectionUtils.isNotEmpty(iPage.getRecords())) {
            String imageTransferDir = sysProperty.getTransferDir();
            Map<String, List<QuestionEntity>> structs = new HashMap<>();
            Map<Integer, AnswerCardEntity> cardMap = new HashMap<>();
            new BatchSetDataUtil<ExportCetVo>() {

                @Override
                protected void setData(List<ExportCetVo> dataList) {
                    List<Long> ids = dataList.stream().map(e -> e.getId()).collect(Collectors.toList());
                    List<PaperPageCetVo> totalpages = paperPageService.listByStudentIds(ids);
                    List<PaperCetVo> totalpapers = paperService.findByStudentIds(ids);
                    Map<Long, List<PaperPageCetVo>> totalpagesmap = ofPage(totalpages);
                    Map<Long, List<PaperCetVo>> totalpapersmap = ofPaper(totalpapers);
                    for (ExportCetVo vo : dataList) {
                        disposeStudent(vo, paperTypeBarcodeContents, totalpagesmap.get(vo.getId()),
                                totalpapersmap.get(vo.getId()), imageTransferDir, structs, cardMap);
                    }

                }
            }.setDataForBatch(iPage.getRecords(), 200);
        }
        return iPage.getRecords();
    }

    private void disposeStudent(ExportCetVo student, List<String> paperTypeBarcodeContents, List<PaperPageCetVo> pages,
            List<PaperCetVo> papers, String imageTransferDir, Map<String, List<QuestionEntity>> structs,
            Map<Integer, AnswerCardEntity> cardMap) {
        int subjectCodeVal = Integer.valueOf(student.getSubjectCode());
        if (subjectCodeVal > 2) {
            if (student.getExamStatus().equals(ExamStatus.ABSENT)) {
                student.setPaperType("000000");
            } else {
                student.setPaperType("888888");
            }
        } else {
            if (StringUtils.isBlank(student.getPaperType()) || "#".equals(student.getPaperType())) {
                student.setPaperType("000000");
            } else if ("?".equals(student.getPaperType())
                    || !paperTypeBarcodeContents.contains(student.getPaperType())) {
                student.setPaperType("999999");
            }
        }
        Map<Long, PaperCetVo> pmap = new HashMap<>();
        for (PaperCetVo v : papers) {
            pmap.put(v.getId(), v);
        }
        student.setAnswer(getCetAnswer(structs, pages, student.getSubjectCode()));
        AnswerCardEntity card = getCard(cardMap, student.getExamId(), student.getCardNumber());
        Set<String> sliceSet = new HashSet<>();
        setCardStatus(paperTypeBarcodeContents, student, card, pages, pmap);
        int index = 0;
        for (PaperPageCetVo p : pages) {
            if (CollectionUtils.isNotEmpty(p.getSlicePath())) {
                for (int i = 0; i < p.getSlicePath().size(); i++) {
                    String sliceName = card.getSliceName().get(index);
                    sliceSet.add(sliceName);
                    index++;
                }
            }
        }
        List<String> sliceNameList = new ArrayList<>(sliceSet);
        sliceNameList.sort((v1, v2) -> Integer.parseInt(v1) > Integer.parseInt(v2) ? 1 : -1);
        // 获取图片大小
        List<String> sliceImageInfo = new ArrayList<String>();
        student.setSliceImageInfo(sliceImageInfo);
        for (String sliceName : sliceNameList) {
            String mirrorSlicePath = toolExportService.getCetSliceUri(student.getExamId(), student.getExamNumber(),
                    sliceName);
            File targetSliceFile = new File(imageTransferDir + "/" + mirrorSlicePath);
            sliceImageInfo.add(sliceName + "-" + targetSliceFile.length());
        }
    }

    private Map<Long, List<PaperPageCetVo>> ofPage(List<PaperPageCetVo> list) {
        Map<Long, List<PaperPageCetVo>> map = new HashMap<>();
        for (PaperPageCetVo p : list) {
            List<PaperPageCetVo> tem = map.get(p.getStudentId());
            if (tem == null) {
                tem = new ArrayList<>();
                map.put(p.getStudentId(), tem);
            }
            tem.add(p);
        }
        return map;
    }

    private Map<Long, List<PaperCetVo>> ofPaper(List<PaperCetVo> list) {
        Map<Long, List<PaperCetVo>> map = new HashMap<>();
        for (PaperCetVo p : list) {
            List<PaperCetVo> tem = map.get(p.getStudentId());
            if (tem == null) {
                tem = new ArrayList<>();
                map.put(p.getStudentId(), tem);
            }
            tem.add(p);
        }
        return map;
    }

    private AnswerCardEntity getCard(Map<Integer, AnswerCardEntity> cardMap, Long examId, Integer cardNumber) {
        AnswerCardEntity card = cardMap.get(cardNumber);
        if (card == null) {
            card = answerCardService.findByExamAndNumber(examId, cardNumber);
            cardMap.put(cardNumber, card);
        }
        return card;
    }

    private void setCardStatus(List<String> paperTpeCodes, ExportCetVo student, AnswerCardEntity card,
            List<PaperPageCetVo> pages, Map<Long, PaperCetVo> pmap) {
        int subject = Integer.valueOf(student.getSubjectCode());
        if (subject > 2) {
            setCardStatusSmall(student, card, pages, pmap);
        } else {
            setCardStatusCet(paperTpeCodes, student, card, pages, pmap);
        }
    }

    private void setCardStatusSmall(ExportCetVo student, AnswerCardEntity card, List<PaperPageCetVo> pages,
            Map<Long, PaperCetVo> pmap) {
        PaperPageCetVo p = pages.get(0);
        if (ExamStatus.ABSENT.equals(student.getExamStatus())) {
            if (pmap.get(p.getPaperId()).getQuestionFilled()) {
                student.setCardFirst(1);
            } else {
                student.setCardFirst(0);
            }
        } else {
            student.setCardFirst(0);
        }
        student.setCardSecond(0);
    }

    private void setCardStatusCet(List<String> paperTpeCodes, ExportCetVo student, AnswerCardEntity card,
            List<PaperPageCetVo> pages, Map<Long, PaperCetVo> pmap) {
        if (card.getPaperCount() == 1) {
            PaperPageCetVo p = pages.get(0);
            if (ExamStatus.ABSENT.equals(student.getExamStatus())) {
                if (pmap.get(p.getPaperId()).getQuestionFilled()) {
                    student.setCardFirst(1);
                } else if (isPaperTypeValid(paperTpeCodes, p.getPaperType())) {
                    student.setCardFirst(7);
                } else if (isPaperTypeEmpty(p.getPaperType())) {
                    student.setCardFirst(0);
                } else {
                    student.setCardFirst(7);
                }
            } else {
                if (isPaperTypeValid(paperTpeCodes, p.getPaperType())) {
                    student.setCardFirst(0);
                } else {
                    student.setCardFirst(7);
                }
            }
            student.setCardSecond(0);
        } else {
            PaperPageCetVo fp = pages.get(0);
            PaperPageCetVo sp;
            if (card.getSinglePage()) {
                sp = pages.get(1);
            } else {
                sp = pages.get(2);
            }
            if (ExamStatus.ABSENT.equals(student.getExamStatus())) {
                if (pmap.get(fp.getPaperId()).getQuestionFilled()) {
                    student.setCardFirst(1);
                } else if (isPaperTypeValid(paperTpeCodes, fp.getPaperType())) {
                    student.setCardFirst(7);
                } else if (isPaperTypeEmpty(fp.getPaperType())) {
                    student.setCardFirst(0);
                } else {
                    student.setCardFirst(7);
                }
            } else {
                if ("考生94".equals(student.getName())) {
                    System.out.println();
                }
                if (isPaperTypeValid(paperTpeCodes, fp.getPaperType())) {
                    student.setCardFirst(0);
                } else {
                    student.setCardFirst(7);
                }
            }
            if (ExamStatus.ABSENT.equals(student.getExamStatus())) {
                if (pmap.get(sp.getPaperId()).getQuestionFilled()) {
                    student.setCardSecond(1);
                } else if (isPaperTypeValid(paperTpeCodes, fp.getPaperType())) {
                    student.setCardSecond(7);
                } else if (isPaperTypeEmpty(fp.getPaperType())) {
                    student.setCardSecond(0);
                } else {
                    student.setCardSecond(7);
                }
            } else {
                if (isPaperTypeValid(paperTpeCodes, fp.getPaperType())) {
                    student.setCardSecond(0);
                } else {
                    student.setCardSecond(7);
                }
            }
        }
    }

    private boolean isPaperTypeEmpty(StringResult sr) {
        if (sr == null) {
            return true;
        }
        if (StringUtils.isBlank(sr.getResult())) {
            return true;
        }
        if ("#".equals(sr.getResult())) {
            return true;
        }
        return false;
    }

    private boolean isPaperTypeValid(List<String> paperTpeCodes, StringResult sr) {
        if (sr == null) {
            return false;
        }
        if (StringUtils.isBlank(sr.getResult())) {
            return false;
        }
        if ("#".equals(sr.getResult()) || "?".equals(sr.getResult())) {
            return false;
        }
        if (CollectionUtils.isEmpty(paperTpeCodes)) {
            return false;
        }
        if (!paperTpeCodes.contains(sr.getResult())) {
            return false;
        }
        return true;
    }

    private String getCetAnswer(Map<String, List<QuestionEntity>> structs, List<PaperPageCetVo> pages,
            String subjectCode) {
        List<String> answers = new ArrayList<String>();
        List<QuestionEntity> struct = structs.get(subjectCode);
        if (struct == null) {
            struct = questionService.findBySubjectCode(subjectCode);
            if (struct == null) {
                throw new ParameterException("科目：" + subjectCode + " 未上传试卷结构");
            }
            structs.put(subjectCode, struct);
        }
        for (PaperPageCetVo page : pages) {
            disposeQuestionMark(page.getQuestion());
            try {
                if (page.getQuestion() != null && CollectionUtils.isNotEmpty(page.getQuestion().getResult())) {
                    answers.addAll(page.getQuestion().getResult());
                }
            } catch (Exception e) {
                throw e;
            }
        }
        for (int i = 0; i < answers.size(); i++) {
            if ("#".equals(answers.get(i))) {
                answers.set(i, ".");
            }
            if (answers.get(i).length() > 1) {
                answers.set(i, ">");
            }
        }
        int subject = Integer.valueOf(subjectCode);
        if (subject < 3) {// CET4 CET6
            return StringUtils.join(answers, "");
        } else {// 小语种
            List<String> tem = new ArrayList<String>();
            int index = 0;
            for (QuestionEntity s : struct) {
                if (s.getObjective()) {
                    if (index >= answers.size()) {
                        throw new ParameterException("科目：" + subjectCode + " 试卷结构和题卡客观题数量不一致");
                    }
                    tem.add(answers.get(index));
                    index++;
                } else {
                    tem.add(".");
                }
            }
            return StringUtils.join(tem, "");
        }
    }

    @Transactional
    @Override
    public void updateCheckMark(Long studentId, Boolean tag) {
        LambdaUpdateWrapper<StudentEntity> updateWrapper = new LambdaUpdateWrapper<>();
        updateWrapper.set(StudentEntity::getCheckMark, tag);
        updateWrapper.eq(StudentEntity::getId, studentId);
        this.update(updateWrapper);
    }

    @Transactional
    @Override
    public void pictureCopy(StudentUploadVo vo) {
        concurrentService.getReadWriteLock(LockType.STUDENT + "-" + vo.getId()).writeLock().lock();
        StudentEntity se = this.getById(vo.getId());
        try {
            if (UploadStatus.WAITING_UPLOAD.equals(se.getFileUploadStatus())) {
                toolExportService.studentFileCopy(se.getId(), vo.getMode());
                this.updateFileUploadStatus(se.getId(), UploadStatus.UPLOADED);
            }
        } catch (Exception e) {
            this.updateFileUploadStatus(se.getId(), UploadStatus.ERROR);
            log.error("转存文件出错.studentId:" + se.getId(), e);
        } finally {
            concurrentService.getReadWriteLock(LockType.STUDENT + "-" + vo.getId()).writeLock().unlock();
        }
    }

    @Override
    @Transactional
    public void resetExamStatus(ExamStatusResetTaskVo vo) {
        Long examId = vo.getExamId();
        Integer examNumberFillCount = vo.getExamNumberFillCount();
        QueryWrapper<StudentEntity> wrapper = new QueryWrapper<>();
        LambdaQueryWrapper<StudentEntity> lw = wrapper.lambda();
        lw.eq(StudentEntity::getExamId, examId);
        List<StudentEntity> list = this.list(wrapper);
        for (StudentEntity student : list) {
            concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().lock();
            try {
                List<StudentPaperEntity> studentPaperList = studentPaperService.findByStudentId(student.getId());
                int omrExamNumberCount = 0;
                for (StudentPaperEntity studentPaper : studentPaperList) {
                    PaperEntity paper = paperService.getById(studentPaper.getPaperId());
                    int paperExamNumberCount = paper.getOmrExamNumber().replace("#", "").length();
                    if (omrExamNumberCount < paperExamNumberCount) {
                        omrExamNumberCount = paperExamNumberCount;
                    }
                }
                resetExamStatus(student, omrExamNumberCount, examNumberFillCount);
                saveOrUpdate(student);
            } finally {
                concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().unlock();
            }
            vo.setProgressCount(vo.getProgressCount() + 1);
        }
        examService.updateExamNumberFillCount(examId, examNumberFillCount);
    }

    private void resetExamStatus(StudentEntity student, Integer omrExamNumberCount, Integer examNumberFillCount) {
        if (ScanStatus.UNEXIST.equals(student.getStatus())) {
            student.setExamStatus(null);
        } else {
            // 客观题有作答，不缺考
            if (student.getQuestionFilled()) {
                student.setExamStatus(ExamStatus.OK);
            } else {
                if (student.getSubjectiveFilled()) {
                    // 客观题未作答，主观题有作答，待确认1
                    student.setExamStatus(ExamStatus.UNCHECK1);
                } else {
                    // 客观题未作答，主观题未作答，填涂大于10位
                    if (omrExamNumberCount >= examNumberFillCount) {
                        if (!"#".equals(student.getPaperType())) {
                            // 客观题未作答，主观题未作答，填涂大于10位，有卷型，待校验2
                            student.setExamStatus(ExamStatus.UNCHECK2);
                        } else {
                            // 客观题未作答，主观题未作答，填涂大于10位，无卷型，缺考
                            student.setExamStatus(ExamStatus.ABSENT);
                        }
                    } else {
                        // 客观题未作答，主观题未作答，填涂小于10位，缺考
                        student.setExamStatus(ExamStatus.ABSENT);
                    }
                }
            }

        }
    }

    @Override
    @Transactional
    public void updateExamStatus(Long id, ExamStatus examStatus) {
        LambdaUpdateWrapper<StudentEntity> lw = new LambdaUpdateWrapper<>();
        lw.set(StudentEntity::getExamStatus, examStatus);
        lw.eq(StudentEntity::getId, id);
        this.update(lw);
    }

    @Override
    public void importExamStatus(ExamStatusImportTaskVo vo) {
        Map<String, StudentEntity> examNumbers = new HashMap<>();
        Map<String, Boolean> absentMap = new HashMap<>();
        InputStream in = null;
        try {
            in = new FileInputStream(vo.getFile());
            examStatusImportCheck(vo, in, examNumbers, absentMap);
        } catch (ParameterException e) {
            vo.setErrMsg(e.getMessage());
            vo.setStatus(AsyncTaskStatus.FAILED);
            throw e;
        } catch (Exception e) {
            vo.setErrMsg("系统错误");
            vo.setStatus(AsyncTaskStatus.FAILED);
            throw new ParameterException("系统错误", e);
        } finally {
            if (in != null) {
                try {
                    in.close();
                } catch (IOException e) {
                }
            }
        }

        if (ExamStatusCheckMode.OVERRIDE.equals(vo.getMode())) {
            for (StudentEntity student : examNumbers.values()) {
                concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().lock();
                try {
                    if (absentMap.get(student.getExamNumber())) {
                        student.setExamStatus(ExamStatus.ABSENT);
                    } else {
                        student.setExamStatus(ExamStatus.OK);
                    }
                    saveOrUpdate(student);
                    vo.setProgressCount(vo.getProgressCount() + 1);
                } finally {
                    concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().unlock();
                }
            }
        }
        if (ExamStatusCheckMode.COMPARE.equals(vo.getMode())) {
            for (StudentEntity student : examNumbers.values()) {
                concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().lock();
                try {
                    if (absentMap.get(student.getExamNumber()) && !ExamStatus.ABSENT.equals(student.getExamStatus())) {
                        student.setExamStatus(ExamStatus.UNCHECK3);
                    }
                    if (!absentMap.get(student.getExamNumber()) && !ExamStatus.OK.equals(student.getExamStatus())) {
                        student.setExamStatus(ExamStatus.UNCHECK3);
                    }
                    saveOrUpdate(student);
                    vo.setProgressCount(vo.getProgressCount() + 1);
                } finally {
                    concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().unlock();
                }
            }
        }
    }

    private void examStatusImportCheck(ExamStatusImportTaskVo vo, InputStream in,
            Map<String, StudentEntity> examNumbers, Map<String, Boolean> absentMap) {
        List<String> lineList = null;
        try {
            lineList = IOUtils.readLines(in, "UTF-8");
        } catch (IOException e) {
            throw new ParameterException("读取文件出错", e);
        }
        for (int i = 1; i < lineList.size(); i++) {
            String line = lineList.get(i);
            if (StringUtils.isBlank(line)) {
                continue;
            }
            // 已读字符串长度
            StringBuilder msg = new StringBuilder();
            String[] str = line.split(",");
            if (str.length != 2) {
                msg.append("  无法解析，请检查分隔符和数据");
                throw new ParameterException(newError(i + 1, msg.toString()));
            }
            String examNumber = str[0];
            String absent = str[1];
            if (StringUtils.isBlank(examNumber)) {
                examNumber = null;
                msg.append("  准考证号不能为空");
            } else if (examNumber.length() < 15) {
                examNumber = null;
                msg.append("  准考证号不能小于15位");
            }
            if (StringUtils.isBlank(absent)) {
                msg.append("  缺考标识不能为空");
            } else if (!absent.equals("0") && !absent.equals("1")) {
                msg.append("  缺考标识只能为0或1");
            }
            if (examNumber != null) {
                if (examNumbers.containsKey(examNumber)) {
                    msg.append("  准考证号有重复");
                } else {
                    StudentEntity student = this.findByExamAndSubjectCodeAndExamNumber(vo.getExamId(),
                            vo.getSubjectCode(), examNumber);
                    if (student == null) {
                        msg.append("  准考证号不存在");
                    } else {
                        examNumbers.put(examNumber, student);
                        absentMap.put(examNumber, absent.equals("1"));
                    }
                }
            }
            if (msg.length() > 0) {
                throw new ParameterException(newError(i + 1, msg.toString()));
            }
        }
    }

    private String newError(int lineNum, String msg) {
        return "第" + lineNum + "行 " + msg;
    }

    @Override
    @Transactional
    public void updateAssignedCheckCount(Long id, boolean deleteHistory) {
        if (deleteHistory) {
            assignedCheckHistoryService.deleteByStudentId(id);
        }
        this.baseMapper.updateAssignedCheckCount(id);
    }

    @Override
    public int getCountByExamAndAssignedCheckCount(Long examId, String subjectCode, int assignedCheckCount, OP op) {
        LambdaQueryWrapper<StudentEntity> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(StudentEntity::getExamId, examId);
        if (subjectCode != null) {
            wrapper.eq(StudentEntity::getSubjectCode, subjectCode);
        }
        wrapper.eq(StudentEntity::getAssigned, true);

        if (OP.EQ == op) {
            wrapper.eq(StudentEntity::getAssignedCheckCount, assignedCheckCount);
        } else if (OP.GT == op) {
            wrapper.gt(StudentEntity::getAssignedCheckCount, assignedCheckCount);
        } else if (OP.GE == op) {
            wrapper.ge(StudentEntity::getAssignedCheckCount, assignedCheckCount);
        } else if (OP.LE == op) {
            wrapper.le(StudentEntity::getAssignedCheckCount, assignedCheckCount);
        } else if (OP.LT == op) {
            wrapper.lt(StudentEntity::getAssignedCheckCount, assignedCheckCount);
        }

        return this.count(wrapper);
    }

    @Override
    public int countByExamIdAndExamStatus(Long examId, ExamStatus... examStatus) {
        LambdaQueryWrapper<StudentEntity> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(StudentEntity::getExamId, examId);
        wrapper.in(StudentEntity::getExamStatus, Arrays.asList(examStatus));
        return this.count(wrapper);
    }

    @Override
    public List<AssignedCheckExport> exportAssignedCheckPage(AssignedQueryDomain query) {
        List<AssignedCheckExport> ret = this.baseMapper.exportAssignedCheckPage(
                new Page<AssignedCheckExport>(query.getPageNumber(), query.getPageSize()), query);
        return ret;
    }

    @Override
    public PageResult<AnswerQueryVo> queryAssignedCheckPage(AssignedQueryDomain query) {
        // 查询考生分页信息
        IPage<AnswerQueryVo> iPage = baseMapper
                .queryAssignedCheckPage(new Page<>(query.getPageNumber(), query.getPageSize()), query);
        if (CollectionUtils.isNotEmpty(iPage.getRecords()) && query.getWithPaper()) {
            Map<Long, AnswerQueryVo> map = new HashMap<>();
            for (AnswerQueryVo vo : iPage.getRecords()) {
                List<AnswerPaperVo> papers = new ArrayList<>();
                vo.setPapers(papers);
                if (vo.getAuditorId() != null) {
                    UserEntity au = userService.getById(vo.getAuditorId());
                    vo.setAuditorName(au.getLoginName());
                }
                // if (vo.getCardPaperCount() != null) {
                // for (int i = 1; i <= vo.getCardPaperCount(); i++) {
                // AnswerPaperVo pv = new AnswerPaperVo();
                // pv.setNumber(i);
                // papers.add(pv);
                // }
                // }
                map.put(vo.getId(), vo);
            }
            // 根据考生id查找绑定paper
            List<Long> studentIds = iPage.getRecords().stream().map(p -> p.getId()).collect(Collectors.toList());
            List<StudentPaperVo> paperList = new BatchGetDataUtil<StudentPaperVo, Long>() {

                @Override
                public List<StudentPaperVo> getData(List<Long> paramList) {
                    return paperService.listByStudentIds(paramList);
                }
            }.getDataForBatch(studentIds, 20);

            if (CollectionUtils.isNotEmpty(paperList)) {
                Map<Long, AnswerPaperVo> paperMap = new HashMap<>();
                for (StudentPaperVo p : paperList) {
                    AnswerQueryVo vo = map.get(p.getStudentId());
                    if (vo == null) {
                        continue;
                    }
                    List<AnswerPaperVo> papers = vo.getPapers();
                    if (papers == null) {
                        continue;
                    }
                    // if (papers.size() < p.getNumber()) {
                    // continue;
                    // }
                    if (!p.getAssigned()) {
                        continue;
                    }
                    // AnswerPaperVo pvo = papers.get(p.getNumber() - 1);
                    AnswerPaperVo pvo = new AnswerPaperVo();
                    pvo.setId(p.getPaperId());
                    pvo.setNumber(p.getNumber());
                    pvo.setAssigned(p.getAssigned());
                    // pvo.setAssignedSuspect(p.getAssignedSuspect());
                    papers.add(pvo);
                    paperMap.put(p.getPaperId(), pvo);
                }
                // 查找page
                List<Long> paperIds = paperList.stream().map(p -> p.getPaperId()).collect(Collectors.toList());
                List<PaperPageEntity> paperPageList = new BatchGetDataUtil<PaperPageEntity, Long>() {

                    @Override
                    public List<PaperPageEntity> getData(List<Long> paramList) {
                        return paperPageService.listByPaperList(paramList);
                    }
                }.getDataForBatch(paperIds, 20);

                if (CollectionUtils.isNotEmpty(paperPageList)) {
                    for (PaperPageEntity p : paperPageList) {
                        AnswerPaperVo pvo = paperMap.get(p.getPaperId());
                        if (pvo == null) {
                            continue;
                        }
                        List<AnswerPageVo> pages = pvo.getPages();
                        if (pages == null) {
                            pages = new ArrayList<>();
                            pvo.setPages(pages);
                        }
                        AnswerPageVo pageVo = new AnswerPageVo();
                        pageVo.setIndex(p.getPageIndex());
                        pageVo.setSheetUri(p.getSheetPath());
                        pageVo.setSliceUri(p.getSlicePath());
                        pages.add(pageVo);
                    }
                }
            }
        } else {
            for (AnswerQueryVo vo : iPage.getRecords()) {
                if (vo.getAuditorId() != null) {
                    UserEntity au = userService.getById(vo.getAuditorId());
                    vo.setAuditorName(au.getLoginName());
                }
            }
        }
        return PageUtil.of(iPage);
    }

    @Override
    public boolean apply(StudentEntity t, String account) {
        TaskLock taskLock = TaskLockUtil.getAssignedCheckTask(t.getExamId() + "_" + t.getSubjectCode());
        boolean lock = taskLock.add(t.getId(), account);
        // 上锁失败直接返回
        if (!lock) {
            return false;
        }
        // 重复校验任务状态
        if (t.getAssignedCheckCount() == 0 || t.getAssignedCheckCount() == 1) {
            return true;
        } else {
            taskLock.remove(t.getId());
            return false;
        }
    }

    @Override
    public boolean hasAppliedAssignedCheckTask(StudentEntity t, String account) {
        TaskLock taskLock = TaskLockUtil.getAssignedCheckTask(t.getExamId() + "_" + t.getSubjectCode());
        return taskLock.exist(t.getId(), account);
    }

    @Override
    public TaskStatusVo getAssignedCheckTaskStatus(Long examId, String subjectCode, User user) {
        TaskStatusVo status = new TaskStatusVo();
        status.setFinishCount(assignedCheckHistoryService.getCountByUserId(user.getId(), examId, subjectCode));
        if (Role.AUDITOR.equals(user.getRole())) {
            status.setTodoCount(this.getCountByExamAndAssignedCheckCount(examId, subjectCode, 0, OP.EQ));
        } else {
            status.setTodoCount(this.getCountByExamAndAssignedCheckCount(examId, subjectCode, 1, OP.EQ));
        }
        return status;
    }

    @Override
    public void releaseAssignedCheckTaskByUser(Long examId, String subjectCode, String account) {
        TaskLock taskLock = TaskLockUtil.getAssignedCheckTask(examId + "_" + subjectCode);
        taskLock.clear(account);
    }

    @Override
    @Transactional
    public AssignedTaskSaveVo submitAssignedCheckTask(AssginedTaskResult result, User user) {
        StudentEntity student = getById(result.getId());
        if (student == null) {
            throw new ParameterException("考生信息未找到");
        }
        if (student.getAssignedCheckCount() == 0 && !this.hasAppliedAssignedCheckTask(student, user.getAccount())) {
            throw new ParameterException("任务非本人领取");
        }
        concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().lock();
        try {
            assignedCheckHistoryService.deleteByStudentIdAndUserRole(student.getId(), user.getRole());
            assignedCheckHistoryService.save(user.getId(), student.getId(), student.getExamId());
            // for (AssignedTaskResultPaper paper : result.getPapers()) {
            // paperService.updatePaperAssignedSuspect(student.getId(),
            // paper.getNumber(), result.getAssignedSuspect());
            // }
            // updateStudentByPaper(user, student.getId(), false);
            student.setAssignedSuspect(result.getAssignedSuspect());
            saveOrUpdate(student);
            updateAssignedCheckCount(student.getId(), false);
        } finally {
            concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().unlock();
        }
        AssignedTaskSaveVo vo = new AssignedTaskSaveVo();
        vo.setId(student.getId());
        vo.setStatus(this.getAssignedCheckTaskStatus(student.getExamId(), student.getSubjectCode(), user));
        return vo;
    }

    @Override
    public PageResult<AnswerQueryVo> getAssignedCheckTaskHistory(Long examId, String subjectCode, Long pageNumber,
            Long pageSize, User user) {
        IPage<AnswerQueryVo> result = this.baseMapper.getAssignedCheckTaskHistory(new Page<>(pageNumber, pageSize),
                examId, subjectCode, user.getId());
        SubjectEntity subject = subjectService.findByExamIdAndCode(examId,subjectCode);
        for (AnswerQueryVo t : result.getRecords()) {
            t.setSubjectName(subject.getName());
            t = toTaskVo(t);
        }
        return PageUtil.of(result);
    }

    @Override
    public AnswerQueryVo getAssignedCheckTask(Long examId, String subjectCode, User user) {
        ExamEntity exam = examService.getById(examId);
        if (exam.getEnableSyncVerify() && Role.AUDITOR.equals(user.getRole())) {
            throw new ParameterException("已开启实时审核,审核员无法获取任务");
        }
        int retry = 1;
        AnswerQueryVo task = null;
        int checkCount = 0;
        if (Role.AUDITOR.equals(user.getRole())) {
            checkCount = 0;
        } else {
            checkCount = 1;
        }
        SubjectEntity subject = subjectService.findByExamIdAndCode(examId,subjectCode);
        while (task == null) {
            IPage<AnswerQueryVo> list = this.findUnCheck(examId, subjectCode, checkCount, retry, 20);
            if (list.getRecords().isEmpty()) {
                break;
            }
            for (AnswerQueryVo t : list.getRecords()) {
                StudentEntity student = this.getById(t.getId());
                if (this.apply(student, user.getAccount())) {
                    t.setSubjectName(subject.getName());
                    task = toTaskVo(t);
                    break;
                }
            }
            if (task == null) {
                retry++;
            }
        }
        if (task == null) {
            throw NotFoundExceptions.NO_CHECK_ASSIGNED_TASK;
        }
        return task;
    }

    private IPage<AnswerQueryVo> findUnCheck(Long examId, String subjectCode, int checkCount, int pageNumber,
            int pageSize) {
        return this.baseMapper.findUnCheck(new Page<>(pageNumber, pageSize), examId, subjectCode, checkCount);
    }

    private AnswerQueryVo toTaskVo(AnswerQueryVo t) {
        List<AnswerPaperVo> papers = new ArrayList<>();
        t.setPapers(papers);
        // if (t.getCardPaperCount() != null) {
        // for (int i = 1; i <= t.getCardPaperCount(); i++) {
        // AnswerPaperVo pv = new AnswerPaperVo();
        // pv.setNumber(i);
        // papers.add(pv);
        // }
        // }
        List<Long> studentIds = new ArrayList<>();
        studentIds.add(t.getId());
        List<StudentPaperVo> paperList = new BatchGetDataUtil<StudentPaperVo, Long>() {

            @Override
            public List<StudentPaperVo> getData(List<Long> paramList) {
                return paperService.listByStudentIds(paramList);
            }
        }.getDataForBatch(studentIds, 20);

        if (CollectionUtils.isNotEmpty(paperList)) {
            Map<Long, AnswerPaperVo> paperMap = new HashMap<>();
            for (StudentPaperVo p : paperList) {
                AnswerQueryVo vo = t;
                if (vo == null) {
                    continue;
                }
                // if (papers.size() < p.getNumber()) {
                // continue;
                // }
                if (!p.getAssigned()) {
                    continue;
                }
                AnswerPaperVo pvo = new AnswerPaperVo();
                pvo.setId(p.getPaperId());
                pvo.setNumber(p.getNumber());
                pvo.setAssigned(p.getAssigned());
                // pvo.setAssignedSuspect(p.getAssignedSuspect());
                papers.add(pvo);
                paperMap.put(p.getPaperId(), pvo);
            }
            // 查找page
            List<Long> paperIds = paperList.stream().map(p -> p.getPaperId()).collect(Collectors.toList());
            List<PaperPageEntity> paperPageList = new BatchGetDataUtil<PaperPageEntity, Long>() {

                @Override
                public List<PaperPageEntity> getData(List<Long> paramList) {
                    return paperPageService.listByPaperList(paramList);
                }
            }.getDataForBatch(paperIds, 20);

            if (CollectionUtils.isNotEmpty(paperPageList)) {
                for (PaperPageEntity p : paperPageList) {
                    AnswerPaperVo pvo = paperMap.get(p.getPaperId());
                    if (pvo == null) {
                        continue;
                    }
                    List<AnswerPageVo> pages = pvo.getPages();
                    if (pages == null) {
                        pages = new ArrayList<>();
                        pvo.setPages(pages);
                    }
                    AnswerPageVo pageVo = new AnswerPageVo();
                    pageVo.setIndex(p.getPageIndex());
                    pageVo.setSheetUri(p.getSheetPath());
                    pageVo.setSliceUri(p.getSlicePath());
                    pages.add(pageVo);
                }
            }
        }
        return t;
    }

    @Override
    public StudentAnswerVo studentAnswer(Long batchId, Long studentId) {
        if (batchId == null) {
            throw new ParameterException("batchId不能为空");
        }
        if (studentId == null) {
            throw new ParameterException("studentId不能为空");
        }
        StudentAnswerVo ret = this.baseMapper.getStudentVo(studentId);
        if (ret == null) {
            throw new ParameterException("未找到考生信息");
        }
        ret.setPapers(new ArrayList<>());
        List<StudentPaperVo> paperList = paperService.listByBatchIdAndStudentId(batchId, studentId);

        if (CollectionUtils.isNotEmpty(paperList)) {
            Map<Long, AnswerPaperVo> paperMap = new HashMap<>();
            for (StudentPaperVo p : paperList) {
                AnswerPaperVo pvo = new AnswerPaperVo();
                pvo.setId(p.getPaperId());
                pvo.setNumber(p.getNumber());
                pvo.setAssigned(p.getAssigned());
                pvo.setPages(new ArrayList<>());
                ret.getPapers().add(pvo);
                paperMap.put(p.getPaperId(), pvo);
            }
            // 查找page
            List<Long> paperIds = paperList.stream().map(p -> p.getPaperId()).collect(Collectors.toList());
            List<PaperPageEntity> paperPageList = paperPageService.listByPaperList(paperIds);

            if (CollectionUtils.isNotEmpty(paperPageList)) {
                for (PaperPageEntity p : paperPageList) {
                    AnswerPaperVo pvo = paperMap.get(p.getPaperId());
                    if (pvo == null) {
                        continue;
                    }
                    AnswerPageVo pageVo = new AnswerPageVo();
                    pageVo.setIndex(p.getPageIndex());
                    pageVo.setSheetUri(p.getSheetPath());
                    pageVo.setSliceUri(p.getSlicePath());
                    pageVo.setAbsent(p.getAbsent());
                    pageVo.setBreach(p.getBreach());
                    pageVo.setPaperType(p.getPaperType());
                    pageVo.setQuestion(p.getQuestion());
                    pageVo.setSelective(p.getSelective());
                    pageVo.setRecogData(p.getRecogData());
                    pvo.getPages().add(pageVo);
                }
            }
        }
        return ret;
    }

    @Override
    public List<SubjectScanProgressVo> scanProgress(Long examId, String subjectCode) {
        return this.baseMapper.scanProgress(examId, subjectCode);
    }

    @Override
    public PageResult<StudentPageVo> studentPage(StudentPageQuery query) {
        // 查询考生分页信息
        IPage<StudentPageVo> iPage = baseMapper.studentPage(new Page<>(query.getPageNumber(), query.getPageSize()),
                query);
        if (CollectionUtils.isNotEmpty(iPage.getRecords())) {
            for (StudentPageVo vo : iPage.getRecords()) {
                if (ScanStatus.SCANNED.equals(vo.getStatus())) {
                    vo.setScanned("已扫描");
                } else {
                    vo.setScanned("未扫描");
                }
            }
        }
        return PageUtil.of(iPage);
    }

    @Override
    public List<StudentPageVo> studentList(StudentPageQuery query) {
        return studentPage(query).getResult();
    }

    @Override
    public List<StudentVo> studentExportList(AnswerQueryDomain query) {
        return baseMapper.studentExport(new Page<>(query.getPageNumber(), query.getPageSize()), query).getRecords();
    }

    @Override
    public List<StudentExamRoomVo> studentExamRoomExportList(AnswerQueryDomain query) {
        return baseMapper.studentExamRoomExport(new Page<>(query.getPageNumber(), query.getPageSize()), query)
                .getRecords();
    }

    @Override
    public TaskIdVo breachImport(Long examId, String subjectCode, MultipartFile file) {
        if (!file.getOriginalFilename().toLowerCase().endsWith(".txt")) {
            throw new ParameterException("只能是txt文件");
        }
        String taskId = FastUUID.get();
        // 暂存临时文件
        File temDir = new File("temp/" + taskId + "/");
        temDir.mkdirs();
        File txt = new File(temDir.getAbsolutePath() + "/breach.txt");
        try {
            file.transferTo(txt);
            List<String> list = FileUtils.readLines(txt, "utf-8");
            if (CollectionUtils.isEmpty(list) || list.size() <= 1) {
                throw new ParameterException("文件内容为空");
            }
            BreachAndStatusImportTaskVo vo = new BreachAndStatusImportTaskVo();
            vo.setTaskId(taskId);
            vo.setTotalCount(list.size() - 1);
            vo.setExamId(examId);
            vo.setSubjectCode(subjectCode);
            vo.setStatus(AsyncTaskStatus.RUNNING);
            vo.setProgress(0.0);
            vo.setTempDir(temDir);
            vo.setFile(txt);
            BreachImportConsumer com = SpringContextHolder.getBean(BreachImportConsumer.class);
            com.setVo(vo);
            exec.execute(com);
            asyncTaskService.addTask(vo);
            return TaskIdVo.create(vo.getTaskId());
        } catch (ParameterException e) {
            throw e;
        } catch (Exception e) {
            throw new RuntimeException("系统错误", e);
        }

    }

    @Override
    public void breachImportDispose(BreachAndStatusImportTaskVo vo) {
        InputStream in = null;
        try {
            in = new FileInputStream(vo.getFile());
            breachImportCheck(vo, in);
        } catch (ParameterException e) {
            vo.setErrMsg(e.getMessage());
            vo.setStatus(AsyncTaskStatus.FAILED);
            throw e;
        } catch (Exception e) {
            vo.setErrMsg("系统错误");
            vo.setStatus(AsyncTaskStatus.FAILED);
            throw new ParameterException("系统错误", e);
        } finally {
            if (in != null) {
                try {
                    in.close();
                } catch (IOException e) {
                }
            }
        }
        // 根据校验结果上传文件
        InputStream excelIn = null;
        try {
            String md5 = MD5Util.md5Hex(vo.getFile());
            excelIn = new FileInputStream(vo.getFile());
            fileService.uploadBreach(excelIn, md5, vo.getExamId(), vo.getSubjectCode());
        } catch (IOException e) {
            vo.setErrMsg("系统错误");
            vo.setStatus(AsyncTaskStatus.FAILED);
            throw new ParameterException("系统错误", e);
        } finally {
            if (excelIn != null) {
                try {
                    excelIn.close();
                } catch (IOException e) {
                }
            }
        }
        File info = new File(vo.getTempDir().getAbsolutePath() + "/breach-info.txt");
        InputStream infoIn = null;
        try {
            FileUtils.write(info, vo.getProgressCount() + "", "utf-8");
            String md5 = MD5Util.md5Hex(info);
            infoIn = new FileInputStream(info);
            fileService.uploadBreachInfo(infoIn, md5, vo.getExamId(), vo.getSubjectCode());
        } catch (IOException e) {
            vo.setErrMsg("系统错误");
            vo.setStatus(AsyncTaskStatus.FAILED);
            throw new ParameterException("系统错误", e);
        } finally {
            if (infoIn != null) {
                try {
                    infoIn.close();
                } catch (IOException e) {
                }
            }
        }
        vo.setTotalCount(vo.getProgressCount());
        vo.setStatus(AsyncTaskStatus.SUCCESS);
    }

    private void breachImportCheck(BreachAndStatusImportTaskVo vo, InputStream in) {
        List<String> lineList = null;
        try {
            lineList = IOUtils.readLines(in, "UTF-8");
        } catch (IOException e) {
            throw new ParameterException("读取文件出错", e);
        }
        Set<String> examNumberSet = new HashSet<>();
        for (int i = 1; i < lineList.size(); i++) {
            String lineString = lineList.get(i);
            if (StringUtils.isBlank(lineString)) {
                continue;
            }
            StringBuilder msg = new StringBuilder();
            String[] line = lineString.split(",");
            if (line.length != 3) {
                msg.append("  格式错误");
            } else {
                String examNumber = trimAndNullIfBlank(line[0]);
                if (StringUtils.isBlank(examNumber)) {
                    msg.append("  准考证号不能为空");
                } else {
                    StudentEntity s = findByExamAndSubjectCodeAndExamNumber(vo.getExamId(), vo.getSubjectCode(),
                            examNumber);
                    if (s == null) {
                        msg.append("  准考证号未找到");
                    } else {
                        if (examNumberSet.contains(examNumber)) {
                            msg.append("  准考证号重复");
                        } else {
                            examNumberSet.add(examNumber);
                        }
                    }
                }

                String breach = trimAndNullIfBlank(line[2]);
                if (StringUtils.isBlank(breach)) {
                    msg.append("  违纪不能为空");
                } else {
                    vo.setProgressCount(vo.getProgressCount() + 1);
                }
            }
            if (msg.length() > 0) {
                throw new ParameterException(errorMsg(i + 1, msg.toString()));
            }
        }

    }

    private String errorMsg(int lineNum, String msg) {
        return "第" + lineNum + "行 " + msg;
    }

    @Override
    public TaskIdVo custStatusImport(Long examId, String subjectCode, MultipartFile file) {
        if (!file.getOriginalFilename().toLowerCase().endsWith(".txt")) {
            throw new ParameterException("只能是txt文件");
        }
        String taskId = FastUUID.get();
        // 暂存临时文件
        File temDir = new File("temp/" + taskId + "/");
        temDir.mkdirs();
        File txt = new File(temDir.getAbsolutePath() + "/cust-status.txt");
        try {
            file.transferTo(txt);
            List<String> list = FileUtils.readLines(txt, "utf-8");
            if (CollectionUtils.isEmpty(list) || list.size() <= 1) {
                throw new ParameterException("文件内容为空");
            }
            BreachAndStatusImportTaskVo vo = new BreachAndStatusImportTaskVo();
            vo.setTaskId(taskId);
            vo.setTotalCount(list.size() - 1);
            vo.setExamId(examId);
            vo.setSubjectCode(subjectCode);
            vo.setStatus(AsyncTaskStatus.RUNNING);
            vo.setProgress(0.0);
            vo.setTempDir(temDir);
            vo.setFile(txt);
            CustStatusImportConsumer com = SpringContextHolder.getBean(CustStatusImportConsumer.class);
            com.setVo(vo);
            exec.execute(com);
            asyncTaskService.addTask(vo);
            return TaskIdVo.create(vo.getTaskId());
        } catch (ParameterException e) {
            throw e;
        } catch (Exception e) {
            throw new RuntimeException("系统错误", e);
        }
    }

    @Override
    public void custStatusImportDispose(BreachAndStatusImportTaskVo vo) {
        InputStream in = null;
        try {
            in = new FileInputStream(vo.getFile());
            custStatusImportCheck(vo, in);
        } catch (ParameterException e) {
            vo.setErrMsg(e.getMessage());
            vo.setStatus(AsyncTaskStatus.FAILED);
            throw e;
        } catch (Exception e) {
            vo.setErrMsg("系统错误");
            vo.setStatus(AsyncTaskStatus.FAILED);
            throw new ParameterException("系统错误", e);
        } finally {
            if (in != null) {
                try {
                    in.close();
                } catch (IOException e) {
                }
            }
        }
        // 根据校验结果上传文件
        InputStream excelIn = null;
        try {
            String md5 = MD5Util.md5Hex(vo.getFile());
            excelIn = new FileInputStream(vo.getFile());
            fileService.uploadCustStatus(excelIn, md5, vo.getExamId(), vo.getSubjectCode());
        } catch (IOException e) {
            vo.setErrMsg("系统错误");
            vo.setStatus(AsyncTaskStatus.FAILED);
            throw new ParameterException("系统错误", e);
        } finally {
            if (excelIn != null) {
                try {
                    excelIn.close();
                } catch (IOException e) {
                }
            }
        }
        File info = new File(vo.getTempDir().getAbsolutePath() + "/cust-status-info.txt");
        InputStream infoIn = null;
        try {
            FileUtils.write(info, vo.getProgressCount() + "", "utf-8");
            String md5 = MD5Util.md5Hex(info);
            infoIn = new FileInputStream(info);
            fileService.uploadCustStatusInfo(infoIn, md5, vo.getExamId(), vo.getSubjectCode());
        } catch (IOException e) {
            vo.setErrMsg("系统错误");
            vo.setStatus(AsyncTaskStatus.FAILED);
            throw new ParameterException("系统错误", e);
        } finally {
            if (infoIn != null) {
                try {
                    infoIn.close();
                } catch (IOException e) {
                }
            }
        }
        vo.setTotalCount(vo.getProgressCount());
        vo.setStatus(AsyncTaskStatus.SUCCESS);
    }

    private void custStatusImportCheck(BreachAndStatusImportTaskVo vo, InputStream in) {
        List<String> lineList = null;
        try {
            lineList = IOUtils.readLines(in, "UTF-8");
        } catch (IOException e) {
            throw new ParameterException("读取文件出错", e);
        }
        Set<String> examNumberSet = new HashSet<>();
        for (int i = 1; i < lineList.size(); i++) {
            String lineString = lineList.get(i);
            if (StringUtils.isBlank(lineString)) {
                continue;
            }
            StringBuilder msg = new StringBuilder();
            String[] line = lineString.split(",");
            if (line.length != 3) {
                msg.append("  格式错误");
            } else {
                String examNumber = trimAndNullIfBlank(line[0]);
                if (StringUtils.isBlank(examNumber)) {
                    msg.append("  准考证号不能为空");
                } else {
                    StudentEntity s = findByExamAndSubjectCodeAndExamNumber(vo.getExamId(), vo.getSubjectCode(),
                            examNumber);
                    if (s == null) {
                        msg.append("  准考证号未找到");
                    } else {
                        if (examNumberSet.contains(examNumber)) {
                            msg.append("  准考证号重复");
                        } else {
                            examNumberSet.add(examNumber);
                        }
                    }
                }

                String breach = trimAndNullIfBlank(line[2]);
                if (StringUtils.isBlank(breach)) {
                    msg.append("  考生状态不能为空");
                } else {
                    vo.setProgressCount(vo.getProgressCount() + 1);
                }
            }
            if (msg.length() > 0) {
                throw new ParameterException(errorMsg(i + 1, msg.toString()));
            }
        }

    }

    @Override
    public List<StudentCountVo> countStudent(Long examId) {
        if (examId == null) {
            throw new ParameterException("examId不能为空");
        }
        return baseMapper.countStudent(examId);
    }

    @Override
    public List<AssignedCheckExamRoomExport> exportAssignedCheck(Long examId, String subjectCode) {
        return baseMapper.exportAssignedCheck(examId, subjectCode);
    }

    @Override
    public void resetAssignedCheck(Long examId, String subjectCode) {
        TaskLock taskLock = TaskLockUtil.getAssignedCheckTask(examId + "_" + subjectCode);
        taskLock.clear();

        QueryWrapper<StudentEntity> wrapper = new QueryWrapper<>();
        LambdaQueryWrapper<StudentEntity> lw = wrapper.lambda();
        lw.eq(StudentEntity::getExamId, examId);
        lw.eq(StudentEntity::getSubjectCode, subjectCode);
        lw.eq(StudentEntity::getAssigned, true);
        lw.gt(StudentEntity::getAssignedCheckCount, 1);
        List<StudentEntity> list = this.list(wrapper);
        for (StudentEntity student : list) {
            concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().lock();
            try {
                student.setAbsentSuspect(false);
                student.setAssignedCheckCount(1);
                saveOrUpdate(student);
                assignedCheckHistoryService.deleteByStudentIdAndUserRole(student.getId(), Role.SCHOOL_ADMIN);
            } finally {
                concurrentService.getReadWriteLock(LockType.STUDENT + "-" + student.getId()).writeLock().unlock();
            }
        }
    }

    @Transactional
    @Override
    public void updateImageCheckStatus(Long studentId, ImageCheckStatus status) {
        LambdaUpdateWrapper<StudentEntity> lw = new LambdaUpdateWrapper<>();
        lw.set(StudentEntity::getImageCheckStatus, status);
        lw.eq(StudentEntity::getId, studentId);
        update(lw);
    }

    // @Transactional
    // @Override
    // public void resetFileAndImageCheckStatus(Long examId, String subjectCode,
    // String examNumber) {
    // LambdaUpdateWrapper<StudentEntity> lw = new LambdaUpdateWrapper<>();
    // lw.set(StudentEntity::getImageCheckStatus, ImageCheckStatus.WAITING);
    // lw.set(StudentEntity::getFileUploadStatus, UploadStatus.WAITING_UPLOAD);
    // lw.eq(StudentEntity::getExamId, examId);
    // lw.eq(StudentEntity::getSubjectCode, subjectCode);
    // lw.eq(StudentEntity::getExamNumber, examNumber);
    // update(lw);
    // }

    @Override
    public boolean existUncheck(Long examId, String subjectCode) {
        List<ExamStatus> st = new ArrayList<>();
        st.add(ExamStatus.UNCHECK1);
        st.add(ExamStatus.UNCHECK2);
        st.add(ExamStatus.UNCHECK3);
        LambdaQueryWrapper<StudentEntity> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(StudentEntity::getExamId, examId);
        wrapper.eq(StudentEntity::getSubjectCode, subjectCode);
        wrapper.in(StudentEntity::getExamStatus, st);
        wrapper.last("LIMIT 1");
        return this.getOne(wrapper) != null;
    }

    @Override
    public boolean existImageCheckUnFinish(Long examId, String subjectCode) {
        Long id = this.baseMapper.getImageCheckUnFinish(examId, subjectCode);
        return id != null;
    }

    @Override
    public Integer countByExamIdAndSubjectCode(Long examId, String subjectCode) {
        LambdaQueryWrapper<StudentEntity> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(StudentEntity::getExamId, examId);
        wrapper.eq(StudentEntity::getSubjectCode, subjectCode);
        return this.count(wrapper);
    }

    @Override
    public Integer getImageCheckFailedCount(Long examId, String subjectCode) {
        return this.baseMapper.getImageCheckFailedCount(examId, subjectCode);
    }

    @Override
    public Integer getImageCheckDisposedCount(Long examId, String subjectCode) {
        return this.baseMapper.getImageCheckDisposedCount(examId, subjectCode);
    }

}