quartz + JPA

Author: yulc-coding

quartz/src/main/java/org/ylc/note/quartz/constant/EnumConstant.java

@@ -0,0 +1,30 @@
+package org.ylc.note.quartz.constant;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * 代码全万行，注释第一行
+ * 注释不规范，同事泪两行
+ *
+ * @author YuLc
+ * @version 1.0.0
+ * @date 2020-09-12
+ */
+public class EnumConstant {
+
+    @Getter
+    @AllArgsConstructor
+    public enum JobStatus {
+
+        PAUSED("0", "暂停"),
+        NORMAL("1", "正常");
+
+
+        private String code;
+
+        private String value;
+
+    }
+
+}

quartz/src/main/java/org/ylc/note/quartz/controller/ScheduleController.java

@@ -1,7 +1,10 @@
 package org.ylc.note.quartz.controller;
 
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
+import org.ylc.note.quartz.entity.ScheduleJob;
+import org.ylc.note.quartz.service.ScheduleJobService;
+
+import java.util.List;
 
 /**
  * 代码全万行，注释第一行
@@ -15,6 +18,22 @@
 @RestController
 public class ScheduleController {
 
+    private final ScheduleJobService scheduleJobService;
+
+    public ScheduleController(ScheduleJobService scheduleJobService) {
+        this.scheduleJobService = scheduleJobService;
+    }
+
+    @GetMapping("/list")
+    public List<ScheduleJob> list() {
+        List<ScheduleJob> jobs = scheduleJobService.list();
+        jobs.forEach(System.out::print);
+        return jobs;
+    }
 
+    @PostMapping("/create")
+    public void create(@RequestBody ScheduleJob job) {
+        scheduleJobService.createJob(job);
+    }
 
 }

quartz/src/main/java/org/ylc/note/quartz/entity/ScheduleJob.java

@@ -0,0 +1,49 @@
+package org.ylc.note.quartz.entity;
+
+import lombok.Getter;
+import lombok.Setter;
+
+import javax.persistence.*;
+import java.time.LocalDateTime;
+
+/**
+ * 代码全万行，注释第一行
+ * 注释不规范，同事泪两行
+ * <p>
+ * 定时任务
+ *
+ * @author YuLc
+ * @version 1.0.0
+ * @date 2020-09-12
+ */
+@Getter
+@Setter
+@Entity
+@Table(name = "schedule_job")
+public class ScheduleJob {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column(name = "class_name", nullable = false)
+    private String className;
+
+    @Column(name = "method_name", nullable = false)
+    private String methodName;
+
+    private String parameter;
+
+    @Column(name = "cron_expression", nullable = false)
+    private String cronExpression;
+
+    private String status;
+
+    @Column(name = "job_sched")
+    private String jobSched;
+
+    private String remark;
+
+    @Column(name = "create_time", nullable = false)
+    private LocalDateTime createTime;
+}

quartz/src/main/java/org/ylc/note/quartz/repository/ScheduleJobRepository.java

@@ -0,0 +1,17 @@
+package org.ylc.note.quartz.repository;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.ylc.note.quartz.entity.ScheduleJob;
+
+/**
+ * 代码全万行，注释第一行
+ * 注释不规范，同事泪两行
+ * <p>
+ * 定时任务数据库操作接口
+ *
+ * @author YuLc
+ * @version 1.0.0
+ * @date 2020-09-12
+ */
+public interface ScheduleJobRepository extends JpaRepository<ScheduleJob, Long> {
+}

quartz/src/main/java/org/ylc/note/quartz/service/ScheduleJobService.java

@@ -0,0 +1,55 @@
+package org.ylc.note.quartz.service;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.ylc.note.quartz.constant.EnumConstant;
+import org.ylc.note.quartz.entity.ScheduleJob;
+import org.ylc.note.quartz.repository.ScheduleJobRepository;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * 代码全万行，注释第一行
+ * 注释不规范，同事泪两行
+ *
+ * @author YuLc
+ * @version 1.0.0
+ * @date 2020-09-11
+ */
+@Service
+public class ScheduleJobService {
+
+    @Autowired
+    private ScheduleJobRepository scheduleJobRepository;
+
+    @Autowired
+    private QuartzService quartzService;
+
+    public List<ScheduleJob> list() {
+        return scheduleJobRepository.findAll();
+    }
+
+    public void createJob(ScheduleJob job) {
+        job.setStatus(EnumConstant.JobStatus.NORMAL.getCode());
+        job.setCreateTime(LocalDateTime.now());
+        scheduleJobRepository.save(job);
+        quartzService.createJob();
+    }
+
+    public void pauseJob() {
+        quartzService.pauseJob();
+    }
+
+    public void restoreJob() {
+        quartzService.restoreJob();
+    }
+
+    public void modifyJob() {
+        quartzService.modifyJob();
+    }
+
+    public void removeJob() {
+        quartzService.restoreJob();
+    }
+}

quartz/src/main/java/org/ylc/note/quartz/service/ScheduleService.java

@@ -2,10 +2,11 @@ spring:
   application:
     name: quzrtz
   datasource:
-    url: jdbc:mysql://localhost:3306/quarzt?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2B8&autoReconnect=true
+    url: jdbc:mysql://localhost:3306/quartz?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&autoReconnect=true
     username: root
-    password: root2019!
+    password: root2020!
     driver-class-name: com.mysql.cj.jdbc.Driver
+    type: com.zaxxer.hikari.HikariDataSource
     # Hikari 连接池配置
     hikari:
       # 连接池名称
@@ -21,4 +22,6 @@ spring:
       maxLifetime: 1800000
       connection-test-query: select 1
   jpa:
-    database: mysql
+    database: mysql
+    # 打印SQL语句
+    show-sql: true