server/src/main/java/cn/com/qmth/scancentral/task/ImageCheckJob.java

package cn.com.qmth.scancentral.task;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;

import cn.com.qmth.scancentral.entity.ExamEntity;
import cn.com.qmth.scancentral.enums.ExamMode;
import cn.com.qmth.scancentral.service.ExamService;
import cn.com.qmth.scancentral.service.ImageCheckService;

@Service
public class ImageCheckJob {

    @Autowired
    private ExamService examService;

    @Autowired
    private ImageCheckService imageCheckService;

    @Scheduled(fixedDelay = 20 * 1000, initialDelay = 20 * 1000)
    public void process() {
        LambdaQueryWrapper<ExamEntity> wrapper = Wrappers.lambdaQuery();
        wrapper.select(ExamEntity::getId, ExamEntity::getMode);
        wrapper.eq(ExamEntity::getEnable, true);
        List<ExamEntity> exams = examService.list(wrapper);

        for (ExamEntity exam : exams) {
            if (ExamMode.CET.equals(exam.getMode())) {
                imageCheckService.check(exam.getId());
            }
        }
    }

}