From 6f9abd16a03d0049134e79d4df828c7864121f8e Mon Sep 17 00:00:00 2001
From: Rohit <rohitparih@gmail.com>
Date: Fri, 30 Aug 2024 00:09:03 +0530
Subject: [PATCH] feature/blog-scheduler

---
 .../implementation/pgsqlimplementation/SchedulerDataDao.java | 3 ++-
 .../dao/repository/postgres/SchedulerDataRepository.java     | 2 +-
 .../blog/scheduler/executor/TwoMinutesScheduler.java         | 5 +++++
 3 files changed, 8 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/bloggios/blog/dao/implementation/pgsqlimplementation/SchedulerDataDao.java b/src/main/java/com/bloggios/blog/dao/implementation/pgsqlimplementation/SchedulerDataDao.java
index c745d7f..f08725e 100644
--- a/src/main/java/com/bloggios/blog/dao/implementation/pgsqlimplementation/SchedulerDataDao.java
+++ b/src/main/java/com/bloggios/blog/dao/implementation/pgsqlimplementation/SchedulerDataDao.java
@@ -25,7 +25,8 @@ protected SchedulerDataDao(SchedulerDataRepository repository) {
     }
 
     public List<SchedulerData> getOverduePendingSchedulingData() {
-        return repository.findAllByIsSchedulingDoneTrueAndScheduleDateLessThanEqual(new Date());
+
+        return repository.findAllByScheduleDateLessThanEqual(new Date());
     }
 
     public void deleteByEntity(SchedulerData schedulerData) {
diff --git a/src/main/java/com/bloggios/blog/dao/repository/postgres/SchedulerDataRepository.java b/src/main/java/com/bloggios/blog/dao/repository/postgres/SchedulerDataRepository.java
index 017f1e2..d952d04 100644
--- a/src/main/java/com/bloggios/blog/dao/repository/postgres/SchedulerDataRepository.java
+++ b/src/main/java/com/bloggios/blog/dao/repository/postgres/SchedulerDataRepository.java
@@ -17,5 +17,5 @@
 
 public interface SchedulerDataRepository extends JpaRepository<SchedulerData, String> {
 
-    List<SchedulerData> findAllByIsSchedulingDoneTrueAndScheduleDateLessThanEqual(Date currentDate);
+    List<SchedulerData> findAllByScheduleDateLessThanEqual(Date currentDate);
 }
diff --git a/src/main/java/com/bloggios/blog/scheduler/executor/TwoMinutesScheduler.java b/src/main/java/com/bloggios/blog/scheduler/executor/TwoMinutesScheduler.java
index 8d44952..b838d74 100644
--- a/src/main/java/com/bloggios/blog/scheduler/executor/TwoMinutesScheduler.java
+++ b/src/main/java/com/bloggios/blog/scheduler/executor/TwoMinutesScheduler.java
@@ -4,8 +4,10 @@
 import com.bloggios.blog.modal.SchedulerData;
 import com.bloggios.blog.scheduler.TimeScheduler;
 import com.bloggios.blog.scheduler.implementation.BlogSchedulerImplementation;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -18,6 +20,7 @@
  */
 
 @Component
+@Slf4j
 public class TwoMinutesScheduler implements TimeScheduler {
 
     private final SchedulerDataDao schedulerDataDao;
@@ -33,7 +36,9 @@ public TwoMinutesScheduler(
 
     @Override
     public void initOperation() {
+        log.error("Scheduler Date : {}", new Date());
         List<SchedulerData> overduePendingSchedulingData = schedulerDataDao.getOverduePendingSchedulingData();
+        log.error("Schedulers List: {}", overduePendingSchedulingData.size());
         if (overduePendingSchedulingData.isEmpty()) return;
         overduePendingSchedulingData
                 .forEach(schedulerData -> {