From b1a7382e328760a3bfaa410def1008dcda237a35 Mon Sep 17 00:00:00 2001 From: chengkun <2500338766@qq.com> Date: Thu, 12 May 2022 18:21:24 +0800 Subject: [PATCH] =?UTF-8?q?feature1.0.0:=E7=A7=BB=E9=99=A4bnyer-job?= =?UTF-8?q?=EF=BC=8C=E6=B7=BB=E5=8A=A0xxl-job?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../bnyer/common/core/constant/Constants.java | 13 +- .../core/exception/job/TaskException.java | 34 --- .../src/main/resources/bootstrap-dev.yml | 2 +- bnyer-services/bnyer-img/pom.xml | 9 +- .../com/bnyer/img/config/XxlJobConfig.java | 56 ++++ .../java/com/bnyer/img/task/LikeSyncTask.java | 24 ++ bnyer-services/bnyer-job/pom.xml | 100 ------- .../com/bnyer/job/BnyerJobApplication.java | 31 --- .../com/bnyer/job/config/ScheduleConfig.java | 57 ---- .../job/controller/SysJobController.java | 186 ------------- .../job/controller/SysJobLogController.java | 92 ------- .../java/com/bnyer/job/domain/SysJob.java | 171 ------------ .../java/com/bnyer/job/domain/SysJobLog.java | 155 ----------- .../com/bnyer/job/mapper/SysJobLogMapper.java | 65 ----- .../com/bnyer/job/mapper/SysJobMapper.java | 67 ----- .../bnyer/job/service/ISysJobLogService.java | 57 ---- .../com/bnyer/job/service/ISysJobService.java | 102 ------- .../job/service/SysJobLogServiceImpl.java | 86 ------ .../bnyer/job/service/SysJobServiceImpl.java | 253 ------------------ .../main/java/com/bnyer/job/task/RyTask.java | 28 -- .../com/bnyer/job/util/AbstractQuartzJob.java | 106 -------- .../java/com/bnyer/job/util/CronUtils.java | 63 ----- .../com/bnyer/job/util/JobInvokeUtil.java | 182 ------------- .../QuartzDisallowConcurrentExecution.java | 21 -- .../bnyer/job/util/QuartzJobExecution.java | 19 -- .../com/bnyer/job/util/ScheduleUtils.java | 132 --------- .../src/main/resources/bootstrap-dev.yml | 22 -- .../src/main/resources/bootstrap-grey.yml | 22 -- .../src/main/resources/bootstrap-prod.yml | 22 -- .../src/main/resources/bootstrap-test.yml | 22 -- .../src/main/resources/bootstrap.yml | 15 -- .../com/bnyer/job/mapper/SysJobLogMapper.xml | 93 ------- .../com/bnyer/job/mapper/SysJobMapper.xml | 111 -------- .../bnyer-job/src/main/resources/logback.xml | 74 ----- bnyer-services/pom.xml | 1 - 35 files changed, 90 insertions(+), 2403 deletions(-) delete mode 100644 bnyer-common/bnyer-common-core/src/main/java/com/bnyer/common/core/exception/job/TaskException.java create mode 100644 bnyer-services/bnyer-img/src/main/java/com/bnyer/img/config/XxlJobConfig.java create mode 100644 bnyer-services/bnyer-img/src/main/java/com/bnyer/img/task/LikeSyncTask.java delete mode 100644 bnyer-services/bnyer-job/pom.xml delete mode 100644 bnyer-services/bnyer-job/src/main/java/com/bnyer/job/BnyerJobApplication.java delete mode 100644 bnyer-services/bnyer-job/src/main/java/com/bnyer/job/config/ScheduleConfig.java delete mode 100644 bnyer-services/bnyer-job/src/main/java/com/bnyer/job/controller/SysJobController.java delete mode 100644 bnyer-services/bnyer-job/src/main/java/com/bnyer/job/controller/SysJobLogController.java delete mode 100644 bnyer-services/bnyer-job/src/main/java/com/bnyer/job/domain/SysJob.java delete mode 100644 bnyer-services/bnyer-job/src/main/java/com/bnyer/job/domain/SysJobLog.java delete mode 100644 bnyer-services/bnyer-job/src/main/java/com/bnyer/job/mapper/SysJobLogMapper.java delete mode 100644 bnyer-services/bnyer-job/src/main/java/com/bnyer/job/mapper/SysJobMapper.java delete mode 100644 bnyer-services/bnyer-job/src/main/java/com/bnyer/job/service/ISysJobLogService.java delete mode 100644 bnyer-services/bnyer-job/src/main/java/com/bnyer/job/service/ISysJobService.java delete mode 100644 bnyer-services/bnyer-job/src/main/java/com/bnyer/job/service/SysJobLogServiceImpl.java delete mode 100644 bnyer-services/bnyer-job/src/main/java/com/bnyer/job/service/SysJobServiceImpl.java delete mode 100644 bnyer-services/bnyer-job/src/main/java/com/bnyer/job/task/RyTask.java delete mode 100644 bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/AbstractQuartzJob.java delete mode 100644 bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/CronUtils.java delete mode 100644 bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/JobInvokeUtil.java delete mode 100644 bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/QuartzDisallowConcurrentExecution.java delete mode 100644 bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/QuartzJobExecution.java delete mode 100644 bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/ScheduleUtils.java delete mode 100644 bnyer-services/bnyer-job/src/main/resources/bootstrap-dev.yml delete mode 100644 bnyer-services/bnyer-job/src/main/resources/bootstrap-grey.yml delete mode 100644 bnyer-services/bnyer-job/src/main/resources/bootstrap-prod.yml delete mode 100644 bnyer-services/bnyer-job/src/main/resources/bootstrap-test.yml delete mode 100644 bnyer-services/bnyer-job/src/main/resources/bootstrap.yml delete mode 100644 bnyer-services/bnyer-job/src/main/resources/com/bnyer/job/mapper/SysJobLogMapper.xml delete mode 100644 bnyer-services/bnyer-job/src/main/resources/com/bnyer/job/mapper/SysJobMapper.xml delete mode 100644 bnyer-services/bnyer-job/src/main/resources/logback.xml diff --git a/bnyer-common/bnyer-common-core/src/main/java/com/bnyer/common/core/constant/Constants.java b/bnyer-common/bnyer-common-core/src/main/java/com/bnyer/common/core/constant/Constants.java index f464197..939bd06 100644 --- a/bnyer-common/bnyer-common-core/src/main/java/com/bnyer/common/core/constant/Constants.java +++ b/bnyer-common/bnyer-common-core/src/main/java/com/bnyer/common/core/constant/Constants.java @@ -2,7 +2,7 @@ package com.bnyer.common.core.constant; /** * 通用常量信息 - * + * * @author ruoyi */ public class Constants @@ -127,15 +127,4 @@ public class Constants * 资源映射路径 前缀 */ public static final String RESOURCE_PREFIX = "/profile"; - - /** - * 定时任务白名单配置（仅允许访问的包名，如其他需要可以自行添加） - */ - public static final String[] JOB_WHITELIST_STR = { "com.bnyer" }; - - /** - * 定时任务违规的字符 - */ - public static final String[] JOB_ERROR_STR = { "java.net.URL", "javax.naming.InitialContext", "org.yaml.snakeyaml", - "org.springframework", "org.apache", "com.bnyer.common.core.utils.file" }; } diff --git a/bnyer-common/bnyer-common-core/src/main/java/com/bnyer/common/core/exception/job/TaskException.java b/bnyer-common/bnyer-common-core/src/main/java/com/bnyer/common/core/exception/job/TaskException.java deleted file mode 100644 index c0df1c6..0000000 --- a/bnyer-common/bnyer-common-core/src/main/java/com/bnyer/common/core/exception/job/TaskException.java +++ /dev/null @@ -1,34 +0,0 @@ -package com.bnyer.common.core.exception.job; - -/** - * 计划策略异常 - * - * @author ruoyi - */ -public class TaskException extends Exception -{ - private static final long serialVersionUID = 1L; - - private Code code; - - public TaskException(String msg, Code code) - { - this(msg, code, null); - } - - public TaskException(String msg, Code code, Exception nestedEx) - { - super(msg, nestedEx); - this.code = code; - } - - public Code getCode() - { - return code; - } - - public enum Code - { - TASK_EXISTS, NO_TASK_EXISTS, TASK_ALREADY_STARTED, UNKNOWN, CONFIG_ERROR, TASK_NODE_NOT_AVAILABLE - } -} \ No newline at end of file diff --git a/bnyer-gateway/src/main/resources/bootstrap-dev.yml b/bnyer-gateway/src/main/resources/bootstrap-dev.yml index 4d750b5..3ec8647 100644 --- a/bnyer-gateway/src/main/resources/bootstrap-dev.yml +++ b/bnyer-gateway/src/main/resources/bootstrap-dev.yml @@ -25,7 +25,7 @@ spring: eager: true transport: # 控制台地址 - dashboard: 127.0.0.1:7011 + dashboard: http://175.24.122.142:8858 # nacos配置持久化 datasource: ds1: diff --git a/bnyer-services/bnyer-img/pom.xml b/bnyer-services/bnyer-img/pom.xml index d37f875..47d63c9 100644 --- a/bnyer-services/bnyer-img/pom.xml +++ b/bnyer-services/bnyer-img/pom.xml @@ -88,6 +88,13 @@ com.baomidou mybatis-plus-boot-starter + + + + com.xuxueli + xxl-job-core + 2.1.2 + @@ -106,4 +113,4 @@ - \ No newline at end of file + diff --git a/bnyer-services/bnyer-img/src/main/java/com/bnyer/img/config/XxlJobConfig.java b/bnyer-services/bnyer-img/src/main/java/com/bnyer/img/config/XxlJobConfig.java new file mode 100644 index 0000000..a260ce3 --- /dev/null +++ b/bnyer-services/bnyer-img/src/main/java/com/bnyer/img/config/XxlJobConfig.java @@ -0,0 +1,56 @@ +package com.bnyer.img.config; + +import com.xxl.job.core.executor.impl.XxlJobSpringExecutor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.boot.context.properties.ConfigurationProperties; +import org.springframework.cloud.context.config.annotation.RefreshScope; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +/** + * @author chengkun + * @date 2022/5/12 17:18 + */ +@Configuration +@Slf4j +@RefreshScope +public class XxlJobConfig { + + @Value("${xxl-job.addresses}") + private String adminAddresses; + +// @Value("${xxl.job.executor.appname}") +// private String appName; +// +// @Value("${xxl.job.executor.ip}") +// private String ip; + + @Value("${xxl-job.port}") + private int port; + + @Value("${xxl-job.accessToken}") + private String accessToken; + + @Value("${xxl-job.logpath}") + private String logPath; + + //@Value("${xxl.job.executor.logretentiondays}") + //private int logRetentionDays; + + + @Bean(initMethod = "start", destroyMethod = "destroy") + public XxlJobSpringExecutor xxlJobExecutor() { + log.info(">>>>>>>>>>> xxl-job 配置初始化开始 <<<<<<<<<<<<."); + XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor(); + xxlJobSpringExecutor.setAdminAddresses(adminAddresses); + //xxlJobSpringExecutor.setAppName(appName); + //xxlJobSpringExecutor.setIp(ip); + xxlJobSpringExecutor.setPort(port); + xxlJobSpringExecutor.setAccessToken(accessToken); + xxlJobSpringExecutor.setLogPath(logPath); + //xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays); + log.info(">>>>>>>>>>> xxl-job 配置初始化结束 <<<<<<<<<<<<."); + return xxlJobSpringExecutor; + } +} diff --git a/bnyer-services/bnyer-img/src/main/java/com/bnyer/img/task/LikeSyncTask.java b/bnyer-services/bnyer-img/src/main/java/com/bnyer/img/task/LikeSyncTask.java new file mode 100644 index 0000000..ac36a57 --- /dev/null +++ b/bnyer-services/bnyer-img/src/main/java/com/bnyer/img/task/LikeSyncTask.java @@ -0,0 +1,24 @@ +package com.bnyer.img.task; + +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.handler.IJobHandler; +import com.xxl.job.core.handler.annotation.JobHandler; +import com.xxl.job.core.handler.annotation.XxlJob; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +/** + * @author chengkun + * @date 2022/5/12 18:13 + */ +@Component +@Slf4j +@JobHandler(value = "likeSyncTask") +public class LikeSyncTask extends IJobHandler { + + @Override + public ReturnT execute(String param) throws Exception { + System.out.println("123125123123123"); + return null; + } +} diff --git a/bnyer-services/bnyer-job/pom.xml b/bnyer-services/bnyer-job/pom.xml deleted file mode 100644 index 30c6c9a..0000000 --- a/bnyer-services/bnyer-job/pom.xml +++ /dev/null @@ -1,100 +0,0 @@ - - - - com.dimensionalnode - bnyer-services - 1.0.0 - - 4.0.0 - - bnyer-job - - - bnyer-job定时任务服务 - - - - - - - com.alibaba.cloud - spring-cloud-starter-alibaba-nacos-discovery - - - - - com.alibaba.cloud - spring-cloud-starter-alibaba-nacos-config - - - - - com.alibaba.cloud - spring-cloud-starter-alibaba-sentinel - - - - - org.springframework.boot - spring-boot-starter-actuator - - - - - io.springfox - springfox-swagger-ui - ${swagger.fox.version} - - - - - org.quartz-scheduler - quartz - - - com.mchange - c3p0 - - - - - - - mysql - mysql-connector-java - - - - - com.dimensionalnode - bnyer-common-log - - - - - com.dimensionalnode - bnyer-common-swagger - - - - - - ${project.artifactId} - - - org.springframework.boot - spring-boot-maven-plugin - - - - repackage - - - - - - - - \ No newline at end of file diff --git a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/BnyerJobApplication.java b/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/BnyerJobApplication.java deleted file mode 100644 index 0e1f11e..0000000 --- a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/BnyerJobApplication.java +++ /dev/null @@ -1,31 +0,0 @@ -package com.bnyer.job; - -import org.springframework.boot.SpringApplication; -import org.springframework.boot.autoconfigure.SpringBootApplication; -import com.bnyer.common.security.annotation.EnableCustomConfig; -import com.bnyer.common.security.annotation.EnableRyFeignClients; -import com.bnyer.common.swagger.annotation.EnableCustomSwagger2; - -/** - * 定时任务 - * - * @author ruoyi - */ -@EnableCustomConfig -@EnableCustomSwagger2 -@EnableRyFeignClients -@SpringBootApplication -public class BnyerJobApplication -{ - public static void main(String[] args) - { - SpringApplication.run(BnyerJobApplication.class, args); - System.out.println("(♥◠‿◠)ﾉﾞ bnyer认识任务服务启动成功 ლ(´ڡ`ლ)ﾞ \n" + - "__________ \n" + - "\\______ \\ ____ ___.__. ___________ \n" + - " | | _// < | |/ __ \\_ __ \\\n" + - " | | \\ | \\___ \\ ___/| | \\/\n" + - " |______ /___| / ____|\\___ >__| \n" + - " \\/ \\/\\/ \\/ \n"); - } -} diff --git a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/config/ScheduleConfig.java b/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/config/ScheduleConfig.java deleted file mode 100644 index 838a38d..0000000 --- a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/config/ScheduleConfig.java +++ /dev/null @@ -1,57 +0,0 @@ -package com.bnyer.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", "BnyerScheduler"); - 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.springframework.scheduling.quartz.LocalDataSourceJobStore"); - // 集群配置 - 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("BnyerScheduler"); - // 延时启动 - factory.setStartupDelay(1); - factory.setApplicationContextSchedulerContextKey("applicationContextKey"); - // 可选，QuartzScheduler - // 启动时更新己存在的Job，这样就不用每次修改targetObject后删除qrtz_job_details表对应记录了 - factory.setOverwriteExistingJobs(true); - // 设置自动启动，默认为true - factory.setAutoStartup(true); - - return factory; - } -} diff --git a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/controller/SysJobController.java b/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/controller/SysJobController.java deleted file mode 100644 index 4eb7e1e..0000000 --- a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/controller/SysJobController.java +++ /dev/null @@ -1,186 +0,0 @@ -package com.bnyer.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.bnyer.common.core.constant.Constants; -import com.bnyer.common.core.exception.job.TaskException; -import com.bnyer.common.core.utils.StringUtils; -import com.bnyer.common.core.utils.poi.ExcelUtil; -import com.bnyer.common.core.web.controller.BaseController; -import com.bnyer.common.core.web.domain.AjaxResult; -import com.bnyer.common.core.web.page.TableDataInfo; -import com.bnyer.common.log.annotation.Log; -import com.bnyer.common.log.enums.BusinessType; -import com.bnyer.common.security.annotation.RequiresPermissions; -import com.bnyer.common.security.utils.SecurityUtils; -import com.bnyer.job.domain.SysJob; -import com.bnyer.job.service.ISysJobService; -import com.bnyer.job.util.CronUtils; -import com.bnyer.job.util.ScheduleUtils; - -/** - * 调度任务信息操作处理 - * - * @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 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 list = jobService.selectJobList(sysJob); - ExcelUtil util = new ExcelUtil(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.containsAnyIgnoreCase(job.getInvokeTarget(), new String[] { Constants.LOOKUP_LDAP, Constants.LOOKUP_LDAPS })) - { - return error("新增任务'" + job.getJobName() + "'失败，目标字符串不允许'ldap(s)'调用"); - } - 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() + "'失败，目标字符串存在违规"); - } - else if (!ScheduleUtils.whiteList(job.getInvokeTarget())) - { - 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.containsAnyIgnoreCase(job.getInvokeTarget(), new String[] { Constants.LOOKUP_LDAP, Constants.LOOKUP_LDAPS })) - { - return error("修改任务'" + job.getJobName() + "'失败，目标字符串不允许'ldap(s)'调用"); - } - 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() + "'失败，目标字符串存在违规"); - } - else if (!ScheduleUtils.whiteList(job.getInvokeTarget())) - { - 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(); - } -} diff --git a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/controller/SysJobLogController.java b/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/controller/SysJobLogController.java deleted file mode 100644 index a2c4a2c..0000000 --- a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/controller/SysJobLogController.java +++ /dev/null @@ -1,92 +0,0 @@ -package com.bnyer.job.controller; - -import java.util.List; -import javax.servlet.http.HttpServletResponse; - -import com.bnyer.job.domain.SysJobLog; -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.bnyer.common.core.utils.poi.ExcelUtil; -import com.bnyer.common.core.web.controller.BaseController; -import com.bnyer.common.core.web.domain.AjaxResult; -import com.bnyer.common.core.web.page.TableDataInfo; -import com.bnyer.common.log.annotation.Log; -import com.bnyer.common.log.enums.BusinessType; -import com.bnyer.common.security.annotation.RequiresPermissions; -import com.bnyer.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 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 list = jobLogService.selectJobLogList(sysJobLog); - ExcelUtil util = new ExcelUtil(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(); - } -} diff --git a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/domain/SysJob.java b/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/domain/SysJob.java deleted file mode 100644 index 7cf3dbc..0000000 --- a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/domain/SysJob.java +++ /dev/null @@ -1,171 +0,0 @@ -package com.bnyer.job.domain; - -import java.util.Date; -import javax.validation.constraints.NotBlank; -import javax.validation.constraints.Size; -import org.apache.commons.lang3.builder.ToStringBuilder; -import org.apache.commons.lang3.builder.ToStringStyle; -import com.fasterxml.jackson.annotation.JsonFormat; -import com.bnyer.common.core.annotation.Excel; -import com.bnyer.common.core.annotation.Excel.ColumnType; -import com.bnyer.common.core.constant.ScheduleConstants; -import com.bnyer.common.core.utils.StringUtils; -import com.bnyer.common.core.web.domain.BaseEntity; -import com.bnyer.job.util.CronUtils; - -/** - * 定时任务调度表 sys_job - * - * @author ruoyi - */ -public class SysJob extends BaseEntity -{ - private static final long serialVersionUID = 1L; - - /** 任务ID */ - @Excel(name = "任务序号", cellType = ColumnType.NUMERIC) - private Long jobId; - - /** 任务名称 */ - @Excel(name = "任务名称") - private String jobName; - - /** 任务组名 */ - @Excel(name = "任务组名") - private String jobGroup; - - /** 调用目标字符串 */ - @Excel(name = "调用目标字符串") - private String invokeTarget; - - /** cron执行表达式 */ - @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; - - public Long getJobId() - { - return jobId; - } - - public void setJobId(Long jobId) - { - this.jobId = jobId; - } - - @NotBlank(message = "任务名称不能为空") - @Size(min = 0, max = 64, message = "任务名称不能超过64个字符") - public String getJobName() - { - return jobName; - } - - public void setJobName(String jobName) - { - this.jobName = jobName; - } - - public String getJobGroup() - { - return jobGroup; - } - - public void setJobGroup(String jobGroup) - { - this.jobGroup = jobGroup; - } - - @NotBlank(message = "调用目标字符串不能为空") - @Size(min = 0, max = 500, message = "调用目标字符串长度不能超过500个字符") - public String getInvokeTarget() - { - return invokeTarget; - } - - public void setInvokeTarget(String invokeTarget) - { - this.invokeTarget = invokeTarget; - } - - @NotBlank(message = "Cron执行表达式不能为空") - @Size(min = 0, max = 255, message = "Cron执行表达式不能超过255个字符") - public String getCronExpression() - { - return cronExpression; - } - - public void setCronExpression(String cronExpression) - { - this.cronExpression = cronExpression; - } - - @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") - public Date getNextValidTime() - { - if (StringUtils.isNotEmpty(cronExpression)) - { - return CronUtils.getNextExecution(cronExpression); - } - return null; - } - - public String getMisfirePolicy() - { - return misfirePolicy; - } - - public void setMisfirePolicy(String misfirePolicy) - { - this.misfirePolicy = misfirePolicy; - } - - public String getConcurrent() - { - return concurrent; - } - - public void setConcurrent(String concurrent) - { - this.concurrent = concurrent; - } - - public String getStatus() - { - return status; - } - - public void setStatus(String status) - { - this.status = status; - } - - @Override - public String toString() { - return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE) - .append("jobId", getJobId()) - .append("jobName", getJobName()) - .append("jobGroup", getJobGroup()) - .append("cronExpression", getCronExpression()) - .append("nextValidTime", getNextValidTime()) - .append("misfirePolicy", getMisfirePolicy()) - .append("concurrent", getConcurrent()) - .append("status", getStatus()) - .append("createBy", getCreateBy()) - .append("createTime", getCreateTime()) - .append("updateBy", getUpdateBy()) - .append("updateTime", getUpdateTime()) - .append("remark", getRemark()) - .toString(); - } -} \ No newline at end of file diff --git a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/domain/SysJobLog.java b/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/domain/SysJobLog.java deleted file mode 100644 index 7c181ea..0000000 --- a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/domain/SysJobLog.java +++ /dev/null @@ -1,155 +0,0 @@ -package com.bnyer.job.domain; - -import java.util.Date; -import org.apache.commons.lang3.builder.ToStringBuilder; -import org.apache.commons.lang3.builder.ToStringStyle; -import com.bnyer.common.core.annotation.Excel; -import com.bnyer.common.core.web.domain.BaseEntity; - -/** - * 定时任务调度日志表 sys_job_log - * - * @author ruoyi - */ -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; - - public Long getJobLogId() - { - return jobLogId; - } - - public void setJobLogId(Long jobLogId) - { - this.jobLogId = jobLogId; - } - - public String getJobName() - { - return jobName; - } - - public void setJobName(String jobName) - { - this.jobName = jobName; - } - - public String getJobGroup() - { - return jobGroup; - } - - public void setJobGroup(String jobGroup) - { - this.jobGroup = jobGroup; - } - - public String getInvokeTarget() - { - return invokeTarget; - } - - public void setInvokeTarget(String invokeTarget) - { - this.invokeTarget = invokeTarget; - } - - public String getJobMessage() - { - return jobMessage; - } - - public void setJobMessage(String jobMessage) - { - this.jobMessage = jobMessage; - } - - public String getStatus() - { - return status; - } - - public void setStatus(String status) - { - this.status = status; - } - - public String getExceptionInfo() - { - return exceptionInfo; - } - - public void setExceptionInfo(String exceptionInfo) - { - this.exceptionInfo = exceptionInfo; - } - - public Date getStartTime() - { - return startTime; - } - - public void setStartTime(Date startTime) - { - this.startTime = startTime; - } - - public Date getStopTime() - { - return stopTime; - } - - public void setStopTime(Date stopTime) - { - this.stopTime = stopTime; - } - - @Override - public String toString() { - return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE) - .append("jobLogId", getJobLogId()) - .append("jobName", getJobName()) - .append("jobGroup", getJobGroup()) - .append("jobMessage", getJobMessage()) - .append("status", getStatus()) - .append("exceptionInfo", getExceptionInfo()) - .append("startTime", getStartTime()) - .append("stopTime", getStopTime()) - .toString(); - } -} diff --git a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/mapper/SysJobLogMapper.java b/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/mapper/SysJobLogMapper.java deleted file mode 100644 index df22878..0000000 --- a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/mapper/SysJobLogMapper.java +++ /dev/null @@ -1,65 +0,0 @@ -package com.bnyer.job.mapper; - -import java.util.List; - -import com.bnyer.job.domain.SysJobLog; - -/** - * 调度任务日志信息 数据层 - * - * @author ruoyi - */ -public interface SysJobLogMapper -{ - /** - * 获取quartz调度器日志的计划任务 - * - * @param jobLog 调度日志信息 - * @return 调度任务日志集合 - */ - public List selectJobLogList(SysJobLog jobLog); - - /** - * 查询所有调度任务日志 - * - * @return 调度任务日志列表 - */ - public List 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(); -} diff --git a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/mapper/SysJobMapper.java b/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/mapper/SysJobMapper.java deleted file mode 100644 index 513807c..0000000 --- a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/mapper/SysJobMapper.java +++ /dev/null @@ -1,67 +0,0 @@ -package com.bnyer.job.mapper; - -import java.util.List; -import com.bnyer.job.domain.SysJob; - -/** - * 调度任务信息 数据层 - * - * @author ruoyi - */ -public interface SysJobMapper -{ - /** - * 查询调度任务日志集合 - * - * @param job 调度信息 - * @return 操作日志集合 - */ - public List selectJobList(SysJob job); - - /** - * 查询所有调度任务 - * - * @return 调度任务列表 - */ - public List 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); -} diff --git a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/service/ISysJobLogService.java b/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/service/ISysJobLogService.java deleted file mode 100644 index 0c3367b..0000000 --- a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/service/ISysJobLogService.java +++ /dev/null @@ -1,57 +0,0 @@ -package com.bnyer.job.service; - -import java.util.List; - -import com.bnyer.job.domain.SysJobLog; - -/** - * 定时任务调度日志信息信息 服务层 - * - * @author ruoyi - */ -public interface ISysJobLogService -{ - /** - * 获取quartz调度器日志的计划任务 - * - * @param jobLog 调度日志信息 - * @return 调度任务日志集合 - */ - public List 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(); -} diff --git a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/service/ISysJobService.java b/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/service/ISysJobService.java deleted file mode 100644 index b03aab7..0000000 --- a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/service/ISysJobService.java +++ /dev/null @@ -1,102 +0,0 @@ -package com.bnyer.job.service; - -import java.util.List; -import org.quartz.SchedulerException; -import com.bnyer.common.core.exception.job.TaskException; -import com.bnyer.job.domain.SysJob; - -/** - * 定时任务调度信息信息 服务层 - * - * @author ruoyi - */ -public interface ISysJobService -{ - /** - * 获取quartz调度器的计划任务 - * - * @param job 调度信息 - * @return 调度任务集合 - */ - public List 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); -} \ No newline at end of file diff --git a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/service/SysJobLogServiceImpl.java b/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/service/SysJobLogServiceImpl.java deleted file mode 100644 index d04308d..0000000 --- a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/service/SysJobLogServiceImpl.java +++ /dev/null @@ -1,86 +0,0 @@ -package com.bnyer.job.service; - -import java.util.List; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Service; -import com.bnyer.job.domain.SysJobLog; -import com.bnyer.job.mapper.SysJobLogMapper; - -/** - * 定时任务调度日志信息 服务层 - * - * @author ruoyi - */ -@Service -public class SysJobLogServiceImpl implements ISysJobLogService -{ - @Autowired - private SysJobLogMapper jobLogMapper; - - /** - * 获取quartz调度器日志的计划任务 - * - * @param jobLog 调度日志信息 - * @return 调度任务日志集合 - */ - @Override - public List 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(); - } -} diff --git a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/service/SysJobServiceImpl.java b/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/service/SysJobServiceImpl.java deleted file mode 100644 index e67d6b5..0000000 --- a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/service/SysJobServiceImpl.java +++ /dev/null @@ -1,253 +0,0 @@ -package com.bnyer.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.bnyer.common.core.constant.ScheduleConstants; -import com.bnyer.common.core.exception.job.TaskException; -import com.bnyer.job.domain.SysJob; -import com.bnyer.job.mapper.SysJobMapper; -import com.bnyer.job.util.CronUtils; -import com.bnyer.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 jobList = jobMapper.selectJobAll(); - for (SysJob job : jobList) - { - ScheduleUtils.createScheduleJob(scheduler, job); - } - } - - /** - * 获取quartz调度器的计划任务列表 - * - * @param job 调度信息 - * @return - */ - @Override - public List 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); - } -} \ No newline at end of file diff --git a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/task/RyTask.java b/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/task/RyTask.java deleted file mode 100644 index 938a646..0000000 --- a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/task/RyTask.java +++ /dev/null @@ -1,28 +0,0 @@ -package com.bnyer.job.task; - -import org.springframework.stereotype.Component; -import com.bnyer.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("执行无参方法"); - } -} diff --git a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/AbstractQuartzJob.java b/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/AbstractQuartzJob.java deleted file mode 100644 index 7381383..0000000 --- a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/AbstractQuartzJob.java +++ /dev/null @@ -1,106 +0,0 @@ -package com.bnyer.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.bnyer.common.core.constant.ScheduleConstants; -import com.bnyer.common.core.utils.ExceptionUtil; -import com.bnyer.common.core.utils.SpringUtils; -import com.bnyer.common.core.utils.StringUtils; -import com.bnyer.common.core.utils.bean.BeanUtils; -import com.bnyer.job.domain.SysJob; -import com.bnyer.job.domain.SysJobLog; -import com.bnyer.job.service.ISysJobLogService; - -/** - * 抽象quartz调用 - * - * @author ruoyi - */ -public abstract class AbstractQuartzJob implements Job -{ - private static final Logger log = LoggerFactory.getLogger(AbstractQuartzJob.class); - - /** - * 线程本地变量 - */ - private static ThreadLocal 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; -} diff --git a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/CronUtils.java b/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/CronUtils.java deleted file mode 100644 index 7c10ab2..0000000 --- a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/CronUtils.java +++ /dev/null @@ -1,63 +0,0 @@ -package com.bnyer.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()); - } - } -} diff --git a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/JobInvokeUtil.java b/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/JobInvokeUtil.java deleted file mode 100644 index 27a853e..0000000 --- a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/JobInvokeUtil.java +++ /dev/null @@ -1,182 +0,0 @@ -package com.bnyer.job.util; - -import java.lang.reflect.InvocationTargetException; -import java.lang.reflect.Method; -import java.util.LinkedList; -import java.util.List; -import com.bnyer.common.core.utils.SpringUtils; -import com.bnyer.common.core.utils.StringUtils; -import com.bnyer.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 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 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 getMethodParams(String invokeTarget) - { - String methodStr = StringUtils.substringBetween(invokeTarget, "(", ")"); - if (StringUtils.isEmpty(methodStr)) - { - return null; - } - String[] methodParams = methodStr.split(",(?=([^\"']*[\"'][^\"']*[\"'])*[^\"']*$)"); - List 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 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 methodParams) - { - Object[] classs = new Object[methodParams.size()]; - int index = 0; - for (Object[] os : methodParams) - { - classs[index] = (Object) os[0]; - index++; - } - return classs; - } -} diff --git a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/QuartzDisallowConcurrentExecution.java b/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/QuartzDisallowConcurrentExecution.java deleted file mode 100644 index 5b4ed75..0000000 --- a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/QuartzDisallowConcurrentExecution.java +++ /dev/null @@ -1,21 +0,0 @@ -package com.bnyer.job.util; - -import com.bnyer.job.domain.SysJob; -import org.quartz.DisallowConcurrentExecution; -import org.quartz.JobExecutionContext; - -/** - * 定时任务处理（禁止并发执行） - * - * @author ruoyi - * - */ -@DisallowConcurrentExecution -public class QuartzDisallowConcurrentExecution extends AbstractQuartzJob -{ - @Override - protected void doExecute(JobExecutionContext context, SysJob sysJob) throws Exception - { - JobInvokeUtil.invokeMethod(sysJob); - } -} diff --git a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/QuartzJobExecution.java b/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/QuartzJobExecution.java deleted file mode 100644 index 9744ac3..0000000 --- a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/QuartzJobExecution.java +++ /dev/null @@ -1,19 +0,0 @@ -package com.bnyer.job.util; - -import com.bnyer.job.domain.SysJob; -import org.quartz.JobExecutionContext; - -/** - * 定时任务处理（允许并发执行） - * - * @author ruoyi - * - */ -public class QuartzJobExecution extends AbstractQuartzJob -{ - @Override - protected void doExecute(JobExecutionContext context, SysJob sysJob) throws Exception - { - JobInvokeUtil.invokeMethod(sysJob); - } -} diff --git a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/ScheduleUtils.java b/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/ScheduleUtils.java deleted file mode 100644 index 7bfabbc..0000000 --- a/bnyer-services/bnyer-job/src/main/java/com/bnyer/job/util/ScheduleUtils.java +++ /dev/null @@ -1,132 +0,0 @@ -package com.bnyer.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.bnyer.common.core.constant.Constants; -import com.bnyer.common.core.constant.ScheduleConstants; -import com.bnyer.common.core.exception.job.TaskException; -import com.bnyer.common.core.exception.job.TaskException.Code; -import com.bnyer.common.core.utils.StringUtils; -import com.bnyer.job.domain.SysJob; - -/** - * 定时任务工具类 - * - * @author ruoyi - * - */ -public class ScheduleUtils -{ - /** - * 得到quartz任务类 - * - * @param sysJob 执行计划 - * @return 具体执行任务类 - */ - private static Class 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 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); - } - } - - /** - * 检查包名是否为白名单配置 - * - * @param invokeTarget 目标字符串 - * @return 结果 - */ - public static boolean whiteList(String invokeTarget) - { - String packageName = StringUtils.substringBefore(invokeTarget, "("); - int count = StringUtils.countMatches(packageName, "."); - if (count > 1) - { - return StringUtils.containsAnyIgnoreCase(invokeTarget, Constants.JOB_WHITELIST_STR); - } - return true; - } -} diff --git a/bnyer-services/bnyer-job/src/main/resources/bootstrap-dev.yml b/bnyer-services/bnyer-job/src/main/resources/bootstrap-dev.yml deleted file mode 100644 index 6d55152..0000000 --- a/bnyer-services/bnyer-job/src/main/resources/bootstrap-dev.yml +++ /dev/null @@ -1,22 +0,0 @@ -spring: - cloud: - nacos: - discovery: - # 服务注册地址 - server-addr: http://117.50.61.7:8848 - # 命名空间地址 - namespace: c4f53d8c-0a91-4249-a804-f16f543ec3b0 - # 命名空间分组 - group: dev - config: - # 配置中心地址 - server-addr: http://117.50.61.7:8848 - # 配置文件格式 - file-extension: yml - # 命名空间地址 - namespace: c4f53d8c-0a91-4249-a804-f16f543ec3b0 - # 命名空间分组 - group: dev - # 共享配置 - shared-configs: - - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} diff --git a/bnyer-services/bnyer-job/src/main/resources/bootstrap-grey.yml b/bnyer-services/bnyer-job/src/main/resources/bootstrap-grey.yml deleted file mode 100644 index e8342bf..0000000 --- a/bnyer-services/bnyer-job/src/main/resources/bootstrap-grey.yml +++ /dev/null @@ -1,22 +0,0 @@ -spring: - cloud: - nacos: - discovery: - # 服务注册地址 - server-addr: http://175.24.122.142:8848 - # 命名空间地址 - namespace: abfe8ee6-161b-4f8f-b61f-51663bbfa4f9 - # 命名空间分组 - group: grey - config: - # 配置中心地址 - server-addr: http://175.24.122.142:8848 - # 配置文件格式 - file-extension: yml - # 命名空间地址 - namespace: abfe8ee6-161b-4f8f-b61f-51663bbfa4f9 - # 命名空间分组 - group: grey - # 共享配置 - shared-configs: - - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} diff --git a/bnyer-services/bnyer-job/src/main/resources/bootstrap-prod.yml b/bnyer-services/bnyer-job/src/main/resources/bootstrap-prod.yml deleted file mode 100644 index d8c9f80..0000000 --- a/bnyer-services/bnyer-job/src/main/resources/bootstrap-prod.yml +++ /dev/null @@ -1,22 +0,0 @@ -spring: - cloud: - nacos: - discovery: - # 服务注册地址 - server-addr: http://175.24.122.142:8848 - # 命名空间地址 - namespace: 604df951-ada5-481f-a0be-9fd9b97a7f4d - # 命名空间分组 - group: prod - config: - # 配置中心地址 - server-addr: http://175.24.122.142:8848 - # 配置文件格式 - file-extension: yml - # 命名空间地址 - namespace: 604df951-ada5-481f-a0be-9fd9b97a7f4d - # 命名空间分组 - group: prod - # 共享配置 - shared-configs: - - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} diff --git a/bnyer-services/bnyer-job/src/main/resources/bootstrap-test.yml b/bnyer-services/bnyer-job/src/main/resources/bootstrap-test.yml deleted file mode 100644 index e3d566c..0000000 --- a/bnyer-services/bnyer-job/src/main/resources/bootstrap-test.yml +++ /dev/null @@ -1,22 +0,0 @@ -spring: - cloud: - nacos: - discovery: - # 服务注册地址 - server-addr: #http://117.50.61.7:8848 - # 命名空间地址 - namespace: #1bf94455-a046-41e3-b7e4-c12fd11c3690 - # 命名空间分组 - group: test - config: - # 配置中心地址 - server-addr: #http://117.50.61.7:8848 - # 配置文件格式 - file-extension: yml - # 命名空间地址 - namespace: #1bf94455-a046-41e3-b7e4-c12fd11c3690 - # 命名空间分组 - group: test - # 共享配置 - shared-configs: - - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} diff --git a/bnyer-services/bnyer-job/src/main/resources/bootstrap.yml b/bnyer-services/bnyer-job/src/main/resources/bootstrap.yml deleted file mode 100644 index 2a71d77..0000000 --- a/bnyer-services/bnyer-job/src/main/resources/bootstrap.yml +++ /dev/null @@ -1,15 +0,0 @@ -# Tomcat -server: - port: 8012 - -# Spring -spring: - main: - #解决循环依赖问题 - allow-circular-references: true - application: - # 应用名称 - name: bnyer-job - profiles: - # 环境配置 - active: dev diff --git a/bnyer-services/bnyer-job/src/main/resources/com/bnyer/job/mapper/SysJobLogMapper.xml b/bnyer-services/bnyer-job/src/main/resources/com/bnyer/job/mapper/SysJobLogMapper.xml deleted file mode 100644 index 8fbf386..0000000 --- a/bnyer-services/bnyer-job/src/main/resources/com/bnyer/job/mapper/SysJobLogMapper.xml +++ /dev/null @@ -1,93 +0,0 @@ - - - - - - - - - - - - - - - - - select job_log_id, job_name, job_group, invoke_target, job_message, status, exception_info, create_time - from sys_job_log - - - - - - - - - - delete from sys_job_log where job_log_id = #{jobLogId} - - - - delete from sys_job_log where job_log_id in - - #{jobLogId} - - - - - truncate table sys_job_log - - - - insert into sys_job_log( - job_log_id, - job_name, - job_group, - invoke_target, - job_message, - status, - exception_info, - create_time - )values( - #{jobLogId}, - #{jobName}, - #{jobGroup}, - #{invokeTarget}, - #{jobMessage}, - #{status}, - #{exceptionInfo}, - sysdate() - ) - - - \ No newline at end of file diff --git a/bnyer-services/bnyer-job/src/main/resources/com/bnyer/job/mapper/SysJobMapper.xml b/bnyer-services/bnyer-job/src/main/resources/com/bnyer/job/mapper/SysJobMapper.xml deleted file mode 100644 index 612a482..0000000 --- a/bnyer-services/bnyer-job/src/main/resources/com/bnyer/job/mapper/SysJobMapper.xml +++ /dev/null @@ -1,111 +0,0 @@ - - - - - - - - - - - - - - - - - - - - - - select job_id, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, status, create_by, create_time, remark - from sys_job - - - - - - - - - - delete from sys_job where job_id = #{jobId} - - - - delete from sys_job where job_id in - - #{jobId} - - - - - update sys_job - - job_name = #{jobName}, - job_group = #{jobGroup}, - invoke_target = #{invokeTarget}, - cron_expression = #{cronExpression}, - misfire_policy = #{misfirePolicy}, - concurrent = #{concurrent}, - status = #{status}, - remark = #{remark}, - update_by = #{updateBy}, - update_time = sysdate() - - where job_id = #{jobId} - - - - insert into sys_job( - job_id, - job_name, - job_group, - invoke_target, - cron_expression, - misfire_policy, - concurrent, - status, - remark, - create_by, - create_time - )values( - #{jobId}, - #{jobName}, - #{jobGroup}, - #{invokeTarget}, - #{cronExpression}, - #{misfirePolicy}, - #{concurrent}, - #{status}, - #{remark}, - #{createBy}, - sysdate() - ) - - - \ No newline at end of file diff --git a/bnyer-services/bnyer-job/src/main/resources/logback.xml b/bnyer-services/bnyer-job/src/main/resources/logback.xml deleted file mode 100644 index 93fee1e..0000000 --- a/bnyer-services/bnyer-job/src/main/resources/logback.xml +++ /dev/null @@ -1,74 +0,0 @@ - - - - - - - - - - - ${log.pattern} - - - - - - ${log.path}/info.log - - - - ${log.path}/info.%d{yyyy-MM-dd}.log - - 20 - - - ${log.pattern} - - - - INFO - - ACCEPT - - DENY - - - - - ${log.path}/error.log - - - - ${log.path}/error.%d{yyyy-MM-dd}.log - - 20 - - - ${log.pattern} - - - - ERROR - - ACCEPT - - DENY - - - - - - - - - - - - - - - - - - \ No newline at end of file diff --git a/bnyer-services/pom.xml b/bnyer-services/pom.xml index 0c4673f..f2251b4 100644 --- a/bnyer-services/pom.xml +++ b/bnyer-services/pom.xml @@ -10,7 +10,6 @@ bnyer-system - bnyer-job bnyer-file bnyer-img