定时任务质量稽核

server/src/main/java/edp/davinci/service/impl/AuditorScheduleServiceImpl.java

@@ -0,0 +1,43 @@
+package edp.davinci.service.impl;
+
+import com.alibaba.druid.util.StringUtils;
+import com.alibaba.fastjson.JSONObject;
+import edp.core.common.quartz.ScheduleService;
+import edp.davinci.core.enums.LogNameEnum;
+import edp.davinci.dao.CronJobMapper;
+import edp.davinci.dto.cronJobDto.CronJobConfig;
+import edp.davinci.model.CronJob;
+import edp.davinci.model.QualityTask;
+import edp.davinci.service.QualityTaskService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service("auditorScheduleService")
+public class AuditorScheduleServiceImpl extends BaseScheduleService implements ScheduleService {
+
+    private static final Logger scheduleLogger = LoggerFactory.getLogger(LogNameEnum.BUSINESS_SCHEDULE.getName());
+
+    @Autowired
+    private CronJobMapper cronJobMapper;
+
+    @Autowired
+    private QualityTaskService  qualityTaskService;
+
+    @Override
+    public void execute(long jobId) throws Exception {
+        CronJob cronJob = cronJobMapper.getById(jobId);
+        cronJobMapper.updateExecLog(jobId, "");
+        scheduleLogger.info("CronJob({}) is start! --------------", jobId);
+
+        // 质量稽核
+        QualityTask qualityTask = qualityTaskService.getQualityTaskByCronJobId(cronJob.getId());
+        if (null != qualityTask) {
+            qualityTaskService.auditor(qualityTask.getId());
+            scheduleLogger.info("execute quality auditor");
+        }
+        scheduleLogger.info("CronJob({}) is finish! --------------", jobId);
+
+    }
+}