From 1b90ad8521c790a4c72a3ebf8260145fbd6c2dd7 Mon Sep 17 00:00:00 2001 From: Bunny <1319900154@qq.com> Date: Thu, 25 Jul 2024 23:26:27 +0800 Subject: [PATCH] =?UTF-8?q?feat(=E6=96=B0=E5=A2=9E):=20=E5=88=9D=E5=A7=8B?= =?UTF-8?q?=E5=8C=96=E5=AE=9E=E4=BD=93=E7=B1=BB=E3=80=81=E6=8E=A5=E5=8F=A3?= =?UTF-8?q?=E7=9B=B8=E5=85=B3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cn/bunny/common/generator/NewCodeGet.java | 7 +- .../java/cn/bunny/dto/quartz/QuartzDto.java | 24 +++++++ .../bunny/entity/system/quartz/Calendars.java | 41 +++++++++++ .../entity/system/quartz/CronTriggers.java | 46 +++++++++++++ .../entity/system/quartz/FiredTriggers.java | 61 +++++++++++++++++ .../entity/system/quartz/JobDetails.java | 56 +++++++++++++++ .../cn/bunny/entity/system/quartz/Locks.java | 39 +++++++++++ .../system/quartz/PausedTriggerGrps.java | 39 +++++++++++ .../entity/system/quartz/SchedulerState.java | 43 ++++++++++++ .../entity/system/quartz/SimpleTriggers.java | 48 +++++++++++++ .../entity/system/quartz/SimpropTriggers.java | 65 ++++++++++++++++++ .../bunny/entity/system/quartz/Triggers.java | 68 +++++++++++++++++++ service/pom.xml | 6 +- .../quartz/BlobTriggersController.java | 4 +- .../quartz/CalendarsController.java | 18 +++++ .../quartz/CronTriggersController.java | 18 +++++ .../quartz/FiredTriggersController.java | 18 +++++ .../quartz/JobDetailsController.java | 18 +++++ .../controller/quartz/LocksController.java | 18 +++++ .../quartz/PausedTriggerGrpsController.java | 18 +++++ .../quartz/SchedulerStateController.java | 18 +++++ .../quartz/SimpleTriggersController.java | 18 +++++ .../quartz/SimpropTriggersController.java | 18 +++++ .../controller/quartz/TriggersController.java | 18 +++++ .../bunny/service/job/dynamic/JobHello.java | 5 ++ .../mapper/quartz/CalendarsMapper.java | 18 +++++ .../mapper/quartz/CronTriggersMapper.java | 18 +++++ .../mapper/quartz/FiredTriggersMapper.java | 18 +++++ .../mapper/quartz/JobDetailsMapper.java | 18 +++++ .../service/mapper/quartz/LocksMapper.java | 18 +++++ .../quartz/PausedTriggerGrpsMapper.java | 18 +++++ .../mapper/quartz/SchedulerStateMapper.java | 18 +++++ .../mapper/quartz/SimpleTriggersMapper.java | 18 +++++ .../mapper/quartz/SimpropTriggersMapper.java | 18 +++++ .../service/mapper/quartz/TriggersMapper.java | 18 +++++ .../service/quartz/CalendarsService.java | 16 +++++ .../service/quartz/CronTriggersService.java | 16 +++++ .../service/quartz/FiredTriggersService.java | 16 +++++ .../service/quartz/JobDetailsService.java | 16 +++++ .../service/service/quartz/LocksService.java | 16 +++++ .../quartz/PausedTriggerGrpsService.java | 16 +++++ .../service/quartz/SchedulerStateService.java | 16 +++++ .../service/quartz/SimpleTriggersService.java | 16 +++++ .../quartz/SimpropTriggersService.java | 16 +++++ .../service/quartz/TriggersService.java | 16 +++++ .../quartz/impl/CalendarsServiceImpl.java | 22 ++++++ .../quartz/impl/CronTriggersServiceImpl.java | 22 ++++++ .../quartz/impl/FiredTriggersServiceImpl.java | 22 ++++++ .../quartz/impl/JobDetailsServiceImpl.java | 22 ++++++ .../service/quartz/impl/LocksServiceImpl.java | 22 ++++++ .../impl/PausedTriggerGrpsServiceImpl.java | 22 ++++++ .../impl/SchedulerStateServiceImpl.java | 22 ++++++ .../impl/SimpleTriggersServiceImpl.java | 22 ++++++ .../impl/SimpropTriggersServiceImpl.java | 22 ++++++ .../quartz/impl/TriggersServiceImpl.java | 22 ++++++ .../mapper/quartz/CalendarsMapper.xml | 17 +++++ .../mapper/quartz/CronTriggersMapper.xml | 19 ++++++ .../mapper/quartz/FiredTriggersMapper.xml | 27 ++++++++ .../mapper/quartz/JobDetailsMapper.xml | 24 +++++++ .../resources/mapper/quartz/LocksMapper.xml | 16 +++++ .../mapper/quartz/PausedTriggerGrpsMapper.xml | 16 +++++ .../mapper/quartz/SchedulerStateMapper.xml | 18 +++++ .../mapper/quartz/SimpleTriggersMapper.xml | 20 ++++++ .../mapper/quartz/SimpropTriggersMapper.xml | 28 ++++++++ .../mapper/quartz/TriggersMapper.xml | 30 ++++++++ 65 files changed, 1501 insertions(+), 6 deletions(-) create mode 100644 dao/src/main/java/cn/bunny/dto/quartz/QuartzDto.java create mode 100644 dao/src/main/java/cn/bunny/entity/system/quartz/Calendars.java create mode 100644 dao/src/main/java/cn/bunny/entity/system/quartz/CronTriggers.java create mode 100644 dao/src/main/java/cn/bunny/entity/system/quartz/FiredTriggers.java create mode 100644 dao/src/main/java/cn/bunny/entity/system/quartz/JobDetails.java create mode 100644 dao/src/main/java/cn/bunny/entity/system/quartz/Locks.java create mode 100644 dao/src/main/java/cn/bunny/entity/system/quartz/PausedTriggerGrps.java create mode 100644 dao/src/main/java/cn/bunny/entity/system/quartz/SchedulerState.java create mode 100644 dao/src/main/java/cn/bunny/entity/system/quartz/SimpleTriggers.java create mode 100644 dao/src/main/java/cn/bunny/entity/system/quartz/SimpropTriggers.java create mode 100644 dao/src/main/java/cn/bunny/entity/system/quartz/Triggers.java create mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/CalendarsController.java create mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/CronTriggersController.java create mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/FiredTriggersController.java create mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/JobDetailsController.java create mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/LocksController.java create mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/PausedTriggerGrpsController.java create mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/SchedulerStateController.java create mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/SimpleTriggersController.java create mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/SimpropTriggersController.java create mode 100644 service/src/main/java/cn/bunny/service/controller/quartz/TriggersController.java create mode 100644 service/src/main/java/cn/bunny/service/job/dynamic/JobHello.java create mode 100644 service/src/main/java/cn/bunny/service/mapper/quartz/CalendarsMapper.java create mode 100644 service/src/main/java/cn/bunny/service/mapper/quartz/CronTriggersMapper.java create mode 100644 service/src/main/java/cn/bunny/service/mapper/quartz/FiredTriggersMapper.java create mode 100644 service/src/main/java/cn/bunny/service/mapper/quartz/JobDetailsMapper.java create mode 100644 service/src/main/java/cn/bunny/service/mapper/quartz/LocksMapper.java create mode 100644 service/src/main/java/cn/bunny/service/mapper/quartz/PausedTriggerGrpsMapper.java create mode 100644 service/src/main/java/cn/bunny/service/mapper/quartz/SchedulerStateMapper.java create mode 100644 service/src/main/java/cn/bunny/service/mapper/quartz/SimpleTriggersMapper.java create mode 100644 service/src/main/java/cn/bunny/service/mapper/quartz/SimpropTriggersMapper.java create mode 100644 service/src/main/java/cn/bunny/service/mapper/quartz/TriggersMapper.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/CalendarsService.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/CronTriggersService.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/FiredTriggersService.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/JobDetailsService.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/LocksService.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/PausedTriggerGrpsService.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/SchedulerStateService.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/SimpleTriggersService.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/SimpropTriggersService.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/TriggersService.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/impl/CalendarsServiceImpl.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/impl/CronTriggersServiceImpl.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/impl/FiredTriggersServiceImpl.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/impl/JobDetailsServiceImpl.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/impl/LocksServiceImpl.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/impl/PausedTriggerGrpsServiceImpl.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/impl/SchedulerStateServiceImpl.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/impl/SimpleTriggersServiceImpl.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/impl/SimpropTriggersServiceImpl.java create mode 100644 service/src/main/java/cn/bunny/service/service/quartz/impl/TriggersServiceImpl.java create mode 100644 service/src/main/resources/mapper/quartz/CalendarsMapper.xml create mode 100644 service/src/main/resources/mapper/quartz/CronTriggersMapper.xml create mode 100644 service/src/main/resources/mapper/quartz/FiredTriggersMapper.xml create mode 100644 service/src/main/resources/mapper/quartz/JobDetailsMapper.xml create mode 100644 service/src/main/resources/mapper/quartz/LocksMapper.xml create mode 100644 service/src/main/resources/mapper/quartz/PausedTriggerGrpsMapper.xml create mode 100644 service/src/main/resources/mapper/quartz/SchedulerStateMapper.xml create mode 100644 service/src/main/resources/mapper/quartz/SimpleTriggersMapper.xml create mode 100644 service/src/main/resources/mapper/quartz/SimpropTriggersMapper.xml create mode 100644 service/src/main/resources/mapper/quartz/TriggersMapper.xml diff --git a/common/common-generator/src/main/java/cn/bunny/common/generator/NewCodeGet.java b/common/common-generator/src/main/java/cn/bunny/common/generator/NewCodeGet.java index d159135..ce3ab00 100644 --- a/common/common-generator/src/main/java/cn/bunny/common/generator/NewCodeGet.java +++ b/common/common-generator/src/main/java/cn/bunny/common/generator/NewCodeGet.java @@ -15,12 +15,15 @@ public class NewCodeGet { // 作者名称 public static final String author = "Bunny"; // 公共路径 - public static final String outputDir = "D:\\MyFolder\\Quartz-Demo\\service"; + // public static final String outputDir = "D:\\MyFolder\\Quartz-Demo\\service"; + public static final String outputDir = "D:\\Project\\web\\PC\\demo\\Quartz-Demo\\service"; // 实体类名称 public static final String entity = "Bunny"; public static void main(String[] args) { - Generation("QRTZ_BLOB_TRIGGERS"); + Generation("QRTZ_CALENDARS","QRTZ_CRON_TRIGGERS","QRTZ_FIRED_TRIGGERS","QRTZ_JOB_DETAILS","QRTZ_LOCKS","QRTZ_PAUSED_TRIGGER_GRPS","QRTZ_SCHEDULER_STATE", +"QRTZ_SIMPLE_TRIGGERS","QRTZ_SIMPROP_TRIGGERS","QRTZ_TRIGGERS" + ); } /** diff --git a/dao/src/main/java/cn/bunny/dto/quartz/QuartzDto.java b/dao/src/main/java/cn/bunny/dto/quartz/QuartzDto.java new file mode 100644 index 0000000..90ab24f --- /dev/null +++ b/dao/src/main/java/cn/bunny/dto/quartz/QuartzDto.java @@ -0,0 +1,24 @@ +package cn.bunny.dto.quartz; + +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +@Data +@AllArgsConstructor +@NoArgsConstructor +@Builder +public class QuartzDto { + private String jobName;// 任务名称 + private String jobGroup;// 任务分组 + private String description;// 任务描述 + private String jobClassName;// 执行类 + private String jobMethodName;// 执行方法 + private String cronExpression;// 执行时间 + private String triggerName;// 执行时间 + private String triggerState;// 任务状态 + + private String oldJobName;// 任务名称 用于修改 + private String oldJobGroup;// 任务分组 用于修改 +} \ No newline at end of file diff --git a/dao/src/main/java/cn/bunny/entity/system/quartz/Calendars.java b/dao/src/main/java/cn/bunny/entity/system/quartz/Calendars.java new file mode 100644 index 0000000..ecd335b --- /dev/null +++ b/dao/src/main/java/cn/bunny/entity/system/quartz/Calendars.java @@ -0,0 +1,41 @@ +package cn.bunny.entity.system.quartz; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; + +import java.io.Serial; +import java.io.Serializable; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Getter; +import lombok.Setter; +import lombok.experimental.Accessors; + +/** + *
+ * + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Getter +@Setter +@Accessors(chain = true) +@TableName("QRTZ_CALENDARS") +@ApiModel(value = "Calendars对象", description = "") +public class Calendars implements Serializable { + + @Serial + private static final long serialVersionUID = 1L; + + @TableField(value = "SCHED_NAME") + private String schedName; + + @TableField(value = "CALENDAR_NAME") + private String calendarName; + + private byte[] calendar; +} diff --git a/dao/src/main/java/cn/bunny/entity/system/quartz/CronTriggers.java b/dao/src/main/java/cn/bunny/entity/system/quartz/CronTriggers.java new file mode 100644 index 0000000..65bc503 --- /dev/null +++ b/dao/src/main/java/cn/bunny/entity/system/quartz/CronTriggers.java @@ -0,0 +1,46 @@ +package cn.bunny.entity.system.quartz; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; + +import java.io.Serial; +import java.io.Serializable; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Getter; +import lombok.Setter; +import lombok.experimental.Accessors; + +/** + *+ * + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Getter +@Setter +@Accessors(chain = true) +@TableName("QRTZ_CRON_TRIGGERS") +@ApiModel(value = "CronTriggers对象", description = "") +public class CronTriggers implements Serializable { + + @Serial + private static final long serialVersionUID = 1L; + + @TableField(value = "SCHED_NAME") + private String schedName; + + @TableField(value = "TRIGGER_NAME") + private String triggerName; + + @TableField(value = "TRIGGER_GROUP") + private String triggerGroup; + + private String cronExpression; + + private String timeZoneId; +} diff --git a/dao/src/main/java/cn/bunny/entity/system/quartz/FiredTriggers.java b/dao/src/main/java/cn/bunny/entity/system/quartz/FiredTriggers.java new file mode 100644 index 0000000..25657a4 --- /dev/null +++ b/dao/src/main/java/cn/bunny/entity/system/quartz/FiredTriggers.java @@ -0,0 +1,61 @@ +package cn.bunny.entity.system.quartz; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; + +import java.io.Serial; +import java.io.Serializable; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Getter; +import lombok.Setter; +import lombok.experimental.Accessors; + +/** + *+ * + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Getter +@Setter +@Accessors(chain = true) +@TableName("QRTZ_FIRED_TRIGGERS") +@ApiModel(value = "FiredTriggers对象", description = "") +public class FiredTriggers implements Serializable { + + @Serial + private static final long serialVersionUID = 1L; + + @TableField(value = "SCHED_NAME") + private String schedName; + + @TableField(value = "ENTRY_ID") + private String entryId; + + private String triggerName; + + private String triggerGroup; + + private String instanceName; + + private Long firedTime; + + private Long schedTime; + + private Integer priority; + + private String state; + + private String jobName; + + private String jobGroup; + + private String isNonconcurrent; + + private String requestsRecovery; +} diff --git a/dao/src/main/java/cn/bunny/entity/system/quartz/JobDetails.java b/dao/src/main/java/cn/bunny/entity/system/quartz/JobDetails.java new file mode 100644 index 0000000..2661882 --- /dev/null +++ b/dao/src/main/java/cn/bunny/entity/system/quartz/JobDetails.java @@ -0,0 +1,56 @@ +package cn.bunny.entity.system.quartz; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; + +import java.io.Serial; +import java.io.Serializable; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Getter; +import lombok.Setter; +import lombok.experimental.Accessors; + +/** + *+ * + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Getter +@Setter +@Accessors(chain = true) +@TableName("QRTZ_JOB_DETAILS") +@ApiModel(value = "JobDetails对象", description = "") +public class JobDetails implements Serializable { + + @Serial + private static final long serialVersionUID = 1L; + + @TableField(value = "SCHED_NAME") + private String schedName; + + @TableField(value = "JOB_NAME") + private String jobName; + + @TableField(value = "JOB_GROUP") + private String jobGroup; + + private String description; + + private String jobClassName; + + private String isDurable; + + private String isNonconcurrent; + + private String isUpdateData; + + private String requestsRecovery; + + private byte[] jobData; +} diff --git a/dao/src/main/java/cn/bunny/entity/system/quartz/Locks.java b/dao/src/main/java/cn/bunny/entity/system/quartz/Locks.java new file mode 100644 index 0000000..d50192b --- /dev/null +++ b/dao/src/main/java/cn/bunny/entity/system/quartz/Locks.java @@ -0,0 +1,39 @@ +package cn.bunny.entity.system.quartz; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; + +import java.io.Serial; +import java.io.Serializable; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Getter; +import lombok.Setter; +import lombok.experimental.Accessors; + +/** + *+ * + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Getter +@Setter +@Accessors(chain = true) +@TableName("QRTZ_LOCKS") +@ApiModel(value = "Locks对象", description = "") +public class Locks implements Serializable { + + @Serial + private static final long serialVersionUID = 1L; + + @TableField(value = "SCHED_NAME") + private String schedName; + + @TableField(value = "LOCK_NAME") + private String lockName; +} diff --git a/dao/src/main/java/cn/bunny/entity/system/quartz/PausedTriggerGrps.java b/dao/src/main/java/cn/bunny/entity/system/quartz/PausedTriggerGrps.java new file mode 100644 index 0000000..ac1ef53 --- /dev/null +++ b/dao/src/main/java/cn/bunny/entity/system/quartz/PausedTriggerGrps.java @@ -0,0 +1,39 @@ +package cn.bunny.entity.system.quartz; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; + +import java.io.Serial; +import java.io.Serializable; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Getter; +import lombok.Setter; +import lombok.experimental.Accessors; + +/** + *+ * + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Getter +@Setter +@Accessors(chain = true) +@TableName("QRTZ_PAUSED_TRIGGER_GRPS") +@ApiModel(value = "PausedTriggerGrps对象", description = "") +public class PausedTriggerGrps implements Serializable { + + @Serial + private static final long serialVersionUID = 1L; + + @TableId(value = "SCHED_NAME") + private String schedName; + + @TableField(value = "TRIGGER_GROUP") + private String triggerGroup; +} diff --git a/dao/src/main/java/cn/bunny/entity/system/quartz/SchedulerState.java b/dao/src/main/java/cn/bunny/entity/system/quartz/SchedulerState.java new file mode 100644 index 0000000..3da7af7 --- /dev/null +++ b/dao/src/main/java/cn/bunny/entity/system/quartz/SchedulerState.java @@ -0,0 +1,43 @@ +package cn.bunny.entity.system.quartz; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; + +import java.io.Serial; +import java.io.Serializable; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Getter; +import lombok.Setter; +import lombok.experimental.Accessors; + +/** + *+ * + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Getter +@Setter +@Accessors(chain = true) +@TableName("QRTZ_SCHEDULER_STATE") +@ApiModel(value = "SchedulerState对象", description = "") +public class SchedulerState implements Serializable { + + @Serial + private static final long serialVersionUID = 1L; + + @TableField(value = "SCHED_NAME") + private String schedName; + + @TableField(value = "INSTANCE_NAME") + private String instanceName; + + private Long lastCheckinTime; + + private Long checkinInterval; +} diff --git a/dao/src/main/java/cn/bunny/entity/system/quartz/SimpleTriggers.java b/dao/src/main/java/cn/bunny/entity/system/quartz/SimpleTriggers.java new file mode 100644 index 0000000..488d884 --- /dev/null +++ b/dao/src/main/java/cn/bunny/entity/system/quartz/SimpleTriggers.java @@ -0,0 +1,48 @@ +package cn.bunny.entity.system.quartz; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; + +import java.io.Serial; +import java.io.Serializable; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Getter; +import lombok.Setter; +import lombok.experimental.Accessors; + +/** + *+ * + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Getter +@Setter +@Accessors(chain = true) +@TableName("QRTZ_SIMPLE_TRIGGERS") +@ApiModel(value = "SimpleTriggers对象", description = "") +public class SimpleTriggers implements Serializable { + + @Serial + private static final long serialVersionUID = 1L; + + @TableField(value = "SCHED_NAME") + private String schedName; + + @TableField(value = "TRIGGER_NAME") + private String triggerName; + + @TableField(value = "TRIGGER_GROUP") + private String triggerGroup; + + private Long repeatCount; + + private Long repeatInterval; + + private Long timesTriggered; +} diff --git a/dao/src/main/java/cn/bunny/entity/system/quartz/SimpropTriggers.java b/dao/src/main/java/cn/bunny/entity/system/quartz/SimpropTriggers.java new file mode 100644 index 0000000..34a5f1b --- /dev/null +++ b/dao/src/main/java/cn/bunny/entity/system/quartz/SimpropTriggers.java @@ -0,0 +1,65 @@ +package cn.bunny.entity.system.quartz; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; + +import java.io.Serial; +import java.io.Serializable; +import java.math.BigDecimal; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Getter; +import lombok.Setter; +import lombok.experimental.Accessors; + +/** + *+ * + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Getter +@Setter +@Accessors(chain = true) +@TableName("QRTZ_SIMPROP_TRIGGERS") +@ApiModel(value = "SimpropTriggers对象", description = "") +public class SimpropTriggers implements Serializable { + + @Serial + private static final long serialVersionUID = 1L; + + @TableField(value = "SCHED_NAME") + private String schedName; + + @TableField(value = "TRIGGER_NAME") + private String triggerName; + + @TableField(value = "TRIGGER_GROUP") + private String triggerGroup; + + private String strProp1; + + private String strProp2; + + private String strProp3; + + private Integer intProp1; + + private Integer intProp2; + + private Long longProp1; + + private Long longProp2; + + private BigDecimal decProp1; + + private BigDecimal decProp2; + + private String boolProp1; + + private String boolProp2; +} diff --git a/dao/src/main/java/cn/bunny/entity/system/quartz/Triggers.java b/dao/src/main/java/cn/bunny/entity/system/quartz/Triggers.java new file mode 100644 index 0000000..30cf21f --- /dev/null +++ b/dao/src/main/java/cn/bunny/entity/system/quartz/Triggers.java @@ -0,0 +1,68 @@ +package cn.bunny.entity.system.quartz; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; + +import java.io.Serial; +import java.io.Serializable; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Getter; +import lombok.Setter; +import lombok.experimental.Accessors; + +/** + *+ * + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Getter +@Setter +@Accessors(chain = true) +@TableName("QRTZ_TRIGGERS") +@ApiModel(value = "Triggers对象", description = "") +public class Triggers implements Serializable { + + @Serial + private static final long serialVersionUID = 1L; + + @TableField(value = "SCHED_NAME") + private String schedName; + + @TableField(value = "TRIGGER_NAME") + private String triggerName; + + @TableField(value = "TRIGGER_GROUP") + private String triggerGroup; + + private String jobName; + + private String jobGroup; + + private String description; + + private Long nextFireTime; + + private Long prevFireTime; + + private Integer priority; + + private String triggerState; + + private String triggerType; + + private Long startTime; + + private Long endTime; + + private String calendarName; + + private Short misfireInstr; + + private byte[] jobData; +} diff --git a/service/pom.xml b/service/pom.xml index 17b9d27..54ec483 100644 --- a/service/pom.xml +++ b/service/pom.xml @@ -60,7 +60,7 @@+ * 前端控制器 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@RestController +@RequestMapping("/calendars") +public class CalendarsController { + +} diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/CronTriggersController.java b/service/src/main/java/cn/bunny/service/controller/quartz/CronTriggersController.java new file mode 100644 index 0000000..b364890 --- /dev/null +++ b/service/src/main/java/cn/bunny/service/controller/quartz/CronTriggersController.java @@ -0,0 +1,18 @@ +package cn.bunny.service.controller.quartz; + +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + *+ * 前端控制器 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@RestController +@RequestMapping("/cronTriggers") +public class CronTriggersController { + +} diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/FiredTriggersController.java b/service/src/main/java/cn/bunny/service/controller/quartz/FiredTriggersController.java new file mode 100644 index 0000000..9004114 --- /dev/null +++ b/service/src/main/java/cn/bunny/service/controller/quartz/FiredTriggersController.java @@ -0,0 +1,18 @@ +package cn.bunny.service.controller.quartz; + +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + *+ * 前端控制器 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@RestController +@RequestMapping("/firedTriggers") +public class FiredTriggersController { + +} diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/JobDetailsController.java b/service/src/main/java/cn/bunny/service/controller/quartz/JobDetailsController.java new file mode 100644 index 0000000..37e6a08 --- /dev/null +++ b/service/src/main/java/cn/bunny/service/controller/quartz/JobDetailsController.java @@ -0,0 +1,18 @@ +package cn.bunny.service.controller.quartz; + +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + *+ * 前端控制器 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@RestController +@RequestMapping("/jobDetails") +public class JobDetailsController { + +} diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/LocksController.java b/service/src/main/java/cn/bunny/service/controller/quartz/LocksController.java new file mode 100644 index 0000000..512fef6 --- /dev/null +++ b/service/src/main/java/cn/bunny/service/controller/quartz/LocksController.java @@ -0,0 +1,18 @@ +package cn.bunny.service.controller.quartz; + +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + *+ * 前端控制器 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@RestController +@RequestMapping("/locks") +public class LocksController { + +} diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/PausedTriggerGrpsController.java b/service/src/main/java/cn/bunny/service/controller/quartz/PausedTriggerGrpsController.java new file mode 100644 index 0000000..721f232 --- /dev/null +++ b/service/src/main/java/cn/bunny/service/controller/quartz/PausedTriggerGrpsController.java @@ -0,0 +1,18 @@ +package cn.bunny.service.controller.quartz; + +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + *+ * 前端控制器 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@RestController +@RequestMapping("/pausedTriggerGrps") +public class PausedTriggerGrpsController { + +} diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/SchedulerStateController.java b/service/src/main/java/cn/bunny/service/controller/quartz/SchedulerStateController.java new file mode 100644 index 0000000..d4a81b9 --- /dev/null +++ b/service/src/main/java/cn/bunny/service/controller/quartz/SchedulerStateController.java @@ -0,0 +1,18 @@ +package cn.bunny.service.controller.quartz; + +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + *+ * 前端控制器 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@RestController +@RequestMapping("/schedulerState") +public class SchedulerStateController { + +} diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/SimpleTriggersController.java b/service/src/main/java/cn/bunny/service/controller/quartz/SimpleTriggersController.java new file mode 100644 index 0000000..0569735 --- /dev/null +++ b/service/src/main/java/cn/bunny/service/controller/quartz/SimpleTriggersController.java @@ -0,0 +1,18 @@ +package cn.bunny.service.controller.quartz; + +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + *+ * 前端控制器 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@RestController +@RequestMapping("/simpleTriggers") +public class SimpleTriggersController { + +} diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/SimpropTriggersController.java b/service/src/main/java/cn/bunny/service/controller/quartz/SimpropTriggersController.java new file mode 100644 index 0000000..81f63ae --- /dev/null +++ b/service/src/main/java/cn/bunny/service/controller/quartz/SimpropTriggersController.java @@ -0,0 +1,18 @@ +package cn.bunny.service.controller.quartz; + +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + *+ * 前端控制器 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@RestController +@RequestMapping("/simpropTriggers") +public class SimpropTriggersController { + +} diff --git a/service/src/main/java/cn/bunny/service/controller/quartz/TriggersController.java b/service/src/main/java/cn/bunny/service/controller/quartz/TriggersController.java new file mode 100644 index 0000000..b1e3de0 --- /dev/null +++ b/service/src/main/java/cn/bunny/service/controller/quartz/TriggersController.java @@ -0,0 +1,18 @@ +package cn.bunny.service.controller.quartz; + +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + *+ * 前端控制器 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@RestController +@RequestMapping("/triggers") +public class TriggersController { + +} diff --git a/service/src/main/java/cn/bunny/service/job/dynamic/JobHello.java b/service/src/main/java/cn/bunny/service/job/dynamic/JobHello.java new file mode 100644 index 0000000..544fea7 --- /dev/null +++ b/service/src/main/java/cn/bunny/service/job/dynamic/JobHello.java @@ -0,0 +1,5 @@ +package cn.bunny.service.job.dynamic; + +public class JobHello { + +} diff --git a/service/src/main/java/cn/bunny/service/mapper/quartz/CalendarsMapper.java b/service/src/main/java/cn/bunny/service/mapper/quartz/CalendarsMapper.java new file mode 100644 index 0000000..4177e33 --- /dev/null +++ b/service/src/main/java/cn/bunny/service/mapper/quartz/CalendarsMapper.java @@ -0,0 +1,18 @@ +package cn.bunny.service.mapper.quartz; + +import cn.bunny.entity.system.quartz.Calendars; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.apache.ibatis.annotations.Mapper; + +/** + *+ * Mapper 接口 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Mapper +public interface CalendarsMapper extends BaseMapper+ * Mapper 接口 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Mapper +public interface CronTriggersMapper extends BaseMapper+ * Mapper 接口 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Mapper +public interface FiredTriggersMapper extends BaseMapper+ * Mapper 接口 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Mapper +public interface JobDetailsMapper extends BaseMapper+ * Mapper 接口 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Mapper +public interface LocksMapper extends BaseMapper+ * Mapper 接口 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Mapper +public interface PausedTriggerGrpsMapper extends BaseMapper+ * Mapper 接口 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Mapper +public interface SchedulerStateMapper extends BaseMapper+ * Mapper 接口 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Mapper +public interface SimpleTriggersMapper extends BaseMapper+ * Mapper 接口 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Mapper +public interface SimpropTriggersMapper extends BaseMapper+ * Mapper 接口 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Mapper +public interface TriggersMapper extends BaseMapper+ * 服务类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +public interface CalendarsService extends IService+ * 服务类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +public interface CronTriggersService extends IService+ * 服务类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +public interface FiredTriggersService extends IService+ * 服务类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +public interface JobDetailsService extends IService+ * 服务类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +public interface LocksService extends IService+ * 服务类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +public interface PausedTriggerGrpsService extends IService+ * 服务类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +public interface SchedulerStateService extends IService+ * 服务类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +public interface SimpleTriggersService extends IService+ * 服务类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +public interface SimpropTriggersService extends IService+ * 服务类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +public interface TriggersService extends IService+ * 服务实现类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Service +@DS("myDS") +public class CalendarsServiceImpl extends ServiceImpl+ * 服务实现类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Service +@DS("myDS") +public class CronTriggersServiceImpl extends ServiceImpl+ * 服务实现类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Service +@DS("myDS") +public class FiredTriggersServiceImpl extends ServiceImpl+ * 服务实现类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Service +@DS("myDS") +public class JobDetailsServiceImpl extends ServiceImpl+ * 服务实现类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Service +@DS("myDS") +public class LocksServiceImpl extends ServiceImpl+ * 服务实现类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Service +@DS("myDS") +public class PausedTriggerGrpsServiceImpl extends ServiceImpl+ * 服务实现类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Service +@DS("myDS") +public class SchedulerStateServiceImpl extends ServiceImpl+ * 服务实现类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Service +@DS("myDS") +public class SimpleTriggersServiceImpl extends ServiceImpl+ * 服务实现类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Service +@DS("myDS") +public class SimpropTriggersServiceImpl extends ServiceImpl+ * 服务实现类 + *
+ * + * @author Bunny + * @since 2024-07-25 + */ +@Service +@DS("myDS") +public class TriggersServiceImpl extends ServiceImpl