diff --git a/src/main/java/com/mini/capi/api/job/jobController.java b/src/main/java/com/mini/capi/api/job/jobController.java index b3a2df8..37dff71 100644 --- a/src/main/java/com/mini/capi/api/job/jobController.java +++ b/src/main/java/com/mini/capi/api/job/jobController.java @@ -12,7 +12,6 @@ import com.mini.capi.model.info.TableTree; import com.mini.capi.utils.*; import jakarta.annotation.Resource; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; -import org.springframework.util.StringUtils; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; @@ -97,7 +96,7 @@ public class jobController { @GetMapping("getJobDataTableMarge") public ApiResult getJobDataTableMarge() { QueryWrapper queryWrapper = new QueryWrapper<>(); - queryWrapper.eq("is_enabled","1"); + queryWrapper.eq("is_enabled", "1"); List configs = bizDbConfigService.list(queryWrapper); List> futures = new ArrayList<>(configs.size()); for (BizDbConfig config : configs) { @@ -107,8 +106,8 @@ public class jobController { for (TableTree tableTree : tableTrees) { DataTableInfo tableInfo = tableTree.getTableInfo(); List tableFields = tableTree.getTableFields(); - for (DataTableField field : tableFields) { - dataTableFieldService.save(field); + for (DataTableField tableField : tableFields) { + dataTableFieldService.save(tableField); } dataTableInfoService.save(tableInfo); logger.info("已同步数据库:", tableInfo.getDataSource(), ",数据表:", tableInfo.getTableName(), ",总计:", tableFields.size(), "个字段");