diff --git a/core/core-backend/src/main/java/io/dataease/job/sechedule/CheckDsStatusJob.java b/core/core-backend/src/main/java/io/dataease/job/sechedule/CheckDsStatusJob.java new file mode 100644 index 0000000000..71c63b3b70 --- /dev/null +++ b/core/core-backend/src/main/java/io/dataease/job/sechedule/CheckDsStatusJob.java @@ -0,0 +1,27 @@ +package io.dataease.job.sechedule; + + +import io.dataease.datasource.server.DatasourceServer; +import io.dataease.utils.CommonBeanFactory; +import io.dataease.utils.LogUtil; +import jakarta.annotation.Resource; +import org.quartz.*; +import org.springframework.stereotype.Component; + +@Component +public class CheckDsStatusJob implements Job { + + @Resource + private DatasourceServer datasourceServer; + + public CheckDsStatusJob() { + datasourceServer = (DatasourceServer) CommonBeanFactory.getBean(DatasourceServer.class); + } + + @Override + public void execute(JobExecutionContext context) throws JobExecutionException { + LogUtil.info("Begin to check ds status..."); + datasourceServer.updateDatasourceStatus(); + } + +}