Skip to content

H
holmes
Commit 0b6b9a2f authored by 黎博's avatar 黎博
Browse files
Options

修改表名及接口url

parent c2145f1f
Hide whitespace changes
Inline Side-by-side
Showing with 150 additions and 114 deletions
src/main/java/cn/qg/holmes/config/QuartzInitRunner.java
View file @ 0b6b9a2f
package cn.qg.holmes.config;
import cn.qg.holmes.entity.monitor.MonitorTask;
import cn.qg.holmes.service.monitor.MonitorTaskService;
import cn.qg.holmes.entity.monitor.SqlMonitorTask;
import cn.qg.holmes.service.monitor.SqlMonitorTaskService;
import cn.qg.holmes.utils.QuartzUtils;
import lombok.extern.slf4j.Slf4j;
import org.quartz.Scheduler;
......@@ -22,17 +22,17 @@ import java.util.List;
public class QuartzInitRunner implements ApplicationRunner {
@Autowired
MonitorTaskService monitorTaskService;
SqlMonitorTaskService sqlMonitorTaskService;
@Autowired
private Scheduler scheduler;
@Override
public void run(ApplicationArguments args) {
List<MonitorTask> monitorTaskList = monitorTaskService.list();
for (MonitorTask monitorTask: monitorTaskList) {
if (monitorTask.getStatus() == 1) {
QuartzUtils.createScheduleJob(scheduler, monitorTask);
List<SqlMonitorTask> sqlMonitorTaskList = sqlMonitorTaskService.list();
for (SqlMonitorTask sqlMonitorTask : sqlMonitorTaskList) {
if (sqlMonitorTask.getStatus() == 1) {
QuartzUtils.createSqlScheduleJob(scheduler, sqlMonitorTask);
}
}
}
......
src/main/java/cn/qg/holmes/controller/monitor/MonitorDataSourceController.java → src/main/java/cn/qg/holmes/controller/monitor/SqlMonitorDataSourceController.java
View file @ 0b6b9a2f
package cn.qg.holmes.controller.monitor;
import cn.qg.holmes.common.JsonResult;
import cn.qg.holmes.entity.monitor.MonitorDataSource;
import cn.qg.holmes.service.monitor.MonitorDataSourceService;
import cn.qg.holmes.entity.monitor.SqlMonitorDataSource;
import cn.qg.holmes.service.monitor.SqlMonitorDataSourceService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
......@@ -19,10 +19,10 @@ import java.util.Map;
@CrossOrigin
@RestController
@RequestMapping("/monitor/ds")
public class MonitorDataSourceController {
public class SqlMonitorDataSourceController {
@Autowired
MonitorDataSourceService monitorDataSourceService;
SqlMonitorDataSourceService sqlMonitorDataSourceService;
/**
* 获取监控数据源列表，带分页和筛选
......@@ -35,12 +35,12 @@ public class MonitorDataSourceController {
public JsonResult getMonitorDataSourceListWithPaging(@RequestParam(defaultValue = "1") Integer pageNum,
@RequestParam(defaultValue = "10") Integer pageSize,
String dsName) {
IPage<MonitorDataSource> IPageParam = new Page<>(pageNum, pageSize);
QueryWrapper<MonitorDataSource> queryWrapper = new QueryWrapper<>();
IPage<SqlMonitorDataSource> IPageParam = new Page<>(pageNum, pageSize);
QueryWrapper<SqlMonitorDataSource> queryWrapper = new QueryWrapper<>();
if (!StringUtils.isEmpty(dsName)) {
queryWrapper.eq("name", dsName);
}
IPage<MonitorDataSource> IPageResult = monitorDataSourceService.page(IPageParam);
IPage<SqlMonitorDataSource> IPageResult = sqlMonitorDataSourceService.page(IPageParam);
Map<String, Object> dsResult = new HashMap<>();
dsResult.put("total", IPageResult.getTotal());
dsResult.put("list", IPageResult.getRecords());
......@@ -53,50 +53,50 @@ public class MonitorDataSourceController {
*/
@GetMapping("/list")
public JsonResult getMonitorDataSourceList() {
return JsonResult.buildSuccessResult(monitorDataSourceService.list());
return JsonResult.buildSuccessResult(sqlMonitorDataSourceService.list());
}
/**
* 添加监控数据源
* @param monitorDataSource
* @param sqlMonitorDataSource
* @return
*/
@PostMapping("/add")
public JsonResult addMonitorDataSource(@RequestBody MonitorDataSource monitorDataSource) {
return JsonResult.buildSuccessResult(monitorDataSourceService.saveOrUpdate(monitorDataSource));
public JsonResult addMonitorDataSource(@RequestBody SqlMonitorDataSource sqlMonitorDataSource) {
return JsonResult.buildSuccessResult(sqlMonitorDataSourceService.saveOrUpdate(sqlMonitorDataSource));
}
/**
* 更新监控数据源
* @param monitorDataSource
* @param sqlMonitorDataSource
* @return
*/
@PostMapping("/update")
public JsonResult updateMonitorDataSource(@RequestBody MonitorDataSource monitorDataSource) {
Integer dsId = monitorDataSource.getId();
public JsonResult updateMonitorDataSource(@RequestBody SqlMonitorDataSource sqlMonitorDataSource) {
Integer dsId = sqlMonitorDataSource.getId();
if (dsId == null) {
return JsonResult.buildErrorStateResult("数据源不存在！", null);
}
if (monitorDataSourceService.getById(dsId) == null) {
if (sqlMonitorDataSourceService.getById(dsId) == null) {
return JsonResult.buildErrorStateResult("数据源不存在", null);
}
return JsonResult.buildSuccessResult(monitorDataSourceService.saveOrUpdate(monitorDataSource));
return JsonResult.buildSuccessResult(sqlMonitorDataSourceService.saveOrUpdate(sqlMonitorDataSource));
}
/**
* 删除监控数据源
* @param monitorDataSource
* @param sqlMonitorDataSource
* @return
*/
@PostMapping("/delete")
public JsonResult deleteMonitorDataSource(@RequestBody MonitorDataSource monitorDataSource) {
Integer dsId = monitorDataSource.getId();
public JsonResult deleteMonitorDataSource(@RequestBody SqlMonitorDataSource sqlMonitorDataSource) {
Integer dsId = sqlMonitorDataSource.getId();
if (dsId == null) {
return JsonResult.buildErrorStateResult("数据源不存在！", null);
}
if (monitorDataSourceService.getById(dsId) == null) {
if (sqlMonitorDataSourceService.getById(dsId) == null) {
return JsonResult.buildErrorStateResult("数据源不存在", null);
}
return JsonResult.buildSuccessResult(monitorDataSourceService.getById(dsId));
return JsonResult.buildSuccessResult(sqlMonitorDataSourceService.getById(dsId));
}
}
src/main/java/cn/qg/holmes/controller/monitor/MonitorTaskController.java → src/main/java/cn/qg/holmes/controller/monitor/SqlMonitorTaskController.java
View file @ 0b6b9a2f
package cn.qg.holmes.controller.monitor;
import cn.qg.holmes.common.JsonResult;
import cn.qg.holmes.entity.monitor.MonitorDataSource;
import cn.qg.holmes.entity.monitor.MonitorTask;
import cn.qg.holmes.service.monitor.MonitorDataSourceService;
import cn.qg.holmes.service.monitor.MonitorTaskService;
import cn.qg.holmes.entity.monitor.SqlMonitorDataSource;
import cn.qg.holmes.entity.monitor.SqlMonitorTask;
import cn.qg.holmes.service.monitor.SqlMonitorDataSourceService;
import cn.qg.holmes.service.monitor.SqlMonitorTaskService;
import cn.qg.holmes.utils.DingdingUtils;
import cn.qg.holmes.utils.JdbcUtils;
import com.alibaba.fastjson.JSON;
......@@ -25,14 +25,14 @@ import java.util.Map;
*/
@CrossOrigin
@RestController
@RequestMapping("/monitor/task")
public class MonitorTaskController {
@RequestMapping("/sql/monitor")
public class SqlMonitorTaskController {
@Autowired
MonitorTaskService monitorTaskService;
SqlMonitorTaskService sqlMonitorTaskService;
@Autowired
MonitorDataSourceService monitorDataSourceService;
SqlMonitorDataSourceService sqlMonitorDataSourceService;
@Autowired
JdbcTemplate jdbcTemplate;
......@@ -50,7 +50,7 @@ public class MonitorTaskController {
@RequestParam(defaultValue = "10") Integer pageSize,
@RequestParam String serviceName,
@RequestParam String taskName) {
QueryWrapper<MonitorTask> queryWrapper = new QueryWrapper<>();
QueryWrapper<SqlMonitorTask> queryWrapper = new QueryWrapper<>();
if (!StringUtils.isEmpty(serviceName)) {
queryWrapper.eq("service_name", serviceName);
}
......@@ -58,14 +58,14 @@ public class MonitorTaskController {
queryWrapper.eq("task_name", taskName);
}
queryWrapper.orderByDesc("id");
IPage<MonitorTask> pageParam = new Page<>(pageNum, pageSize);
IPage<MonitorTask> monitorTaskIPage = monitorTaskService.page(pageParam, queryWrapper);
List<MonitorTask> monitorTaskList = monitorTaskIPage.getRecords();
for (MonitorTask monitorTask: monitorTaskList) {
monitorTask.setDsName(monitorDataSourceService.getById(monitorTask.getDsId()).getName());
IPage<SqlMonitorTask> pageParam = new Page<>(pageNum, pageSize);
IPage<SqlMonitorTask> monitorTaskIPage = sqlMonitorTaskService.page(pageParam, queryWrapper);
List<SqlMonitorTask> sqlMonitorTaskList = monitorTaskIPage.getRecords();
for (SqlMonitorTask sqlMonitorTask : sqlMonitorTaskList) {
sqlMonitorTask.setDsName(sqlMonitorDataSourceService.getById(sqlMonitorTask.getDsId()).getName());
}
Map<String, Object> resultMap = new HashMap<>();
resultMap.put("list", monitorTaskList);
resultMap.put("list", sqlMonitorTaskList);
resultMap.put("total", monitorTaskIPage.getTotal());
return JsonResult.buildSuccessResult(resultMap);
}
......@@ -73,38 +73,38 @@ public class MonitorTaskController {
/**
* 新增监控
*
* @param monitorTask
* @param sqlMonitorTask
* @return
*/
@PostMapping("/add")
public JsonResult addMonitorTask(@RequestBody MonitorTask monitorTask) {
return JsonResult.buildSuccessResult(monitorTaskService.save(monitorTask));
public JsonResult addMonitorTask(@RequestBody SqlMonitorTask sqlMonitorTask) {
return JsonResult.buildSuccessResult(sqlMonitorTaskService.save(sqlMonitorTask));
}
/**
* 修改监控
*
* @param monitorTask
* @param sqlMonitorTask
* @return
*/
@PostMapping("/edit")
public JsonResult editMonitorTask(@RequestBody MonitorTask monitorTask) {
return JsonResult.buildSuccessResult(monitorTaskService.saveOrUpdate(monitorTask));
public JsonResult editMonitorTask(@RequestBody SqlMonitorTask sqlMonitorTask) {
return JsonResult.buildSuccessResult(sqlMonitorTaskService.saveOrUpdate(sqlMonitorTask));
}
/**
* 删除监控
*
* @param monitorTask
* @param sqlMonitorTask
* @return
*/
@PostMapping("/delete")
public JsonResult deleteMonitorTask(@RequestBody MonitorTask monitorTask) {
Integer taskId = monitorTask.getId();
if (monitorTaskService.getById(taskId) == null) {
public JsonResult deleteMonitorTask(@RequestBody SqlMonitorTask sqlMonitorTask) {
Integer taskId = sqlMonitorTask.getId();
if (sqlMonitorTaskService.getById(taskId) == null) {
return JsonResult.buildErrorStateResult("定时任务不存在!", false);
}
boolean delResult = monitorTaskService.removeById(taskId);
boolean delResult = sqlMonitorTaskService.removeById(taskId);
if (delResult) {
return JsonResult.buildSuccessResult("删除成功!");
} else {
......@@ -121,27 +121,27 @@ public class MonitorTaskController {
*/
@PostMapping("/execute")
public JsonResult executeSql(@RequestParam Integer dsId, @RequestParam String sql) {
MonitorDataSource monitorDataSource = monitorDataSourceService.getById(dsId);
List<Map<String, Object>> resultList = JdbcUtils.queryForList(monitorDataSource.getHost(), monitorDataSource.getPort(), monitorDataSource.getUsername(),
monitorDataSource.getPassword(), null, sql);
SqlMonitorDataSource sqlMonitorDataSource = sqlMonitorDataSourceService.getById(dsId);
List<Map<String, Object>> resultList = JdbcUtils.queryForList(sqlMonitorDataSource.getHost(), sqlMonitorDataSource.getPort(), sqlMonitorDataSource.getUsername(),
sqlMonitorDataSource.getPassword(), null, sql);
return JsonResult.buildSuccessResult(resultList);
}
/**
* 发送测试，立即测试下定时任务发送消息是否准确
*
* @param monitorTask 监控任务
* @param sqlMonitorTask 监控任务
* @return
*/
@PostMapping("/test")
public JsonResult testMonitorTask(@RequestBody MonitorTask monitorTask) {
public JsonResult testMonitorTask(@RequestBody SqlMonitorTask sqlMonitorTask) {
try {
Integer dsId = monitorTask.getDsId();
MonitorDataSource monitorDataSource = monitorDataSourceService.getById(dsId);
List<Map<String, Object>> resultList = JdbcUtils.queryForList(monitorDataSource.getHost(), monitorDataSource.getPort(),
monitorDataSource.getUsername(), monitorDataSource.getPassword(), null, monitorTask.getSql());
String dingUrl = monitorTask.getDingUrl();
String dingText = monitorTask.getDingText();
Integer dsId = sqlMonitorTask.getDsId();
SqlMonitorDataSource sqlMonitorDataSource = sqlMonitorDataSourceService.getById(dsId);
List<Map<String, Object>> resultList = JdbcUtils.queryForList(sqlMonitorDataSource.getHost(), sqlMonitorDataSource.getPort(),
sqlMonitorDataSource.getUsername(), sqlMonitorDataSource.getPassword(), null, sqlMonitorTask.getSql());
String dingUrl = sqlMonitorTask.getDingUrl();
String dingText = sqlMonitorTask.getDingText();
dingText = dingText.replaceAll("\\{count}", String.valueOf(resultList.size()));
String markdownMsg = DingdingUtils.buildMarkdownMsg("监控测试", dingText + "\n" + JSON.toJSONString(resultList), false);
boolean result = DingdingUtils.sendToDingding(markdownMsg, dingUrl);
......
src/main/java/cn/qg/holmes/entity/monitor/MonitorDataSource.java → src/main/java/cn/qg/holmes/entity/monitor/SqlMonitorDataSource.java
View file @ 0b6b9a2f
......@@ -14,8 +14,8 @@ import java.util.Date;
* @author libo
*/
@Data
@TableName(value = "monitor_data_source")
public class MonitorDataSource {
@TableName(value = "sql_monitor_data_source")
public class SqlMonitorDataSource {
@TableId(type = IdType.AUTO)
private Integer id;
......
src/main/java/cn/qg/holmes/entity/monitor/MonitorTask.java → src/main/java/cn/qg/holmes/entity/monitor/SqlMonitorTask.java
View file @ 0b6b9a2f
......@@ -16,8 +16,8 @@ import java.util.Date;
* @author libo
*/
@Data
@TableName(value = "monitor_task")
public class MonitorTask {
@TableName(value = "sql_monitor_task")
public class SqlMonitorTask {
@TableId(type = IdType.AUTO)
private Integer id;
......
src/main/java/cn/qg/holmes/mapper/monitor/MonitorDataSourceMapper.java → src/main/java/cn/qg/holmes/mapper/monitor/SqlMonitorDataSourceMapper.java
View file @ 0b6b9a2f
package cn.qg.holmes.mapper.monitor;
import cn.qg.holmes.entity.monitor.MonitorDataSource;
import cn.qg.holmes.entity.monitor.SqlMonitorDataSource;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
public interface MonitorDataSourceMapper extends BaseMapper<MonitorDataSource> {
public interface SqlMonitorDataSourceMapper extends BaseMapper<SqlMonitorDataSource> {
}
src/main/java/cn/qg/holmes/mapper/monitor/MonitorTaskMapper.java → src/main/java/cn/qg/holmes/mapper/monitor/SqlMonitorTaskMapper.java
View file @ 0b6b9a2f
package cn.qg.holmes.mapper.monitor;
import cn.qg.holmes.entity.monitor.MonitorTask;
import cn.qg.holmes.entity.monitor.SqlMonitorTask;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
public interface MonitorTaskMapper extends BaseMapper<MonitorTask> {
public interface SqlMonitorTaskMapper extends BaseMapper<SqlMonitorTask> {
}
src/main/java/cn/qg/holmes/quartz/SqlMonitorTask.java
View file @ 0b6b9a2f
package cn.qg.holmes.quartz;
import cn.qg.holmes.entity.monitor.MonitorDataSource;
import cn.qg.holmes.entity.monitor.MonitorTask;
import cn.qg.holmes.service.monitor.MonitorDataSourceService;
import cn.qg.holmes.service.monitor.MonitorTaskService;
import cn.qg.holmes.entity.monitor.SqlMonitorDataSource;
import cn.qg.holmes.service.monitor.SqlMonitorDataSourceService;
import cn.qg.holmes.service.monitor.SqlMonitorTaskService;
import cn.qg.holmes.utils.DingdingUtils;
import cn.qg.holmes.utils.JdbcUtils;
import com.alibaba.fastjson.JSON;
......@@ -27,10 +26,10 @@ import java.util.regex.Pattern;
public class SqlMonitorTask extends QuartzJobBean {
@Autowired
MonitorDataSourceService monitorDataSourceService;
SqlMonitorDataSourceService sqlMonitorDataSourceService;
@Autowired
MonitorTaskService monitorTaskService;
SqlMonitorTaskService sqlMonitorTaskService;
@Override
protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
......@@ -38,17 +37,17 @@ public class SqlMonitorTask extends QuartzJobBean {
// 定时任务名称
String taskName = jobDetail.getKey().getName();
// 获取定时任务信息
QueryWrapper<MonitorTask> monitorTaskQueryWrapper = new QueryWrapper<>();
QueryWrapper<cn.qg.holmes.entity.monitor.SqlMonitorTask> monitorTaskQueryWrapper = new QueryWrapper<>();
monitorTaskQueryWrapper.eq("task_name", taskName);
MonitorTask monitorTask = monitorTaskService.getOne(monitorTaskQueryWrapper);
cn.qg.holmes.entity.monitor.SqlMonitorTask sqlMonitorTask = sqlMonitorTaskService.getOne(monitorTaskQueryWrapper);
// 获取数据源相关信息
Integer dsId = monitorTask.getDsId();
MonitorDataSource monitorDataSource = monitorDataSourceService.getById(dsId);
Integer dsId = sqlMonitorTask.getDsId();
SqlMonitorDataSource sqlMonitorDataSource = sqlMonitorDataSourceService.getById(dsId);
List<Map<String, Object>> resultList = JdbcUtils.queryForList(monitorDataSource.getHost(), monitorDataSource.getPort(),
monitorDataSource.getUsername(), monitorDataSource.getPassword(), null, monitorTask.getSql());
String dingUrl = monitorTask.getDingUrl();
String dingText = monitorTask.getDingText();
List<Map<String, Object>> resultList = JdbcUtils.queryForList(sqlMonitorDataSource.getHost(), sqlMonitorDataSource.getPort(),
sqlMonitorDataSource.getUsername(), sqlMonitorDataSource.getPassword(), null, sqlMonitorTask.getSql());
String dingUrl = sqlMonitorTask.getDingUrl();
String dingText = sqlMonitorTask.getDingText();
dingText = replaceDingText(dingText, resultList);
String markdownMsg = DingdingUtils.buildMarkdownMsg("监控测试", dingText + "\n" + JSON.toJSONString(resultList), false);
DingdingUtils.sendToDingding(markdownMsg, dingUrl);
......
src/main/java/cn/qg/holmes/service/monitor/MonitorService.java deleted 100644 → 0
View file @ c2145f1f
package cn.qg.holmes.service.monitor;
/**
* 监控Service
*/
public interface MonitorService {
}
src/main/java/cn/qg/holmes/service/monitor/MonitorDataSourceService.java → src/main/java/cn/qg/holmes/service/monitor/SqlMonitorDataSourceService.java
View file @ 0b6b9a2f
package cn.qg.holmes.service.monitor;
import cn.qg.holmes.entity.monitor.MonitorDataSource;
import cn.qg.holmes.entity.monitor.SqlMonitorDataSource;
import com.baomidou.mybatisplus.extension.service.IService;
/**
* 监控数据源Service
*/
public interface MonitorDataSourceService extends IService<MonitorDataSource> {
public interface SqlMonitorDataSourceService extends IService<SqlMonitorDataSource> {
}
src/main/java/cn/qg/holmes/service/monitor/MonitorTaskService.java → src/main/java/cn/qg/holmes/service/monitor/SqlMonitorTaskService.java
View file @ 0b6b9a2f
package cn.qg.holmes.service.monitor;
import cn.qg.holmes.entity.monitor.MonitorTask;
import cn.qg.holmes.entity.monitor.SqlMonitorTask;
import com.baomidou.mybatisplus.extension.service.IService;
public interface MonitorTaskService extends IService<MonitorTask> {
public interface SqlMonitorTaskService extends IService<SqlMonitorTask> {
}
src/main/java/cn/qg/holmes/service/monitor/impl/MonitorServiceImpl.java deleted 100644 → 0
View file @ c2145f1f
package cn.qg.holmes.service.monitor.impl;
import cn.qg.holmes.service.monitor.MonitorService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
@Slf4j
@Service
public class MonitorServiceImpl implements MonitorService {
}
src/main/java/cn/qg/holmes/service/monitor/impl/MonitorDataSourceServiceImpl.java → src/main/java/cn/qg/holmes/service/monitor/impl/SqlMonitorDataSourceServiceImpl.java
View file @ 0b6b9a2f
package cn.qg.holmes.service.monitor.impl;
import cn.qg.holmes.entity.monitor.MonitorDataSource;
import cn.qg.holmes.mapper.monitor.MonitorDataSourceMapper;
import cn.qg.holmes.service.monitor.MonitorDataSourceService;
import cn.qg.holmes.entity.monitor.SqlMonitorDataSource;
import cn.qg.holmes.mapper.monitor.SqlMonitorDataSourceMapper;
import cn.qg.holmes.service.monitor.SqlMonitorDataSourceService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
@Service
public class MonitorDataSourceServiceImpl extends ServiceImpl<MonitorDataSourceMapper, MonitorDataSource>
implements MonitorDataSourceService {
public class SqlMonitorDataSourceServiceImpl extends ServiceImpl<SqlMonitorDataSourceMapper, SqlMonitorDataSource>
implements SqlMonitorDataSourceService {
}
src/main/java/cn/qg/holmes/service/monitor/impl/MonitorTaskServiceImpl.java → src/main/java/cn/qg/holmes/service/monitor/impl/SqlMonitorTaskServiceImpl.java
View file @ 0b6b9a2f
package cn.qg.holmes.service.monitor.impl;
import cn.qg.holmes.entity.monitor.MonitorTask;
import cn.qg.holmes.mapper.monitor.MonitorTaskMapper;
import cn.qg.holmes.service.monitor.MonitorTaskService;
import cn.qg.holmes.entity.monitor.SqlMonitorTask;
import cn.qg.holmes.mapper.monitor.SqlMonitorTaskMapper;
import cn.qg.holmes.service.monitor.SqlMonitorTaskService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
@Service
public class MonitorTaskServiceImpl extends ServiceImpl<MonitorTaskMapper, MonitorTask> implements MonitorTaskService {
public class SqlMonitorTaskServiceImpl extends ServiceImpl<SqlMonitorTaskMapper, SqlMonitorTask> implements SqlMonitorTaskService {
}
src/main/java/cn/qg/holmes/utils/QuartzUtils.java
View file @ 0b6b9a2f
package cn.qg.holmes.utils;
import cn.qg.holmes.entity.monitor.MonitorTask;
import cn.qg.holmes.entity.monitor.SqlMonitorTask;
import lombok.extern.slf4j.Slf4j;
import org.quartz.*;
@Slf4j
public class QuartzUtils {
public static void createScheduleJob(Scheduler scheduler, MonitorTask monitorTask) {
public static void createSqlScheduleJob(Scheduler scheduler, SqlMonitorTask sqlMonitorTask) {
try {
Class<? extends Job> jobClass = (Class<? extends Job>) Class.forName("cn.qg.holmes.quartz." + monitorTask.getTaskClass());
Class<? extends Job> jobClass = (Class<? extends Job>) Class.forName("cn.qg.holmes.quartz." + sqlMonitorTask.getTaskClass());
JobDetail jobDetail = JobBuilder
.newJob(jobClass)
.withIdentity(monitorTask.getTaskName())
.withIdentity(sqlMonitorTask.getTaskName())
.build();
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(monitorTask.getTaskCron());
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(sqlMonitorTask.getTaskCron());
CronTrigger cronTrigger = TriggerBuilder
.newTrigger()
.withIdentity(monitorTask.getTaskName())
.withIdentity(sqlMonitorTask.getTaskName())
.withSchedule(scheduleBuilder)
.build();
scheduler.scheduleJob(jobDetail, cronTrigger);
} catch (ClassNotFoundException e) {
log.info("定时任务类: {}路径出错：请输入类的绝对路径", monitorTask.getTaskClass());
log.info("定时任务类: {}路径出错：请输入类的绝对路径", sqlMonitorTask.getTaskClass());
} catch (SchedulerException e) {
log.info("创建定时任务出错:" + e.getMessage());
}
log.info("创建定时任务: {}", monitorTask.getTaskName());
log.info("创建定时任务: {}", sqlMonitorTask.getTaskName());
}
/**
......@@ -78,15 +78,15 @@ public class QuartzUtils {
* 更新定时任务
*
* @param scheduler 调度器
* @param monitorTask 定时任务信息类
* @param sqlMonitorTask 定时任务信息类
* @throws SchedulerException
*/
public static void updateScheduleJob(Scheduler scheduler, MonitorTask monitorTask) {
public static void updateSqlScheduleJob(Scheduler scheduler, SqlMonitorTask sqlMonitorTask) {
try {
//获取到对应任务的触发器
TriggerKey triggerKey = TriggerKey.triggerKey(monitorTask.getTaskName());
TriggerKey triggerKey = TriggerKey.triggerKey(sqlMonitorTask.getTaskName());
//设置定时任务执行方式
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(monitorTask.getTaskCron());
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(sqlMonitorTask.getTaskCron());
//重新构建任务的触发器trigger
CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
trigger = trigger
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment