fix:() 优化任务调动方法

cloud-property-server/src/main/java/com/muyu/server/service/impl/DataLinkServiceImpl.java

@@ -81,6 +81,7 @@ public class DataLinkServiceImpl implements DataLinkService {
         BaseQueryHandler.set(mySqlQuery);
         MySqlDataSource mySqlDataSource = new MySqlDataSource();
         DataValue[][] rows = mySqlDataSource.getSqlDataSource();
+        log.info("rows：{}",rows);
         return rows;
     }
 

cloud-property-server/src/main/java/com/muyu/server/service/impl/DataRunNameServiceImpl.java

@@ -116,11 +116,11 @@ public class DataRunNameServiceImpl implements DataRunNameService {
         //数据库名称查询
         List<DataName> dataNameList = dataNameService.list().stream()
                 .map(DataName::dataNameBuild).toList();
-
+        HashSet<TableNames> set1 = new HashSet<>();
         //遍历获取数据数据库名称对象
         dataNameList.forEach(dataName -> {
 
-            List<TableNames> set1;
+
 
                 //使用安全管理工具获取当前登录的用户对象
                 LoginUser loginUser = SecurityUtils.getLoginUser();
@@ -138,7 +138,7 @@ public class DataRunNameServiceImpl implements DataRunNameService {
                 // 调用assetImpowerService服务的findTableIdAndBasicIdByDeptId方法
                 // 传入部门ID，获取该部门下所有授权的表ID和基础ID
                 List<AssetAuthorization> idByDeptId = dataRunNameMapper.findTableIdAndBasicIdByDeptId(deptId);
-                set1 = new ArrayList<>();
+
                 //在取数据数据遍历里获取表名称查询方法
                 tableIdAndBasicIdByUserId.forEach(tableIdAndBasicId -> {
 
@@ -152,7 +152,8 @@ public class DataRunNameServiceImpl implements DataRunNameService {
                     System.out.println(tableNames);
                     set1.addAll(tableNames);
                 });
-            dataName.setTableNames(set1);
+            List<TableNames> set2 = new ArrayList<>(set1);
+            dataName.setTableNames(set2);
         });
         //返回所有数据
         return dataNameList;