1

Created first Api implementation

This commit is contained in:
LukasEttel
2020-03-12 14:40:07 +01:00
parent c6c62b07bf
commit a30d458219
3 changed files with 44 additions and 4 deletions

View File

@ -1,14 +1,18 @@
package mops.gruppen2.repository; package mops.gruppen2.repository;
import mops.gruppen2.domain.EventDTO; import mops.gruppen2.domain.EventDTO;
import mops.gruppen2.domain.event.Event;
import org.springframework.data.jdbc.repository.query.Query; import org.springframework.data.jdbc.repository.query.Query;
import org.springframework.data.repository.CrudRepository; import org.springframework.data.repository.CrudRepository;
import org.springframework.data.repository.query.Param; import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
import java.util.List;
@Repository @Repository
public interface EventRepository extends CrudRepository<EventDTO, Long> { public interface EventRepository extends CrudRepository<EventDTO, Long> {
@Query("SELECT * FROM event WHERE event_id > ?#{[0]}") @Query("SELECT * FROM event WHERE event_id > @status")
public Iterable<EventDTO> findNewEventSinceStatus(@Param("status") Long status); public Iterable<EventDTO> findNewEventSinceStatus(@Param("status") Long status);
@Query("SELECT * FROM event WHERE group_id IN @groupIds ")
public Iterable<EventDTO> findAllEventsOfGroups(@Param("groupIds") List<Long> groupIds);
} }

View File

@ -55,9 +55,11 @@ public class EventService {
public List<Event> getNewEvents(Long status){ public List<Event> getNewEvents(Long status){
Iterable<EventDTO> eventDTOS = eventStore.findNewEventSinceStatus(status); Iterable<EventDTO> newEventDTOS = eventStore.findNewEventSinceStatus(status);
List<Long> groupIdsThatChanged = this.getAllGroupIds(newEventDTOS);
return translateEventDTOs(eventDTOS); Iterable<EventDTO> groupEventDTOS = eventStore.findAllEventsOfGroups(groupIdsThatChanged);
return translateEventDTOs(groupEventDTOS);
} }
private List<Event> translateEventDTOs(Iterable<EventDTO> eventDTOS){ private List<Event> translateEventDTOs(Iterable<EventDTO> eventDTOS){
@ -74,4 +76,15 @@ public class EventService {
return events; return events;
} }
private List<Long> getAllGroupIds(Iterable<EventDTO> eventDTOS){
List<Long> idsOfChangedGroups = new ArrayList<>();
for (EventDTO eventDTO : eventDTOS){
if (!idsOfChangedGroups.contains(eventDTO.getGroup_id())) {
idsOfChangedGroups.add(eventDTO.getGroup_id());
}
}
return idsOfChangedGroups;
}
} }

View File

@ -10,6 +10,7 @@ import org.junit.jupiter.api.Test;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import static org.assertj.core.api.Assertions.assertThat;
import static org.junit.jupiter.api.Assertions.*; import static org.junit.jupiter.api.Assertions.*;
import static org.mockito.Mockito.mock; import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when; import static org.mockito.Mockito.when;
@ -37,4 +38,26 @@ class EventServiceTest {
when(eventRepositoryMock.findAll()).thenReturn(eventDTOS); when(eventRepositoryMock.findAll()).thenReturn(eventDTOS);
assertEquals(eventDTO1.getGroup_id()+1, eventService.checkGroup()); assertEquals(eventDTO1.getGroup_id()+1, eventService.checkGroup());
} }
@Test
void checkGetAllGroupIdsWithRepeadedId(){
ArrayList<EventDTO> eventDTOS = new ArrayList<>();
EventDTO eventDTO1 = new EventDTO();
eventDTO1.setGroup_id(1L);
eventDTOS.add(eventDTO1);
EventDTO eventDTO2 = new EventDTO();
eventDTO2.setGroup_id(2L);
eventDTOS.add(eventDTO2);
EventDTO eventDTO3 = new EventDTO();
eventDTO3.setGroup_id(1L);
eventDTOS.add(eventDTO3);
List<Long> groupIds = eventService.getAllGroupIds(eventDTOS);
assertThat(groupIds.size()).isEqualTo(2);
}
} }