diff --git a/src/main/java/mops/gruppen2/controller/SwaggerAPIControllerExample.java b/src/main/java/mops/gruppen2/controller/SwaggerAPIControllerExample.java index 3b5c06e..5953926 100644 --- a/src/main/java/mops/gruppen2/controller/SwaggerAPIControllerExample.java +++ b/src/main/java/mops/gruppen2/controller/SwaggerAPIControllerExample.java @@ -55,14 +55,16 @@ public class SwaggerAPIControllerExample { @GetMapping("/json") public void json() { + AddUserEvent aEvent = new AddUserEvent( + 1, + 1, + "Eins", + faker.leagueOfLegends().location(), + faker.name().lastName(), + "123@email.de"); try { - serializationService.serializeEvent(new AddUserEvent( - 1, - 1, - "Eins", - faker.leagueOfLegends().location(), - faker.name().lastName(), - "123@email.de")); + serializationService.serializeEvent(aEvent); + serializationService.saveEvent(aEvent); } catch (JsonProcessingException e) { e.printStackTrace(); } diff --git a/src/main/java/mops/gruppen2/domain/EventDTO.java b/src/main/java/mops/gruppen2/domain/EventDTO.java index 13bee88..c7ceda5 100644 --- a/src/main/java/mops/gruppen2/domain/EventDTO.java +++ b/src/main/java/mops/gruppen2/domain/EventDTO.java @@ -1,11 +1,14 @@ package mops.gruppen2.domain; +import lombok.Data; import lombok.Value; +import org.springframework.data.annotation.Id; import org.springframework.data.relational.core.mapping.Table; -@Value @Table("event") +@Data public class EventDTO { + @Id long event_id; long group_id; String user_id; diff --git a/src/main/java/mops/gruppen2/repository/EventRepository.java b/src/main/java/mops/gruppen2/repository/EventRepository.java index 0e04761..4352a97 100644 --- a/src/main/java/mops/gruppen2/repository/EventRepository.java +++ b/src/main/java/mops/gruppen2/repository/EventRepository.java @@ -1,7 +1,8 @@ package mops.gruppen2.repository; +import mops.gruppen2.domain.EventDTO; import mops.gruppen2.domain.event.Event; import org.springframework.data.repository.CrudRepository; -public interface EventRepository extends CrudRepository { +public interface EventRepository extends CrudRepository { } diff --git a/src/main/java/mops/gruppen2/service/SerializationService.java b/src/main/java/mops/gruppen2/service/SerializationService.java index 57e9f3f..c20af44 100644 --- a/src/main/java/mops/gruppen2/service/SerializationService.java +++ b/src/main/java/mops/gruppen2/service/SerializationService.java @@ -2,6 +2,7 @@ package mops.gruppen2.service; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; +import mops.gruppen2.domain.EventDTO; import mops.gruppen2.domain.event.Event; import mops.gruppen2.repository.EventRepository; import org.slf4j.Logger; @@ -27,4 +28,17 @@ public class SerializationService { log.info(json); return json; } + + public void saveEvent(Event event){ + try { + EventDTO eventDTO = new EventDTO(); + eventDTO.setGroup_id(event.getGroup_id()); + eventDTO.setUser_id(event.getUser_id()); + eventDTO.setEvent_payload(serializeEvent(event)); + eventStore.save(eventDTO); + } catch (JsonProcessingException e) { + e.printStackTrace(); + } + + } }