Skip to content

Commit

Permalink
fix date -> instant
Browse files Browse the repository at this point in the history
  • Loading branch information
cesarecaccuri committed Sep 15, 2023
1 parent dd2b3ce commit 42c2e98
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 18 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -119,7 +119,7 @@ public void processNodoReEvent (
final ReEvent reEvent = reEvents.get(index);
Map<String, Object> reEventMap = om.convertValue(reEvent, new TypeReference<Map<String, Object>>() {
});
String partitionKey = reEvent.getCreated().toString().substring(0,10);
String partitionKey = reEvent.getCreated().substring(0,10);
reEventMap.put(partitionKeyColumnCreated,partitionKey);
properties[index].forEach((p,v)->{
String s = replaceDashWithUppercase(p);
Expand Down
23 changes: 6 additions & 17 deletions src/main/java/it/gov/pagopa/fdrretodatastore/ReEvent.java
Original file line number Diff line number Diff line change
@@ -1,43 +1,32 @@
package it.gov.pagopa.fdrretodatastore;

import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.*;

import java.time.Instant;
import java.util.List;
import java.util.Map;

@Data
@Getter
@Setter
@NoArgsConstructor
@AllArgsConstructor
@Builder
@JsonIgnoreProperties(ignoreUnknown = true)
public class ReEvent {
private String uniqueId;

private String serviceIdentifier;

private Instant created;
private String created;
private String sessionId;
private String eventType;

private String fdr;

private String pspId;

private String organizationId;

private String fdrAction;

private String httpType;

private String httpMethod;

private String httpUrl;

private String payload;

private BlobHttpBody blobBodyRef;

private Map<String, List<String>> header;
private boolean fdrPhysicalDelete;
private String fdrStatus;
Expand Down

0 comments on commit 42c2e98

Please sign in to comment.