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

cloud-property-server/src/main/java/com/muyu/server/controller/DataLinkController.java

@@ -37,11 +37,11 @@ public class DataLinkController {
     }
 
     /**
-     * 查询表数据count
+     * 添加产品数据库
      * @param databaseName 数据库名称
-     * @param tableName sql语句
-     * @param listList sql语句
-     * @return 反护试图
+     * @param tableName 表名称
+     * @param listList 添加数据
+     * @return 返回试图
      */
     @PostMapping("/addProduct")
     public Result addProduct(@RequestParam("databaseName") String databaseName,

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

@@ -23,7 +23,7 @@ public interface DataLinkService {
      * 查询表数据count
      * @param dataName 数据库名称
      * @param sql sql语句
-     * @return 反护试图
+     * @return 返回试图
      */
     public Long findCount(String dataName, String sql);
 
@@ -34,37 +34,37 @@ public interface DataLinkService {
      * @param sql      sql语句
      * @param one
      * @param two
-     * @return 反护试图
+     * @return 返回试图
      */
     DataValue[][] findSelectDataList(String databaseName, String sql, String tableName, Long one, Integer two);
 
     /**
      * 查询表数据下所有表表
      * @para 数据库名称
-     * @return 反护试图
+     * @return 返回试图
      */
     List<DataName> findSelectDataShow();
 
     /**
      * 查询表数据dashuju表
      * @param id 查看表下的所有数据
-     * @return 反护试图
+     * @return 返回试图
      */
     List<TableNames> findSelectTableShow(Integer id);
 
     /**
      * 查询表数据dashuju表
      * @param dataTableName 查看表下的所有数据
-     * @return 反护试图
+     * @return 返回试图
      */
     List<TableFie> findSelectTableFieShow(String dataTableName);
 
     /**
-     * 查询表数据count
+     * 添加产品数据库
      * @param databaseName 数据库名称
-     * @param tableName sql语句
-     * @param listList sql语句
-     * @return 反护试图
+     * @param tableName 表名称
+     * @param listList 添加数据
+     * @return 返回试图
      */
     int addProduct(String databaseName, String tableName, DataValue[]... listList);
 }

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

@@ -134,9 +134,9 @@ public class DataLinkServiceImpl implements DataLinkService {
     /**
      * 添加方法
      * @param databaseName 数据库名称
-     * @param tableName sql语句
-     * @param listList sql语句
-     * @return
+     * @param tableName 表名称
+     * @param listList 数据值
+     * @return 返回视图
      */
     @Override
     @Log(title = "添加产品数据库", businessType = BusinessType.INSERT)
@@ -242,6 +242,9 @@ public class DataLinkServiceImpl implements DataLinkService {
 
         // 构建字段名
         for (DataValue dataValue : batch[0]) {
+            if (dataValue == null) {
+                throw new IllegalArgumentException("dataValue cannot be null");
+            }
             String key = dataValue.getKey();
             columns.append(key).append(", ");
         }