hotfix: sending activatedAt on import workflow when persist onboarding (

#199)
pagopa · Mar 5, 2024 · 5cb09d9 · 5cb09d9
1 parent b540338
commit 5cb09d9
Showing 7 changed files with 211 additions and 49 deletions.
diff --git a/apps/onboarding-functions/src/main/java/it/pagopa/selfcare/onboarding/entity/Onboarding.java b/apps/onboarding-functions/src/main/java/it/pagopa/selfcare/onboarding/entity/Onboarding.java
@@ -30,6 +30,7 @@ public class Onboarding  {
     private OnboardingStatus status;
     private String userRequestUid;
     private String workflowInstanceId;
+    private LocalDateTime activatedAt;
 
     public String getId() {
         return id;
@@ -134,4 +135,12 @@ public List<String> getTestEnvProductIds() {
     public void setTestEnvProductIds(List<String> testEnvproductIds) {
         this.testEnvProductIds = testEnvproductIds;
     }
+
+    public LocalDateTime getActivatedAt() {
+        return activatedAt;
+    }
+
+    public void setActivatedAt(LocalDateTime activatedAt) {
+        this.activatedAt = activatedAt;
+    }
 }
diff --git a/...nctions/src/main/java/it/pagopa/selfcare/onboarding/service/CompletionServiceDefault.java b/...nctions/src/main/java/it/pagopa/selfcare/onboarding/service/CompletionServiceDefault.java
@@ -26,6 +26,7 @@
 import org.openapi.quarkus.user_registry_json.model.UserResource;
 
 import java.time.LocalDateTime;
+import java.time.ZoneId;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Objects;
@@ -219,6 +220,8 @@ public void persistOnboarding(Onboarding onboarding) {
         onboardingRequest.pricingPlan(onboarding.getPricingPlan());
         onboardingRequest.productId(onboarding.getProductId());
         onboardingRequest.setTokenId(onboarding.getId());
+        Optional.ofNullable(onboarding.getActivatedAt())
+                .ifPresent(date -> onboardingRequest.setActivatedAt(date.atZone(ZoneId.systemDefault()).toOffsetDateTime()));
 
         if(Objects.nonNull(onboarding.getBilling())) {
             BillingRequest billingRequest = new BillingRequest();