BFD-4278: V3 server - Log pulled bene_sks (#2802)

Author: MahiFentaye

apps/bfd-server-ng/src/main/java/gov/cms/bfd/server/ng/beneficiary/BeneficiaryRepository.java

@@ -1,9 +1,10 @@
 package gov.cms.bfd.server.ng.beneficiary;
 
-import gov.cms.bfd.server.ng.DateUtil;
 import gov.cms.bfd.server.ng.beneficiary.model.Beneficiary;
 import gov.cms.bfd.server.ng.beneficiary.model.BeneficiaryIdentity;
 import gov.cms.bfd.server.ng.input.DateTimeRange;
+import gov.cms.bfd.server.ng.util.DateUtil;
+import gov.cms.bfd.server.ng.util.LogUtil;
 import jakarta.persistence.EntityManager;
 import java.time.ZonedDateTime;
 import java.util.List;
@@ -46,26 +47,30 @@ public List<BeneficiaryIdentity> getValidBeneficiaryIdentities(long beneXrefSk)
    * @return beneficiary record
    */
   public Optional<Beneficiary> findById(long beneSk, DateTimeRange lastUpdatedRange) {
-    return entityManager
-        .createQuery(
-            String.format(
-                """
+    var optionalBeneficiary =
+        entityManager
+            .createQuery(
+                String.format(
+                    """
               SELECT bene
               FROM Beneficiary bene
               WHERE bene.beneSk = :beneSk
                 AND ((cast(:lowerBound AS ZonedDateTime)) IS NULL OR bene.meta.updatedTimestamp %s :lowerBound)
                 AND ((cast(:upperBound AS ZonedDateTime)) IS NULL OR bene.meta.updatedTimestamp %s :upperBound)
               ORDER BY bene.obsoleteTimestamp DESC
               """,
-                lastUpdatedRange.getLowerBoundSqlOperator(),
-                lastUpdatedRange.getUpperBoundSqlOperator()),
-            Beneficiary.class)
-        .setParameter("beneSk", beneSk)
-        .setParameter("lowerBound", lastUpdatedRange.getLowerBoundDateTime().orElse(null))
-        .setParameter("upperBound", lastUpdatedRange.getUpperBoundDateTime().orElse(null))
-        .getResultList()
-        .stream()
-        .findFirst();
+                    lastUpdatedRange.getLowerBoundSqlOperator(),
+                    lastUpdatedRange.getUpperBoundSqlOperator()),
+                Beneficiary.class)
+            .setParameter("beneSk", beneSk)
+            .setParameter("lowerBound", lastUpdatedRange.getLowerBoundDateTime().orElse(null))
+            .setParameter("upperBound", lastUpdatedRange.getUpperBoundDateTime().orElse(null))
+            .getResultList()
+            .stream()
+            .findFirst();
+
+    optionalBeneficiary.ifPresent(beneficiary -> LogUtil.logBeneSk(beneficiary.getBeneSk()));
+    return optionalBeneficiary;
   }
 
   /**

apps/bfd-server-ng/src/main/java/gov/cms/bfd/server/ng/beneficiary/model/Beneficiary.java

@@ -1,6 +1,6 @@
 package gov.cms.bfd.server.ng.beneficiary.model;
 
-import gov.cms.bfd.server.ng.DateUtil;
+import gov.cms.bfd.server.ng.util.DateUtil;
 import jakarta.persistence.Entity;
 import jakarta.persistence.Table;
 import java.util.List;

apps/bfd-server-ng/src/main/java/gov/cms/bfd/server/ng/beneficiary/model/BeneficiaryIdentity.java

@@ -1,7 +1,7 @@
 package gov.cms.bfd.server.ng.beneficiary.model;
 
-import gov.cms.bfd.server.ng.DateUtil;
-import gov.cms.bfd.server.ng.SystemUrls;
+import gov.cms.bfd.server.ng.util.DateUtil;
+import gov.cms.bfd.server.ng.util.SystemUrls;
 import jakarta.persistence.Column;
 import jakarta.persistence.Entity;
 import jakarta.persistence.Id;

apps/bfd-server-ng/src/main/java/gov/cms/bfd/server/ng/beneficiary/model/CurrentIdentifier.java

@@ -1,6 +1,6 @@
 package gov.cms.bfd.server.ng.beneficiary.model;
 
-import gov.cms.bfd.server.ng.SystemUrls;
+import gov.cms.bfd.server.ng.util.SystemUrls;
 import jakarta.persistence.Column;
 import jakarta.persistence.Embeddable;
 import java.util.Optional;

apps/bfd-server-ng/src/main/java/gov/cms/bfd/server/ng/beneficiary/model/DeathDate.java

@@ -1,8 +1,8 @@
 package gov.cms.bfd.server.ng.beneficiary.model;
 
 import ca.uhn.fhir.model.api.TemporalPrecisionEnum;
-import gov.cms.bfd.server.ng.DateUtil;
 import gov.cms.bfd.server.ng.converter.DefaultFalseBooleanConverter;
+import gov.cms.bfd.server.ng.util.DateUtil;
 import jakarta.persistence.Column;
 import jakarta.persistence.Convert;
 import jakarta.persistence.Embeddable;

apps/bfd-server-ng/src/main/java/gov/cms/bfd/server/ng/beneficiary/model/LanguageCode.java

@@ -1,6 +1,6 @@
 package gov.cms.bfd.server.ng.beneficiary.model;
 
-import gov.cms.bfd.server.ng.SystemUrls;
+import gov.cms.bfd.server.ng.util.SystemUrls;
 import java.util.Arrays;
 import lombok.AllArgsConstructor;
 import lombok.Getter;

apps/bfd-server-ng/src/main/java/gov/cms/bfd/server/ng/beneficiary/model/Meta.java

@@ -1,7 +1,7 @@
 package gov.cms.bfd.server.ng.beneficiary.model;
 
-import gov.cms.bfd.server.ng.DateUtil;
-import gov.cms.bfd.server.ng.SystemUrls;
+import gov.cms.bfd.server.ng.util.DateUtil;
+import gov.cms.bfd.server.ng.util.SystemUrls;
 import jakarta.persistence.Column;
 import jakarta.persistence.Embeddable;
 import java.time.ZonedDateTime;

apps/bfd-server-ng/src/main/java/gov/cms/bfd/server/ng/beneficiary/model/OrganizationFactory.java

@@ -1,6 +1,6 @@
 package gov.cms.bfd.server.ng.beneficiary.model;
 
-import gov.cms.bfd.server.ng.SystemUrls;
+import gov.cms.bfd.server.ng.util.SystemUrls;
 import org.hl7.fhir.r4.model.CodeableConcept;
 import org.hl7.fhir.r4.model.Coding;
 import org.hl7.fhir.r4.model.ContactPoint;

apps/bfd-server-ng/src/main/java/gov/cms/bfd/server/ng/beneficiary/model/RaceCode.java

@@ -1,6 +1,6 @@
 package gov.cms.bfd.server.ng.beneficiary.model;
 
-import gov.cms.bfd.server.ng.SystemUrls;
+import gov.cms.bfd.server.ng.util.SystemUrls;
 import java.util.Arrays;
 import lombok.AllArgsConstructor;
 import lombok.Getter;

apps/bfd-server-ng/src/main/java/gov/cms/bfd/server/ng/beneficiary/model/RelationshipFactory.java

@@ -1,6 +1,6 @@
 package gov.cms.bfd.server.ng.beneficiary.model;
 
-import gov.cms.bfd.server.ng.SystemUrls;
+import gov.cms.bfd.server.ng.util.SystemUrls;
 import org.hl7.fhir.r4.model.CodeableConcept;
 
 /**