remove 移除 Quartz 后续集成 xxl-job
疯狂的狮子li
parent
6524f2781e
commit
33ec29140e
8
pom.xml
8
pom.xml
|
|
@ -33,7 +33,6 @@
|
||||||
<commons.io.version>2.11.0</commons.io.version>
|
<commons.io.version>2.11.0</commons.io.version>
|
||||||
<commons.fileupload.version>1.4</commons.fileupload.version>
|
<commons.fileupload.version>1.4</commons.fileupload.version>
|
||||||
<velocity.version>2.3</velocity.version>
|
<velocity.version>2.3</velocity.version>
|
||||||
<fastjson.version>1.2.79</fastjson.version>
|
|
||||||
<jjwt.version>0.9.1</jjwt.version>
|
<jjwt.version>0.9.1</jjwt.version>
|
||||||
<minio.version>8.2.2</minio.version>
|
<minio.version>8.2.2</minio.version>
|
||||||
<poi.version>4.1.2</poi.version>
|
<poi.version>4.1.2</poi.version>
|
||||||
|
|
@ -191,13 +190,6 @@
|
||||||
<version>${commons-collections.version}</version>
|
<version>${commons-collections.version}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
<!-- JSON 解析器和生成器 -->
|
|
||||||
<dependency>
|
|
||||||
<groupId>com.alibaba</groupId>
|
|
||||||
<artifactId>fastjson</artifactId>
|
|
||||||
<version>${fastjson.version}</version>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
<!-- JWT -->
|
<!-- JWT -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>io.jsonwebtoken</groupId>
|
<groupId>io.jsonwebtoken</groupId>
|
||||||
|
|
|
||||||
|
|
@ -75,12 +75,6 @@
|
||||||
<artifactId>jackson-datatype-jsr310</artifactId>
|
<artifactId>jackson-datatype-jsr310</artifactId>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
<!-- Alibaba Fastjson -->
|
|
||||||
<dependency>
|
|
||||||
<groupId>com.alibaba</groupId>
|
|
||||||
<artifactId>fastjson</artifactId>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
<!-- Jwt -->
|
<!-- Jwt -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>io.jsonwebtoken</groupId>
|
<groupId>io.jsonwebtoken</groupId>
|
||||||
|
|
|
||||||
|
|
@ -11,7 +11,6 @@
|
||||||
<modules>
|
<modules>
|
||||||
<module>ruoyi-system</module>
|
<module>ruoyi-system</module>
|
||||||
<module>ruoyi-gen</module>
|
<module>ruoyi-gen</module>
|
||||||
<module>ruoyi-job</module>
|
|
||||||
<module>ruoyi-file</module>
|
<module>ruoyi-file</module>
|
||||||
</modules>
|
</modules>
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -1,100 +0,0 @@
|
||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
|
||||||
xmlns="http://maven.apache.org/POM/4.0.0"
|
|
||||||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
|
||||||
<parent>
|
|
||||||
<groupId>com.ruoyi</groupId>
|
|
||||||
<artifactId>ruoyi-modules</artifactId>
|
|
||||||
<version>3.3.0</version>
|
|
||||||
</parent>
|
|
||||||
<modelVersion>4.0.0</modelVersion>
|
|
||||||
|
|
||||||
<artifactId>ruoyi-modules-job</artifactId>
|
|
||||||
|
|
||||||
<description>
|
|
||||||
ruoyi-modules-job定时任务
|
|
||||||
</description>
|
|
||||||
|
|
||||||
<dependencies>
|
|
||||||
|
|
||||||
<!-- SpringCloud Alibaba Nacos -->
|
|
||||||
<dependency>
|
|
||||||
<groupId>com.alibaba.cloud</groupId>
|
|
||||||
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
<!-- SpringCloud Alibaba Nacos Config -->
|
|
||||||
<dependency>
|
|
||||||
<groupId>com.alibaba.cloud</groupId>
|
|
||||||
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
<!-- SpringCloud Alibaba Sentinel -->
|
|
||||||
<dependency>
|
|
||||||
<groupId>com.alibaba.cloud</groupId>
|
|
||||||
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
<!-- SpringBoot Actuator -->
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.springframework.boot</groupId>
|
|
||||||
<artifactId>spring-boot-starter-actuator</artifactId>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
<!-- Swagger UI -->
|
|
||||||
<dependency>
|
|
||||||
<groupId>io.springfox</groupId>
|
|
||||||
<artifactId>springfox-swagger-ui</artifactId>
|
|
||||||
<version>${swagger.fox.version}</version>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
<!-- Quartz -->
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.quartz-scheduler</groupId>
|
|
||||||
<artifactId>quartz</artifactId>
|
|
||||||
<exclusions>
|
|
||||||
<exclusion>
|
|
||||||
<groupId>com.mchange</groupId>
|
|
||||||
<artifactId>c3p0</artifactId>
|
|
||||||
</exclusion>
|
|
||||||
</exclusions>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
<!-- Mysql Connector -->
|
|
||||||
<dependency>
|
|
||||||
<groupId>mysql</groupId>
|
|
||||||
<artifactId>mysql-connector-java</artifactId>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
<!-- RuoYi Common Log -->
|
|
||||||
<dependency>
|
|
||||||
<groupId>com.ruoyi</groupId>
|
|
||||||
<artifactId>ruoyi-common-log</artifactId>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
<!-- RuoYi Common Swagger -->
|
|
||||||
<dependency>
|
|
||||||
<groupId>com.ruoyi</groupId>
|
|
||||||
<artifactId>ruoyi-common-swagger</artifactId>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
</dependencies>
|
|
||||||
|
|
||||||
<build>
|
|
||||||
<finalName>${project.artifactId}</finalName>
|
|
||||||
<plugins>
|
|
||||||
<plugin>
|
|
||||||
<groupId>org.springframework.boot</groupId>
|
|
||||||
<artifactId>spring-boot-maven-plugin</artifactId>
|
|
||||||
<executions>
|
|
||||||
<execution>
|
|
||||||
<goals>
|
|
||||||
<goal>repackage</goal>
|
|
||||||
</goals>
|
|
||||||
</execution>
|
|
||||||
</executions>
|
|
||||||
</plugin>
|
|
||||||
</plugins>
|
|
||||||
</build>
|
|
||||||
|
|
||||||
</project>
|
|
||||||
|
|
@ -1,34 +0,0 @@
|
||||||
package com.ruoyi.job;
|
|
||||||
|
|
||||||
import org.springframework.boot.SpringApplication;
|
|
||||||
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
|
||||||
import com.ruoyi.common.security.annotation.EnableCustomConfig;
|
|
||||||
import com.ruoyi.common.security.annotation.EnableRyFeignClients;
|
|
||||||
import com.ruoyi.common.swagger.annotation.EnableCustomSwagger2;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 定时任务
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
*/
|
|
||||||
@EnableCustomConfig
|
|
||||||
@EnableCustomSwagger2
|
|
||||||
@EnableRyFeignClients
|
|
||||||
@SpringBootApplication
|
|
||||||
public class RuoYiJobApplication
|
|
||||||
{
|
|
||||||
public static void main(String[] args)
|
|
||||||
{
|
|
||||||
SpringApplication.run(RuoYiJobApplication.class, args);
|
|
||||||
System.out.println("(♥◠‿◠)ﾉﾞ 定时任务模块启动成功 ლ(´ڡ`ლ)ﾞ \n" +
|
|
||||||
" .-------. ____ __ \n" +
|
|
||||||
" | _ _ \\ \\ \\ / / \n" +
|
|
||||||
" | ( ' ) | \\ _. / ' \n" +
|
|
||||||
" |(_ o _) / _( )_ .' \n" +
|
|
||||||
" | (_,_).' __ ___(_ o _)' \n" +
|
|
||||||
" | |\\ \\ | || |(_,_)' \n" +
|
|
||||||
" | | \\ `' /| `-' / \n" +
|
|
||||||
" | | \\ / \\ / \n" +
|
|
||||||
" ''-' `'-' `-..-' ");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,57 +0,0 @@
|
||||||
package com.ruoyi.job.config;
|
|
||||||
|
|
||||||
import java.util.Properties;
|
|
||||||
import javax.sql.DataSource;
|
|
||||||
import org.springframework.context.annotation.Bean;
|
|
||||||
import org.springframework.context.annotation.Configuration;
|
|
||||||
import org.springframework.scheduling.quartz.SchedulerFactoryBean;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 定时任务配置（单机部署建议删除此类和qrtz数据库表，默认走内存会最高效）
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
*/
|
|
||||||
@Configuration
|
|
||||||
public class ScheduleConfig
|
|
||||||
{
|
|
||||||
@Bean
|
|
||||||
public SchedulerFactoryBean schedulerFactoryBean(DataSource dataSource)
|
|
||||||
{
|
|
||||||
SchedulerFactoryBean factory = new SchedulerFactoryBean();
|
|
||||||
factory.setDataSource(dataSource);
|
|
||||||
|
|
||||||
// quartz参数
|
|
||||||
Properties prop = new Properties();
|
|
||||||
prop.put("org.quartz.scheduler.instanceName", "RuoyiScheduler");
|
|
||||||
prop.put("org.quartz.scheduler.instanceId", "AUTO");
|
|
||||||
// 线程池配置
|
|
||||||
prop.put("org.quartz.threadPool.class", "org.quartz.simpl.SimpleThreadPool");
|
|
||||||
prop.put("org.quartz.threadPool.threadCount", "20");
|
|
||||||
prop.put("org.quartz.threadPool.threadPriority", "5");
|
|
||||||
// JobStore配置
|
|
||||||
prop.put("org.quartz.jobStore.class", "org.quartz.impl.jdbcjobstore.JobStoreTX");
|
|
||||||
// 集群配置
|
|
||||||
prop.put("org.quartz.jobStore.isClustered", "true");
|
|
||||||
prop.put("org.quartz.jobStore.clusterCheckinInterval", "15000");
|
|
||||||
prop.put("org.quartz.jobStore.maxMisfiresToHandleAtATime", "1");
|
|
||||||
prop.put("org.quartz.jobStore.txIsolationLevelSerializable", "true");
|
|
||||||
|
|
||||||
// sqlserver 启用
|
|
||||||
// prop.put("org.quartz.jobStore.selectWithLockSQL", "SELECT * FROM {0}LOCKS UPDLOCK WHERE LOCK_NAME = ?");
|
|
||||||
prop.put("org.quartz.jobStore.misfireThreshold", "12000");
|
|
||||||
prop.put("org.quartz.jobStore.tablePrefix", "QRTZ_");
|
|
||||||
factory.setQuartzProperties(prop);
|
|
||||||
|
|
||||||
factory.setSchedulerName("RuoyiScheduler");
|
|
||||||
// 延时启动
|
|
||||||
factory.setStartupDelay(1);
|
|
||||||
factory.setApplicationContextSchedulerContextKey("applicationContextKey");
|
|
||||||
// 可选，QuartzScheduler
|
|
||||||
// 启动时更新己存在的Job，这样就不用每次修改targetObject后删除qrtz_job_details表对应记录了
|
|
||||||
factory.setOverwriteExistingJobs(true);
|
|
||||||
// 设置自动启动，默认为true
|
|
||||||
factory.setAutoStartup(true);
|
|
||||||
|
|
||||||
return factory;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,177 +0,0 @@
|
||||||
package com.ruoyi.job.controller;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
import javax.servlet.http.HttpServletResponse;
|
|
||||||
import org.quartz.SchedulerException;
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
|
||||||
import org.springframework.web.bind.annotation.DeleteMapping;
|
|
||||||
import org.springframework.web.bind.annotation.GetMapping;
|
|
||||||
import org.springframework.web.bind.annotation.PathVariable;
|
|
||||||
import org.springframework.web.bind.annotation.PostMapping;
|
|
||||||
import org.springframework.web.bind.annotation.PutMapping;
|
|
||||||
import org.springframework.web.bind.annotation.RequestBody;
|
|
||||||
import org.springframework.web.bind.annotation.RequestMapping;
|
|
||||||
import org.springframework.web.bind.annotation.RestController;
|
|
||||||
import com.ruoyi.common.core.constant.Constants;
|
|
||||||
import com.ruoyi.common.core.exception.job.TaskException;
|
|
||||||
import com.ruoyi.common.core.utils.StringUtils;
|
|
||||||
import com.ruoyi.common.core.utils.poi.ExcelUtil;
|
|
||||||
import com.ruoyi.common.core.web.controller.BaseController;
|
|
||||||
import com.ruoyi.common.core.web.domain.AjaxResult;
|
|
||||||
import com.ruoyi.common.core.web.page.TableDataInfo;
|
|
||||||
import com.ruoyi.common.log.annotation.Log;
|
|
||||||
import com.ruoyi.common.log.enums.BusinessType;
|
|
||||||
import com.ruoyi.common.security.annotation.RequiresPermissions;
|
|
||||||
import com.ruoyi.common.security.utils.SecurityUtils;
|
|
||||||
import com.ruoyi.job.domain.SysJob;
|
|
||||||
import com.ruoyi.job.service.ISysJobService;
|
|
||||||
import com.ruoyi.job.util.CronUtils;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 调度任务信息操作处理
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
*/
|
|
||||||
@RestController
|
|
||||||
@RequestMapping("/job")
|
|
||||||
public class SysJobController extends BaseController
|
|
||||||
{
|
|
||||||
@Autowired
|
|
||||||
private ISysJobService jobService;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询定时任务列表
|
|
||||||
*/
|
|
||||||
@RequiresPermissions("monitor:job:list")
|
|
||||||
@GetMapping("/list")
|
|
||||||
public TableDataInfo list(SysJob sysJob)
|
|
||||||
{
|
|
||||||
startPage();
|
|
||||||
List<SysJob> list = jobService.selectJobList(sysJob);
|
|
||||||
return getDataTable(list);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 导出定时任务列表
|
|
||||||
*/
|
|
||||||
@RequiresPermissions("monitor:job:export")
|
|
||||||
@Log(title = "定时任务", businessType = BusinessType.EXPORT)
|
|
||||||
@PostMapping("/export")
|
|
||||||
public void export(HttpServletResponse response, SysJob sysJob)
|
|
||||||
{
|
|
||||||
List<SysJob> list = jobService.selectJobList(sysJob);
|
|
||||||
ExcelUtil<SysJob> util = new ExcelUtil<SysJob>(SysJob.class);
|
|
||||||
util.exportExcel(response, list, "定时任务");
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取定时任务详细信息
|
|
||||||
*/
|
|
||||||
@RequiresPermissions("monitor:job:query")
|
|
||||||
@GetMapping(value = "/{jobId}")
|
|
||||||
public AjaxResult getInfo(@PathVariable("jobId") Long jobId)
|
|
||||||
{
|
|
||||||
return AjaxResult.success(jobService.selectJobById(jobId));
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 新增定时任务
|
|
||||||
*/
|
|
||||||
@RequiresPermissions("monitor:job:add")
|
|
||||||
@Log(title = "定时任务", businessType = BusinessType.INSERT)
|
|
||||||
@PostMapping
|
|
||||||
public AjaxResult add(@RequestBody SysJob job) throws SchedulerException, TaskException
|
|
||||||
{
|
|
||||||
if (!CronUtils.isValid(job.getCronExpression()))
|
|
||||||
{
|
|
||||||
return error("新增任务'" + job.getJobName() + "'失败，Cron表达式不正确");
|
|
||||||
}
|
|
||||||
else if (StringUtils.containsIgnoreCase(job.getInvokeTarget(), Constants.LOOKUP_RMI))
|
|
||||||
{
|
|
||||||
return error("新增任务'" + job.getJobName() + "'失败，目标字符串不允许'rmi://'调用");
|
|
||||||
}
|
|
||||||
else if (StringUtils.containsIgnoreCase(job.getInvokeTarget(), Constants.LOOKUP_LDAP))
|
|
||||||
{
|
|
||||||
return error("新增任务'" + job.getJobName() + "'失败，目标字符串不允许'ldap://'调用");
|
|
||||||
}
|
|
||||||
else if (StringUtils.containsAnyIgnoreCase(job.getInvokeTarget(), new String[] { Constants.HTTP, Constants.HTTPS }))
|
|
||||||
{
|
|
||||||
return error("新增任务'" + job.getJobName() + "'失败，目标字符串不允许'http(s)//'调用");
|
|
||||||
}
|
|
||||||
else if (StringUtils.containsAnyIgnoreCase(job.getInvokeTarget(), Constants.JOB_ERROR_STR))
|
|
||||||
{
|
|
||||||
return error("新增任务'" + job.getJobName() + "'失败，目标字符串存在违规");
|
|
||||||
}
|
|
||||||
job.setCreateBy(SecurityUtils.getUsername());
|
|
||||||
return toAjax(jobService.insertJob(job));
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 修改定时任务
|
|
||||||
*/
|
|
||||||
@RequiresPermissions("monitor:job:edit")
|
|
||||||
@Log(title = "定时任务", businessType = BusinessType.UPDATE)
|
|
||||||
@PutMapping
|
|
||||||
public AjaxResult edit(@RequestBody SysJob job) throws SchedulerException, TaskException
|
|
||||||
{
|
|
||||||
if (!CronUtils.isValid(job.getCronExpression()))
|
|
||||||
{
|
|
||||||
return error("修改任务'" + job.getJobName() + "'失败，Cron表达式不正确");
|
|
||||||
}
|
|
||||||
else if (StringUtils.containsIgnoreCase(job.getInvokeTarget(), Constants.LOOKUP_RMI))
|
|
||||||
{
|
|
||||||
return error("修改任务'" + job.getJobName() + "'失败，目标字符串不允许'rmi://'调用");
|
|
||||||
}
|
|
||||||
else if (StringUtils.containsIgnoreCase(job.getInvokeTarget(), Constants.LOOKUP_LDAP))
|
|
||||||
{
|
|
||||||
return error("修改任务'" + job.getJobName() + "'失败，目标字符串不允许'ldap://'调用");
|
|
||||||
}
|
|
||||||
else if (StringUtils.containsAnyIgnoreCase(job.getInvokeTarget(), new String[] { Constants.HTTP, Constants.HTTPS }))
|
|
||||||
{
|
|
||||||
return error("修改任务'" + job.getJobName() + "'失败，目标字符串不允许'http(s)//'调用");
|
|
||||||
}
|
|
||||||
else if (StringUtils.containsAnyIgnoreCase(job.getInvokeTarget(), Constants.JOB_ERROR_STR))
|
|
||||||
{
|
|
||||||
return error("修改任务'" + job.getJobName() + "'失败，目标字符串存在违规");
|
|
||||||
}
|
|
||||||
job.setUpdateBy(SecurityUtils.getUsername());
|
|
||||||
return toAjax(jobService.updateJob(job));
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 定时任务状态修改
|
|
||||||
*/
|
|
||||||
@RequiresPermissions("monitor:job:changeStatus")
|
|
||||||
@Log(title = "定时任务", businessType = BusinessType.UPDATE)
|
|
||||||
@PutMapping("/changeStatus")
|
|
||||||
public AjaxResult changeStatus(@RequestBody SysJob job) throws SchedulerException
|
|
||||||
{
|
|
||||||
SysJob newJob = jobService.selectJobById(job.getJobId());
|
|
||||||
newJob.setStatus(job.getStatus());
|
|
||||||
return toAjax(jobService.changeStatus(newJob));
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 定时任务立即执行一次
|
|
||||||
*/
|
|
||||||
@RequiresPermissions("monitor:job:changeStatus")
|
|
||||||
@Log(title = "定时任务", businessType = BusinessType.UPDATE)
|
|
||||||
@PutMapping("/run")
|
|
||||||
public AjaxResult run(@RequestBody SysJob job) throws SchedulerException
|
|
||||||
{
|
|
||||||
jobService.run(job);
|
|
||||||
return AjaxResult.success();
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 删除定时任务
|
|
||||||
*/
|
|
||||||
@RequiresPermissions("monitor:job:remove")
|
|
||||||
@Log(title = "定时任务", businessType = BusinessType.DELETE)
|
|
||||||
@DeleteMapping("/{jobIds}")
|
|
||||||
public AjaxResult remove(@PathVariable Long[] jobIds) throws SchedulerException, TaskException
|
|
||||||
{
|
|
||||||
jobService.deleteJobByIds(jobIds);
|
|
||||||
return AjaxResult.success();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,91 +0,0 @@
|
||||||
package com.ruoyi.job.controller;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
import javax.servlet.http.HttpServletResponse;
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
|
||||||
import org.springframework.web.bind.annotation.DeleteMapping;
|
|
||||||
import org.springframework.web.bind.annotation.GetMapping;
|
|
||||||
import org.springframework.web.bind.annotation.PathVariable;
|
|
||||||
import org.springframework.web.bind.annotation.PostMapping;
|
|
||||||
import org.springframework.web.bind.annotation.RequestMapping;
|
|
||||||
import org.springframework.web.bind.annotation.RestController;
|
|
||||||
import com.ruoyi.common.core.utils.poi.ExcelUtil;
|
|
||||||
import com.ruoyi.common.core.web.controller.BaseController;
|
|
||||||
import com.ruoyi.common.core.web.domain.AjaxResult;
|
|
||||||
import com.ruoyi.common.core.web.page.TableDataInfo;
|
|
||||||
import com.ruoyi.common.log.annotation.Log;
|
|
||||||
import com.ruoyi.common.log.enums.BusinessType;
|
|
||||||
import com.ruoyi.common.security.annotation.RequiresPermissions;
|
|
||||||
import com.ruoyi.job.domain.SysJobLog;
|
|
||||||
import com.ruoyi.job.service.ISysJobLogService;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 调度日志操作处理
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
*/
|
|
||||||
@RestController
|
|
||||||
@RequestMapping("/job/log")
|
|
||||||
public class SysJobLogController extends BaseController
|
|
||||||
{
|
|
||||||
@Autowired
|
|
||||||
private ISysJobLogService jobLogService;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询定时任务调度日志列表
|
|
||||||
*/
|
|
||||||
@RequiresPermissions("monitor:job:list")
|
|
||||||
@GetMapping("/list")
|
|
||||||
public TableDataInfo list(SysJobLog sysJobLog)
|
|
||||||
{
|
|
||||||
startPage();
|
|
||||||
List<SysJobLog> list = jobLogService.selectJobLogList(sysJobLog);
|
|
||||||
return getDataTable(list);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 导出定时任务调度日志列表
|
|
||||||
*/
|
|
||||||
@RequiresPermissions("monitor:job:export")
|
|
||||||
@Log(title = "任务调度日志", businessType = BusinessType.EXPORT)
|
|
||||||
@PostMapping("/export")
|
|
||||||
public void export(HttpServletResponse response, SysJobLog sysJobLog)
|
|
||||||
{
|
|
||||||
List<SysJobLog> list = jobLogService.selectJobLogList(sysJobLog);
|
|
||||||
ExcelUtil<SysJobLog> util = new ExcelUtil<SysJobLog>(SysJobLog.class);
|
|
||||||
util.exportExcel(response, list, "调度日志");
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 根据调度编号获取详细信息
|
|
||||||
*/
|
|
||||||
@RequiresPermissions("monitor:job:query")
|
|
||||||
@GetMapping(value = "/{configId}")
|
|
||||||
public AjaxResult getInfo(@PathVariable Long jobLogId)
|
|
||||||
{
|
|
||||||
return AjaxResult.success(jobLogService.selectJobLogById(jobLogId));
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 删除定时任务调度日志
|
|
||||||
*/
|
|
||||||
@RequiresPermissions("monitor:job:remove")
|
|
||||||
@Log(title = "定时任务调度日志", businessType = BusinessType.DELETE)
|
|
||||||
@DeleteMapping("/{jobLogIds}")
|
|
||||||
public AjaxResult remove(@PathVariable Long[] jobLogIds)
|
|
||||||
{
|
|
||||||
return toAjax(jobLogService.deleteJobLogByIds(jobLogIds));
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 清空定时任务调度日志
|
|
||||||
*/
|
|
||||||
@RequiresPermissions("monitor:job:remove")
|
|
||||||
@Log(title = "调度日志", businessType = BusinessType.CLEAN)
|
|
||||||
@DeleteMapping("/clean")
|
|
||||||
public AjaxResult clean()
|
|
||||||
{
|
|
||||||
jobLogService.cleanJobLog();
|
|
||||||
return AjaxResult.success();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,93 +0,0 @@
|
||||||
package com.ruoyi.job.domain;
|
|
||||||
|
|
||||||
import java.util.Date;
|
|
||||||
import javax.validation.constraints.NotBlank;
|
|
||||||
import javax.validation.constraints.Size;
|
|
||||||
|
|
||||||
import lombok.*;
|
|
||||||
import lombok.experimental.Accessors;
|
|
||||||
import org.apache.commons.lang3.builder.ToStringBuilder;
|
|
||||||
import org.apache.commons.lang3.builder.ToStringStyle;
|
|
||||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
|
||||||
import com.ruoyi.common.core.annotation.Excel;
|
|
||||||
import com.ruoyi.common.core.annotation.Excel.ColumnType;
|
|
||||||
import com.ruoyi.common.core.constant.ScheduleConstants;
|
|
||||||
import com.ruoyi.common.core.utils.StringUtils;
|
|
||||||
import com.ruoyi.common.core.web.domain.BaseEntity;
|
|
||||||
import com.ruoyi.job.util.CronUtils;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 定时任务调度表 sys_job
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
*/
|
|
||||||
@Data
|
|
||||||
@EqualsAndHashCode(callSuper = true)
|
|
||||||
@NoArgsConstructor
|
|
||||||
@Accessors(chain = true)
|
|
||||||
public class SysJob extends BaseEntity {
|
|
||||||
private static final long serialVersionUID = 1L;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 任务ID
|
|
||||||
*/
|
|
||||||
@Excel(name = "任务序号", cellType = ColumnType.NUMERIC)
|
|
||||||
private Long jobId;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 任务名称
|
|
||||||
*/
|
|
||||||
@NotBlank(message = "任务名称不能为空")
|
|
||||||
@Size(min = 0, max = 64, message = "任务名称不能超过64个字符")
|
|
||||||
@Excel(name = "任务名称")
|
|
||||||
private String jobName;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 任务组名
|
|
||||||
*/
|
|
||||||
@Excel(name = "任务组名")
|
|
||||||
private String jobGroup;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 调用目标字符串
|
|
||||||
*/
|
|
||||||
@NotBlank(message = "调用目标字符串不能为空")
|
|
||||||
@Size(min = 0, max = 500, message = "调用目标字符串长度不能超过500个字符")
|
|
||||||
@Excel(name = "调用目标字符串")
|
|
||||||
private String invokeTarget;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* cron执行表达式
|
|
||||||
*/
|
|
||||||
@NotBlank(message = "Cron执行表达式不能为空")
|
|
||||||
@Size(min = 0, max = 255, message = "Cron执行表达式不能超过255个字符")
|
|
||||||
@Excel(name = "执行表达式 ")
|
|
||||||
private String cronExpression;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* cron计划策略
|
|
||||||
*/
|
|
||||||
@Excel(name = "计划策略 ", readConverterExp = "0=默认,1=立即触发执行,2=触发一次执行,3=不触发立即执行")
|
|
||||||
private String misfirePolicy = ScheduleConstants.MISFIRE_DEFAULT;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 是否并发执行（0允许 1禁止）
|
|
||||||
*/
|
|
||||||
@Excel(name = "并发执行", readConverterExp = "0=允许,1=禁止")
|
|
||||||
private String concurrent;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 任务状态（0正常 1暂停）
|
|
||||||
*/
|
|
||||||
@Excel(name = "任务状态", readConverterExp = "0=正常,1=暂停")
|
|
||||||
private String status;
|
|
||||||
|
|
||||||
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
|
|
||||||
public Date getNextValidTime() {
|
|
||||||
if (StringUtils.isNotEmpty(cronExpression)) {
|
|
||||||
return CronUtils.getNextExecution(cronExpression);
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,76 +0,0 @@
|
||||||
package com.ruoyi.job.domain;
|
|
||||||
|
|
||||||
import java.util.Date;
|
|
||||||
|
|
||||||
import lombok.*;
|
|
||||||
import lombok.experimental.Accessors;
|
|
||||||
import org.apache.commons.lang3.builder.ToStringBuilder;
|
|
||||||
import org.apache.commons.lang3.builder.ToStringStyle;
|
|
||||||
import com.ruoyi.common.core.annotation.Excel;
|
|
||||||
import com.ruoyi.common.core.web.domain.BaseEntity;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 定时任务调度日志表 sys_job_log
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
*/
|
|
||||||
@Data
|
|
||||||
@EqualsAndHashCode(callSuper = true)
|
|
||||||
@NoArgsConstructor
|
|
||||||
@Accessors(chain = true)
|
|
||||||
public class SysJobLog extends BaseEntity {
|
|
||||||
private static final long serialVersionUID = 1L;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* ID
|
|
||||||
*/
|
|
||||||
@Excel(name = "日志序号")
|
|
||||||
private Long jobLogId;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 任务名称
|
|
||||||
*/
|
|
||||||
@Excel(name = "任务名称")
|
|
||||||
private String jobName;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 任务组名
|
|
||||||
*/
|
|
||||||
@Excel(name = "任务组名")
|
|
||||||
private String jobGroup;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 调用目标字符串
|
|
||||||
*/
|
|
||||||
@Excel(name = "调用目标字符串")
|
|
||||||
private String invokeTarget;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 日志信息
|
|
||||||
*/
|
|
||||||
@Excel(name = "日志信息")
|
|
||||||
private String jobMessage;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 执行状态（0正常 1失败）
|
|
||||||
*/
|
|
||||||
@Excel(name = "执行状态", readConverterExp = "0=正常,1=失败")
|
|
||||||
private String status;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 异常信息
|
|
||||||
*/
|
|
||||||
@Excel(name = "异常信息")
|
|
||||||
private String exceptionInfo;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 开始时间
|
|
||||||
*/
|
|
||||||
private Date startTime;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 停止时间
|
|
||||||
*/
|
|
||||||
private Date stopTime;
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,64 +0,0 @@
|
||||||
package com.ruoyi.job.mapper;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
import com.ruoyi.job.domain.SysJobLog;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 调度任务日志信息 数据层
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
*/
|
|
||||||
public interface SysJobLogMapper
|
|
||||||
{
|
|
||||||
/**
|
|
||||||
* 获取quartz调度器日志的计划任务
|
|
||||||
*
|
|
||||||
* @param jobLog 调度日志信息
|
|
||||||
* @return 调度任务日志集合
|
|
||||||
*/
|
|
||||||
public List<SysJobLog> selectJobLogList(SysJobLog jobLog);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询所有调度任务日志
|
|
||||||
*
|
|
||||||
* @return 调度任务日志列表
|
|
||||||
*/
|
|
||||||
public List<SysJobLog> selectJobLogAll();
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 通过调度任务日志ID查询调度信息
|
|
||||||
*
|
|
||||||
* @param jobLogId 调度任务日志ID
|
|
||||||
* @return 调度任务日志对象信息
|
|
||||||
*/
|
|
||||||
public SysJobLog selectJobLogById(Long jobLogId);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 新增任务日志
|
|
||||||
*
|
|
||||||
* @param jobLog 调度日志信息
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int insertJobLog(SysJobLog jobLog);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 批量删除调度日志信息
|
|
||||||
*
|
|
||||||
* @param logIds 需要删除的数据ID
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int deleteJobLogByIds(Long[] logIds);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 删除任务日志
|
|
||||||
*
|
|
||||||
* @param jobId 调度日志ID
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int deleteJobLogById(Long jobId);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 清空任务日志
|
|
||||||
*/
|
|
||||||
public void cleanJobLog();
|
|
||||||
}
|
|
||||||
|
|
@ -1,67 +0,0 @@
|
||||||
package com.ruoyi.job.mapper;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
import com.ruoyi.job.domain.SysJob;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 调度任务信息 数据层
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
*/
|
|
||||||
public interface SysJobMapper
|
|
||||||
{
|
|
||||||
/**
|
|
||||||
* 查询调度任务日志集合
|
|
||||||
*
|
|
||||||
* @param job 调度信息
|
|
||||||
* @return 操作日志集合
|
|
||||||
*/
|
|
||||||
public List<SysJob> selectJobList(SysJob job);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询所有调度任务
|
|
||||||
*
|
|
||||||
* @return 调度任务列表
|
|
||||||
*/
|
|
||||||
public List<SysJob> selectJobAll();
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 通过调度ID查询调度任务信息
|
|
||||||
*
|
|
||||||
* @param jobId 调度ID
|
|
||||||
* @return 角色对象信息
|
|
||||||
*/
|
|
||||||
public SysJob selectJobById(Long jobId);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 通过调度ID删除调度任务信息
|
|
||||||
*
|
|
||||||
* @param jobId 调度ID
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int deleteJobById(Long jobId);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 批量删除调度任务信息
|
|
||||||
*
|
|
||||||
* @param ids 需要删除的数据ID
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int deleteJobByIds(Long[] ids);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 修改调度任务信息
|
|
||||||
*
|
|
||||||
* @param job 调度任务信息
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int updateJob(SysJob job);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 新增调度任务信息
|
|
||||||
*
|
|
||||||
* @param job 调度任务信息
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int insertJob(SysJob job);
|
|
||||||
}
|
|
||||||
|
|
@ -1,56 +0,0 @@
|
||||||
package com.ruoyi.job.service;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
import com.ruoyi.job.domain.SysJobLog;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 定时任务调度日志信息信息 服务层
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
*/
|
|
||||||
public interface ISysJobLogService
|
|
||||||
{
|
|
||||||
/**
|
|
||||||
* 获取quartz调度器日志的计划任务
|
|
||||||
*
|
|
||||||
* @param jobLog 调度日志信息
|
|
||||||
* @return 调度任务日志集合
|
|
||||||
*/
|
|
||||||
public List<SysJobLog> selectJobLogList(SysJobLog jobLog);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 通过调度任务日志ID查询调度信息
|
|
||||||
*
|
|
||||||
* @param jobLogId 调度任务日志ID
|
|
||||||
* @return 调度任务日志对象信息
|
|
||||||
*/
|
|
||||||
public SysJobLog selectJobLogById(Long jobLogId);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 新增任务日志
|
|
||||||
*
|
|
||||||
* @param jobLog 调度日志信息
|
|
||||||
*/
|
|
||||||
public void addJobLog(SysJobLog jobLog);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 批量删除调度日志信息
|
|
||||||
*
|
|
||||||
* @param logIds 需要删除的日志ID
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int deleteJobLogByIds(Long[] logIds);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 删除任务日志
|
|
||||||
*
|
|
||||||
* @param jobId 调度日志ID
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int deleteJobLogById(Long jobId);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 清空任务日志
|
|
||||||
*/
|
|
||||||
public void cleanJobLog();
|
|
||||||
}
|
|
||||||
|
|
@ -1,102 +0,0 @@
|
||||||
package com.ruoyi.job.service;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
import org.quartz.SchedulerException;
|
|
||||||
import com.ruoyi.common.core.exception.job.TaskException;
|
|
||||||
import com.ruoyi.job.domain.SysJob;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 定时任务调度信息信息 服务层
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
*/
|
|
||||||
public interface ISysJobService
|
|
||||||
{
|
|
||||||
/**
|
|
||||||
* 获取quartz调度器的计划任务
|
|
||||||
*
|
|
||||||
* @param job 调度信息
|
|
||||||
* @return 调度任务集合
|
|
||||||
*/
|
|
||||||
public List<SysJob> selectJobList(SysJob job);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 通过调度任务ID查询调度信息
|
|
||||||
*
|
|
||||||
* @param jobId 调度任务ID
|
|
||||||
* @return 调度任务对象信息
|
|
||||||
*/
|
|
||||||
public SysJob selectJobById(Long jobId);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 暂停任务
|
|
||||||
*
|
|
||||||
* @param job 调度信息
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int pauseJob(SysJob job) throws SchedulerException;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 恢复任务
|
|
||||||
*
|
|
||||||
* @param job 调度信息
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int resumeJob(SysJob job) throws SchedulerException;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 删除任务后，所对应的trigger也将被删除
|
|
||||||
*
|
|
||||||
* @param job 调度信息
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int deleteJob(SysJob job) throws SchedulerException;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 批量删除调度信息
|
|
||||||
*
|
|
||||||
* @param jobIds 需要删除的任务ID
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public void deleteJobByIds(Long[] jobIds) throws SchedulerException;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 任务调度状态修改
|
|
||||||
*
|
|
||||||
* @param job 调度信息
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int changeStatus(SysJob job) throws SchedulerException;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 立即运行任务
|
|
||||||
*
|
|
||||||
* @param job 调度信息
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public void run(SysJob job) throws SchedulerException;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 新增任务
|
|
||||||
*
|
|
||||||
* @param job 调度信息
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int insertJob(SysJob job) throws SchedulerException, TaskException;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 更新任务
|
|
||||||
*
|
|
||||||
* @param job 调度信息
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int updateJob(SysJob job) throws SchedulerException, TaskException;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 校验cron表达式是否有效
|
|
||||||
*
|
|
||||||
* @param cronExpression 表达式
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public boolean checkCronExpressionIsValid(String cronExpression);
|
|
||||||
}
|
|
||||||
|
|
@ -1,86 +0,0 @@
|
||||||
package com.ruoyi.job.service;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
|
||||||
import org.springframework.stereotype.Service;
|
|
||||||
import com.ruoyi.job.domain.SysJobLog;
|
|
||||||
import com.ruoyi.job.mapper.SysJobLogMapper;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 定时任务调度日志信息 服务层
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
*/
|
|
||||||
@Service
|
|
||||||
public class SysJobLogServiceImpl implements ISysJobLogService
|
|
||||||
{
|
|
||||||
@Autowired
|
|
||||||
private SysJobLogMapper jobLogMapper;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取quartz调度器日志的计划任务
|
|
||||||
*
|
|
||||||
* @param jobLog 调度日志信息
|
|
||||||
* @return 调度任务日志集合
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public List<SysJobLog> selectJobLogList(SysJobLog jobLog)
|
|
||||||
{
|
|
||||||
return jobLogMapper.selectJobLogList(jobLog);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 通过调度任务日志ID查询调度信息
|
|
||||||
*
|
|
||||||
* @param jobLogId 调度任务日志ID
|
|
||||||
* @return 调度任务日志对象信息
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public SysJobLog selectJobLogById(Long jobLogId)
|
|
||||||
{
|
|
||||||
return jobLogMapper.selectJobLogById(jobLogId);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 新增任务日志
|
|
||||||
*
|
|
||||||
* @param jobLog 调度日志信息
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public void addJobLog(SysJobLog jobLog)
|
|
||||||
{
|
|
||||||
jobLogMapper.insertJobLog(jobLog);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 批量删除调度日志信息
|
|
||||||
*
|
|
||||||
* @param logIds 需要删除的数据ID
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public int deleteJobLogByIds(Long[] logIds)
|
|
||||||
{
|
|
||||||
return jobLogMapper.deleteJobLogByIds(logIds);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 删除任务日志
|
|
||||||
*
|
|
||||||
* @param jobId 调度日志ID
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public int deleteJobLogById(Long jobId)
|
|
||||||
{
|
|
||||||
return jobLogMapper.deleteJobLogById(jobId);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 清空任务日志
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public void cleanJobLog()
|
|
||||||
{
|
|
||||||
jobLogMapper.cleanJobLog();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,253 +0,0 @@
|
||||||
package com.ruoyi.job.service;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
import javax.annotation.PostConstruct;
|
|
||||||
import org.quartz.JobDataMap;
|
|
||||||
import org.quartz.JobKey;
|
|
||||||
import org.quartz.Scheduler;
|
|
||||||
import org.quartz.SchedulerException;
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
|
||||||
import org.springframework.stereotype.Service;
|
|
||||||
import org.springframework.transaction.annotation.Transactional;
|
|
||||||
import com.ruoyi.common.core.constant.ScheduleConstants;
|
|
||||||
import com.ruoyi.common.core.exception.job.TaskException;
|
|
||||||
import com.ruoyi.job.domain.SysJob;
|
|
||||||
import com.ruoyi.job.mapper.SysJobMapper;
|
|
||||||
import com.ruoyi.job.util.CronUtils;
|
|
||||||
import com.ruoyi.job.util.ScheduleUtils;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 定时任务调度信息 服务层
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
*/
|
|
||||||
@Service
|
|
||||||
public class SysJobServiceImpl implements ISysJobService
|
|
||||||
{
|
|
||||||
@Autowired
|
|
||||||
private Scheduler scheduler;
|
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private SysJobMapper jobMapper;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 项目启动时，初始化定时器 主要是防止手动修改数据库导致未同步到定时任务处理（注：不能手动修改数据库ID和任务组名，否则会导致脏数据）
|
|
||||||
*/
|
|
||||||
@PostConstruct
|
|
||||||
public void init() throws SchedulerException, TaskException
|
|
||||||
{
|
|
||||||
scheduler.clear();
|
|
||||||
List<SysJob> jobList = jobMapper.selectJobAll();
|
|
||||||
for (SysJob job : jobList)
|
|
||||||
{
|
|
||||||
ScheduleUtils.createScheduleJob(scheduler, job);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取quartz调度器的计划任务列表
|
|
||||||
*
|
|
||||||
* @param job 调度信息
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public List<SysJob> selectJobList(SysJob job)
|
|
||||||
{
|
|
||||||
return jobMapper.selectJobList(job);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 通过调度任务ID查询调度信息
|
|
||||||
*
|
|
||||||
* @param jobId 调度任务ID
|
|
||||||
* @return 调度任务对象信息
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public SysJob selectJobById(Long jobId)
|
|
||||||
{
|
|
||||||
return jobMapper.selectJobById(jobId);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 暂停任务
|
|
||||||
*
|
|
||||||
* @param job 调度信息
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public int pauseJob(SysJob job) throws SchedulerException
|
|
||||||
{
|
|
||||||
Long jobId = job.getJobId();
|
|
||||||
String jobGroup = job.getJobGroup();
|
|
||||||
job.setStatus(ScheduleConstants.Status.PAUSE.getValue());
|
|
||||||
int rows = jobMapper.updateJob(job);
|
|
||||||
if (rows > 0)
|
|
||||||
{
|
|
||||||
scheduler.pauseJob(ScheduleUtils.getJobKey(jobId, jobGroup));
|
|
||||||
}
|
|
||||||
return rows;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 恢复任务
|
|
||||||
*
|
|
||||||
* @param job 调度信息
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public int resumeJob(SysJob job) throws SchedulerException
|
|
||||||
{
|
|
||||||
Long jobId = job.getJobId();
|
|
||||||
String jobGroup = job.getJobGroup();
|
|
||||||
job.setStatus(ScheduleConstants.Status.NORMAL.getValue());
|
|
||||||
int rows = jobMapper.updateJob(job);
|
|
||||||
if (rows > 0)
|
|
||||||
{
|
|
||||||
scheduler.resumeJob(ScheduleUtils.getJobKey(jobId, jobGroup));
|
|
||||||
}
|
|
||||||
return rows;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 删除任务后，所对应的trigger也将被删除
|
|
||||||
*
|
|
||||||
* @param job 调度信息
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public int deleteJob(SysJob job) throws SchedulerException
|
|
||||||
{
|
|
||||||
Long jobId = job.getJobId();
|
|
||||||
String jobGroup = job.getJobGroup();
|
|
||||||
int rows = jobMapper.deleteJobById(jobId);
|
|
||||||
if (rows > 0)
|
|
||||||
{
|
|
||||||
scheduler.deleteJob(ScheduleUtils.getJobKey(jobId, jobGroup));
|
|
||||||
}
|
|
||||||
return rows;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 批量删除调度信息
|
|
||||||
*
|
|
||||||
* @param jobIds 需要删除的任务ID
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public void deleteJobByIds(Long[] jobIds) throws SchedulerException
|
|
||||||
{
|
|
||||||
for (Long jobId : jobIds)
|
|
||||||
{
|
|
||||||
SysJob job = jobMapper.selectJobById(jobId);
|
|
||||||
deleteJob(job);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 任务调度状态修改
|
|
||||||
*
|
|
||||||
* @param job 调度信息
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public int changeStatus(SysJob job) throws SchedulerException
|
|
||||||
{
|
|
||||||
int rows = 0;
|
|
||||||
String status = job.getStatus();
|
|
||||||
if (ScheduleConstants.Status.NORMAL.getValue().equals(status))
|
|
||||||
{
|
|
||||||
rows = resumeJob(job);
|
|
||||||
}
|
|
||||||
else if (ScheduleConstants.Status.PAUSE.getValue().equals(status))
|
|
||||||
{
|
|
||||||
rows = pauseJob(job);
|
|
||||||
}
|
|
||||||
return rows;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 立即运行任务
|
|
||||||
*
|
|
||||||
* @param job 调度信息
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public void run(SysJob job) throws SchedulerException
|
|
||||||
{
|
|
||||||
Long jobId = job.getJobId();
|
|
||||||
String jobGroup = job.getJobGroup();
|
|
||||||
SysJob properties = selectJobById(job.getJobId());
|
|
||||||
// 参数
|
|
||||||
JobDataMap dataMap = new JobDataMap();
|
|
||||||
dataMap.put(ScheduleConstants.TASK_PROPERTIES, properties);
|
|
||||||
scheduler.triggerJob(ScheduleUtils.getJobKey(jobId, jobGroup), dataMap);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 新增任务
|
|
||||||
*
|
|
||||||
* @param job 调度信息 调度信息
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public int insertJob(SysJob job) throws SchedulerException, TaskException
|
|
||||||
{
|
|
||||||
job.setStatus(ScheduleConstants.Status.PAUSE.getValue());
|
|
||||||
int rows = jobMapper.insertJob(job);
|
|
||||||
if (rows > 0)
|
|
||||||
{
|
|
||||||
ScheduleUtils.createScheduleJob(scheduler, job);
|
|
||||||
}
|
|
||||||
return rows;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 更新任务的时间表达式
|
|
||||||
*
|
|
||||||
* @param job 调度信息
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public int updateJob(SysJob job) throws SchedulerException, TaskException
|
|
||||||
{
|
|
||||||
SysJob properties = selectJobById(job.getJobId());
|
|
||||||
int rows = jobMapper.updateJob(job);
|
|
||||||
if (rows > 0)
|
|
||||||
{
|
|
||||||
updateSchedulerJob(job, properties.getJobGroup());
|
|
||||||
}
|
|
||||||
return rows;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 更新任务
|
|
||||||
*
|
|
||||||
* @param job 任务对象
|
|
||||||
* @param jobGroup 任务组名
|
|
||||||
*/
|
|
||||||
public void updateSchedulerJob(SysJob job, String jobGroup) throws SchedulerException, TaskException
|
|
||||||
{
|
|
||||||
Long jobId = job.getJobId();
|
|
||||||
// 判断是否存在
|
|
||||||
JobKey jobKey = ScheduleUtils.getJobKey(jobId, jobGroup);
|
|
||||||
if (scheduler.checkExists(jobKey))
|
|
||||||
{
|
|
||||||
// 防止创建时存在数据问题 先移除，然后在执行创建操作
|
|
||||||
scheduler.deleteJob(jobKey);
|
|
||||||
}
|
|
||||||
ScheduleUtils.createScheduleJob(scheduler, job);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 校验cron表达式是否有效
|
|
||||||
*
|
|
||||||
* @param cronExpression 表达式
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public boolean checkCronExpressionIsValid(String cronExpression)
|
|
||||||
{
|
|
||||||
return CronUtils.isValid(cronExpression);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,28 +0,0 @@
|
||||||
package com.ruoyi.job.task;
|
|
||||||
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
import com.ruoyi.common.core.utils.StringUtils;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 定时任务调度测试
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
*/
|
|
||||||
@Component("ryTask")
|
|
||||||
public class RyTask
|
|
||||||
{
|
|
||||||
public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i)
|
|
||||||
{
|
|
||||||
System.out.println(StringUtils.format("执行多参方法： 字符串类型{}，布尔类型{}，长整型{}，浮点型{}，整形{}", s, b, l, d, i));
|
|
||||||
}
|
|
||||||
|
|
||||||
public void ryParams(String params)
|
|
||||||
{
|
|
||||||
System.out.println("执行有参方法：" + params);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void ryNoParams()
|
|
||||||
{
|
|
||||||
System.out.println("执行无参方法");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,106 +0,0 @@
|
||||||
package com.ruoyi.job.util;
|
|
||||||
|
|
||||||
import java.util.Date;
|
|
||||||
import org.quartz.Job;
|
|
||||||
import org.quartz.JobExecutionContext;
|
|
||||||
import org.quartz.JobExecutionException;
|
|
||||||
import org.slf4j.Logger;
|
|
||||||
import org.slf4j.LoggerFactory;
|
|
||||||
import com.ruoyi.common.core.constant.ScheduleConstants;
|
|
||||||
import com.ruoyi.common.core.utils.ExceptionUtil;
|
|
||||||
import com.ruoyi.common.core.utils.SpringUtils;
|
|
||||||
import com.ruoyi.common.core.utils.StringUtils;
|
|
||||||
import com.ruoyi.common.core.utils.bean.BeanUtils;
|
|
||||||
import com.ruoyi.job.domain.SysJob;
|
|
||||||
import com.ruoyi.job.domain.SysJobLog;
|
|
||||||
import com.ruoyi.job.service.ISysJobLogService;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 抽象quartz调用
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
*/
|
|
||||||
public abstract class AbstractQuartzJob implements Job
|
|
||||||
{
|
|
||||||
private static final Logger log = LoggerFactory.getLogger(AbstractQuartzJob.class);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 线程本地变量
|
|
||||||
*/
|
|
||||||
private static ThreadLocal<Date> threadLocal = new ThreadLocal<>();
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void execute(JobExecutionContext context) throws JobExecutionException
|
|
||||||
{
|
|
||||||
SysJob sysJob = new SysJob();
|
|
||||||
BeanUtils.copyBeanProp(sysJob, context.getMergedJobDataMap().get(ScheduleConstants.TASK_PROPERTIES));
|
|
||||||
try
|
|
||||||
{
|
|
||||||
before(context, sysJob);
|
|
||||||
if (sysJob != null)
|
|
||||||
{
|
|
||||||
doExecute(context, sysJob);
|
|
||||||
}
|
|
||||||
after(context, sysJob, null);
|
|
||||||
}
|
|
||||||
catch (Exception e)
|
|
||||||
{
|
|
||||||
log.error("任务执行异常 - ：", e);
|
|
||||||
after(context, sysJob, e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 执行前
|
|
||||||
*
|
|
||||||
* @param context 工作执行上下文对象
|
|
||||||
* @param sysJob 系统计划任务
|
|
||||||
*/
|
|
||||||
protected void before(JobExecutionContext context, SysJob sysJob)
|
|
||||||
{
|
|
||||||
threadLocal.set(new Date());
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 执行后
|
|
||||||
*
|
|
||||||
* @param context 工作执行上下文对象
|
|
||||||
* @param sysJob 系统计划任务
|
|
||||||
*/
|
|
||||||
protected void after(JobExecutionContext context, SysJob sysJob, Exception e)
|
|
||||||
{
|
|
||||||
Date startTime = threadLocal.get();
|
|
||||||
threadLocal.remove();
|
|
||||||
|
|
||||||
final SysJobLog sysJobLog = new SysJobLog();
|
|
||||||
sysJobLog.setJobName(sysJob.getJobName());
|
|
||||||
sysJobLog.setJobGroup(sysJob.getJobGroup());
|
|
||||||
sysJobLog.setInvokeTarget(sysJob.getInvokeTarget());
|
|
||||||
sysJobLog.setStartTime(startTime);
|
|
||||||
sysJobLog.setStopTime(new Date());
|
|
||||||
long runMs = sysJobLog.getStopTime().getTime() - sysJobLog.getStartTime().getTime();
|
|
||||||
sysJobLog.setJobMessage(sysJobLog.getJobName() + " 总共耗时：" + runMs + "毫秒");
|
|
||||||
if (e != null)
|
|
||||||
{
|
|
||||||
sysJobLog.setStatus("1");
|
|
||||||
String errorMsg = StringUtils.substring(ExceptionUtil.getExceptionMessage(e), 0, 2000);
|
|
||||||
sysJobLog.setExceptionInfo(errorMsg);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
sysJobLog.setStatus("0");
|
|
||||||
}
|
|
||||||
|
|
||||||
// 写入数据库当中
|
|
||||||
SpringUtils.getBean(ISysJobLogService.class).addJobLog(sysJobLog);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 执行方法，由子类重载
|
|
||||||
*
|
|
||||||
* @param context 工作执行上下文对象
|
|
||||||
* @param sysJob 系统计划任务
|
|
||||||
* @throws Exception 执行过程中的异常
|
|
||||||
*/
|
|
||||||
protected abstract void doExecute(JobExecutionContext context, SysJob sysJob) throws Exception;
|
|
||||||
}
|
|
||||||
|
|
@ -1,63 +0,0 @@
|
||||||
package com.ruoyi.job.util;
|
|
||||||
|
|
||||||
import java.text.ParseException;
|
|
||||||
import java.util.Date;
|
|
||||||
import org.quartz.CronExpression;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* cron表达式工具类
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class CronUtils
|
|
||||||
{
|
|
||||||
/**
|
|
||||||
* 返回一个布尔值代表一个给定的Cron表达式的有效性
|
|
||||||
*
|
|
||||||
* @param cronExpression Cron表达式
|
|
||||||
* @return boolean 表达式是否有效
|
|
||||||
*/
|
|
||||||
public static boolean isValid(String cronExpression)
|
|
||||||
{
|
|
||||||
return CronExpression.isValidExpression(cronExpression);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 返回一个字符串值,表示该消息无效Cron表达式给出有效性
|
|
||||||
*
|
|
||||||
* @param cronExpression Cron表达式
|
|
||||||
* @return String 无效时返回表达式错误描述,如果有效返回null
|
|
||||||
*/
|
|
||||||
public static String getInvalidMessage(String cronExpression)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
new CronExpression(cronExpression);
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
catch (ParseException pe)
|
|
||||||
{
|
|
||||||
return pe.getMessage();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 返回下一个执行时间根据给定的Cron表达式
|
|
||||||
*
|
|
||||||
* @param cronExpression Cron表达式
|
|
||||||
* @return Date 下次Cron表达式执行时间
|
|
||||||
*/
|
|
||||||
public static Date getNextExecution(String cronExpression)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
CronExpression cron = new CronExpression(cronExpression);
|
|
||||||
return cron.getNextValidTimeAfter(new Date(System.currentTimeMillis()));
|
|
||||||
}
|
|
||||||
catch (ParseException e)
|
|
||||||
{
|
|
||||||
throw new IllegalArgumentException(e.getMessage());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,182 +0,0 @@
|
||||||
package com.ruoyi.job.util;
|
|
||||||
|
|
||||||
import java.lang.reflect.InvocationTargetException;
|
|
||||||
import java.lang.reflect.Method;
|
|
||||||
import java.util.LinkedList;
|
|
||||||
import java.util.List;
|
|
||||||
import com.ruoyi.common.core.utils.SpringUtils;
|
|
||||||
import com.ruoyi.common.core.utils.StringUtils;
|
|
||||||
import com.ruoyi.job.domain.SysJob;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 任务执行工具
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
*/
|
|
||||||
public class JobInvokeUtil
|
|
||||||
{
|
|
||||||
/**
|
|
||||||
* 执行方法
|
|
||||||
*
|
|
||||||
* @param sysJob 系统任务
|
|
||||||
*/
|
|
||||||
public static void invokeMethod(SysJob sysJob) throws Exception
|
|
||||||
{
|
|
||||||
String invokeTarget = sysJob.getInvokeTarget();
|
|
||||||
String beanName = getBeanName(invokeTarget);
|
|
||||||
String methodName = getMethodName(invokeTarget);
|
|
||||||
List<Object[]> methodParams = getMethodParams(invokeTarget);
|
|
||||||
|
|
||||||
if (!isValidClassName(beanName))
|
|
||||||
{
|
|
||||||
Object bean = SpringUtils.getBean(beanName);
|
|
||||||
invokeMethod(bean, methodName, methodParams);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
Object bean = Class.forName(beanName).newInstance();
|
|
||||||
invokeMethod(bean, methodName, methodParams);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 调用任务方法
|
|
||||||
*
|
|
||||||
* @param bean 目标对象
|
|
||||||
* @param methodName 方法名称
|
|
||||||
* @param methodParams 方法参数
|
|
||||||
*/
|
|
||||||
private static void invokeMethod(Object bean, String methodName, List<Object[]> methodParams)
|
|
||||||
throws NoSuchMethodException, SecurityException, IllegalAccessException, IllegalArgumentException,
|
|
||||||
InvocationTargetException
|
|
||||||
{
|
|
||||||
if (StringUtils.isNotNull(methodParams) && methodParams.size() > 0)
|
|
||||||
{
|
|
||||||
Method method = bean.getClass().getDeclaredMethod(methodName, getMethodParamsType(methodParams));
|
|
||||||
method.invoke(bean, getMethodParamsValue(methodParams));
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
Method method = bean.getClass().getDeclaredMethod(methodName);
|
|
||||||
method.invoke(bean);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 校验是否为为class包名
|
|
||||||
*
|
|
||||||
* @param invokeTarget 名称
|
|
||||||
* @return true是 false否
|
|
||||||
*/
|
|
||||||
public static boolean isValidClassName(String invokeTarget)
|
|
||||||
{
|
|
||||||
return StringUtils.countMatches(invokeTarget, ".") > 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取bean名称
|
|
||||||
*
|
|
||||||
* @param invokeTarget 目标字符串
|
|
||||||
* @return bean名称
|
|
||||||
*/
|
|
||||||
public static String getBeanName(String invokeTarget)
|
|
||||||
{
|
|
||||||
String beanName = StringUtils.substringBefore(invokeTarget, "(");
|
|
||||||
return StringUtils.substringBeforeLast(beanName, ".");
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取bean方法
|
|
||||||
*
|
|
||||||
* @param invokeTarget 目标字符串
|
|
||||||
* @return method方法
|
|
||||||
*/
|
|
||||||
public static String getMethodName(String invokeTarget)
|
|
||||||
{
|
|
||||||
String methodName = StringUtils.substringBefore(invokeTarget, "(");
|
|
||||||
return StringUtils.substringAfterLast(methodName, ".");
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取method方法参数相关列表
|
|
||||||
*
|
|
||||||
* @param invokeTarget 目标字符串
|
|
||||||
* @return method方法相关参数列表
|
|
||||||
*/
|
|
||||||
public static List<Object[]> getMethodParams(String invokeTarget)
|
|
||||||
{
|
|
||||||
String methodStr = StringUtils.substringBetween(invokeTarget, "(", ")");
|
|
||||||
if (StringUtils.isEmpty(methodStr))
|
|
||||||
{
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
String[] methodParams = methodStr.split(",(?=([^\"']*[\"'][^\"']*[\"'])*[^\"']*$)");
|
|
||||||
List<Object[]> classs = new LinkedList<>();
|
|
||||||
for (int i = 0; i < methodParams.length; i++)
|
|
||||||
{
|
|
||||||
String str = StringUtils.trimToEmpty(methodParams[i]);
|
|
||||||
// String字符串类型，以'或"开头
|
|
||||||
if (StringUtils.startsWithAny(str, "'", "\""))
|
|
||||||
{
|
|
||||||
classs.add(new Object[] { StringUtils.substring(str, 1, str.length() - 1), String.class });
|
|
||||||
}
|
|
||||||
// boolean布尔类型，等于true或者false
|
|
||||||
else if ("true".equalsIgnoreCase(str) || "false".equalsIgnoreCase(str))
|
|
||||||
{
|
|
||||||
classs.add(new Object[] { Boolean.valueOf(str), Boolean.class });
|
|
||||||
}
|
|
||||||
// long长整形，以L结尾
|
|
||||||
else if (StringUtils.endsWith(str, "L"))
|
|
||||||
{
|
|
||||||
classs.add(new Object[] { Long.valueOf(StringUtils.substring(str, 0, str.length() - 1)), Long.class });
|
|
||||||
}
|
|
||||||
// double浮点类型，以D结尾
|
|
||||||
else if (StringUtils.endsWith(str, "D"))
|
|
||||||
{
|
|
||||||
classs.add(new Object[] { Double.valueOf(StringUtils.substring(str, 0, str.length() - 1)), Double.class });
|
|
||||||
}
|
|
||||||
// 其他类型归类为整形
|
|
||||||
else
|
|
||||||
{
|
|
||||||
classs.add(new Object[] { Integer.valueOf(str), Integer.class });
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return classs;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取参数类型
|
|
||||||
*
|
|
||||||
* @param methodParams 参数相关列表
|
|
||||||
* @return 参数类型列表
|
|
||||||
*/
|
|
||||||
public static Class<?>[] getMethodParamsType(List<Object[]> methodParams)
|
|
||||||
{
|
|
||||||
Class<?>[] classs = new Class<?>[methodParams.size()];
|
|
||||||
int index = 0;
|
|
||||||
for (Object[] os : methodParams)
|
|
||||||
{
|
|
||||||
classs[index] = (Class<?>) os[1];
|
|
||||||
index++;
|
|
||||||
}
|
|
||||||
return classs;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取参数值
|
|
||||||
*
|
|
||||||
* @param methodParams 参数相关列表
|
|
||||||
* @return 参数值列表
|
|
||||||
*/
|
|
||||||
public static Object[] getMethodParamsValue(List<Object[]> methodParams)
|
|
||||||
{
|
|
||||||
Object[] classs = new Object[methodParams.size()];
|
|
||||||
int index = 0;
|
|
||||||
for (Object[] os : methodParams)
|
|
||||||
{
|
|
||||||
classs[index] = (Object) os[0];
|
|
||||||
index++;
|
|
||||||
}
|
|
||||||
return classs;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,22 +0,0 @@
|
||||||
package com.ruoyi.job.util;
|
|
||||||
|
|
||||||
import org.quartz.DisallowConcurrentExecution;
|
|
||||||
import org.quartz.JobExecutionContext;
|
|
||||||
|
|
||||||
import com.ruoyi.job.domain.SysJob;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 定时任务处理（禁止并发执行）
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
@DisallowConcurrentExecution
|
|
||||||
public class QuartzDisallowConcurrentExecution extends AbstractQuartzJob
|
|
||||||
{
|
|
||||||
@Override
|
|
||||||
protected void doExecute(JobExecutionContext context, SysJob sysJob) throws Exception
|
|
||||||
{
|
|
||||||
JobInvokeUtil.invokeMethod(sysJob);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,20 +0,0 @@
|
||||||
package com.ruoyi.job.util;
|
|
||||||
|
|
||||||
import org.quartz.JobExecutionContext;
|
|
||||||
|
|
||||||
import com.ruoyi.job.domain.SysJob;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 定时任务处理（允许并发执行）
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class QuartzJobExecution extends AbstractQuartzJob
|
|
||||||
{
|
|
||||||
@Override
|
|
||||||
protected void doExecute(JobExecutionContext context, SysJob sysJob) throws Exception
|
|
||||||
{
|
|
||||||
JobInvokeUtil.invokeMethod(sysJob);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,113 +0,0 @@
|
||||||
package com.ruoyi.job.util;
|
|
||||||
|
|
||||||
import org.quartz.CronScheduleBuilder;
|
|
||||||
import org.quartz.CronTrigger;
|
|
||||||
import org.quartz.Job;
|
|
||||||
import org.quartz.JobBuilder;
|
|
||||||
import org.quartz.JobDetail;
|
|
||||||
import org.quartz.JobKey;
|
|
||||||
import org.quartz.Scheduler;
|
|
||||||
import org.quartz.SchedulerException;
|
|
||||||
import org.quartz.TriggerBuilder;
|
|
||||||
import org.quartz.TriggerKey;
|
|
||||||
import com.ruoyi.common.core.constant.ScheduleConstants;
|
|
||||||
import com.ruoyi.common.core.exception.job.TaskException;
|
|
||||||
import com.ruoyi.common.core.exception.job.TaskException.Code;
|
|
||||||
import com.ruoyi.job.domain.SysJob;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 定时任务工具类
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class ScheduleUtils
|
|
||||||
{
|
|
||||||
/**
|
|
||||||
* 得到quartz任务类
|
|
||||||
*
|
|
||||||
* @param sysJob 执行计划
|
|
||||||
* @return 具体执行任务类
|
|
||||||
*/
|
|
||||||
private static Class<? extends Job> getQuartzJobClass(SysJob sysJob)
|
|
||||||
{
|
|
||||||
boolean isConcurrent = "0".equals(sysJob.getConcurrent());
|
|
||||||
return isConcurrent ? QuartzJobExecution.class : QuartzDisallowConcurrentExecution.class;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 构建任务触发对象
|
|
||||||
*/
|
|
||||||
public static TriggerKey getTriggerKey(Long jobId, String jobGroup)
|
|
||||||
{
|
|
||||||
return TriggerKey.triggerKey(ScheduleConstants.TASK_CLASS_NAME + jobId, jobGroup);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 构建任务键对象
|
|
||||||
*/
|
|
||||||
public static JobKey getJobKey(Long jobId, String jobGroup)
|
|
||||||
{
|
|
||||||
return JobKey.jobKey(ScheduleConstants.TASK_CLASS_NAME + jobId, jobGroup);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 创建定时任务
|
|
||||||
*/
|
|
||||||
public static void createScheduleJob(Scheduler scheduler, SysJob job) throws SchedulerException, TaskException
|
|
||||||
{
|
|
||||||
Class<? extends Job> jobClass = getQuartzJobClass(job);
|
|
||||||
// 构建job信息
|
|
||||||
Long jobId = job.getJobId();
|
|
||||||
String jobGroup = job.getJobGroup();
|
|
||||||
JobDetail jobDetail = JobBuilder.newJob(jobClass).withIdentity(getJobKey(jobId, jobGroup)).build();
|
|
||||||
|
|
||||||
// 表达式调度构建器
|
|
||||||
CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(job.getCronExpression());
|
|
||||||
cronScheduleBuilder = handleCronScheduleMisfirePolicy(job, cronScheduleBuilder);
|
|
||||||
|
|
||||||
// 按新的cronExpression表达式构建一个新的trigger
|
|
||||||
CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(getTriggerKey(jobId, jobGroup))
|
|
||||||
.withSchedule(cronScheduleBuilder).build();
|
|
||||||
|
|
||||||
// 放入参数，运行时的方法可以获取
|
|
||||||
jobDetail.getJobDataMap().put(ScheduleConstants.TASK_PROPERTIES, job);
|
|
||||||
|
|
||||||
// 判断是否存在
|
|
||||||
if (scheduler.checkExists(getJobKey(jobId, jobGroup)))
|
|
||||||
{
|
|
||||||
// 防止创建时存在数据问题 先移除，然后在执行创建操作
|
|
||||||
scheduler.deleteJob(getJobKey(jobId, jobGroup));
|
|
||||||
}
|
|
||||||
|
|
||||||
scheduler.scheduleJob(jobDetail, trigger);
|
|
||||||
|
|
||||||
// 暂停任务
|
|
||||||
if (job.getStatus().equals(ScheduleConstants.Status.PAUSE.getValue()))
|
|
||||||
{
|
|
||||||
scheduler.pauseJob(ScheduleUtils.getJobKey(jobId, jobGroup));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 设置定时任务策略
|
|
||||||
*/
|
|
||||||
public static CronScheduleBuilder handleCronScheduleMisfirePolicy(SysJob job, CronScheduleBuilder cb)
|
|
||||||
throws TaskException
|
|
||||||
{
|
|
||||||
switch (job.getMisfirePolicy())
|
|
||||||
{
|
|
||||||
case ScheduleConstants.MISFIRE_DEFAULT:
|
|
||||||
return cb;
|
|
||||||
case ScheduleConstants.MISFIRE_IGNORE_MISFIRES:
|
|
||||||
return cb.withMisfireHandlingInstructionIgnoreMisfires();
|
|
||||||
case ScheduleConstants.MISFIRE_FIRE_AND_PROCEED:
|
|
||||||
return cb.withMisfireHandlingInstructionFireAndProceed();
|
|
||||||
case ScheduleConstants.MISFIRE_DO_NOTHING:
|
|
||||||
return cb.withMisfireHandlingInstructionDoNothing();
|
|
||||||
default:
|
|
||||||
throw new TaskException("The task misfire policy '" + job.getMisfirePolicy()
|
|
||||||
+ "' cannot be used in cron schedule tasks", Code.CONFIG_ERROR);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,10 +0,0 @@
|
||||||
Spring Boot Version: ${spring-boot.version}
|
|
||||||
Spring Application Name: ${spring.application.name}
|
|
||||||
_ _ _
|
|
||||||
(_) (_) | |
|
|
||||||
_ __ _ _ ___ _ _ _ ______ _ ___ | |__
|
|
||||||
| '__|| | | | / _ \ | | | || ||______| | | / _ \ | '_ \
|
|
||||||
| | | |_| || (_) || |_| || | | || (_) || |_) |
|
|
||||||
|_| \__,_| \___/ \__, ||_| | | \___/ |_.__/
|
|
||||||
__/ | _/ |
|
|
||||||
|___/ |__/
|
|
||||||
|
|
@ -1,32 +0,0 @@
|
||||||
# Tomcat
|
|
||||||
server:
|
|
||||||
port: 9203
|
|
||||||
|
|
||||||
# Spring
|
|
||||||
spring:
|
|
||||||
application:
|
|
||||||
# 应用名称
|
|
||||||
name: ruoyi-job
|
|
||||||
profiles:
|
|
||||||
# 环境配置
|
|
||||||
active: @profiles.active@
|
|
||||||
|
|
||||||
--- # nacos 配置
|
|
||||||
spring:
|
|
||||||
cloud:
|
|
||||||
nacos:
|
|
||||||
discovery:
|
|
||||||
# 服务注册地址
|
|
||||||
server-addr: @nacos.server@
|
|
||||||
# 注册组
|
|
||||||
group: @nacos.discovery.group@
|
|
||||||
config:
|
|
||||||
# 配置中心地址
|
|
||||||
server-addr: @nacos.server@
|
|
||||||
# 配置组
|
|
||||||
group: @nacos.config.group@
|
|
||||||
# 配置文件格式
|
|
||||||
file-extension: yml
|
|
||||||
# 共享配置
|
|
||||||
shared-configs:
|
|
||||||
- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
|
|
||||||
|
|
@ -1,74 +0,0 @@
|
||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<configuration scan="true" scanPeriod="60 seconds" debug="false">
|
|
||||||
<!-- 日志存放路径 -->
|
|
||||||
<property name="log.path" value="logs/ruoyi-job" />
|
|
||||||
<!-- 日志输出格式 -->
|
|
||||||
<property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n" />
|
|
||||||
|
|
||||||
<!-- 控制台输出 -->
|
|
||||||
<appender name="console" class="ch.qos.logback.core.ConsoleAppender">
|
|
||||||
<encoder>
|
|
||||||
<pattern>${log.pattern}</pattern>
|
|
||||||
</encoder>
|
|
||||||
</appender>
|
|
||||||
|
|
||||||
<!-- 系统日志输出 -->
|
|
||||||
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
|
|
||||||
<file>${log.path}/info.log</file>
|
|
||||||
<!-- 循环政策：基于时间创建日志文件 -->
|
|
||||||
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
|
|
||||||
<!-- 日志文件名格式 -->
|
|
||||||
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
|
|
||||||
<!-- 日志最大的历史 60天 -->
|
|
||||||
<maxHistory>60</maxHistory>
|
|
||||||
</rollingPolicy>
|
|
||||||
<encoder>
|
|
||||||
<pattern>${log.pattern}</pattern>
|
|
||||||
</encoder>
|
|
||||||
<filter class="ch.qos.logback.classic.filter.LevelFilter">
|
|
||||||
<!-- 过滤的级别 -->
|
|
||||||
<level>INFO</level>
|
|
||||||
<!-- 匹配时的操作：接收（记录） -->
|
|
||||||
<onMatch>ACCEPT</onMatch>
|
|
||||||
<!-- 不匹配时的操作：拒绝（不记录） -->
|
|
||||||
<onMismatch>DENY</onMismatch>
|
|
||||||
</filter>
|
|
||||||
</appender>
|
|
||||||
|
|
||||||
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
|
|
||||||
<file>${log.path}/error.log</file>
|
|
||||||
<!-- 循环政策：基于时间创建日志文件 -->
|
|
||||||
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
|
|
||||||
<!-- 日志文件名格式 -->
|
|
||||||
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
|
|
||||||
<!-- 日志最大的历史 60天 -->
|
|
||||||
<maxHistory>60</maxHistory>
|
|
||||||
</rollingPolicy>
|
|
||||||
<encoder>
|
|
||||||
<pattern>${log.pattern}</pattern>
|
|
||||||
</encoder>
|
|
||||||
<filter class="ch.qos.logback.classic.filter.LevelFilter">
|
|
||||||
<!-- 过滤的级别 -->
|
|
||||||
<level>ERROR</level>
|
|
||||||
<!-- 匹配时的操作：接收（记录） -->
|
|
||||||
<onMatch>ACCEPT</onMatch>
|
|
||||||
<!-- 不匹配时的操作：拒绝（不记录） -->
|
|
||||||
<onMismatch>DENY</onMismatch>
|
|
||||||
</filter>
|
|
||||||
</appender>
|
|
||||||
|
|
||||||
<!-- 系统模块日志级别控制 -->
|
|
||||||
<logger name="com.ruoyi" level="info" />
|
|
||||||
<!-- Spring日志级别控制 -->
|
|
||||||
<logger name="org.springframework" level="warn" />
|
|
||||||
|
|
||||||
<root level="info">
|
|
||||||
<appender-ref ref="console" />
|
|
||||||
</root>
|
|
||||||
|
|
||||||
<!--系统操作日志-->
|
|
||||||
<root level="info">
|
|
||||||
<appender-ref ref="file_info" />
|
|
||||||
<appender-ref ref="file_error" />
|
|
||||||
</root>
|
|
||||||
</configuration>
|
|
||||||
|
|
@ -1,93 +0,0 @@
|
||||||
<?xml version="1.0" encoding="UTF-8" ?>
|
|
||||||
<!DOCTYPE mapper
|
|
||||||
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
|
|
||||||
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
|
||||||
<mapper namespace="com.ruoyi.job.mapper.SysJobLogMapper">
|
|
||||||
|
|
||||||
<resultMap type="SysJobLog" id="SysJobLogResult">
|
|
||||||
<id property="jobLogId" column="job_log_id" />
|
|
||||||
<result property="jobName" column="job_name" />
|
|
||||||
<result property="jobGroup" column="job_group" />
|
|
||||||
<result property="invokeTarget" column="invoke_target" />
|
|
||||||
<result property="jobMessage" column="job_message" />
|
|
||||||
<result property="status" column="status" />
|
|
||||||
<result property="exceptionInfo" column="exception_info" />
|
|
||||||
<result property="createTime" column="create_time" />
|
|
||||||
</resultMap>
|
|
||||||
|
|
||||||
<sql id="selectJobLogVo">
|
|
||||||
select job_log_id, job_name, job_group, invoke_target, job_message, status, exception_info, create_time
|
|
||||||
from sys_job_log
|
|
||||||
</sql>
|
|
||||||
|
|
||||||
<select id="selectJobLogList" parameterType="SysJobLog" resultMap="SysJobLogResult">
|
|
||||||
<include refid="selectJobLogVo"/>
|
|
||||||
<where>
|
|
||||||
<if test="jobName != null and jobName != ''">
|
|
||||||
AND job_name like concat('%', #{jobName}, '%')
|
|
||||||
</if>
|
|
||||||
<if test="jobGroup != null and jobGroup != ''">
|
|
||||||
AND job_group = #{jobGroup}
|
|
||||||
</if>
|
|
||||||
<if test="status != null and status != ''">
|
|
||||||
AND status = #{status}
|
|
||||||
</if>
|
|
||||||
<if test="invokeTarget != null and invokeTarget != ''">
|
|
||||||
AND invoke_target like concat('%', #{invokeTarget}, '%')
|
|
||||||
</if>
|
|
||||||
<if test="params.beginTime != null and params.beginTime != ''"><!-- 开始时间检索 -->
|
|
||||||
and date_format(create_time,'%y%m%d') >= date_format(#{params.beginTime},'%y%m%d')
|
|
||||||
</if>
|
|
||||||
<if test="params.endTime != null and params.endTime != ''"><!-- 结束时间检索 -->
|
|
||||||
and date_format(create_time,'%y%m%d') <= date_format(#{params.endTime},'%y%m%d')
|
|
||||||
</if>
|
|
||||||
</where>
|
|
||||||
</select>
|
|
||||||
|
|
||||||
<select id="selectJobLogAll" resultMap="SysJobLogResult">
|
|
||||||
<include refid="selectJobLogVo"/>
|
|
||||||
</select>
|
|
||||||
|
|
||||||
<select id="selectJobLogById" parameterType="Long" resultMap="SysJobLogResult">
|
|
||||||
<include refid="selectJobLogVo"/>
|
|
||||||
where job_log_id = #{jobLogId}
|
|
||||||
</select>
|
|
||||||
|
|
||||||
<delete id="deleteJobLogById" parameterType="Long">
|
|
||||||
delete from sys_job_log where job_log_id = #{jobLogId}
|
|
||||||
</delete>
|
|
||||||
|
|
||||||
<delete id="deleteJobLogByIds" parameterType="Long">
|
|
||||||
delete from sys_job_log where job_log_id in
|
|
||||||
<foreach collection="array" item="jobLogId" open="(" separator="," close=")">
|
|
||||||
#{jobLogId}
|
|
||||||
</foreach>
|
|
||||||
</delete>
|
|
||||||
|
|
||||||
<update id="cleanJobLog">
|
|
||||||
truncate table sys_job_log
|
|
||||||
</update>
|
|
||||||
|
|
||||||
<insert id="insertJobLog" parameterType="SysJobLog">
|
|
||||||
insert into sys_job_log(
|
|
||||||
<if test="jobLogId != null and jobLogId != 0">job_log_id,</if>
|
|
||||||
<if test="jobName != null and jobName != ''">job_name,</if>
|
|
||||||
<if test="jobGroup != null and jobGroup != ''">job_group,</if>
|
|
||||||
<if test="invokeTarget != null and invokeTarget != ''">invoke_target,</if>
|
|
||||||
<if test="jobMessage != null and jobMessage != ''">job_message,</if>
|
|
||||||
<if test="status != null and status != ''">status,</if>
|
|
||||||
<if test="exceptionInfo != null and exceptionInfo != ''">exception_info,</if>
|
|
||||||
create_time
|
|
||||||
)values(
|
|
||||||
<if test="jobLogId != null and jobLogId != 0">#{jobLogId},</if>
|
|
||||||
<if test="jobName != null and jobName != ''">#{jobName},</if>
|
|
||||||
<if test="jobGroup != null and jobGroup != ''">#{jobGroup},</if>
|
|
||||||
<if test="invokeTarget != null and invokeTarget != ''">#{invokeTarget},</if>
|
|
||||||
<if test="jobMessage != null and jobMessage != ''">#{jobMessage},</if>
|
|
||||||
<if test="status != null and status != ''">#{status},</if>
|
|
||||||
<if test="exceptionInfo != null and exceptionInfo != ''">#{exceptionInfo},</if>
|
|
||||||
sysdate()
|
|
||||||
)
|
|
||||||
</insert>
|
|
||||||
|
|
||||||
</mapper>
|
|
||||||
|
|
@ -1,111 +0,0 @@
|
||||||
<?xml version="1.0" encoding="UTF-8" ?>
|
|
||||||
<!DOCTYPE mapper
|
|
||||||
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
|
|
||||||
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
|
||||||
<mapper namespace="com.ruoyi.job.mapper.SysJobMapper">
|
|
||||||
|
|
||||||
<resultMap type="SysJob" id="SysJobResult">
|
|
||||||
<id property="jobId" column="job_id" />
|
|
||||||
<result property="jobName" column="job_name" />
|
|
||||||
<result property="jobGroup" column="job_group" />
|
|
||||||
<result property="invokeTarget" column="invoke_target" />
|
|
||||||
<result property="cronExpression" column="cron_expression" />
|
|
||||||
<result property="misfirePolicy" column="misfire_policy" />
|
|
||||||
<result property="concurrent" column="concurrent" />
|
|
||||||
<result property="status" column="status" />
|
|
||||||
<result property="createBy" column="create_by" />
|
|
||||||
<result property="createTime" column="create_time" />
|
|
||||||
<result property="updateBy" column="update_by" />
|
|
||||||
<result property="updateTime" column="update_time" />
|
|
||||||
<result property="remark" column="remark" />
|
|
||||||
</resultMap>
|
|
||||||
|
|
||||||
<sql id="selectJobVo">
|
|
||||||
select job_id, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, status, create_by, create_time, remark
|
|
||||||
from sys_job
|
|
||||||
</sql>
|
|
||||||
|
|
||||||
<select id="selectJobList" parameterType="SysJob" resultMap="SysJobResult">
|
|
||||||
<include refid="selectJobVo"/>
|
|
||||||
<where>
|
|
||||||
<if test="jobName != null and jobName != ''">
|
|
||||||
AND job_name like concat('%', #{jobName}, '%')
|
|
||||||
</if>
|
|
||||||
<if test="jobGroup != null and jobGroup != ''">
|
|
||||||
AND job_group = #{jobGroup}
|
|
||||||
</if>
|
|
||||||
<if test="status != null and status != ''">
|
|
||||||
AND status = #{status}
|
|
||||||
</if>
|
|
||||||
<if test="invokeTarget != null and invokeTarget != ''">
|
|
||||||
AND invoke_target like concat('%', #{invokeTarget}, '%')
|
|
||||||
</if>
|
|
||||||
</where>
|
|
||||||
</select>
|
|
||||||
|
|
||||||
<select id="selectJobAll" resultMap="SysJobResult">
|
|
||||||
<include refid="selectJobVo"/>
|
|
||||||
</select>
|
|
||||||
|
|
||||||
<select id="selectJobById" parameterType="Long" resultMap="SysJobResult">
|
|
||||||
<include refid="selectJobVo"/>
|
|
||||||
where job_id = #{jobId}
|
|
||||||
</select>
|
|
||||||
|
|
||||||
<delete id="deleteJobById" parameterType="Long">
|
|
||||||
delete from sys_job where job_id = #{jobId}
|
|
||||||
</delete>
|
|
||||||
|
|
||||||
<delete id="deleteJobByIds" parameterType="Long">
|
|
||||||
delete from sys_job where job_id in
|
|
||||||
<foreach collection="array" item="jobId" open="(" separator="," close=")">
|
|
||||||
#{jobId}
|
|
||||||
</foreach>
|
|
||||||
</delete>
|
|
||||||
|
|
||||||
<update id="updateJob" parameterType="SysJob">
|
|
||||||
update sys_job
|
|
||||||
<set>
|
|
||||||
<if test="jobName != null and jobName != ''">job_name = #{jobName},</if>
|
|
||||||
<if test="jobGroup != null and jobGroup != ''">job_group = #{jobGroup},</if>
|
|
||||||
<if test="invokeTarget != null and invokeTarget != ''">invoke_target = #{invokeTarget},</if>
|
|
||||||
<if test="cronExpression != null and cronExpression != ''">cron_expression = #{cronExpression},</if>
|
|
||||||
<if test="misfirePolicy != null and misfirePolicy != ''">misfire_policy = #{misfirePolicy},</if>
|
|
||||||
<if test="concurrent != null and concurrent != ''">concurrent = #{concurrent},</if>
|
|
||||||
<if test="status !=null">status = #{status},</if>
|
|
||||||
<if test="remark != null and remark != ''">remark = #{remark},</if>
|
|
||||||
<if test="updateBy != null and updateBy != ''">update_by = #{updateBy},</if>
|
|
||||||
update_time = sysdate()
|
|
||||||
</set>
|
|
||||||
where job_id = #{jobId}
|
|
||||||
</update>
|
|
||||||
|
|
||||||
<insert id="insertJob" parameterType="SysJob" useGeneratedKeys="true" keyProperty="jobId">
|
|
||||||
insert into sys_job(
|
|
||||||
<if test="jobId != null and jobId != 0">job_id,</if>
|
|
||||||
<if test="jobName != null and jobName != ''">job_name,</if>
|
|
||||||
<if test="jobGroup != null and jobGroup != ''">job_group,</if>
|
|
||||||
<if test="invokeTarget != null and invokeTarget != ''">invoke_target,</if>
|
|
||||||
<if test="cronExpression != null and cronExpression != ''">cron_expression,</if>
|
|
||||||
<if test="misfirePolicy != null and misfirePolicy != ''">misfire_policy,</if>
|
|
||||||
<if test="concurrent != null and concurrent != ''">concurrent,</if>
|
|
||||||
<if test="status != null and status != ''">status,</if>
|
|
||||||
<if test="remark != null and remark != ''">remark,</if>
|
|
||||||
<if test="createBy != null and createBy != ''">create_by,</if>
|
|
||||||
create_time
|
|
||||||
)values(
|
|
||||||
<if test="jobId != null and jobId != 0">#{jobId},</if>
|
|
||||||
<if test="jobName != null and jobName != ''">#{jobName},</if>
|
|
||||||
<if test="jobGroup != null and jobGroup != ''">#{jobGroup},</if>
|
|
||||||
<if test="invokeTarget != null and invokeTarget != ''">#{invokeTarget},</if>
|
|
||||||
<if test="cronExpression != null and cronExpression != ''">#{cronExpression},</if>
|
|
||||||
<if test="misfirePolicy != null and misfirePolicy != ''">#{misfirePolicy},</if>
|
|
||||||
<if test="concurrent != null and concurrent != ''">#{concurrent},</if>
|
|
||||||
<if test="status != null and status != ''">#{status},</if>
|
|
||||||
<if test="remark != null and remark != ''">#{remark},</if>
|
|
||||||
<if test="createBy != null and createBy != ''">#{createBy},</if>
|
|
||||||
sysdate()
|
|
||||||
)
|
|
||||||
</insert>
|
|
||||||
|
|
||||||
</mapper>
|
|
||||||
174
sql/quartz.sql
174
sql/quartz.sql
|
|
@ -1,174 +0,0 @@
|
||||||
DROP TABLE IF EXISTS QRTZ_FIRED_TRIGGERS;
|
|
||||||
DROP TABLE IF EXISTS QRTZ_PAUSED_TRIGGER_GRPS;
|
|
||||||
DROP TABLE IF EXISTS QRTZ_SCHEDULER_STATE;
|
|
||||||
DROP TABLE IF EXISTS QRTZ_LOCKS;
|
|
||||||
DROP TABLE IF EXISTS QRTZ_SIMPLE_TRIGGERS;
|
|
||||||
DROP TABLE IF EXISTS QRTZ_SIMPROP_TRIGGERS;
|
|
||||||
DROP TABLE IF EXISTS QRTZ_CRON_TRIGGERS;
|
|
||||||
DROP TABLE IF EXISTS QRTZ_BLOB_TRIGGERS;
|
|
||||||
DROP TABLE IF EXISTS QRTZ_TRIGGERS;
|
|
||||||
DROP TABLE IF EXISTS QRTZ_JOB_DETAILS;
|
|
||||||
DROP TABLE IF EXISTS QRTZ_CALENDARS;
|
|
||||||
|
|
||||||
-- ----------------------------
|
|
||||||
-- 1、存储每一个已配置的 jobDetail 的详细信息
|
|
||||||
-- ----------------------------
|
|
||||||
create table QRTZ_JOB_DETAILS (
|
|
||||||
sched_name varchar(120) not null comment '调度名称',
|
|
||||||
job_name varchar(200) not null comment '任务名称',
|
|
||||||
job_group varchar(200) not null comment '任务组名',
|
|
||||||
description varchar(250) null comment '相关介绍',
|
|
||||||
job_class_name varchar(250) not null comment '执行任务类名称',
|
|
||||||
is_durable varchar(1) not null comment '是否持久化',
|
|
||||||
is_nonconcurrent varchar(1) not null comment '是否并发',
|
|
||||||
is_update_data varchar(1) not null comment '是否更新数据',
|
|
||||||
requests_recovery varchar(1) not null comment '是否接受恢复执行',
|
|
||||||
job_data blob null comment '存放持久化job对象',
|
|
||||||
primary key (sched_name, job_name, job_group)
|
|
||||||
) engine=innodb comment = '任务详细信息表';
|
|
||||||
|
|
||||||
-- ----------------------------
|
|
||||||
-- 2、 存储已配置的 Trigger 的信息
|
|
||||||
-- ----------------------------
|
|
||||||
create table QRTZ_TRIGGERS (
|
|
||||||
sched_name varchar(120) not null comment '调度名称',
|
|
||||||
trigger_name varchar(200) not null comment '触发器的名字',
|
|
||||||
trigger_group varchar(200) not null comment '触发器所属组的名字',
|
|
||||||
job_name varchar(200) not null comment 'qrtz_job_details表job_name的外键',
|
|
||||||
job_group varchar(200) not null comment 'qrtz_job_details表job_group的外键',
|
|
||||||
description varchar(250) null comment '相关介绍',
|
|
||||||
next_fire_time bigint(13) null comment '上一次触发时间（毫秒）',
|
|
||||||
prev_fire_time bigint(13) null comment '下一次触发时间（默认为-1表示不触发）',
|
|
||||||
priority integer null comment '优先级',
|
|
||||||
trigger_state varchar(16) not null comment '触发器状态',
|
|
||||||
trigger_type varchar(8) not null comment '触发器的类型',
|
|
||||||
start_time bigint(13) not null comment '开始时间',
|
|
||||||
end_time bigint(13) null comment '结束时间',
|
|
||||||
calendar_name varchar(200) null comment '日程表名称',
|
|
||||||
misfire_instr smallint(2) null comment '补偿执行的策略',
|
|
||||||
job_data blob null comment '存放持久化job对象',
|
|
||||||
primary key (sched_name, trigger_name, trigger_group),
|
|
||||||
foreign key (sched_name, job_name, job_group) references QRTZ_JOB_DETAILS(sched_name, job_name, job_group)
|
|
||||||
) engine=innodb comment = '触发器详细信息表';
|
|
||||||
|
|
||||||
-- ----------------------------
|
|
||||||
-- 3、 存储简单的 Trigger，包括重复次数，间隔，以及已触发的次数
|
|
||||||
-- ----------------------------
|
|
||||||
create table QRTZ_SIMPLE_TRIGGERS (
|
|
||||||
sched_name varchar(120) not null comment '调度名称',
|
|
||||||
trigger_name varchar(200) not null comment 'qrtz_triggers表trigger_name的外键',
|
|
||||||
trigger_group varchar(200) not null comment 'qrtz_triggers表trigger_group的外键',
|
|
||||||
repeat_count bigint(7) not null comment '重复的次数统计',
|
|
||||||
repeat_interval bigint(12) not null comment '重复的间隔时间',
|
|
||||||
times_triggered bigint(10) not null comment '已经触发的次数',
|
|
||||||
primary key (sched_name, trigger_name, trigger_group),
|
|
||||||
foreign key (sched_name, trigger_name, trigger_group) references QRTZ_TRIGGERS(sched_name, trigger_name, trigger_group)
|
|
||||||
) engine=innodb comment = '简单触发器的信息表';
|
|
||||||
|
|
||||||
-- ----------------------------
|
|
||||||
-- 4、 存储 Cron Trigger，包括 Cron 表达式和时区信息
|
|
||||||
-- ----------------------------
|
|
||||||
create table QRTZ_CRON_TRIGGERS (
|
|
||||||
sched_name varchar(120) not null comment '调度名称',
|
|
||||||
trigger_name varchar(200) not null comment 'qrtz_triggers表trigger_name的外键',
|
|
||||||
trigger_group varchar(200) not null comment 'qrtz_triggers表trigger_group的外键',
|
|
||||||
cron_expression varchar(200) not null comment 'cron表达式',
|
|
||||||
time_zone_id varchar(80) comment '时区',
|
|
||||||
primary key (sched_name, trigger_name, trigger_group),
|
|
||||||
foreign key (sched_name, trigger_name, trigger_group) references QRTZ_TRIGGERS(sched_name, trigger_name, trigger_group)
|
|
||||||
) engine=innodb comment = 'Cron类型的触发器表';
|
|
||||||
|
|
||||||
-- ----------------------------
|
|
||||||
-- 5、 Trigger 作为 Blob 类型存储(用于 Quartz 用户用 JDBC 创建他们自己定制的 Trigger 类型，JobStore 并不知道如何存储实例的时候)
|
|
||||||
-- ----------------------------
|
|
||||||
create table QRTZ_BLOB_TRIGGERS (
|
|
||||||
sched_name varchar(120) not null comment '调度名称',
|
|
||||||
trigger_name varchar(200) not null comment 'qrtz_triggers表trigger_name的外键',
|
|
||||||
trigger_group varchar(200) not null comment 'qrtz_triggers表trigger_group的外键',
|
|
||||||
blob_data blob null comment '存放持久化Trigger对象',
|
|
||||||
primary key (sched_name, trigger_name, trigger_group),
|
|
||||||
foreign key (sched_name, trigger_name, trigger_group) references QRTZ_TRIGGERS(sched_name, trigger_name, trigger_group)
|
|
||||||
) engine=innodb comment = 'Blob类型的触发器表';
|
|
||||||
|
|
||||||
-- ----------------------------
|
|
||||||
-- 6、 以 Blob 类型存储存放日历信息， quartz可配置一个日历来指定一个时间范围
|
|
||||||
-- ----------------------------
|
|
||||||
create table QRTZ_CALENDARS (
|
|
||||||
sched_name varchar(120) not null comment '调度名称',
|
|
||||||
calendar_name varchar(200) not null comment '日历名称',
|
|
||||||
calendar blob not null comment '存放持久化calendar对象',
|
|
||||||
primary key (sched_name, calendar_name)
|
|
||||||
) engine=innodb comment = '日历信息表';
|
|
||||||
|
|
||||||
-- ----------------------------
|
|
||||||
-- 7、 存储已暂停的 Trigger 组的信息
|
|
||||||
-- ----------------------------
|
|
||||||
create table QRTZ_PAUSED_TRIGGER_GRPS (
|
|
||||||
sched_name varchar(120) not null comment '调度名称',
|
|
||||||
trigger_group varchar(200) not null comment 'qrtz_triggers表trigger_group的外键',
|
|
||||||
primary key (sched_name, trigger_group)
|
|
||||||
) engine=innodb comment = '暂停的触发器表';
|
|
||||||
|
|
||||||
-- ----------------------------
|
|
||||||
-- 8、 存储与已触发的 Trigger 相关的状态信息，以及相联 Job 的执行信息
|
|
||||||
-- ----------------------------
|
|
||||||
create table QRTZ_FIRED_TRIGGERS (
|
|
||||||
sched_name varchar(120) not null comment '调度名称',
|
|
||||||
entry_id varchar(95) not null comment '调度器实例id',
|
|
||||||
trigger_name varchar(200) not null comment 'qrtz_triggers表trigger_name的外键',
|
|
||||||
trigger_group varchar(200) not null comment 'qrtz_triggers表trigger_group的外键',
|
|
||||||
instance_name varchar(200) not null comment '调度器实例名',
|
|
||||||
fired_time bigint(13) not null comment '触发的时间',
|
|
||||||
sched_time bigint(13) not null comment '定时器制定的时间',
|
|
||||||
priority integer not null comment '优先级',
|
|
||||||
state varchar(16) not null comment '状态',
|
|
||||||
job_name varchar(200) null comment '任务名称',
|
|
||||||
job_group varchar(200) null comment '任务组名',
|
|
||||||
is_nonconcurrent varchar(1) null comment '是否并发',
|
|
||||||
requests_recovery varchar(1) null comment '是否接受恢复执行',
|
|
||||||
primary key (sched_name, entry_id)
|
|
||||||
) engine=innodb comment = '已触发的触发器表';
|
|
||||||
|
|
||||||
-- ----------------------------
|
|
||||||
-- 9、 存储少量的有关 Scheduler 的状态信息，假如是用于集群中，可以看到其他的 Scheduler 实例
|
|
||||||
-- ----------------------------
|
|
||||||
create table QRTZ_SCHEDULER_STATE (
|
|
||||||
sched_name varchar(120) not null comment '调度名称',
|
|
||||||
instance_name varchar(200) not null comment '实例名称',
|
|
||||||
last_checkin_time bigint(13) not null comment '上次检查时间',
|
|
||||||
checkin_interval bigint(13) not null comment '检查间隔时间',
|
|
||||||
primary key (sched_name, instance_name)
|
|
||||||
) engine=innodb comment = '调度器状态表';
|
|
||||||
|
|
||||||
-- ----------------------------
|
|
||||||
-- 10、 存储程序的悲观锁的信息(假如使用了悲观锁)
|
|
||||||
-- ----------------------------
|
|
||||||
create table QRTZ_LOCKS (
|
|
||||||
sched_name varchar(120) not null comment '调度名称',
|
|
||||||
lock_name varchar(40) not null comment '悲观锁名称',
|
|
||||||
primary key (sched_name, lock_name)
|
|
||||||
) engine=innodb comment = '存储的悲观锁信息表';
|
|
||||||
|
|
||||||
-- ----------------------------
|
|
||||||
-- 11、 Quartz集群实现同步机制的行锁表
|
|
||||||
-- ----------------------------
|
|
||||||
create table QRTZ_SIMPROP_TRIGGERS (
|
|
||||||
sched_name varchar(120) not null comment '调度名称',
|
|
||||||
trigger_name varchar(200) not null comment 'qrtz_triggers表trigger_name的外键',
|
|
||||||
trigger_group varchar(200) not null comment 'qrtz_triggers表trigger_group的外键',
|
|
||||||
str_prop_1 varchar(512) null comment 'String类型的trigger的第一个参数',
|
|
||||||
str_prop_2 varchar(512) null comment 'String类型的trigger的第二个参数',
|
|
||||||
str_prop_3 varchar(512) null comment 'String类型的trigger的第三个参数',
|
|
||||||
int_prop_1 int null comment 'int类型的trigger的第一个参数',
|
|
||||||
int_prop_2 int null comment 'int类型的trigger的第二个参数',
|
|
||||||
long_prop_1 bigint null comment 'long类型的trigger的第一个参数',
|
|
||||||
long_prop_2 bigint null comment 'long类型的trigger的第二个参数',
|
|
||||||
dec_prop_1 numeric(13,4) null comment 'decimal类型的trigger的第一个参数',
|
|
||||||
dec_prop_2 numeric(13,4) null comment 'decimal类型的trigger的第二个参数',
|
|
||||||
bool_prop_1 varchar(1) null comment 'Boolean类型的trigger的第一个参数',
|
|
||||||
bool_prop_2 varchar(1) null comment 'Boolean类型的trigger的第二个参数',
|
|
||||||
primary key (sched_name, trigger_name, trigger_group),
|
|
||||||
foreign key (sched_name, trigger_name, trigger_group) references QRTZ_TRIGGERS(sched_name, trigger_name, trigger_group)
|
|
||||||
) engine=innodb comment = '同步机制的行锁表';
|
|
||||||
|
|
||||||
commit;
|
|
||||||
|
|
@ -174,7 +174,7 @@ insert into sys_menu values('106', '参数设置', '1', '7', 'config',
|
||||||
insert into sys_menu values('107', '通知公告', '1', '8', 'notice', 'system/notice/index', '', 1, 0, 'C', '0', '0', 'system:notice:list', 'message', 'admin', sysdate(), '', null, '通知公告菜单');
|
insert into sys_menu values('107', '通知公告', '1', '8', 'notice', 'system/notice/index', '', 1, 0, 'C', '0', '0', 'system:notice:list', 'message', 'admin', sysdate(), '', null, '通知公告菜单');
|
||||||
insert into sys_menu values('108', '日志管理', '1', '9', 'log', '', '', 1, 0, 'M', '0', '0', '', 'log', 'admin', sysdate(), '', null, '日志管理菜单');
|
insert into sys_menu values('108', '日志管理', '1', '9', 'log', '', '', 1, 0, 'M', '0', '0', '', 'log', 'admin', sysdate(), '', null, '日志管理菜单');
|
||||||
insert into sys_menu values('109', '在线用户', '2', '1', 'online', 'monitor/online/index', '', 1, 0, 'C', '0', '0', 'monitor:online:list', 'online', 'admin', sysdate(), '', null, '在线用户菜单');
|
insert into sys_menu values('109', '在线用户', '2', '1', 'online', 'monitor/online/index', '', 1, 0, 'C', '0', '0', 'monitor:online:list', 'online', 'admin', sysdate(), '', null, '在线用户菜单');
|
||||||
insert into sys_menu values('110', '定时任务', '2', '2', 'job', 'monitor/job/index', '', 1, 0, 'C', '0', '0', 'monitor:job:list', 'job', 'admin', sysdate(), '', null, '定时任务菜单');
|
# insert into sys_menu values('110', '定时任务', '2', '2', 'job', 'monitor/job/index', '', 1, 0, 'C', '0', '0', 'monitor:job:list', 'job', 'admin', sysdate(), '', null, '定时任务菜单');
|
||||||
insert into sys_menu values('111', 'Sentinel控制台', '2', '3', 'http://localhost:8718', '', '', 0, 0, 'C', '0', '0', 'monitor:sentinel:list', 'sentinel', 'admin', sysdate(), '', null, '流量控制菜单');
|
insert into sys_menu values('111', 'Sentinel控制台', '2', '3', 'http://localhost:8718', '', '', 0, 0, 'C', '0', '0', 'monitor:sentinel:list', 'sentinel', 'admin', sysdate(), '', null, '流量控制菜单');
|
||||||
insert into sys_menu values('112', 'Nacos控制台', '2', '4', 'http://localhost:8848/nacos', '', '', 0, 0, 'C', '0', '0', 'monitor:nacos:list', 'nacos', 'admin', sysdate(), '', null, '服务治理菜单');
|
insert into sys_menu values('112', 'Nacos控制台', '2', '4', 'http://localhost:8848/nacos', '', '', 0, 0, 'C', '0', '0', 'monitor:nacos:list', 'nacos', 'admin', sysdate(), '', null, '服务治理菜单');
|
||||||
insert into sys_menu values('113', 'Admin控制台', '2', '5', 'http://localhost:9100/login', '', '', 0, 0, 'C', '0', '0', 'monitor:server:list', 'server', 'admin', sysdate(), '', null, '服务监控菜单');
|
insert into sys_menu values('113', 'Admin控制台', '2', '5', 'http://localhost:9100/login', '', '', 0, 0, 'C', '0', '0', 'monitor:server:list', 'server', 'admin', sysdate(), '', null, '服务监控菜单');
|
||||||
|
|
@ -243,13 +243,6 @@ insert into sys_menu values('1045', '日志导出', '501', '3', '#', '', '', 1,
|
||||||
insert into sys_menu values('1046', '在线查询', '109', '1', '#', '', '', 1, 0, 'F', '0', '0', 'monitor:online:query', '#', 'admin', sysdate(), '', null, '');
|
insert into sys_menu values('1046', '在线查询', '109', '1', '#', '', '', 1, 0, 'F', '0', '0', 'monitor:online:query', '#', 'admin', sysdate(), '', null, '');
|
||||||
insert into sys_menu values('1047', '批量强退', '109', '2', '#', '', '', 1, 0, 'F', '0', '0', 'monitor:online:batchLogout', '#', 'admin', sysdate(), '', null, '');
|
insert into sys_menu values('1047', '批量强退', '109', '2', '#', '', '', 1, 0, 'F', '0', '0', 'monitor:online:batchLogout', '#', 'admin', sysdate(), '', null, '');
|
||||||
insert into sys_menu values('1048', '单条强退', '109', '3', '#', '', '', 1, 0, 'F', '0', '0', 'monitor:online:forceLogout', '#', 'admin', sysdate(), '', null, '');
|
insert into sys_menu values('1048', '单条强退', '109', '3', '#', '', '', 1, 0, 'F', '0', '0', 'monitor:online:forceLogout', '#', 'admin', sysdate(), '', null, '');
|
||||||
-- 定时任务按钮
|
|
||||||
insert into sys_menu values('1049', '任务查询', '110', '1', '#', '', '', 1, 0, 'F', '0', '0', 'monitor:job:query', '#', 'admin', sysdate(), '', null, '');
|
|
||||||
insert into sys_menu values('1050', '任务新增', '110', '2', '#', '', '', 1, 0, 'F', '0', '0', 'monitor:job:add', '#', 'admin', sysdate(), '', null, '');
|
|
||||||
insert into sys_menu values('1051', '任务修改', '110', '3', '#', '', '', 1, 0, 'F', '0', '0', 'monitor:job:edit', '#', 'admin', sysdate(), '', null, '');
|
|
||||||
insert into sys_menu values('1052', '任务删除', '110', '4', '#', '', '', 1, 0, 'F', '0', '0', 'monitor:job:remove', '#', 'admin', sysdate(), '', null, '');
|
|
||||||
insert into sys_menu values('1053', '状态修改', '110', '5', '#', '', '', 1, 0, 'F', '0', '0', 'monitor:job:changeStatus', '#', 'admin', sysdate(), '', null, '');
|
|
||||||
insert into sys_menu values('1054', '任务导出', '110', '7', '#', '', '', 1, 0, 'F', '0', '0', 'monitor:job:export', '#', 'admin', sysdate(), '', null, '');
|
|
||||||
-- 代码生成按钮
|
-- 代码生成按钮
|
||||||
insert into sys_menu values('1055', '生成查询', '115', '1', '#', '', '', 1, 0, 'F', '0', '0', 'tool:gen:query', '#', 'admin', sysdate(), '', null, '');
|
insert into sys_menu values('1055', '生成查询', '115', '1', '#', '', '', 1, 0, 'F', '0', '0', 'tool:gen:query', '#', 'admin', sysdate(), '', null, '');
|
||||||
insert into sys_menu values('1056', '生成修改', '115', '2', '#', '', '', 1, 0, 'F', '0', '0', 'tool:gen:edit', '#', 'admin', sysdate(), '', null, '');
|
insert into sys_menu values('1056', '生成修改', '115', '2', '#', '', '', 1, 0, 'F', '0', '0', 'tool:gen:edit', '#', 'admin', sysdate(), '', null, '');
|
||||||
|
|
@ -556,50 +549,6 @@ create table sys_logininfor (
|
||||||
primary key (info_id)
|
primary key (info_id)
|
||||||
) engine=innodb auto_increment=100 comment = '系统访问记录';
|
) engine=innodb auto_increment=100 comment = '系统访问记录';
|
||||||
|
|
||||||
|
|
||||||
-- ----------------------------
|
|
||||||
-- 15、定时任务调度表
|
|
||||||
-- ----------------------------
|
|
||||||
drop table if exists sys_job;
|
|
||||||
create table sys_job (
|
|
||||||
job_id bigint(20) not null auto_increment comment '任务ID',
|
|
||||||
job_name varchar(64) default '' comment '任务名称',
|
|
||||||
job_group varchar(64) default 'DEFAULT' comment '任务组名',
|
|
||||||
invoke_target varchar(500) not null comment '调用目标字符串',
|
|
||||||
cron_expression varchar(255) default '' comment 'cron执行表达式',
|
|
||||||
misfire_policy varchar(20) default '3' comment '计划执行错误策略（1立即执行 2执行一次 3放弃执行）',
|
|
||||||
concurrent char(1) default '1' comment '是否并发执行（0允许 1禁止）',
|
|
||||||
status char(1) default '0' comment '状态（0正常 1暂停）',
|
|
||||||
create_by varchar(64) default '' comment '创建者',
|
|
||||||
create_time datetime comment '创建时间',
|
|
||||||
update_by varchar(64) default '' comment '更新者',
|
|
||||||
update_time datetime comment '更新时间',
|
|
||||||
remark varchar(500) default '' comment '备注信息',
|
|
||||||
primary key (job_id, job_name, job_group)
|
|
||||||
) engine=innodb auto_increment=100 comment = '定时任务调度表';
|
|
||||||
|
|
||||||
insert into sys_job values(1, '系统默认（无参）', 'DEFAULT', 'ryTask.ryNoParams', '0/10 * * * * ?', '3', '1', '1', 'admin', sysdate(), '', null, '');
|
|
||||||
insert into sys_job values(2, '系统默认（有参）', 'DEFAULT', 'ryTask.ryParams(\'ry\')', '0/15 * * * * ?', '3', '1', '1', 'admin', sysdate(), '', null, '');
|
|
||||||
insert into sys_job values(3, '系统默认（多参）', 'DEFAULT', 'ryTask.ryMultipleParams(\'ry\', true, 2000L, 316.50D, 100)', '0/20 * * * * ?', '3', '1', '1', 'admin', sysdate(), '', null, '');
|
|
||||||
|
|
||||||
|
|
||||||
-- ----------------------------
|
|
||||||
-- 16、定时任务调度日志表
|
|
||||||
-- ----------------------------
|
|
||||||
drop table if exists sys_job_log;
|
|
||||||
create table sys_job_log (
|
|
||||||
job_log_id bigint(20) not null auto_increment comment '任务日志ID',
|
|
||||||
job_name varchar(64) not null comment '任务名称',
|
|
||||||
job_group varchar(64) not null comment '任务组名',
|
|
||||||
invoke_target varchar(500) not null comment '调用目标字符串',
|
|
||||||
job_message varchar(500) comment '日志信息',
|
|
||||||
status char(1) default '0' comment '执行状态（0正常 1失败）',
|
|
||||||
exception_info varchar(2000) default '' comment '异常信息',
|
|
||||||
create_time datetime comment '创建时间',
|
|
||||||
primary key (job_log_id)
|
|
||||||
) engine=innodb comment = '定时任务调度日志表';
|
|
||||||
|
|
||||||
|
|
||||||
-- ----------------------------
|
-- ----------------------------
|
||||||
-- 17、通知公告表
|
-- 17、通知公告表
|
||||||
-- ----------------------------
|
-- ----------------------------
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue