72 lines
2.2 KiB
Java
Executable File
72 lines
2.2 KiB
Java
Executable File
package com.plannaplan.services;
|
|
|
|
import java.util.HashMap;
|
|
import java.util.Map;
|
|
import java.util.concurrent.ScheduledFuture;
|
|
|
|
import javax.annotation.PostConstruct;
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.scheduling.annotation.Scheduled;
|
|
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
|
|
import org.springframework.scheduling.support.CronTrigger;
|
|
import org.springframework.stereotype.Service;
|
|
|
|
/**
|
|
* Service to manage app events
|
|
*/
|
|
@Service
|
|
public class EventService {
|
|
|
|
@Autowired
|
|
private ExchangeService exchangeService;
|
|
|
|
public static final int FIRST_TOUR_SCHEDULE = 0;
|
|
public static final int SECOND_TOUR_SCHEDULE = 1;
|
|
|
|
private ThreadPoolTaskScheduler scheduler;
|
|
private Map<Integer, ScheduledFuture<?>> jobsMap = new HashMap<>();
|
|
|
|
@Scheduled(cron = "0 24 17 * * *")
|
|
public void collectGroupLosses() {
|
|
System.out.println("Checking for groups");
|
|
}
|
|
|
|
/**
|
|
* perfroms checks for matching exchanges daily
|
|
*/
|
|
@Scheduled(cron = "0 0 0 * * *")
|
|
public void performExchangeService() {
|
|
System.out.println("Performing Exchange");
|
|
this.exchangeService.performExchange();
|
|
}
|
|
|
|
/**
|
|
* Schedule provided task to perform
|
|
*
|
|
* @param taskId static filed of this class that represents to what event
|
|
* we want to assign task
|
|
* @param task runnable class that perform task in implemented run method
|
|
* @param cronTrigger CronTrigger instance with date to perform
|
|
*/
|
|
public void scheduleTask(int taskId, Runnable task, CronTrigger cronTrigger) {
|
|
ScheduledFuture<?> scheduledTask = jobsMap.get(taskId);
|
|
if (scheduledTask != null) {
|
|
scheduledTask.cancel(true);
|
|
jobsMap.put(taskId, null);
|
|
}
|
|
scheduledTask = this.scheduler.schedule(task, cronTrigger);
|
|
jobsMap.put(taskId, scheduledTask);
|
|
}
|
|
|
|
/**
|
|
* init resources needed for dynamicly creating new tasks (needed to set tours
|
|
* end events)
|
|
*/
|
|
@PostConstruct
|
|
public void initialize() {
|
|
this.scheduler = new ThreadPoolTaskScheduler();
|
|
this.scheduler.initialize();
|
|
}
|
|
}
|