diff --git a/src/main/java/de/ozgcloud/nachrichten/postfach/muk/transfer/ElsterTransferRemoteService.java b/src/main/java/de/ozgcloud/nachrichten/postfach/muk/transfer/ElsterTransferRemoteService.java index 701a666aec82e76bc8b46e38c516fc9dedcf9c31..a832c9561d3e9e3c65140300571ea9e804051c95 100644 --- a/src/main/java/de/ozgcloud/nachrichten/postfach/muk/transfer/ElsterTransferRemoteService.java +++ b/src/main/java/de/ozgcloud/nachrichten/postfach/muk/transfer/ElsterTransferRemoteService.java @@ -148,7 +148,7 @@ public class ElsterTransferRemoteService { BereitstellungAntwort createAntwort(PostfachNachricht nachricht) { var antwort = new BereitstellungAntwort(); - antwort.setZuordnungskriterium(ObjectIdToUUIDConverter.toUUID(nachricht.getVorgangId())); + antwort.setZuordnungskriterium(ObjectIdToUUIDConverter.toUUID(nachricht.getId())); antwort.setAntwortBetreffe(Set.of(postfachProperties.getReplySubjectPrefix() + nachricht.getSubject())); antwort.setAntwortFrist(LocalDate.now().plusDays(postfachProperties.getReplyInDays())); return antwort; @@ -176,13 +176,13 @@ public class ElsterTransferRemoteService { .mailBody(postfachProperties.getBody()); if (Objects.nonNull(antwortDetails.getZuordnungskriterium())) { - var vorgangId = ObjectIdToUUIDConverter.toObjectId(antwortDetails.getZuordnungskriterium()); - nachrichtBuilder.vorgangId(vorgangId.toHexString()); + var nachrichtId = ObjectIdToUUIDConverter.toObjectId(antwortDetails.getZuordnungskriterium()); + nachrichtBuilder.referencedNachricht(nachrichtId.toHexString()); if (Objects.nonNull(antwortDetails.getAnhaenge())) { nachrichtBuilder.attachments(antwortDetails.getAnhaenge().stream() .filter(Objects::nonNull) - .map(downloadAnhangDetails -> this.downloadAnhang(downloadAnhangDetails, vorgangId.toHexString())) + .map(downloadAnhangDetails -> this.downloadAnhang(downloadAnhangDetails, nachrichtId.toHexString())) .filter(Optional::isPresent) .map(Optional::get) .toList()); @@ -192,7 +192,7 @@ public class ElsterTransferRemoteService { return nachrichtBuilder.build(); } - Optional<String> downloadAnhang(DownloadAnhangDetails downloadAnhangDetails, String vorgangId) { + Optional<String> downloadAnhang(DownloadAnhangDetails downloadAnhangDetails, String nachrichtId) { Optional<String> fileIdOptional = Optional.empty(); var url = postfachProperties.getServer() + downloadAnhangDetails.getDownloadUrl(); @@ -200,7 +200,7 @@ public class ElsterTransferRemoteService { if (Objects.nonNull(data)) { try (var dataIn = new ByteArrayInputStream(data)) { - fileIdOptional = storeToOzgCloud(downloadAnhangDetails, vorgangId, dataIn); + fileIdOptional = storeToOzgCloud(downloadAnhangDetails, nachrichtId, dataIn); } catch (IOException e) { LOG.error("Error transferring attachment body from Elster-Transfer to OZG-Cloud.", e); throw new TechnicalException("Error downloading anhang", e); @@ -227,12 +227,12 @@ public class ElsterTransferRemoteService { return Optional.empty(); } - static OzgCloudUploadFile createOzgCloudUploadFile(final DownloadAnhangDetails downloadAnhangDetails, final String vorgangId) { + static OzgCloudUploadFile createOzgCloudUploadFile(final DownloadAnhangDetails downloadAnhangDetails, final String nachrichtId) { return OzgCloudUploadFile.builder() .fileName(downloadAnhangDetails.getDatei()) .fieldName(POSTFACH) .contentType(downloadAnhangDetails.getMimeType()) - .vorgangId(vorgangId).build(); + .nachrichtReferenz(nachrichtId).build(); } } diff --git a/src/test/java/de/ozgcloud/nachrichten/postfach/muk/PostfachNachrichtTestFactory.java b/src/test/java/de/ozgcloud/nachrichten/postfach/muk/PostfachNachrichtTestFactory.java index c1886ef8b3658d31b5fc61e968354cab3f40c994..a4e0f80645fab2e272c82ec7fa5cec9a9a9e050d 100644 --- a/src/test/java/de/ozgcloud/nachrichten/postfach/muk/PostfachNachrichtTestFactory.java +++ b/src/test/java/de/ozgcloud/nachrichten/postfach/muk/PostfachNachrichtTestFactory.java @@ -37,7 +37,7 @@ import de.ozgcloud.nachrichten.postfach.PostfachNachricht.Direction; public class PostfachNachrichtTestFactory { - public static final String ID = UUID.randomUUID().toString(); + public static final String ID = ObjectId.get().toHexString(); public static final String CREATED_AT_STR = "2020-04-01T10:30:10Z"; public static final ZonedDateTime CREATED_AT = ZonedDateTime.parse(CREATED_AT_STR); public static final String CREATED_BY = UUID.randomUUID().toString();