Merge branch 'master' into MODSOURMAN-1246

folio-org · Nov 15, 2024 · 3183d34 · 3183d34
2 parents badec97 + c597b4f
commit 3183d34
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 0 deletions.
diff --git a/NEWS.md b/NEWS.md
@@ -1,3 +1,6 @@
+## 2024-11-15 3.10.0-SNAPSHOT
+* [MODSOURMAN-1249](https://folio-org.atlassian.net/browse/MODSOURMAN-1249) Added DI_MARC_FOR_UPDATE_RECEIVED log message handling
+
 ## 2024-10-29 v3.9.0
 * [MODSOURMAN-1232](https://folio-org.atlassian.net/browse/MODSOURMAN-1232) Add the option to exclude job profile names to GET "/metadata-provider/jobExecutions" endpoint
 * [MODSOURMAN-1195](https://folio-org.atlassian.net/browse/MODSOURMAN-1195) Save job execution progress in batches

diff --git a/...ger-server/src/main/java/org/folio/verticle/consumers/StoredRecordChunksKafkaHandler.java b/...ger-server/src/main/java/org/folio/verticle/consumers/StoredRecordChunksKafkaHandler.java
@@ -145,6 +145,7 @@ public Future<String> handle(KafkaConsumerRecord<String, byte[]> record) {
   }
 
   private void saveCreatedRecordsInfoToDataImportLog(List<Record> storedRecords, String tenantId) {
+    LOGGER.debug("saveCreatedRecordsInfoToDataImportLog :: count: {}", storedRecords.size());
     MappingRuleCacheKey cacheKey = new MappingRuleCacheKey(tenantId, storedRecords.get(0).getRecordType());
 
     mappingRuleCache.get(cacheKey).onComplete(rulesAr -> {

diff --git a/...-record-manager-server/src/main/java/org/folio/verticle/consumers/util/JournalParams.java b/...-record-manager-server/src/main/java/org/folio/verticle/consumers/util/JournalParams.java
@@ -3,6 +3,7 @@
 import static org.folio.rest.jaxrs.model.EntityType.EDIFACT_INVOICE;
 import static org.folio.rest.jaxrs.model.JournalRecord.ActionStatus.ERROR;
 import static org.folio.rest.jaxrs.model.JournalRecord.ActionType.CREATE;
+import static org.folio.rest.jaxrs.model.JournalRecord.ActionType.UPDATE;
 
 import java.util.Arrays;
 import java.util.Map;
@@ -117,6 +118,14 @@ public Optional<JournalParams> getJournalParams(DataImportEventPayload eventPayl
           JournalRecord.ActionStatus.COMPLETED));
       }
     },
+    DI_MARC_FOR_UPDATE_RECEIVED {
+      @Override
+      public Optional<JournalParams> getJournalParams(DataImportEventPayload eventPayload) {
+        return Optional.of(new JournalParams(UPDATE,
+          JournalRecord.EntityType.MARC_BIBLIOGRAPHIC,
+          JournalRecord.ActionStatus.COMPLETED));
+      }
+    },
     DI_INVENTORY_INSTANCE_CREATED {
       @Override
       public Optional<JournalParams> getJournalParams(DataImportEventPayload eventPayload) {