Skip to content

C
cloud-job
Commit 34b2545c by lilingye
Options

init

parent 617cc397
Showing with 180 additions and 179 deletions
cloud-job-api/pom.xml
...@@ -4,12 +4,12 @@ ...@@ -4,12 +4,12 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent> <parent>
<artifactId>cloud-job</artifactId> <artifactId>cloud-job</artifactId>
<groupId>com.fulan.job</groupId> <groupId>com.yizhi.job</groupId>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
</parent> </parent>
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<groupId>com.fulan.job</groupId> <groupId>com.yizhi.job</groupId>
<artifactId>cloud-job-api</artifactId> <artifactId>cloud-job-api</artifactId>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
......
cloud-job-api/src/main/java/com/fulan/application/job/domain/VmyJob.java
package com.fulan.application.job.domain; package com.yizhi.application.job.domain;
import lombok.Data; import lombok.Data;
/** /**
......
cloud-job-api/src/main/java/com/fulan/application/job/remote/JobClient.java
package com.fulan.application.job.remote; package com.yizhi.application.job.remote;
import com.fulan.application.job.domain.VmyJob; import com.yizhi.application.job.domain.VmyJob;
import org.springframework.cloud.openfeign.FeignClient; import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
......
cloud-job-service/pom.xml
...@@ -4,12 +4,12 @@ ...@@ -4,12 +4,12 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent> <parent>
<artifactId>cloud-job</artifactId> <artifactId>cloud-job</artifactId>
<groupId>com.fulan.job</groupId> <groupId>com.yizhi.job</groupId>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
</parent> </parent>
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<groupId>com.fulan.job</groupId> <groupId>com.yizhi.job</groupId>
<artifactId>cloud-job-service</artifactId> <artifactId>cloud-job-service</artifactId>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
...@@ -17,7 +17,7 @@ ...@@ -17,7 +17,7 @@
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>com.fulan</groupId> <groupId>com.yizhi</groupId>
<artifactId>cloud-common-service</artifactId> <artifactId>cloud-common-service</artifactId>
</dependency> </dependency>
...@@ -35,100 +35,100 @@ ...@@ -35,100 +35,100 @@
<dependency> <dependency>
<groupId>com.fulan.job</groupId> <groupId>com.yizhi.job</groupId>
<artifactId>cloud-job-api</artifactId> <artifactId>cloud-job-api</artifactId>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.fulan.site</groupId> <groupId>com.yizhi</groupId>
<artifactId>cloud-site-api</artifactId> <artifactId>cloud-site-api</artifactId>
</dependency> </dependency>
<!-- 专辑api 依赖 --> <!-- 专辑api 依赖 -->
<dependency> <dependency>
<groupId>com.fulan.album</groupId> <groupId>com.yizhi</groupId>
<artifactId>cloud-album-api</artifactId> <artifactId>cloud-album-api</artifactId>
</dependency> </dependency>
<!-- 本地依赖 --> <!-- 本地依赖 -->
<!-- 课程api 依赖 --> <!-- 课程api 依赖 -->
<dependency> <dependency>
<groupId>com.fulan.course</groupId> <groupId>com.yizhi</groupId>
<artifactId>cloud-course-api</artifactId> <artifactId>cloud-course-api</artifactId>
</dependency> </dependency>
<!-- 报表 --> <!-- 报表 -->
<dependency> <dependency>
<groupId>com.fulan.statistics</groupId> <groupId>com.yizhi</groupId>
<artifactId>cloud-statistics-api</artifactId> <artifactId>cloud-statistics-api</artifactId>
</dependency> </dependency>
<!-- 培训项目api 依赖 --> <!-- 培训项目api 依赖 -->
<dependency> <dependency>
<groupId>com.fulan</groupId> <groupId>com.yizhi</groupId>
<artifactId>cloud-training-project-api</artifactId> <artifactId>cloud-training-project-api</artifactId>
</dependency> </dependency>
<!-- 签到api 依赖 --> <!-- 签到api 依赖 -->
<dependency> <dependency>
<groupId>com.fulan.sign</groupId> <groupId>com.yizhi</groupId>
<artifactId>cloud-sign-api</artifactId> <artifactId>cloud-sign-api</artifactId>
</dependency> </dependency>
<!-- 学习日志api 依赖 --> <!-- 学习日志api 依赖 -->
<dependency> <dependency>
<groupId>com.fulan.studyLog</groupId> <groupId>com.yizhi</groupId>
<artifactId>cloud-course-studyLog-api</artifactId> <artifactId>cloud-course-studyLog-api</artifactId>
</dependency> </dependency>
<!-- 积分api 依赖 --> <!-- 积分api 依赖 -->
<dependency> <dependency>
<groupId>com.fulan.point</groupId> <groupId>com.yizhi</groupId>
<artifactId>cloud-point-api</artifactId> <artifactId>cloud-point-api</artifactId>
</dependency> </dependency>
<!-- 考试api 依赖 --> <!-- 考试api 依赖 -->
<dependency> <dependency>
<groupId>com.fulan</groupId> <groupId>com.yizhi</groupId>
<artifactId>cloud-exam-api</artifactId> <artifactId>cloud-exam-api</artifactId>
</dependency> </dependency>
<!-- 调研api 依赖 --> <!-- 调研api 依赖 -->
<dependency> <dependency>
<groupId>com.fulan.research</groupId> <groupId>com.yizhi</groupId>
<artifactId>cloud-research-api</artifactId> <artifactId>cloud-research-api</artifactId>
</dependency> </dependency>
<!--微信服务依赖--> <!--微信服务依赖-->
<dependency> <dependency>
<groupId>com.fulan</groupId> <groupId>com.yizhi</groupId>
<artifactId>cloud-wechat-api</artifactId> <artifactId>cloud-wechat-api</artifactId>
</dependency> </dependency>
<!-- 案例api 依赖 --> <!-- 案例api 依赖 -->
<dependency> <dependency>
<groupId>com.fulan.caselibrary</groupId> <groupId>com.yizhi</groupId>
<artifactId>library-api</artifactId> <artifactId>library-api</artifactId>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.fulan</groupId> <groupId>com.yizhi</groupId>
<artifactId>cloud-system-api</artifactId> <artifactId>cloud-system-api</artifactId>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.fulan</groupId> <groupId>com.yizhi</groupId>
<artifactId>cloud-newMessage-api</artifactId> <artifactId>cloud-newMessage-api</artifactId>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.fulan</groupId> <groupId>com.yizhi</groupId>
<artifactId>cloud-aliyun-api</artifactId> <artifactId>cloud-aliyun-api</artifactId>
</dependency> </dependency>
<dependency> <!-- <dependency>-->
<groupId>com.fulan</groupId> <!-- <groupId>com.yizhi</groupId>-->
<artifactId>cloud-suyinbean-api</artifactId> <!-- <artifactId>cloud-suyinbean-api</artifactId>-->
<version>1.0-SNAPSHOT</version> <!-- <version>1.0-SNAPSHOT</version>-->
</dependency> <!-- </dependency>-->
<dependency> <dependency>
<groupId>org.apache.axis</groupId> <groupId>org.apache.axis</groupId>
<artifactId>axis</artifactId> <artifactId>axis</artifactId>
......
cloud-job-service/src/main/java/com/fulan/application/JobApplication.java
package com.fulan.application; package com.yizhi.application;
import org.springframework.boot.SpringApplication; import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.SpringBootApplication;
...@@ -7,7 +7,7 @@ import org.springframework.cloud.openfeign.EnableFeignClients; ...@@ -7,7 +7,7 @@ import org.springframework.cloud.openfeign.EnableFeignClients;
@SpringBootApplication @SpringBootApplication
@EnableDiscoveryClient @EnableDiscoveryClient
@EnableFeignClients(basePackages = {"com.fulan"}) @EnableFeignClients(basePackages = {"com.yizhi"})
public class JobApplication { public class JobApplication {
public static void main(String[] args) { public static void main(String[] args) {
......
cloud-job-service/src/main/java/com/fulan/application/config/SwaggerConfig.java
package com.fulan.application.config; package com.yizhi.application.config;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
...@@ -39,7 +39,7 @@ public class SwaggerConfig extends WebMvcConfigurerAdapter{ ...@@ -39,7 +39,7 @@ public class SwaggerConfig extends WebMvcConfigurerAdapter{
public Docket createRestApi() { public Docket createRestApi() {
return new Docket(DocumentationType.SWAGGER_2) return new Docket(DocumentationType.SWAGGER_2)
.select() .select()
.apis(RequestHandlerSelectors.basePackage("com.fulan.application")) .apis(RequestHandlerSelectors.basePackage("com.yizhi.application"))
.build() .build()
.genericModelSubstitutes(DeferredResult.class) .genericModelSubstitutes(DeferredResult.class)
.genericModelSubstitutes(ResponseEntity.class) .genericModelSubstitutes(ResponseEntity.class)
......
cloud-job-service/src/main/java/com/fulan/application/config/WebConfig.java
package com.fulan.application.config; package com.yizhi.application.config;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
import org.springframework.util.ResourceUtils; import org.springframework.util.ResourceUtils;
......
cloud-job-service/src/main/java/com/fulan/application/constant/JobError.java
/** /**
* *
*/ */
package com.fulan.application.constant; package com.yizhi.application.constant;
/** /**
* 任务有关错误 * 任务有关错误
......
cloud-job-service/src/main/java/com/fulan/application/controller/AdminController.java
package com.fulan.application.controller; package com.yizhi.application.controller;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
......
cloud-job-service/src/main/java/com/fulan/application/controller/QuartzController.java
package com.fulan.application.controller; package com.yizhi.application.controller;
import static org.quartz.CronScheduleBuilder.cronSchedule; import static org.quartz.CronScheduleBuilder.cronSchedule;
...@@ -39,12 +39,12 @@ import org.springframework.web.bind.annotation.RequestParam; ...@@ -39,12 +39,12 @@ import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.fulan.application.constant.JobError; import com.yizhi.application.constant.JobError;
import com.fulan.application.handle.quartz.QuartzConfigration; import com.yizhi.application.handle.quartz.QuartzConfigration;
import com.fulan.application.util.constant.ReturnCode; import com.yizhi.application.util.constant.ReturnCode;
import com.fulan.application.util.date.DateUtil; import com.yizhi.application.util.date.DateUtil;
import com.fulan.application.util.domain.Response; import com.yizhi.application.util.domain.Response;
import com.fulan.application.util.str.StringUtil; import com.yizhi.application.util.str.StringUtil;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam; import io.swagger.annotations.ApiParam;
......
cloud-job-service/src/main/java/com/fulan/application/controller/ScheduleController.java
package com.fulan.application.controller; package com.yizhi.application.controller;
import static org.quartz.CronScheduleBuilder.cronSchedule; import static org.quartz.CronScheduleBuilder.cronSchedule;
import static org.quartz.JobBuilder.newJob; import static org.quartz.JobBuilder.newJob;
...@@ -43,9 +43,9 @@ import org.springframework.web.bind.annotation.RequestMapping; ...@@ -43,9 +43,9 @@ import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.servlet.ModelAndView; import org.springframework.web.servlet.ModelAndView;
import com.fulan.application.handle.quartz.QuartzConfigration; import com.yizhi.application.handle.quartz.QuartzConfigration;
import com.fulan.application.util.date.DateUtil; import com.yizhi.application.util.date.DateUtil;
import com.fulan.application.util.str.StringUtil; import com.yizhi.application.util.str.StringUtil;
/** /**
* schedeule任务类 * schedeule任务类
......
cloud-job-service/src/main/java/com/fulan/application/controller/remote/RemoteQuartzController.java
package com.fulan.application.controller.remote; package com.yizhi.application.controller.remote;
import static org.quartz.CronScheduleBuilder.cronSchedule; import static org.quartz.CronScheduleBuilder.cronSchedule;
...@@ -25,12 +25,12 @@ import org.springframework.web.bind.annotation.RequestMapping; ...@@ -25,12 +25,12 @@ import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import com.fulan.application.constant.JobError; import com.yizhi.application.constant.JobError;
import com.fulan.application.exception.BizException; import com.yizhi.application.exception.BizException;
import com.fulan.application.handle.quartz.QuartzConfigration; import com.yizhi.application.handle.quartz.QuartzConfigration;
import com.fulan.application.job.domain.VmyJob; import com.yizhi.application.job.domain.VmyJob;
import com.fulan.application.util.constant.ReturnCode; import com.yizhi.application.util.constant.ReturnCode;
import com.fulan.application.util.domain.Response; import com.yizhi.application.util.domain.Response;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam; import io.swagger.annotations.ApiParam;
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/BaseJob.java
package com.fulan.application.handle.quartz; package com.yizhi.application.handle.quartz;
import org.quartz.Job; import org.quartz.Job;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/MyJobFactory.java
...@@ -7,7 +7,7 @@ ...@@ -7,7 +7,7 @@
* <author> <time> <version> <desc> * <author> <time> <version> <desc>
* 作者姓名 修改时间 版本号 描述 * 作者姓名 修改时间 版本号 描述
*/ */
package com.fulan.application.handle.quartz; package com.yizhi.application.handle.quartz;
import org.quartz.spi.TriggerFiredBundle; import org.quartz.spi.TriggerFiredBundle;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/QuartzConfigration.java
package com.fulan.application.handle.quartz; package com.yizhi.application.handle.quartz;
import java.io.IOException; import java.io.IOException;
import java.util.ArrayList; import java.util.ArrayList;
...@@ -21,7 +21,7 @@ import org.springframework.core.io.ClassPathResource; ...@@ -21,7 +21,7 @@ import org.springframework.core.io.ClassPathResource;
import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.quartz.SchedulerFactoryBean; import org.springframework.scheduling.quartz.SchedulerFactoryBean;
import com.fulan.application.util.file.FileUtils; import com.yizhi.application.util.file.FileUtils;
/** /**
* Quartz配置类 * Quartz配置类
...@@ -32,7 +32,7 @@ public class QuartzConfigration { ...@@ -32,7 +32,7 @@ public class QuartzConfigration {
private static Logger logger = LoggerFactory.getLogger(QuartzConfigration.class); private static Logger logger = LoggerFactory.getLogger(QuartzConfigration.class);
public static final String PACKAGE_BASE = "com.fulan.application.handle.quartz.job"; public static final String PACKAGE_BASE = "com.yizhi.application.handle.quartz.job";
// public static final String JOB_GROUP = "group"; // public static final String JOB_GROUP = "group";
// public static final String TIGGERNAME = "tigger"; // public static final String TIGGERNAME = "tigger";
private Map<String, List<String>> jobClassesMap = new HashMap<String, List<String>>(); private Map<String, List<String>> jobClassesMap = new HashMap<String, List<String>>();
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/AddMediaTranscodeJob.java
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import com.fulan.application.feign.AliyunClient; import com.yizhi.application.feign.AliyunClient;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
import lombok.extern.log4j.Log4j2; import lombok.extern.log4j.Log4j2;
import org.quartz.InterruptableJob; import org.quartz.InterruptableJob;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/AlbumUnLockJob.java
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.Date; import java.util.Date;
...@@ -11,8 +11,8 @@ import org.slf4j.Logger; ...@@ -11,8 +11,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import com.fulan.application.feign.AlbumJobHandleClient; import com.yizhi.application.feign.AlbumJobHandleClient;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
public class AlbumUnLockJob implements BaseJob, InterruptableJob { public class AlbumUnLockJob implements BaseJob, InterruptableJob {
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/BannerUpJob.java
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import com.fulan.application.feign.BannerManageFeignClients; import com.yizhi.application.feign.BannerManageFeignClients;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
import org.quartz.InterruptableJob; import org.quartz.InterruptableJob;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException; import org.quartz.JobExecutionException;
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/CourseIntoTableJob.java
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import org.quartz.InterruptableJob; import org.quartz.InterruptableJob;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
...@@ -8,10 +8,10 @@ import org.slf4j.Logger; ...@@ -8,10 +8,10 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import com.fulan.api.feign.StatisticStudentCaseClient; import com.yizhi.api.feign.StatisticStudentCaseClient;
import com.fulan.application.feign.CourseReportClient; import com.yizhi.application.feign.CourseReportClient;
import com.fulan.application.feign.StatisticsCourseClient; import com.yizhi.application.feign.StatisticsCourseClient;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
public class CourseIntoTableJob implements BaseJob, InterruptableJob { public class CourseIntoTableJob implements BaseJob, InterruptableJob {
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/CourseInvalidJob.java
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import com.fulan.application.feign.CourseClient; import com.yizhi.application.feign.CourseClient;
import com.fulan.application.feign.InformationManageFeignClients; import com.yizhi.application.feign.InformationManageFeignClients;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
import org.quartz.InterruptableJob; import org.quartz.InterruptableJob;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException; import org.quartz.JobExecutionException;
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/CourseStudyHourRankingJob.java
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import com.fulan.application.feign.CourseStudyHourRankingClient; import com.yizhi.application.feign.CourseStudyHourRankingClient;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
import com.fulan.application.system.remote.SiteClient; import com.yizhi.application.system.remote.SiteClient;
import org.quartz.InterruptableJob; import org.quartz.InterruptableJob;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException; import org.quartz.JobExecutionException;
...@@ -35,7 +35,7 @@ public class CourseStudyHourRankingJob implements BaseJob, InterruptableJob { ...@@ -35,7 +35,7 @@ public class CourseStudyHourRankingJob implements BaseJob, InterruptableJob {
// 1 在QRTZ_JOB_DETAILS 配置 job执行的处理类，实现 implements BaseJob, InterruptableJob // 1 在QRTZ_JOB_DETAILS 配置 job执行的处理类，实现 implements BaseJob, InterruptableJob
//SCHED_NAME JOB_NAME JOB_GROUP DESCRIPTION JOB_CLASS_NAME IS_DURABLE IS_NONCONCURRENT IS_UPDATE_DATA REQUESTS_RECOVERY //SCHED_NAME JOB_NAME JOB_GROUP DESCRIPTION JOB_CLASS_NAME IS_DURABLE IS_NONCONCURRENT IS_UPDATE_DATA REQUESTS_RECOVERY
//scheduler studyHourRanking course 课程学习时间排名 Job定义 com.fulan.application.handle.quartz.job.CourseStudyHourRankingJob 0 0 0 0 //scheduler studyHourRanking course 课程学习时间排名 Job定义 com.yizhi.application.handle.quartz.job.CourseStudyHourRankingJob 0 0 0 0
// 2 在QRTZ_TRIGGERS（存储已配置的 Trigger 的信息）表添加触发时间点（每次执行完批处理后，根据QRTZ_CRON_TRIGGERS表配置的cron表达式生成新的下一个执行时间） // 2 在QRTZ_TRIGGERS（存储已配置的 Trigger 的信息）表添加触发时间点（每次执行完批处理后，根据QRTZ_CRON_TRIGGERS表配置的cron表达式生成新的下一个执行时间）
// NEXT_FIRE_TIME（下次执行时间戳例如1566282600000）和NEXT_FIRE_TIME设置为0；为0表示初始化，这些字段在下个job启动完会更新 // NEXT_FIRE_TIME（下次执行时间戳例如1566282600000）和NEXT_FIRE_TIME设置为0；为0表示初始化，这些字段在下个job启动完会更新
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/DashboardJob.java
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
import com.fulan.application.feign.RemoteDaIndicatorCourseClient; import com.yizhi.application.feign.RemoteDaIndicatorCourseClient;
import com.fulan.application.feign.RemoteDaIndicatorTpClient; import com.yizhi.application.feign.RemoteDaIndicatorTpClient;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
import com.fulan.application.system.remote.RemoteDaIndicatorSystemClient; import com.yizhi.application.system.remote.RemoteDaIndicatorSystemClient;
import com.fulan.application.system.remote.SiteClient; import com.yizhi.application.system.remote.SiteClient;
import com.fulan.application.vo.RemoteDaIndicatorVo; import com.yizhi.application.vo.RemoteDaIndicatorVo;
import org.apache.commons.collections.CollectionUtils; import org.apache.commons.collections.CollectionUtils;
import org.quartz.InterruptableJob; import org.quartz.InterruptableJob;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/DataInputJob.java
//package com.fulan.application.handle.quartz.job; //package com.yizhi.application.handle.quartz.job;
// //
//import org.quartz.InterruptableJob; //import org.quartz.InterruptableJob;
//import org.quartz.JobExecutionContext; //import org.quartz.JobExecutionContext;
...@@ -8,8 +8,8 @@ ...@@ -8,8 +8,8 @@
//import org.slf4j.Logger; //import org.slf4j.Logger;
//import org.slf4j.LoggerFactory; //import org.slf4j.LoggerFactory;
// //
//import com.fulan.application.handle.quartz.BaseJob; //import com.yizhi.application.handle.quartz.BaseJob;
//import com.fulan.application.util.spring.JobUtil; //import com.yizhi.application.util.spring.JobUtil;
// //
///** ///**
// * 数据下发任务 // * 数据下发任务
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/ExamInToTableJob.java
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import org.quartz.InterruptableJob; import org.quartz.InterruptableJob;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
...@@ -7,8 +7,8 @@ import org.quartz.UnableToInterruptJobException; ...@@ -7,8 +7,8 @@ import org.quartz.UnableToInterruptJobException;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import com.fulan.api.feign.StatisticsExamMetadataClient; import com.yizhi.api.feign.StatisticsExamMetadataClient;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
public class ExamInToTableJob implements BaseJob, InterruptableJob { public class ExamInToTableJob implements BaseJob, InterruptableJob {
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/ExamJob.java
...@@ -7,7 +7,7 @@ ...@@ -7,7 +7,7 @@
* <author> <time> <version> <desc> * <author> <time> <version> <desc>
* 作者姓名 修改时间 版本号 描述 * 作者姓名 修改时间 版本号 描述
*/ */
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import org.quartz.InterruptableJob; import org.quartz.InterruptableJob;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
...@@ -17,9 +17,9 @@ import org.slf4j.Logger; ...@@ -17,9 +17,9 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import com.fulan.api.feign.ExamQuestionApiClient; import com.yizhi.api.feign.ExamQuestionApiClient;
import com.fulan.api.vo.exam.ExamAnswerVO; import com.yizhi.api.vo.exam.ExamAnswerVO;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
/** /**
* 定时检查是否有过期的考试，有的话自动提交考试信息 * 定时检查是否有过期的考试，有的话自动提交考试信息
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/HttpSetjob.java
...@@ -7,19 +7,19 @@ ...@@ -7,19 +7,19 @@
* <author> <time> <version> <desc> * <author> <time> <version> <desc>
* 作者姓名 修改时间 版本号 描述 * 作者姓名 修改时间 版本号 描述
*/ */
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.fulan.application.cache.RedisCache; import com.yizhi.application.cache.RedisCache;
import com.fulan.application.cache.distributedlock.impl.RedisDistributedLock; import com.yizhi.application.cache.distributedlock.impl.RedisDistributedLock;
import com.fulan.application.domain.*; import com.yizhi.application.domain.*;
import com.fulan.application.feign.CourseClient; import com.yizhi.application.feign.CourseClient;
import com.fulan.application.feign.CourseStudyClient; import com.yizhi.application.feign.CourseStudyClient;
import com.fulan.application.feign.RecordeClient; import com.yizhi.application.feign.RecordeClient;
import com.fulan.application.feign.StudyLogClient; import com.yizhi.application.feign.StudyLogClient;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
import com.fulan.application.util.date.DateUtil; import com.yizhi.application.util.date.DateUtil;
import com.fulan.application.vo.HeartBeatVo; import com.yizhi.application.vo.HeartBeatVo;
import org.apache.commons.collections.CollectionUtils; import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.quartz.InterruptableJob; import org.quartz.InterruptableJob;
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/HttpSetjobBack.java
...@@ -7,20 +7,20 @@ ...@@ -7,20 +7,20 @@
* <author> <time> <version> <desc> * <author> <time> <version> <desc>
* 作者姓名 修改时间 版本号 描述 * 作者姓名 修改时间 版本号 描述
*/ */
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.fulan.application.cache.RedisCache; import com.yizhi.application.cache.RedisCache;
import com.fulan.application.domain.*; import com.yizhi.application.domain.*;
import com.fulan.application.event.EventWrapper; import com.yizhi.application.event.EventWrapper;
import com.fulan.application.feign.*; import com.yizhi.application.feign.*;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
import com.fulan.application.publish.CloudEventPublisher; import com.yizhi.application.publish.CloudEventPublisher;
import com.fulan.application.task.TaskExecutor; import com.yizhi.application.task.TaskExecutor;
import com.fulan.application.util.constant.QueueConstant; import com.yizhi.application.util.constant.QueueConstant;
import com.fulan.application.util.event.TrainingProjectEvent; import com.yizhi.application.util.event.TrainingProjectEvent;
import com.fulan.application.vo.PointParamVO; import com.yizhi.application.vo.PointParamVO;
import com.fulan.application.vo.RecordeDurationVO; import com.yizhi.application.vo.RecordeDurationVO;
import org.apache.commons.lang3.time.DateUtils; import org.apache.commons.lang3.time.DateUtils;
import org.quartz.InterruptableJob; import org.quartz.InterruptableJob;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/InformationUpJob.java
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import com.fulan.application.feign.InformationManageFeignClients; import com.yizhi.application.feign.InformationManageFeignClients;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
import org.quartz.InterruptableJob; import org.quartz.InterruptableJob;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException; import org.quartz.JobExecutionException;
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/OrganizationJob.java
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
import com.fulan.application.system.remote.OrganizationClient; import com.yizhi.application.system.remote.OrganizationClient;
import org.quartz.InterruptableJob; import org.quartz.InterruptableJob;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException; import org.quartz.JobExecutionException;
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/OrganizationRedisJob.java
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import com.fulan.application.cache.CacheNamespace; import com.yizhi.application.cache.CacheNamespace;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
import com.fulan.application.system.remote.OrganizationClient; import com.yizhi.application.system.remote.OrganizationClient;
import lombok.extern.log4j.Log4j2; import lombok.extern.log4j.Log4j2;
import org.apache.commons.collections.CollectionUtils; import org.apache.commons.collections.CollectionUtils;
import org.quartz.InterruptableJob; import org.quartz.InterruptableJob;
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/ResearchIntoTable.java
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import org.quartz.InterruptableJob; import org.quartz.InterruptableJob;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
...@@ -8,8 +8,8 @@ import org.slf4j.Logger; ...@@ -8,8 +8,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import com.fulan.application.feign.ResearchReportClient; import com.yizhi.application.feign.ResearchReportClient;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
public class ResearchIntoTable implements BaseJob, InterruptableJob { public class ResearchIntoTable implements BaseJob, InterruptableJob {
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/SendMessageJob.java
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
import org.quartz.InterruptableJob; import org.quartz.InterruptableJob;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException; import org.quartz.JobExecutionException;
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/SendNewMessageJob.java
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import com.fulan.application.feign.remote.RemoteJobHandleClient; import com.yizhi.application.feign.remote.RemoteJobHandleClient;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
import org.quartz.InterruptableJob; import org.quartz.InterruptableJob;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException; import org.quartz.JobExecutionException;
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/SignInToTable.java
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import org.quartz.InterruptableJob; import org.quartz.InterruptableJob;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
...@@ -8,8 +8,8 @@ import org.slf4j.Logger; ...@@ -8,8 +8,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import com.fulan.application.feign.ReportSignClient; import com.yizhi.application.feign.ReportSignClient;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
public class SignInToTable implements BaseJob, InterruptableJob { public class SignInToTable implements BaseJob, InterruptableJob {
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/StatisticsTrainingProjectJob.java
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import org.quartz.InterruptableJob; import org.quartz.InterruptableJob;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
...@@ -8,8 +8,8 @@ import org.slf4j.Logger; ...@@ -8,8 +8,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import com.fulan.application.feign.TrainingProjectReportClient; import com.yizhi.application.feign.TrainingProjectReportClient;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
public class StatisticsTrainingProjectJob implements BaseJob, InterruptableJob { public class StatisticsTrainingProjectJob implements BaseJob, InterruptableJob {
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/SydPointAcctranJob.java
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.Date; import java.util.Date;
...@@ -11,8 +11,8 @@ import org.slf4j.Logger; ...@@ -11,8 +11,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import com.fulan.application.feign.SydPointAcctranClient; import com.yizhi.application.feign.SydPointAcctranClient;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
public class SydPointAcctranJob implements BaseJob, InterruptableJob { public class SydPointAcctranJob implements BaseJob, InterruptableJob {
private final Logger LOG = LoggerFactory.getLogger(AlbumUnLockJob.class); private final Logger LOG = LoggerFactory.getLogger(AlbumUnLockJob.class);
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/TestJob.java
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
import org.quartz.*; import org.quartz.*;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/VoteToTable.java
//package com.fulan.application.handle.quartz.job; //package com.yizhi.application.handle.quartz.job;
// //
//import org.quartz.InterruptableJob; //import org.quartz.InterruptableJob;
//import org.quartz.JobExecutionContext; //import org.quartz.JobExecutionContext;
...@@ -8,8 +8,8 @@ ...@@ -8,8 +8,8 @@
//import org.slf4j.LoggerFactory; //import org.slf4j.LoggerFactory;
//import org.springframework.beans.factory.annotation.Autowired; //import org.springframework.beans.factory.annotation.Autowired;
// //
//import com.fulan.application.feign.ReportVoteClient; //import com.yizhi.application.feign.ReportVoteClient;
//import com.fulan.application.handle.quartz.BaseJob; //import com.yizhi.application.handle.quartz.BaseJob;
// //
//public class VoteToTable implements BaseJob, InterruptableJob { //public class VoteToTable implements BaseJob, InterruptableJob {
// //
......
cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/WechatJob.java
package com.fulan.application.handle.quartz.job; package com.yizhi.application.handle.quartz.job;
import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONArray;
import com.fulan.application.cache.RedisCache; import com.yizhi.application.cache.RedisCache;
import com.fulan.application.domain.Chapter; import com.yizhi.application.domain.Chapter;
import com.fulan.application.domain.Recorde; import com.yizhi.application.domain.Recorde;
import com.fulan.application.domain.StudyLog; import com.yizhi.application.domain.StudyLog;
import com.fulan.application.event.EventWrapper; import com.yizhi.application.event.EventWrapper;
import com.fulan.application.feign.*; import com.yizhi.application.feign.*;
import com.fulan.application.handle.quartz.BaseJob; import com.yizhi.application.handle.quartz.BaseJob;
import com.fulan.application.publish.CloudEventPublisher; import com.yizhi.application.publish.CloudEventPublisher;
import com.fulan.application.task.AbstractTaskHandler; import com.yizhi.application.task.AbstractTaskHandler;
import com.fulan.application.task.TaskExecutor; import com.yizhi.application.task.TaskExecutor;
import com.fulan.application.util.constant.QueueConstant; import com.yizhi.application.util.constant.QueueConstant;
import com.fulan.application.util.event.TrainingProjectEvent; import com.yizhi.application.util.event.TrainingProjectEvent;
import com.fulan.application.vo.PointParamVO; import com.yizhi.application.vo.PointParamVO;
import org.quartz.InterruptableJob; import org.quartz.InterruptableJob;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException; import org.quartz.JobExecutionException;
......
cloud-job-service/src/main/java/com/fulan/application/task/HeartbeatHandleAsync.java
package com.fulan.application.task; package com.yizhi.application.task;
import com.fulan.application.feign.HeartbeatHandleClient; import com.yizhi.application.feign.HeartbeatHandleClient;
import com.fulan.application.file.task.AbstractDefaultTask; import com.yizhi.application.file.task.AbstractDefaultTask;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
......
cloud-job-service/src/main/java/com/fulan/application/util/HttpUtil.java
package com.fulan.application.util; package com.yizhi.application.util;
import org.apache.commons.io.IOUtils; import org.apache.commons.io.IOUtils;
import org.apache.http.HttpEntity; import org.apache.http.HttpEntity;
......
cloud-job-service/src/main/resources/META-INF/app.properties
app.name=com.fulan.application.job app.name=com.yizhi.application.job
\ No newline at end of file \ No newline at end of file
cloud-job-service/src/main/resources/META-INF/cat/client.xml
<?xml version="1.0" encoding="utf-8"?> <?xml version="1.0" encoding="utf-8"?>
<config mode="client"> <config mode="client">
<domain id="com.fulan.application.job"/> <domain id="com.yizhi.application.job"/>
</config> </config>
cloud-job-service/src/main/resources/logback-spring.xml
...@@ -44,7 +44,7 @@ ...@@ -44,7 +44,7 @@
<appender-ref ref="STDOUT"/> <appender-ref ref="STDOUT"/>
</root> </root>
<logger name="com.fulan.application.mapper" level="debug" additivity="false"> <logger name="com.yizhi.application.mapper" level="debug" additivity="false">
<appender-ref ref="STDOUT"/> <appender-ref ref="STDOUT"/>
</logger> </logger>
</configuration> </configuration>
\ No newline at end of file
cloud-job-service/src/test/java/com/fulan/application/TestApplication.java
package com.fulan.application; package com.yizhi.application;
import com.fulan.application.cache.CacheNamespace; import com.yizhi.application.cache.CacheNamespace;
import org.junit.Test; import org.junit.Test;
import org.junit.runner.RunWith; import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
......
pom.xml
...@@ -11,7 +11,7 @@ ...@@ -11,7 +11,7 @@
<relativePath/> <relativePath/>
</parent> </parent>
<groupId>com.fulan.job</groupId> <groupId>com.yizhi.job</groupId>
<artifactId>cloud-job</artifactId> <artifactId>cloud-job</artifactId>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
<modules> <modules>
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment