mirror of
https://github.com/fabioformosa/quartz-manager.git
synced 2025-12-15 23:23:31 +09:00
feat: configure Trigger JobData
- add `jobDataMap` property to SimpleTriggerInputDTO - update SimpleTriggerCommandDTOToSimpleTrigger converter - update SimpleTriggerToSimpleTriggerDTO converter - update unit tests - add .idea and .iml to .gitignore for ignoring intellij files
This commit is contained in:
committed by
Fabio Formosa
parent
13c438d097
commit
e6f6fb5f06
2
.gitignore
vendored
2
.gitignore
vendored
@@ -1 +1,3 @@
|
|||||||
/.project
|
/.project
|
||||||
|
.idea
|
||||||
|
*.iml
|
||||||
|
|||||||
1
quartz-manager-parent/.gitignore
vendored
1
quartz-manager-parent/.gitignore
vendored
@@ -4,3 +4,4 @@
|
|||||||
.classpath
|
.classpath
|
||||||
.project
|
.project
|
||||||
.idea
|
.idea
|
||||||
|
*.iml
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ package it.fabioformosa.quartzmanager.api.converters;
|
|||||||
|
|
||||||
|
|
||||||
import it.fabioformosa.quartzmanager.api.dto.SimpleTriggerCommandDTO;
|
import it.fabioformosa.quartzmanager.api.dto.SimpleTriggerCommandDTO;
|
||||||
|
import org.quartz.JobDataMap;
|
||||||
import org.quartz.SimpleScheduleBuilder;
|
import org.quartz.SimpleScheduleBuilder;
|
||||||
import org.quartz.SimpleTrigger;
|
import org.quartz.SimpleTrigger;
|
||||||
import org.quartz.Trigger;
|
import org.quartz.Trigger;
|
||||||
@@ -19,6 +20,8 @@ public class SimpleTriggerCommandDTOToSimpleTrigger implements Converter<SimpleT
|
|||||||
if (triggerCommandDTO.getSimpleTriggerInputDTO().getEndDate() != null)
|
if (triggerCommandDTO.getSimpleTriggerInputDTO().getEndDate() != null)
|
||||||
triggerTriggerBuilder.endAt(triggerCommandDTO.getSimpleTriggerInputDTO().getEndDate());
|
triggerTriggerBuilder.endAt(triggerCommandDTO.getSimpleTriggerInputDTO().getEndDate());
|
||||||
|
|
||||||
|
if (triggerCommandDTO.getSimpleTriggerInputDTO().getJobDataMap() != null)
|
||||||
|
triggerTriggerBuilder.usingJobData(new JobDataMap(triggerCommandDTO.getSimpleTriggerInputDTO().getJobDataMap()));
|
||||||
|
|
||||||
SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule();
|
SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule();
|
||||||
if (triggerCommandDTO.getSimpleTriggerInputDTO().getRepeatInterval() != null)
|
if (triggerCommandDTO.getSimpleTriggerInputDTO().getRepeatInterval() != null)
|
||||||
|
|||||||
@@ -14,6 +14,7 @@ public class SimpleTriggerToSimpleTriggerDTO extends TriggerToTriggerDTO<SimpleT
|
|||||||
target.setRepeatCount(source.getRepeatCount());
|
target.setRepeatCount(source.getRepeatCount());
|
||||||
target.setRepeatInterval(source.getRepeatInterval());
|
target.setRepeatInterval(source.getRepeatInterval());
|
||||||
target.setMisfireInstruction(source.getMisfireInstruction());
|
target.setMisfireInstruction(source.getMisfireInstruction());
|
||||||
|
target.setJobDataMap(source.getJobDataMap());
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|||||||
@@ -3,8 +3,9 @@ package it.fabioformosa.quartzmanager.api.dto;
|
|||||||
import it.fabioformosa.quartzmanager.api.validators.ValidTriggerRepetition;
|
import it.fabioformosa.quartzmanager.api.validators.ValidTriggerRepetition;
|
||||||
import lombok.*;
|
import lombok.*;
|
||||||
import lombok.experimental.SuperBuilder;
|
import lombok.experimental.SuperBuilder;
|
||||||
|
import javax.annotation.Nullable;
|
||||||
import javax.validation.constraints.Positive;
|
import javax.validation.constraints.Positive;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
@ValidTriggerRepetition
|
@ValidTriggerRepetition
|
||||||
@SuperBuilder
|
@SuperBuilder
|
||||||
@@ -18,4 +19,7 @@ public class SimpleTriggerInputDTO extends TriggerCommandDTO implements TriggerR
|
|||||||
|
|
||||||
@Positive
|
@Positive
|
||||||
private Long repeatInterval;
|
private Long repeatInterval;
|
||||||
|
|
||||||
|
@Nullable
|
||||||
|
private Map<String, ?> jobDataMap;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -4,6 +4,7 @@ import lombok.AllArgsConstructor;
|
|||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.NoArgsConstructor;
|
import lombok.NoArgsConstructor;
|
||||||
import lombok.experimental.SuperBuilder;
|
import lombok.experimental.SuperBuilder;
|
||||||
|
import org.quartz.JobDataMap;
|
||||||
|
|
||||||
import java.util.Date;
|
import java.util.Date;
|
||||||
|
|
||||||
@@ -23,4 +24,5 @@ public class TriggerDTO {
|
|||||||
private JobKeyDTO jobKeyDTO;
|
private JobKeyDTO jobKeyDTO;
|
||||||
private JobDetailDTO jobDetailDTO;
|
private JobDetailDTO jobDetailDTO;
|
||||||
private boolean mayFireAgain;
|
private boolean mayFireAgain;
|
||||||
|
private JobDataMap jobDataMap;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -21,7 +21,8 @@ import org.springframework.test.web.servlet.MockMvc;
|
|||||||
import org.springframework.test.web.servlet.result.MockMvcResultMatchers;
|
import org.springframework.test.web.servlet.result.MockMvcResultMatchers;
|
||||||
|
|
||||||
import java.util.Date;
|
import java.util.Date;
|
||||||
|
import java.util.Map;
|
||||||
|
import static java.util.Map.entry;
|
||||||
import static org.mockito.ArgumentMatchers.any;
|
import static org.mockito.ArgumentMatchers.any;
|
||||||
import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.*;
|
import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.*;
|
||||||
|
|
||||||
@@ -68,6 +69,10 @@ class SimpleTriggerControllerTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private SimpleTriggerInputDTO buildACompleteSimpleTriggerCommandDTO() {
|
private SimpleTriggerInputDTO buildACompleteSimpleTriggerCommandDTO() {
|
||||||
|
Map<String, ?> triggerJobDataMap = Map.ofEntries(
|
||||||
|
entry("customTriggerData1", "value1"),
|
||||||
|
entry("customTriggerData2", "value2")
|
||||||
|
);
|
||||||
return SimpleTriggerInputDTO.builder()
|
return SimpleTriggerInputDTO.builder()
|
||||||
.jobClass("it.fabioformosa.quartzmanager.api.jobs.SampleJob")
|
.jobClass("it.fabioformosa.quartzmanager.api.jobs.SampleJob")
|
||||||
.startDate(new Date())
|
.startDate(new Date())
|
||||||
@@ -75,6 +80,7 @@ class SimpleTriggerControllerTest {
|
|||||||
.misfireInstruction(MisfireInstruction.MISFIRE_INSTRUCTION_FIRE_NOW)
|
.misfireInstruction(MisfireInstruction.MISFIRE_INSTRUCTION_FIRE_NOW)
|
||||||
.repeatCount(5)
|
.repeatCount(5)
|
||||||
.repeatInterval(1000L * 60 * 60)
|
.repeatInterval(1000L * 60 * 60)
|
||||||
|
.jobDataMap(triggerJobDataMap)
|
||||||
.build();
|
.build();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -2,8 +2,19 @@ package it.fabioformosa.quartzmanager.api.controllers.utils;
|
|||||||
|
|
||||||
import it.fabioformosa.quartzmanager.api.common.utils.DateUtils;
|
import it.fabioformosa.quartzmanager.api.common.utils.DateUtils;
|
||||||
import it.fabioformosa.quartzmanager.api.dto.*;
|
import it.fabioformosa.quartzmanager.api.dto.*;
|
||||||
|
import org.quartz.JobDataMap;
|
||||||
|
import org.quartz.SimpleScheduleBuilder;
|
||||||
|
import org.quartz.SimpleTrigger;
|
||||||
|
import org.quartz.Trigger;
|
||||||
|
import org.quartz.TriggerBuilder;
|
||||||
|
|
||||||
|
import java.text.ParseException;
|
||||||
|
import java.text.SimpleDateFormat;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
|
import java.util.Date;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
|
import static java.util.Map.entry;
|
||||||
|
|
||||||
public class TriggerUtils {
|
public class TriggerUtils {
|
||||||
|
|
||||||
@@ -48,6 +59,7 @@ public class TriggerUtils {
|
|||||||
.nextFireTime(DateUtils.addHoursToNow(1L))
|
.nextFireTime(DateUtils.addHoursToNow(1L))
|
||||||
.priority(1)
|
.priority(1)
|
||||||
.startTime(DateUtils.fromLocalDateTimeToDate(LocalDateTime.now()))
|
.startTime(DateUtils.fromLocalDateTimeToDate(LocalDateTime.now()))
|
||||||
|
.jobDataMap(new JobDataMap(simpleTriggerInputDTO.getJobDataMap()))
|
||||||
.build();
|
.build();
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -71,6 +83,44 @@ public class TriggerUtils {
|
|||||||
.nextFireTime(DateUtils.addHoursToNow(1L))
|
.nextFireTime(DateUtils.addHoursToNow(1L))
|
||||||
.priority(1)
|
.priority(1)
|
||||||
.startTime(DateUtils.fromLocalDateTimeToDate(LocalDateTime.now()))
|
.startTime(DateUtils.fromLocalDateTimeToDate(LocalDateTime.now()))
|
||||||
|
.jobDataMap(new JobDataMap(Map.ofEntries(entry("customTriggerData1", "value1"))))
|
||||||
|
.build();
|
||||||
|
}
|
||||||
|
|
||||||
|
static public SimpleTrigger buildSimpleTrigger() {
|
||||||
|
TriggerBuilder<Trigger> triggerTriggerBuilder = TriggerBuilder.newTrigger();
|
||||||
|
triggerTriggerBuilder.startAt(new Date());
|
||||||
|
triggerTriggerBuilder.endAt(DateUtils.addHoursToNow(1));
|
||||||
|
triggerTriggerBuilder.usingJobData(new JobDataMap(Map.ofEntries(entry("data", "value"))));
|
||||||
|
|
||||||
|
SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule();
|
||||||
|
scheduleBuilder.withIntervalInMilliseconds(1000);
|
||||||
|
scheduleBuilder.withRepeatCount(1);
|
||||||
|
scheduleBuilder.withMisfireHandlingInstructionFireNow();
|
||||||
|
|
||||||
|
return triggerTriggerBuilder.withSchedule(
|
||||||
|
scheduleBuilder
|
||||||
|
)
|
||||||
|
.withIdentity("simpleTrigger").build();
|
||||||
|
}
|
||||||
|
|
||||||
|
static public SimpleTriggerCommandDTO buildSimpleTriggerCommandDTO(String triggerName) throws ParseException {
|
||||||
|
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
|
||||||
|
Date startDate = dateFormat.parse("2024-02-02");
|
||||||
|
Date endDate = dateFormat.parse("2024-03-02");
|
||||||
|
|
||||||
|
SimpleTriggerInputDTO triggerInputDTO = SimpleTriggerInputDTO.builder()
|
||||||
|
.misfireInstruction(MisfireInstruction.MISFIRE_INSTRUCTION_FIRE_NOW)
|
||||||
|
.jobClass("sample.jobClass")
|
||||||
|
.repeatCount(1)
|
||||||
|
.repeatInterval(1000L)
|
||||||
|
.startDate(startDate)
|
||||||
|
.endDate(endDate)
|
||||||
|
.jobDataMap(Map.ofEntries(entry("data", "value")))
|
||||||
|
.build();
|
||||||
|
return SimpleTriggerCommandDTO.builder()
|
||||||
|
.triggerName(triggerName)
|
||||||
|
.simpleTriggerInputDTO(triggerInputDTO)
|
||||||
.build();
|
.build();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,41 @@
|
|||||||
|
package it.fabioformosa.quartzmanager.api.converters;
|
||||||
|
|
||||||
|
import it.fabioformosa.quartzmanager.api.controllers.utils.TriggerUtils;
|
||||||
|
import it.fabioformosa.quartzmanager.api.dto.SimpleTriggerCommandDTO;
|
||||||
|
import org.assertj.core.api.Assertions;
|
||||||
|
import org.junit.jupiter.api.MethodOrderer;
|
||||||
|
import org.junit.jupiter.api.Order;
|
||||||
|
import org.junit.jupiter.api.Test;
|
||||||
|
import org.junit.jupiter.api.TestMethodOrder;
|
||||||
|
import org.quartz.SimpleTrigger;
|
||||||
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
|
import org.springframework.boot.test.context.SpringBootTest;
|
||||||
|
import org.springframework.core.convert.ConversionService;
|
||||||
|
|
||||||
|
import java.text.ParseException;
|
||||||
|
import java.text.SimpleDateFormat;
|
||||||
|
import java.util.Date;
|
||||||
|
|
||||||
|
@TestMethodOrder(MethodOrderer.OrderAnnotation.class)
|
||||||
|
@SpringBootTest
|
||||||
|
class SimpleTriggerCommandDTOToSimpleTriggerTest {
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private ConversionService conversionService;
|
||||||
|
|
||||||
|
@Order(1)
|
||||||
|
@Test
|
||||||
|
void givenSimpleTriggerCommandDTO_whenItIsConverted_thenASimpleTriggerIsReturned() throws ParseException {
|
||||||
|
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
|
||||||
|
Date startDate = dateFormat.parse("2024-02-02");
|
||||||
|
Date endDate = dateFormat.parse("2024-03-02");
|
||||||
|
SimpleTriggerCommandDTO simpleTriggerCommandDTO = TriggerUtils.buildSimpleTriggerCommandDTO("mytrigger");
|
||||||
|
SimpleTrigger simpleTrigger = conversionService.convert(simpleTriggerCommandDTO, SimpleTrigger.class);
|
||||||
|
Assertions.assertThat(simpleTrigger).isNotNull();
|
||||||
|
Assertions.assertThat(simpleTrigger.getRepeatCount()).isEqualTo(simpleTriggerCommandDTO.getSimpleTriggerInputDTO().getRepeatCount());
|
||||||
|
Assertions.assertThat(simpleTrigger.getRepeatInterval()).isEqualTo(simpleTriggerCommandDTO.getSimpleTriggerInputDTO().getRepeatInterval());
|
||||||
|
Assertions.assertThat(simpleTrigger.getJobDataMap()).containsEntry("data", "value");
|
||||||
|
Assertions.assertThat(simpleTrigger.getStartTime()).isEqualTo(startDate);
|
||||||
|
Assertions.assertThat(simpleTrigger.getEndTime()).isEqualTo(endDate);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,36 @@
|
|||||||
|
package it.fabioformosa.quartzmanager.api.converters;
|
||||||
|
|
||||||
|
import it.fabioformosa.quartzmanager.api.controllers.utils.TriggerUtils;
|
||||||
|
import it.fabioformosa.quartzmanager.api.dto.SimpleTriggerDTO;
|
||||||
|
import org.assertj.core.api.Assertions;
|
||||||
|
import org.junit.jupiter.api.MethodOrderer;
|
||||||
|
import org.junit.jupiter.api.Order;
|
||||||
|
import org.junit.jupiter.api.Test;
|
||||||
|
import org.junit.jupiter.api.TestMethodOrder;
|
||||||
|
import org.quartz.SimpleTrigger;
|
||||||
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
|
import org.springframework.boot.test.context.SpringBootTest;
|
||||||
|
import org.springframework.core.convert.ConversionService;
|
||||||
|
|
||||||
|
|
||||||
|
@TestMethodOrder(MethodOrderer.OrderAnnotation.class)
|
||||||
|
@SpringBootTest
|
||||||
|
class SimpleTriggerToSimpleTriggerDTOTest {
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private ConversionService conversionService;
|
||||||
|
|
||||||
|
@Order(1)
|
||||||
|
@Test
|
||||||
|
void givenSimpleTrigger_whenItIsConverted_thenADtoIsReturned() {
|
||||||
|
SimpleTrigger simpleTrigger = TriggerUtils.buildSimpleTrigger();
|
||||||
|
SimpleTriggerDTO simpleTriggerDTO = conversionService.convert(simpleTrigger, SimpleTriggerDTO.class);
|
||||||
|
Assertions.assertThat(simpleTriggerDTO).isNotNull();
|
||||||
|
Assertions.assertThat(simpleTriggerDTO.getRepeatCount()).isEqualTo(simpleTrigger.getRepeatCount());
|
||||||
|
Assertions.assertThat(simpleTriggerDTO.getRepeatInterval()).isEqualTo(simpleTrigger.getRepeatInterval());
|
||||||
|
Assertions.assertThat(simpleTriggerDTO.getJobDataMap()).containsEntry("data", "value");
|
||||||
|
Assertions.assertThat(simpleTriggerDTO.getStartTime()).isEqualTo(simpleTrigger.getStartTime());
|
||||||
|
Assertions.assertThat(simpleTriggerDTO.getEndTime()).isEqualTo(simpleTrigger.getEndTime());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
Reference in New Issue
Block a user