diff --git a/jeecg-module-sync/src/main/java/org/jeecg/taskConfig/service/impl/StasTaskConfigServiceImpl.java b/jeecg-module-sync/src/main/java/org/jeecg/taskConfig/service/impl/StasTaskConfigServiceImpl.java
index 5e70f87..36907d0 100644
--- a/jeecg-module-sync/src/main/java/org/jeecg/taskConfig/service/impl/StasTaskConfigServiceImpl.java
+++ b/jeecg-module-sync/src/main/java/org/jeecg/taskConfig/service/impl/StasTaskConfigServiceImpl.java
@@ -49,30 +49,20 @@ public class StasTaskConfigServiceImpl extends ServiceImpl<StasTaskConfigMapper,
      */
     @Override
     public MindMapVO getMindMap(String taskId) {
-        // 1. 使用多线程并行查询数据库
-        CompletableFuture<StasTaskConfig> taskConfigFuture = CompletableFuture.supplyAsync(() ->
-                stasTaskConfigMapper.selectById(taskId));
+        StasTaskConfig stasTaskConfig = stasTaskConfigMapper.selectById(taskId);
+        if(Objects.isNull(stasTaskConfig)) {
+            throw new RuntimeException("此任务不存在");
+        }
+        LambdaQueryWrapper<StasSyncStrategy> strategyQueryWrapper = new LambdaQueryWrapper<>();
+        strategyQueryWrapper.eq(StasSyncStrategy::getTaskId, taskId);
+        List<StasSyncStrategy> syncStrategies = stasSyncStrategyMapper.selectList(strategyQueryWrapper);
 
-        CompletableFuture<List<StasSyncStrategy>> strategiesFuture = taskConfigFuture.thenApplyAsync(config ->
-                stasSyncStrategyMapper.selectList(
-                        new LambdaQueryWrapper<StasSyncStrategy>()
-                                .eq(StasSyncStrategy::getTaskId, taskId)));
-
-        CompletableFuture<StasDataSource> dataSourceFuture = taskConfigFuture.thenApplyAsync(config ->
-                stasDataSourceMapper.selectById(config.getSourceId()));
-
-        // 2. 等待所有查询完成
-        CompletableFuture.allOf(taskConfigFuture, strategiesFuture, dataSourceFuture).join();
-
-        // 3. 构建响应对象
-        StasDataSource sourceInfo = dataSourceFuture.join();
-        List<StasSyncStrategy> stasSyncStrategies = strategiesFuture.join();
+        StasDataSource stasDataSource = stasDataSourceMapper.selectById(stasTaskConfig.getSourceId());
 
         MindMapVO mindMapVO = new MindMapVO();
-        mindMapVO.setDatabaseName(sourceInfo.getInstanceName());
+        mindMapVO.setDatabaseName(stasDataSource.getInstanceName());
 
-        // 4. 使用流式处理简化代码
-        List<UserInfoVO> userInfos = stasSyncStrategies.stream()
+        List<UserInfoVO> userInfos = syncStrategies.stream()
                 .collect(Collectors.groupingBy(StasSyncStrategy::getSourceOwner))
                 .entrySet().stream()
                 .map(entry -> {
@@ -84,6 +74,7 @@ public class StasTaskConfigServiceImpl extends ServiceImpl<StasTaskConfigMapper,
                                 TableInfoVO tableInfoVO = new TableInfoVO();
                                 tableInfoVO.setTableName(strategy.getTableName());
                                 tableInfoVO.setColumnName(strategy.getColumnName());
+                                tableInfoVO.setSyncCount(strategy.getSyncCount());
                                 return tableInfoVO;
                             })
                             .collect(Collectors.toList());
diff --git a/jeecg-module-sync/src/main/java/org/jeecg/vo/TableInfoVO.java b/jeecg-module-sync/src/main/java/org/jeecg/vo/TableInfoVO.java
index 4492767..4f794a3 100644
--- a/jeecg-module-sync/src/main/java/org/jeecg/vo/TableInfoVO.java
+++ b/jeecg-module-sync/src/main/java/org/jeecg/vo/TableInfoVO.java
@@ -6,4 +6,5 @@ import lombok.Data;
 public class TableInfoVO {
     private String tableName;
     private String columnName;
+    private Integer syncCount;
 }