[MODORDSTOR-356] - Initial setup of claiming batch job (#791)

folio-org · Nov 13, 2023 · 99d87b7 · 99d87b7
1 parent aa294fe
commit 99d87b7
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 4 deletions.
diff --git a/src/main/java/org/folio/service/pieces/flows/update/PieceUpdateFlowManager.java b/src/main/java/org/folio/service/pieces/flows/update/PieceUpdateFlowManager.java
@@ -17,6 +17,8 @@
 import io.vertx.core.Promise;
 import io.vertx.core.json.JsonObject;
 
+import java.util.Date;
+
 public class PieceUpdateFlowManager {
   private static final Logger logger = LogManager.getLogger(PieceUpdateFlowManager.class);
 
@@ -68,6 +70,7 @@ public Future<Void> updatePiece(Piece pieceToUpdate, boolean createItem, boolean
         logger.debug("receivingStatusStorage -- {}", receivingStatusStorage);
         logger.debug("receivingStatusUpdate -- {}", receivingStatusUpdate);
         if (receivingStatusStorage.compareTo(receivingStatusUpdate) != 0) {
+          holder.getPieceToUpdate().setStatusUpdatedDate(new Date());
           pieceService.receiptConsistencyPiecePoLine(messageToEventBus, requestContext);
         }
         return null;

diff --git a/src/test/java/org/folio/rest/impl/PieceApiTest.java b/src/test/java/org/folio/rest/impl/PieceApiTest.java
@@ -152,7 +152,10 @@ void testPutPiecesByIdTest() throws Exception {
     pieceRequest.put("receivingStatus", "Received");
 
     addMockEntry(PIECES_STORAGE, pieceStorage);
-    verifyPut(String.format(PIECES_ID_PATH, pieceId), pieceRequest, "", 204);
+    verifyPut(String.format(PIECES_ID_PATH, pieceId), pieceRequest, "", 204)
+      .then()
+      .assertThat()
+      .body("statusUpdatedDate", notNullValue());;
 
     // Message sent to event bus
     HandlersTestHelper.verifyReceiptStatusUpdateEvent(1);

diff --git a/src/test/java/org/folio/service/pieces/flows/update/PieceUpdateFlowManagerTest.java b/src/test/java/org/folio/service/pieces/flows/update/PieceUpdateFlowManagerTest.java
@@ -13,8 +13,7 @@
 import static org.folio.service.inventory.InventoryManager.HOLDING_PERMANENT_LOCATION_ID;
 import static org.folio.service.inventory.InventoryManager.ITEM_STATUS;
 import static org.folio.service.inventory.InventoryManager.ITEM_STATUS_NAME;
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertNull;
+import static org.junit.jupiter.api.Assertions.*;
 import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.ArgumentMatchers.eq;
 import static org.mockito.Mockito.doAnswer;
@@ -235,7 +234,7 @@ void shouldUpdateLineQuantityIfPoLineIsNotPackageAndHoldingReferenceChangedAndSh
     Piece pieceFromStorage = new Piece().withId(pieceId).withPoLineId(lineId).withItemId(itemId).withTitleId(titleId)
       .withHoldingId(oldHoldingId).withFormat(Piece.Format.ELECTRONIC);
     Piece incomingPieceToUpdate = new Piece().withId(pieceId).withPoLineId(lineId).withItemId(itemId).withTitleId(titleId)
-      .withHoldingId(holdingIdToUpdate).withFormat(Piece.Format.ELECTRONIC);
+      .withHoldingId(holdingIdToUpdate).withFormat(Piece.Format.ELECTRONIC).withReceivingStatus(Piece.ReceivingStatus.RECEIVED);
     Cost cost = new Cost().withQuantityElectronic(1);
     Location loc = new Location().withHoldingId(oldHoldingId).withQuantityElectronic(1).withQuantity(1);
     PoLine poLine = new PoLine().withIsPackage(false).withPurchaseOrderId(orderId).withId(lineId)
@@ -265,6 +264,7 @@ void shouldUpdateLineQuantityIfPoLineIsNotPackageAndHoldingReferenceChangedAndSh
     Piece pieceToUpdate = pieceToUpdateCapture.getValue();
     PieceUpdateHolder pieceUpdateHolder = pieceUpdateHolderCapture.getValue();
 
+    assertNotNull(pieceToUpdate.getStatusUpdatedDate());
     verify(basePieceFlowHolderBuilder).updateHolderWithOrderInformation(pieceUpdateHolderCapture.capture(), eq(requestContext));
     verify(pieceUpdateFlowPoLineService).updatePoLine(pieceUpdateHolderCapture.capture(), eq(requestContext));
     verify(pieceUpdateFlowInventoryManager).processInventory(any(PieceUpdateHolder.class), eq(requestContext));