Scheduler Job added for automatic publishing the blog and removed EntityListner

Author: ManikGantait

src/main/java/com/example/cms/ContentManagementSystemApplication.java

@@ -2,8 +2,10 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
+@EnableScheduling
 public class ContentManagementSystemApplication {
 
 public static void main(String[] args) {

src/main/java/com/example/cms/entity/BlogPost.java

@@ -26,7 +26,7 @@
 @Entity
 @Getter
 @Setter
-@EntityListeners(AuditingEntityListener.class)
+//@EntityListeners(AuditingEntityListener.class)
 public class BlogPost {
 
 @Id
@@ -42,14 +42,14 @@ public class BlogPost {
 @ManyToOne
 private Blog blog;
 
-@CreatedBy
+//@CreatedBy
 private String createdBy;
 @CreatedDate
 @Column(updatable = false)
 private LocalDateTime createAt;
 @LastModifiedDate
 private LocalDateTime lastModifiedAt;
-@LastModifiedBy
+//@LastModifiedBy
 private String lastModifiedBy;
 
 @OneToOne

src/main/java/com/example/cms/entity/Publish.java

@@ -20,7 +20,10 @@ public class Publish {
 private String scoDescription;
 private String scoTags;
 
-@OneToOne
+@OneToOne(mappedBy = "publish")
 private BlogPost blogPost;
+
+@OneToOne
+private Schedule schedule;
 
 }

src/main/java/com/example/cms/entity/Schedule.java

@@ -0,0 +1,25 @@
+package com.example.cms.entity;
+
+import java.time.LocalDateTime;
+
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import lombok.Getter;
+import lombok.Setter;
+
+@Entity
+@Getter
+@Setter
+public class Schedule {
+
+@Id
+@GeneratedValue(strategy = GenerationType.IDENTITY)
+private int scheduleId;
+
+
+private LocalDateTime dateTime;
+
+
+}

src/main/java/com/example/cms/enums/PostType.java

@@ -1,6 +1,6 @@
 package com.example.cms.enums;
 
 public enum PostType {
-DRAFT,PUBLISHED;
+DRAFT,PUBLISHED,SCHEDULED;
 
 }

src/main/java/com/example/cms/exception/ScheduleTimeNotValidException.java

@@ -0,0 +1,11 @@
+package com.example.cms.exception;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+@AllArgsConstructor
+@Getter
+public class ScheduleTimeNotValidException extends RuntimeException {
+private String message;
+
+}

src/main/java/com/example/cms/repository/BlogPostRepository.java

@@ -1,5 +1,8 @@
 package com.example.cms.repository;
 
+import java.time.LocalDateTime;
+import java.util.Collection;
+import java.util.List;
 import java.util.Optional;
 
 import org.springframework.data.jpa.repository.JpaRepository;
@@ -12,4 +15,9 @@ public interface BlogPostRepository extends JpaRepository<BlogPost, Integer>{
 
 Optional<BlogPost> findByPostIdAndPostType(int postId, PostType published);
 
+
+Collection<BlogPost> findAllByPublishScheduleDateTimeLessThanEqualAndPostType(LocalDateTime now,
+PostType scheduled);
+
+
 }

src/main/java/com/example/cms/repository/PublishRepository.java

@@ -2,8 +2,12 @@
 
 import org.springframework.data.jpa.repository.JpaRepository;
 
+import com.example.cms.entity.BlogPost;
 import com.example.cms.entity.Publish;
+import com.example.cms.entity.Schedule;
 
 public interface PublishRepository extends JpaRepository<Publish, Integer>{
 
+
+
 }

src/main/java/com/example/cms/repository/ScheduleRepository.java

@@ -0,0 +1,14 @@
+package com.example.cms.repository;
+
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Optional;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import com.example.cms.entity.Schedule;
+
+public interface ScheduleRepository extends JpaRepository<Schedule, Integer>{
+
+
+}

src/main/java/com/example/cms/requestdto/PublishRequestEntity.java

@@ -1,5 +1,7 @@
 package com.example.cms.requestdto;
 
+import com.example.cms.entity.Schedule;
+
 import jakarta.validation.constraints.NotNull;
 import lombok.Getter;
 
@@ -10,5 +12,8 @@ public class PublishRequestEntity {
 private String scoTitle;
 private String scoDescription;
 private String scoTags;
+
+
+private ScheduleRequestEntity schedule;
 
 }