srt_cloud/srt-cloud-data-governance/src/main/java/net/srt/init/BusinessInitializer.java

35 lines
978 B
Java

package net.srt.init;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import net.srt.service.MetadataCollectRecordService;
import net.srt.service.QualityTaskService;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component;
@Slf4j
@Component
@RequiredArgsConstructor
public class BusinessInitializer implements ApplicationRunner {
private final MetadataCollectRecordService metadataCollectRecordService;
private final QualityTaskService qualityTaskService;
@Override
public void run(ApplicationArguments args) {
initScheduleMonitor();
}
/**
* init task monitor
*/
private void initScheduleMonitor() {
//处理没执行完的采集任务
metadataCollectRecordService.dealNotFinished();
//处理没执行完的质量检测任务
qualityTaskService.dealNotFinished();
}
}