Skip to content

Commit 32329c5

Browse files
committed
refactored and decomposed schedule job
1 parent e0c2391 commit 32329c5

1 file changed

Lines changed: 18 additions & 5 deletions

File tree

src/main/java/edu/tamu/app/job/ProcessSchedules.java renamed to src/main/java/edu/tamu/app/job/UpdateSchedules.java

Lines changed: 18 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -19,9 +19,9 @@
1919
import edu.tamu.framework.model.ApiResponse;
2020

2121
@Service
22-
public class ProcessSchedules {
22+
public class UpdateSchedules {
2323

24-
private Logger logger = LoggerFactory.getLogger(ProcessSchedules.class);
24+
private Logger logger = LoggerFactory.getLogger(UpdateSchedules.class);
2525

2626
@Autowired
2727
private ScheduleRepo scheduleRepo;
@@ -36,7 +36,15 @@ public class ProcessSchedules {
3636
private SimpMessagingTemplate simpMessagingTemplate;
3737

3838
@Scheduled(cron = "5 0/1 * * * ?")
39-
private void checkSchedules() {
39+
private void updateSchedules() {
40+
41+
updateEndingSchedules();
42+
43+
updateStartingSchedules();
44+
45+
}
46+
47+
private synchronized void updateEndingSchedules() {
4048

4149
Date date = new Date();
4250
Long now = date.getTime();
@@ -53,8 +61,13 @@ private void checkSchedules() {
5361
scheduleRepo.delete(schedule);
5462
broadcastUpdate(scheduler);
5563
});
56-
57-
now = date.getTime();
64+
65+
}
66+
67+
private synchronized void updateStartingSchedules() {
68+
69+
Date date = new Date();
70+
Long now = date.getTime();
5871

5972
logger.info("Checking for starting schedules");
6073
scheduleRepo.findByScheduledPostingStartLessThanEqualAndScheduledPostingEndGreaterThanEqualAndSchedulerWithinScheduleFalse(now, now).forEach(schedule -> {

0 commit comments

Comments
 (0)