Merge branch 'master' into change-to-polymorphie
This commit is contained in:
@ -2,8 +2,6 @@ package mops.gruppen2.service;
|
||||
|
||||
import com.fasterxml.jackson.core.JsonProcessingException;
|
||||
import mops.gruppen2.domain.EventDTO;
|
||||
import mops.gruppen2.domain.Exceptions.EventException;
|
||||
import mops.gruppen2.domain.Group;
|
||||
import mops.gruppen2.domain.Visibility;
|
||||
import mops.gruppen2.domain.event.CreateGroupEvent;
|
||||
import mops.gruppen2.domain.event.Event;
|
||||
@ -23,17 +21,19 @@ public class EventService {
|
||||
this.eventStore = eventStore;
|
||||
}
|
||||
|
||||
/** sichert ein Event Objekt indem es ein EventDTO Objekt erzeugt
|
||||
/**
|
||||
* sichert ein Event Objekt indem es ein EventDTO Objekt erzeugt
|
||||
*
|
||||
* @param event
|
||||
*/
|
||||
public void saveEvent(Event event){
|
||||
public void saveEvent(Event event) {
|
||||
EventDTO eventDTO = getDTO(event);
|
||||
eventStore.save(eventDTO);
|
||||
}
|
||||
|
||||
/** Erzeugt aus einem Event Objekt ein EventDTO Objekt.
|
||||
* Ist die Gruppe öffentlich, dann wird die visibility auf true gesetzt.
|
||||
/**
|
||||
* Erzeugt aus einem Event Objekt ein EventDTO Objekt.
|
||||
* Ist die Gruppe öffentlich, dann wird die visibility auf true gesetzt.
|
||||
*
|
||||
* @param event
|
||||
* @return EventDTO
|
||||
@ -42,24 +42,24 @@ public class EventService {
|
||||
EventDTO eventDTO = new EventDTO();
|
||||
eventDTO.setGroup_id(event.getGroup_id());
|
||||
eventDTO.setUser_id(event.getUser_id());
|
||||
if(event instanceof CreateGroupEvent) {
|
||||
if(((CreateGroupEvent) event).getGroupVisibility() == Visibility.PRIVATE) {
|
||||
if (event instanceof CreateGroupEvent) {
|
||||
if (((CreateGroupEvent) event).getGroupVisibility() == Visibility.PRIVATE) {
|
||||
eventDTO.setVisibility(false);
|
||||
}else {
|
||||
} else {
|
||||
eventDTO.setVisibility(true);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
try {
|
||||
eventDTO.setEvent_payload(serializationService.serializeEvent(event));
|
||||
} catch (JsonProcessingException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
return eventDTO;
|
||||
return eventDTO;
|
||||
}
|
||||
|
||||
/** Sorgt dafür die Group_id immer um 1 zu erhöhen
|
||||
/**
|
||||
* Sorgt dafür die Group_id immer um 1 zu erhöhen
|
||||
*
|
||||
* @return Gibt Long zurück
|
||||
*/
|
||||
@ -77,30 +77,32 @@ public class EventService {
|
||||
return tmpId;
|
||||
}
|
||||
|
||||
/** Findet alle Events welche ab dem neuen Status hinzugekommen sind
|
||||
/**
|
||||
* Findet alle Events welche ab dem neuen Status hinzugekommen sind
|
||||
*
|
||||
* @param status
|
||||
* @return Liste von Events
|
||||
*/
|
||||
public List<Event> getNewEvents(Long status){
|
||||
public List<Event> getNewEvents(Long status) {
|
||||
List<Long> groupIdsThatChanged = eventStore.findNewEventSinceStatus(status);
|
||||
|
||||
List<EventDTO> groupEventDTOS = eventStore.findAllEventsOfGroups(groupIdsThatChanged);
|
||||
return translateEventDTOs(groupEventDTOS);
|
||||
}
|
||||
|
||||
/** Erzeugt aus einer Liste von eventDTOs eine Liste von Events
|
||||
/**
|
||||
* Erzeugt aus einer Liste von eventDTOs eine Liste von Events
|
||||
*
|
||||
* @param eventDTOS
|
||||
* @return Liste von Events
|
||||
*/
|
||||
public List<Event> translateEventDTOs(Iterable<EventDTO> eventDTOS){
|
||||
public List<Event> translateEventDTOs(Iterable<EventDTO> eventDTOS) {
|
||||
List<Event> events = new ArrayList<>();
|
||||
|
||||
for (EventDTO eventDTO : eventDTOS) {
|
||||
try {
|
||||
events.add(serializationService.deserializeEvent(eventDTO.getEvent_payload()));
|
||||
}catch (JsonProcessingException e) {
|
||||
} catch (JsonProcessingException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
@ -113,12 +115,12 @@ public class EventService {
|
||||
* @param createGroupEvents Liste von Event Objekten
|
||||
*/
|
||||
public void saveEventList(List<Event> createGroupEvents) {
|
||||
for(Event event : createGroupEvents) {
|
||||
for (Event event : createGroupEvents) {
|
||||
saveEvent(event);
|
||||
}
|
||||
}
|
||||
|
||||
public Long getMaxEvent_id(){
|
||||
public Long getMaxEvent_id() {
|
||||
return eventStore.getHighesEvent_ID();
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user