新增日志

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

@@ -13,6 +13,7 @@ import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.quartz.Scheduler;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -28,6 +29,7 @@ import java.util.Map;
 /**
  * 定时任务Controller
  */
+@Slf4j
 @CrossOrigin
 @RestController
 @RequestMapping("/sql/monitor")
@@ -221,7 +223,7 @@ public class SqlMonitorTaskController {
             }
             String markdownMsg = DingdingUtils.buildMarkdownMsg("监控报警", "**" + sqlMonitorTask.getTaskName() + "**\n\n" + dingText + "\n\n" + "[请" + sqlMonitorTask.getOwner() + "同学跟进，查看报警详情.]" + "(" + qaPlatformHost + "/monitor/addSqlMonitor?id=" + sqlMonitorTask.getId() + ")", true);
             boolean result = DingdingUtils.sendToDingding(markdownMsg, dingUrl);
-            return result ? JsonResult.buildSuccessResult("发送成功！") : JsonResult.buildErrorStateResult("发送失败！", false);
+            return result ? JsonResult.buildSuccessResult("发送成功！", true) : JsonResult.buildErrorStateResult("发送失败！", false);
         } catch (Exception e) {
             e.printStackTrace();
             return JsonResult.buildErrorStateResult("发送异常！", false);

src/main/java/cn/qg/holmes/utils/QuartzUtils.java

 package cn.qg.holmes.utils;
 
 import cn.qg.holmes.entity.monitor.SqlMonitorTask;
+import com.alibaba.fastjson.JSON;
 import lombok.extern.slf4j.Slf4j;
 import org.quartz.*;
 
@@ -38,8 +39,8 @@ public class QuartzUtils {
     public static void pauseScheduleJob(Scheduler scheduler, String jobName) {
         JobKey jobKey = JobKey.jobKey(jobName);
         try {
-            log.info("暂停定时任务：{}", jobName);
             scheduler.pauseJob(jobKey);
+            log.info("暂停定时任务：{}", jobName);
         } catch (SchedulerException e) {
             log.info("暂停定时任务出错：" + e.getMessage());
         }
@@ -54,8 +55,8 @@ public class QuartzUtils {
     public static void resumeScheduleJob(Scheduler scheduler, String jobName) {
         JobKey jobKey = JobKey.jobKey(jobName);
         try {
-            log.info("启动定时任务：{}", jobName);
             scheduler.resumeJob(jobKey);
+            log.info("启动定时任务：{}", jobName);
         } catch (SchedulerException e) {
             log.info("启动定时任务出错：" + e.getMessage());
         }
@@ -71,6 +72,7 @@ public class QuartzUtils {
         JobKey jobKey = JobKey.jobKey(jobName);
         try {
             scheduler.triggerJob(jobKey);
+            log.info("立即执行一次Job：{}", jobName);
         } catch (SchedulerException e) {
             log.info("运行定时任务出错：" + e.getMessage());
         }
@@ -98,6 +100,7 @@ public class QuartzUtils {
                     .build();
             //重置对应的job
             scheduler.rescheduleJob(triggerKey, trigger);
+            log.info("更新定时任务：{}", JSON.toJSONString(sqlMonitorTask));
         } catch (SchedulerException e) {
             System.out.println("更新定时任务出错：" + e.getMessage());
         }
@@ -114,6 +117,7 @@ public class QuartzUtils {
         JobKey jobKey = JobKey.jobKey(jobName);
         try {
             scheduler.deleteJob(jobKey);
+            log.info("删除Job：{}", jobName);
         } catch (SchedulerException e) {
             log.info("删除定时任务出错：" + e.getMessage());
         }