feature(info-query): 增加查询未跨天表名

service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/InfoService.java

@@ -43,4 +43,10 @@ public interface InfoService {
 
     @Get("/sync_state/detail")
     SyncState syncStateDetail(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias);
+
+    @Get("/non_updated_version_tables")
+    ImmutableList<String> nonUpdatedVersionTables();
+
+    @Get("/updated_version_tables")
+    ImmutableList<String> updatedVersionTables();
 }

service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/controller/InfoController.java

@@ -89,4 +89,14 @@ public class InfoController {
     public SyncState syncState(@RequestParam("flink_job_id") Long flinkJobId, @RequestParam("alias") String alias) {
         return infoService.syncState(flinkJobId, alias);
     }
+
+    @GetMapping("/non_updated_version_tables")
+    public ImmutableList<String> nonUpdatedVersionTables() {
+        return infoService.nonUpdatedVersionTables();
+    }
+
+    @GetMapping("/updated_version_tables")
+    public ImmutableList<String> updatedVersionTables() {
+        return infoService.nonUpdatedVersionTables();
+    }
 }

service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/InfoService.java

@@ -186,4 +186,16 @@ public class InfoService {
     public TableMeta tableMeta(Long flinkJobId, String alias) {
         return databaseService.getTableMeta(flinkJobId, alias);
     }
+
+    @Cacheable("un-updated-version-table")
+    @Retryable(Throwable.class)
+    public ImmutableList<String> nonUpdatedVersionTables() {
+        return databaseService.findAllUnScheduledTable();
+    }
+
+    @Cacheable("updated-version-table")
+    @Retryable(Throwable.class)
+    public ImmutableList<String> updatedVersionTables() {
+        return databaseService.findAllScheduledTable();
+    }
 }