新增参数判断

src/main/java/cn/qg/holmes/controller/monitor/SqlMonitorTaskController.java

@@ -159,7 +159,13 @@ public class SqlMonitorTaskController {
      */
     @PostMapping("/execute")
     public JsonResult executeSql(@RequestParam Integer dsId, @RequestParam String sql) {
+        if (dsId == null) {
+            return JsonResult.buildErrorStateResult("数据源不能为空！", false);
+        }
         SqlMonitorDataSource sqlMonitorDataSource = sqlMonitorDataSourceService.getById(dsId);
+        if (sqlMonitorDataSource == null) {
+            return JsonResult.buildErrorStateResult("数据源不存在！", false);
+        }
         List<Map<String, Object>> resultList = JdbcUtils.queryForList(sqlMonitorDataSource.getHost(), sqlMonitorDataSource.getPort(), sqlMonitorDataSource.getUsername(),
                 sqlMonitorDataSource.getPassword(), null, sql);
         return JsonResult.buildSuccessResult(resultList);
@@ -175,7 +181,13 @@ public class SqlMonitorTaskController {
     public JsonResult testMonitorTask(@RequestBody SqlMonitorTask sqlMonitorTask) {
         try {
             Integer dsId = sqlMonitorTask.getDsId();
+            if (dsId == null) {
+                return JsonResult.buildErrorStateResult("数据源不能为空！", false);
+            }
             SqlMonitorDataSource sqlMonitorDataSource = sqlMonitorDataSourceService.getById(dsId);
+            if (sqlMonitorDataSource == null) {
+                return JsonResult.buildErrorStateResult("数据源不存在！", false);
+            }
             List<Map<String, Object>> resultList = JdbcUtils.queryForList(sqlMonitorDataSource.getHost(), sqlMonitorDataSource.getPort(),
                     sqlMonitorDataSource.getUsername(), sqlMonitorDataSource.getPassword(), null, sqlMonitorTask.getSql());
             String dingUrl = sqlMonitorTask.getDingUrl();