更新数据同步

This commit is contained in:
2025-11-17 14:40:41 +08:00
parent add23676b2
commit 84acc5c1e4

View File

@@ -109,6 +109,7 @@ public class jobController {
dataTableFieldService.save(field); dataTableFieldService.save(field);
} }
dataTableInfoService.save(tableInfo); dataTableInfoService.save(tableInfo);
logger.info("已同步数据库:", tableInfo.getDataSource(), ",数据表:", tableInfo.getTableName(), ",总计:", tableFields.size(), "个字段");
} }
} catch (Exception e) { } catch (Exception e) {
logger.error(e.getMessage()); logger.error(e.getMessage());
@@ -118,7 +119,7 @@ public class jobController {
} }
try { try {
CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])) CompletableFuture.allOf(futures.toArray(new CompletableFuture[0]))
.get(60, TimeUnit.SECONDS); // 超时时间可根据业务调整 .get(30, TimeUnit.SECONDS);
return ApiResult.success(); return ApiResult.success();
} catch (Exception e) { } catch (Exception e) {
return ApiResult.error(101, e.getMessage()); return ApiResult.error(101, e.getMessage());